X-Git-Url: http://git.linex4red.de/pub/Android/ownCloud.git/blobdiff_plain/dc8c32fb3f7033d6fdfa7e1b64eaa77884da678a..a10efb1229c7200721b19533dde9301d9052ce25:/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 ef9da411..133e5fc1 100644
--- a/src/eu/alefzero/owncloud/syncadapter/FileSyncAdapter.java
+++ b/src/eu/alefzero/owncloud/syncadapter/FileSyncAdapter.java
@@ -20,25 +20,20 @@ package eu.alefzero.owncloud.syncadapter;
 
 import java.io.IOException;
 
-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 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.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.db.ProviderMeta.ProviderTableMeta;
-import eu.alefzero.webdav.HttpPropFind;
-import eu.alefzero.webdav.TreeNode;
-import eu.alefzero.webdav.TreeNode.NodeProperty;
-import eu.alefzero.webdav.WebdavUtils;
+import eu.alefzero.owncloud.datamodel.FileDataStorageManager;
+import eu.alefzero.owncloud.datamodel.OCFile;
+import eu.alefzero.webdav.WebdavEntry;
 
 /**
  * SyncAdapter implementation for syncing sample SyncAdapter contacts to the
@@ -47,12 +42,11 @@ 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, 
@@ -61,82 +55,74 @@ public class FileSyncAdapter extends AbstractOwnCloudSyncAdapter {
 			ContentProviderClient provider, 
 			SyncResult syncResult) {
 
-		try {
 			this.setAccount(account);
 			this.setContentProvider(provider);
+			this.setStorageManager(new FileDataStorageManager(account, getContentProvider()));
 
-			HttpPropFind query = this.getPropFindQuery();
-			query.setEntity(new StringEntity(WebdavUtils.prepareXmlForPropFind()));
-			TreeNode root = this.fireRequest(query);
-
-			commitToDatabase(root, null);
-		} catch (OperationCanceledException e) {
-			e.printStackTrace();
-		} catch (AuthenticatorException e) {
-			syncResult.stats.numAuthExceptions++;
-			e.printStackTrace();
-		} catch (IOException e) {
-			syncResult.stats.numIoExceptions++;
-			e.printStackTrace();
-		} catch (RemoteException e) {
-			e.printStackTrace();
-		}
+			PropFindMethod query;
+      try {
+        query = new PropFindMethod(getUri().toString());
+        getClient().executeMethod(query);
+        MultiStatus resp = null;
+        resp = query.getResponseBodyAsMultiStatus();
+        if (resp.getResponses().length > 0) {
+          WebdavEntry we = new WebdavEntry(resp.getResponses()[0]);
+          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();
+      }
+      
 	}
 
-	private void commitToDatabase(TreeNode root, String parentId) throws RemoteException {
-		for (TreeNode n : root.getChildList()) {
-			Log.d(TAG, n.toString());
-			ContentValues cv = new ContentValues();
-			cv.put(ProviderTableMeta.FILE_CONTENT_LENGTH, n.getProperty(NodeProperty.CONTENT_LENGTH));
-			cv.put(ProviderTableMeta.FILE_MODIFIED, n.getProperty(NodeProperty.LAST_MODIFIED_DATE));
-			cv.put(ProviderTableMeta.FILE_CONTENT_TYPE, n.getProperty(NodeProperty.RESOURCE_TYPE));
-			cv.put(ProviderTableMeta.FILE_PARENT, parentId);
-
-			String name = n.getProperty(NodeProperty.NAME),
-					path = n.getProperty(NodeProperty.PATH);
-			Cursor c = this.getContentProvider().query(ProviderTableMeta.CONTENT_URI_FILE,
-					null,
-					ProviderTableMeta.FILE_NAME+"=? AND " + ProviderTableMeta.FILE_PATH + "=? AND " + ProviderTableMeta.FILE_ACCOUNT_OWNER + "=?",
-					new String[]{name, path, this.getAccount().name},
-					null);
-			if (c.moveToFirst()) {
-				this.getContentProvider().update(ProviderTableMeta.CONTENT_URI,
-						cv,
-						ProviderTableMeta._ID+"=?",
-								new String[]{c.getString(c.getColumnIndex(ProviderTableMeta._ID))});
-				Log.d(TAG, "ID of: "+name+":"+c.getString(c.getColumnIndex(ProviderTableMeta._ID)));
-			} else {
-				cv.put(ProviderTableMeta.FILE_NAME, n.getProperty(NodeProperty.NAME));
-				cv.put(ProviderTableMeta.FILE_PATH, n.getProperty(NodeProperty.PATH));
-				cv.put(ProviderTableMeta.FILE_ACCOUNT_OWNER, this.getAccount().name);
-				Uri entry = this.getContentProvider().insert(ProviderTableMeta.CONTENT_URI_FILE, cv);
-				Log.d(TAG, "Inserting new entry " + path + name);
-				c = this.getContentProvider().query(entry, null, null, null, null);
-				c.moveToFirst();
-			}
-			if (n.getProperty(NodeProperty.RESOURCE_TYPE).equals("DIR")) {
-				commitToDatabase(n, c.getString(c.getColumnIndex(ProviderTableMeta._ID)));
-			}
-		}
-		// clean removed files
-		String[] selection = new String[root.getChildList().size()+2];
-		selection[0] = this.getAccount().name;
-		selection[1] = parentId;
-		String qm = "";
-		for (int i = 2; i < selection.length-1; ++i) {
-			qm += "?,";
-			selection[i] = root.getChildList().get(i-2).getProperty(NodeProperty.NAME);
-		}
-		if (selection.length >= 3) {
-			selection[selection.length-1] = root.getChildrenNames()[selection.length-3];
-			qm += "?";
-		}
-		for (int i = 0; i < selection.length; ++i) {
-			Log.d(TAG,selection[i]+"");
-		}
-		Log.d(TAG,"Removing files "+ parentId);
-		this.getContentProvider().delete(ProviderTableMeta.CONTENT_URI,
-				ProviderTableMeta.FILE_ACCOUNT_OWNER+"=? AND " + ProviderTableMeta.FILE_PARENT + (parentId==null?" IS ":"=")+"? AND " + ProviderTableMeta.FILE_NAME + " NOT IN ("+qm+")",
-				selection);
-	}
+  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]);
+        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());
+      }
+    } 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 OCFile fillOCFile(WebdavEntry we) {
+    OCFile file = new OCFile(we.path());
+    file.setCreationTimestamp(we.createTimestamp());
+    file.setFileLength(we.contentLength());
+    file.setMimetype(we.contentType());
+    file.setModificationTimestamp(we.modifiedTimesamp());
+    return file;
+  }
+	
 }