diff --git a/src/cmds/migration/run.ts b/src/cmds/migration/run.ts index 11f4cc1..a883ebc 100644 --- a/src/cmds/migration/run.ts +++ b/src/cmds/migration/run.ts @@ -147,7 +147,7 @@ const runMigrationCommand: yargs.CommandModule = { client: apiClient, projectId: projectId, operation: operation, - saveStatusFromPlugin: plugin?.saveStatus ?? null + saveStatusFromPlugin: plugin?.saveStatus ?? null, }; const migrationsStatus = await loadMigrationsExecutionStatus(plugin?.readStatus ?? null); @@ -213,9 +213,9 @@ export const getRange = (range: string): IRange | null => { return from <= to ? { - from, - to, - } + from, + to, + } : null; }; @@ -235,9 +235,9 @@ export const getRangeDate = (range: string): IRange | null => { return from.getTime() <= to.getTime() ? { - from, - to, - } + from, + to, + } : null; }; diff --git a/src/tests/cmds/run/runMigrationWithRollback.test.ts b/src/tests/cmds/run/runMigrationWithRollback.test.ts index 01cfbba..ab67fc2 100644 --- a/src/tests/cmds/run/runMigrationWithRollback.test.ts +++ b/src/tests/cmds/run/runMigrationWithRollback.test.ts @@ -199,5 +199,4 @@ describe('run migration command tests', () => { expect(mockExit).toHaveBeenCalledWith(0); }); - }); diff --git a/src/tests/runMigration.test.ts b/src/tests/runMigration.test.ts index f7ece89..1513ad5 100644 --- a/src/tests/runMigration.test.ts +++ b/src/tests/runMigration.test.ts @@ -3,53 +3,46 @@ import { runMigration } from '../utils/migrationUtils'; import * as statusManager from '../utils/statusManager'; import { createManagementClient } from '@kontent-ai/management-sdk'; -jest.spyOn(statusManager, 'markAsCompleted').mockImplementation(async () => { }); - +jest.spyOn(statusManager, 'markAsCompleted').mockImplementation(async () => {}); describe('statusManager runMigration function', () => { it('runMigration no rollback function specified should throw', async () => { const migration: IMigration = { - name: "test_migration", + name: 'test_migration', module: { order: 1, - run: async () => { } - } + run: async () => {}, + }, }; - const returnCode = await runMigration( - {}, - migration, - { - client: createManagementClient({ apiKey: '' }), - projectId: 'fcb801c6-fe1d-41cf-af91-ec13802a1ed2', - operation: 'rollback', - saveStatusFromPlugin: null - }); + const returnCode = await runMigration({}, migration, { + client: createManagementClient({ apiKey: '' }), + projectId: 'fcb801c6-fe1d-41cf-af91-ec13802a1ed2', + operation: 'rollback', + saveStatusFromPlugin: null, + }); expect(returnCode).toEqual(1); }); it('runMigration rollback function specified should call rollback', async () => { const migration: IMigration = { - name: "test_migration", + name: 'test_migration', module: { order: 1, - run: async () => { }, - rollback: async () => {} - } + run: async () => {}, + rollback: async () => {}, + }, }; const rollback = jest.spyOn(migration.module, 'rollback'); - const returnCode = await runMigration( - {}, - migration, - { - client: createManagementClient({ apiKey: '' }), - projectId: 'fcb801c6-fe1d-41cf-af91-ec13802a1ed2', - operation: 'rollback', - saveStatusFromPlugin: null - }); + const returnCode = await runMigration({}, migration, { + client: createManagementClient({ apiKey: '' }), + projectId: 'fcb801c6-fe1d-41cf-af91-ec13802a1ed2', + operation: 'rollback', + saveStatusFromPlugin: null, + }); expect(rollback).toBeCalledTimes(1); expect(returnCode).toEqual(0); @@ -57,25 +50,22 @@ describe('statusManager runMigration function', () => { it('runMigration should call run', async () => { const migration: IMigration = { - name: "test_migration", + name: 'test_migration', module: { order: 1, - run: async () => { }, - rollback: async () => {} - } + run: async () => {}, + rollback: async () => {}, + }, }; const run = jest.spyOn(migration.module, 'run'); - const returnCode = await runMigration( - {}, - migration, - { - client: createManagementClient({ apiKey: '' }), - projectId: 'fcb801c6-fe1d-41cf-af91-ec13802a1ed2', - operation: 'run', - saveStatusFromPlugin: null - }); + const returnCode = await runMigration({}, migration, { + client: createManagementClient({ apiKey: '' }), + projectId: 'fcb801c6-fe1d-41cf-af91-ec13802a1ed2', + operation: 'run', + saveStatusFromPlugin: null, + }); expect(run).toBeCalledTimes(1); expect(returnCode).toEqual(0); diff --git a/src/utils/migrationUtils.ts b/src/utils/migrationUtils.ts index 3c7b97f..1c793d9 100644 --- a/src/utils/migrationUtils.ts +++ b/src/utils/migrationUtils.ts @@ -57,14 +57,14 @@ interface RunMigrationOptions { } export const runMigration = async (migrationsStatus: IStatus, migration: IMigration, options: RunMigrationOptions): Promise => { - const {client, projectId, operation, saveStatusFromPlugin} = options; + const { client, projectId, operation, saveStatusFromPlugin } = options; console.log(`Running the ${operation === 'rollback' && 'rollback of'} ${migration.name} migration.`); let isSuccess = true; try { - if(operation === 'run') { + if (operation === 'run') { await migration.module.run(client).then(async () => { await markAsCompleted(migrationsStatus, projectId, migration.name, migration.module.order, operation, saveStatusFromPlugin); }); diff --git a/src/utils/statusManager.ts b/src/utils/statusManager.ts index 221e0c8..9736304 100644 --- a/src/utils/statusManager.ts +++ b/src/utils/statusManager.ts @@ -4,7 +4,6 @@ import { fileExists } from './fileUtils'; import * as path from 'path'; import { type StatusPlugin } from './status/statusPlugin'; - const migrationStatusFilename = 'status.json'; const pluginsFilename = 'plugins.js'; // let status: IStatus = {}; @@ -99,7 +98,6 @@ const readFromStatus = (): IStatus => { console.warn(`Status JSON file is invalid because of ${error instanceof Error ? error.message : 'unknown error.'}. Continuing with empty status.`); return {}; } - }; const saveStatusToFile = (data: string): void => {