feat: release 3.8.3 (#160)

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@openim/wasm-client-sdk",
-  "version": "3.8.2-3",
+  "version": "3.8.3",
   "description": "open im sdk for web",
   "source": "src/index.ts",
   "main": "lib/index.js",

src/api/database/message.ts

@@ -3,6 +3,7 @@ import {
   ClientMessage,
   getMessage as databaseGetMessage,
   getAlreadyExistSeqList as databaseGetAlreadyExistSeqList,
+  getLatestValidServerMessage as databaseGetLatestValidServerMessage,
   getMessageBySeq as databaseGetMessageBySeq,
   getMessagesByClientMsgIDs as databaseGetMessagesByClientMsgIDs,
   getMessagesBySeqs as databaseGetMessagesBySeqs,
@@ -107,6 +108,47 @@ export async function getAlreadyExistSeqList(
   }
 }
 
+export async function getLatestValidServerMessage(
+  conversationID: string,
+  startTime: number,
+  isReverse: boolean
+): Promise<string> {
+  try {
+    const db = await getInstance();
+
+    const execResult = databaseGetLatestValidServerMessage(
+      db,
+      conversationID,
+      startTime,
+      isReverse
+    );
+
+    const message = converSqlExecResult(execResult[0], 'CamelCase', [
+      'isRead',
+      'isReact',
+      'isExternalExtensions',
+    ])[0];
+
+    if (!message) {
+      return formatResponse(
+        '',
+        DatabaseErrorCode.ErrorNoRecord,
+        `no message with conversationID ${conversationID}`
+      );
+    }
+
+    return formatResponse(message);
+  } catch (e) {
+    console.error(e);
+
+    return formatResponse(
+      undefined,
+      DatabaseErrorCode.ErrorInit,
+      JSON.stringify(e)
+    );
+  }
+}
+
 export async function getMessageList(
   conversationID: string,
   count: number,

src/api/index.ts

@@ -238,6 +238,9 @@ export function initDatabaseAPI(isLogStandardOutput = true): void {
   window.getAlreadyExistSeqList = registeMethodOnWindow(
     'getAlreadyExistSeqList'
   );
+  window.getLatestValidServerMessage = registeMethodOnWindow(
+    'getLatestValidServerMessage'
+  );
   window.getMessageBySeq = registeMethodOnWindow('getMessageBySeq');
   window.getMessagesByClientMsgIDs = registeMethodOnWindow(
     'getMessagesByClientMsgIDs'

src/api/worker.ts

@@ -158,6 +158,7 @@ import {
   getPageFriendList,
   getGroupMemberAllGroupIDs,
   getAlreadyExistSeqList,
+  getLatestValidServerMessage,
   markConversationAllMessageAsRead,
   searchAllMessageByContentType,
   deleteConversationMsgs,
@@ -249,6 +250,7 @@ rpc.registerMethod(
   updateMsgSenderFaceURLAndSenderNickname
 );
 rpc.registerMethod('getAlreadyExistSeqList', getAlreadyExistSeqList);
+rpc.registerMethod('getLatestValidServerMessage', getLatestValidServerMessage);
 rpc.registerMethod('getMessageBySeq', getMessageBySeq);
 rpc.registerMethod('getMessagesByClientMsgIDs', getMessagesByClientMsgIDs);
 rpc.registerMethod('getMessagesBySeqs', getMessagesBySeqs);

src/sdk/index.ts

@@ -74,6 +74,7 @@ import {
   GetSpecifiedFriendsParams,
   ChangeInputStatesParams,
   GetInputstatesParams,
+  FetchSurroundingParams,
 } from '../types/params';
 
 import {
@@ -299,6 +300,16 @@ class SDK extends Emitter {
       [operationID, JSON.stringify(params)]
     );
   };
+  fetchSurroundingMessages = (
+    params: FetchSurroundingParams,
+    operationID = uuidv4()
+  ) => {
+    return this._invoker<{ messageList: MessageItem[] }>(
+      'fetchSurroundingMessages',
+      window.fetchSurroundingMessages,
+      [operationID, JSON.stringify(params)]
+    );
+  };
   getSpecifiedGroupsInfo = (params: string[], operationID = uuidv4()) => {
     return this._invoker<GroupItem[]>(
       'getSpecifiedGroupsInfo',

src/sqls/localChatLogsConversationID.ts

@@ -586,3 +586,22 @@ export function getLatestActiveMessage(
     `
   );
 }
+
+export function getLatestValidServerMessage(
+  db: Database,
+  conversationID: string,
+  startTime: number,
+  isReverse: boolean
+): QueryExecResult[] {
+  _initLocalChatLogsTable(db, conversationID);
+  const order = isReverse ? 'ASC' : 'DESC';
+  return db.exec(
+    `
+      SELECT * FROM 'chat_logs_${conversationID}' WHERE send_time ${
+      isReverse ? '<' : '>'
+    } ${startTime} AND seq != 0 ORDER BY send_time ${
+      isReverse ? 'DESC' : 'ASC'
+    } LIMIT 1
+    `
+  );
+}

src/types/entity.ts

@@ -416,7 +416,6 @@ export type SearchMessageResultItem = {
 
 export type AdvancedGetMessageResult = {
   isEnd: boolean;
-  lastMinSeq: number;
   errCode: number;
   errMsg: string;
   messageList: MessageItem[];

src/types/enum.ts

@@ -132,3 +132,7 @@ export enum GroupMessageReaderFilter {
   Read = 0,
   UnRead = 1,
 }
+export enum ViewType {
+  History = 0,
+  Search = 1,
+}

src/types/index.d.ts

@@ -56,6 +56,7 @@ declare global {
     updateGroupMessageHasRead: DatabaseApi;
     updateMessageStatusBySourceID: DatabaseApi;
     getAlreadyExistSeqList: DatabaseApi;
+    getLatestValidServerMessage: DatabaseApi;
     getMessageBySeq: DatabaseApi;
     getMessagesByClientMsgIDs: DatabaseApi;
     getMessagesBySeqs: DatabaseApi;
@@ -267,6 +268,10 @@ declare global {
       operationID: string,
       getAdvancedHistoryMessageListReverseParamsStr: string
     ) => Promise<string>;
+    fetchSurroundingMessages: (
+      operationID: string,
+      fetchSurroundingMessagesParamsStr: string
+    ) => Promise<string>;
     getHistoryMessageList: (
       operationID: string,
       getHistoryMsgParamsParamsStr: string

src/types/params.ts

@@ -19,6 +19,7 @@ import {
   LogLevel,
   GroupMessageReaderFilter,
   GroupAtType,
+  ViewType,
 } from './enum';
 
 export type WasmPathConfig = {
@@ -44,13 +45,17 @@ export type GetOneConversationParams = {
   sessionType: number;
 };
 export type GetAdvancedHistoryMsgParams = {
-  userID?: string;
-  groupID?: string;
-  lastMinSeq: number;
   count: number;
+  viewType: ViewType;
   startClientMsgID: string;
   conversationID: string;
 };
+export type FetchSurroundingParams = {
+  startMessage: MessageItem;
+  viewType: ViewType;
+  before: number;
+  after: number;
+};
 export type GetHistoryMsgParams = {
   userID: string;
   groupID: string;