From 96f75f898fe40d0ff7c4b1ef6e0ef73d774999e1 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Gerg=C5=91=20M=C3=B3ricz?= Date: Mon, 2 Jun 2025 21:49:45 +0200 Subject: [PATCH] feat(search): only for low tier users for good DX --- apps/api/src/controllers/v1/search.ts | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/apps/api/src/controllers/v1/search.ts b/apps/api/src/controllers/v1/search.ts index 7cbe6e64..fe104dc1 100644 --- a/apps/api/src/controllers/v1/search.ts +++ b/apps/api/src/controllers/v1/search.ts @@ -76,6 +76,7 @@ async function scrapeSearchResult( logger: Logger, costTracking: CostTracking, flags: TeamFlags, + directToBullMQ: boolean = false, ): Promise { const jobId = uuidv4(); const jobPriority = await getJobPriority({ @@ -106,7 +107,7 @@ async function scrapeSearchResult( {}, jobId, jobPriority, - true, + directToBullMQ, ); const doc: Document = await waitForJob(jobId, options.timeout); @@ -229,7 +230,7 @@ export async function searchController( origin: req.body.origin, timeout: req.body.timeout, scrapeOptions: req.body.scrapeOptions, - }, logger, costTracking, req.acuc?.flags ?? null), + }, logger, costTracking, req.acuc?.flags ?? null, (req.acuc?.price_credits ?? 0) <= 3000), ); const docs = await Promise.all(scrapePromises);