updating connection options again after connection is established

[l4mby]

Hello, we were trying to use rhea to connect to a rabbitmq server with PLAIN oauth2, i tried following this issue #393
and connetted to the container with these options:

const connection_options = {
   host: "localhost",
   port: 5672,
   username: "guest"
   token: "<token-value>"
}

and it keeps saying that the token is for a wrong user, so next i tried to put password with the token value and it worked just fine. Is this the right way to do it? or am i doing something wrong?

Then of course before the token expires i need to update its value, is there a way i can do that? I thought it was possible with the connection_details
param, so doing something like this:

let details = {
   host: "localhost",
   port: 5672,
   username: "guest"
   token: "<token-value>"
}

container.connect({
  connection_details: function() {
     return details
  }
})

// here i can update details
details.token = "<new-token-value">

But it keeps reconnecting saying the sasl mechanism is not enabled.
Am i doing something wrong, can you help us understand? Thank you in advance!

[grs]

If using SASL's PLAIN mechanism, you should set a password. It is not possible to update the password on an active connection. If the broker disconnects you due to expiration, you will need to reconnect.

[l4mby]

@grs thank you for the response.
So basically if the broker disconnects me due to expiration i can reconnect using rhea built in reconnect mechanism?
For example having reconnect active by default, it's possible to reconnect using connection_details? Or do i have to create a new connection losing all links i had on the previous connection? Thank you, again.

[grs]

Reconnect should work, provided your function returning the connection details returns an object with an updated token.

[l4mby]

@grs i tried to reconnect with an updated token but it fails immediately after the first attempt, saying to me that the token is not valid, even though i set its duration after 400 seconds. I think i don't understand how to use the connection_details correctly, could you please give me an example on how to do this? (when and if you have time, of course)

the script i am using right now is this

function main() {
  return new Promise((res) => {
    const token = generateToken(5);

    // Configure connection options
    let details = {
      port: 5672,
      host: "localhost",
      username: "rabbit",
      password: token,
    };

    var container = rhea.create_container();
    // When the connection is lost
    container.on("disconnected", function (context) {
      if (context.error) {
        console.error("Disconnected due to error: %s", context.error);
      } else {
        console.log("Disconnected");
      }

      if (context.reconnecting) {
        console.log("Attempting to reconnect...");
      } else {
        console.log("Exiting");
      }
    });
    console.log(inspect(container));
    console.log("Connecting to RabbitMQ at %s:%s...", "rabbit", "rabbit");
    // Connect but don't store the returned object since we're not using it directly
    container.connect({
      ...details,
      connection_details: function () {
        console.log(details);
        return {
          host: details.host,
          port: details.port,
          options: details,
        };
      },
    });

    sleep(5500).then(() => {
      console.log("ENTER");
      const newToken = generateToken(400);
      details.password = newToken;

      // When the connection is established
      container.on("connection_open", function (context) {
        console.log("Connected to RabbitMQ");
        let sender;

        // Create a sender for the specified address
        var target = {};
        const address = "rhea-first-queue";
        if (address) {
          // If sending to an exchange, set the address and use 'address' as routing key
          target = {
            address: address,
            capabilities: ["fanout"],
          };
          sender = context.connection.open_sender({
            target: target,
            properties: {
              "routing-key": address,
              subject: address,
            },
          });
          res(true);
        } else {
          // For direct access to the queue
          target = {
            address: address,
          };
          sender = context.connection.open_sender({
            target: target,
          });
          res(true);
        }

        console.log("Created sender to %s (address: %s)", address, address);
      });
    });
  });
}

process.on("uncaughtException", function (err) {
  console.error("Uncaught exception:", err);
});

main().then(() => {
  console.log("Test");
});

thank you in advance.

[grs]

The connection_details function you supply needs to generate or lookup an updated token every time it is invoked, returning that in the option. I.e.

    container.connect({
      ...details,
      connection_details: function () {
        console.log(details);
        return {
          host: details.host,
          port: details.port,
          options: details,
        };
      },
    });

The function you define above needs to ensure that a valid token is returned every time it is invoked.

[l4mby]

ok, so @grs i need to generate an already updated token from the rabbitmq server. I mean, i call the PUT method to /auth/tokens with a token value i want and then the connection_details function needs to return this updated token, am i right?
Also i wanted to ask, if the broker disconnects the connection due to token expired, rhea does not reconnect right?