agora-rtm-sdk

import AgoraRTM from 'agora-rtm-sdk'; const APP_ID = process.env.AGORA_APP_ID ?? ''; const UID = process.env.AGORA_UID ?? String(Math.floor(Math.random() * 100000)); const CHANNEL_NAME = 'my_agora_channel'; async function startRTMClient() { if (!APP_ID) { console.error('AGORA_APP_ID is not set. Please set it as an environment variable or replace the placeholder.'); return; } const client = AgoraRTM.createInstance(APP_ID); console.log('RTM Client created.'); client.on('ConnectionStateChange', (newState, reason) => { console.log(`Connection state changed to ${newState}, reason: ${reason}`); if (newState === 'CONNECTED') { console.log('Successfully connected to Agora RTM.'); } }); client.on('MessageFromPeer', ({ text }, peerId) => { console.log(`Peer message from ${peerId}: ${text}`); }); try { await client.login({ uid: UID, token: undefined }); // Use undefined for temporary token in debug mode console.log(`Logged in as ${UID}.`); const channel = client.createChannel(CHANNEL_NAME); console.log(`Channel '${CHANNEL_NAME}' created.`); channel.on('ChannelMessage', ({ text }, senderId) => { console.log(`Channel message from ${senderId}: ${text}`); }); await channel.join(); console.log(`Joined channel '${CHANNEL_NAME}'.`); await channel.sendMessage({ text: 'Hello, Agora RTM Channel!' }); console.log('Message sent to channel.'); } catch (err) { console.error('Agora RTM error:', err); } } startRTMClient();