aboutsummaryrefslogtreecommitdiff
path: root/app/src/main/java
diff options
context:
space:
mode:
Diffstat (limited to 'app/src/main/java')
-rw-r--r--app/src/main/java/ml/docilealligator/infinityforreddit/Service/DownloadRedditVideoService.java529
1 files changed, 293 insertions, 236 deletions
diff --git a/app/src/main/java/ml/docilealligator/infinityforreddit/Service/DownloadRedditVideoService.java b/app/src/main/java/ml/docilealligator/infinityforreddit/Service/DownloadRedditVideoService.java
index bdfd4784..648639c2 100644
--- a/app/src/main/java/ml/docilealligator/infinityforreddit/Service/DownloadRedditVideoService.java
+++ b/app/src/main/java/ml/docilealligator/infinityforreddit/Service/DownloadRedditVideoService.java
@@ -13,7 +13,6 @@ import android.media.MediaCodec;
import android.media.MediaExtractor;
import android.media.MediaFormat;
import android.media.MediaMuxer;
-import android.media.MediaScannerConnection;
import android.net.Uri;
import android.os.AsyncTask;
import android.os.Build;
@@ -22,10 +21,10 @@ import android.os.IBinder;
import android.provider.MediaStore;
import android.util.Log;
+import androidx.annotation.NonNull;
import androidx.annotation.RequiresApi;
import androidx.core.app.NotificationCompat;
import androidx.core.app.NotificationManagerCompat;
-import androidx.core.content.FileProvider;
import org.greenrobot.eventbus.EventBus;
@@ -60,6 +59,14 @@ public class DownloadRedditVideoService extends Service {
public static final String EXTRA_SUBREDDIT = "ES";
public static final String EXTRA_POST_ID = "EPI";
+ private static final int NO_ERROR = -1;
+ private static final int ERROR_CANNOT_GET_CACHE_DIRECTORY = 0;
+ private static final int ERROR_VIDEO_FILE_CANNOT_DOWNLOAD = 1;
+ private static final int ERROR_VIDEO_FILE_CANNOT_SAVE = 2;
+ private static final int ERROR_AUDIO_FILE_CANNOT_SAVE = 3;
+ private static final int ERROR_MUX_FAILED = 4;
+ private static final int ERROR_MUXED_VIDEO_FILE_CANNOT_SAVE = 5;
+
@Inject
@Named("download_reddit_video")
Retrofit retrofit;
@@ -97,310 +104,360 @@ public class DownloadRedditVideoService extends Service {
startForeground(
NotificationUtils.DOWNLOAD_REDDIT_VIDEO_NOTIFICATION_ID,
- createNotification(R.string.downloading_reddit_video, fileName + ".mp4", false, null)
+ createNotification(R.string.downloading_reddit_video, fileName + ".mp4", null)
);
DownloadRedditVideo downloadRedditVideo = retrofit.create(DownloadRedditVideo.class);
File directory = getExternalCacheDir();
+ String destinationFileName = fileName + ".mp4";
if (directory != null) {
String directoryPath = directory.getAbsolutePath() + "/";
downloadRedditVideo.downloadFile(videoUrl).enqueue(new Callback<ResponseBody>() {
@Override
- public void onResponse(Call<ResponseBody> call, Response<ResponseBody> videoResponse) {
+ public void onResponse(@NonNull Call<ResponseBody> call, @NonNull Response<ResponseBody> videoResponse) {
if (videoResponse.isSuccessful() && videoResponse.body() != null) {
- String videoFilePath = writeResponseBodyToDisk(videoResponse.body(), directoryPath + fileName + "-cache.mp4");
- if (videoFilePath != null) {
- resultFile = videoFilePath;
- updateNotification(R.string.downloading_reddit_video_audio_track, fileName + ".mp3", false);
-
- downloadRedditVideo.downloadFile(audioUrl).enqueue(new Callback<ResponseBody>() {
- @Override
- public void onResponse(Call<ResponseBody> call, Response<ResponseBody> audioResponse) {
- if (audioResponse.isSuccessful() && audioResponse.body() != null) {
- String audioFilePath = writeResponseBodyToDisk(audioResponse.body(), directoryPath + fileName + "-cache.mp3");
- if (audioFilePath != null) {
- updateNotification(R.string.downloading_reddit_video_muxing, null, false);
- String outputFilePath = directoryPath + fileName + ".mp4";
- if (muxVideoAndAudio(videoFilePath, audioFilePath, outputFilePath)) {
- resultFile = outputFilePath;
- }
- new File(audioFilePath).delete();
- }
- }
- copyVideoToPublicDir(resultFile, fileName, new String[]{videoFilePath, resultFile});
- }
-
- @Override
- public void onFailure(Call<ResponseBody> call, Throwable t) {
- copyVideoToPublicDir(resultFile, fileName, new String[]{videoFilePath, resultFile});
+ updateNotification(R.string.downloading_reddit_video_audio_track, destinationFileName, null);
+ downloadRedditVideo.downloadFile(audioUrl).enqueue(new Callback<ResponseBody>() {
+ @Override
+ public void onResponse(@NonNull Call<ResponseBody> call, @NonNull Response<ResponseBody> audioResponse) {
+ if (audioResponse.isSuccessful() && audioResponse.body() != null) {
+ String videoFilePath = directoryPath + fileName + "-cache.mp4";
+ String audioFilePath = directoryPath + fileName + "-cache.mp3";
+ String outputFilePath = directoryPath + fileName + ".mp4";
+ new SaveTempMuxAndCopyAsyncTask(videoResponse.body(),
+ audioResponse.body(), videoFilePath, audioFilePath, outputFilePath,
+ destinationFileName, getContentResolver(),
+ new SaveTempMuxAndCopyAsyncTask.SaveTempMuxAndCopyAsyncTaskListener() {
+ @Override
+ public void finished(Uri destinationFileUri, int errorCode) {
+ new File(videoFilePath).delete();
+ new File(audioFilePath).delete();
+ new File(outputFilePath).delete();
+ downloadFinished(destinationFileUri, destinationFileName, errorCode);
+ }
+
+ @Override
+ public void updateProgressNotification(int stringResId) {
+ updateNotification(stringResId, destinationFileName, null);
+ }
+ }).execute();
+ } else {
+ String videoFilePath = directoryPath + fileName + "-cache.mp4";
+ String destinationFileName = fileName + ".mp4";
+ new SaveTempMuxAndCopyAsyncTask(videoResponse.body(),
+ null, videoFilePath, null, null,
+ destinationFileName, getContentResolver(),
+ new SaveTempMuxAndCopyAsyncTask.SaveTempMuxAndCopyAsyncTaskListener() {
+ @Override
+ public void finished(Uri destinationFileUri, int errorCode) {
+ new File(videoFilePath).delete();
+ downloadFinished(destinationFileUri, destinationFileName, errorCode);
+ }
+
+ @Override
+ public void updateProgressNotification(int stringResId) {
+ updateNotification(stringResId, destinationFileName, null);
+ }
+ }).execute();
}
- });
+ }
+
+ @Override
+ public void onFailure(@NonNull Call<ResponseBody> call, @NonNull Throwable t) {
+ String videoFilePath = directoryPath + fileName + "-cache.mp4";
+ String destinationFileName = fileName + ".mp4";
+ new SaveTempMuxAndCopyAsyncTask(videoResponse.body(),
+ null, videoFilePath, null, null,
+ destinationFileName, getContentResolver(),
+ new SaveTempMuxAndCopyAsyncTask.SaveTempMuxAndCopyAsyncTaskListener() {
+ @Override
+ public void finished(Uri destinationFileUri, int errorCode) {
+ new File(videoFilePath).delete();
+ downloadFinished(destinationFileUri, destinationFileName, errorCode);
+ }
- } else {
- downloadFinished(false);
- }
+ @Override
+ public void updateProgressNotification(int stringResId) {
+ updateNotification(stringResId, destinationFileName, null);
+ }
+ }).execute();
+ }
+ });
} else {
- downloadFinished(false);
+ downloadFinished(null, destinationFileName, ERROR_VIDEO_FILE_CANNOT_DOWNLOAD);
}
}
@Override
- public void onFailure(Call<ResponseBody> call, Throwable t) {
- downloadFinished(false);
+ public void onFailure(@NonNull Call<ResponseBody> call, @NonNull Throwable t) {
+ downloadFinished(null, destinationFileName, ERROR_VIDEO_FILE_CANNOT_DOWNLOAD);
}
});
} else {
- downloadFinished(false);
+ downloadFinished(null, destinationFileName, ERROR_CANNOT_GET_CACHE_DIRECTORY);
}
return START_NOT_STICKY;
}
- private void addMediaFileAndShareNotification(File f, int stringResId, String fileName) {
- MediaScannerConnection.scanFile(
- this, new String[]{f.getAbsolutePath()}, null,
- (path, uri) -> openVideoNotification(f, stringResId, fileName)
- );
- }
-
- private void openVideoNotification(File f, int stringResId, String fileName) {
- final Intent viewIntent = new Intent(Intent.ACTION_VIEW);
- Uri selectedUri = FileProvider.getUriForFile(this, getApplicationContext().getPackageName() + ".provider", f);
- viewIntent.setDataAndType(selectedUri, getContentResolver().getType(selectedUri));
- viewIntent.setFlags(Intent.FLAG_GRANT_READ_URI_PERMISSION | Intent.FLAG_GRANT_WRITE_URI_PERMISSION);
- PendingIntent contentIntent = PendingIntent.getActivity(this, 0, viewIntent, PendingIntent.FLAG_CANCEL_CURRENT);
- updateNotification(stringResId, fileName, true, contentIntent);
- }
-
- private void downloadFinished(boolean isSuccessful) {
- EventBus.getDefault().post(new DownloadRedditVideoEvent(isSuccessful));
- if (!isSuccessful)
- updateNotification(R.string.downloading_reddit_video_failed, null, true);
- stopService();
+ private void downloadFinished(Uri destinationFileUri, String fileName, int errorCode) {
+ if (errorCode != NO_ERROR) {
+ switch (errorCode) {
+ case ERROR_CANNOT_GET_CACHE_DIRECTORY:
+ updateNotification(R.string.downloading_reddit_video_failed_cannot_get_cache_directory, fileName, null);
+ break;
+ case ERROR_VIDEO_FILE_CANNOT_DOWNLOAD:
+ updateNotification(R.string.downloading_reddit_video_failed_cannot_download_video, fileName, null);
+ break;
+ case ERROR_VIDEO_FILE_CANNOT_SAVE:
+ updateNotification(R.string.downloading_reddit_video_failed_cannot_save_video, fileName, null);
+ break;
+ case ERROR_AUDIO_FILE_CANNOT_SAVE:
+ updateNotification(R.string.downloading_reddit_video_failed_cannot_save_audio, fileName, null);
+ break;
+ case ERROR_MUX_FAILED:
+ updateNotification(R.string.downloading_reddit_video_failed_cannot_mux, fileName, null);
+ break;
+ case ERROR_MUXED_VIDEO_FILE_CANNOT_SAVE:
+ updateNotification(R.string.downloading_reddit_video_failed_cannot_save_mux_video, fileName, null);
+ break;
+ }
+ EventBus.getDefault().post(new DownloadRedditVideoEvent(false));
+ } else {
+ Intent intent = new Intent();
+ intent.setAction(android.content.Intent.ACTION_VIEW);
+ intent.setDataAndType(destinationFileUri, "video/*");
+ PendingIntent pendingIntent = PendingIntent.getActivity(this, 0, intent, PendingIntent.FLAG_CANCEL_CURRENT);
+ updateNotification(R.string.downloading_reddit_video_finished, fileName, pendingIntent);
+ EventBus.getDefault().post(new DownloadRedditVideoEvent(true));
+ }
+ stopForeground(false);
}
- private Notification createNotification(int stringResId, String fileName, boolean finished, PendingIntent contentIntent) {
+ private Notification createNotification(int stringResId, String fileName, PendingIntent pendingIntent) {
NotificationCompat.Builder builder = new NotificationCompat.Builder(this, NotificationUtils.CHANNEL_ID_DOWNLOAD_REDDIT_VIDEO);
- if (fileName != null) {
- builder.setContentTitle(getString(stringResId, fileName));
- } else {
- builder.setContentTitle(getString(stringResId));
+ builder.setContentTitle(fileName).setContentText(getString(stringResId));
+ if (pendingIntent != null) {
+ builder.setContentIntent(pendingIntent);
}
- if (!finished)
- builder.setContentText(getString(R.string.please_wait));
- if (contentIntent != null)
- builder.setContentIntent(contentIntent);
return builder.setSmallIcon(R.drawable.ic_notification)
.setColor(mCustomThemeWrapper.getColorPrimaryLightTheme())
.build();
}
- private void updateNotification(int stringResId, String fileName, boolean finished) {
- updateNotification(stringResId, fileName, finished, null);
- }
-
- private void updateNotification(int stringResId, String fileName, boolean finished, PendingIntent contentIntent) {
+ private void updateNotification(int stringResId, String fileName, PendingIntent pendingIntent) {
NotificationManager notificationManager = (NotificationManager) getSystemService(Context.NOTIFICATION_SERVICE);
if (notificationManager != null) {
notificationManager.notify(NotificationUtils.DOWNLOAD_REDDIT_VIDEO_NOTIFICATION_ID,
- createNotification(stringResId, fileName, finished, contentIntent));
+ createNotification(stringResId, fileName, pendingIntent));
}
}
- private void copyVideoToPublicDir(String resFilePath, String newFileName, String[] tempFiles) {
- new CopyFileAsyncTask(new File(resFilePath), newFileName + ".mp4",
- getContentResolver(), new CopyFileAsyncTask.CopyFileAsyncTaskListener() {
- @Override
- public void successful(File dstFile) {
- if (dstFile != null) {
- addMediaFileAndShareNotification(dstFile, R.string.downloading_reddit_video_finished, newFileName + ".mp4");
- } else {
- updateNotification(R.string.downloading_reddit_video_finished, newFileName + ".mp4", true);
- }
+ private static class SaveTempMuxAndCopyAsyncTask extends AsyncTask<Void, Integer, Void> {
- for (int i = 0; i < tempFiles.length; i++) {
- new File(tempFiles[i]).delete();
- }
- downloadFinished(true);
+ private ResponseBody videoResponse;
+ private ResponseBody audioResponse;
+ private String videoFilePath;
+ private String audioFilePath;
+ private String outputFilePath;
+ private String destinationFileName;
+ private ContentResolver contentResolver;
+ private SaveTempMuxAndCopyAsyncTaskListener saveTempMuxAndCopyAsyncTaskListener;
+ private Uri destinationFileUri;
+ private int errorCode = NO_ERROR;
+
+ public SaveTempMuxAndCopyAsyncTask(ResponseBody videoResponse, ResponseBody audioResponse,
+ String videoFilePath, String audioFilePath, String outputFilePath,
+ String destinationFileName, ContentResolver contentResolver,
+ SaveTempMuxAndCopyAsyncTaskListener saveTempMuxAndCopyAsyncTaskListener) {
+ this.videoResponse = videoResponse;
+ this.audioResponse = audioResponse;
+ this.videoFilePath = videoFilePath;
+ this.audioFilePath = audioFilePath;
+ this.outputFilePath = outputFilePath;
+ this.destinationFileName = destinationFileName;
+ this.contentResolver = contentResolver;
+ this.saveTempMuxAndCopyAsyncTaskListener = saveTempMuxAndCopyAsyncTaskListener;
+ }
+
+ @Override
+ protected void onProgressUpdate(Integer... values) {
+ super.onProgressUpdate(values);
+ saveTempMuxAndCopyAsyncTaskListener.updateProgressNotification(values[0]);
+ }
+
+ @Override
+ protected Void doInBackground(Void... voids) {
+ publishProgress(R.string.downloading_reddit_video_save_video);
+ String savedVideoFilePath = writeResponseBodyToDisk(videoResponse, videoFilePath);
+ if (savedVideoFilePath == null) {
+ errorCode = ERROR_VIDEO_FILE_CANNOT_SAVE;
+ return null;
}
+ if (audioResponse != null) {
+ publishProgress(R.string.downloading_reddit_video_save_audio);
+ String savedAudioFilePath = writeResponseBodyToDisk(audioResponse, audioFilePath);
+ if (savedAudioFilePath == null) {
+ errorCode = ERROR_AUDIO_FILE_CANNOT_SAVE;
+ return null;
+ }
- @Override
- public void failed() {
- for (int i = 0; i < tempFiles.length; i++) {
- new File(tempFiles[i]).delete();
+ publishProgress(R.string.downloading_reddit_video_muxing);
+ if (!muxVideoAndAudio(videoFilePath, audioFilePath, outputFilePath)) {
+ errorCode = ERROR_MUX_FAILED;
+ return null;
}
- downloadFinished(false);
- }
- }).execute();
- }
- private String writeResponseBodyToDisk(ResponseBody body, String filePath) {
- try {
- File file = new File(filePath);
+ publishProgress(R.string.downloading_reddit_video_save_file_to_public_dir);
+ copyToDestination(outputFilePath);
+ } else {
+ publishProgress(R.string.downloading_reddit_video_save_file_to_public_dir);
+ copyToDestination(videoFilePath);
+ }
+ return null;
+ }
- InputStream inputStream = null;
- OutputStream outputStream = null;
+ @Override
+ protected void onPostExecute(Void aVoid) {
+ super.onPostExecute(aVoid);
+ saveTempMuxAndCopyAsyncTaskListener.finished(destinationFileUri, errorCode);
+ }
+ private String writeResponseBodyToDisk(ResponseBody body, String filePath) {
try {
- byte[] fileReader = new byte[4096];
+ File file = new File(filePath);
- long fileSize = body.contentLength();
- long fileSizeDownloaded = 0;
+ InputStream inputStream = null;
+ OutputStream outputStream = null;
- inputStream = body.byteStream();
- outputStream = new FileOutputStream(file);
+ try {
+ byte[] fileReader = new byte[4096];
- while (true) {
- int read = inputStream.read(fileReader);
+ long fileSize = body.contentLength();
+ long fileSizeDownloaded = 0;
- if (read == -1) {
- break;
- }
+ inputStream = body.byteStream();
+ outputStream = new FileOutputStream(file);
- outputStream.write(fileReader, 0, read);
+ while (true) {
+ int read = inputStream.read(fileReader);
- fileSizeDownloaded += read;
- Log.i("asdfsadf", "file download: " + fileSizeDownloaded + " of " + fileSize);
- }
+ if (read == -1) {
+ break;
+ }
- outputStream.flush();
+ outputStream.write(fileReader, 0, read);
- return file.getPath();
- } catch (IOException e) {
- return null;
- } finally {
- if (inputStream != null) {
- inputStream.close();
- }
+ fileSizeDownloaded += read;
+ Log.i("asdfsadf", "file download: " + fileSizeDownloaded + " of " + fileSize);
+ }
+
+ outputStream.flush();
+
+ return file.getPath();
+ } catch (IOException e) {
+ return null;
+ } finally {
+ if (inputStream != null) {
+ inputStream.close();
+ }
- if (outputStream != null) {
- outputStream.close();
+ if (outputStream != null) {
+ outputStream.close();
+ }
}
+ } catch (IOException e) {
+ return null;
}
- } catch (IOException e) {
- return null;
}
- }
- private boolean muxVideoAndAudio(String videoFilePath, String audioFilePath, String outputFilePath) {
- try {
- File file = new File(outputFilePath);
- file.createNewFile();
- MediaExtractor videoExtractor = new MediaExtractor();
- videoExtractor.setDataSource(videoFilePath);
- MediaExtractor audioExtractor = new MediaExtractor();
- audioExtractor.setDataSource(audioFilePath);
- MediaMuxer muxer = new MediaMuxer(outputFilePath, MediaMuxer.OutputFormat.MUXER_OUTPUT_MPEG_4);
-
- videoExtractor.selectTrack(0);
- MediaFormat videoFormat = videoExtractor.getTrackFormat(0);
- int videoTrack = muxer.addTrack(videoFormat);
-
- audioExtractor.selectTrack(0);
- MediaFormat audioFormat = audioExtractor.getTrackFormat(0);
- int audioTrack = muxer.addTrack(audioFormat);
- boolean sawEOS = false;
- int offset = 100;
- int sampleSize = 256 * 1024;
- ByteBuffer videoBuf = ByteBuffer.allocate(sampleSize);
- ByteBuffer audioBuf = ByteBuffer.allocate(sampleSize);
- MediaCodec.BufferInfo videoBufferInfo = new MediaCodec.BufferInfo();
- MediaCodec.BufferInfo audioBufferInfo = new MediaCodec.BufferInfo();
-
- videoExtractor.seekTo(0, MediaExtractor.SEEK_TO_CLOSEST_SYNC);
- audioExtractor.seekTo(0, MediaExtractor.SEEK_TO_CLOSEST_SYNC);
-
- muxer.start();
-
- while (!sawEOS) {
- videoBufferInfo.offset = offset;
- videoBufferInfo.size = videoExtractor.readSampleData(videoBuf, offset);
-
-
- if (videoBufferInfo.size < 0 || audioBufferInfo.size < 0) {
- // Log.d(TAG, "saw input EOS.");
- sawEOS = true;
- videoBufferInfo.size = 0;
- } else {
- videoBufferInfo.presentationTimeUs = videoExtractor.getSampleTime();
- videoBufferInfo.flags = videoExtractor.getSampleFlags();
- muxer.writeSampleData(videoTrack, videoBuf, videoBufferInfo);
- videoExtractor.advance();
+ private boolean muxVideoAndAudio(String videoFilePath, String audioFilePath, String outputFilePath) {
+ try {
+ File file = new File(outputFilePath);
+ file.createNewFile();
+ MediaExtractor videoExtractor = new MediaExtractor();
+ videoExtractor.setDataSource(videoFilePath);
+ MediaExtractor audioExtractor = new MediaExtractor();
+ audioExtractor.setDataSource(audioFilePath);
+ MediaMuxer muxer = new MediaMuxer(outputFilePath, MediaMuxer.OutputFormat.MUXER_OUTPUT_MPEG_4);
+
+ videoExtractor.selectTrack(0);
+ MediaFormat videoFormat = videoExtractor.getTrackFormat(0);
+ int videoTrack = muxer.addTrack(videoFormat);
+
+ audioExtractor.selectTrack(0);
+ MediaFormat audioFormat = audioExtractor.getTrackFormat(0);
+ int audioTrack = muxer.addTrack(audioFormat);
+ boolean sawEOS = false;
+ int offset = 100;
+ int sampleSize = 256 * 1024;
+ ByteBuffer videoBuf = ByteBuffer.allocate(sampleSize);
+ ByteBuffer audioBuf = ByteBuffer.allocate(sampleSize);
+ MediaCodec.BufferInfo videoBufferInfo = new MediaCodec.BufferInfo();
+ MediaCodec.BufferInfo audioBufferInfo = new MediaCodec.BufferInfo();
+
+ videoExtractor.seekTo(0, MediaExtractor.SEEK_TO_CLOSEST_SYNC);
+ audioExtractor.seekTo(0, MediaExtractor.SEEK_TO_CLOSEST_SYNC);
+
+ muxer.start();
+
+ while (!sawEOS) {
+ videoBufferInfo.offset = offset;
+ videoBufferInfo.size = videoExtractor.readSampleData(videoBuf, offset);
+
+
+ if (videoBufferInfo.size < 0 || audioBufferInfo.size < 0) {
+ sawEOS = true;
+ videoBufferInfo.size = 0;
+ } else {
+ videoBufferInfo.presentationTimeUs = videoExtractor.getSampleTime();
+ videoBufferInfo.flags = videoExtractor.getSampleFlags();
+ muxer.writeSampleData(videoTrack, videoBuf, videoBufferInfo);
+ videoExtractor.advance();
+ }
}
- }
- boolean sawEOS2 = false;
- while (!sawEOS2) {
- audioBufferInfo.offset = offset;
- audioBufferInfo.size = audioExtractor.readSampleData(audioBuf, offset);
+ boolean sawEOS2 = false;
+ while (!sawEOS2) {
+ audioBufferInfo.offset = offset;
+ audioBufferInfo.size = audioExtractor.readSampleData(audioBuf, offset);
- if (videoBufferInfo.size < 0 || audioBufferInfo.size < 0) {
- sawEOS2 = true;
- audioBufferInfo.size = 0;
- } else {
- audioBufferInfo.presentationTimeUs = audioExtractor.getSampleTime();
- audioBufferInfo.flags = audioExtractor.getSampleFlags();
- muxer.writeSampleData(audioTrack, audioBuf, audioBufferInfo);
- audioExtractor.advance();
+ if (videoBufferInfo.size < 0 || audioBufferInfo.size < 0) {
+ sawEOS2 = true;
+ audioBufferInfo.size = 0;
+ } else {
+ audioBufferInfo.presentationTimeUs = audioExtractor.getSampleTime();
+ audioBufferInfo.flags = audioExtractor.getSampleFlags();
+ muxer.writeSampleData(audioTrack, audioBuf, audioBufferInfo);
+ audioExtractor.advance();
+ }
}
- }
-
- muxer.stop();
- muxer.release();
- } catch (IOException e) {
- e.printStackTrace();
- return false;
- }
-
- return true;
- }
- private void stopService() {
- stopForeground(false);
- }
-
- private static class CopyFileAsyncTask extends AsyncTask<Void, Void, Void> {
-
- private File src;
- private String destinationFileName;
- private File destinationFile;
- private ContentResolver contentResolver;
- private CopyFileAsyncTaskListener copyFileAsyncTaskListener;
- private boolean successful;
+ muxer.stop();
+ muxer.release();
+ } catch (IOException e) {
+ e.printStackTrace();
+ return false;
+ }
- CopyFileAsyncTask(File src, String destinationFileName, ContentResolver contentResolver, CopyFileAsyncTaskListener copyFileAsyncTaskListener) {
- this.src = src;
- this.destinationFileName = destinationFileName;
- this.contentResolver = contentResolver;
- this.copyFileAsyncTaskListener = copyFileAsyncTaskListener;
+ return true;
}
- @Override
- protected Void doInBackground(Void... voids) {
+ private void copyToDestination(String srcPath) {
if (android.os.Build.VERSION.SDK_INT < Build.VERSION_CODES.Q) {
- successful = copy(src, destinationFileName);
+ if (!copy(new File(srcPath), destinationFileName)) {
+ errorCode = ERROR_MUXED_VIDEO_FILE_CANNOT_SAVE;
+ }
} else {
try {
- copyFileQ(src, destinationFileName);
- successful = true;
+ copyFileQ(new File(srcPath), destinationFileName);
} catch (IOException e) {
e.printStackTrace();
- successful = false;
+ errorCode = ERROR_MUXED_VIDEO_FILE_CANNOT_SAVE;
}
}
- return null;
- }
-
- @Override
- protected void onPostExecute(Void aVoid) {
- super.onPostExecute(aVoid);
- if (successful) {
- copyFileAsyncTaskListener.successful(destinationFile);
- } else {
- copyFileAsyncTaskListener.failed();
- }
}
@RequiresApi(api = Build.VERSION_CODES.Q)
@@ -440,6 +497,7 @@ public class DownloadRedditVideoService extends Service {
contentValues.clear();
contentValues.put(MediaStore.Images.Media.IS_PENDING, 0);
contentResolver.update(uri, contentValues, null, null);
+ destinationFileUri = uri;
} catch (IOException e) {
if (uri != null) {
// Don't leave an orphan entry in the MediaStore
@@ -458,10 +516,11 @@ public class DownloadRedditVideoService extends Service {
File directory = getExternalStoragePublicDirectory(Environment.DIRECTORY_PICTURES);
if (directory != null) {
String directoryPath = directory.getAbsolutePath() + "/Infinity/";
- destinationFile = new File(directoryPath, outputFileName);
+ String destinationFilePath = directoryPath + outputFileName;
+ destinationFileUri = Uri.parse(destinationFilePath);
try (InputStream in = new FileInputStream(src)) {
- try (OutputStream out = new FileOutputStream(destinationFile)) {
+ try (OutputStream out = new FileOutputStream(destinationFilePath)) {
byte[] buf = new byte[1024];
int len;
while ((len = in.read(buf)) > 0) {
@@ -482,11 +541,9 @@ public class DownloadRedditVideoService extends Service {
}
}
- interface CopyFileAsyncTaskListener {
-
- void successful(File dstFile);
-
- void failed();
+ interface SaveTempMuxAndCopyAsyncTaskListener {
+ void finished(Uri destinationFileUri, int errorCode);
+ void updateProgressNotification(int stringResId);
}
}
}
generated by cgit (git). Responsive design from responsive-cgit-css. Dark theme color palette from Dracula theme