fix(core): update

test/test.nonci.ts

@@ -59,4 +59,19 @@ tap.test('should delete documents not part of the piping session', async () => {
   await testElasticDoc.endPipingSession();
 });
 
+tap.test('should take and store snapshot', async () => {
+  await testElasticDoc.takeSnapshot(async (iterator, prevSnapshot) => {
+    const aggregationData = [];
+    for await (const doc of iterator) {
+      // Sample aggregation: counting documents
+      aggregationData.push(doc);
+    }
+    const snapshot = {
+      date: new Date().toISOString(),
+      aggregationData,
+    };
+    return snapshot;
+  });
+});
+
 tap.start();