PLAT-11060: Reauthenticate DF loop

lib/DatafeedClient/index.js

@@ -38,6 +38,8 @@ DatafeedClient.getEventsFromDatafeed = datafeedId => {
 
       if (response.statusCode === 200) {
         return { status: 'success', body: JSON.parse(response.body) }
+      } else if (response.statusCode === 401) {
+        return { status: 'reauth' }
       } else if (response.statusCode === 204) {
         return { status: 'timeout' }
       } else {

lib/DatafeedEventsService/index.js

@@ -111,7 +111,19 @@ class DatafeedEventsService extends EventEmitter {
   _read() {
     DatafeedClient.getEventsFromDatafeed(this.id).then(
       response => {
-        if (response.status === 'success') {
+        if (response.status === 'reauth') {
+          if (SymBotAuth.debug) {
+            console.log(
+                '[DEBUG]',
+                'Session expired, trying to reauthenticate')
+          }
+          // session expired, try to reauthenticate to keep the DF loop running
+          SymBotAuth.authenticate(SymBotAuth.symConfig)
+              .then(() => {
+                this.continueReading();
+              })
+
+        } else if (response.status === 'success') {
           const eventsByType = response.body.reduce((acc, event) => {
             const type = event.type.toLowerCase()
             if (!acc[type]) {
@@ -134,24 +146,32 @@ class DatafeedEventsService extends EventEmitter {
               this.emit(type, events)
             }
           })
-        }
-
-        if (this.liveStatus) {
-          // continue reading from datafeed
-          this._read()
+          this.continueReading()
         } else {
-          this.emit('stopped')
-          this.unregisterShutdownHooks()
+          // empty content, just keep reading DF
+          this.continueReading()
         }
 
-        this.retries = 0
+
       },
       err => {
         this._retryConnection(err)
       }
     )
   }
 
+  continueReading() {
+    if (this.liveStatus) {
+      // continue reading from datafeed
+      this._read()
+    } else {
+      this.emit('stopped')
+      this.unregisterShutdownHooks()
+    }
+
+    this.retries = 0
+  }
+
   stop(onStopped) {
     console.log(`The BOT ${SymBotAuth.botUser.displayName} is shutting down`)
     this.liveStatus = false

lib/SymBotAuth/index.js

@@ -14,7 +14,6 @@ SymBotAuth.sessionAuthenticate = (symConfig) => {
 
   if (symConfig.authType === 'rsa') {
     body = { 'token': SymBotAuth.getJwtToken(symConfig) }
-    body = { 'token': SymBotAuth.getJwtToken(symConfig) }
 
     options = {
       'hostname': symConfig.podHost,