Signal/Android
1
0
Fork 0
mirror of https://github.com/signalapp/Signal-Android.git synced 2025-12-22 20:18:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

Convert ThreadDatabase to kotlin.

Browse Source
This commit is contained in:
Greyson Parrelli
2022-10-24 13:18:42 -04:00
committed by Alex Hart
parent d2b72fc8b7
commit 1e88fb428d
6 changed files with 1765 additions and 1964 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
app/src/androidTest/java/org/thoughtcrime/securesms/database/ThreadDatabaseTest_pinned.kt
View File

@@ -36,7 +36,7 @@ class ThreadDatabaseTest_pinned {
SignalDatabase.mms.deleteMessage(messageId)
// THEN
val pinned = SignalDatabase.threads.pinnedThreadIds
val pinned = SignalDatabase.threads.getPinnedThreadIds()
assertTrue(threadId in pinned)
}
@@ -51,7 +51,7 @@ class ThreadDatabaseTest_pinned {
SignalDatabase.mms.deleteMessage(messageId)
// THEN
val unarchivedCount = SignalDatabase.threads.unarchivedConversationListCount
val unarchivedCount = SignalDatabase.threads.getUnarchivedConversationListCount()
assertEquals(1, unarchivedCount)
}

4
app/src/main/java/org/thoughtcrime/securesms/database/RecipientDatabase.kt
View File

@@ -3162,7 +3162,7 @@ open class RecipientDatabase(context: Context, databaseHelper: SignalDatabase) :
val recipientsWithinInteractionThreshold: MutableSet<RecipientId> = LinkedHashSet()
threadDatabase.readerFor(threadDatabase.getRecentPushConversationList(-1, false)).use { reader ->
var record: ThreadRecord? = reader.next
var record: ThreadRecord? = reader.getNext()
while (record != null && record.date > lastInteractionThreshold) {
val recipient = Recipient.resolved(record.recipient.id)
@@ -3171,7 +3171,7 @@ open class RecipientDatabase(context: Context, databaseHelper: SignalDatabase) :
} else {
recipientsWithinInteractionThreshold.add(recipient.id)
}
record = reader.next
record = reader.getNext()
}
}

1950
app/src/main/java/org/thoughtcrime/securesms/database/ThreadDatabase.java
View File

File diff suppressed because it is too large Load Diff

1759
app/src/main/java/org/thoughtcrime/securesms/database/ThreadDatabase.kt Normal file
View File

File diff suppressed because it is too large Load Diff

4
app/src/main/java/org/thoughtcrime/securesms/stories/tabs/ConversationListTabRepository.kt
View File

@@ -17,9 +17,9 @@ class ConversationListTabRepository {
fun getNumberOfUnreadConversations(): Observable<Long> {
return Observable.create<Long> {
fun refresh() {
it.onNext(SignalDatabase.threads.unreadThreadCount)
it.onNext(SignalDatabase.threads.getUnreadThreadCount())
val ids = SignalDatabase.threads.unreadThreadIdList
val ids = SignalDatabase.threads.getUnreadThreadIdList()
Log.d(TAG, "Unread threads: { $ids }")
}

8
core-util/src/main/java/org/signal/core/util/CursorUtil.java
View File

@@ -104,12 +104,4 @@ public final class CursorUtil {
return row.toString();
}
public static @Nullable <T> T getAggregateOrDefault(@NonNull Cursor cursor, @Nullable T defaultValue, @NonNull Function<Integer, T> cursorColumnFn) {
if (cursor.moveToFirst()) {
return cursorColumnFn.apply(0);
} else {
return defaultValue;
}
}
}