From 19b07a6f67b3c5ba58d11258be9db4a6c2596326 Mon Sep 17 00:00:00 2001
From: Johan Haals <johan.haals@gmail.com>
Date: Mon, 26 Apr 2021 14:02:41 +0200
Subject: [PATCH] Remove addProcessingItems
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Co-authored-by: Fredrik Adelöw <freben@users.noreply.github.com>
Co-authored-by: Ben Lambert <ben@blam.sh>
Co-authored-by: Patrik Oldsberg <poldsberg@gmail.com>
Signed-off-by: Johan Haals <johan.haals@gmail.com>
---
 plugins/catalog-backend/src/next/Stitcher.ts | 4 ++--
 plugins/catalog-backend/src/next/types.ts    | 7 -------
 2 files changed, 2 insertions(+), 9 deletions(-)

diff --git a/plugins/catalog-backend/src/next/Stitcher.ts b/plugins/catalog-backend/src/next/Stitcher.ts
index f53b7c6fad..57f5ae9167 100644
--- a/plugins/catalog-backend/src/next/Stitcher.ts
+++ b/plugins/catalog-backend/src/next/Stitcher.ts
@@ -19,7 +19,7 @@ import { Logger } from 'winston';
 import { Transaction } from '../database';
 import { ConflictError } from '@backstage/errors';
 import {
-  DbRefreshStateReferences,
+  DbRefreshStateReferencesRow,
   DbRefreshStateRow,
   DbRelationsRow,
 } from './database/DefaultProcessingDatabase';
@@ -73,7 +73,7 @@ export class Stitcher {
           return;
         }
 
-        const [reference_count_result] = await tx<DbRefreshStateReferences>(
+        const [reference_count_result] = await tx<DbRefreshStateReferencesRow>(
           'refresh_state_references',
         )
           .where({ target_entity_ref: entityRef })
diff --git a/plugins/catalog-backend/src/next/types.ts b/plugins/catalog-backend/src/next/types.ts
index a39ab9a8ff..ef3bab797b 100644
--- a/plugins/catalog-backend/src/next/types.ts
+++ b/plugins/catalog-backend/src/next/types.ts
@@ -101,12 +101,6 @@ export type ProcessingItemResult = {
   deferredEntities: Entity[];
 };
 
-export type AddProcessingItemRequest = {
-  type: 'entity' | 'provider';
-  id: string;
-  entities: Entity[];
-};
-
 export type ProcessingItem = {
   id: string;
   entity: Entity;
@@ -128,6 +122,5 @@ export type ReplaceProcessingItemsRequest =
 export interface ProcessingStateManager {
   setProcessingItemResult(result: ProcessingItemResult): Promise<void>;
   getNextProcessingItem(): Promise<ProcessingItem>;
-  addProcessingItems(request: AddProcessingItemRequest): Promise<void>;
   replaceProcessingItems(request: ReplaceProcessingItemsRequest): Promise<void>;
 }