Node.js server SDK

npm install @applooma/server-sdk

APPLOOMA_API_KEY=ak_your_key
APPLOOMA_API_SECRET=as_your_secret

import express from 'express';
import { AppServerClient, AppApiError } from '@applooma/server-sdk';

const app = express();
app.use(express.json());

const applooma = new AppServerClient({
  apiKey: process.env.APPLOOMA_API_KEY,
  apiSecret: process.env.APPLOOMA_API_SECRET,
});

app.post('/api/rtc-token', async (req, res) => {
  // 1. Authenticate YOUR user. This endpoint is the gate to your quota.
  const user = await authenticate(req);
  if (!user) return res.status(401).json({ error: 'Sign in first' });

  // 2. Decide the channel and role yourself. Do not take the role
  //    from the request body unless you have checked it.
  const channel = String(req.body.channel || '');
  const role = user.id === (await hostOf(channel)) ? 'host' : 'audience';

  try {
    const result = await applooma.createToken({
      roomName: channel,          // [a-zA-Z0-9_-], 1-64 characters
      identity: user.id,          // unique per participant
      role,                       // 'host' | 'cohost' | 'audience'
      metadata: { name: user.displayName },
    });

    res.json({ token: result.token, wsUrl: result.wsUrl });
  } catch (err) {
    if (err instanceof AppApiError) {
      console.error('AppLooma', err.status, err.code, err.message);
      if (err.code === 'QUOTA_EXCEEDED') {
        return res.status(503).json({ error: 'Calling is temporarily unavailable' });
      }
      return res.status(502).json({ error: 'Could not start the call' });
    }
    throw err;
  }
});

app.listen(3001);

createToken(params: CreateTokenParams): Promise<TokenResponse>

listRooms(): Promise<AppRoom[]>

listParticipants(roomName: string): Promise<{ identity: string; name?: string; joinedAt: string | number }[]>

getGifts(): Promise<AppGift[]>

sendGift(params: SendGiftParams): Promise<{ txId: string; coinTotal: number; sentAt: string }>

giftLeaderboard(roomName?: string): Promise<{
  topSenders: { identity: string; coins: number; gifts: number }[];
  topReceivers: { identity: string; coins: number; gifts: number }[];
}>

class AppApiError extends Error {
  name: 'AppApiError';
  status: number;    // HTTP status
  message: string;   // human-readable message from the API
  code?: string;     // machine-readable code, when present
}

import { AppApiError } from '@applooma/server-sdk';

try {
  await applooma.createToken({ roomName: 'lobby', identity: user.id });
} catch (err) {
  if (!(err instanceof AppApiError)) throw err;

  switch (err.code) {
    case 'QUOTA_EXCEEDED':
      // Out of minutes for the month. Alert your team and upgrade the plan.
      return res.status(503).json({ error: 'Calling is temporarily unavailable' });
    case 'ACCOUNT_SUSPENDED':
      // Billing or policy issue. Only the account owner can resolve it.
      return res.status(503).json({ error: 'Calling is temporarily unavailable' });
    default:
      if (err.status === 400) return res.status(400).json({ error: err.message });
      if (err.status === 401) throw new Error('AppLooma credentials are wrong');
      return res.status(502).json({ error: 'Upstream error' });
  }
}

const BASE = 'https://api.applooma.dev/v1';
const headers = {
  'content-type': 'application/json',
  'x-applooma-key': process.env.APPLOOMA_API_KEY,
  'x-applooma-secret': process.env.APPLOOMA_API_SECRET,
};

// Create an RTMP ingest for OBS
const res = await fetch(`${BASE}/streams/ingest`, {
  method: 'POST',
  headers,
  body: JSON.stringify({ roomName: 'lobby', name: 'obs-ingest', type: 'rtmp' }),
});
if (!res.ok) throw new Error(`ingest failed: ${res.status}`);

const { ingestId, url, streamKey } = await res.json();
// Give url + streamKey to the broadcaster to paste into OBS.