Revert "Convert ThreadDatabase to kotlin."

This reverts commit 1e88fb428d.

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

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

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

@@ -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.getNext()
+      var record: ThreadRecord? = reader.next
 
       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.getNext()
+        record = reader.next
       }
     }
 

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

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

core-util/src/main/java/org/signal/core/util/CursorUtil.java

@@ -104,4 +104,12 @@ 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;
+    }
+  }
 }