diff --git a/apps/api/src/controllers/v1/scrape-status.ts b/apps/api/src/controllers/v1/scrape-status.ts index e89f724e..4f076a34 100644 --- a/apps/api/src/controllers/v1/scrape-status.ts +++ b/apps/api/src/controllers/v1/scrape-status.ts @@ -1,9 +1,18 @@ import { Response } from "express"; import { supabaseGetJobByIdOnlyData } from "../../lib/supabase-jobs"; import { getJob } from "./crawl-status"; +import { logger as _logger } from "../../lib/logger"; export async function scrapeStatusController(req: any, res: any) { - const job = await supabaseGetJobByIdOnlyData(req.params.jobId); + const logger = _logger.child({ + module: "scrape-status", + method: "scrapeStatusController", + teamId: req.auth.team_id, + jobId: req.params.jobId, + scrapeId: req.params.jobId, + }); + + const job = await supabaseGetJobByIdOnlyData(req.params.jobId, logger); if (!job) { return res.status(404).json({ diff --git a/apps/api/src/lib/supabase-jobs.ts b/apps/api/src/lib/supabase-jobs.ts index 874c5293..7e826849 100644 --- a/apps/api/src/lib/supabase-jobs.ts +++ b/apps/api/src/lib/supabase-jobs.ts @@ -1,3 +1,4 @@ +import type { Logger } from "winston"; import { supabase_rr_service, supabase_service } from "../services/supabase"; import { logger } from "./logger"; import * as Sentry from "@sentry/node"; @@ -73,7 +74,7 @@ export const supabaseGetJobsByCrawlId = async (crawlId: string) => { return data; }; -export const supabaseGetJobByIdOnlyData = async (jobId: string) => { +export const supabaseGetJobByIdOnlyData = async (jobId: string, logger?: Logger) => { const { data, error } = await supabase_rr_service .from("firecrawl_jobs") .select("team_id") @@ -81,6 +82,9 @@ export const supabaseGetJobByIdOnlyData = async (jobId: string) => { .single(); if (error) { + if (logger) { + logger.error("Error in supabaseGetJobByIdOnlyData", { error }); + } return null; }