From 325e1cd6b644e3998c877ad0fc3b8fbfe77a8392 Mon Sep 17 00:00:00 2001
From: VZ Build <vz@979labs.com>
Date: Tue, 14 Jul 2026 17:00:07 +0000
Subject: [PATCH] Fix adapter_api import error and postgres password

---
 adapter_api.py | 33 +++++++++++++++++++--------------
 1 file changed, 19 insertions(+), 14 deletions(-)

diff --git a/adapter_api.py b/adapter_api.py
index 3878027..87f4ad8 100644
--- a/adapter_api.py
+++ b/adapter_api.py
@@ -10,7 +10,7 @@ from datetime import datetime, timezone
 from flask import Flask, jsonify, request, abort
 import redis
 import psycopg2
-from koreid import KoreIDGenerator, wrap_ethereum_event
+from koreid import KoreIDGenerator
 
 logging.basicConfig(level=logging.INFO, format='%(asctime)s [ADAPTER-API] %(message)s')
 app = Flask(__name__)
@@ -107,9 +107,9 @@ def generate_koreid():
     try:
         gen = KoreIDGenerator()
         result = gen.generate(
-            event_type=data.get('event_type', 'EXTERNAL'),
-            currency=data.get('currency', 'USD'),
-            current_network=data.get('network', 'ETHEREUM'),
+            type_token=data.get('event_type', 'EVT'),
+            domain_token=data.get('domain', 'ANCHOR'),
+            payload={'currency': data.get('currency', 'USD'), 'network': data.get('network', 'ETHEREUM')},
         )
         return jsonify(result)
     except Exception as e:
@@ -128,20 +128,25 @@ def inject_event():
     try:
         r   = get_redis()
         gen = KoreIDGenerator()
-        payload = wrap_ethereum_event(
-            event_type=data['event_type'],
-            amount=float(data['amount']),
-            currency=data['currency'],
+        kid = gen.for_ethereum_anchor(
+            original_koreid=data.get('linked_koreid', 'GENESIS-07'),
             tx_hash=data['tx_hash'],
             block_number=int(data.get('block_number', 0)),
-            from_address=data.get('from_address', '0x0'),
-            to_address=data.get('to_address', '0x0'),
-            token_symbol=data['token_symbol'],
-            koreid_generator=gen,
-            linked_koreid=data.get('linked_koreid'),
+            event_type=data['event_type'],
         )
+        payload = {
+            'koreid':       kid['koreid'],
+            'guid':         kid['guid'],
+            'step':         data['event_type'],
+            'currency':     data['currency'],
+            'amount':       float(data['amount']),
+            'token_symbol': data['token_symbol'],
+            'ethereum_tx':  data['tx_hash'],
+            'linked_to':    data.get('linked_koreid', 'GENESIS-07'),
+            'anchored_at':  __import__('datetime').datetime.utcnow().isoformat(),
+        }
         r.lpush(QUEUE_KEY, json.dumps(payload))
-        return jsonify({'queued': True, 'koreid': payload['koreid']})
+        return jsonify({'queued': True, 'koreid': kid['koreid']})
     except Exception as e:
         return jsonify({'error': str(e)}), 500