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

Update supabase-jobs.ts

Browse Source
This commit is contained in:
Nicolas 2024-08-30 14:52:59 -03:00
parent 2fd9c285bd
commit 234c6daee8
1 changed files with 12 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
apps/api/src/lib/supabase-jobs.ts
View File

@ -1,10 +1,12 @@
import { supabase_service } from "../services/supabase"; import { supabase_service } from "../services/supabase";
import { Logger } from "./logger";
import * as Sentry from "@sentry/node";
export const supabaseGetJobById = async (jobId: string) => { export const supabaseGetJobById = async (jobId: string) => {
const { data, error } = await supabase_service const { data, error } = await supabase_service
.from('firecrawl_jobs') .from("firecrawl_jobs")
.select('*') .select("*")
.eq('job_id', jobId) .eq("job_id", jobId)
.single(); .single();
if (error) { if (error) {
@ -16,15 +18,16 @@ export const supabaseGetJobById = async (jobId: string) => {
} }
return data; return data;
} };
export const supabaseGetJobsById = async (jobIds: string[]) => { export const supabaseGetJobsById = async (jobIds: string[]) => {
const { data, error } = await supabase_service const { data, error } = await supabase_service.rpc("get_jobs_by_ids", {
.from('firecrawl_jobs') job_ids: jobIds,
.select('*') });
.in('job_id', jobIds);
if (error) { if (error) {
Logger.error(`Error in get_jobs_by_ids: ${error}`);
Sentry.captureException(error);
return []; return [];
} }
@ -33,5 +36,4 @@ export const supabaseGetJobsById = async (jobIds: string[]) => {
} }
return data; return data;
} };