Added registration id to the CQN subscription callback function's message object parameter (Issue #1692)

Author: sharadraju

doc/src/release_notes.rst

@@ -42,6 +42,10 @@ Thick Mode changes
 #)  Fixed bug which throws ``ORA-22288`` error in certain scenarios when
     querying ``BFILENAME()`` with outbinds.
 
+#)  Added registration id to the CQN subscription callback function's message
+    object parameter.
+    See `Issue #1692 <https://github.com/oracle/node-oracledb/issues/1692>`__.
+
 node-oracledb `v6.6.0 <https://github.com/oracle/node-oracledb/compare/v6.5.1...v6.6.0>`__ (25 Jul 2024)
 ---------------------------------------------------------------------------------------------------------
 

examples/cqn1.js

@@ -79,6 +79,7 @@ function myCallback(message) {
   }
   console.log("Message database name:", message.dbName);
   console.log("Message transaction id:", message.txId);
+  console.log("Registration id:", Number(message.regId));
   console.log("Message queries:");
   for (let i = 0; i < message.queries.length; i++) {
     const query = message.queries[i];

src/njsSubscription.c

@@ -37,7 +37,7 @@ static NJS_NAPI_FINALIZE(njsSubscription_finalize);
 
 // other methods
 static bool njsSubscription_createMessage(napi_env env,
-        dpiSubscrMessage *message, napi_value *messageObj);
+        njsSubscription *subscr, napi_value *messageObj);
 static bool njsSubscription_createMessageQuery(napi_env env,
         dpiSubscrMessageQuery *query, napi_value *queryObj);
 static bool njsSubscription_createMessageRow(napi_env env,
@@ -58,10 +58,11 @@ static void njsSubscription_waitOnBarrier(njsSubscription *subscr);
 //   Create message that will be passed to the callback.
 //-----------------------------------------------------------------------------
 static bool njsSubscription_createMessage(napi_env env,
-        dpiSubscrMessage *message, napi_value *messageObj)
+        njsSubscription *subscr, napi_value *messageObj)
 {
     napi_value temp, array;
     uint32_t i;
+    dpiSubscrMessage *message = subscr->message;
 
     // create message object
     NJS_CHECK_NAPI(env, napi_create_object(env, messageObj))
@@ -92,6 +93,11 @@ static bool njsSubscription_createMessage(napi_env env,
     NJS_CHECK_NAPI(env, napi_set_named_property(env, *messageObj, "registered",
             temp))
 
+    // set registration id
+    NJS_CHECK_NAPI(env,  napi_create_bigint_uint64(env, subscr->regId, &temp))
+    NJS_CHECK_NAPI(env, napi_set_named_property(env, *messageObj, "regId",
+            temp))
+
     // set queue name
     if (message->queueNameLength > 0) {
         NJS_CHECK_NAPI(env, napi_create_string_utf8(env, message->queueName,
@@ -390,7 +396,7 @@ static bool njsSubscription_processNotificationHelper(napi_env env,
     NJS_CHECK_NAPI(env, napi_get_global(env, &global))
     NJS_CHECK_NAPI(env, napi_get_reference_value(env, subscr->jsCallback,
             &callback))
-    if (!njsSubscription_createMessage(env, subscr->message, &message))
+    if (!njsSubscription_createMessage(env, subscr, &message))
         return false;
 
     // perform callback and clear any exception that occurs