Add transactions api

Author: SeniorZhai

build.gradle

@@ -1,6 +1,6 @@
 // Top-level build file where you can add configuration options common to all sub-projects/modules.
 buildscript {
-    ext.kotlinVersion = '1.4.21'
+    ext.kotlinVersion = '1.4.32'
     ext.okhttpVersion = '4.9.0'
     ext.gsonVersion = '2.8.6'
     ext.jjwtVersion = 'd6feebe558'

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

@@ -7,8 +7,12 @@ import one.mixin.bot.vo.Fiat
 import one.mixin.bot.vo.PendingDeposit
 import one.mixin.bot.vo.Ticker
 import one.mixin.bot.vo.TopAsset
+import one.mixin.bot.vo.TransactionRequest
+import one.mixin.bot.vo.TransactionResponse
 import retrofit2.Call
+import retrofit2.http.Body
 import retrofit2.http.GET
+import retrofit2.http.POST
 import retrofit2.http.Path
 import retrofit2.http.Query
 
@@ -44,4 +48,7 @@ interface AssetCallService {
 
     @GET("assets/{id}/fee")
     fun assetsFeeCall(@Path("id") id: String): Call<MixinResponse<AssetFee>>
+
+    @POST("transactions")
+    fun transactionsCall(@Body request: TransactionRequest): Call<MixinResponse<TransactionResponse>>
 }

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

@@ -7,7 +7,11 @@ import one.mixin.bot.vo.Fiat
 import one.mixin.bot.vo.PendingDeposit
 import one.mixin.bot.vo.Ticker
 import one.mixin.bot.vo.TopAsset
+import one.mixin.bot.vo.TransactionRequest
+import one.mixin.bot.vo.TransactionResponse
+import retrofit2.http.Body
 import retrofit2.http.GET
+import retrofit2.http.POST
 import retrofit2.http.Path
 import retrofit2.http.Query
 
@@ -42,4 +46,7 @@ interface AssetCoroutineService {
 
     @GET("assets/{id}/fee")
     suspend fun assetsFee(@Path("id") id: String): MixinResponse<AssetFee>
+
+    @POST("transactions")
+    suspend fun transactions(@Body request: TransactionRequest): MixinResponse<TransactionResponse>
 }

library/src/main/kotlin/one/mixin/bot/vo/TransactionRequest.kt

@@ -0,0 +1,20 @@
+package one.mixin.bot.vo
+
+import com.google.gson.annotations.SerializedName
+
+data class TransactionRequest(
+    @SerializedName("asset_id")
+    val assetId: String,
+    @SerializedName("opponent_multisig")
+    val opponentMultisig: OpponentMultisig,
+    val amount: String,
+    val pin: String,
+    @SerializedName("trace_id")
+    val traceId: String?,
+    val memo: String?
+)
+
+data class OpponentMultisig(
+    val receivers: List<String>,
+    val threshold: Int
+)

library/src/main/kotlin/one/mixin/bot/vo/TransactionResponse.kt

@@ -0,0 +1,21 @@
+package one.mixin.bot.vo
+
+import com.google.gson.annotations.SerializedName
+
+data class TransactionResponse(
+    val type: String,
+    @SerializedName("snapshot_id")
+    val snapshotId: String,
+    @SerializedName("opponent_receivers")
+    val opponentReceivers: List<String>,
+    @SerializedName("opponent_threshold")
+    val opponentThreshold: Int,
+    @SerializedName("asset_id")
+    val assetId: String,
+    val amount: String,
+    @SerializedName("trace_id")
+    val traceId: String,
+    val memo: String?,
+    @SerializedName("created_at")
+    val createdAt: String
+)

samples/build.gradle

@@ -9,8 +9,8 @@ java {
 }
 
 dependencies {
-     implementation project(':library')
-//    implementation 'com.github.MixinNetwork:bot-api-kotlin-client:main-SNAPSHOT'
+    implementation project(':library')
+    // implementation 'com.github.MixinNetwork:bot-api-kotlin-client:main-SNAPSHOT'
 
     // Kotlin
     implementation "org.jetbrains.kotlin:kotlin-stdlib:$kotlinVersion"

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

@@ -42,7 +42,7 @@ public static void main(String[] args) {
             // decrypt pin token
             String userAesKey;
             EdDSAPrivateKey userPrivateKey = (EdDSAPrivateKey) sessionKey.getPrivate();
-            userAesKey = base64Encode(calculateAgreement(base64Decode(user.getPinToken()), userPrivateKey));
+            userAesKey = base64Encode(calculateAgreement(Objects.requireNonNull(base64Decode(user.getPinToken())), userPrivateKey));
 
             // get fiats
             getFiats(client);
@@ -76,6 +76,12 @@ public static void main(String[] args) {
             client.setUserToken(null);
             // Send text message
             sendTextMessage(client, "639ec50a-d4f1-4135-8624-3c71189dcdcc", "Test message");
+
+            List<String> receivers = new ArrayList<>();
+            receivers.add("00c5a4ae-dcdc-48db-ab8e-a7eef69b441d");
+            receivers.add("087e91ff-7169-451a-aaaa-5b3297411a4b");
+            receivers.add("105f6e8b-d249-4b4d-9beb-e03cefaebc37");
+            transactions(client, receivers, pinToken, pin);
         } catch (InterruptedException | IOException e) {
             System.out.println(e.getMessage());
         }
@@ -192,7 +198,7 @@ private static void getFiats(HttpClient client) throws IOException {
         MixinResponse<List<Fiat>> fiatsResponse = client.getAssetService().getFiatsCall().execute().body();
         assert fiatsResponse != null;
         if (fiatsResponse.isSuccess()) {
-            System.out.printf("Fiats success: %f%n", fiatsResponse.getData().get(0).getRate());
+            System.out.printf("Fiats success: %f%n", Objects.requireNonNull(fiatsResponse.getData()).get(0).getRate());
         } else {
             System.out.println("Fiats fail");
         }
@@ -216,6 +222,7 @@ private static void sendTextMessage(HttpClient client, String recipientId, Strin
                 Base64.getEncoder().encodeToString(text.getBytes()), null, null
         ));
         MixinResponse messageResponse = client.getMessageService().postMessageCall(messageRequests).execute().body();
+        assert messageResponse != null;
         if (messageResponse.isSuccess()) {
             System.out.println("Send success");
         } else {
@@ -232,4 +239,19 @@ private static SessionToken getUserToken(User user, KeyPair sessionKey, boolean
         }
     }
 
+
+    private static void transactions(HttpClient client, List<String> receivers, String aseKey, String pin) throws IOException {
+        MixinResponse<TransactionResponse> transactionResponse = client.getAssetService().transactionsCall(
+                new TransactionRequest(Sample.CNB_assetId, new OpponentMultisig(
+                        receivers,
+                        2
+                ), Sample.amount, encryptPin(aseKey, pin, System.nanoTime())
+                        , null, null)).execute().body();
+        assert transactionResponse != null;
+        if (transactionResponse.isSuccess()) {
+            System.out.printf("TransactionsResponse success: %s%n", Objects.requireNonNull(transactionResponse.getData()).getSnapshotId());
+        } else {
+            System.out.printf("Transactions fail: %s", Objects.requireNonNull(transactionResponse.getError()).getDescription());
+        }
+    }
 }

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

@@ -16,7 +16,9 @@ import one.mixin.bot.util.generateEd25519KeyPair
 import one.mixin.bot.util.getEdDSAPrivateKeyFromString
 import one.mixin.bot.vo.AccountRequest
 import one.mixin.bot.vo.AddressRequest
+import one.mixin.bot.vo.OpponentMultisig
 import one.mixin.bot.vo.PinRequest
+import one.mixin.bot.vo.TransactionRequest
 import one.mixin.bot.vo.TransferRequest
 import one.mixin.bot.vo.User
 import one.mixin.bot.vo.WithdrawalRequest
@@ -27,7 +29,7 @@ import java.util.UUID
 const val CNB_ID = "965e5c6e-434c-3fa9-b780-c50f43cd955c"
 const val BTC_ID = "c6d0c728-2624-429b-8e0d-d9d19b6592fa"
 const val DEFAULT_PIN = "131416"
-const val DEFAULT_AMOUNT = "2"
+const val DEFAULT_AMOUNT = "1"
 
 fun main() = runBlocking {
     val key = getEdDSAPrivateKeyFromString(Config.privateKey)
@@ -92,6 +94,10 @@ fun main() = runBlocking {
     client.setUserToken(null)
     // Send text message
     sendTextMessage(client, "639ec50a-d4f1-4135-8624-3c71189dcdcc", "Text message")
+
+    // Transactions
+    transactions(client, pinToken)
+
     return@runBlocking
 }
 
@@ -228,9 +234,35 @@ private suspend fun sendTextMessage(client: HttpClient, recipientId: String, tex
             )
         )
     )
-    if(response.isSuccess()){
+    if (response.isSuccess()) {
         println("Send success")
-    }else{
+    } else {
         println("Send fail")
     }
+}
+
+private suspend fun transactions(
+    client: HttpClient,
+    userAesKey: String,
+) {
+    // Transactions
+    val transactionsResponse = client.assetService.transactions(
+        TransactionRequest(
+            CNB_ID,
+            OpponentMultisig(listOf("00c5a4ae-dcdc-48db-ab8e-a7eef69b441d", "087e91ff-7169-451a-aaaa-5b3297411a4b", "4e0e6e6b-6c9d-4e99-b7f1-1356322abec3"), 2),
+            DEFAULT_AMOUNT,
+            encryptPin(
+                userAesKey,
+                DEFAULT_PIN,
+                System.nanoTime()
+            ),
+            UUID.randomUUID().toString(),
+            "memo"
+        )
+    )
+    if (transactionsResponse.isSuccess()) {
+        println("Transactions success: ${transactionsResponse.data?.snapshotId}")
+    } else {
+        println("Transactions fail")
+    }
 }