BB-727: Log zookeeper details

Author: BourgoisMickael

lib/clients/ZookeeperManager.js

@@ -21,6 +21,20 @@ class ZookeeperManager extends EventEmitter {
         this._connect();
     }
 
+    zkDetails(client) {
+        const localAddress = client.connectionManager.socket.address();
+        return {
+            sessionId: `0x${ client.getSessionId().toString('hex')}`,
+            socket: `${localAddress.address}:${localAddress.port}`,
+            stateConn: client.connectionManager.state,
+            state: client.getState(),
+            xid: client.connectionManager.xid,
+            zxid: client.connectionManager.zxid.toString('hex'),
+            nextServerIndex: client.connectionManager.nextServerIndex,
+            serverAttempts: client.connectionManager.serverAttempts,
+        };
+    }
+
     /**
      * Establishes a connection to the ZooKeeper server.
      *
@@ -51,6 +65,10 @@ class ZookeeperManager extends EventEmitter {
         async.series([
             // Check zookeeper client is connected
             next => this.client.once('connected', next),
+            next => {
+                this.log.info('connected to zookeeper', { zk: this.zkDetails(this.client) });
+                next();
+            },
             // Create namespace if it exists and options.autoCreateNamespace is true
             next => {
                 // TODO: ARTESCA-10337 The 'autoCreateNamespace' functionality is currently specific to
@@ -82,7 +100,12 @@ class ZookeeperManager extends EventEmitter {
                 const hostPort = this.connectionString.slice(0, nsIndex);
                 rootZkClient = zookeeper.createClient(hostPort, this.options);
                 rootZkClient.connect();
-                rootZkClient.once('connected', () => next());
+                rootZkClient.once('connected', () => {
+                    this.log.info('connected to root zookeeper', {
+                        zk: this.zkDetails(rootZkClient),
+                    });
+                    next();
+                });
             },
             // Once connected, use the root zookeeper client to create the namespace
             next => rootZkClient.mkdirp(namespace, err => {
@@ -93,30 +116,35 @@ class ZookeeperManager extends EventEmitter {
                 return next({ event: 'ready' });
             }),
         ], ({ event, err }) => {
+            this.log.info('zookeeper client event', { event, err, zk: this.zkDetails(this.client) });
             this.emit(event, err);
         });
 
         this.client.once('expired', () => {
             this.log.info('zookeeper client expired', {
                 method: 'ZookeeperManager.once.expired',
+                zk: this.zkDetails(this.client),
             });
             // establish a new session with the ZooKeeper.
             this._connect();
         });
 
         this.client.on('state', state => {
-            this.log.debug('zookeeper new state', {
+            this.log.info('zookeeper new state', {
                 state,
                 method: 'ZookeeperManager.on.state',
+                zk: this.zkDetails(this.client),
             });
         });
 
         // Forward ZooKeeper events
         this.client.on('connected', () => {
+            this.log.info('zookeeper client connected', { zk: this.zkDetails(this.client) });
             this.emit('connected');
         });
 
         this.client.on('disconnected', () => {
+            this.log.info('zookeeper client disconnected', { zk: this.zkDetails(this.client) });
             this.emit('disconnected');
         });
 
@@ -131,6 +159,7 @@ class ZookeeperManager extends EventEmitter {
      * @return {undefined}
      */
     close() {
+        this.log.info('closing existing zookeeper client', { zk: this.zkDetails(this.client) });
         this.client.close();
         return;
     }