awesome-bookmarks/arcanechat-android
3
0
Fork 0
mirror of https://github.com/ArcaneChat/android.git synced 2026-07-03 14:05:24 +02:00
Code Issues Packages Projects Releases 3 Wiki Activity

apply code formatter

Browse Source
This commit is contained in:
adbenitez
2026-03-11 18:53:16 +01:00
parent efb4bf0536
commit ae7be8a841
674 changed files with 24629 additions and 21640 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/org/thoughtcrime/securesms/ResolveMediaTask.java
+100 -95
View File
@@ -8,112 +8,117 @@ import android.net.Uri;
import android.os.AsyncTask;
import android.provider.OpenableColumns;
import android.util.Log;
import org.thoughtcrime.securesms.providers.PersistentBlobProvider;
import de.cketti.safecontentresolver.SafeContentResolver;
import java.io.FileNotFoundException;
import java.io.InputStream;
import java.lang.ref.WeakReference;
import java.util.HashSet;
import de.cketti.safecontentresolver.SafeContentResolver;
import org.thoughtcrime.securesms.providers.PersistentBlobProvider;
public class ResolveMediaTask extends AsyncTask<Uri, Void, Uri> {
private static final String TAG = ResolveMediaTask.class.getSimpleName();
private static final String TAG = ResolveMediaTask.class.getSimpleName();
interface OnMediaResolvedListener {
void onMediaResolved(Uri uri);
interface OnMediaResolvedListener {
void onMediaResolved(Uri uri);
}
private final WeakReference<Activity> contextRef;
private final WeakReference<OnMediaResolvedListener> listenerWeakReference;
private static final HashSet<ResolveMediaTask> instances = new HashSet<>();
ResolveMediaTask(Activity activityContext, ResolveMediaTask.OnMediaResolvedListener listener) {
this.contextRef = new WeakReference<>(activityContext);
this.listenerWeakReference = new WeakReference<>(listener);
instances.add(this);
}
@Override
protected Uri doInBackground(Uri... uris) {
try {
Uri uri = uris[0];
if (uris.length != 1 || uri == null) {
return null;
}
InputStream inputStream;
String fileName = null;
Long fileSize = null;
SafeContentResolver safeContentResolver = SafeContentResolver.newInstance(contextRef.get());
inputStream = safeContentResolver.openInputStream(uri);
if (inputStream == null) {
return null;
}
Cursor cursor =
contextRef
.get()
.getContentResolver()
.query(
uri,
new String[] {OpenableColumns.DISPLAY_NAME, OpenableColumns.SIZE},
null,
null,
null);
try {
if (cursor != null && cursor.moveToFirst()) {
try {
fileName = cursor.getString(cursor.getColumnIndexOrThrow(OpenableColumns.DISPLAY_NAME));
fileSize = cursor.getLong(cursor.getColumnIndexOrThrow(OpenableColumns.SIZE));
} catch (IllegalArgumentException e) {
Log.w(TAG, e);
}
}
} finally {
if (cursor != null) cursor.close();
}
private final WeakReference<Activity> contextRef;
private final WeakReference<OnMediaResolvedListener> listenerWeakReference;
if (fileName == null) {
fileName = uri.getLastPathSegment();
}
private static final HashSet<ResolveMediaTask> instances = new HashSet<>();
ResolveMediaTask(Activity activityContext, ResolveMediaTask.OnMediaResolvedListener listener) {
this.contextRef = new WeakReference<>(activityContext);
this.listenerWeakReference = new WeakReference<>(listener);
instances.add(this);
}
@Override
protected Uri doInBackground(Uri... uris) {
try {
Uri uri = uris[0];
if (uris.length != 1 || uri == null) {
return null;
}
InputStream inputStream;
String fileName = null;
Long fileSize = null;
SafeContentResolver safeContentResolver = SafeContentResolver.newInstance(contextRef.get());
inputStream = safeContentResolver.openInputStream(uri);
if (inputStream == null) {
return null;
}
Cursor cursor = contextRef.get().getContentResolver().query(uri, new String[]{OpenableColumns.DISPLAY_NAME, OpenableColumns.SIZE}, null, null, null);
try {
if (cursor != null && cursor.moveToFirst()) {
try {
fileName = cursor.getString(cursor.getColumnIndexOrThrow(OpenableColumns.DISPLAY_NAME));
fileSize = cursor.getLong(cursor.getColumnIndexOrThrow(OpenableColumns.SIZE));
} catch (IllegalArgumentException e) {
Log.w(TAG, e);
}
}
} finally {
if (cursor != null) cursor.close();
}
if (fileName == null) {
fileName = uri.getLastPathSegment();
}
String mimeType = getMimeType(contextRef.get(), uri);
return PersistentBlobProvider.getInstance().create(contextRef.get(), inputStream, mimeType, fileName, fileSize);
} catch (NullPointerException | FileNotFoundException ioe) {
Log.w(TAG, ioe);
return null;
}
}
@Override
protected void onPostExecute(Uri uri) {
instances.remove(this);
if (!this.isCancelled()) {
listenerWeakReference.get().onMediaResolved(uri);
}
}
@Override
protected void onCancelled() {
instances.remove(this);
super.onCancelled();
listenerWeakReference.get().onMediaResolved(null);
}
public static boolean isExecuting() {
return !instances.isEmpty();
}
public static void cancelTasks() {
for (ResolveMediaTask task : instances) {
task.cancel(true);
}
}
private boolean hasFileScheme(Uri uri) {
if (uri == null) {
return false;
}
return "file".equals(uri.getScheme());
String mimeType = getMimeType(contextRef.get(), uri);
return PersistentBlobProvider.getInstance()
.create(contextRef.get(), inputStream, mimeType, fileName, fileSize);
} catch (NullPointerException | FileNotFoundException ioe) {
Log.w(TAG, ioe);
return null;
}
}
@Override
protected void onPostExecute(Uri uri) {
instances.remove(this);
if (!this.isCancelled()) {
listenerWeakReference.get().onMediaResolved(uri);
}
}
@Override
protected void onCancelled() {
instances.remove(this);
super.onCancelled();
listenerWeakReference.get().onMediaResolved(null);
}
public static boolean isExecuting() {
return !instances.isEmpty();
}
public static void cancelTasks() {
for (ResolveMediaTask task : instances) {
task.cancel(true);
}
}
private boolean hasFileScheme(Uri uri) {
if (uri == null) {
return false;
}
return "file".equals(uri.getScheme());
}
}