[Loopring 3.6] Demo AMM pool

packages/loopring_v3.js/src/exchange_v3.ts

@@ -675,18 +675,29 @@ export class ExchangeV3 {
 
     // Get the block data from the transaction data
     //const submitBlocksFunctionSignature = "0x8dadd3af"; // submitBlocks
-    const submitBlocksFunctionSignature = "0x14867212"; // submitBlocksCompressed
+    const submitBlocksFunctionSignature = "0x78e9a4f3"; // submitBlocksWithCallbacks
 
     const transaction = await this.web3.eth.getTransaction(
       event.transactionHash
     );
     //console.log(transaction.input);
     if (transaction.input.startsWith(submitBlocksFunctionSignature)) {
       const decodedCompressedInput = this.web3.eth.abi.decodeParameters(
-        ["bytes"],
+        [
+          "bool",
+          "bytes",
+          {
+            "struct BlockCallback[]": {
+              target: "address",
+              blockIdx: "uint",
+              txIdx: "uint",
+              auxiliaryData: "bytes"
+            }
+          }
+        ],
         "0x" + transaction.input.slice(2 + 4 * 2)
       );
-      const data = decompressZeros(decodedCompressedInput[0]);
+      const data = decompressZeros(decodedCompressedInput[1]);
       // Get the inputs to commitBlock
       const decodedInputs = this.web3.eth.abi.decodeParameters(
         [

packages/loopring_v3/circuit/Circuits/TransferCircuit.h

@@ -54,6 +54,7 @@ class TransferCircuit : public BaseTransactionCircuit
     DualVariableGadget payer_to;
     DualVariableGadget payee_toAccountID;
     DualVariableGadget maxFee;
+    DualVariableGadget putAddressesInDA;
 
     // Check if the inputs are valid
     EqualGadget isTransferTx;
@@ -93,6 +94,7 @@ class TransferCircuit : public BaseTransactionCircuit
 
     // DA optimization
     OrGadget da_NeedsToAddress;
+    OrGadget da_NeedsFromAddress;
     ArrayTernaryGadget da_To;
     ArrayTernaryGadget da_From;
 
@@ -136,6 +138,7 @@ class TransferCircuit : public BaseTransactionCircuit
           payer_to(pb, NUM_BITS_ADDRESS, FMT(prefix, ".payer_to")),
           payee_toAccountID(pb, NUM_BITS_ACCOUNT, FMT(prefix, ".payee_toAccountID")),
           maxFee(pb, NUM_BITS_AMOUNT, FMT(prefix, ".maxFee")),
+          putAddressesInDA(pb, 1, FMT(prefix, ".putAddressesInDA")),
 
           // Check if the inputs are valid
           isTransferTx( //
@@ -256,17 +259,21 @@ class TransferCircuit : public BaseTransactionCircuit
           // DA optimization
           da_NeedsToAddress(
             pb,
-            {toAccountValid.isNewAccount(), isConditional.result()},
+            {toAccountValid.isNewAccount(), isConditional.result(), putAddressesInDA.packed},
             FMT(prefix, ".da_NeedsToAddress")),
           da_To(
             pb,
             da_NeedsToAddress.result(),
             to.bits,
             VariableArrayT(NUM_BITS_ADDRESS, state.constants._0),
             FMT(prefix, ".da_To")),
+          da_NeedsFromAddress(
+            pb,
+            {isConditional.result(), putAddressesInDA.packed},
+            FMT(prefix, ".da_NeedsFromAddress")),
           da_From(
             pb,
-            isConditional.result(),
+            da_NeedsFromAddress.result(),
             from.bits,
             VariableArrayT(NUM_BITS_ADDRESS, state.constants._0),
             FMT(prefix, ".da_From")),
@@ -361,6 +368,7 @@ class TransferCircuit : public BaseTransactionCircuit
         payer_to.generate_r1cs_witness(pb, transfer.payerTo);
         payee_toAccountID.generate_r1cs_witness(pb, transfer.payeeToAccountID);
         maxFee.generate_r1cs_witness(pb, transfer.maxFee);
+        putAddressesInDA.generate_r1cs_witness(pb, transfer.putAddressesInDA);
 
         // Check if the inputs are valid
         isTransferTx.generate_r1cs_witness();
@@ -401,6 +409,7 @@ class TransferCircuit : public BaseTransactionCircuit
         // DA optimization
         da_NeedsToAddress.generate_r1cs_witness();
         da_To.generate_r1cs_witness();
+        da_NeedsFromAddress.generate_r1cs_witness();
         da_From.generate_r1cs_witness();
 
         // Fee as float
@@ -438,6 +447,7 @@ class TransferCircuit : public BaseTransactionCircuit
         payer_to.generate_r1cs_constraints(true);
         payee_toAccountID.generate_r1cs_constraints(true);
         maxFee.generate_r1cs_constraints(true);
+        putAddressesInDA.generate_r1cs_constraints(true);
 
         // Check if the inputs are valid
         isTransferTx.generate_r1cs_constraints();
@@ -478,6 +488,7 @@ class TransferCircuit : public BaseTransactionCircuit
         // DA optimization
         da_NeedsToAddress.generate_r1cs_constraints();
         da_To.generate_r1cs_constraints();
+        da_NeedsFromAddress.generate_r1cs_constraints();
         da_From.generate_r1cs_constraints();
 
         // Fee as float

packages/loopring_v3/circuit/Utils/Data.h

@@ -66,7 +66,8 @@ static auto dummyTransfer = R"({
     "payerToAccountID": 2,
     "payerTo": "2",
     "payeeToAccountID": 2,
-    "storageID": "0"
+    "storageID": "0",
+    "putAddressesInDA": false
 })"_json;
 
 static auto dummyWithdraw = R"({
@@ -437,6 +438,7 @@ class Transfer
     ethsnarks::FieldT payerTo;
     ethsnarks::FieldT payeeToAccountID;
     ethsnarks::FieldT maxFee;
+    ethsnarks::FieldT putAddressesInDA;
     ethsnarks::FieldT type;
 };
 
@@ -457,6 +459,7 @@ static void from_json(const json &j, Transfer &transfer)
     transfer.payerTo = ethsnarks::FieldT(j["payerTo"].get<std::string>().c_str());
     transfer.payeeToAccountID = ethsnarks::FieldT(j.at("payeeToAccountID"));
     transfer.maxFee = ethsnarks::FieldT(j["maxFee"].get<std::string>().c_str());
+    transfer.putAddressesInDA = ethsnarks::FieldT(j.at("putAddressesInDA").get<bool>() ? 1 : 0);
     transfer.type = ethsnarks::FieldT(j.at("type"));
 }