Disable inline message processing for internal users.

fork-5.53.8
Greyson Parrelli 2021-03-25 12:35:58 -04:00 zatwierdzone przez Alex Hart
rodzic f06817f00d
commit 58a32c11ec
2 zmienionych plików z 19 dodań i 29 usunięć

Wyświetl plik

@ -1,10 +1,5 @@
package org.thoughtcrime.securesms.crypto;
import net.sqlcipher.database.SQLiteDatabase;
import org.thoughtcrime.securesms.database.DatabaseFactory;
import org.thoughtcrime.securesms.dependencies.ApplicationDependencies;
import org.thoughtcrime.securesms.util.FeatureFlags;
import org.whispersystems.signalservice.api.SignalSessionLock;
import java.util.concurrent.locks.ReentrantLock;
@ -24,26 +19,25 @@ public enum DatabaseSessionLock implements SignalSessionLock {
@Override
public Lock acquire() {
if (FeatureFlags.internalUser()) {
SQLiteDatabase db = DatabaseFactory.getInstance(ApplicationDependencies.getApplication()).getRawDatabase();
LEGACY_LOCK.lock();
return LEGACY_LOCK::unlock;
if (db.isDbLockedByCurrentThread()) {
return () -> {};
}
db.beginTransaction();
ownerThreadId = Thread.currentThread().getId();
return () -> {
ownerThreadId = -1;
db.setTransactionSuccessful();
db.endTransaction();
};
} else {
LEGACY_LOCK.lock();
return LEGACY_LOCK::unlock;
}
// TODO [greyson][db] Revisit after improving database locking
// SQLiteDatabase db = DatabaseFactory.getInstance(ApplicationDependencies.getApplication()).getRawDatabase();
//
// if (db.isDbLockedByCurrentThread()) {
// return () -> {};
// }
//
// db.beginTransaction();
//
// ownerThreadId = Thread.currentThread().getId();
//
// return () -> {
// ownerThreadId = -1;
// db.setTransactionSuccessful();
// db.endTransaction();
// };
}
/**

Wyświetl plik

@ -100,11 +100,7 @@ public class IncomingMessageProcessor {
}
private @Nullable String processMessage(@NonNull SignalServiceEnvelope envelope) {
if (FeatureFlags.internalUser()) {
return processMessageInline(envelope);
} else {
return processMessageDeferred(envelope);
}
return processMessageDeferred(envelope);
}
private @Nullable String processMessageDeferred(@NonNull SignalServiceEnvelope envelope) {