salesforce-pubsub-api-client

import { PubSubApiClient } from 'salesforce-pubsub-api-client'; import type { SubscribeCallback, SubscriptionInfo } from 'salesforce-pubsub-api-client'; // Ensure these environment variables are set for authentication const CLIENT_ID = process.env.SF_CLIENT_ID ?? 'YOUR_SALESFORCE_CLIENT_ID'; const CLIENT_SECRET = process.env.SF_CLIENT_SECRET ?? 'YOUR_SALESFORCE_CLIENT_SECRET'; const USERNAME = process.env.SF_USERNAME ?? 'your.email@example.com'; const PASSWORD = process.env.SF_PASSWORD ?? 'YOUR_SALESFORCE_PASSWORD'; const LOGIN_URL = process.env.SF_LOGIN_URL ?? 'https://login.salesforce.com'; // Or https://test.salesforce.com async function main() { const client = new PubSubApiClient({ instanceUrl: LOGIN_URL, auth: { username: USERNAME, password: PASSWORD, clientId: CLIENT_ID, clientSecret: CLIENT_SECRET }, isDebugLogEnabled: true // Enable debug logging }); // Define the callback function for incoming events and lifecycle events const subscribeCallback: SubscribeCallback = ( subscription: SubscriptionInfo, callbackType: 'data' | 'unsubscribing' | 'error' | 'reconnecting', data: any ) => { if (callbackType === 'data') { console.log(`Received event on ${subscription.topicName}:`, JSON.stringify(data, null, 2)); } else if (callbackType === 'error') { console.error(`Subscription error on ${subscription.topicName}:`, data); } else { console.log(`Subscription lifecycle event on ${subscription.topicName}: ${callbackType}`); } }; try { await client.connect(); console.log('Connected to Salesforce Pub/Sub API.'); // Subscribe to a Platform Event or Change Data Capture topic const topicName = '/event/My_Platform_Event__e'; // Replace with your topic await client.subscribe(topicName, subscribeCallback); console.log(`Subscribed to topic: ${topicName}. Waiting for events...`); // Keep the process alive to receive events process.on('SIGINT', async () => { console.log('Disconnecting from Pub/Sub API...'); await client.disconnect(); console.log('Disconnected. Exiting.'); process.exit(0); }); } catch (error) { console.error('Failed to connect or subscribe:', error); await client.disconnect(); } } main().catch(console.error);