Add feeds-api

Author: szuperaz

generate-openapi.sh

@@ -1,11 +1,11 @@
 #!/bin/bash
 set -euo pipefail
 
-OUTPUT_DIR="../stream-node/src/gen"
+OUTPUT_DIR="../stream-node/src/gen-feeds"
 CHAT_DIR="../chat"
 
 rm -rf $OUTPUT_DIR
 
-( cd $CHAT_DIR ; make openapi ; go run ./cmd/chat-manager openapi generate-client --language ts --spec ./releases/v2/serverside-api.yaml --output $OUTPUT_DIR )
+( cd $CHAT_DIR ; make openapi ; go run ./cmd/chat-manager openapi generate-client --language ts --spec ./releases/v2/feeds-serverside-api.yaml --output $OUTPUT_DIR )
 
 yarn lint:gen

index.ts

@@ -1,6 +1,7 @@
-export * from './src/gen/models';
 export * from './src/StreamClient';
 export * from './src/StreamCall';
 export * from './src/StreamChatClient';
 export * from './src/StreamChannel';
 export * from './src/StreamVideoClient';
+export * from './src/gen-feeds/models';
+export * from './src/gen/models';

package.json

@@ -29,7 +29,7 @@
     "lint": "eslint **/*.ts",
     "lint:fix": "eslint --fix **/*.ts",
     "prettier:fix": "prettier . --write",
