Getting Started

import { loadOrCreateIdentity } from '@toolkit-p2p/identity';

// Creates Ed25519 keypair, stored in IndexedDB
const identity = await loadOrCreateIdentity();

console.log(identity.did);
// Output: "did:zeta:5HqJw2..." (base58-encoded public key)

import { createTransport } from '@toolkit-p2p/transport';

// Create WebRTC mesh transport
const transport = createTransport({
  identity,
  signalingUrl: 'ws://localhost:8080',  // Or your signaling server
  roomCode: 'ABC123',
});

// Listen for peer connections
transport.onPeerJoined((peerId) => {
  console.log('Peer joined:', peerId);
});

transport.onPeerLeft((peerId) => {
  console.log('Peer left:', peerId);
});

// Broadcast cursor position to all peers
document.addEventListener('mousemove', (e) => {
  const data = {
    type: 'cursor',
    x: e.clientX,
    y: e.clientY,
  };

  const encoded = new TextEncoder().encode(JSON.stringify(data));
  transport.broadcast(encoded);
});

// Receive cursor updates from peers
transport.onMessage((peerId, data) => {
  const decoded = JSON.parse(new TextDecoder().decode(data));

  if (decoded.type === 'cursor') {
    updatePeerCursor(peerId, decoded.x, decoded.y);
  }
});

import { Bulletin } from '@toolkit-p2p/bulletin';

// Create shared CRDT state
const bulletin = new Bulletin();

// Set your status (automatically syncs via LWW-Map CRDT)
bulletin.set('status', 'online', { ttlSec: 3600 });

// Listen for remote status changes
bulletin.onChange((field, value) => {
  console.log(`Field ${field} updated:`, value);
});

// Sync with peers (merge remote state)
transport.onMessage((peerId, data) => {
  const message = JSON.parse(new TextDecoder().decode(data));

  if (message.type === 'bulletin-sync') {
    bulletin.merge(message.snapshot);
  }
});

import { MailboxQueue, deriveSessionKey, encrypt } from '@toolkit-p2p/mailbox';

// Derive session key from room code (PBKDF2-SHA256)
const sessionKey = await deriveSessionKey(identity, 'ABC123');

// Encrypt message (AES-256-GCM)
const message = { text: 'Hello, P2P world!' };
const encoded = new TextEncoder().encode(JSON.stringify(message));
const encrypted = await encrypt(encoded, sessionKey);

// Send to specific peer
await transport.send(targetPeerId, encrypted);

import { HeadlessNode } from '@toolkit-p2p/headless';

const lighthouse = new HeadlessNode({
  storagePath: '~/.lighthouse',
  port: 3000,
});

await lighthouse.start();
// Lighthouse now provides store-and-forward for offline peers