From 20cce38c844e0227940e13a5e9c70b8e385749ba Mon Sep 17 00:00:00 2001 From: Johan Haals Date: Fri, 10 Sep 2021 14:19:19 +0200 Subject: [PATCH] Fix refresh route Co-authored-by: Ben Lambert Signed-off-by: Johan Haals --- .../catalog-backend/src/next/NextRouter.ts | 24 +++++++++++++------ 1 file changed, 17 insertions(+), 7 deletions(-) diff --git a/plugins/catalog-backend/src/next/NextRouter.ts b/plugins/catalog-backend/src/next/NextRouter.ts index 9e95cf6434..03d4005769 100644 --- a/plugins/catalog-backend/src/next/NextRouter.ts +++ b/plugins/catalog-backend/src/next/NextRouter.ts @@ -34,7 +34,11 @@ import { parseEntityTransformParams, } from '../service/request'; import { disallowReadonlyMode, validateRequestBody } from '../service/util'; -import { CatalogProcessingEngine, LocationService, EntityRefreshOptions } from './types'; +import { + CatalogProcessingEngine, + LocationService, + EntityRefreshOptions, +} from './types'; export interface NextRouterOptions { entitiesCatalog?: EntitiesCatalog; @@ -48,8 +52,14 @@ export interface NextRouterOptions { export async function createNextRouter( options: NextRouterOptions, ): Promise { - const { entitiesCatalog, locationAnalyzer, locationService, processingEngine, config, logger } = - options; + const { + entitiesCatalog, + locationAnalyzer, + locationService, + processingEngine, + config, + logger, + } = options; const router = Router(); router.use(express.json()); @@ -61,10 +71,10 @@ export async function createNextRouter( } if (processingEngine) { - router.post('/refresh'), async (req, res) => { - const options: EntityRefreshOptions = req.body; - await processingEngine.refresh(options); - res.status(200); + router.post('/refresh', async (req, res) => { + const refreshOptions: EntityRefreshOptions = req.body; + await processingEngine.refresh(refreshOptions); + res.status(200).send(); }); }