Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
9 changes: 2 additions & 7 deletions eslint.config.mjs
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
import tsBaseConfig, { namingConventions } from '@map-colonies/eslint-config/ts-base';
import { config } from '@map-colonies/eslint-config/helpers';
import { defineConfig } from '@map-colonies/eslint-config/helpers';
import vitestConfig from '@map-colonies/eslint-config/vitest';

const AllowedSqlOperators = {
Expand All @@ -19,13 +19,8 @@ const customConfig = {
'@typescript-eslint/naming-convention': namingConvention,
'no-console': 'error',
},
languageOptions: {
parserOptions: {
project: './tsconfig.json',
},
},
};

export default config(vitestConfig, tsBaseConfig, customConfig, {
export default defineConfig(vitestConfig, tsBaseConfig, customConfig, {
ignores: ['src/db/prisma/generated', 'src/common/generated', 'vitest.config.mts'],
});
1,271 changes: 524 additions & 747 deletions package-lock.json

Large diffs are not rendered by default.

8 changes: 4 additions & 4 deletions package.json
Original file line number Diff line number Diff line change
Expand Up @@ -51,9 +51,9 @@
"@map-colonies/js-logger": "^4.0.0",
"@map-colonies/openapi-express-viewer": "^5.0.0",
"@map-colonies/openapi-helpers": "^5.1.0",
"@map-colonies/prometheus": "^1.0.0",
"@map-colonies/read-pkg": "^2.0.0",
"@map-colonies/schemas": "^1.14.0",
"@map-colonies/prometheus": "^1.0.0",
"@map-colonies/semantic-conventions": "^1.0.0",
"@map-colonies/tracing": "^1.0.0",
"@map-colonies/tracing-utils": "^1.0.0",
Expand All @@ -78,8 +78,7 @@
"@commitlint/cli": "^20.2.0",
"@faker-js/faker": "^9.9.0",
"@map-colonies/commitlint-config": "^2.0.0",
"@map-colonies/eslint-config": "^8.0.0",
"@vitest/eslint-plugin": "^1.6.9",
"@map-colonies/eslint-config": "file:../infra-packages/packages/eslint-config/map-colonies-eslint-config-8.1.0.tgz",
"@map-colonies/infra-copilot-instructions": "^1.2.0",
"@map-colonies/prettier-config": "^1.0.0",
"@map-colonies/tsconfig": "^2.0.0",
Expand All @@ -96,11 +95,12 @@
"@types/supertest": "^6.0.2",
"@types/swagger-ui-express": "^4.1.8",
"@vitest/coverage-v8": "^4.0.16",
"@vitest/eslint-plugin": "^1.6.9",
"@vitest/ui": "^4.0.16",
"copyfiles": "^2.4.1",
"cross-env": "^10.1.0",
"docker-compose": "^1.3.0",
"eslint": "^9.39.1",
"eslint": "^10.0.0",
"get-port-please": "^3.2.0",
"husky": "^9.1.7",
"is-ci": "^4.1.0",
Expand Down
6 changes: 4 additions & 2 deletions src/db/createConnection.ts
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,9 @@ export const createConnectionOptions = (dbConfig: DbConfig): PoolConfig => {
ca: readFileSync(ssl.ca),
};
} catch (error) {
throw new Error(`Failed to load SSL certificates. Ensure the files exist and are accessible. Details: ${(error as Error).message}`);
throw new Error(`Failed to load SSL certificates. Ensure the files exist and are accessible. Details: ${(error as Error).message}`, {
cause: error,
});
}
}
return poolConfig;
Expand Down Expand Up @@ -75,6 +77,6 @@ export async function verifyDbSetup(prisma: PrismaClient, schema: string): Promi
await prisma.stage.count(); // validate migration deployed stage table
await prisma.task.count(); // validate migration deployed task table
} catch (error) {
throw new Error(`Error on db connection: ${(error as Error).message}`);
throw new Error(`Error on db connection: ${(error as Error).message}`, { cause: error });
}
}
2 changes: 1 addition & 1 deletion src/stages/models/manager.ts
Original file line number Diff line number Diff line change
Expand Up @@ -388,7 +388,7 @@ export class StageManager {
},
});

