chore: add methods to check session connection status for standard and managed channels

Author: ionutmanolache-okta

lib/client.js

@@ -161,6 +161,32 @@ module.exports = function (dependencies) {
     return isStatusCodeRetryable || isProviderTokenExpired || isTransientWriteFailure;
   };
 
+  /**
+   * returns true if the standard session is connected and ready for use, false otherwise
+   * Note that even if this returns true, a request can still fail due to transient network issues, in which case the request will be retried according to the retry logic in the write method.
+   * @returns {boolean}
+   */
+  Client.prototype.isStandardSessionConnected = function isStandardSessionConnected() {
+    return (
+      this.session && !this.isSessionClosing && !this.session.closed && !this.session.destroyed
+    );
+  };
+
+  /**
+   * returns true if the manageChannels session is connected and ready for use, false otherwise
+   * Note that even if this returns true, a request can still fail due to transient network issues, in which case the request will be retried according to the retry logic in the write method.
+   * @returns {boolean}
+   */
+  Client.prototype.isManagedChannelsSessionConnected =
+    function isManagedChannelsSessionConnected() {
+      return (
+        this.manageChannelsSession &&
+        !this.isSessionClosing &&
+        !this.manageChannelsSession.closed &&
+        !this.manageChannelsSession.destroyed
+      );
+    };
+
   Client.prototype.write = async function write(notification, subDirectory, type, method, count) {
     const retryCount = count || 0;
     const subDirectoryLabel = this.subDirectoryLabel(type) ?? type;
@@ -193,12 +219,7 @@ module.exports = function (dependencies) {
 
     if (path.includes('/1/apps/')) {
       // Connect manageChannelsSession.
-      if (
-        !this.manageChannelsSession ||
-        this.isSessionClosing ||
-        this.manageChannelsSession.closed ||
-        this.manageChannelsSession.destroyed
-      ) {
+      if (!this.isManagedChannelsSessionConnected()) {
         try {
           await this.manageChannelsConnect();
         } catch (error) {
@@ -247,7 +268,7 @@ module.exports = function (dependencies) {
       }
     } else {
       // Connect to standard session.
-      if (!this.session || this.isSessionClosing ||  this.session.closed || this.session.destroyed) {
+      if (!this.isStandardSessionConnected()) {
         try {
           await this.connect();
         } catch (error) {