chore: bump version 9.16.3

Signed-off-by: Dylan <[email protected]>

Author: nmgwddj

.prettierrc

@@ -1,6 +1,6 @@
 {
     "printWidth": 160,
-    "tabWidth": 4,
+    "tabWidth": 2,
     "singleQuote": true,
     "semi": false,
     "bracketSpacing": true,

package.json

@@ -1,6 +1,6 @@
 {
     "name": "node-nim",
-    "version": "9.16.2",
+    "version": "9.16.3",
     "description": "NetEase IM nodejs wrapper based on NetEase IM C++ SDK",
     "main": "dist/node-nim.js",
     "bin": {

src/nim/msglog/nim_node_msglog.cpp

@@ -40,7 +40,10 @@ Napi::Object NIMMsgLog::Init(Napi::Env env, Napi::Object exports) {
             RegApi("QueryMessageIsThreadRoot", &MsgLog::QueryMessageIsThreadRoot), RegApi("QueryMessageOnline", &MsgLog::QueryMessageOnline),
             RegApi("QueryThreadHistoryMsg", &MsgLog::QueryThreadHistoryMsg),
             RegApi("QueryLocalThreadHistoryMsg", &MsgLog::QueryLocalThreadHistoryMsg),
-            RegApi("FullTextSearchOnlineAsync", &MsgLog::FullTextSearchOnlineAsync)});
+            RegApi("FullTextSearchOnlineAsync", &MsgLog::FullTextSearchOnlineAsync),
+            RegApi("QueryMessagesByKeywordAsync", &MsgLog::QueryMessagesByKeywordAsync),
+            RegApi("IsMessageIndexEstablished", &MsgLog::IsMessageIndexEstablished), RegApi("BuildMsglogIndexes", &MsgLog::BuildMsglogIndexes),
+            RegApi("CancelMsglogIndexesBuilding", &MsgLog::CancelMsglogIndexesBuilding)});
 }
 
 void NIMMsgLog::InitEventHandlers() {

src/reflection/nim_msglog_reflection.h

@@ -126,6 +126,17 @@ ReflectionDefinition_O(MsgLog::QueryMsgByOptionsAsyncParam,
     msg_type_,
     msg_sub_type_,
     search_content_);
+ReflectionDefinition_O(MsgLog::QueryMsgByKeywordParam,
+    keyword_,
+    account_id_,
+    to_type_,
+    type_,
+    limit_count_,
+    from_time_,
+    end_time_,
+    direction_,
+    segment_engine_,
+    enable_pinyin_);
 
 // Callback
 CallbackSpecialization(MsgLog::QueryMsgCallback);
@@ -140,6 +151,9 @@ CallbackSpecialization(MsgLog::DeleteHistoryOnLineNotifyCallback);
 CallbackSpecialization(MsgLog::QueryMessageIsThreadRootAsyncCallback);
 CallbackSpecialization(MsgLog::QueryThreadHistoryMsgCallback);
 CallbackSpecialization(MsgLog::FullTextSearchOnlineAsyncCallback);
+CallbackSpecialization(MsgLog::IsMessageIndexEstablishedCallback);
+CallbackSpecialization(MsgLog::BuildMsglogIndexesProgress);
+CallbackSpecialization(MsgLog::BuildMsglogIndexesComplete);
 
 // xpack specialization
 namespace xpack {

test/test_msglog.js

@@ -1,7 +1,8 @@
-const NIM = require('../../dist/node-nim')
+const NIM = require('../dist/node-nim')
 const assert = require('assert')
 
 const msglog = new NIM.NIMMsgLog()
+const talk = new NIM.NIMTalk()
 
 describe('********************Msglog********************', function () {
   let signalMsgId = ''
@@ -491,4 +492,69 @@ describe('******************** Msglog thread ********************', function ()
       assert.ok(replyCount > 0)
     })
   })
+  describe('#queryMessagesByKeywordAsync', () => {
+  it('Query messages by keyword should return with query keyword', async () => {
+      const result = await NIM.nim.msgLog.queryMessagesByKeywordAsync({
+          keyword_: '测试',
+          type_: [0],
+          limit_count_: 1000,
+      })
+      assert.strictEqual(result[3].msglogs_.length, 1000)
+  })
+  it('Query messages by option with content should return with query keyword', async () => {
+    const result = await NIM.nim.msgLog.queryMsgByOptionsAsync({
+      query_range_: 100,
+      ids: [],
+      from_time_: 0,
+      end_time_: 0,
+      limit_count_: 1000,
+      msg_sub_type_: 0,
+      msg_type_: 0,
+      reverse_: true,
+      search_content_: '测试',
+    })
+    assert.strictEqual(result[3].msglogs_.length, 1000)
+  })
+  });
+  describe('#queryMessagesByKeywordAsync', () => {
+    before(async function () {
+      for (let i = 0; i < 10; i++) {
+        let obj = {
+          session_type_: 0, // p2p
+          receiver_accid_: 'jiajia02',
+          timetag_: new Date().getTime(),
+          type_: 0, // text message
+          content_: `Test message sent by node-nim, message index ${i}`,
+          client_msg_id_: new Date().getTime().toString() // use an uuid
+        }
+        await talk.sendMsg(obj, '')
+      }
+    })
+    it('Query messages by keyword result should return with Test message', async function () {
+      const result = await NIM.nim.msgLog.queryMessagesByKeywordAsync({
+        keyword_: 'Test message',
+        type_: [0],
+        limit_count_: 10
+      })
+      assert.strictEqual(result[3].msglogs_.length, 10)
+      result[3].msglogs_.map((message) => {
+        assert.strictEqual(message.content_.includes('Test message'), true)
+      })
+    })
+  });
+  describe('#buildMsglogIndexes', () => {
+    it('buildMsglogIndexes should return with complete', async function () {
+      const [reason, message] = await NIM.nim.msgLog.buildMsglogIndexes(5000, (total, built) => {
+          console.log(`Total: ${total}, Built: ${built}`)
+      })
+      console.log('reason', reason, message)
+      assert.strictEqual(reason, 0)
+    })
+  })
+  describe('#isMsglogIndexesEstablished', () => {
+    it('isMsglogIndexesEstablished should return with true', async function () {
+      const established = await NIM.nim.msgLog.isMessageIndexEstablished()
+      assert.strictEqual(established, true)
+    })
+  })
 })