From 8d525d6ee2c058994b217c588ad2ddf288f0b579 Mon Sep 17 00:00:00 2001
From: Nicolas Chaulet <nicolas.chaulet@elastic.co>
Date: Mon, 14 Sep 2020 09:01:18 -0400
Subject: [PATCH] [Ingest Manager] Fix polling for new agent action

---
 .../server/services/agents/checkin/state_new_actions.ts   | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/x-pack/plugins/ingest_manager/server/services/agents/checkin/state_new_actions.ts b/x-pack/plugins/ingest_manager/server/services/agents/checkin/state_new_actions.ts
index 8f586420c3ecb7..4122677a615ca8 100644
--- a/x-pack/plugins/ingest_manager/server/services/agents/checkin/state_new_actions.ts
+++ b/x-pack/plugins/ingest_manager/server/services/agents/checkin/state_new_actions.ts
@@ -53,11 +53,15 @@ function getInternalUserSOClient() {
 }
 
 function createNewActionsSharedObservable(): Observable<AgentAction[]> {
-  const internalSOClient = getInternalUserSOClient();
+  let lastTimestamp = new Date().toISOString();
 
   return timer(0, AGENT_UPDATE_ACTIONS_INTERVAL_MS).pipe(
     switchMap(() => {
-      return from(getNewActionsSince(internalSOClient, new Date().toISOString()));
+      const internalSOClient = getInternalUserSOClient();
+
+      const timestamp = lastTimestamp;
+      lastTimestamp = new Date().toISOString();
+      return from(getNewActionsSince(internalSOClient, timestamp));
     }),
     shareReplay({ refCount: true, bufferSize: 1 })
   );