X-Git-Url: http://git.linex4red.de/pub/Android/ownCloud.git/blobdiff_plain/87814cec4292fee1303c85dfce68b2d122ffb6b2..5f61cb15552eb2fda01716078a9191b88cebf764:/src/eu/alefzero/owncloud/syncadapter/FileSyncAdapter.java

diff --git a/src/eu/alefzero/owncloud/syncadapter/FileSyncAdapter.java b/src/eu/alefzero/owncloud/syncadapter/FileSyncAdapter.java
index bf480127..85f9cbb3 100644
--- a/src/eu/alefzero/owncloud/syncadapter/FileSyncAdapter.java
+++ b/src/eu/alefzero/owncloud/syncadapter/FileSyncAdapter.java
@@ -19,34 +19,25 @@
 package eu.alefzero.owncloud.syncadapter;
 
 import java.io.IOException;
+import java.net.URLDecoder;
+import java.util.Vector;
 
-import org.apache.http.entity.StringEntity;
 import org.apache.jackrabbit.webdav.DavException;
 import org.apache.jackrabbit.webdav.MultiStatus;
 import org.apache.jackrabbit.webdav.client.methods.PropFindMethod;
-import org.apache.jackrabbit.webdav.property.DavProperty;
-import org.apache.jackrabbit.webdav.property.DavPropertyName;
 
 import android.accounts.Account;
 import android.accounts.AuthenticatorException;
 import android.accounts.OperationCanceledException;
 import android.content.ContentProviderClient;
-import android.content.ContentValues;
 import android.content.Context;
+import android.content.Intent;
 import android.content.SyncResult;
-import android.database.Cursor;
-import android.net.Uri;
 import android.os.Bundle;
-import android.os.RemoteException;
 import android.util.Log;
 import eu.alefzero.owncloud.datamodel.FileDataStorageManager;
 import eu.alefzero.owncloud.datamodel.OCFile;
-import eu.alefzero.owncloud.db.ProviderMeta.ProviderTableMeta;
-import eu.alefzero.webdav.HttpPropFind;
-import eu.alefzero.webdav.TreeNode;
-import eu.alefzero.webdav.TreeNode.NodeProperty;
 import eu.alefzero.webdav.WebdavEntry;
