Anchor from your agent

npm install @sanning/anchor

pip install sanning-anchor

import {
  createEnvelopeAnchorer,
  FsLogStore,
  LocalEd25519Signer,
} from "@sanning/anchor";

// Read the environment once and fail fast. `process.env.X` is
// `string | undefined`, so an assertion here would assert exactly what
// this check exists to disprove.
const apiKey = process.env.SANNING_API_KEY;
const seedHex = process.env.SANNING_SIGNING_SEED;
if (!apiKey || !seedHex) {
  throw new Error("set SANNING_API_KEY and SANNING_SIGNING_SEED");
}

const anchorer = createEnvelopeAnchorer({
  environment: "dev",
  // Your agent's identity. The seed stays on your machine.
  signer: LocalEd25519Signer.fromSeedHex(seedHex),
  subject: { type: "producer", producer_id: "claims-triage" },
  controlPlane: { apiKey },
  // Keeps the bytes the commitment is over. See the log store guide.
  logStore: new FsLogStore("./logstore"),
});

const decision = { claim: "CLM-4417", outcome: "refer", confidence: 0.62 };

const result = await anchorer.anchor({
  type: "claims.decision",
  // Hashed in this process. These bytes are never sent to Sanning.
  data: JSON.stringify(decision),
  metadata: { queue: "queue-3" },
});

console.log(result.eventId);

// Settles every event. Throws if anything was signed and never delivered.
await anchorer.close();

import json
import os

from nacl.signing import SigningKey
from sanning_anchor import Anchorer, FsLogStore

anchorer = Anchorer(
    environment="dev",
    # Your agent's identity. The seed stays on your machine.
    signing_key=SigningKey(bytes.fromhex(os.environ["SANNING_SIGNING_SEED"])),
    subject={"type": "producer", "producer_id": "claims-triage"},
    api_key=os.environ["SANNING_API_KEY"],
    # Keeps the bytes the commitment is over. See the log store guide.
    log_store=FsLogStore("./logstore"),
)

decision = {"claim": "CLM-4417", "outcome": "refer", "confidence": 0.62}

result = anchorer.anchor(
    event_type="claims.decision",
    # Hashed in this process. These bytes are never sent to Sanning.
    content=json.dumps(decision).encode(),
    metadata={"queue": "queue-3"},
)

print(result.event_id)

# Settles every event. Raises if anything was signed and never delivered.
anchorer.close()

anchorer.gaps; // each carries the recordBytes for one event
await anchorer.close(); // throws IncompleteTrailError if any remain

anchorer.gaps          # each carries the record_bytes for one event
anchorer.close()       # raises IncompleteTrailError if any remain