if (nextStage && nextStage.status === StageOperationStatus.CREATED) {
if (nextStage?.status === StageOperationStatus.CREATED) {
await this.executeUpdateStatus(nextStage.id, StageOperationStatus.PENDING, tx);
trace.getActiveSpan()?.addEvent('Next stage set to PENDING', { nextStageId: nextStage.id });
}
Expand Down
21 changes: 11 additions & 10 deletions tests/integration/jobs/jobs.spec.ts
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,12 @@ import { jsLogger } from '@map-colonies/js-logger';
import { InMemorySpanExporter, NodeTracerProvider, SimpleSpanProcessor } from '@opentelemetry/sdk-trace-node';
import { trace } from '@opentelemetry/api';
import { StatusCodes } from 'http-status-codes';
import { createRequestSender, type RequestSender } from '@map-colonies/openapi-helpers/requestSender';
import {
createRequestSender,
expectResponseStatusFactory,
type ExpectResponseStatus,
type RequestSender,
} from '@map-colonies/openapi-helpers/requestSender';
import type { paths, operations } from '@openapi';
import { JobOperationStatus, Priority, StageOperationStatus, type PrismaClient } from '@prismaClient';
import type { PrismaTransaction } from '@src/db/types';
Expand All @@ -26,6 +31,8 @@ const spanProcessor = new SimpleSpanProcessor(memoryExporter);
const provider = new NodeTracerProvider({ spanProcessors: [spanProcessor] });
provider.register();

const expectResponseStatus: ExpectResponseStatus = expectResponseStatusFactory(expect);

describe('job', function () {
let requestSender: RequestSender<paths, operations>;
let prisma: PrismaClient;
Expand Down Expand Up @@ -69,9 +76,7 @@ describe('job', function () {

const response = await requestSender.findJobsV1({ queryParams: { should_return_stages: true } });

if (response.status !== StatusCodes.OK) {
throw new Error();
}
expectResponseStatus(response, 200);

expect(response).toSatisfyApiSpec();
expect(response.body).toBeArray();
Expand All @@ -88,9 +93,7 @@ describe('job', function () {

const response = await requestSender.findJobsV1({ queryParams: { should_return_stages: false } });

if (response.status !== StatusCodes.OK) {
throw new Error();
}
expectResponseStatus(response, 200);

expect(response).toSatisfyApiSpec();
expect(response.body[0]).toMatchObject(jobRequestBody);
Expand All @@ -105,9 +108,7 @@ describe('job', function () {
});

const response = await requestSender.findJobsV1({ queryParams: {} });
if (response.status !== StatusCodes.OK) {
throw new Error();
}
expectResponseStatus(response, 200);

expect(response).toSatisfyApiSpec();
expect(response.body[0]).toMatchObject(jobRequestBody);
Expand Down
25 changes: 12 additions & 13 deletions tests/integration/stages/stages.spec.ts
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,12 @@ import { jsLogger } from '@map-colonies/js-logger';
import { trace } from '@opentelemetry/api';
import { StatusCodes } from 'http-status-codes';
import { InMemorySpanExporter, NodeTracerProvider, SimpleSpanProcessor } from '@opentelemetry/sdk-trace-node';
import { createRequestSender, type RequestSender } from '@map-colonies/openapi-helpers/requestSender';
import {
createRequestSender,
expectResponseStatusFactory,
type ExpectResponseStatus,
type RequestSender,
} from '@map-colonies/openapi-helpers/requestSender';
import { faker } from '@faker-js/faker';
import type { paths, operations } from '@openapi';
import { JobOperationStatus, StageOperationStatus, TaskOperationStatus, type PrismaClient } from '@prismaClient';
Expand All @@ -30,6 +35,8 @@ import { createProxyMock } from '@tests/configurations/mockPrisma';
import { createJobRecord, createJobRequestBody, testJobId, testStageId } from '../jobs/helpers';
import { createJobnikTree, createMockPrismaError, createMockUnknownDbError } from '../common/utils';

const expectResponseStatus: ExpectResponseStatus = expectResponseStatusFactory(expect);

describe('stage', function () {
let requestSender: RequestSender<paths, operations>;
let prisma: PrismaClient;
Expand Down Expand Up @@ -150,9 +157,7 @@ describe('stage', function () {

const response = await requestSender.getStagesV1({ queryParams: { job_id: job.id, should_return_tasks: false } });

if (response.status !== StatusCodes.OK) {
throw new Error();
}
expectResponseStatus(response, 200);

expect(response).toSatisfyApiSpec();
expect(response).toMatchObject({
Expand Down Expand Up @@ -328,9 +333,7 @@ describe('stage', function () {

const getStageResponse = await requestSender.getStagesByJobIdV1({ pathParams: { jobId: job.id } });

if (getStageResponse.status !== StatusCodes.OK) {
throw new Error();
}
expectResponseStatus(getStageResponse, 200);

expect(getStageResponse).toSatisfyApiSpec();
expect(getStageResponse).toMatchObject({ status: StatusCodes.OK, body: [{ status: StageOperationStatus.CREATED, id: stage.id }] });
Expand All @@ -347,9 +350,7 @@ describe('stage', function () {
queryParams: { should_return_tasks: true },
});

if (getStageResponse.status !== StatusCodes.OK) {
throw new Error();
}
expectResponseStatus(getStageResponse, 200);

expect(getStageResponse).toSatisfyApiSpec();
expect(getStageResponse).toMatchObject({ status: StatusCodes.OK, body: [{ status: StageOperationStatus.CREATED, id: stage.id }] });
Expand All @@ -367,9 +368,7 @@ describe('stage', function () {
queryParams: { should_return_tasks: false },
});

if (getStageResponse.status !== StatusCodes.OK) {
throw new Error();
}
expectResponseStatus(getStageResponse, 200);

expect(getStageResponse).toSatisfyApiSpec();
expect(getStageResponse).toMatchObject({ status: StatusCodes.OK, body: [{ status: StageOperationStatus.CREATED, id: stage.id }] });
Expand Down
17 changes: 10 additions & 7 deletions tests/integration/tasks/tasks.spec.ts
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,12 @@ import { jsLogger } from '@map-colonies/js-logger';
import { trace } from '@opentelemetry/api';
import { StatusCodes } from 'http-status-codes';
import { InMemorySpanExporter, NodeTracerProvider, SimpleSpanProcessor } from '@opentelemetry/sdk-trace-node';
import { createRequestSender, type RequestSender } from '@map-colonies/openapi-helpers/requestSender';
import {
createRequestSender,
expectResponseStatusFactory,
type ExpectResponseStatus,
type RequestSender,
} from '@map-colonies/openapi-helpers/requestSender';
import { faker } from '@faker-js/faker';
import type { paths, operations } from '@openapi';
import { JobOperationStatus, Priority, Prisma, StageOperationStatus, TaskOperationStatus, type PrismaClient } from '@prismaClient';
Expand All @@ -31,6 +36,8 @@ import { addJobRecord, addStageRecord, createStageBody } from '../stages/helpers
import { createJobnikTree, createMockPrismaError, createMockUnknownDbError } from '../common/utils';
import { createTaskBody, createTaskRecords } from './helpers';

const expectResponseStatus: ExpectResponseStatus = expectResponseStatusFactory(expect);

describe('task', function () {
let requestSender: RequestSender<paths, operations>;
let prisma: PrismaClient;
Expand Down Expand Up @@ -96,9 +103,7 @@ describe('task', function () {

const response = await requestSender.getTasksByCriteriaV1();

if (response.status !== StatusCodes.OK) {
throw new Error();
}
expectResponseStatus(response, 200);

expect(response).toSatisfyApiSpec();
expect(response).toHaveProperty('status', StatusCodes.OK);
Expand Down Expand Up @@ -905,9 +910,7 @@ describe('task', function () {
},
});

if (secondStage.status !== StatusCodes.CREATED) {
throw new Error('Failed to create second stage');
}
expectResponseStatus(secondStage, 201);

const taskId = tasks[0]!.id;
const stageId = stage.id;
Expand Down
4 changes: 2 additions & 2 deletions tests/unit/db/helpers.spec.ts
Original file line number Diff line number Diff line change
Expand Up @@ -21,8 +21,8 @@ function createJobEntity(override: Partial<commonDbFullV1Type>) {
function createQueryParamsObject(paramsString: string) {
const queryParamsArr = paramsString.split('&');
const queryParamsPairs = queryParamsArr.map((params) => params.split('='));
// eslint-disable-next-line @typescript-eslint/no-unsafe-assignment
const queryObject: object = Object.fromEntries(queryParamsPairs);

const queryObject: Record<string, string> = Object.fromEntries(queryParamsPairs as [string, string][]);
return queryObject;
}

Expand Down
4 changes: 1 addition & 3 deletions tests/unit/stages/stages.spec.ts
Original file line number Diff line number Diff line change
Expand Up @@ -763,9 +763,7 @@ describe('JobManager', () => {
prisma.$transaction.mockImplementationOnce(async (callback) => {
const mockTx = {
stage: {
findUnique: vi
.fn()
.mockResolvedValue({ ...stageEntity, job: { status: JobOperationStatus.IN_PROGRESS } } as unknown as StageWithTasks),
findUnique: vi.fn().mockResolvedValue({ ...stageEntity, job: { status: JobOperationStatus.IN_PROGRESS } }),
},
} as unknown as Omit<PrismaClient, '$connect' | '$disconnect' | '$on' | '$transaction' | '$use' | '$extends'>;

Expand Down
Loading