SITES-28550: Polling action: increase test coverage

Author: BaDos

test/aem.test.js

@@ -0,0 +1,108 @@
+/*
+Copyright 2025 Adobe. All rights reserved.
+This file is licensed to you under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License. You may obtain a copy
+of the License at http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software distributed under
+the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR REPRESENTATIONS
+OF ANY KIND, either express or implied. See the License for the specific language
+governing permissions and limitations under the License.
+*/
+
+const { AdminAPI } = require('../actions/check-product-changes/lib/aem');
+const { request } = require('../actions/utils');
+
+jest.mock('../actions/utils', () => ({
+    request: jest.fn(),
+}));
+
+describe('AdminAPI Optimized Tests', () => {
+    let adminAPI;
+    const context = { logger: { info: jest.fn(), error: jest.fn() } };
+
+    beforeEach(() => {
+        adminAPI = new AdminAPI(
+            { org: 'testOrg', site: 'testSite' },
+            context,
+            { requestPerSecond: 5, publishBatchSize: 100, authToken: 'testToken' }
+        );
+        jest.useFakeTimers();
+        jest.spyOn(global, 'setInterval');
+        jest.spyOn(global, 'clearInterval');
+    });
+
+    afterEach(() => {
+        jest.clearAllMocks();
+    });
+
+    test('should initialize with correct parameters', () => {
+        expect(adminAPI.org).toBe('testOrg');
+        expect(adminAPI.site).toBe('testSite');
+        expect(adminAPI.requestPerSecond).toBe(5);
+        expect(adminAPI.publishBatchSize).toBe(100);
+        expect(adminAPI.authToken).toBe('testToken');
+    });
+
+    test('should add record to previewQueue on previewAndPublish', async () => {
+        const record = { path: '/test' };
+        adminAPI.previewAndPublish(record);
+        expect(adminAPI.previewQueue).toHaveLength(1);
+        await Promise.resolve();
+    });
+
+    test('should add record to unpublishQueue on unpublishAndDelete', async () => {
+        const record = { path: '/test' };
+        adminAPI.unpublishAndDelete(record);
+        expect(adminAPI.unpublishQueue).toHaveLength(1);
+        await Promise.resolve();
+    });
+
+    test('should start processing queues', async () => {
+        await adminAPI.startProcessing();
+        expect(global.setInterval).toHaveBeenCalled();
+        jest.runOnlyPendingTimers();
+    });
+
+    test('should stop processing queues', async () => {
+        await adminAPI.startProcessing();
+        jest.runOnlyPendingTimers();
+        const stopPromise = adminAPI.stopProcessing();
+        jest.runOnlyPendingTimers();
+        await stopPromise;
+        expect(global.clearInterval).toHaveBeenCalled();
+    });
+
+    test('should execute admin request', async () => {
+        await adminAPI.execAdminRequest('POST', 'preview', '/test', { data: 'test' });
+        expect(request).toHaveBeenCalledWith('preview', 'https://admin.hlx.page/preview/testOrg/testSite/main/test', {
+            method: 'POST',
+            headers: {
+                'content-type': 'application/json',
+                'x-auth-token': 'testToken',
+            },
+            body: JSON.stringify({ data: 'test' }),
+        });
+    });
+
+    test('should process preview queue', async () => {
+        const record = { path: '/test' };
+        adminAPI.previewQueue.push({ record, resolve: jest.fn() });
+        adminAPI.processQueues();
+        expect(context.logger.info).toHaveBeenCalledWith('Queues: preview=1, publish=0, unpublish=0, inflight=0');
+    });
+
+    test('should process publish queue', async () => {
+        const record = { path: '/test' };
+        adminAPI.publishQueue.push({ record, resolve: jest.fn() });
+        adminAPI.processQueues();
+        expect(context.logger.info).toHaveBeenCalledWith('Queues: preview=0, publish=1, unpublish=0, inflight=0');
+    });
+
+    test('should process unpublish queue', async () => {
+        const record = { path: '/test' };
+        adminAPI.unpublishQueue.push({ record, resolve: jest.fn() });
+        adminAPI.processQueues();
+        expect(context.logger.info).toHaveBeenCalledWith('Queues: preview=0, publish=0, unpublish=1, inflight=0');
+    });
+});

test/check-product-changes.test.js

@@ -1,8 +1,20 @@
+/*
+Copyright 2025 Adobe. All rights reserved.
+This file is licensed to you under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License. You may obtain a copy
+of the License at http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software distributed under
+the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR REPRESENTATIONS
+OF ANY KIND, either express or implied. See the License for the specific language
+governing permissions and limitations under the License.
+*/
+
 const assert = require('node:assert/strict');
 const { loadState, saveState, getFileLocation, poll } = require('../actions/check-product-changes/poller.js');
 const Files = require('./__mocks__/files.js');
 const { AdminAPI } = require('../actions/check-product-changes/lib/aem');
-const { requestSaaS, requestSpreadsheet, isValidUrl, getProductUrl, mapLocale } = require('../actions/utils');
+const { requestSaaS, requestSpreadsheet, isValidUrl} = require('../actions/utils');
 const { GetAllSkusQuery } = require('../actions/queries');
 
 jest.mock('../actions/utils', () => ({