feat(jike-client): add queryFollowingUpdates

Author: sxzz

src/client/client.ts

@@ -8,13 +8,16 @@ import { JikeUser } from './user'
 import { fetchPaginated } from './utils/paginate'
 import { AuthorizationError } from './errors/AuthorizationError'
 import { JikePost } from './post'
+import type { PersonalUpdate } from '../types/api-responses'
 import type { CreatePostOption, PostType } from '../types/options'
-import type { Notification } from '../types/entity'
+import type { Notification, PostDetail } from '../types/entity'
 import type { BeforeRetryState } from 'ky/distribution/types/hooks'
 import type { PaginatedFetcher, PaginatedOption } from './utils/paginate'
 import type { Api } from '../api'
 import type { ApiConfig, ApiConfigResolved } from '../request'
 
+type FollowingUpdatesMoreKey = PersonalUpdate.FollowingUpdatesResponseMoreKey
+
 export class JikeClient {
   #refreshToken: string
   #config: ApiConfigResolved
@@ -194,6 +197,37 @@ export class JikeClient {
     )
   }
 
+  /**
+   * 查询关注动态
+   */
+  async queryFollowingUpdates(
+    option: PaginatedOption<
+      PostDetail,
+      'createdAt',
+      FollowingUpdatesMoreKey
+    > = {}
+  ) {
+    const fetcher: PaginatedFetcher<
+      PostDetail,
+      FollowingUpdatesMoreKey
+    > = async (lastKey) => {
+      const result = await this.#client.personalUpdate.followingUpdates({
+        loadMoreKey: lastKey,
+      })
+      if (!isSuccess(result)) throwRequestFailureError(result, '查询关注动态')
+      const newKey = result.data.loadMoreKey
+      return [newKey, result.data.data]
+    }
+    return fetchPaginated(
+      fetcher,
+      (item, data) => ({
+        createdAt: new Date(item.createdAt),
+        total: data.length + 1,
+      }),
+      option
+    )
+  }
+
   /**
    *
    * @param type 动态类型，原帖 或 转发

src/types/api-responses.ts

@@ -126,6 +126,9 @@ export namespace PersonalUpdate {
       lastReadTime: number
     }
   }
+
+  export type FollowingUpdatesResponseMoreKey =
+    FollowingUpdatesResponse['loadMoreKey']
 }
 
 export namespace Comments {

tests/jike-client/feeds.test.ts

@@ -0,0 +1,15 @@
+import { describe, expect, it } from 'vitest'
+import { JikeClient, limit } from '../../src'
+import { config, refreshToken } from '../config'
+
+describe('feeds', () => {
+  const client = new JikeClient({ ...config, refreshToken })
+
+  it('queryFollowingUpdates should work', async () => {
+    const MAX_COUNT = 40
+    const records = await client.queryFollowingUpdates({
+      limit: limit.limitMaxCount(MAX_COUNT),
+    })
+    expect(records.length).toBe(40)
+  })
+})