@twurple/eventsub-ws
Advanced tools
Comparing version 7.1.0-pre.1 to 7.1.0-pre.2
@@ -69,5 +69,5 @@ import { type HelixEventSubWebSocketTransportOptions } from '@twurple/api'; | ||
_handleSubscriptionRevoke(subscription: EventSubSubscription): void; | ||
protected _genericSubscribe<T, Args extends unknown[]>(clazz: new (handler: (obj: T) => void, client: EventSubBase, ...args: Args) => EventSubSubscription<T>, handler: (obj: T) => void, client: EventSubBase, ...params: Args): EventSubSubscription; | ||
protected _genericSubscribe<T, Args extends unknown[]>(clazz: new (handler: (obj: T) => void | Promise<void>, client: EventSubBase, ...args: Args) => EventSubSubscription<T>, handler: (obj: T) => void, client: EventSubBase, ...params: Args): EventSubSubscription; | ||
protected _findTwitchSubscriptionToContinue(): undefined; | ||
} | ||
//# sourceMappingURL=EventSubWsListener.d.ts.map |
@@ -88,7 +88,7 @@ "use strict"; | ||
for (const event of notificationPayload.events) { | ||
subscription._handleData(event.data); | ||
this._handleSingleEventPayload(subscription, event.data); | ||
} | ||
} | ||
else { | ||
subscription._handleData(notificationPayload.event); | ||
this._handleSingleEventPayload(subscription, notificationPayload.event); | ||
} | ||
@@ -156,2 +156,12 @@ break; | ||
} | ||
/** @internal */ | ||
_handleSingleEventPayload(subscription, payload) { | ||
subscription._handleData(payload).catch(e => { | ||
var _a; | ||
this._logger.error(`Caught an unhandled error in EventSub event handler for subscription ${subscription.id}. | ||
You should probably add try-catch to your handler to be able to examine it further. | ||
Message: ${(_a = e === null || e === void 0 ? void 0 : e.message) !== null && _a !== void 0 ? _a : e}`); | ||
}); | ||
} | ||
} | ||
@@ -158,0 +168,0 @@ tslib_1.__decorate([ |
{ | ||
"name": "@twurple/eventsub-ws", | ||
"version": "7.1.0-pre.1", | ||
"version": "7.1.0-pre.2", | ||
"publishConfig": { | ||
@@ -40,12 +40,12 @@ "access": "public" | ||
"@d-fischer/typed-event-emitter": "^3.3.0", | ||
"@twurple/auth": "7.1.0-pre.1", | ||
"@twurple/common": "7.1.0-pre.1", | ||
"@twurple/eventsub-base": "7.1.0-pre.1", | ||
"@twurple/auth": "7.1.0-pre.2", | ||
"@twurple/common": "7.1.0-pre.2", | ||
"@twurple/eventsub-base": "7.1.0-pre.2", | ||
"tslib": "^2.0.3" | ||
}, | ||
"devDependencies": { | ||
"@twurple/api": "7.1.0-pre.1" | ||
"@twurple/api": "7.1.0-pre.2" | ||
}, | ||
"peerDependencies": { | ||
"@twurple/api": "7.1.0-pre.1" | ||
"@twurple/api": "7.1.0-pre.2" | ||
}, | ||
@@ -52,0 +52,0 @@ "files": [ |
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
34768
777
+ Added@twurple/api@7.1.0-pre.2(transitive)
+ Added@twurple/api-call@7.1.0-pre.2(transitive)
+ Added@twurple/auth@7.1.0-pre.2(transitive)
+ Added@twurple/common@7.1.0-pre.2(transitive)
+ Added@twurple/eventsub-base@7.1.0-pre.2(transitive)
- Removed@twurple/api@7.1.0-pre.1(transitive)
- Removed@twurple/api-call@7.1.0-pre.1(transitive)
- Removed@twurple/auth@7.1.0-pre.1(transitive)
- Removed@twurple/common@7.1.0-pre.1(transitive)
- Removed@twurple/eventsub-base@7.1.0-pre.1(transitive)
Updated@twurple/auth@7.1.0-pre.2
Updated@twurple/common@7.1.0-pre.2