feat: update to latest API spec, deprecate followBatch and unfollowBatch

Author: szuperaz

src/StreamClient.ts

@@ -6,8 +6,10 @@ import { StreamChatClient } from './StreamChatClient';
 import { CallTokenPayload, UserTokenPayload } from './types';
 import {
   FileUploadRequest,
+  FollowBatchRequest,
   ImageUploadRequest,
   QueryBannedUsersPayload,
+  UnfollowBatchRequest,
   UserRequest,
 } from './gen/models';
 import { StreamModerationClient } from './StreamModerationClient';
@@ -240,6 +242,20 @@ export class StreamClient extends CommonApi {
     return JWTUserToken(this.secret, payload);
   };
 
+  /**
+   * @deprecated use `getOrCreateFollows` instead
+   */
+  followBatch(request: FollowBatchRequest) {
+    return this.feeds.followBatch(request);
+  }
+
+  /**
+   * @deprecated use `getOrCreateUnfollows` instead
+   */
+  followUnbatch(request: UnfollowBatchRequest) {
+    return this.feeds.unfollowBatch(request);
+  }
+
   verifyWebhook = (requestBody: string | Buffer, xSignature: string) => {
     const key = Buffer.from(this.secret, 'utf8');
     const hash = crypto

src/gen/feeds/FeedsApi.ts

@@ -43,6 +43,8 @@ import {
   DeleteFeedUserDataRequest,
   DeleteFeedUserDataResponse,
   DeleteFeedViewResponse,
+  DeleteFeedsBatchRequest,
+  DeleteFeedsBatchResponse,
   ExportFeedUserDataResponse,
   FollowBatchRequest,
   FollowBatchResponse,
@@ -66,8 +68,8 @@ import {
   ListFeedViewsResponse,
   ListFeedVisibilitiesResponse,
   MarkActivityRequest,
-  OwnCapabilitiesBatchRequest,
-  OwnCapabilitiesBatchResponse,
+  OwnBatchRequest,
+  OwnBatchResponse,
   PinActivityRequest,
   PinActivityResponse,
   PollVoteResponse,
@@ -1237,6 +1239,7 @@ export class FeedsApi {
       view: request?.view,
       watch: request?.watch,
       data: request?.data,
+      enrichment_options: request?.enrichment_options,
       external_ranking: request?.external_ranking,
       filter: request?.filter,
       followers_pagination: request?.followers_pagination,
@@ -1849,27 +1852,52 @@ export class FeedsApi {
     return { ...response.body, metadata: response.metadata };
   }
 
-  async ownCapabilitiesBatch(
-    request: OwnCapabilitiesBatchRequest,
-  ): Promise<StreamResponse<OwnCapabilitiesBatchResponse>> {
+  async deleteFeedsBatch(
+    request: DeleteFeedsBatchRequest,
+  ): Promise<StreamResponse<DeleteFeedsBatchResponse>> {
+    const body = {
+      feeds: request?.feeds,
+      hard_delete: request?.hard_delete,
+    };
+
+    const response = await this.apiClient.sendRequest<
+      StreamResponse<DeleteFeedsBatchResponse>
+    >(
+      'POST',
+      '/api/v2/feeds/feeds/delete',
+      undefined,
+      undefined,
+      body,
+      'application/json',
+    );
+
+    decoders.DeleteFeedsBatchResponse?.(response.body);
+
+    return { ...response.body, metadata: response.metadata };
+  }
+
+  async ownBatch(
+    request: OwnBatchRequest,
+  ): Promise<StreamResponse<OwnBatchResponse>> {
     const body = {
       feeds: request?.feeds,
       user_id: request?.user_id,
+      fields: request?.fields,
       user: request?.user,
     };
 
     const response = await this.apiClient.sendRequest<
-      StreamResponse<OwnCapabilitiesBatchResponse>
+      StreamResponse<OwnBatchResponse>
     >(
       'POST',
-      '/api/v2/feeds/feeds/own_capabilities/batch',
+      '/api/v2/feeds/feeds/own/batch',
       undefined,
       undefined,
       body,
       'application/json',
     );
 
-    decoders.OwnCapabilitiesBatchResponse?.(response.body);
+    decoders.OwnBatchResponse?.(response.body);
 
     return { ...response.body, metadata: response.metadata };
   }
@@ -2031,6 +2059,29 @@ export class FeedsApi {
     return { ...response.body, metadata: response.metadata };
   }
 
+  async getOrCreateFollows(
+    request: FollowBatchRequest,
+  ): Promise<StreamResponse<FollowBatchResponse>> {
+    const body = {
+      follows: request?.follows,
+    };
+
+    const response = await this.apiClient.sendRequest<
+      StreamResponse<FollowBatchResponse>
+    >(
+      'POST',
+      '/api/v2/feeds/follows/batch/upsert',
+      undefined,
+      undefined,
+      body,
+      'application/json',
+    );
+
+    decoders.FollowBatchResponse?.(response.body);
+
+    return { ...response.body, metadata: response.metadata };
+  }
+
   async queryFollows(
     request?: QueryFollowsRequest,
   ): Promise<StreamResponse<QueryFollowsResponse>> {
@@ -2256,6 +2307,29 @@ export class FeedsApi {
     return { ...response.body, metadata: response.metadata };
   }
 
+  async getOrCreateUnfollows(
+    request: UnfollowBatchRequest,
+  ): Promise<StreamResponse<UnfollowBatchResponse>> {
+    const body = {
+      follows: request?.follows,
+    };
+
+    const response = await this.apiClient.sendRequest<
+      StreamResponse<UnfollowBatchResponse>
+    >(
+      'POST',
+      '/api/v2/feeds/unfollow/batch/upsert',
+      undefined,
+      undefined,
+      body,
+      'application/json',
+    );
+
+    decoders.UnfollowBatchResponse?.(response.body);
+
+    return { ...response.body, metadata: response.metadata };
+  }
+
   async deleteFeedUserData(
     request: DeleteFeedUserDataRequest & { user_id: string },
   ): Promise<StreamResponse<DeleteFeedUserDataResponse>> {

src/gen/model-decoders/decoders.ts

@@ -2094,6 +2094,15 @@ decoders.FeedMemberUpdatedEvent = (input?: Record<string, any>) => {
   return decode(typeMappings, input);
 };
 
+decoders.FeedOwnData = (input?: Record<string, any>) => {
+  const typeMappings: TypeMapping = {
+    own_follows: { type: 'FollowResponse', isSingle: false },
+
+    own_membership: { type: 'FeedMemberResponse', isSingle: true },
+  };
+  return decode(typeMappings, input);
+};
+
 decoders.FeedResponse = (input?: Record<string, any>) => {
   const typeMappings: TypeMapping = {
     created_at: { type: 'DatetimeType', isSingle: true },
@@ -2195,6 +2204,8 @@ decoders.FlagUpdatedEvent = (input?: Record<string, any>) => {
 
 decoders.FollowBatchResponse = (input?: Record<string, any>) => {
   const typeMappings: TypeMapping = {
+    created: { type: 'FollowResponse', isSingle: false },
+
     follows: { type: 'FollowResponse', isSingle: false },
   };
   return decode(typeMappings, input);
@@ -3164,6 +3175,13 @@ decoders.NotificationStatusResponse = (input?: Record<string, any>) => {
   return decode(typeMappings, input);
 };
 
+decoders.OwnBatchResponse = (input?: Record<string, any>) => {
+  const typeMappings: TypeMapping = {
+    data: { type: 'FeedOwnData', isSingle: false },
+  };
+  return decode(typeMappings, input);
+};
+
 decoders.OwnUser = (input?: Record<string, any>) => {
   const typeMappings: TypeMapping = {
     created_at: { type: 'DatetimeType', isSingle: true },
@@ -3490,6 +3508,21 @@ decoders.QueryCallSessionParticipantStatsTimelineResponse = (
   return decode(typeMappings, input);
 };
 
+decoders.QueryCallStatsMapResponse = (input?: Record<string, any>) => {
+  const typeMappings: TypeMapping = {
+    call_ended_at: { type: 'DatetimeType', isSingle: true },
+
+    call_started_at: { type: 'DatetimeType', isSingle: true },
+
+    end_time: { type: 'DatetimeType', isSingle: true },
+
+    generated_at: { type: 'DatetimeType', isSingle: true },
+
+    start_time: { type: 'DatetimeType', isSingle: true },
+  };
+  return decode(typeMappings, input);
+};
+
 decoders.QueryCallStatsResponse = (input?: Record<string, any>) => {
   const typeMappings: TypeMapping = {
     reports: { type: 'CallStatsReportSummaryResponse', isSingle: false },