Query Index Changes

This PR updates for the new query-index API. The original formulation of query-index was not actually very usable as it was intended.

The new query-index API returns events sorted by time for a particular content-type, and then some associated feed integrity proof stuff that can be ignored for now.

As part of this deletes need to include some extra indexing information about the original event.

Lastly where query-index was originally being used to load the latest for some set of content-types (such as username, description), there is now 'queryLatest' which handles that case.

Note that the server component of this is not currently deployed but can be whenever PlatformPlayer is ready / you want it to be.

app/src/main/java/com/futo/polycentric/core/ApiMethods.kt

@@ -77,15 +77,17 @@ class ApiMethods {
             return Protocol.Events.parseFrom(result.get())
         }
 
-        fun getQueryIndex(server: String, system: Protocol.PublicKey, eventTypes: List<Long>, limit: Int? = null): Protocol.Events {
+        fun getQueryIndex(server: String, system: Protocol.PublicKey, contentType: Long, after: Int? = null, limit: Int? = null): Protocol.QueryIndexResponse {
             val systemQuery = system.toByteArray().toBase64Url()
-            val eventTypesQuery = Protocol.RepeatedUInt64.newBuilder()
-                .addAllNumbers(eventTypes).build().toByteArray().toBase64Url()
 
-            val path = if (limit != null) {
-                "/query_index?system=$systemQuery&event_types=$eventTypesQuery&limit=$limit"
+            val path = if (after != null && limit != null) {
+                "/query_index?system=$systemQuery&content_type=$contentType&after=$after&limit=$limit"
+            } else if (limit != null) {
+                "/query_index?system=$systemQuery&content_type=$contentType&limit=$limit"
+            } else if (after != null) {
+                "/query_index?system=$systemQuery&content_type=$contentType&after=$after"
             } else {
-                "/query_index?system=$systemQuery&event_types=$eventTypesQuery"
+                "/query_index?system=$systemQuery&content_type=$contentType"
             }
             val (_, response, result) = "$server$path".httpGet()
                 .header(Headers.CONTENT_TYPE, "application/octet-stream")
@@ -96,6 +98,25 @@ class ApiMethods {
                 throw Exception(formattedMessage)
             }
 
+            return Protocol.QueryIndexResponse.parseFrom(result.get())
+        }
+
+        fun getQueryLatest(server: String, system: Protocol.PublicKey, eventTypes: List<Long>): Protocol.Events {
+            val systemQuery = system.toByteArray().toBase64Url()
+            val eventTypesQuery = Protocol.RepeatedUInt64.newBuilder()
+                .addAllNumbers(eventTypes).build().toByteArray().toBase64Url()
+
+            val path = "/query_latest?system=$systemQuery&event_types=$eventTypesQuery";
+
+            val (_, response, result) = "$server$path".httpGet()
+                .header(Headers.CONTENT_TYPE, "application/octet-stream")
+                .response()
+
+            if (!response.isSuccessful) {
+                val formattedMessage = "getQueryLatest to $server failed with status code ${response.statusCode}. Response body: ${response.body().toByteArray().decodeToString()}"
+                throw Exception(formattedMessage)
+            }
+
             return Protocol.Events.parseFrom(result.get())
         }
 
@@ -125,4 +146,4 @@ class ApiMethods {
             return Protocol.QueryReferencesResponse.parseFrom(result.get())
         }
     }
-}
\ No newline at end of file
+}