feat(core): channel context

ChatKitty · Sep 27, 2023 · b79d186 · b79d186
1 parent 602c7b6
commit b79d186
Show file tree

Hide file tree

Showing 4 changed files with 45 additions and 0 deletions.
diff --git a/packages/core/src/lib/channel.ts b/packages/core/src/lib/channel.ts
@@ -42,6 +42,7 @@ export type PrivateChannel = GroupChannel & {
 
 declare class ChannelRelays {
   self: string;
+  context: string;
   messages: string;
   messagesCount: string;
   lastReceivedMessage: string;
@@ -85,6 +86,10 @@ declare class ChannelStreams {
   messages: string;
 }
 
+export declare class ChannelContext {
+  readBy: { [key: string]: number[] };
+}
+
 export function isDirectChannel(channel: Channel): channel is DirectChannel {
   return channel.type === 'DIRECT';
 }
@@ -152,6 +157,12 @@ export declare class ListUnreadChannelsFilter {
 
 export type CountUnreadChannelsRequest = ListUnreadChannelsRequest;
 
+export declare class RetrieveChannelContextRequest {
+  channel: Channel;
+  startCursor: number;
+  endCursor: number;
+}
+
 export declare class RetrieveChannelUnreadRequest {
   channel: Channel;
 }
@@ -176,6 +187,16 @@ export class RetrieveChannelSucceededResult extends ChatKittySucceededResult {
   }
 }
 
+export type RetrieveChannelContextResult =
+  | RetrieveChannelContextSucceededResult
+  | ChatKittyFailedResult;
+
+export class RetrieveChannelContextSucceededResult extends ChatKittySucceededResult {
+  constructor(public context: ChannelContext) {
+    super();
+  }
+}
+
 export declare class CheckChannelUnreadRequest {
   channel: Channel;
 }

diff --git a/packages/core/src/lib/chatkitty.ts b/packages/core/src/lib/chatkitty.ts
@@ -58,6 +58,9 @@ import {
   CountUnreadChannelsRequest,
   CheckChannelUnreadSucceededResult,
   CheckChannelUnreadRequest,
+  RetrieveChannelContextRequest,
+  RetrieveChannelContextResult,
+  RetrieveChannelContextSucceededResult, ChannelContext,
 } from './channel';
 import {
   ChatSession,
@@ -601,6 +604,24 @@ export class ChatKitty {
     });
   }
 
+  retrieveChannelContext(request: RetrieveChannelContextRequest): Promise<RetrieveChannelContextResult> {
+    return new Promise((resolve) => {
+      this.stompX.relayResource<ChannelContext>({
+        destination: request.channel._relays.context,
+        parameters: {
+          startCursor: request.startCursor,
+          endCursor: request.endCursor,
+        },
+        onSuccess: (context) => {
+          resolve(new RetrieveChannelContextSucceededResult(context));
+        },
+        onError: (error) => {
+          resolve(new ChatKittyFailedResult(error));
+        },
+      });
+    });
+  }
+
   joinChannel(request: JoinChannelRequest): Promise<JoinChannelResult> {
     const currentUser = this.currentUser;
 

diff --git a/packages/core/src/lib/message.ts b/packages/core/src/lib/message.ts
@@ -23,6 +23,7 @@ export type FileMessage = FileSystemMessage | FileUserMessage;
 
 export interface BaseMessage {
   id: number;
+  cursor: number;
   type: string;
   channelId: number;
   createdTime: string;

diff --git a/packages/core/src/lib/stompx.ts b/packages/core/src/lib/stompx.ts
@@ -534,6 +534,8 @@ export declare class StompXPageMetadata {
   totalElement: number;
   totalPages: number;
   number: number;
+  start: number;
+  next: number;
 }
 
 export declare class StompXPageRelays {