Sovereign computing,
between domains you
already own.

import { NorthstarClient } from "@northstar/client"

// Connect and authenticate (automatic)
const client = await NorthstarClient.connect(
  "wss://your-node.example"
)

// Join a remote space
await client.space.join(
  "northstar://other-node.example/channel/z6MkfA/protocols"
)

// Beam into space · SDK handles signing
await client.space.beam("channel/z6MkfA/protocols", {
  title: "On sovereign substrates",
  body: "Email is older than most platforms…",
})

// Space owner verifies, assigns sequence,
// gossips to 5 random member nodes.
// Within seconds, all members see the beam.

import { NorthstarClient } from "@northstar/client"

const client = await NorthstarClient.connect("wss://node.example")

// Create a private space
const room = await client.space.create({
  type: "dm",
  name: "Project Chat",
  uniqueId: "project-chat",
})

// Share space link · members join themselves
const link = NorthstarClient.toLink(room)
// → "northstar://node.example/dm/z6Mk.../abc"

// Subscribe to space events
await client.subscribe(room.id)
client.on("event", render)

// Send a message · SDK signs automatically
await client.space.append(room.id, {
  type: "message",
  body: "hey, this room is up",
})

import { NorthstarClient } from "@northstar/client"

// ═══ BROADCASTER ═══════════════════════════════════════
const broadcaster = await NorthstarClient.connect("wss://node.example")

const stream = await broadcaster.stream.start({
  title: "Studio session",
  latencyProfile: "low",
})

// Share stream link
const link = NorthstarClient.toLink(stream)
// → "northstar://node.example/stream/z6Mk.../live"

// Capture → encode → push signed chunks
const recorder = new MediaRecorder(mediaStream)
recorder.ondataavailable = async (e) => {
  const bytes = await e.data.arrayBuffer()
  const base64 = btoa(String.fromCharCode(...new Uint8Array(bytes)))
  await broadcaster.stream.chunk({ streamId: stream.streamId, data: base64 })
}
recorder.start(1000)

// ═══ VIEWER ════════════════════════════════════════════
const viewer = await NorthstarClient.connect("wss://viewer-node.example")

// Join via link (auto-subscribes via relay tree)
const info = await viewer.stream.join(
  "northstar://node.example/stream/z6Mk.../live"
)

// Receive signed chunks from relay tree
viewer.stream.onChunk(info.joined, (chunk) => {
  const bytes = viewer.stream.decodeChunk(chunk)
  sourceBuffer.appendBuffer(bytes)  // MSE playback
})