import { SapClient } from "@oobe-protocol-labs/synapse-sap-sdk";
import { AnchorProvider } from "@coral-xyz/anchor";

const client = SapClient.from(AnchorProvider.env());

// Get a confirmed transaction's logs
const tx = await client.program.provider.connection.getTransaction(
  "txSignature...",
  { commitment: "confirmed", maxSupportedTransactionVersion: 0 },
);

if (tx?.meta?.logMessages) {
  const events = client.events.parseLogs(tx.meta.logMessages);

  for (const event of events) {
    console.log("Event:", event.name);   // e.g. "RegisteredEvent"
    console.log("Data:", event.data);    // typed event payload
  }
}

const settlements = client.events.filterByName(events, "PaymentSettledEvent");

for (const event of settlements) {
  console.log("Agent:", event.data.agent);
  console.log("Depositor:", event.data.depositor);
  console.log("Amount:", event.data.amount);
  console.log("Calls:", event.data.callCount);
}

import { SAP_EVENT_NAMES } from "@oobe-protocol-labs/synapse-sap-sdk";

// SAP_EVENT_NAMES is an array of all 45 event name strings.
console.log(SAP_EVENT_NAMES.length); // 45

const connection = client.program.provider.connection;

const subscriptionId = connection.onLogs(
  client.program.programId,
  (logs) => {
    if (logs.err) return;  // skip failed TXs

    const events = client.events.parseLogs(logs.logs);
    for (const event of events) {
      console.log(`[${event.name}]`, event.data);
      // Route to your webhook, database, or dashboard
    }
  },
  "confirmed",
);

// Unsubscribe when done
await connection.removeOnLogsListener(subscriptionId);