Merge pull request #756 from amqp-node/connection-update-secret

Add connection-update-secret

Makefile

@@ -1,7 +1,6 @@
-RABBITMQ_SRC_VERSION=rabbitmq_v3_2_1
+RABBITMQ_SRC_VERSION=v3.12.13
 JSON=amqp-rabbitmq-0.9.1.json
-RABBITMQ_CODEGEN=https://raw.githubusercontent.com/rabbitmq/rabbitmq-codegen
-AMQP_JSON=$(RABBITMQ_CODEGEN)/$(RABBITMQ_SRC_VERSION)/$(JSON)
+AMQP_JSON=https://raw.githubusercontent.com/rabbitmq/rabbitmq-server/$(RABBITMQ_SRC_VERSION)/deps/rabbitmq_codegen/$(JSON)
 
 NODEJS_VERSIONS='10.21' '11.15' '12.18' '13.14' '14.5' '15.8' '16.3.0' '18.1.0' '20.10.0'
 

lib/callback_model.js

@@ -24,6 +24,10 @@ class CallbackModel extends EventEmitter {
     this.connection.close(cb);
   }
 
+  updateSecret(newSecret, reason, cb) {
+    this.connection._updateSecret(newSecret, reason, cb);
+  }
+
   createChannel (cb) {
     var ch = new Channel(this.connection);
     ch.open(function (err, ok) {

lib/channel_model.js

@@ -26,6 +26,10 @@ class ChannelModel extends EventEmitter {
     return promisify(this.connection.close.bind(this.connection))();
   }
 
+  updateSecret(newSecret, reason) {
+    return promisify(this.connection._updateSecret.bind(this.connection))(newSecret, reason);
+  }
+
   async createChannel() {
     const channel = new Channel(this.connection);
     await channel.open();

lib/connection.js

@@ -361,6 +361,14 @@ class Connection extends EventEmitter {
     this.emit('close', maybeErr);
   }
 
+  _updateSecret(newSecret, reason, cb) {
+    this.sendMethod(0, defs.ConnectionUpdateSecret, {
+      newSecret,
+      reason
+    });
+    this.once('update-secret-ok', cb);
+  }
+
   // ===
   startHeartbeater () {
     if (this.heartbeat === 0)
@@ -611,6 +619,9 @@ function channel0(connection) {
     else if (f.id === defs.ConnectionUnblocked) {
       connection.emit('unblocked');
     }
+    else if (f.id === defs.ConnectionUpdateSecretOk) {
+      connection.emit('update-secret-ok');
+    }
     else {
       connection.closeWithError(
         fmt("Unexpected frame on channel 0"),