Rename IOutputDeduplicationService to IOutputService

pagopa · Mar 1, 2024 · baf816f · baf816f
1 parent 8d8ec0e
commit baf816f
Show file tree

Hide file tree

Showing 6 changed files with 12 additions and 12 deletions.
diff --git a/src/output/__tests__/indexer-deduplication.test.ts b/src/output/__tests__/indexer-deduplication.test.ts
@@ -1,14 +1,14 @@
 import * as TE from "fp-ts/TaskEither";
 import { constVoid, pipe } from "fp-ts/lib/function";
 import { IOutputDocument } from "../elasticsearch/elasticsearch";
-import { IOutputDeduplicationService } from "../elasticsearch/service";
+import { IOutputService } from "../elasticsearch/service";
 import { indexerDeduplication } from "../indexer-deduplication";
 
 const mockGet = jest.fn();
 const mockInsert = jest.fn();
 const mockUpdate = jest.fn();
 
-const mockService: IOutputDeduplicationService = {
+const mockService: IOutputService = {
   get: mockGet,
   insert: mockInsert,
   update: mockUpdate

diff --git a/src/output/__tests__/tablestorage-deduplication.test.ts b/src/output/__tests__/tablestorage-deduplication.test.ts
@@ -5,7 +5,7 @@ import * as tableUtils from "../../utils/tableStorage";
 
 import { pipe } from "fp-ts/lib/function";
 import { IOutputDocument } from "../elasticsearch/elasticsearch";
-import { IOutputDeduplicationService } from "../elasticsearch/service";
+import { IOutputService } from "../elasticsearch/service";
 import { tableStorageDeduplication } from "../tablestorage-deduplication";
 import { NonEmptyString } from "@pagopa/ts-commons/lib/strings";
 
@@ -19,7 +19,7 @@ const mockGet = jest.fn();
 const mockInsert = jest.fn().mockImplementation(() => TE.right(void 0));
 const mockUpdate = jest.fn().mockImplementation(() => TE.right(void 0));
 
-const mockService: IOutputDeduplicationService = {
+const mockService: IOutputService = {
   get: mockGet,
   insert: mockInsert,
   update: mockUpdate

diff --git a/src/output/elasticsearch/service.ts b/src/output/elasticsearch/service.ts
@@ -15,7 +15,7 @@ import {
 export type OutputClient = EL.Client;
 export type OutputDataRead = GetResponse<IOutputDocument>;
 export type OutputDataWrite = EL.estypes.Result;
-export interface IOutputDeduplicationService {
+export interface IOutputService {
   readonly get: (
     indexName: string,
     document: IOutputDocument
@@ -32,7 +32,7 @@ export interface IOutputDeduplicationService {
 
 export const getElasticSearchService = (
   connectionString: string
-): E.Either<Error, IOutputDeduplicationService> =>
+): E.Either<Error, IOutputService> =>
   pipe(
     getElasticClient(connectionString),
     E.map(client => ({

diff --git a/src/output/indexer-deduplication.ts b/src/output/indexer-deduplication.ts
@@ -4,12 +4,12 @@ import * as O from "fp-ts/Option";
 import * as TE from "fp-ts/TaskEither";
 import { flow, pipe } from "fp-ts/lib/function";
 import { IOutputDocument } from "./elasticsearch/elasticsearch";
-import { IOutputDeduplicationService } from "./elasticsearch/service";
+import { IOutputService } from "./elasticsearch/service";
 
 export const indexerDeduplication = (
   indexName: string,
   document: IOutputDocument
-) => (service: IOutputDeduplicationService): TE.TaskEither<Error, void> =>
+) => (service: IOutputService): TE.TaskEither<Error, void> =>
   pipe(
     service.get(indexName, document),
     TE.map(O.some),

diff --git a/src/output/service.ts b/src/output/service.ts
@@ -1,15 +1,15 @@
 import * as TE from "fp-ts/TaskEither";
 import { NonEmptyString } from "@pagopa/ts-commons/lib/strings";
 import { IOutputDocument } from "./elasticsearch/elasticsearch";
-import { IOutputDeduplicationService } from "./elasticsearch/service";
+import { IOutputService } from "./elasticsearch/service";
 import { indexerDeduplication } from "./indexer-deduplication";
 import { tableStorageDeduplication } from "./tablestorage-deduplication";
 
 export interface IDeduplicationStrategy {
   readonly execute: (
     indexName: string,
     document: IOutputDocument
-  ) => (service: IOutputDeduplicationService) => TE.TaskEither<Error, void>;
+  ) => (service: IOutputService) => TE.TaskEither<Error, void>;
 }
 
 export const indexerDeduplicationStrategy: IDeduplicationStrategy = {

diff --git a/src/output/tablestorage-deduplication.ts b/src/output/tablestorage-deduplication.ts
@@ -10,12 +10,12 @@ import {
   upsertTableDocument
 } from "../utils/tableStorage";
 import { IOutputDocument } from "./elasticsearch/elasticsearch";
-import { IOutputDeduplicationService } from "./elasticsearch/service";
+import { IOutputService } from "./elasticsearch/service";
 
 export const tableStorageDeduplication = (
   tableStorageConnectionString: NonEmptyString
 ) => (indexName: string, document: IOutputDocument) => (
-  service: IOutputDeduplicationService
+  service: IOutputService
 ): TE.TaskEither<Error, void> =>
   pipe(
     TE.Do,