feat: use new ownBatch endpoint (this is an internal endpoint) (#181)

🎫 Ticket:
https://linear.app/stream/issue/REACT-681/migrate-to-new-batch-endpoint

📑 Docs: N/A internal endpoint

### 💡 Overview
- `ownCapabilitiesBatch` is replaced with `ownBatch`
- The new endpoint is capable of backfilling all `own_` fields of
`FeedResponse` not just `own_capabilities`

### 📝 Implementation notes
- The SDK only backfills `own_capabilities` for now (JS can't easily
backfill all `own_` fields, so there is a follow up issue for that)

Author: szuperaz

packages/feeds-client/__integration-tests__/deferred-own-capabilities-hydration.test.ts

@@ -249,7 +249,7 @@ describe('Deferred own_capabilities hydration', () => {
 
   it('should throttle new capabilities hydration', async () => {
     const client = createTestClient();
-    const getCapabilitiesSpy = vi.spyOn(client as any, 'ownCapabilitiesBatch');
+    const getCapabilitiesSpy = vi.spyOn(client as any, 'ownBatch');
     await client.connectUser(ownUser, createTestTokenGenerator(ownUser));
     const ownFeed = client.feed(feedGroup, feedId);
 

packages/feeds-client/src/feeds-client/feeds-client.ts

@@ -16,7 +16,7 @@ import type {
   FollowRequest,
   GetOrCreateFeedRequest,
   ImageUploadRequest,
-  OwnCapabilitiesBatchRequest,
+  OwnBatchRequest,
   PollResponse,
   PollVotesResponse,
   QueryFeedsRequest,
@@ -286,7 +286,7 @@ export class FeedsClient extends FeedsApi {
       cancelTimer: cancel,
     } = throttle<GetBatchedOwnCapabilitiesThrottledCallback>(
       (feeds, callback) => {
-        this.ownCapabilitiesBatch({
+        this.ownBatch({
           feeds,
         }).catch((error) => {
           this.eventDispatcher.dispatch({
@@ -745,12 +745,12 @@ export class FeedsClient extends FeedsApi {
     };
   }
 
-  async ownCapabilitiesBatch(request: OwnCapabilitiesBatchRequest) {
-    const response = await super.ownCapabilitiesBatch(request);
-    const feedResponses = Object.entries(response.capabilities).map(
-      ([feed, own_capabilities]) => ({
+  async ownBatch(request: OwnBatchRequest) {
+    const response = await super.ownBatch(request);
+    const feedResponses = Object.entries(response.data).map(
+      ([feed, ownFields]) => ({
         feed,
-        own_capabilities,
+        own_capabilities: ownFields.own_capabilities,
       }),
     );
     this.hydrateCapabilitiesCache(feedResponses);

packages/feeds-client/src/gen/feeds/FeedsApi.ts

@@ -62,8 +62,8 @@ import type {
   ListBlockListResponse,
   ListDevicesResponse,
   MarkActivityRequest,
-  OwnCapabilitiesBatchRequest,
-  OwnCapabilitiesBatchResponse,
+  OwnBatchRequest,
+  OwnBatchResponse,
   PinActivityRequest,
   PinActivityResponse,
   PollOptionResponse,
@@ -104,6 +104,8 @@ import type {
   SingleFollowResponse,
   UnblockUsersRequest,
   UnblockUsersResponse,
+  UnfollowBatchRequest,
+  UnfollowBatchResponse,
   UnfollowResponse,
   UnpinActivityResponse,
   UpdateActivityPartialRequest,
@@ -979,14 +981,14 @@ export class FeedsApi {
   }
 
   async addComment(
-    request: AddCommentRequest,
+    request?: AddCommentRequest,
   ): Promise<StreamResponse<AddCommentResponse>> {
     const body = {
-      object_id: request?.object_id,
-      object_type: request?.object_type,
       comment: request?.comment,
       create_notification_activity: request?.create_notification_activity,
       id: request?.id,
+      object_id: request?.object_id,
+      object_type: request?.object_type,
       parent_id: request?.parent_id,
       skip_enrich_url: request?.skip_enrich_url,
       skip_push: request?.skip_push,
@@ -1621,28 +1623,29 @@ export class FeedsApi {
     return { ...response.body, metadata: response.metadata };
   }
 
-  async ownCapabilitiesBatch(
-    request: OwnCapabilitiesBatchRequest & { connection_id?: string },
-  ): Promise<StreamResponse<OwnCapabilitiesBatchResponse>> {
+  async ownBatch(
+    request: OwnBatchRequest & { connection_id?: string },
+  ): Promise<StreamResponse<OwnBatchResponse>> {
     const queryParams = {
       connection_id: request?.connection_id,
     };
     const body = {
       feeds: request?.feeds,
+      fields: request?.fields,
     };
 
     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,
       queryParams,
       body,
       'application/json',
     );
 
-    decoders.OwnCapabilitiesBatchResponse?.(response.body);
+    decoders.OwnBatchResponse?.(response.body);
 
     return { ...response.body, metadata: response.metadata };
   }
@@ -1783,6 +1786,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>> {
@@ -1857,6 +1883,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 createGuest(
     request: CreateGuestRequest,
   ): Promise<StreamResponse<CreateGuestResponse>> {