feat(api/v1/scrape-status): log supa lookup errors

This commit is contained in:
Gergő Móricz 2025-05-29 13:02:54 +02:00
parent 3557c90210
commit 706d378a89
2 changed files with 15 additions and 2 deletions

View File

@ -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({

View File

@ -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;
}