@twurple/api - npm Package Compare versions

Comparing version 7.1.0-pre.8 to 7.1.0-pre.9

lib/endpoints/eventSub/HelixEventSubApi.d.ts

@@ -0,4 +1,6 @@
+import type { HelixPaginatedResponse } from '@twurple/api-call';
 import { type UserIdResolvable } from '@twurple/common';
-import { type HelixEventSubSubscriptionStatus } from '../../interfaces/endpoints/eventSub.external';
-import { type HelixEventSubDropEntitlementGrantFilter, type HelixEventSubTransportOptions, type HelixPaginatedEventSubSubscriptionsResult } from '../../interfaces/endpoints/eventSub.input';
+import { type HelixEventSubSubscriptionStatus, type HelixEventSubConduitShardData } from '../../interfaces/endpoints/eventSub.external';
+import { type HelixEventSubDropEntitlementGrantFilter, type HelixEventSubTransportOptions, type HelixPaginatedEventSubSubscriptionsResult, type HelixEventSubConduitShardsOptions } from '../../interfaces/endpoints/eventSub.input';
+import { HelixPaginatedRequest } from '../../utils/pagination/HelixPaginatedRequest';
 import { type HelixPagination } from '../../utils/pagination/HelixPagination';
@@ -8,2 +10,4 @@ import { BaseApi } from '../BaseApi';
 import { HelixPaginatedEventSubSubscriptionsRequest } from './HelixPaginatedEventSubSubscriptionsRequest';
+import { HelixEventSubConduit } from './HelixEventSubConduit';
+import { HelixEventSubConduitShard } from './HelixEventSubConduitShard';
 /**
@@ -480,2 +484,9 @@ * The API methods that deal with EventSub.
     /**
+     * Subscribe to events that represent chat settings being updated in a channel.
+     *
+     * @param broadcaster The broadcaster for which you want to listen to chat settings update events.
+     * @param transport The transport options.
+     */
+    subscribeToChannelChatSettingsUpdateEvents(broadcaster: UserIdResolvable, transport: HelixEventSubTransportOptions): Promise<HelixEventSubSubscription>;
+    /**
      * Subscribe to events that represent an extension Bits transaction.
@@ -521,4 +532,50 @@ *
     subscribeToDropEntitlementGrantEvents(filter: HelixEventSubDropEntitlementGrantFilter, transport: HelixEventSubTransportOptions): Promise<HelixEventSubSubscription>;
+    /**
+     * Gets the current EventSub conduits for the current client.
+     *
+     */
+    getConduits(): Promise<HelixEventSubConduit[]>;
+    /**
+     * Creates a new EventSub conduit for the current client.
+     *
+     * @param shardCount The number of shards to create for this conduit.
+     */
+    createConduit(shardCount: number): Promise<HelixEventSubConduit>;
+    /**
+     * Updates an EventSub conduit for the current client.
+     *
+     * @param id The ID of the conduit to update.
+     * @param shardCount The number of shards to update for this conduit.
+     */
+    updateConduit(id: string, shardCount: number): Promise<HelixEventSubConduit>;
+    /**
+     * Deletes an EventSub conduit for the current client.
+     *
+     * @param id The ID of the conduit to delete.
+     */
+    deleteConduit(id: string): Promise<void>;
+    /**
+     * Gets the shards of an EventSub conduit for the current client.
+     *
+     * @param conduitId The ID of the conduit to get shards for.
+     * @param status The status of the shards to filter by.
+     * @param pagination
+     */
+    getConduitShards(conduitId: string, status?: HelixEventSubSubscriptionStatus | undefined, pagination?: HelixPagination): Promise<HelixPaginatedResponse<HelixEventSubConduitShard>>;
+    /**
+     * Creates a paginator for the shards of an EventSub conduit for the current client.
+     *
+     * @param conduitId The ID of the conduit to get shards for.
+     * @param status The status of the shards to filter by.
+     */
+    getConduitShardsPaginated(conduitId: string, status?: HelixEventSubSubscriptionStatus | undefined): HelixPaginatedRequest<HelixEventSubConduitShardData, HelixEventSubConduitShard>;
+    /**
+     * Updates shards of an EventSub conduit for the current client.
+     *
+     * @param conduitId The ID of the conduit to update shards for.
+     * @param shards List of shards to update
+     */
+    updateConduitShards(conduitId: string, shards: HelixEventSubConduitShardsOptions[]): Promise<HelixEventSubConduitShard[]>;
     private _deleteSubscriptionsWithCondition;
 }
 //# sourceMappingURL=HelixEventSubApi.d.ts.map

