chore: release v3.8.2-2 (#143)

* feat: add new input state api (#137)

* fix: update friends params type & add deprecated description

* fix: add db method & app sdk version  add field

* chore: core update v3.8.2

* chore: release 3.8.2-2

Author: Bloomingg

assets/openIM.wasm

@@ -0,0 +1 @@
+v3.8.2

assets/version

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

package.json

@@ -3,6 +3,7 @@ import { Database } from '@jlongster/sql.js';
 export function alterTable(db: Database) {
   alter351(db);
   alter380(db);
+  alter381(db);
 }
 
 function alter351(db: Database) {
@@ -28,3 +29,15 @@ function alter380(db: Database) {
     // alter table error
   }
 }
+
+function alter381(db: Database) {
+  try {
+    db.exec(
+      `
+        ALTER TABLE local_app_sdk_version ADD COLUMN installed numeric;
+        `
+    );
+  } catch (error) {
+    // alter table error
+  }
+}

src/api/database/alter.ts

@@ -8,6 +8,7 @@ import {
   getConversation as databaseGetConversation,
   getHiddenConversationList as databaseGetHiddenConversationList,
   getAllSingleConversationIDList as databaseGetAllSingleConversationIDList,
+  findAllUnreadConversationConversationID as databaseFindAllUnreadConversationConversationID,
   getAllConversationIDList as databaseGetAllConversationIDList,
   updateColumnsConversation as databaseUpdateColumnsConversation,
   getTotalUnreadMsgCount as databaseGetTotalUnreadMsgCount,
@@ -87,6 +88,28 @@ export async function getAllConversationListToSync(): Promise<string> {
   }
 }
 
+export async function findAllUnreadConversationConversationID(): Promise<string> {
+  try {
+    const db = await getInstance();
+
+    const execResult = databaseFindAllUnreadConversationConversationID(db);
+
+    return formatResponse(
+      converSqlExecResult(execResult[0], 'CamelCase').map(
+        item => item.conversationID
+      )
+    );
+  } catch (e) {
+    console.error(e);
+
+    return formatResponse(
+      undefined,
+      DatabaseErrorCode.ErrorInit,
+      JSON.stringify(e)
+    );
+  }
+}
+
 export async function getAllSingleConversationIDList(): Promise<string> {
   try {
     const db = await getInstance();

src/api/database/conversation.ts

@@ -28,7 +28,7 @@ export async function getAppSDKVersion(): Promise<string> {
     }
 
     return formatResponse(
-      converSqlExecResult(execResult[0], 'CamelCase', [])[0]
+      converSqlExecResult(execResult[0], 'CamelCase', ['installed'])[0]
     );
   } catch (e) {
     console.error(e);
@@ -53,7 +53,9 @@ export async function setAppSDKVersion(
 
     const execResult = databaseGetAppSDKVersion(db);
 
-    const result = converSqlExecResult(execResult[0], 'CamelCase', []);
+    const result = converSqlExecResult(execResult[0], 'CamelCase', [
+      'installed',
+    ]);
     if (result[0] && result[0].version) {
       databaseUpdateAppSDKVersion(
         db,

src/api/database/localAppSdkVersion.ts

@@ -113,6 +113,9 @@ export async function getMessageList(
   startTime: number,
   isReverse = false
 ): Promise<string> {
+  if (startTime <= 0) {
+    return getMessageListNoTime(conversationID, count, isReverse);
+  }
   try {
     const db = await getInstance();
 

src/api/database/message.ts

@@ -337,6 +337,9 @@ export function initDatabaseAPI(isLogStandardOutput = true): void {
   window.getAllSingleConversationIDList = registeMethodOnWindow(
     'getAllSingleConversationIDList'
   );
+  window.findAllUnreadConversationConversationID = registeMethodOnWindow(
+    'findAllUnreadConversationConversationID'
+  );
   window.getAllConversationIDList = registeMethodOnWindow(
     'getAllConversationIDList'
   );

src/api/index.ts

@@ -153,6 +153,7 @@ import {
   batchInsertTempCacheMessageList,
   InsertTempCacheMessage,
   getAllSingleConversationIDList,
+  findAllUnreadConversationConversationID,
   getAllConversationIDList,
   getPageFriendList,
   getGroupMemberAllGroupIDs,
@@ -319,6 +320,10 @@ rpc.registerMethod(
   'setMultipleConversationRecvMsgOpt',
   setMultipleConversationRecvMsgOpt
 );
+rpc.registerMethod(
+  'findAllUnreadConversationConversationID',
+  findAllUnreadConversationConversationID
+);
 rpc.registerMethod(
   'getAllSingleConversationIDList',
   getAllSingleConversationIDList

src/api/worker.ts

@@ -16,14 +16,17 @@ export enum CbEvents {
   OnProgress = 'OnProgress',
   OnRecvNewMessage = 'OnRecvNewMessage',
   OnRecvNewMessages = 'OnRecvNewMessages',
+  OnRecvOnlineOnlyMessage = 'OnRecvOnlineOnlyMessage',
   OnRecvOfflineNewMessage = 'onRecvOfflineNewMessage',
+  OnRecvOnlineOnlyMessages = 'OnRecvOnlineOnlyMessages',
   OnRecvOfflineNewMessages = 'onRecvOfflineNewMessages',
   OnRecvMessageRevoked = 'OnRecvMessageRevoked',
   OnNewRecvMessageRevoked = 'OnNewRecvMessageRevoked',
   OnRecvC2CReadReceipt = 'OnRecvC2CReadReceipt',
   OnRecvGroupReadReceipt = 'OnRecvGroupReadReceipt',
   OnConversationChanged = 'OnConversationChanged',
   OnNewConversation = 'OnNewConversation',
+  OnConversationUserInputStatusChanged = 'OnConversationUserInputStatusChanged',
   OnSyncServerFailed = 'OnSyncServerFailed',
   OnSyncServerFinish = 'OnSyncServerFinish',
   OnSyncServerProgress = 'OnSyncServerProgress',