From 37c2a0e112b06cbb89045ba36b273708e944ab0f Mon Sep 17 00:00:00 2001
From: Albert Vaca <albertvaka@gmail.com>
Date: Fri, 27 Sep 2013 02:58:16 +0200
Subject: [PATCH] Added multi-file transfer and query for filename and file
 size

---
 KdeConnect/src/main/AndroidManifest.xml       |   5 +
 .../Backends/LanBackend/LanLink.java          |   2 +-
 .../main/java/org/kde/kdeconnect/Device.java  |  66 +++++++-----
 .../UserInterface/ShareToReceiver.java        | 101 ++++++++++++++++--
 4 files changed, 136 insertions(+), 38 deletions(-)

diff --git a/KdeConnect/src/main/AndroidManifest.xml b/KdeConnect/src/main/AndroidManifest.xml
index b9e13acc..c4eb6fe6 100644
--- a/KdeConnect/src/main/AndroidManifest.xml
+++ b/KdeConnect/src/main/AndroidManifest.xml
@@ -127,6 +127,11 @@
                 <category android:name="android.intent.category.DEFAULT" />
                 <data android:mimeType="*/*" />
             </intent-filter>
+            <intent-filter>
+                <action android:name="android.intent.action.SEND_MULTIPLE" />
+                <category android:name="android.intent.category.DEFAULT" />
+                <data android:mimeType="*/*" />
+            </intent-filter>
         </activity>
 
         <service android:name="org.kde.kdeconnect.Plugins.NotificationsPlugin.NotificationReceiver"
