AI/firecrawl
1
0
Fork 0
mirror of https://git.mirrors.martin98.com/https://github.com/mendableai/firecrawl synced 2025-08-12 20:39:00 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(services/webhook): greatly improved logging

Browse Source
This commit is contained in:
Gergő Móricz 2025-05-21 16:01:57 +02:00
parent 9949403b59
commit b8ea4021c1
1 changed files with 32 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
apps/api/src/services/webhook.ts
View File

@ -1,5 +1,5 @@
import axios from "axios"; import axios from "axios";
import { logger } from "../lib/logger"; import { logger as _logger } from "../lib/logger";
import { supabase_rr_service, supabase_service } from "./supabase"; import { supabase_rr_service, supabase_service } from "./supabase";
import { WebhookEventType } from "../types"; import { WebhookEventType } from "../types";
import { configDotenv } from "dotenv"; import { configDotenv } from "dotenv";
@ -16,9 +16,24 @@ export const callWebhook = async (
eventType: WebhookEventType = "crawl.page", eventType: WebhookEventType = "crawl.page",
awaitWebhook: boolean = false, awaitWebhook: boolean = false,
) => { ) => {
const logger = _logger.child({
module: "webhook",
method: "callWebhook",
teamId, team_id: teamId,
crawlId: id,
eventType,
awaitWebhook,
webhook: specified,
isV1: v1,
});
if (specified) { if (specified) {
let subType = eventType.split(".")[1]; let subType = eventType.split(".")[1];
if (!specified.events.includes(subType as any)) { if (!specified.events.includes(subType as any)) {
logger.debug("Webhook event type not in specified events", {
subType,
specified,
});
return false; return false;
} }
} }
@ -43,7 +58,10 @@ export const callWebhook = async (
.limit(1); .limit(1);
if (error) { if (error) {
logger.error( logger.error(
`Error fetching webhook URL for team ID: ${teamId}, error: ${error.message}`, `Error fetching webhook URL for team`,
{
error,
},
); );
return null; return null;
} }
@ -57,11 +75,6 @@ export const callWebhook = async (
logger.debug("Calling webhook...", { logger.debug("Calling webhook...", {
webhookUrl, webhookUrl,
teamId,
specified,
v1,
eventType,
awaitWebhook,
}); });
if (!webhookUrl) { if (!webhookUrl) {
@ -118,7 +131,10 @@ export const callWebhook = async (
); );
} catch (error) { } catch (error) {
logger.error( logger.error(
`Axios error (0) sending webhook for team ID: ${teamId}, error: ${error.message}`, `Failed to send webhook`,
{
error,
},
); );
} }
} else { } else {
@ -150,13 +166,19 @@ export const callWebhook = async (
) )
.catch((error) => { .catch((error) => {
logger.error( logger.error(
`Axios error sending webhook for team ID: ${teamId}, error: ${error.message}`, `Failed to send webhook`,
{
error,
},
); );
}); });
} }
} catch (error) { } catch (error) {
logger.debug( logger.debug(
`Error sending webhook for team ID: ${teamId}, error: ${error.message}`, `Error sending webhook`,
{
error,
},
); );
} }
}; };