test: swap OSMO for BLD with receiver on Agoric

Author: Jorge-Lopes

multichain-testing/scripts/create-osmosis-pool.sh

@@ -186,3 +186,59 @@ echo "Querying pool route ..."
 )
 
 echo "Liquidity Pool open and stored on swaprouter successfully."
+
+SET_REVERSE_ROUTE_JSON=$(jq -n \
+  --arg tokenIn "$TOKEN_OUT_DENOM" \
+  --arg tokenOut "$TOKEN_IN_DENOM" \
+  --arg poolId "$POOL_ID" \
+  '{
+    set_route: {
+      input_denom: $tokenIn,
+      output_denom: $tokenOut,
+      pool_route: [
+        {
+          pool_id: $poolId,
+          token_out_denom: $tokenOut
+        }
+      ]
+    }
+  }')
+
+GET_REVERSE_ROUTE_JSON=$(jq -n \
+  --arg tokenIn "$TOKEN_OUT_DENOM" \
+  --arg tokenOut "$TOKEN_IN_DENOM" \
+  '{
+  "get_route": {
+    "input_denom": $tokenIn,
+    "output_denom": $tokenOut
+  }
+}')
+
+echo "Storing reverse pool on swaprouter contract ..."
+osmosis-exec tx wasm execute "$SWAPROUTER_ADDRESS" "$SET_REVERSE_ROUTE_JSON" --from "$SWAPROUTER_OWNER_ADDRESS" --chain-id osmosislocal --yes --fees 1000uosmo
+
+echo "Querying reverse pool route ..."
+(
+  set +e # handle failure of "osmosis-exec query wasm contract-state smart"
+
+  for ((i = 1; i <= MAX_RETRIES; i++)); do
+    echo "Attempt $i of $MAX_RETRIES..."
+    pool_route_json=$(osmosis-exec query wasm contract-state smart "$SWAPROUTER_ADDRESS" "$GET_REVERSE_ROUTE_JSON" 2> /dev/null)
+
+    if [[ $? -eq 0 ]]; then
+      echo "Pool route found:"
+      echo "$pool_route_json"
+      break
+    fi
+
+    if [[ $i -eq MAX_RETRIES ]]; then
+      echo "Pool not stored after $MAX_RETRIES attempts."
+      exit 1
+    fi
+
+    echo "Query failed. Waiting $DELAY seconds before retrying..."
+    sleep "$DELAY"
+  done
+)
+
+echo "Reverse liquidity Pool open and stored on swaprouter successfully."

multichain-testing/test/xcs-swap-anything/swap-anything.test.ts

@@ -166,6 +166,91 @@ test.serial('BLD for OSMO, receiver on Agoric', async t => {
   );
 });
 
+test.serial('OSMO for BLD, receiver on Agoric', async t => {
+  const {
+    wallets,
+    provisionSmartWallet,
+    vstorageClient,
+    retryUntilCondition,
+    useChain,
+  } = t.context;
+
+  // Provision the Agoric smart wallet
+  const agoricAddr = wallets.agoricReceiver;
+  const wdUser = await provisionSmartWallet(agoricAddr, {
+    BLD: 1000n,
+    IST: 1000n,
+  });
+  t.log(`Provisioned Agoric smart wallet for ${agoricAddr}`);
+
+  const { swapAddress } = await getXcsContractsAddress();
+
+  const doOffer = makeDoOffer(wdUser);
+
+  // Verify deposit
+  const apiUrl = await useChain('agoric').getRestEndpoint();
+  const queryClient = makeQueryClient(apiUrl);
+
+  const brands = await vstorageClient.queryData('published.agoricNames.brand');
+  const bldBrand = Object.fromEntries(brands).OSMO;
+  const swapInAmount = AmountMath.make(bldBrand, 75n);
+  const { balances: balancesBefore } = await queryClient.queryBalances(
+    wallets.agoricReceiver,
+  );
+
+  const osmosisApiUrl = await useChain('osmosis').getRestEndpoint();
+  const osmosisQueryClient = makeQueryClient(osmosisApiUrl);
+
+  const agoricChainId = useChain('agoric').chain.chain_id;
+
+  const {
+    transferChannel: { channelId },
+  } = starshipChainInfo.osmosis.connections[agoricChainId];
+
+  const { hash: outDenomHash } = await osmosisQueryClient.queryDenom(
+    `transfer/${channelId}`,
+    'ubld',
+  );
+
+  // Send swap offer
+  const makeAccountOfferId = `swap-ubld-uosmo-${Date.now()}`;
+  await doOffer({
+    id: makeAccountOfferId,
+    invitationSpec: {
+      source: 'agoricContract',
+      instancePath: [contractName],
+      callPipe: [['makeSendInvitation']],
+    },
+    offerArgs: {
+      // TODO: get the contract address dynamically
+      destAddr: swapAddress,
+      receiverAddr: wallets.agoricReceiver,
+      outDenom: `ibc/${outDenomHash}`,
+      slippage: { slippagePercentage: '20', windowSeconds: 10 },
+      onFailedDelivery: 'do_nothing',
+    },
+    proposal: { give: { Send: swapInAmount } },
+  });
+
+  const { balances: agoricReceiverBalances } = await retryUntilCondition(
+    () => queryClient.queryBalances(wallets.agoricReceiver),
+    ({ balances }) => {
+      const balancesBeforeAmount = BigInt(balancesBefore[0]?.amount || 0);
+      const currentBalanceAmount = BigInt(balances[0]?.amount || 0);
+      return currentBalanceAmount < balancesBeforeAmount;
+    },
+    'Deposit reflected in localOrchAccount balance',
+  );
+  t.log(agoricReceiverBalances);
+
+  t.assert(
+    BigInt(balancesBefore[0].amount) > BigInt(agoricReceiverBalances[0].amount),
+  );
+  t.assert(
+    BigInt(balancesBefore[1].amount) < BigInt(agoricReceiverBalances[1].amount),
+  );
+});
+
 test.serial('BLD for OSMO, receiver on CosmosHub', async t => {
   const {
     wallets,