lib/endpoints/eventSub/HelixEventSubApi.js

@@ -9,2 +9,3 @@ "use strict";
 const generic_external_1 = require("../../interfaces/endpoints/generic.external");
+const HelixPaginatedRequest_1 = require("../../utils/pagination/HelixPaginatedRequest");
 const HelixPaginatedResult_1 = require("../../utils/pagination/HelixPaginatedResult");
@@ -15,2 +16,4 @@ const HelixPagination_1 = require("../../utils/pagination/HelixPagination");
 const HelixPaginatedEventSubSubscriptionsRequest_1 = require("./HelixPaginatedEventSubSubscriptionsRequest");
+const HelixEventSubConduit_1 = require("./HelixEventSubConduit");
+const HelixEventSubConduitShard_1 = require("./HelixEventSubConduitShard");
 /**
@@ -174,3 +177,3 @@ * The API methods that deal with EventSub.
     async createSubscription(type, version, condition, transport, user, requiredScopeSet, canOverrideScopedUserContext, isBatched) {
-        const usesAppAuth = transport.method === 'webhook';
+        const usesAppAuth = transport.method === 'webhook' || transport.method === 'conduit';
         const scopes = usesAppAuth ? undefined : requiredScopeSet;
@@ -702,2 +705,12 @@ if (!usesAppAuth && !user) {
     /**
+     * Subscribe to events that represent chat settings being updated in a channel.
+     *
+     * @param broadcaster The broadcaster for which you want to listen to chat settings update events.
+     * @param transport The transport options.
+     */
+    async subscribeToChannelChatSettingsUpdateEvents(broadcaster, transport) {
+        const broadcasterId = (0, common_1.extractUserId)(broadcaster);
+        return await this.createSubscription('channel.chat_settings.update', '1', (0, eventSub_external_1.createEventSubUserCondition)(broadcasterId, this._getUserContextIdWithDefault(broadcasterId)), transport, broadcaster, ['user:read:chat'], true);
+    }
+    /**
      * Subscribe to events that represent an extension Bits transaction.
@@ -753,2 +766,106 @@ *
     }
+    /**
+     * Gets the current EventSub conduits for the current client.
+     *
+     */
+    async getConduits() {
+        const result = await this._client.callApi({
+            type: 'helix',
+            url: 'eventsub/conduits',
+        });
+        return result.data.map(data => new HelixEventSubConduit_1.HelixEventSubConduit(data, this._client));
+    }
+    /**
+     * Creates a new EventSub conduit for the current client.
+     *
+     * @param shardCount The number of shards to create for this conduit.
+     */
+    async createConduit(shardCount) {
+        const result = await this._client.callApi({
+            type: 'helix',
+            url: 'eventsub/conduits',
+            method: 'POST',
+            query: {
+                ...(0, generic_external_1.createSingleKeyQuery)('shard_count', shardCount.toString()),
+            },
+        });
+        return new HelixEventSubConduit_1.HelixEventSubConduit(result.data[0], this._client);
+    }
+    /**
+     * Updates an EventSub conduit for the current client.
+     *
+     * @param id The ID of the conduit to update.
+     * @param shardCount The number of shards to update for this conduit.
+     */
+    async updateConduit(id, shardCount) {
+        const result = await this._client.callApi({
+            type: 'helix',
+            url: 'eventsub/conduits',
+            method: 'PATCH',
+            query: (0, eventSub_external_1.createEventSubConduitUpdateCondition)(id, shardCount),
+        });
+        return new HelixEventSubConduit_1.HelixEventSubConduit(result.data[0], this._client);
+    }
+    /**
+     * Deletes an EventSub conduit for the current client.
+     *
+     * @param id The ID of the conduit to delete.
+     */
+    async deleteConduit(id) {
+        await this._client.callApi({
+            type: 'helix',
+            url: 'eventsub/conduits',
+            method: 'DELETE',
+            query: {
+                ...(0, generic_external_1.createSingleKeyQuery)('id', id),
+            },
+        });
+    }
+    /**
+     * Gets the shards of an EventSub conduit for the current client.
+     *
+     * @param conduitId The ID of the conduit to get shards for.
+     * @param status The status of the shards to filter by.
+     * @param pagination
+     */
+    async getConduitShards(conduitId, status, pagination) {
+        const result = await this._client.callApi({
+            type: 'helix',
+            url: 'eventsub/conduits/shards',
+            query: {
+                ...(0, eventSub_external_1.createEventSubConduitCondition)(conduitId, status),
+                ...(0, HelixPagination_1.createPaginationQuery)(pagination),
+            },
+        });
+        return {
+            ...(0, HelixPaginatedResult_1.createPaginatedResult)(result, HelixEventSubConduitShard_1.HelixEventSubConduitShard, this._client),
+        };
+    }
+    /**
+     * Creates a paginator for the shards of an EventSub conduit for the current client.
+     *
+     * @param conduitId The ID of the conduit to get shards for.
+     * @param status The status of the shards to filter by.
+     */
+    getConduitShardsPaginated(conduitId, status) {
+        return new HelixPaginatedRequest_1.HelixPaginatedRequest({
+            url: 'eventsub/conduits/shards',
+            query: (0, eventSub_external_1.createEventSubConduitCondition)(conduitId, status),
+        }, this._client, data => new HelixEventSubConduitShard_1.HelixEventSubConduitShard(data));
+    }
+    /**
+     * Updates shards of an EventSub conduit for the current client.
+     *
+     * @param conduitId The ID of the conduit to update shards for.
+     * @param shards List of shards to update
+     */
+    async updateConduitShards(conduitId, shards) {
+        const result = await this._client.callApi({
+            type: 'helix',
+            url: 'eventsub/conduits/shards',
+            method: 'PATCH',
+            jsonBody: (0, eventSub_external_1.createEventSubConduitShardsUpdateCondition)(conduitId, shards),
+        });
+        return result.data.map(data => new HelixEventSubConduitShard_1.HelixEventSubConduitShard(data));
+    }
     async _deleteSubscriptionsWithCondition(cond) {
@@ -755,0 +872,0 @@ const subsPaginator = this.getSubscriptionsPaginated();

lib/endpoints/eventSub/HelixEventSubSubscription.d.ts

@@ -32,2 +32,6 @@ import { DataObject } from '@twurple/common';
     /**
+     * The transport method of the subscription.
+     */
+    get transportMethod(): string;
+    /**
      * End the EventSub subscription.
@@ -34,0 +38,0 @@ */

lib/endpoints/eventSub/HelixEventSubSubscription.js

@@ -53,2 +53,8 @@ "use strict";
     /**
+     * The transport method of the subscription.
+     */
+    get transportMethod() {
+        return this[common_1.rawDataSymbol].transport.method;
+    }
+    /**
      * End the EventSub subscription.
@@ -55,0 +61,0 @@ */

lib/index.d.ts

@@ -47,6 +47,8 @@ export { ApiClient } from './client/ApiClient';
 export { HelixEventSubApi } from './endpoints/eventSub/HelixEventSubApi';
+export { HelixEventSubConduit } from './endpoints/eventSub/HelixEventSubConduit';
+export { HelixEventSubConduitShard } from './endpoints/eventSub/HelixEventSubConduitShard';
 export { HelixEventSubSubscription } from './endpoints/eventSub/HelixEventSubSubscription';
 export { HelixPaginatedEventSubSubscriptionsRequest } from './endpoints/eventSub/HelixPaginatedEventSubSubscriptionsRequest';
 export type { HelixEventSubTransportData, HelixEventSubSubscriptionStatus, } from './interfaces/endpoints/eventSub.external';
-export type { HelixEventSubTransportOptions, HelixEventSubWebSocketTransportOptions, HelixEventSubWebHookTransportOptions, HelixPaginatedEventSubSubscriptionsResult, HelixEventSubDropEntitlementGrantFilter, } from './interfaces/endpoints/eventSub.input';
+export type { HelixEventSubTransportOptions, HelixEventSubWebSocketTransportOptions, HelixEventSubWebHookTransportOptions, HelixEventSubConduitTransportOptions, HelixPaginatedEventSubSubscriptionsResult, HelixEventSubDropEntitlementGrantFilter, HelixEventSubConduitShardsOptions, HelixEventSubConduitShardsTransportOptions, } from './interfaces/endpoints/eventSub.input';
 export { HelixExtensionsApi } from './endpoints/extensions/HelixExtensionsApi';
@@ -53,0 +55,0 @@ export { HelixExtensionBitsProduct } from './endpoints/extensions/HelixExtensionBitsProduct';

lib/index.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.HelixModerator = exports.HelixBan = exports.HelixModerationApi = exports.HelixHypeTrainEvent = exports.HelixHypeTrainContribution = exports.HelixHypeTrainApi = exports.HelixGoal = exports.HelixGoalApi = exports.HelixGame = exports.HelixGameApi = exports.HelixExtensionTransaction = exports.HelixExtensionBitsProduct = exports.HelixExtensionsApi = exports.HelixPaginatedEventSubSubscriptionsRequest = exports.HelixEventSubSubscription = exports.HelixEventSubApi = exports.HelixDropsEntitlement = exports.HelixEntitlementApi = exports.HelixContentClassificationLabel = exports.HelixContentClassificationLabelApi = exports.HelixClip = exports.HelixClipApi = exports.HelixSentChatMessage = exports.HelixPrivilegedChatSettings = exports.HelixEmoteFromSet = exports.HelixChannelEmote = exports.HelixEmote = exports.HelixChatChatter = exports.HelixChatSettings = exports.HelixChatBadgeVersion = exports.HelixChatBadgeSet = exports.HelixChatApi = exports.HelixCharityCampaignAmount = exports.HelixCharityCampaignDonation = exports.HelixCharityCampaign = exports.HelixCharityApi = exports.HelixCustomRewardRedemption = exports.HelixCustomReward = exports.HelixChannelPointsApi = exports.HelixChannelReference = exports.HelixFollowedChannel = exports.HelixChannelFollower = exports.HelixChannelEditor = exports.HelixChannel = exports.HelixChannelApi = exports.HelixCheermoteList = exports.HelixBitsLeaderboardEntry = exports.HelixBitsLeaderboard = exports.HelixBitsApi = exports.ApiClient = void 0;
-exports.extractUserName = exports.extractUserId = exports.HelixPaginatedRequestWithTotal = exports.HelixPaginatedRequest = exports.ApiReportedRequest = exports.StreamNotLiveError = exports.ConfigError = exports.HelixWhisperApi = exports.HelixVideo = exports.HelixVideoApi = exports.HelixUserExtension = exports.HelixInstalledExtensionList = exports.HelixInstalledExtension = exports.HelixBaseExtension = exports.HelixUser = exports.HelixPrivilegedUser = exports.HelixFollow = exports.HelixUserBlock = exports.HelixUserApi = exports.HelixTeamWithUsers = exports.HelixTeam = exports.HelixTeamApi = exports.HelixUserSubscription = exports.HelixSubscription = exports.HelixSubscriptionApi = exports.HelixPaginatedSubscriptionsRequest = exports.HelixStreamMarkerWithVideo = exports.HelixStreamMarker = exports.HelixStream = exports.HelixStreamApi = exports.HelixChannelSearchResult = exports.HelixSearchApi = exports.HelixPaginatedScheduleSegmentRequest = exports.HelixScheduleSegment = exports.HelixSchedule = exports.HelixScheduleApi = exports.HelixUserRelation = exports.HelixRaid = exports.HelixRaidApi = exports.HelixPredictor = exports.HelixPredictionOutcome = exports.HelixPrediction = exports.HelixPredictionApi = exports.HelixPollChoice = exports.HelixPoll = exports.HelixPollApi = exports.HelixShieldModeStatus = exports.HelixBlockedTerm = exports.HelixBanUser = exports.HelixModeratedChannel = void 0;
-exports.HellFreezesOverError = exports.HelixExtension = void 0;
+exports.HelixModerationApi = exports.HelixHypeTrainEvent = exports.HelixHypeTrainContribution = exports.HelixHypeTrainApi = exports.HelixGoal = exports.HelixGoalApi = exports.HelixGame = exports.HelixGameApi = exports.HelixExtensionTransaction = exports.HelixExtensionBitsProduct = exports.HelixExtensionsApi = exports.HelixPaginatedEventSubSubscriptionsRequest = exports.HelixEventSubSubscription = exports.HelixEventSubConduitShard = exports.HelixEventSubConduit = exports.HelixEventSubApi = exports.HelixDropsEntitlement = exports.HelixEntitlementApi = exports.HelixContentClassificationLabel = exports.HelixContentClassificationLabelApi = exports.HelixClip = exports.HelixClipApi = exports.HelixSentChatMessage = exports.HelixPrivilegedChatSettings = exports.HelixEmoteFromSet = exports.HelixChannelEmote = exports.HelixEmote = exports.HelixChatChatter = exports.HelixChatSettings = exports.HelixChatBadgeVersion = exports.HelixChatBadgeSet = exports.HelixChatApi = exports.HelixCharityCampaignAmount = exports.HelixCharityCampaignDonation = exports.HelixCharityCampaign = exports.HelixCharityApi = exports.HelixCustomRewardRedemption = exports.HelixCustomReward = exports.HelixChannelPointsApi = exports.HelixChannelReference = exports.HelixFollowedChannel = exports.HelixChannelFollower = exports.HelixChannelEditor = exports.HelixChannel = exports.HelixChannelApi = exports.HelixCheermoteList = exports.HelixBitsLeaderboardEntry = exports.HelixBitsLeaderboard = exports.HelixBitsApi = exports.ApiClient = void 0;
+exports.HelixPaginatedRequestWithTotal = exports.HelixPaginatedRequest = exports.ApiReportedRequest = exports.StreamNotLiveError = exports.ConfigError = exports.HelixWhisperApi = exports.HelixVideo = exports.HelixVideoApi = exports.HelixUserExtension = exports.HelixInstalledExtensionList = exports.HelixInstalledExtension = exports.HelixBaseExtension = exports.HelixUser = exports.HelixPrivilegedUser = exports.HelixFollow = exports.HelixUserBlock = exports.HelixUserApi = exports.HelixTeamWithUsers = exports.HelixTeam = exports.HelixTeamApi = exports.HelixUserSubscription = exports.HelixSubscription = exports.HelixSubscriptionApi = exports.HelixPaginatedSubscriptionsRequest = exports.HelixStreamMarkerWithVideo = exports.HelixStreamMarker = exports.HelixStream = exports.HelixStreamApi = exports.HelixChannelSearchResult = exports.HelixSearchApi = exports.HelixPaginatedScheduleSegmentRequest = exports.HelixScheduleSegment = exports.HelixSchedule = exports.HelixScheduleApi = exports.HelixUserRelation = exports.HelixRaid = exports.HelixRaidApi = exports.HelixPredictor = exports.HelixPredictionOutcome = exports.HelixPrediction = exports.HelixPredictionApi = exports.HelixPollChoice = exports.HelixPoll = exports.HelixPollApi = exports.HelixShieldModeStatus = exports.HelixBlockedTerm = exports.HelixBanUser = exports.HelixModeratedChannel = exports.HelixModerator = exports.HelixBan = void 0;
+exports.HellFreezesOverError = exports.HelixExtension = exports.extractUserName = exports.extractUserId = void 0;
 var ApiClient_1 = require("./client/ApiClient");
@@ -76,2 +76,6 @@ Object.defineProperty(exports, "ApiClient", { enumerable: true, get: function () { return ApiClient_1.ApiClient; } });
 Object.defineProperty(exports, "HelixEventSubApi", { enumerable: true, get: function () { return HelixEventSubApi_1.HelixEventSubApi; } });
+var HelixEventSubConduit_1 = require("./endpoints/eventSub/HelixEventSubConduit");
+Object.defineProperty(exports, "HelixEventSubConduit", { enumerable: true, get: function () { return HelixEventSubConduit_1.HelixEventSubConduit; } });
+var HelixEventSubConduitShard_1 = require("./endpoints/eventSub/HelixEventSubConduitShard");
+Object.defineProperty(exports, "HelixEventSubConduitShard", { enumerable: true, get: function () { return HelixEventSubConduitShard_1.HelixEventSubConduitShard; } });
 var HelixEventSubSubscription_1 = require("./endpoints/eventSub/HelixEventSubSubscription");
@@ -78,0 +82,0 @@ Object.defineProperty(exports, "HelixEventSubSubscription", { enumerable: true, get: function () { return HelixEventSubSubscription_1.HelixEventSubSubscription; } });

lib/interfaces/endpoints/eventSub.external.d.ts

 import { type HelixPaginatedResponseWithTotal } from '@twurple/api-call';
-export type HelixEventSubSubscriptionStatus = 'enabled' | 'webhook_callback_verification_pending' | 'webhook_callback_verification_failed' | 'notification_failures_exceeded' | 'authorization_revoked' | 'moderator_removed' | 'user_removed' | 'version_removed' | 'beta_maintenance' | 'websocket_disconnected' | 'websocket_failed_ping_pong' | 'websocket_received_inbound_traffic' | 'websocket_connection_unused' | 'websocket_internal_error' | 'websocket_network_timeout' | 'websocket_network_error';
+export type HelixEventSubSubscriptionStatus = 'enabled' | 'webhook_callback_verification_pending' | 'webhook_callback_verification_failed' | 'notification_failures_exceeded' | 'authorization_revoked' | 'moderator_removed' | 'user_removed' | 'version_removed' | 'beta_maintenance' | 'websocket_disconnected' | 'websocket_failed_ping_pong' | 'websocket_received_inbound_traffic' | 'websocket_connection_unused' | 'websocket_internal_error' | 'websocket_network_timeout' | 'websocket_network_error' | 'conduit_deleted';
 /** @private */
@@ -21,3 +21,3 @@ export interface HelixEventSubWebHookTransportData {
     /**
-     * The callback URL to send event notifications to.
+     * The session ID of the websocket.
      */
@@ -29,6 +29,47 @@ session_id: string;
     connected_at: string;
+    /**
+     * The time when the socket connection was lost.
+     */
+    disconnected_at: string;
 }
 /** @private */
-export type HelixEventSubTransportData = HelixEventSubWebHookTransportData | HelixEventSubWebSocketTransportData;
+export interface HelixEventSubConduitTransportData {
+    /**
+     * The type of transport.
+     */
+    method: 'conduit';
+    /**
+     * The conduit ID.
+     */
+    conduit_id: string;
+}
 /** @private */
+export interface HelixEventSubConduitData {
+    /**
+     * The conduit ID.
+     */
+    id: string;
+    /**
+     * The shard count.
+     */
+    shard_count: number;
+}
+/** @private */
+export interface HelixEventSubConduitShardData {
+    /**
+     * The shard ID.
+     */
+    id: string;
+    /**
+     * The shard status.
+     */
+    status: HelixEventSubSubscriptionStatus;
+    /**
+     * The transport method.
+     */
+    transport: HelixEventSubWebHookTransportData | HelixEventSubWebSocketTransportData;
+}
+/** @private */
+export type HelixEventSubTransportData = HelixEventSubWebHookTransportData | HelixEventSubWebSocketTransportData | HelixEventSubConduitTransportData;
+/** @private */
 export interface HelixEventSubSubscriptionData {
@@ -35,0 +76,0 @@ id: string;

lib/interfaces/endpoints/eventSub.external.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.createEventSubDropEntitlementGrantCondition = exports.createEventSubUserCondition = exports.createEventSubModeratorCondition = exports.createEventSubRewardCondition = exports.createEventSubBroadcasterCondition = void 0;
+exports.createEventSubConduitShardsUpdateCondition = exports.createEventSubConduitUpdateCondition = exports.createEventSubConduitCondition = exports.createEventSubDropEntitlementGrantCondition = exports.createEventSubUserCondition = exports.createEventSubModeratorCondition = exports.createEventSubRewardCondition = exports.createEventSubBroadcasterCondition = void 0;
 const common_1 = require("@twurple/common");
@@ -42,1 +42,25 @@ /** @internal */
 exports.createEventSubDropEntitlementGrantCondition = createEventSubDropEntitlementGrantCondition;
+/** @internal */
+function createEventSubConduitCondition(conduitId, status) {
+    return {
+        conduit_id: conduitId,
+        status,
+    };
+}
+exports.createEventSubConduitCondition = createEventSubConduitCondition;
+/** @internal */
+function createEventSubConduitUpdateCondition(conduitId, shardCount) {
+    return {
+        id: conduitId,
+        shard_count: shardCount.toString(),
+    };
+}
+exports.createEventSubConduitUpdateCondition = createEventSubConduitUpdateCondition;
+/** @internal */
+function createEventSubConduitShardsUpdateCondition(conduitId, shards) {
+    return {
+        conduit_id: conduitId,
+        shards,
+    };
+}
+exports.createEventSubConduitShardsUpdateCondition = createEventSubConduitShardsUpdateCondition;

lib/interfaces/endpoints/eventSub.input.d.ts

 import { type HelixEventSubSubscription } from '../../endpoints/eventSub/HelixEventSubSubscription';
 import { type HelixPaginatedResultWithTotal } from '../../utils/pagination/HelixPaginatedResult';
-import { type HelixEventSubWebHookTransportData, type HelixEventSubWebSocketTransportData } from './eventSub.external';
+import type { HelixEventSubWebHookTransportData, HelixEventSubWebSocketTransportData, HelixEventSubConduitTransportData } from './eventSub.external';
 /**
@@ -18,6 +18,11 @@ * The properties describing where a WebHook notification is sent, and how it is signed.
  */
-export interface HelixEventSubWebSocketTransportOptions extends Omit<HelixEventSubWebSocketTransportData, 'connected_at'> {
+export interface HelixEventSubWebSocketTransportOptions extends Omit<HelixEventSubWebSocketTransportData, 'connected_at' | 'disconnected_at'> {
 }
-export type HelixEventSubTransportOptions = HelixEventSubWebHookTransportOptions | HelixEventSubWebSocketTransportOptions;
 /**
+ * The properties describing where a conduit notification is sent.
+ */
+export interface HelixEventSubConduitTransportOptions extends HelixEventSubConduitTransportData {
+}
+export type HelixEventSubTransportOptions = HelixEventSubWebHookTransportOptions | HelixEventSubWebSocketTransportOptions | HelixEventSubConduitTransportOptions;
+/**
  * The result of an EventSub subscription list request.
@@ -54,2 +59,10 @@ *
 }
+export type HelixEventSubConduitShardsTransportOptions = HelixEventSubWebHookTransportOptions | HelixEventSubWebSocketTransportOptions;
+/**
+ * The properties for updating a conduit shard.
+ */
+export interface HelixEventSubConduitShardsOptions {
+    id: string;
+    transport: HelixEventSubConduitShardsTransportOptions;
+}
 //# sourceMappingURL=eventSub.input.d.ts.map

package.json

 {
   "name": "@twurple/api",
-  "version": "7.1.0-pre.8",
+  "version": "7.1.0-pre.9",
   "publishConfig": {
@@ -43,4 +43,4 @@ "access": "public"
     "@d-fischer/typed-event-emitter": "^3.3.1",
-    "@twurple/api-call": "7.1.0-pre.8",
-    "@twurple/common": "7.1.0-pre.8",
+    "@twurple/api-call": "7.1.0-pre.9",
+    "@twurple/common": "7.1.0-pre.9",
     "retry": "^0.13.1",
@@ -50,7 +50,7 @@ "tslib": "^2.0.3"
   "devDependencies": {
-    "@twurple/auth": "7.1.0-pre.8",
+    "@twurple/auth": "7.1.0-pre.9",
     "@types/retry": "^0.12.2"
   },
   "peerDependencies": {
-    "@twurple/auth": "7.1.0-pre.8"
+    "@twurple/auth": "7.1.0-pre.9"
   },
@@ -57,0 +57,0 @@ "files": [

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

1149272

increased by2.06%

Number of package files

495

increased by1.23%

Lines of code

30784

increased by2.11%

Dependency changes

• + Added@twurple/api-call@7.1.0-pre.9(transitive)

• + Added@twurple/auth@7.1.0-pre.9(transitive)

• + Added@twurple/common@7.1.0-pre.9(transitive)

• - Removed@twurple/api-call@7.1.0-pre.8(transitive)

• - Removed@twurple/auth@7.1.0-pre.8(transitive)

• - Removed@twurple/common@7.1.0-pre.8(transitive)

• Updated@twurple/api-call@7.1.0-pre.9

• Updated@twurple/common@7.1.0-pre.9