kdeconnect-android/src/org/kde/kdeconnect/Plugins/SharePlugin/SharePlugin.java

/*
 * Copyright 2014 Albert Vaca Cintora <albertvaka@gmail.com>
 *
 * This program is free software; you can redistribute it and/or
 * modify it under the terms of the GNU General Public License as
 * published by the Free Software Foundation; either version 2 of
 * the License or (at your option) version 3 or any later version
 * accepted by the membership of KDE e.V. (or its successor approved
 * by the membership of KDE e.V.), which shall act as a proxy
 * defined in Section 14 of version 3 of the license.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program.  If not, see <http://www.gnu.org/licenses/>. 
*/

package org.kde.kdeconnect.Plugins.SharePlugin;

import android.app.Activity;
import android.app.Notification;
import android.app.NotificationManager;
import android.app.PendingIntent;
import android.content.ClipboardManager;
import android.content.Context;
import android.content.Intent;
import android.content.SharedPreferences;
import android.content.res.Resources;
import android.graphics.drawable.Drawable;
import android.net.Uri;
import android.os.Environment;
import android.preference.PreferenceManager;
import android.support.v4.app.NotificationCompat;
import android.support.v4.app.TaskStackBuilder;
import android.support.v4.content.ContextCompat;
import android.util.Log;
import android.widget.Toast;

import org.kde.kdeconnect.Helpers.FilesHelper;
import org.kde.kdeconnect.NetworkPackage;
import org.kde.kdeconnect.Plugins.Plugin;
import org.kde.kdeconnect_tp.R;

import java.io.File;
import java.io.FileOutputStream;
import java.io.InputStream;
import java.io.OutputStream;

public class SharePlugin extends Plugin {

    @Override
    public String getDisplayName() {
        return context.getResources().getString(R.string.pref_plugin_sharereceiver);
    }

    @Override
    public Drawable getIcon() {
        return ContextCompat.getDrawable(context, R.drawable.share_plugin_action);
    }

    @Override
    public String getDescription() {
        return context.getResources().getString(R.string.pref_plugin_sharereceiver_desc);
    }

    @Override
    public boolean hasMainActivity() {
        return true;
    }

    @Override
    public String getActionName() {
        return context.getString(R.string.send_files);
    }

    @Override
    public void startMainActivity(Activity parentActivity) {
        //TODO
    }

    @Override
    public boolean hasSettings() {
        return true;
    }