diff --git a/KdeConnect/src/main/java/org/kde/kdeconnect/Backends/LanBackend/LanLink.java b/KdeConnect/src/main/java/org/kde/kdeconnect/Backends/LanBackend/LanLink.java
index 647d766e..3cc7106c 100644
--- a/KdeConnect/src/main/java/org/kde/kdeconnect/Backends/LanBackend/LanLink.java
+++ b/KdeConnect/src/main/java/org/kde/kdeconnect/Backends/LanBackend/LanLink.java
@@ -127,7 +127,7 @@ public class LanLink extends BaseLink {
     public boolean sendPackageEncrypted(NetworkPackage np, PublicKey key) {
 
         if (session == null) {
-            Log.e("LanLink","sendPackage failed: not yet connected");
+            Log.e("LanLink", "sendPackage failed: not yet connected");
             return false;
         }
 
diff --git a/KdeConnect/src/main/java/org/kde/kdeconnect/Device.java b/KdeConnect/src/main/java/org/kde/kdeconnect/Device.java
index d32d3758..cb99ac67 100644
--- a/KdeConnect/src/main/java/org/kde/kdeconnect/Device.java
+++ b/KdeConnect/src/main/java/org/kde/kdeconnect/Device.java
@@ -158,23 +158,32 @@ public class Device implements BaseLink.PackageReceiver {
 
         //Send our own public key
         NetworkPackage np = NetworkPackage.createPublicKeyPackage(context);
-        boolean success = sendPackage(np);
+        sendPackage(np, new SendPackageFinishedCallback(){
 
-        if (!success) {
-            for (PairingCallback cb : pairingCallback) cb.pairingFailed(res.getString(R.string.error_could_not_send_package));
-            return;
-        }
-
-        pairingTimer = new Timer();
-        pairingTimer.schedule(new TimerTask() {
             @Override
-            public void run() {
-                for (PairingCallback cb : pairingCallback) cb.pairingFailed(context.getString(R.string.error_timed_out));
+            public void sendSuccessful() {
+                pairingTimer = new Timer();
+                pairingTimer.schedule(new TimerTask() {
+                    @Override
+                    public void run() {
+                        for (PairingCallback cb : pairingCallback) {
+                            cb.pairingFailed(context.getString(R.string.error_timed_out));
+                        }
+                        pairStatus = PairStatus.NotPaired;
+                    }
+                }, 20*1000);
+                pairStatus = PairStatus.Requested;
+            }
+
+            @Override
+            public void sendFailed() {
+                for (PairingCallback cb : pairingCallback) {
+                    cb.pairingFailed(context.getString(R.string.error_could_not_send_package));
+                }
                 pairStatus = PairStatus.NotPaired;
             }
-        }, 20*1000);
 
-        pairStatus = PairStatus.Requested;
+        });
 
     }
 
@@ -207,9 +216,7 @@ public class Device implements BaseLink.PackageReceiver {
 
         //Send our own public key
         NetworkPackage np = NetworkPackage.createPublicKeyPackage(context);
-        boolean success = sendPackage(np);
-
-        if (!success) return;
+        sendPackage(np); //TODO: Set a callback
 
         pairStatus = PairStatus.Paired;
 
@@ -416,8 +423,16 @@ public class Device implements BaseLink.PackageReceiver {
 
     }
 
+    public interface SendPackageFinishedCallback {
+        void sendSuccessful();
+        void sendFailed();
+    }
 
-    public boolean sendPackage(final NetworkPackage np) {
+    public void sendPackage(NetworkPackage np) {
+        sendPackage(np,null);
+    }
+
+    public void sendPackage(final NetworkPackage np, final SendPackageFinishedCallback callback) {
 
         new Thread(new Runnable() {
             @Override
@@ -429,26 +444,25 @@ public class Device implements BaseLink.PackageReceiver {
 
                 for(BaseLink link : links) {
 
+                    boolean success;
                     if (useEncryption) {
-                        if (link.sendPackageEncrypted(np, publicKey)) {
-                            //Log.e("sendPackage", "Sent");
-                            return;
-                        }
+                        success = link.sendPackageEncrypted(np, publicKey);
                     } else {
-                        if (link.sendPackage(np)) {
-                            //Log.e("sendPackage", "Sent");
-                            return;
-                        }
+                        success = link.sendPackage(np);
+                    }
+                    if (success) {
+                        //Log.e("sendPackage", "Sent");
+                        if (callback != null) callback.sendSuccessful();
+                        return;
                     }
-
                 }
 
+                if (callback != null) callback.sendFailed();
                 Log.e("sendPackage","Error: Package could not be sent ("+links.size()+" links available)");
 
             }
         }).start();
 
-        return !links.isEmpty();
     }
 
 
diff --git a/KdeConnect/src/main/java/org/kde/kdeconnect/UserInterface/ShareToReceiver.java b/KdeConnect/src/main/java/org/kde/kdeconnect/UserInterface/ShareToReceiver.java
index acb71340..64be6f75 100644
--- a/KdeConnect/src/main/java/org/kde/kdeconnect/UserInterface/ShareToReceiver.java
+++ b/KdeConnect/src/main/java/org/kde/kdeconnect/UserInterface/ShareToReceiver.java
@@ -17,6 +17,7 @@ import android.view.View;
 import android.widget.AdapterView;
 import android.widget.ListView;
 
+import org.apache.http.client.utils.URIUtils;
 import org.kde.kdeconnect.BackgroundService;
 import org.kde.kdeconnect.Device;
 import org.kde.kdeconnect.NetworkPackage;
@@ -26,6 +27,7 @@ import org.kde.kdeconnect.UserInterface.List.SectionItem;
 import org.kde.kdeconnect_tp.R;
 
 import java.io.InputStream;
+import java.net.URL;
 import java.util.ArrayList;
 import java.util.Collection;
 
@@ -84,7 +86,8 @@ public class ShareToReceiver extends ActionBarActivity {
 
         final Intent intent = getIntent();
 
-        if (!Intent.ACTION_SEND.equals(intent.getAction())) {
+        String action = intent.getAction();
+        if (!Intent.ACTION_SEND.equals(action) && !Intent.ACTION_SEND_MULTIPLE.equals(action)) {
             finish();
             return;
         }
@@ -117,28 +120,45 @@ public class ShareToReceiver extends ActionBarActivity {
 
                                 Device device = devicesList.get(i-1); //NOTE: -1 because of the title!
 
-                                NetworkPackage np = new NetworkPackage(NetworkPackage.PACKAGE_TYPE_FILETRANSFER);
-
                                 Bundle extras = intent.getExtras();
                                 if (extras.containsKey(Intent.EXTRA_STREAM)) {
+
                                     try {
-                                        Uri uri = extras.getParcelable(Intent.EXTRA_STREAM);
 
-                                        ContentResolver cr = getContentResolver();
+                                        ArrayList<Uri> uriList;
+                                        if (!Intent.ACTION_SEND.equals(intent.getAction())) {
+                                            uriList = intent.getParcelableArrayListExtra(Intent.EXTRA_STREAM);
+                                        } else {
+                                            Uri uri = extras.getParcelable(Intent.EXTRA_STREAM);
+                                            uriList = new ArrayList<Uri>();
+                                            uriList.add(uri);
+                                        }
 
-                                        InputStream inputStream = cr.openInputStream(uri);
-
-                                        //TODO: Figure out a way to find the file size, so we can show a progress bar in KDE
-                                        np.setPayload(inputStream, -1);
+                                        queuedSendUriList(device, uriList);
 
                                     } catch (Exception e) {
                                         Log.e(this.getClass().getName(), e.toString());
                                     }
+
                                 } else if (extras.containsKey(Intent.EXTRA_TEXT)) {
-                                    np.set("text",extras.getString(Intent.EXTRA_TEXT));
+                                    String text = extras.getString(Intent.EXTRA_TEXT);
+                                    boolean isUrl;
+                                    try {
+                                        new URL(text);
+                                        isUrl = true;
+                                    } catch(Exception e) {
+                                        isUrl = false;
+                                    }
+                                    NetworkPackage np = new NetworkPackage(NetworkPackage.PACKAGE_TYPE_FILETRANSFER);
+                                    if (isUrl) {
+                                        np.set("url", text);
+                                    } else {
+                                        np.set("text", text);
+                                    }
+                                    device.sendPackage(np);
                                 }
 
-                                device.sendPackage(np);
+
 
                                 finish();
                             }
@@ -150,6 +170,65 @@ public class ShareToReceiver extends ActionBarActivity {
         });
     }
 
+    private void queuedSendUriList(final Device device, final ArrayList<Uri> uriList) {
+        try {
+            Uri uri = uriList.remove(0);
+            ContentResolver cr = getContentResolver();
+            InputStream inputStream = cr.openInputStream(uri);
+
+            NetworkPackage np = new NetworkPackage(NetworkPackage.PACKAGE_TYPE_FILETRANSFER);
+
+            String[] proj = { MediaStore.MediaColumns.DATA, MediaStore.MediaColumns.SIZE, MediaStore.MediaColumns.DISPLAY_NAME };
+            Cursor cursor = managedQuery(uri, proj, null, null, null);
+
+            int size = -1;
+            try {
+                int column_index = cursor.getColumnIndexOrThrow(MediaStore.MediaColumns.SIZE);
+                cursor.moveToFirst();
+                size = cursor.getInt(column_index);
+            } catch(Exception e) {
+                e.printStackTrace();
+                Log.e("ShareToReceiver", "Could not obtain file size");
+            }
+
+            //Log.e("ShareToReceiver", "Size "+size);
+            np.setPayload(inputStream, size);
+
+            try {
+                int column_index = cursor.getColumnIndexOrThrow(MediaStore.MediaColumns.DATA);
+                cursor.moveToFirst();
+                String path = cursor.getString(column_index);
+                np.set("filename", Uri.parse(path).getLastPathSegment());
+            } catch(Exception _) {
+                try {
+                    int column_index = cursor.getColumnIndexOrThrow(MediaStore.MediaColumns.DISPLAY_NAME);
+                    cursor.moveToFirst();
+                    String name = cursor.getString(column_index);
+                    np.set("filename", name);
+                } catch (Exception e) {
+                    e.printStackTrace();
+                    Log.e("ShareToReceiver", "Could not obtain file name");
+                }
+            }
+
+            device.sendPackage(np, new Device.SendPackageFinishedCallback() {
+                @Override
+                public void sendSuccessful() {
+                    if (!uriList.isEmpty()) queuedSendUriList(device, uriList);
+                    else Log.e("ShareToReceiver", "All files sent");
+                }
+
+                @Override
+                public void sendFailed() {
+                    Log.e("ShareToReceiver", "Failed to send attachment");
+                }
+            });
+        } catch (Exception e) {
+            e.printStackTrace();
+            Log.e("ShareToReceiver", "Failed to send attachment");
+        }
+
+    }
     @Override
     protected void onCreate(Bundle savedInstanceState) {
         super.onCreate(savedInstanceState);