-import eu.alefzero.webdav.WebdavUtils;
 
 /**
  * SyncAdapter implementation for syncing sample SyncAdapter contacts to the
@@ -55,57 +46,107 @@ import eu.alefzero.webdav.WebdavUtils;
  * @author Bartek Przybylski
  */
 public class FileSyncAdapter extends AbstractOwnCloudSyncAdapter {
-	private static final String TAG = "FileSyncAdapter";
 
-	public FileSyncAdapter(Context context, boolean autoInitialize) {
-		super(context, autoInitialize);
-	}
-	
-	@Override
-	public synchronized void onPerformSync(
-			Account account, 
-			Bundle extras, 
-			String authority, 
-			ContentProviderClient provider, 
-			SyncResult syncResult) {
+    private final static String TAG = "FileSyncAdapter"; 
+    
+    private long mCurrentSyncTime;
+    
+    public FileSyncAdapter(Context context, boolean autoInitialize) {
+        super(context, autoInitialize);
+    }
+
+    @Override
+    public synchronized void onPerformSync(Account account, Bundle extras,
+            String authority, ContentProviderClient provider,
+            SyncResult syncResult) {
+
+        this.setAccount(account);
+        this.setContentProvider(provider);
+        this.setStorageManager(new FileDataStorageManager(account,
+                getContentProvider()));
+
+        Log.d(TAG, "syncing owncloud account " + account.name);
+
+        Intent i = new Intent(FileSyncService.SYNC_MESSAGE);
+        i.putExtra(FileSyncService.IN_PROGRESS, true);
+        i.putExtra(FileSyncService.ACCOUNT_NAME, account.name);
+        getContext().sendStickyBroadcast(i);
 
-			this.setAccount(account);
-			this.setContentProvider(provider);
-			this.setStorageManager(new FileDataStorageManager(account, getContentProvider()));
+        PropFindMethod query;
+        try {
+            mCurrentSyncTime = System.currentTimeMillis();
+            query = new PropFindMethod(getUri().toString() + "/");
+            getClient().executeMethod(query);
+            MultiStatus resp = null;
+            resp = query.getResponseBodyAsMultiStatus();
 
-			fetchData(getUri().toString(), syncResult, 0);
-	}
+            if (resp.getResponses().length > 0) {
+                WebdavEntry we = new WebdavEntry(resp.getResponses()[0], getUri().getPath());
+                OCFile file = fillOCFile(we);
+                file.setParentId(0);
+                getStorageManager().saveFile(file);
+                fetchData(getUri().toString(), syncResult, file.getFileId());
+            }
+        } catch (OperationCanceledException e) {
+            e.printStackTrace();
+        } catch (AuthenticatorException e) {
+            syncResult.stats.numAuthExceptions++;
+            e.printStackTrace();
+        } catch (IOException e) {
+            syncResult.stats.numIoExceptions++;
+            e.printStackTrace();
+        } catch (DavException e) {
+            syncResult.stats.numIoExceptions++;
+            e.printStackTrace();
+        }
+        i.putExtra(FileSyncService.IN_PROGRESS, false);
+        getContext().sendStickyBroadcast(i);
+    }
+
+    private void fetchData(String uri, SyncResult syncResult, long parentId) {
+        try {
+            PropFindMethod query = new PropFindMethod(uri);
+            getClient().executeMethod(query);
+            MultiStatus resp = null;
+            resp = query.getResponseBodyAsMultiStatus();
+            for (int i = 1; i < resp.getResponses().length; ++i) {
+                WebdavEntry we = new WebdavEntry(resp.getResponses()[i], getUri().getPath());
+                OCFile file = fillOCFile(we);
+                file.setParentId(parentId);
+                getStorageManager().saveFile(file);
+                if (parentId == 0)
+                    parentId = file.getFileId();
+                if (we.contentType().equals("DIR"))
+                    fetchData(getUri().toString() + we.path(), syncResult, file.getFileId());
+            }
+            Vector<OCFile> files = getStorageManager().getDirectoryContent(
+                    getStorageManager().getFileById(parentId));
+            for (OCFile file : files) {
+                if (file.getLastSyncDate() != mCurrentSyncTime && file.getLastSyncDate() != 0)
+                    getStorageManager().removeFile(file);
+            }
+        } catch (OperationCanceledException e) {
+            e.printStackTrace();
+        } catch (AuthenticatorException e) {
+            syncResult.stats.numAuthExceptions++;
+            e.printStackTrace();
+        } catch (IOException e) {
+            syncResult.stats.numIoExceptions++;
+            e.printStackTrace();
+        } catch (DavException e) {
+            syncResult.stats.numIoExceptions++;
+            e.printStackTrace();
+        }
+    }
 
-  private void fetchData(String uri, SyncResult syncResult, long parentId) {
-    try {
-      PropFindMethod query = new PropFindMethod(uri);
-      getClient().executeMethod(query);
-      MultiStatus resp = null;
-      resp = query.getResponseBodyAsMultiStatus();
-      for (int i = (parentId==0?0:1); i < resp.getResponses().length; ++i) {
-        WebdavEntry we = new WebdavEntry(resp.getResponses()[i]);
-        OCFile file = new OCFile(we.path());
+    private OCFile fillOCFile(WebdavEntry we) {
+        OCFile file = new OCFile(URLDecoder.decode(we.path()));
         file.setCreationTimestamp(we.createTimestamp());
         file.setFileLength(we.contentLength());
         file.setMimetype(we.contentType());
         file.setModificationTimestamp(we.modifiedTimesamp());
-        file.setParentId(parentId);
-        if (we.contentType().equals("DIR"))
-          fetchData(getUri().toString() + we.path(), syncResult, file.getFileId());
-      }
-
-    } catch (OperationCanceledException e) {
-      e.printStackTrace();
-    } catch (AuthenticatorException e) {
-      syncResult.stats.numAuthExceptions++;
-      e.printStackTrace();
-    } catch (IOException e) {
-      syncResult.stats.numIoExceptions++;
-      e.printStackTrace();
-    } catch (DavException e) {
-      syncResult.stats.numIoExceptions++;
-      e.printStackTrace();
+        file.setLastSyncDate(mCurrentSyncTime);
+        return file;
     }
-  }
-	
+
 }