test(bundles): e2e tests for skipping fully indexed bundles

ar-io · Jan 29, 2025 · 45e793e · 45e793e
1 parent 351b0f2
commit 45e793e
Showing 1 changed file with 39 additions and 1 deletion.
diff --git a/test/end-to-end/indexing.test.ts b/test/end-to-end/indexing.test.ts
@@ -647,6 +647,7 @@ describe('Indexing', function () {
   describe('Queue bundle', function () {
     let bundlesDb: Database;
     let compose: StartedDockerComposeEnvironment;
+    const bundleId = 'FcWiW5v28eBf5s9XAKTRiqD7dq9xX_lS5N6Xb2Y89NY';
 
     const waitForIndexing = async () => {
       const getAll = () =>
@@ -679,7 +680,7 @@ describe('Indexing', function () {
           'Content-Type': 'application/json',
         },
         data: {
-          id: 'FcWiW5v28eBf5s9XAKTRiqD7dq9xX_lS5N6Xb2Y89NY',
+          id: bundleId,
         },
       });
 
@@ -833,6 +834,43 @@ describe('Indexing', function () {
 
       assert.equal(dataItems.length, 0);
     });
+
+    it('Verifying if unbundling is skipped when trying to unbundle the same bundle twice using the same filters', async function () {
+      const response = await axios({
+        method: 'post',
+        url: 'http://localhost:4000/ar-io/admin/queue-bundle',
+        headers: {
+          Authorization: 'Bearer secret',
+          'Content-Type': 'application/json',
+        },
+        data: {
+          id: bundleId,
+        },
+      });
+
+      assert.equal(response.data.message, 'Bundle skipped');
+    });
+
+    it('Verifying if unbundling when trying to unbundle the same bundle using different filters', async function () {
+      await compose.down();
+      compose = await composeUp({
+        ANS104_UNBUNDLE_FILTER:
+          '{ "attributes": { "owner": "8jNb-iG3a3XByFuZnZ_MWMQSZE0zvxPMaMMBNMYegY4" } }',
+      });
+      const response = await axios({
+        method: 'post',
+        url: 'http://localhost:4000/ar-io/admin/queue-bundle',
+        headers: {
+          Authorization: 'Bearer secret',
+          'Content-Type': 'application/json',
+        },
+        data: {
+          id: bundleId,
+        },
+      });
+
+      assert.equal(response.data.message, 'Bundle queued');
+    });
   });
 
   describe('Queue data item', function () {