[api/worker] Bump the Python library

OpenCTI-Platform · Apr 7, 2021 · a79a3ba · a79a3ba
1 parent 29e0e5a
commit a79a3ba
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 4 deletions.
diff --git a/opencti-platform/opencti-graphql/src/database/redis.js b/opencti-platform/opencti-graphql/src/database/redis.js
@@ -483,12 +483,17 @@ export const getStreamRange = async (from, limit, callback) => {
   const client = await createRedisClient();
   const size = limit > MAX_RANGE_MESSAGES ? MAX_RANGE_MESSAGES : limit;
   return client.call('XRANGE', OPENCTI_STREAM, from, '+', 'COUNT', size).then(async (results) => {
+    let lastEventId;
     if (results && results.length > 0) {
       await processStreamResult(results, callback);
+      const lastResult = R.last(results);
+      lastEventId = R.head(lastResult);
+    } else {
+      const streamInfo = await fetchStreamInfo();
+      lastEventId = streamInfo.lastEventId;
     }
     await client.disconnect();
-    const lastResult = R.last(results);
-    return { lastEventId: R.head(lastResult) };
+    return { lastEventId };
   });
 };
 // endregion

diff --git a/opencti-platform/opencti-graphql/src/python/requirements.txt b/opencti-platform/opencti-graphql/src/python/requirements.txt
@@ -1,4 +1,4 @@
-pycti==4.3.4
+pycti==4.3.5
 stix2-patterns==1.3.2
 elasticsearch==7.12.0
 plyara==2.1.1

diff --git a/opencti-worker/src/requirements.txt b/opencti-worker/src/requirements.txt
@@ -1,2 +1,2 @@
-pycti==4.3.4
+pycti==4.3.5
 black==20.8b1