Voice control-plane bot

import { Client } from '@cloak-software/bot-sdk';

const client = new Client({
  token: process.env.CLOAK_TOKEN!,
  // Not optional. Identity publication is write-once server-side, so a bot
  // with no keystore works on its first run and can never log in again.
  keystorePath: './voice-bot.cloak-keystore.json',
  // Note what is missing: voice_listen. This bot is deaf on purpose, and not
  // declaring it is the demonstration.
  requiredPermissions: ['message_send', 'voice_connect'],
});

client.on('ready', () => {
  console.log(`Logged in as bot ${client.user?.id}`);
  console.log('Commands: !join <voiceChannelId> [groupId] | !leave | !roster [id] | !mute | !unmute');
});

client.on('messageCreate', async (msg) => {
  if (msg.authorId === client.user?.id) return; // ignore our own messages
  // Voice is server-scoped, and a direct message has a null serverId.
  if (msg.isDM || !msg.serverId) return;

  const [cmd, ...args] = msg.content.trim().split(/\s+/);
  try {
    if (cmd === '!join') {
      const [channelId, groupId] = args;
      if (!channelId) return void (await msg.reply('usage: !join <voiceChannelId> [groupId]'));
      const conn = await client.joinVoice(msg.serverId, channelId, { groupId });
      // Never log or echo the token: it is a live LiveKit credential.
      console.log(`joined voice ${conn.channelId}, url ${conn.url}, token ${conn.token.length} chars`);
      await msg.reply(`in voice ${conn.channelId} (control plane only, no audio)`);
    } else if (cmd === '!leave') {
      await client.leaveVoice();
      await msg.reply('left voice');
    } else if (cmd === '!roster') {
      const channelId = args[0] ?? client.voiceConnection()?.channelId;
      if (!channelId) return void (await msg.reply('not in voice, pass a channel id'));
      const roster = client.voiceRoster(channelId);
      await msg.reply(
        roster.length
          ? roster.map((p) => `${p.userId}${p.muted ? ' (muted)' : ''}`).join(', ')
          : 'nobody in that channel (per the cached roster)',
      );
    } else if (cmd === '!mute' || cmd === '!unmute') {
      await client.setVoiceSelfState({ muted: cmd === '!mute' });
      await msg.reply(`self-muted: ${client.voiceConnection()?.selfMuted}`);
    }
  } catch (e) {
    console.error(`${cmd} failed`, e);
    await msg.reply(`${cmd} failed: ${(e as Error).message}`).catch(() => undefined);
  }
});

// Roster events. All of these fire for the bot's own join and leave too.
client.on('voiceJoin', (p) => console.log(`voice join: ${p.userId} -> ${p.channelId}`));
client.on('voiceLeave', (e) => console.log(`voice leave: ${e.userId} <- ${e.channelId}`));
client.on('voiceStateUpdate', (e) => console.log(`voice state: ${e.userId} ${e.state}=${e.value}`));
client.on('voiceConnectionState', (e) =>
  console.log(`voice ${e.userId} ${e.reconnecting ? 'reconnecting' : 'recovered'}`),
);

// A moderator moved or disconnected us. voiceConnection() is already cleared,
// and the SDK deliberately does not auto-rejoin.
client.on('voiceDisconnect', (e) =>
  console.warn(`removed from voice ${e.channelId} (${e.reason}${e.toChannelId ? ` -> ${e.toChannelId}` : ''})`),
);

client.on('error', (e) => console.error('sdk error', e.source, e.message));
client.on('disconnect', (e) => console.warn('disconnected', e));
client.on('reconnected', () => console.log('reconnected (voice is left and rejoined on our behalf)'));

client.login().catch((e) => {
  console.error('login failed', e);
  process.exit(1);
});