From c10f27b44cece704e1488808a685b043df1043ad Mon Sep 17 00:00:00 2001 From: Damon Kaswell Date: Fri, 9 Dec 2022 16:56:15 -0800 Subject: [PATCH] Fix test and module Signed-off-by: Damon Kaswell --- .../api-report.md | 16 ++++++++++++---- ...lIngestionEntityProviderCatalogModule.test.ts | 2 +- .../src/run.ts | 2 +- 3 files changed, 14 insertions(+), 6 deletions(-) diff --git a/plugins/catalog-backend-module-incremental-ingestion/api-report.md b/plugins/catalog-backend-module-incremental-ingestion/api-report.md index 387e505c33..11ffdd565c 100644 --- a/plugins/catalog-backend-module-incremental-ingestion/api-report.md +++ b/plugins/catalog-backend-module-incremental-ingestion/api-report.md @@ -33,8 +33,8 @@ export type EntityIteratorResult = // @public (undocumented) export class IncrementalCatalogBuilder { // (undocumented) - addIncrementalEntityProvider( - provider: IncrementalEntityProvider, + addIncrementalEntityProvider( + provider: IncrementalEntityProvider, options: IncrementalEntityProviderOptions, ): void; // (undocumented) @@ -48,8 +48,16 @@ export class IncrementalCatalogBuilder { } // @public -export interface IncrementalEntityProvider { +export interface IncrementalEntityProvider { around(burst: (context: TContext) => Promise): Promise; + deltaMapper?: (payload: TInput) => { + delta: + | { + added: DeferredEntity[]; + removed: DeferredEntity[]; + } + | undefined; + }; getProviderName(): string; next( context: TContext, @@ -70,7 +78,7 @@ export interface IncrementalEntityProviderOptions { // @alpha export const incrementalIngestionEntityProviderCatalogModule: (options: { providers: { - provider: IncrementalEntityProvider; + provider: IncrementalEntityProvider; options: IncrementalEntityProviderOptions; }[]; }) => BackendFeature; diff --git a/plugins/catalog-backend-module-incremental-ingestion/src/module/incrementalIngestionEntityProviderCatalogModule.test.ts b/plugins/catalog-backend-module-incremental-ingestion/src/module/incrementalIngestionEntityProviderCatalogModule.test.ts index 06cbcb010e..d196693db8 100644 --- a/plugins/catalog-backend-module-incremental-ingestion/src/module/incrementalIngestionEntityProviderCatalogModule.test.ts +++ b/plugins/catalog-backend-module-incremental-ingestion/src/module/incrementalIngestionEntityProviderCatalogModule.test.ts @@ -24,7 +24,7 @@ import { incrementalIngestionEntityProviderCatalogModule } from './incrementalIn describe('bitbucketServerEntityProviderCatalogModule', () => { it('should register provider at the catalog extension point', async () => { - const provider1: IncrementalEntityProvider = { + const provider1: IncrementalEntityProvider = { getProviderName: () => 'provider1', around: burst => burst(0), next: async (cursor, _context) => { diff --git a/plugins/catalog-backend-module-incremental-ingestion/src/run.ts b/plugins/catalog-backend-module-incremental-ingestion/src/run.ts index 08d95f4417..2dee5716c0 100644 --- a/plugins/catalog-backend-module-incremental-ingestion/src/run.ts +++ b/plugins/catalog-backend-module-incremental-ingestion/src/run.ts @@ -36,7 +36,7 @@ import { incrementalIngestionEntityProviderCatalogModule, } from '.'; -const provider: IncrementalEntityProvider = { +const provider: IncrementalEntityProvider = { getProviderName: () => 'test-provider', around: burst => burst(0), next: async (_context, cursor) => {