Feature/snapshot (#2)

* Snapshot api

* Network snapshot api

Co-authored-by: SeniorZhai <[email protected]>

Author: crossle

library/src/main/kotlin/one/mixin/bot/api/call/SnapshotCallService.kt

@@ -49,4 +49,15 @@ interface SnapshotCallService {
         @Query("destination") destination: String? = null,
         @Query("tag") tag: String? = null
     ): Call<MixinResponse<List<Snapshot>>>
+
+    @GET("/network/snapshots/{id}")
+    fun networkSnapshotCall(@Path("id") snapshotId: String): Call<MixinResponse<Snapshot>>
+
+    @GET("/network/snapshots/")
+    fun networkSnapshotsCall(
+        @Query("asset") assetId: String,
+        @Query("offset") offset: String? = null,
+        @Query("limit") limit: Int = LIMIT,
+        @Query("order") order: String? = null
+    ): Call<MixinResponse<List<Snapshot>>>
 }

library/src/main/kotlin/one/mixin/bot/api/coroutine/SnapshotCoroutineService.kt

@@ -48,4 +48,15 @@ interface SnapshotCoroutineService {
         @Query("destination") destination: String? = null,
         @Query("tag") tag: String? = null
     ): MixinResponse<List<Snapshot>>
+
+    @GET("/network/snapshots/{id}")
+    suspend fun networkSnapshot(@Path("id") snapshotId: String): MixinResponse<Snapshot>
+
+    @GET("/network/snapshots/")
+    suspend fun networkSnapshots(
+        @Query("asset") assetId: String,
+        @Query("offset") offset: String? = null,
+        @Query("limit") limit: Int = SnapshotService.LIMIT,
+        @Query("order") order: String? = null
+    ): MixinResponse<List<Snapshot>>
 }

samples/src/main/java/jvmMain/java/Sample.java

@@ -82,6 +82,9 @@ public static void main(String[] args) {
             receivers.add("087e91ff-7169-451a-aaaa-5b3297411a4b");
             receivers.add("105f6e8b-d249-4b4d-9beb-e03cefaebc37");
             transactions(client, receivers, pinToken, pin);
+
+            networkSnapshot(client, "c8e73a02-b543-4100-bd7a-879ed4accdfc");
+            networkSnapshots(client, CNB_assetId);
         } catch (InterruptedException | IOException e) {
             System.out.println(e.getMessage());
         }
@@ -254,4 +257,24 @@ private static void transactions(HttpClient client, List<String> receivers, Stri
             System.out.printf("Transactions fail: %s", Objects.requireNonNull(transactionResponse.getError()).getDescription());
         }
     }
+
+    private static void networkSnapshot(HttpClient client, String snapshotId) throws IOException {
+        MixinResponse<Snapshot> snapshotResponse = client.getSnapshotService().networkSnapshotCall(snapshotId).execute().body();
+        assert snapshotResponse != null;
+        if (snapshotResponse.isSuccess()) {
+            System.out.printf("Success: %s%n", Objects.requireNonNull(snapshotResponse.getData()).getSnapshotId());
+        } else {
+            System.out.printf("Fail: %s", Objects.requireNonNull(snapshotResponse.getError()).getDescription());
+        }
+    }
+
+    private static void networkSnapshots(HttpClient client, String assetId) throws IOException {
+        MixinResponse<List<Snapshot>> snapshotResponse = client.getSnapshotService().networkSnapshotsCall(assetId, null, 10, "ASC").execute().body();
+        assert snapshotResponse != null;
+        if (snapshotResponse.isSuccess()) {
+            System.out.printf("Success: %d%n", Objects.requireNonNull(snapshotResponse.getData()).size());
+        } else {
+            System.out.printf("Fail: %s", Objects.requireNonNull(snapshotResponse.getError()).getDescription());
+        }
+    }
 }

samples/src/main/java/jvmMain/kotlin/Sample.kt

@@ -98,6 +98,8 @@ fun main() = runBlocking {
     // Transactions
     transactions(client, pinToken)
 
+    networkSnapshots(client, CNB_ID)
+    networkSnapshot(client, "c8e73a02-b543-4100-bd7a-879ed4accdfc")
     return@runBlocking
 }
 
@@ -265,4 +267,28 @@ private suspend fun transactions(
     } else {
         println("Transactions fail")
     }
+}
+
+private suspend fun networkSnapshot(
+    client: HttpClient,
+    snapshotId: String
+) {
+    val snapshotResponse = client.snapshotService.networkSnapshot(snapshotId)
+    if (snapshotResponse.isSuccess()) {
+        println("Success: ${snapshotResponse.data?.snapshotId}")
+    } else {
+        println("Fail")
+    }
+}
+
+private suspend fun networkSnapshots(
+    client: HttpClient,
+    assetId: String
+) {
+    val snapshotResponse = client.snapshotService.networkSnapshots(assetId)
+    if (snapshotResponse.isSuccess()) {
+        println("Success: ${snapshotResponse.data?.size}")
+    } else {
+        println("Fail: ${snapshotResponse.error?.description}")
+    }
 }