/Users/alexpower/Code/Projects/teleingest/node_modules/@rc-ex/ws/lib/subscription.js:22
this.wse.ws.addEventListener('message', this.eventListener);
^
TypeError: Cannot read properties of undefined (reading 'addEventListener')
at Subscription.setupWsEventListener (/Users/alexpower/Code/Projects/teleingest/node_modules/@rc-ex/ws/lib/subscription.js:22:21)
at new Subscription (/Users/alexpower/Code/Projects/teleingest/node_modules/@rc-ex/ws/lib/subscription.js:19:14)
at WebSocketExtension.subscribe (/Users/alexpower/Code/Projects/teleingest/node_modules/@rc-ex/ws/lib/index.js:315:30)
at Subscription.<anonymous> (/Users/alexpower/Code/Projects/teleingest/node_modules/@ringcentral/subscriptions/lib/Subscriptions.js:89:58)
at step (/Users/alexpower/Code/Projects/teleingest/node_modules/@ringcentral/subscriptions/lib/Subscriptions.js:48:23)
at Object.next (/Users/alexpower/Code/Projects/teleingest/node_modules/@ringcentral/subscriptions/lib/Subscriptions.js:29:53)
at fulfilled (/Users/alexpower/Code/Projects/teleingest/node_modules/@ringcentral/subscriptions/lib/Subscriptions.js:20:58)
at process.processTicksAndRejections (node:internal/process/task_queues:95:5)
const sendMessage = require("./src/sendMessage");
const { SDK } = require("@ringcentral/sdk");
const { Subscriptions } = require("@ringcentral/subscriptions");
const logger = require('pino')(
{
messageKey: "message",
formatters: {
level: (label) => {
return { level: label };
},
}
}
);
const sdk = new SDK({
server: process.env.RC_ENV !== "production" ? SDK.server.sandbox : SDK.server.production,
clientId: process.env.RC_CLIENT,
clientSecret: process.env.RC_SECRET
});
const platform = sdk.platform();
const subscriptions = new Subscriptions({
sdk: sdk,
});
const main = async () => {
// login
await platform.login({
jwt: process.env.RC_JWT,
});
// subscribe
const subscription = subscriptions.createSubscription();
subscription.on(subscription.events.notification, (evt) => {
console.log(JSON.stringify(evt, null, 2));
});
await subscription.setEventFilters(('/restapi/v1.0/account/~/telephony/sessions']).register();
// trigger events
subscription
.register()
.then(() => logger.info("Subscribed to events."))
.catch((err) => {
logger.error({ err }, err.message)
});
};
main();