    @Override
    public boolean onPackageReceived(NetworkPackage np) {

        if (!np.getType().equals(NetworkPackage.PACKAGE_TYPE_SHARE)) {
            return false;
        }

        try {
            if (np.hasPayload()) {

                Log.i("SharePlugin", "hasPayload");

                final InputStream input = np.getPayload();
                final long fileLength = np.getPayloadSize();
                final String filename = np.getString("filename", Long.toString(System.currentTimeMillis()));

                String deviceDir = FilesHelper.toFileSystemSafeName(device.getName());
                //Get the external storage and append "/kdeconnect/DEVICE_NAME/"
                String destinationDir = Environment.getExternalStorageDirectory().getPath();
                destinationDir = new File(destinationDir, "kdeconnect").getPath();
                destinationDir = new File(destinationDir, deviceDir).getPath();

                //Create directories if needed
                new File(destinationDir).mkdirs();

                //Append filename to the destination path
                final File destinationFullPath = new File(destinationDir, filename);

                //Log.e("SharePlugin", "destinationFullPath:" + destinationFullPath);

                final NotificationManager notificationManager = (NotificationManager) context.getSystemService(Context.NOTIFICATION_SERVICE);

                final int notificationId = (int)System.currentTimeMillis();
                Resources res = context.getResources();
                final NotificationCompat.Builder builder = new NotificationCompat.Builder(context)
                        .setContentTitle(res.getString(R.string.incoming_file_title, device.getName()))
                        .setContentText(res.getString(R.string.incoming_file_text, filename))
                        .setTicker(res.getString(R.string.incoming_file_title, device.getName()))
                        .setSmallIcon(android.R.drawable.stat_sys_download)
                        .setAutoCancel(true)
                        .setOngoing(true)
                        .setProgress(100,0,true);

                try {
                    notificationManager.notify(notificationId,builder.build());
                } catch(Exception e) {
                    //4.1 will throw an exception about not having the VIBRATE permission, ignore it.
                    //https://android.googlesource.com/platform/frameworks/base/+/android-4.2.1_r1.2%5E%5E!/
                }

                new Thread(new Runnable() {
                    @Override
                    public void run() {
                        OutputStream output = null;
                        boolean successul = true;
                        try {
                            output = new FileOutputStream(destinationFullPath.getPath());
                            byte data[] = new byte[1024];
                            long progress = 0, prevProgressPercentage = 0;
                            int count;
                            while ((count = input.read(data)) >= 0) {
                                progress += count;
                                output.write(data, 0, count);
                                if (fileLength > 0) {
                                    if (progress >= fileLength) break;
                                    long progressPercentage = (progress * 100 / fileLength);
                                    if (progressPercentage != prevProgressPercentage) {
                                        prevProgressPercentage = progressPercentage;
                                        builder.setProgress(100, (int) progressPercentage, false);
                                        try {
                                            notificationManager.notify(notificationId,builder.build());
                                        } catch(Exception e) {
                                            //4.1 will throw an exception about not having the VIBRATE permission, ignore it.
                                            //https://android.googlesource.com/platform/frameworks/base/+/android-4.2.1_r1.2%5E%5E!/
                                        }
                                    }
                                }
                                //else Log.e("SharePlugin", "Infinite loop? :D");
                            }

                            output.flush();

                        } catch (Exception e) {
                            successul = false;
                            Log.e("SharePlugin", "Receiver thread exception");
                            e.printStackTrace();
                        } finally {
                            try { output.close(); } catch (Exception e) {}
                            try { input.close(); } catch (Exception e) {}
                        }

                        try {
                            Log.i("SharePlugin", "Transfer finished");

                            //Make sure it is added to the Android Gallery
                            Intent mediaScanIntent = new Intent(Intent.ACTION_MEDIA_SCANNER_SCAN_FILE);
                            mediaScanIntent.setData(Uri.fromFile(destinationFullPath));
                            context.sendBroadcast(mediaScanIntent);

                            //Update the notification and allow to open the file from it
                            Intent intent = new Intent(Intent.ACTION_VIEW);
                            intent.setDataAndType(Uri.fromFile(destinationFullPath), FilesHelper.getMimeTypeFromFile(destinationFullPath.getPath()));
                            intent.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK);
                            TaskStackBuilder stackBuilder = TaskStackBuilder.create(context);
                            stackBuilder.addNextIntent(intent);
                            PendingIntent resultPendingIntent = stackBuilder.getPendingIntent(
                                    0,
                                    PendingIntent.FLAG_UPDATE_CURRENT
                            );

                            Resources res = context.getResources();

                            String message = successul? res.getString(R.string.received_file_title, device.getName()) : res.getString(R.string.received_file_fail_title, device.getName());
                            NotificationCompat.Builder builder = new NotificationCompat.Builder(context)
                                    .setContentTitle(message)
                                    .setTicker(message)
                                    .setSmallIcon(android.R.drawable.stat_sys_download_done)
                                    .setAutoCancel(true);

                            if (successul) {
                                builder.setContentText(res.getString(R.string.received_file_text, filename))
                                       .setContentIntent(resultPendingIntent);
                            }

                            SharedPreferences prefs = PreferenceManager.getDefaultSharedPreferences(context);
                            if (prefs.getBoolean("share_notification_preference", true)) {
                                builder.setDefaults(Notification.DEFAULT_ALL);
                            }

                            try {
                                notificationManager.notify(notificationId,builder.build());
                            } catch(Exception e) {
                                //4.1 will throw an exception about not having the VIBRATE permission, ignore it.
                                //https://android.googlesource.com/platform/frameworks/base/+/android-4.2.1_r1.2%5E%5E!/
                            }

                        } catch (Exception e) {
                            Log.e("SharePlugin", "Receiver thread exception");
                            e.printStackTrace();

                        }
                    }
                }).start();

            } else if (np.has("text")) {
                Log.i("SharePlugin", "hasText");

                String text = np.getString("text");
                if(android.os.Build.VERSION.SDK_INT >= 11) {
                    ClipboardManager cm = (ClipboardManager)context.getSystemService(Context.CLIPBOARD_SERVICE);
                    cm.setText(text);
                } else {
                    android.text.ClipboardManager clipboard = (android.text.ClipboardManager) context.getSystemService(Context.CLIPBOARD_SERVICE);
                    clipboard.setText(text);
                }
                Toast.makeText(context, R.string.shareplugin_text_saved, Toast.LENGTH_LONG).show();
            } else if (np.has("url")) {

                String url = np.getString("url");

                Log.i("SharePlugin", "hasUrl: "+url);

                Intent browserIntent = new Intent(Intent.ACTION_VIEW, Uri.parse(url));
                browserIntent.addFlags(Intent.FLAG_ACTIVITY_NEW_TASK);

                //Do not launch url directly, show a notification instead

                Resources res = context.getResources();
                TaskStackBuilder stackBuilder = TaskStackBuilder.create(context);
                stackBuilder.addNextIntent(browserIntent);
                PendingIntent resultPendingIntent = stackBuilder.getPendingIntent(
                        0,
                        PendingIntent.FLAG_UPDATE_CURRENT
                );

                Notification noti = new NotificationCompat.Builder(context)
                        .setContentTitle(res.getString(R.string.received_url_title, device.getName()))
                        .setContentText(res.getString(R.string.received_url_text, url))
                        .setContentIntent(resultPendingIntent)
                        .setTicker(res.getString(R.string.received_url_title, device.getName()))
                        .setSmallIcon(android.R.drawable.ic_dialog_alert)
                        .setAutoCancel(true)
                        .setDefaults(Notification.DEFAULT_ALL)
                        .build();

                NotificationManager notificationManager = (NotificationManager) context.getSystemService(Context.NOTIFICATION_SERVICE);
                try {
                    notificationManager.notify((int)System.currentTimeMillis(), noti);
                } catch(Exception e) {
                    //4.1 will throw an exception about not having the VIBRATE permission, ignore it.
                    //https://android.googlesource.com/platform/frameworks/base/+/android-4.2.1_r1.2%5E%5E!/
                }

            } else {
                Log.e("SharePlugin", "Error: Nothing attached!");
            }


        } catch(Exception e) {
            Log.e("SharePlugin","Exception");
            e.printStackTrace();
        }

        return true;
    }

}