show permanent notification while transcoding video

1 files changed, 139 insertions, 0 deletions

diff --git a/src/main/java/de/pixart/messenger/services/AttachFileToConversationRunnable.java b/src/main/java/de/pixart/messenger/services/AttachFileToConversationRunnable.java
new file mode 100644
index 000000000..707bd6ed4
--- /dev/null
+++ b/src/main/java/de/pixart/messenger/services/AttachFileToConversationRunnable.java
@@ -0,0 +1,139 @@
+package de.pixart.messenger.services;
+
+import android.net.Uri;
+import android.os.Build;
+import android.os.ParcelFileDescriptor;
+import android.util.Log;
+
+import net.ypresto.androidtranscoder.MediaTranscoder;
+import net.ypresto.androidtranscoder.format.MediaFormatStrategy;
+import net.ypresto.androidtranscoder.format.MediaFormatStrategyPresets;
+
+import java.io.FileDescriptor;
+import java.io.FileNotFoundException;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.Locale;
+
+import de.pixart.messenger.Config;
+import de.pixart.messenger.R;
+import de.pixart.messenger.crypto.PgpEngine;
+import de.pixart.messenger.entities.DownloadableFile;
+import de.pixart.messenger.entities.Message;
+import de.pixart.messenger.persistance.FileBackend;
+import de.pixart.messenger.ui.UiCallback;
+import de.pixart.messenger.utils.MimeUtils;
+
+public class AttachFileToConversationRunnable implements Runnable, MediaTranscoder.Listener {
+
+    private final XmppConnectionService mXmppConnectionService;
+    private final Message message;
+    private final Uri uri;
+    private final UiCallback<Message> callback;
+    private final boolean isVideoMessage;
+    private int currentProgress = -1;
+
+    public AttachFileToConversationRunnable(XmppConnectionService xmppConnectionService, Uri uri, Message message, UiCallback<Message> callback) {
+        this.uri = uri;
+        this.mXmppConnectionService = xmppConnectionService;
+        this.message = message;
+        this.callback = callback;
+        final String mimeType = MimeUtils.guessMimeTypeFromUri(mXmppConnectionService, uri);
+        this.isVideoMessage = (mimeType != null && mimeType.startsWith("video/") && (Build.VERSION.SDK_INT >= Build.VERSION_CODES.JELLY_BEAN_MR2 || !getFileBackend().useFileAsIs(uri)));
+    }
+
+    private void processAsFile() {
+        final String path = mXmppConnectionService.getFileBackend().getOriginalPath(uri);
+        if (path != null) {
+            message.setRelativeFilePath(path);
+            mXmppConnectionService.getFileBackend().updateFileParams(message);
+            if (message.getEncryption() == Message.ENCRYPTION_DECRYPTED) {
+                mXmppConnectionService.getPgpEngine().encrypt(message, callback);
+            } else {
+                callback.success(message);
+            }
+        } else {
+            try {
+                mXmppConnectionService.getFileBackend().copyFileToPrivateStorage(message, uri);
+                mXmppConnectionService.getFileBackend().updateFileParams(message);
+                if (message.getEncryption() == Message.ENCRYPTION_DECRYPTED) {
+                    final PgpEngine pgpEngine = mXmppConnectionService.getPgpEngine();
+                    if (pgpEngine != null) {
+                        pgpEngine.encrypt(message, callback);
+                    } else if (callback != null) {
+                        callback.error(R.string.unable_to_connect_to_keychain, null);
+                    }
+                } else {
+                    callback.success(message);
+                }
+            } catch (FileBackend.FileCopyException e) {
+                callback.error(e.getResId(), message);
+            }
+        }
+    }
+
+    private void processAsVideo() throws FileNotFoundException {
+        Log.d(Config.LOGTAG, "processing file as video");
+        mXmppConnectionService.startForcingForegroundNotification();
+        SimpleDateFormat fileDateFormat = new SimpleDateFormat("yyyyMMdd_HHmmss", Locale.US);
+        message.setRelativeFilePath(fileDateFormat.format(new Date(message.getTimeSent())) + "_" + message.getUuid().substring(0, 4) + "_komp.mp4");
+        final DownloadableFile file = mXmppConnectionService.getFileBackend().getFile(message);
+        final int runtime = mXmppConnectionService.getFileBackend().getMediaRuntime(uri);
+        MediaFormatStrategy formatStrategy = runtime >= 8000 ? MediaFormatStrategyPresets.createExportPreset960x540Strategy() : MediaFormatStrategyPresets.createAndroid720pStrategy();
+        Log.d(Config.LOGTAG, "runtime " + runtime);
+        file.getParentFile().mkdirs();
+        ParcelFileDescriptor parcelFileDescriptor = mXmppConnectionService.getContentResolver().openFileDescriptor(uri, "r");
+        FileDescriptor fileDescriptor = parcelFileDescriptor.getFileDescriptor();
+        MediaTranscoder.getInstance().transcodeVideo(fileDescriptor, file.getAbsolutePath(), formatStrategy, this);
+    }
+
+    @Override
+    public void onTranscodeProgress(double progress) {
+        final int p = (int) Math.round(progress * 100);
+        if (p > currentProgress) {
+            currentProgress = p;
+            mXmppConnectionService.getNotificationService().updateFileAddingNotification(p, message);
+        }
+    }
+
+    @Override
+    public void onTranscodeCompleted() {
+        mXmppConnectionService.stopForcingForegroundNotification();
+        mXmppConnectionService.getFileBackend().updateFileParams(message);
+        if (message.getEncryption() == Message.ENCRYPTION_DECRYPTED) {
+            mXmppConnectionService.getPgpEngine().encrypt(message, callback);
+        } else {
+            callback.success(message);
+        }
+    }
+
+    @Override
+    public void onTranscodeCanceled() {
+        mXmppConnectionService.stopForcingForegroundNotification();
+        processAsFile();
+    }
+
+    @Override
+    public void onTranscodeFailed(Exception e) {
+        mXmppConnectionService.stopForcingForegroundNotification();
+        Log.d(Config.LOGTAG, "video transcoding failed " + e.getMessage());
+        processAsFile();
+    }
+
+    @Override
+    public void run() {
+        if (isVideoMessage) {
+            try {
+                processAsVideo();
+            } catch (Throwable e) {
+                processAsFile();
+            }
+        } else {
+            processAsFile();
+        }
+    }
+
+    public FileBackend getFileBackend() {
+        return mXmppConnectionService.fileBackend;
+    }
+}
\ No newline at end of file