From 4bb9030574f2adcb53b46a1e7b94e1f60c087729 Mon Sep 17 00:00:00 2001 From: VZ Build Date: Tue, 14 Jul 2026 17:01:58 +0000 Subject: [PATCH] Fix eth_listener wrap_ethereum_event import error --- eth_listener.py | 33 +++++++++++++++++++++++---------- 1 file changed, 23 insertions(+), 10 deletions(-) diff --git a/eth_listener.py b/eth_listener.py index 817d05b..9909122 100644 --- a/eth_listener.py +++ b/eth_listener.py @@ -9,7 +9,7 @@ import os, json, time, logging from datetime import datetime, timezone from web3 import Web3 import redis -from koreid import KoreIDGenerator, wrap_ethereum_event +from koreid import KoreIDGenerator logging.basicConfig( level=logging.INFO, @@ -125,17 +125,30 @@ class EthereumListener: if amount < 1.0: return - payload = wrap_ethereum_event( + tx_hash = log_entry['transactionHash'].hex() + block_number = log_entry['blockNumber'] + kid = self.gen.for_ethereum_anchor( + original_koreid='GENESIS-07', + tx_hash=tx_hash, + block_number=block_number, event_type=event_type, - amount=amount, - currency=token_info['currency'], - tx_hash=log_entry['transactionHash'].hex(), - block_number=log_entry['blockNumber'], - from_address=from_addr, - to_address=to_addr, - token_symbol=token_info['symbol'], - koreid_generator=self.gen, ) + from datetime import datetime, timezone + payload = { + 'koreid': kid['koreid'], + 'guid': kid['guid'], + 'step': event_type, + 'currency': token_info['currency'], + 'token_symbol': token_info['symbol'], + 'amount': amount, + 'ethereum_tx': tx_hash, + 'linked_to': 'GENESIS-07', + 'from_address': from_addr, + 'to_address': to_addr, + 'block_number': block_number, + 'anchored_at': datetime.now(timezone.utc).isoformat(), + 'genesis_root': 'GENESIS-07', + } self._queue_payload(payload)