Merge pull request #91 from bhikadiyajatin/master

Adding fix to reduce intermittent "Initialization failed" and "Missed call" issues
amazon-connect · Jan 9, 2019 · afc3a10 · afc3a10
2 parents 158e11d + f3a5c89
commit afc3a10
Showing 1 changed file with 14 additions and 9 deletions.
diff --git a/src/worker.js b/src/worker.js
@@ -191,7 +191,7 @@
          self.portConduitMap[stream.getId()] = portConduit;
 
          if (self.agent !== null) {
-            portConduit.sendDownstream(connect.AgentEvents.UPDATE, self.agent);
+            self.updateAgent();
          }
 
          portConduit.onDownstream(connect.EventType.API_REQUEST,
@@ -218,14 +218,19 @@
          timeout:       GET_AGENT_TIMEOUT_MS
       }, {
          success: function(data) {
-            self.agent = self.agent || {};
-            self.agent.snapshot = data.snapshot;
-            self.agent.snapshot.localTimestamp = connect.now();
-            self.agent.snapshot.skew = self.agent.snapshot.snapshotTimestamp - self.agent.snapshot.localTimestamp;
-            self.nextToken = data.nextToken;
-            connect.getLog().trace("GET_AGENT_SNAPSHOT succeeded.").withObject(data);
-            self.updateAgent();
-            global.setTimeout(connect.hitch(self, self.pollForAgent), GET_AGENT_SUCCESS_TIMEOUT_MS);
+             try {
+                 self.agent = self.agent || {};
+                 self.agent.snapshot = data.snapshot;
+                 self.agent.snapshot.localTimestamp = connect.now();
+                 self.agent.snapshot.skew = self.agent.snapshot.snapshotTimestamp - self.agent.snapshot.localTimestamp;
+                 self.nextToken = data.nextToken;
+                 connect.getLog().trace("GET_AGENT_SNAPSHOT succeeded.").withObject(data);
+                 self.updateAgent();
+             } catch(e) {
+                 connect.getLog().error("Long poll failed to update agent.").withObject(data).withException(e);
+             } finally {
+                 global.setTimeout(connect.hitch(self, self.pollForAgent), GET_AGENT_SUCCESS_TIMEOUT_MS);
+             }
          },
          failure: function(err, data) {
             try {