ArkivClient send_transaction fails on latest storage contract (missing ArkivEntity* ABI entries)

[cryptobench]

Summary

ArkivClient.send_transaction (and helpers like create_entities / update_entities) crash on the current golembase-op-geth storage contract with web3.exceptions.Web3ValueError: Could not find any event with matching topic. The transaction is accepted by the node, but the SDK cannot decode the logs because the ABI bundled with the SDK does not include the new ArkivEntity* events emitted on-chain.

Environment

• SDK: arkiv-sdk-python (vendored in Arkiv-Network/ctf-ideas, current HEAD)
• Node: golembase-op-geth Docker Compose stack from that repo
• Python: 3.11.13
• Platform: macOS arm64 host (Docker Desktop)

Reproduction

1. Clone https://github.com/Arkiv-Network/ctf-ideas.
2. Set up the virtualenv and install deps:

   python3.11 -m venv .venv
   source .venv/bin/activate
   pip install -U pip
   pip install -r challenges/the-lockbox/server/requirements.txt
   pip install -r challenges/the-lockbox/scripts/requirements.txt

3. Boot the local node and fund a wallet (password secret):

   cd golembase-op-geth
   docker compose up -d
   export WALLET_PASSWORD=secret
   docker compose exec -T op-geth golembase account import --privatekey 0x9e0e50eaab436bc147c947960224895674d6c9c6303cb9ba941ed04e87188576
   docker compose exec -T op-geth golembase account fund --node-url http://localhost:8545 --value 100
   docker compose exec -T op-geth golembase account balance --node-url http://localhost:8545
   cd ..

4. Export the connection variables:

   export ARKIV_RPC_URL=http://localhost:8545
   export ARKIV_WS_URL=ws://localhost:8545
   export ARKIV_PRIVATE_KEY=0x9e0e50eaab436bc147c947960224895674d6c9c6303cb9ba941ed04e87188576

5. Save the script below as scripts/repro_update_entities_failure.py and run it:

   #!/usr/bin/env python3
   """Trigger ArkivClient.update_entities failure without local fallbacks."""
   
   import asyncio
   import json
   import os
   
   from arkiv_sdk import Annotation, ArkivClient, ArkivCreate, ArkivUpdate
   
   
   async def main() -> None:
       rpc = os.environ["ARKIV_RPC_URL"]
       ws = os.environ["ARKIV_WS_URL"]
       pk = bytes.fromhex(os.environ["ARKIV_PRIVATE_KEY"][2:])
       client = await ArkivClient.create_rw_client(rpc_url=rpc, ws_url=ws, private_key=pk)
   
       payload = json.dumps({"status": "Locked", "last_attempt": "None", "correct_digits": 0}).encode()
       receipt = await client.create_entities(
           [
               ArkivCreate(
                   payload,
                   10_000,
                   [Annotation("ctf", "the-lockbox"), Annotation("team", "sdk-repro")],
                   [],
               )
           ]
       )
       lockbox_key = receipt[0].entity_key
   
       attempt_payloads = [
           ("111", 0),
           ("222", 1),
           ("333", 1),
           ("444", 2),
       ]
       for combo, correct in attempt_payloads:
           body = json.dumps(
               {
                   "status": "Unlocked!" if correct == 3 else "Locked",
                   "last_attempt": combo,
                   "correct_digits": correct,
               }
           ).encode()
           receipt = await client.update_entities(
               [
                   ArkivUpdate(
                       lockbox_key,
                       body,
                       10_000,
                       [Annotation("ctf", "the-lockbox"), Annotation("team", "sdk-repro")],
                       [],
                   )
               ]
           )
           print("update receipt", receipt)
   
       await client.disconnect()
   
   
   if __name__ == "__main__":
       asyncio.run(main())

   Command:

   python scripts/repro_update_entities_failure.py

Expected

Both create_entities and subsequent update_entities calls should return receipts without raising.

Actual

The very first create_entities call raises:

web3.exceptions.Web3ValueError: Could not find any event with matching topic

The stack trace points to ArkivClient._process_arkiv_log_receipt, which cannot resolve the emitted topic 0x73dc52f9… (the hash of ArkivEntityCreated(uint256,address,uint256,uint256)) because the SDK ABI only lists the legacy GolemBaseStorage* events. The transaction itself lands on-chain—querying storage immediately after shows the entity exists—which confirms the failure is in SDK-side log decoding.

Impact

All CTF challenge servers currently have to bypass the SDK by crafting raw ArkivTransactions (with manual gas bumps) just to keep basic create/update flows working. Please expand the bundled ABI to include the new ArkivEntity* events and adjust the receipt parsing logic accordingly so ArkivClient.update_entities works out of the box.

[cryptobench]

Quick update after digging through the vendored SDK versus the storage contract that ships with the golembase-op-geth stack:

• arkiv_sdk/constants.py still defines only the legacy GolemBaseStorage* events. On current nodes the contract emits the newer ArkivEntityCreated/Updated/Deleted/BTLExtended topics (see golembase-op-geth/golem-base/logs/arkiv.go), so ArkivClient._process_arkiv_log_receipt calls ContractEvents.get_event_by_topic(...) with an unknown topic and Web3 raises Web3ValueError: Could not find any event with matching topic.
• Because _process_arkiv_receipt iterates every log in the receipt, the exception bubbles up to create_entities / update_entities and the helpers fail before they can return a receipt, even though the transaction itself commits on-chain. This matches the crash in the repro script.

Proposed fix:

1. Extend ARKIV_ABI with the modern ArkivEntity* events (keep the legacy entries for backwards compatibility) so topic lookups succeed against current nodes. Including ArkivEntityExpired(uint256,address) would also prevent housekeeping logs from triggering the same failure when they appear.
2. Teach _process_arkiv_log_receipt to treat both naming schemes as synonyms. When decoding the modern events, map the output back onto the existing CreateEntityReturnType / UpdateEntityReturnType / ExtendEntityReturnType structures. When both the legacy and modern logs are present in the same receipt, skip returning duplicates.
3. Add a regression test that feeds a synthetic receipt containing an ArkivEntityCreated log to _process_arkiv_receipt and asserts that create_entities returns a single entry.

Once the ABI includes the modern events the repro script succeeds without any local monkey patches.

[r-vdp]

Fixed now on main. We are planning to do the full migration to arkiv events soon. I will cut a release later today.

[cryptobench]

Thanks looking forward to testing the release.

[r-vdp]

I released 0.2.2 on PyPi.