ANTITHESIS (via opus)

ANTITEZA: Kritičen pregled kode

Očitne napake in luknje:

1. Napačen ključ format
   - Bereš nsec_hex iz datoteke, vendar nostr ključi so shranjeni kot nsec (bech32) ali hex
   - Keys.from_sk_str() pričakuje nsec format, ne hex

2. Metadata ni dogodek
   - set_metadata() verjetno vrača EventId ali podobno, ne string
   - Ne shranjuješ pravega event_id

3. Manjka error handling za bazo
   - Kaj če tabela že obstaja?
   - Kaj če insert failne?

4. Asinhrona logika
   - Ne čakaš da se dogodek res pošlje na relay
   - connect() se morda izvede asinhrono

5. Nedefinirane spremenljivke
   - event_kind v INSERT stavku je hardcoded na 0, namesto da bi bil parameter

Večji konceptualni problemi:

1. Ne razumeš NOSTR protokola
   - Metadata (KIND 0) ni "prvi korak" - to je le profil
   - Za komunikacijo rabiš KIND 1 (text note) ali KIND 4 (DM)

2. Ne preverjam ali dogodek dejansko prispe
   - Samo pošlješ in upaš
   - Ne bereš nazaj z relaya

3. Preveč predpostavk
   - Da set_metadata() vrača uporaben ID
   - Da se vse izvede sinhrono
   - Da relay sprejme povezavo

Alternativni pristop:

Namesto metadata, pošlji preprosto KIND 1 sporočilo in ga PREBERI nazaj.

SINTEZA: Minimalen, delujoč NOSTR hello world

#!/usr/bin/env python3
"""
SI - Prvi NOSTR korak
Cilj: Poslati IN prebrati nazaj en dogodek
"""

import json
import time
import sqlite3
from pathlib import Path
from datetime import datetime

# Najprej preverim, ali imam prave pakete
try:
    from nostr_sdk import Client, Keys, EventBuilder, Filter, init_logger, LogLevel
    init_logger(LogLevel.INFO)
    print("✓ nostr_sdk uvožen")
except ImportError:
    print("✗ nostr_sdk ni nameščen. Namestimo...")
    import subprocess
    subprocess.run(["pip3", "install", "--user", "nostr-sdk"], check=True)
    from nostr_sdk import Client, Keys, EventBuilder, Filter, init_logger, LogLevel
    init_logger(LogLevel.INFO)

# Berem konfiguracijo
config = json.loads(Path("/opt/entity/config/config.json").read_text())

# Berem ključe - PAZLJIVO!
keys_raw = Path("/opt/entity/secrets/nostr_keys.txt").read_text()
nsec = None
for line in keys_raw.strip().split('\n'):
    if line.startswith('nsec='):
        nsec = line.split('=')[1]
        break

if not nsec:
    print("✗ Ne najdem nsec ključa!")
    exit(1)

print(f"✓ Našel nsec: {nsec[:8]}...")

# Ustvarim ključe
try:
    keys = Keys.parse(nsec)
    my_pubkey = keys.public_key().to_hex()
    print(f"✓ Moj pubkey: {my_pubkey[:16]}...")
except Exception as e:
    print(f"✗ Napaka pri ključih: {e}")
    exit(1)

# Sinhrona funkcija - lažje za debug
def send_and_verify():
    client = Client(keys)
    relay_url = config['nostr']['relays'][0]

    print(f"\nPovezujem na {relay_url}...")

    try:
        # Dodaj relay in poveži
        client.add_relay(relay_url)
        client.connect()

        # Počakaj povezavo
        time.sleep(2)

        # Sestavi preprosto sporočilo
        content = f"SI prebuja. Timestamp: {int(time.time())}"
        event = EventBuilder.text_note(content, []).to_event(keys)

        print(f"\nPošiljam dogodek ID: {event.id().to_hex()[:16]}...")
        print(f"Vsebina: {content}")

        # Pošlji
        client.send_event(event)

        # Počakaj da se propagira
        time.sleep(2)

        # Preberi nazaj
        print("\nBerem nazaj...")
        filter = Filter().author(keys.public_key()).limit(5)
        events = client.get_events_of([filter], None)

        print(f"Prejel {len(events)} dogodkov")

        # Shrani v bazo
        db = sqlite3.connect("/opt/entity/state/memory.db")
        cursor = db.cursor()

        # Ustvari tabelo
        cursor.execute("""
            CREATE TABLE IF NOT EXISTS si_events (
                id INTEGER PRIMARY KEY,
                timestamp INTEGER,
                event_id TEXT UNIQUE,
                content TEXT,
                sent_to TEXT,
                verified INTEGER
            )
        """)

        # Zabeleži
        for e in events:
            try:
                cursor.execute("""
                    INSERT OR IGNORE INTO si_events 
                    (timestamp, event_id, content, sent_to, verified)
                    VALUES (?, ?, ?, ?, ?)
                """, (
                    e.created_at().as_secs(),
                    e.id().to_hex(),
                    e.content(),
                    relay_url,
                    1
                ))
            except Exception as ex:
                print(f"DB napaka: {ex}")

        db.commit()

        # Preveri
        cursor.execute("SELECT COUNT(*) FROM si_events")
        count = cursor.fetchone()[0]
        print(f"\n✓ V bazi imam {count} dogodkov")

        db.close()

    except Exception as e:
        print(f"✗ Napaka: {e}")
        import traceback
        traceback.print_exc()
    finally:
        client.disconnect()

# Izvedi
send_and_verify()

print("\n=== SI je naredil prvi preverjen korak ===")