[Fix] Use a single swap and claim in the Python example

Author: iamalwaysuncomfortable

shield-swap-sdk/examples/first-swap/README.md

@@ -41,16 +41,17 @@ ID. Job completion does not guarantee every token transfer succeeded.
 The faucet allows one request per address per 15 minutes. A rate-limit error
 stops the example; inspect the existing funding before requesting again.
 The example waits for the scanner to report at least 1.5 USDCx before trading.
-It finds
-a direct USDCx/ETH pool and calls `swap_many(count=1)`, which quotes the trade,
-selects a token record, and records the submitted handle in the SDK journal.
+It quotes a direct USDCx/ETH pool with `get_route()`, then calls
+`swap(...).delegate(wait=True)` with that quote and a 0.5% slippage limit.
+The SDK selects a token record and saves the swap handle in its journal.
 One unspent record must cover 1.5 USDCx.
 
 ## Completion and recovery
 
-A successful run ends after `collect_all()` reports the swap's claim.
-`claim["transaction_id"]` identifies the claim and `claim["amount_out"]`
-contains the received ETH in base units. The example writes no console logs
+After the swap confirms, `claim_swap_output(handle).delegate(wait=True)`
+submits one claim and waits for confirmation. The example records the claim
+in the SDK journal. `claim.transaction_id` identifies the claim and
+`claim.amount_out` contains the received ETH in base units. The example writes no console logs
 or additional result files.
 
 Each run submits a new trade. To recover an interrupted run, load the same

shield-swap-sdk/examples/first-swap/swap.py

@@ -1,5 +1,6 @@
 """Create and fund a testnet account, swap 1.5 USDCx for ETH, and claim the output."""
 import time
+from decimal import Decimal
 
 from aleo import testnet
 
@@ -44,26 +45,27 @@
     else:
         raise RuntimeError("USDCx is not available; inspect funding.results and the account balance")
 
-    # Submit one swap with a 0.5% slippage limit. The SDK journals its handle.
-    swaps = dex.swap_many(
+    # Quote the selected pool and convert the expected ETH output to base units.
+    quote = dex.api.get_route(
+        token_in=source.id, token_out=target.id, amount_in="1.5", pool_key=pool.key,
+    )
+    if not quote.estimated_amount_out:
+        raise RuntimeError("The selected pool returned no quote")
+    expected_out = int(Decimal(quote.estimated_amount_out) * 10**target.decimals)
+    if expected_out <= 0:
+        raise RuntimeError("The quote returned no ETH")
+
+    # Submit one swap and wait for confirmation. The SDK journals its handle.
+    handle = dex.swap(
         pool_key=pool.key,
         token_in_id=source.id,
         amount_in=amount_in,
-        count=1,
+        expected_out=expected_out,
         slippage_bps=50,
-    )
-    if swaps.failures or len(swaps.handles) != 1:
-        raise RuntimeError("Swap submission needs inspection; use the SDK journal before retrying")
+    ).delegate(wait=True)
 
-    # Collect the output after confirmation, without submitting another swap.
-    for attempt in range(40):
-        claims = dex.collect_all()
-        claim = next((item for item in claims.claimed
-                      if item["swap_id"] == swaps.handles[0].swap_id), None)
-        if claim is not None:
-            if claim["amount_out"] <= 0:
-                raise RuntimeError("The claim returned no ETH")
-            break
-        time.sleep(15)
-    else:
-        raise RuntimeError("Claim is still pending; resume with dex.collect_all()")
+    # Claim the confirmed swap's output once, then update the SDK journal.
+    claim = dex.claim_swap_output(handle).delegate(wait=True)
+    dex.journal.record_claim(handle.swap_id, claim.transaction_id, claim.amount_out)
+    if claim.amount_out <= 0:
+        raise RuntimeError("The claim returned no ETH")