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

check for existing account IDs

Browse Source
This commit is contained in:
adbenitez
2025-11-28 01:26:51 +01:00
parent 35f6a06406
commit c938c4dcd9
1 changed files with 22 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/org/thoughtcrime/securesms/webxdc/WebxdcGarbageCollectionWorker.java
+22 -12
View File
@@ -12,6 +12,7 @@ import chat.delta.rpc.RpcException;
import com.google.common.util.concurrent.ListenableFuture;
import java.util.Collections;
import java.util.List;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
import org.thoughtcrime.securesms.connect.DcHelper;
@@ -42,23 +43,32 @@ public class WebxdcGarbageCollectionWorker extends ListenableWorker {
return;
}
List<Integer> accounts;
try {
accounts = rpc.getAllAccountIds();
} catch (RpcException e) {
Log.e(TAG, "error calling rpc.getAllAccountIds()", e);
completer.set(Result.failure());
return;
}
for (Object key : origins.keySet()) {
String url = (String)key;
Matcher m = WEBXDC_URL_PATTERN.matcher(url);
if (m.matches()) {
int accId = Integer.parseInt(m.group(1));
int accId = m.matches()? Integer.parseInt(m.group(1)) : 0;
if (accId != 0 && accounts.contains(accId)) {
int msgId = Integer.parseInt(m.group(2));
boolean delete;
try {
delete = rpc.getExistingMsgIds(accId, Collections.singletonList(msgId)).isEmpty();
} catch (RpcException ignore) {
delete = true; // account doesn't exist anymore, clean storage
}
if (delete) {
webStorage.deleteOrigin(url);
Log.i(TAG, String.format("Deleted webxdc origin: %s", url));
} else {
Log.i(TAG, String.format("Existing webxdc origin: %s", url));
if (rpc.getExistingMsgIds(accId, Collections.singletonList(msgId)).isEmpty()) {
webStorage.deleteOrigin(url);
Log.i(TAG, String.format("Deleted webxdc origin: %s", url));
} else {
Log.i(TAG, String.format("Existing webxdc origin: %s", url));
}
} catch (RpcException e) {
Log.e(TAG, "error calling rpc.getExistingMsgIds()", e);
completer.set(Result.failure());
return;
}
} else { // old webxdc URL schemes, etc
webStorage.deleteOrigin(url);