@nolag/stream

import { NoLagApi } from "@nolag/js-sdk";

const api = new NoLagApi(process.env.NOLAG_API_KEY); // nlg_live_...
const app = await api.apps.create({ name: "My App", blueprintId: "nolag-stream-sdk" });
console.log(app.slug); // e.g. "my-app-a3f9": this is your appName

const actor = await api.actors.create({ name: "web-client", actorType: "user" });
console.log(actor.accessToken); // shown once; keep it

npm install @nolag/stream @nolag/js-sdk

import { NoLag } from '@nolag/js-sdk'
import { NoLagStream } from '@nolag/stream'

// The app owns one core client. In a browser, pass a token provider so the
// SDK can mint fresh short-lived client tokens from your backend.
const client = NoLag(async () => (await (await fetch('/api/nolag-token')).json()).token)

// Inject the client into the stream wrapper (role: 'viewer', 'moderator', or 'host')
const stream = new NoLagStream({
  client,
  appName: APP_SLUG, // the slug returned when you created the app
  username: 'Alice',
  role: 'viewer',
})

await client.connect()   // the app owns the connection
await stream.ready()     // wrapper setup complete

// Join the seeded stream
const room = stream.joinStream('live-stream')

// Display live viewer count
stream.on('viewerCountChanged', (count) => {
  console.log('Viewers:', count)
})

// Send a comment. Publishers never receive their own comments back, so the
// wrapper adds it to the local store and emits `commentSent`.
room.sendComment('This is amazing!')

// Listen for comments from other viewers
room.on('comment', (c) => {
  console.log(`[${c.username}]: ${c.text}`)
})

// Send a reaction burst
room.sendReaction('🔥')

room.on('reaction', ({ emoji, count }) => {
  console.log(`${count}x ${emoji}`)
})

// Create a poll (typically broadcaster-side). Polls stay open until closePoll().
const poll = room.createPoll({
  question: 'Which feature next?',
  options: ['Dark mode', 'Mobile app', 'API access'],
})

// Vote on the active poll
room.votePoll(poll.id, 1) // vote for index 1

room.on('pollUpdated', (p) => {
  console.log('Results:', p.options.map((o) => `${o.text}: ${o.votes}`))
})

// Close it when you are done
room.closePoll(poll.id)

// Teardown: the wrapper releases its handlers; the app closes the socket.
stream.detach()
client.disconnect()