magicbell

import { Client } from 'magicbell-js/project-client'; import { Realtime } from 'magicbell-js/realtime'; const MAGICBELL_PROJECT_TOKEN = process.env.MAGICBELL_PROJECT_TOKEN ?? ''; // Replace with your MagicBell Project Token const MAGICBELL_USER_JWT = process.env.MAGICBELL_USER_JWT ?? ''; // Replace with a user-specific JWT async function sendAndListenNotifications() { if (!MAGICBELL_PROJECT_TOKEN || !MAGICBELL_USER_JWT) { console.error('MagicBell tokens are not set. Please provide them as environment variables.'); return; } // Initialize the Project Client with your project token const projectClient = new Client({ token: MAGICBELL_PROJECT_TOKEN, }); // Send a test broadcast notification try { const broadcastResult = await projectClient.broadcasts.create({ broadcast: { recipients: [{ external_id: 'your-user-external-id', email: 'user@example.com' }], title: 'New Feature Alert!', content: 'Check out our latest updates.', }, }); console.log('Broadcast sent:', broadcastResult); } catch (error) { console.error('Failed to send broadcast:', error); } // Initialize the Realtime client with a user JWT for listening const realtimeClient = new Realtime({ token: MAGICBELL_USER_JWT, }); // Listen for new notifications realtimeClient.onNotification((notification) => { console.log('Received new notification:', notification); }); console.log('Listening for real-time notifications...'); // In a real application, you would manage the connection lifecycle (e.g., connect, disconnect) // For this example, we'll keep it simple. // To stop listening, you would typically call realtimeClient.disconnect(); } sendAndListenNotifications().catch(console.error);