diff --git a/packages/kafka-producer/src/config/env.ts b/packages/kafka-producer/src/config/env.ts index 9ea96a5..d9eaf34 100644 --- a/packages/kafka-producer/src/config/env.ts +++ b/packages/kafka-producer/src/config/env.ts @@ -33,11 +33,11 @@ export const KafkaProducerConfig = z const parsedFromEnv = KafkaProducerConfig.safeParse(process.env); if (!parsedFromEnv.success) { const invalidEnvVars = parsedFromEnv.error.issues.flatMap( - (issue) => issue.path + (issue) => issue.path, ); // eslint-disable-next-line no-console console.error( - "Invalid or missing env vars: Kafka Producer " + invalidEnvVars.join(", ") + "Invalid or missing env vars: Kafka Producer " + invalidEnvVars.join(", "), ); process.exit(1); } diff --git a/packages/kafka-producer/src/producer.ts b/packages/kafka-producer/src/producer.ts index ebc2548..4aa8434 100644 --- a/packages/kafka-producer/src/producer.ts +++ b/packages/kafka-producer/src/producer.ts @@ -32,7 +32,7 @@ const errorEventsListener = (consumerOrProducer: Consumer | Producer): void => { processExit(); } catch (e) { genericLogger.error( - `Unexpected error on disconnection with event type ${type}; Error detail: ${e}` + `Unexpected error on disconnection with event type ${type}; Error detail: ${e}`, ); processExit(); } @@ -61,14 +61,14 @@ const producerKafkaEventsListener = (producer: Producer): void => { } producer.on(producer.events.REQUEST_TIMEOUT, (e) => { genericLogger.error( - `Error Request to a broker has timed out : ${JSON.stringify(e)}.` + `Error Request to a broker has timed out : ${JSON.stringify(e)}.`, ); }); }; async function oauthBearerTokenProvider( region: string, - logger: Logger + logger: Logger, ): Promise { logger.debug("Fetching token from AWS"); @@ -77,7 +77,7 @@ async function oauthBearerTokenProvider( }); logger.debug( - `Token fetched from AWS expires at ${authTokenResponse.expiryTime}` + `Token fetched from AWS expires at ${authTokenResponse.expiryTime}`, ); return { @@ -110,7 +110,7 @@ const initKafka = (config: KafkaProducerConfig): Kafka => { ...kafkaConfig, logCreator: ( - _logLevel // eslint-disable-line @typescript-eslint/no-unused-vars + _logLevel, // eslint-disable-line @typescript-eslint/no-unused-vars ) => ({ level, log }) => { const { message, error } = log; @@ -121,7 +121,7 @@ const initKafka = (config: KafkaProducerConfig): Kafka => { (error) => (level === logLevel.ERROR || level === logLevel.WARN) && error.includes("The group is rebalancing, so a rejoin is needed"), - () => logLevel.INFO + () => logLevel.INFO, ) .otherwise(() => level); @@ -129,7 +129,7 @@ const initKafka = (config: KafkaProducerConfig): Kafka => { match(filteredLevel) .with(logLevel.NOTHING, logLevel.ERROR, () => - genericLogger.error(msg) + genericLogger.error(msg), ) .with(logLevel.WARN, () => genericLogger.warn(msg)) .with(logLevel.INFO, () => genericLogger.info(msg)) @@ -141,11 +141,11 @@ const initKafka = (config: KafkaProducerConfig): Kafka => { export const initProducer = async ( config: KafkaProducerConfig, - topics: string + topics: string, ): Promise< Producer & { send: ( - record: Omit & { topic: string } + record: Omit & { topic: string }, ) => Promise; } > => { @@ -186,7 +186,7 @@ export const initProducer = async ( }; } catch (e) { genericLogger.error( - `Generic error occurs during consumer initialization: ${e}` + `Generic error occurs during consumer initialization: ${e}`, ); processExit(); return undefined as never; @@ -195,10 +195,10 @@ export const initProducer = async ( export const validateTopicMetadata = async ( kafka: Kafka, - topicNames: string[] + topicNames: string[], ): Promise => { genericLogger.debug( - `Check topics |${JSON.stringify(topicNames)}| existence...` + `Check topics |${JSON.stringify(topicNames)}| existence...`, ); const admin = kafka.admin(); @@ -215,8 +215,8 @@ export const validateTopicMetadata = async ( await admin.disconnect(); genericLogger.error( `Unable to subscribe! Error during topic metadata fetch: ${JSON.stringify( - e - )}` + e, + )}`, ); return false; } diff --git a/packages/models/src/eservice/eservice.ts b/packages/models/src/eservice/eservice.ts index 17552e5..9fcbc55 100644 --- a/packages/models/src/eservice/eservice.ts +++ b/packages/models/src/eservice/eservice.ts @@ -87,12 +87,11 @@ export const EserviceSaveRequest = z.object({ export type EserviceSaveRequest = z.infer; export const TenantSaveRequest = z.object({ - tenant_id: z.string(), - tenant_name: z.string().optional(), + tenant_id: z.string(), + tenant_name: z.string().optional(), }); export type TenantSaveRequest = z.infer; - /** * Schema for EService. * diff --git a/packages/probing-eservice-operations/src/repositories/modelRepository.ts b/packages/probing-eservice-operations/src/repositories/modelRepository.ts index 4330d21..6c04561 100644 --- a/packages/probing-eservice-operations/src/repositories/modelRepository.ts +++ b/packages/probing-eservice-operations/src/repositories/modelRepository.ts @@ -92,17 +92,17 @@ export class ModelRepository { this.eservices = this.entityManager.getRepository(Eservice); this.tenants = this.entityManager.getRepository(Tenant); this.eserviceProbingRequest = this.entityManager.getRepository( - EserviceProbingRequest + EserviceProbingRequest, ); this.eserviceProbingResponse = this.entityManager.getRepository( - EserviceProbingResponse + EserviceProbingResponse, ); this.eserviceView = this.entityManager.getRepository(EserviceView); } public static async init( config: DbConfig, - initDB: string | null = null + initDB: string | null = null, ): Promise { if (!ModelRepository.instance) { ModelRepository.instance = new ModelRepository(config); @@ -114,7 +114,7 @@ export class ModelRepository { genericLogger.info( `Database Connection Status: ${ connectionStatus ? "Initialized" : "Not Initialized" - }` + }`, ); } diff --git a/packages/probing-eservice-operations/test/eservice.test.ts b/packages/probing-eservice-operations/test/eservice.test.ts index c64b1d8..3a0ad11 100644 --- a/packages/probing-eservice-operations/test/eservice.test.ts +++ b/packages/probing-eservice-operations/test/eservice.test.ts @@ -99,7 +99,7 @@ describe("database test", async () => { ...eServiceDefaultValues, ...partialEserviceData, } satisfies EserviceSchema, - modelRepository.eservices + modelRepository.eservices, ); if (!dataOptions.disableCreationProbingRequest) { @@ -109,7 +109,7 @@ describe("database test", async () => { lastRequest: "2024-01-25T00:51:05.733Z", ...partialProbingRequestData, } satisfies EserviceProbingRequestSchema, - modelRepository.eserviceProbingRequest + modelRepository.eserviceProbingRequest, ); } @@ -121,13 +121,13 @@ describe("database test", async () => { responseReceived: "2024-01-25T00:51:05.736Z", ...partialProbingResponseData, } satisfies EserviceProbingResponseSchema, - modelRepository.eserviceProbingResponse + modelRepository.eserviceProbingResponse, ); } const { versionId, eserviceId } = await getEservice( eserviceRecordId, - modelRepository.eserviceView + modelRepository.eserviceView, ); return { @@ -182,7 +182,7 @@ describe("database test", async () => { const result = await eserviceService.searchEservices( filters, - genericLogger + genericLogger, ); expect(result.content).toStrictEqual([]); @@ -210,7 +210,7 @@ describe("database test", async () => { const result = await eserviceService.searchEservices( filters, - genericLogger + genericLogger, ); expect(result.totalElements).not.toBe(0); expect(result.offset).toBe(0); @@ -235,7 +235,7 @@ describe("database test", async () => { const result = await eserviceService.searchEservices( filters, - genericLogger + genericLogger, ); expect(result.content).toStrictEqual([]); @@ -259,7 +259,7 @@ describe("database test", async () => { const result = await eserviceService.searchEservices( filters, - genericLogger + genericLogger, ); expect(result.totalElements).toBe(1); @@ -274,7 +274,7 @@ describe("database test", async () => { const eservice = await createEservice(); const result = await eserviceService.getEserviceMainData( eservice.eserviceRecordId, - genericLogger + genericLogger, ); expect(result).toBeTruthy(); }); @@ -282,7 +282,7 @@ describe("database test", async () => { it("e-service should not be found and an `eServiceProbingDataByRecordIdNotFound` should be thrown", async () => { await expect( async () => - await eserviceService.getEserviceMainData(99, genericLogger) + await eserviceService.getEserviceMainData(99, genericLogger), ).rejects.toThrowError(eServiceMainDataByRecordIdNotFound(99)); }); }); @@ -292,7 +292,7 @@ describe("database test", async () => { const eservice = await createEservice(); const result = await eserviceService.getEserviceProbingData( eservice.eserviceRecordId, - genericLogger + genericLogger, ); expect(result).toBeTruthy(); }); @@ -300,7 +300,7 @@ describe("database test", async () => { it("e-service should not be found and an `eServiceProbingDataByRecordIdNotFound` should be thrown", async () => { await expect( async () => - await eserviceService.getEserviceProbingData(99, genericLogger) + await eserviceService.getEserviceProbingData(99, genericLogger), ).rejects.toThrowError(eServiceProbingDataByRecordIdNotFound(99)); }); }); @@ -321,7 +321,7 @@ describe("database test", async () => { offset: 0, limit: 2, }, - genericLogger + genericLogger, ); expect(result.content.length).toBe(1); @@ -339,7 +339,7 @@ describe("database test", async () => { await createEservice(); const producers = await eserviceService.getEservicesProducers( filters, - genericLogger + genericLogger, ); expect(producers.content.length).toBe(0); @@ -354,7 +354,7 @@ describe("database test", async () => { await createEservice(); const result = await eserviceService.getEservicesProducers( filters, - genericLogger + genericLogger, ); expect(result.content.length).not.toBe(0); @@ -371,7 +371,7 @@ describe("database test", async () => { await createEservice(); const producers = await eserviceService.getEservicesProducers( eServiceProducer1, - genericLogger + genericLogger, ); expect(producers.content.length).toBe(1); @@ -389,7 +389,7 @@ describe("database test", async () => { { eServiceState: eserviceInteropState.inactive, }, - genericLogger + genericLogger, ); const result = await eservices.findOneBy({ @@ -411,8 +411,8 @@ describe("database test", async () => { { eServiceState: eserviceInteropState.active, }, - genericLogger - ) + genericLogger, + ), ).rejects.toThrowError(eServiceNotFound(eserviceId, versionId)); }); }); @@ -429,7 +429,7 @@ describe("database test", async () => { { probingEnabled: true, }, - genericLogger + genericLogger, ); const result = await eservices.findOneBy({ @@ -452,8 +452,8 @@ describe("database test", async () => { { probingEnabled: true, }, - genericLogger - ) + genericLogger, + ), ).rejects.toThrowError(eServiceNotFound(eserviceId, versionId)); }); }); @@ -476,7 +476,7 @@ describe("database test", async () => { startTime: payload.startTime, endTime: payload.endTime, }, - genericLogger + genericLogger, ); const updatedEservice = await eservices.findOneBy({ @@ -509,8 +509,8 @@ describe("database test", async () => { startTime: payload.startTime, endTime: payload.endTime, }, - genericLogger - ) + genericLogger, + ), ).rejects.toThrowError(eServiceNotFound(eserviceId, versionId)); }); }); @@ -540,7 +540,7 @@ describe("database test", async () => { payload.eserviceId, payload.versionId, payload, - genericLogger + genericLogger, ); const updatedEservice = await eservices.findOneBy({ @@ -579,7 +579,7 @@ describe("database test", async () => { eserviceId, versionId, payload, - genericLogger + genericLogger, ); const updatedEservice = await eservices.findOneBy({ @@ -610,8 +610,8 @@ describe("database test", async () => { payload.eserviceId, payload.versionId, payload, - genericLogger - ) + genericLogger, + ), ).rejects.toThrowError(tenantNotFound(payload.producerId)); }); }); @@ -652,7 +652,7 @@ describe("database test", async () => { const invalidId = "invalid-uuid-format"; await expect( - eserviceService.deleteEservice(invalidId) + eserviceService.deleteEservice(invalidId), ).rejects.toThrow(); }); }); @@ -668,7 +668,7 @@ describe("database test", async () => { await eserviceService.updateEserviceLastRequest( eserviceRecordId, payload, - genericLogger + genericLogger, ); const updatedEservice = await eserviceProbingRequest.findOneBy({ @@ -696,7 +696,7 @@ describe("database test", async () => { await eserviceService.updateEserviceLastRequest( eserviceRecordId, payload, - genericLogger + genericLogger, ); const updatedEservice = await eserviceProbingRequest.findOneBy({ @@ -725,7 +725,7 @@ describe("database test", async () => { await eserviceService.updateResponseReceived( eserviceRecordId, payload, - genericLogger + genericLogger, ); const updatedEservice = await eserviceProbingResponse.findOneBy({ @@ -756,7 +756,7 @@ describe("database test", async () => { await eserviceService.updateResponseReceived( eserviceRecordId, payload, - genericLogger + genericLogger, ); const updatedEservice = await eserviceProbingResponse.findOneBy({ @@ -800,7 +800,7 @@ describe("database test", async () => { const result = await eserviceService.searchEservices( filters, - genericLogger + genericLogger, ); expect(result.totalElements).not.toBe(0); expect(result.offset).toBe(0); diff --git a/packages/probing-eservice-operations/test/utils.ts b/packages/probing-eservice-operations/test/utils.ts index e0f79b4..97edbe0 100644 --- a/packages/probing-eservice-operations/test/utils.ts +++ b/packages/probing-eservice-operations/test/utils.ts @@ -17,7 +17,7 @@ import { EserviceViewSchema } from "../src/repositories/entity/view/eservice.ent export const addEserviceProbingRequest = async ( data: EserviceProbingRequestSchema, - repository: EserviceProbingRequestEntities + repository: EserviceProbingRequestEntities, ): Promise => { const result = await repository.upsert(data, { skipUpdateIfNoValuesChanged: true, @@ -28,7 +28,7 @@ export const addEserviceProbingRequest = async ( export const addEserviceProbingResponse = async ( data: EserviceProbingResponseSchema, - repository: EserviceProbingResponseEntities + repository: EserviceProbingResponseEntities, ): Promise => { const result = await repository.upsert(data, { skipUpdateIfNoValuesChanged: true, @@ -39,7 +39,7 @@ export const addEserviceProbingResponse = async ( export const addEservice = async ( data: EserviceSchema, - repository: EserviceEntities + repository: EserviceEntities, ): Promise => { const result: InsertResult = await repository .createQueryBuilder() @@ -58,7 +58,7 @@ export const addEservice = async ( export const addTenant = async ( data: TenantSchema, - repository: TenantEntities + repository: TenantEntities, ): Promise => { const result: InsertResult = await repository .createQueryBuilder() @@ -77,7 +77,7 @@ export const addTenant = async ( export const getEservice = async ( eserviceRecordId: number, - repository: EserviceViewEntities + repository: EserviceViewEntities, ): Promise => { return (await repository.findOneBy({ eserviceRecordId })) || {}; }; diff --git a/packages/tenant-event-consumer/src/index.ts b/packages/tenant-event-consumer/src/index.ts index e983c2d..d83cdb7 100644 --- a/packages/tenant-event-consumer/src/index.ts +++ b/packages/tenant-event-consumer/src/index.ts @@ -14,5 +14,5 @@ const operationsService: OperationsService = await runConsumer( config, [config.kafkaTopic], - processMessage(operationsService) + processMessage(operationsService), ); diff --git a/packages/tenant-event-consumer/src/messagesHandler.ts b/packages/tenant-event-consumer/src/messagesHandler.ts index 6fd02ab..b2c3138 100644 --- a/packages/tenant-event-consumer/src/messagesHandler.ts +++ b/packages/tenant-event-consumer/src/messagesHandler.ts @@ -10,7 +10,7 @@ import { decodeOutboundTenantEvent } from "@pagopa/interop-outbound-models"; import { handleMessageV1, handleMessageV2 } from "./handlers/index.js"; export function processMessage( - service: OperationsService + service: OperationsService, ): ({ message, partition }: EachMessagePayload) => Promise { return async ({ message, partition }: EachMessagePayload): Promise => { const ctx: AppContext = { @@ -34,15 +34,15 @@ export function processMessage( await match(tenantEvent) .with({ event_version: 1 }, (event) => - handleMessageV1(event, service, ctx, loggerInstance) + handleMessageV1(event, service, ctx, loggerInstance), ) .with({ event_version: 2 }, (event) => - handleMessageV2(event, service, ctx, loggerInstance) + handleMessageV2(event, service, ctx, loggerInstance), ) .exhaustive(); loggerInstance.info( - `Message was processed. Partition number: ${partition}. Offset: ${message.offset}` + `Message was processed. Partition number: ${partition}. Offset: ${message.offset}`, ); } catch (error: unknown) { throw errorMapper(error, logger(ctx)); diff --git a/packages/tenant-event-consumer/src/utilities/config.ts b/packages/tenant-event-consumer/src/utilities/config.ts index 724abc2..a813fb9 100644 --- a/packages/tenant-event-consumer/src/utilities/config.ts +++ b/packages/tenant-event-consumer/src/utilities/config.ts @@ -16,7 +16,7 @@ const tenantEventConsumerConfig = LoggerConfig.and(KafkaConsumerConfig) .transform((c) => ({ applicationName: c.APPLICATION_NAME, operationsBaseUrl: c.API_OPERATIONS_BASEURL, - })) + })), ); export type TenantEventConsumerConfig = z.infer< diff --git a/packages/tenant-event-consumer/test/utils.ts b/packages/tenant-event-consumer/test/utils.ts index 2ec3610..5d36194 100644 --- a/packages/tenant-event-consumer/test/utils.ts +++ b/packages/tenant-event-consumer/test/utils.ts @@ -33,7 +33,7 @@ const descriptor: EServiceDescriptorV1 = { export const createEServiceV1 = ( partialEservice?: Partial, - descriptorItem?: EServiceDescriptorV1 + descriptorItem?: EServiceDescriptorV1, ): EServiceV1 => ({ id: uuidv4(), producerId: uuidv4(), @@ -48,7 +48,7 @@ export const createEServiceV1 = ( export const createTenantEventV1 = ( tenantV1: TenantV1 | undefined, stream_id?: string, - version?: number + version?: number, ): TenantEventV1 => ({ type: "TenantCreated", timestamp: new Date(), @@ -63,7 +63,7 @@ export const createTenantEventV1 = ( export const createTenantEventV2 = ( tenantV2: TenantV2 | undefined, stream_id?: string, - version?: number + version?: number, ): TenantEventV2 => ({ type: "TenantOnboarded", timestamp: new Date(), @@ -118,7 +118,7 @@ export const mockEserviceUpdateV1: EServiceEventV1 = { export const createEserviceAddedEventV2 = ( eServiceV2: EServiceV2, stream_id?: string, - version?: number + version?: number, ): EServiceEventV2 => ({ type: "EServiceAdded", event_version: 2, @@ -131,7 +131,7 @@ export const createEserviceAddedEventV2 = ( }); export const getDescriptorV2 = ( - partialDescriptorV2?: Partial + partialDescriptorV2?: Partial, ): EServiceDescriptorV2 => ({ id: uuidv4(), agreementApprovalPolicy: AgreementApprovalPolicyV2.AUTOMATIC, @@ -152,7 +152,7 @@ export const createV2Event = ( descriptorId: string, producerId: string, eServiceDescriptorState: EServiceDescriptorStateV2, - descriptors?: EServiceDescriptorV2[] + descriptors?: EServiceDescriptorV2[], ): EServiceV2 => ({ id: eServiceId, producerId, @@ -254,7 +254,7 @@ export const mockTenantUpdateV2 = (tenantId: string): TenantEventV2 => ({ export function mockApiClientError( status: number, - statusText: string + statusText: string, ): AxiosError { const mockAxiosError = new AxiosError(statusText); mockAxiosError.response = {