feat: add getLatestActiveMessage func

package.json

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

src/api/database/message.ts

@@ -31,6 +31,7 @@ import {
   getUnreadMessage as databaseGetUnreadMessage,
   markConversationMessageAsReadBySeqs as databaseMarkConversationMessageAsReadBySeqs,
   markConversationMessageAsRead as databaseMarkConversationMessageAsRead,
+  getLatestActiveMessage as databaseGetLatestActiveMessage,
 } from '@/sqls';
 import {
   converSqlExecResult,
@@ -950,3 +951,34 @@ export async function searchAllMessageByContentType(
     );
   }
 }
+
+export async function getLatestActiveMessage(
+  conversationID: string,
+  isReverse: boolean
+): Promise<string> {
+  try {
+    const db = await getInstance();
+
+    const execResult = databaseGetLatestActiveMessage(
+      db,
+      conversationID,
+      isReverse
+    );
+
+    return formatResponse(
+      converSqlExecResult(execResult[0], 'CamelCase', [
+        'isRead',
+        'isReact',
+        'isExternalExtensions',
+      ])
+    );
+  } catch (e) {
+    console.error(e);
+
+    return formatResponse(
+      undefined,
+      DatabaseErrorCode.ErrorInit,
+      JSON.stringify(e)
+    );
+  }
+}

src/api/index.ts

@@ -342,6 +342,9 @@ export function initDatabaseAPI(isLogStandardOutput = true): void {
   );
   window.getAllConversations = registeMethodOnWindow('getAllConversations');
   window.searchConversations = registeMethodOnWindow('searchConversations');
+  window.getLatestActiveMessage = registeMethodOnWindow(
+    'getLatestActiveMessage'
+  );
 
   // users
   window.getLoginUser = registeMethodOnWindow('getLoginUser');

src/api/worker.ts

@@ -22,6 +22,7 @@ import {
   insertSendingMessage,
   deleteSendingMessage,
   getAllSendingMessages,
+  getLatestActiveMessage,
 
   // conversation
   getAllConversationList,
@@ -284,6 +285,7 @@ rpc.registerMethod(
 rpc.registerMethod('insertSendingMessage', insertSendingMessage);
 rpc.registerMethod('deleteSendingMessage', deleteSendingMessage);
 rpc.registerMethod('getAllSendingMessages', getAllSendingMessages);
+rpc.registerMethod('getLatestActiveMessage', getLatestActiveMessage);
 
 // conversation
 rpc.registerMethod('getAllConversationList', getAllConversationList);

src/sqls/localChatLogsConversationID.ts

@@ -572,3 +572,17 @@ export function searchAllMessageByContentType(
       `
   );
 }
+
+export function getLatestActiveMessage(
+  db: Database,
+  conversationID: string,
+  isReverse: boolean
+): QueryExecResult[] {
+  _initLocalChatLogsTable(db, conversationID);
+  const order = isReverse ? 'ASC' : 'DESC';
+  return db.exec(
+    `
+      SELECT * FROM 'chat_logs_${conversationID}' WHERE status < 4 ORDER BY send_time ${order};
+    `
+  );
+}

src/types/index.d.ts

@@ -73,6 +73,7 @@ declare global {
     insertSendingMessage: DatabaseApi;
     deleteSendingMessage: DatabaseApi;
     getAllSendingMessages: DatabaseApi;
+    getLatestActiveMessage: DatabaseApi;
     // conversation
     getAllConversationListDB: DatabaseApi;
     getAllConversationListToSync: DatabaseApi;