-    "lint:gen": "eslint --fix src/gen/**/*ts && prettier src/gen/**/*.ts --write"
+    "lint:gen": "eslint --fix src/gen-feeds/**/*ts && prettier src/gen-feeds/**/*.ts --write"
   },
   "lint-staged": {
     "**/*": [

src/ApiClient.ts

@@ -1,6 +1,6 @@
 import { v4 as uuidv4 } from 'uuid';
 import { ApiConfig, RequestMetadata, StreamError } from './types';
-import { APIError } from './gen/models';
+import { APIError } from './gen-feeds/models';
 import { getRateLimitFromResponseHeader } from './utils/rate-limit';
 
 export class ApiClient {

src/StreamClient.ts

@@ -4,9 +4,11 @@ import { StreamVideoClient } from './StreamVideoClient';
 import crypto from 'crypto';
 import { StreamChatClient } from './StreamChatClient';
 import { CallTokenPayload, UserTokenPayload } from './types';
-import { QueryBannedUsersPayload, UserRequest } from './gen/models';
+import { QueryBannedUsersPayload } from './gen/models';
 import { StreamModerationClient } from './StreamModerationClient';
 import { ApiClient } from './ApiClient';
+import { UserRequest } from './gen-feeds/models';
+import { StreamFeedsClient } from './StreamFeedsClient';
 
 export interface StreamClientOptions {
   timeout?: number;
@@ -20,6 +22,7 @@ export class StreamClient extends CommonApi {
   public readonly video: StreamVideoClient;
   public readonly chat: StreamChatClient;
   public readonly moderation: StreamModerationClient;
+  public readonly feeds: StreamFeedsClient;
   public readonly options: StreamClientOptions = {};
 
   private static readonly DEFAULT_TIMEOUT = 3000;
@@ -39,6 +42,7 @@ export class StreamClient extends CommonApi {
     const timeout = config?.timeout ?? StreamClient.DEFAULT_TIMEOUT;
     const chatBaseUrl = config?.basePath ?? 'https://chat.stream-io-api.com';
     const videoBaseUrl = config?.basePath ?? 'https://video.stream-io-api.com';
+    const feedsBaseUrl = config?.basePath ?? 'https://feeds.stream-io-api.com';
     const chatApiClient = new ApiClient({
       apiKey,
       token,
@@ -55,6 +59,14 @@ export class StreamClient extends CommonApi {
       agent: config?.agent as RequestInit['dispatcher'],
     });
 
+    const feedsApiClient = new ApiClient({
+      apiKey,
+      token,
+      baseUrl: feedsBaseUrl,
+      timeout,
+      agent: config?.agent as RequestInit['dispatcher'],
+    });
+
     super(chatApiClient);
 
     this.video = new StreamVideoClient({
@@ -63,6 +75,7 @@ export class StreamClient extends CommonApi {
     });
     this.chat = new StreamChatClient(this.apiClient);
     this.moderation = new StreamModerationClient(chatApiClient);
+    this.feeds = new StreamFeedsClient(feedsApiClient);
   }
 
   upsertUsers = (users: UserRequest[]) => {

src/StreamFeed.ts

@@ -0,0 +1,3 @@
+import { FeedApi } from './gen-feeds/feeds/FeedApi';
+
+export class StreamFeed extends FeedApi {}

src/StreamFeedsClient.ts

@@ -0,0 +1,8 @@
+import { FeedsApi } from './gen-feeds/feeds/FeedsApi';
+import { StreamFeed } from './StreamFeed';
+
+export class StreamFeedsClient extends FeedsApi {
+  feed = (group: string, id: string) => {
+    return new StreamFeed(this, group, id);
+  };
+}

src/gen-feeds/feeds/FeedApi.ts

@@ -0,0 +1,128 @@
+import { StreamResponse, FeedsApi } from '../../gen-imports';
+import {
+  AcceptFeedMemberRequest,
+  AcceptFeedMemberResponse,
+  DeleteFeedResponse,
+  GetOrCreateFeedRequest,
+  GetOrCreateFeedResponse,
+  MarkActivityRequest,
+  PinActivityRequest,
+  PinActivityResponse,
+  QueryFeedMembersRequest,
+  QueryFeedMembersResponse,
+  RejectFeedMemberRequest,
+  RejectFeedMemberResponse,
+  Response,
+  UnpinActivityResponse,
+  UpdateFeedMembersRequest,
+  UpdateFeedRequest,
+  UpdateFeedResponse,
+} from '../models';
+
+export class FeedApi {
+  constructor(
+    protected feedsApi: FeedsApi,
+    public readonly group: string,
+    public readonly id: string,
+  ) {}
+
+  delete(request?: {
+    hard_delete?: boolean;
+  }): Promise<StreamResponse<DeleteFeedResponse>> {
+    return this.feedsApi.deleteFeed({
+      feed_id: this.id,
+      feed_group_id: this.group,
+      ...request,
+    });
+  }
+
+  update(
+    request?: UpdateFeedRequest,
+  ): Promise<StreamResponse<UpdateFeedResponse>> {
+    return this.feedsApi.updateFeed({
+      feed_id: this.id,
+      feed_group_id: this.group,
+      ...request,
+    });
+  }
+
+  getOrCreate(
+    request?: GetOrCreateFeedRequest,
+  ): Promise<StreamResponse<GetOrCreateFeedResponse>> {
+    return this.feedsApi.getOrCreateFeed({
+      feed_id: this.id,
+      feed_group_id: this.group,
+      ...request,
+    });
+  }
+
+  markActivity(
+    request?: MarkActivityRequest,
+  ): Promise<StreamResponse<Response>> {
+    return this.feedsApi.markActivity({
+      feed_id: this.id,
+      feed_group_id: this.group,
+      ...request,
+    });
+  }
+
+  unpinActivity(request: {
+    activity_id: string;
+  }): Promise<StreamResponse<UnpinActivityResponse>> {
+    return this.feedsApi.unpinActivity({
+      feed_id: this.id,
+      feed_group_id: this.group,
+      ...request,
+    });
+  }
+
+  pinActivity(
+    request: PinActivityRequest & { activity_id: string },
+  ): Promise<StreamResponse<PinActivityResponse>> {
+    return this.feedsApi.pinActivity({
+      feed_id: this.id,
+      feed_group_id: this.group,
+      ...request,
+    });
+  }
+
+  updateFeedMembers(
+    request: UpdateFeedMembersRequest,
+  ): Promise<StreamResponse<Response>> {
+    return this.feedsApi.updateFeedMembers({
+      feed_id: this.id,
+      feed_group_id: this.group,
+      ...request,
+    });
+  }
+
+  acceptFeedMember(
+    request: AcceptFeedMemberRequest,
+  ): Promise<StreamResponse<AcceptFeedMemberResponse>> {
+    return this.feedsApi.acceptFeedMember({
+      feed_id: this.id,
+      feed_group_id: this.group,
+      ...request,
+    });
+  }
+
+  queryFeedMembers(
+    request?: QueryFeedMembersRequest,
+  ): Promise<StreamResponse<QueryFeedMembersResponse>> {
+    return this.feedsApi.queryFeedMembers({
+      feed_id: this.id,
+      feed_group_id: this.group,
+      ...request,
+    });
+  }
+
+  rejectFeedMember(
+    request: RejectFeedMemberRequest,
+  ): Promise<StreamResponse<RejectFeedMemberResponse>> {
+    return this.feedsApi.rejectFeedMember({
+      feed_id: this.id,
+      feed_group_id: this.group,
+      ...request,
+    });
+  }
+}