Austin/firecrawl
1
0
Fork 0
mirror of https://github.com/mendableai/firecrawl.git synced 2024-11-16 03:32:22 +08:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Merge pull request #374 from StefanTerdell/fix-372

Browse Source 
Only check Supabase if configured to when cancelling job
This commit is contained in:
Nicolas 2024-07-07 22:53:15 -03:00 committed by GitHub
commit 002bfdf639
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 15 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
apps/api/src/controllers/crawl-cancel.ts
View File

@ -8,6 +8,8 @@ import { billTeam } from "../../src/services/billing/credit_billing";
export async function crawlCancelController(req: Request, res: Response) { export async function crawlCancelController(req: Request, res: Response) {
try { try {
const useDbAuthentication = process.env.USE_DB_AUTHENTICATION === 'true';
const { success, team_id, error, status } = await authenticateUser( const { success, team_id, error, status } = await authenticateUser(
req, req,
res, res,
@ -22,18 +24,21 @@ export async function crawlCancelController(req: Request, res: Response) {
} }
// check if the job belongs to the team // check if the job belongs to the team
const { data, error: supaError } = await supabase_service if (useDbAuthentication) {
.from("bulljobs_teams") const { data, error: supaError } = await supabase_service
.select("*") .from("bulljobs_teams")
.eq("job_id", req.params.jobId) .select("*")
.eq("team_id", team_id); .eq("job_id", req.params.jobId)
if (supaError) { .eq("team_id", team_id);
return res.status(500).json({ error: supaError.message }); if (supaError) {
return res.status(500).json({ error: supaError.message });
}
if (data.length === 0) {
return res.status(403).json({ error: "Unauthorized" });
}
} }
if (data.length === 0) {
return res.status(403).json({ error: "Unauthorized" });
}
const jobState = await job.getState(); const jobState = await job.getState();
const { partialDocs } = await job.progress(); const { partialDocs } = await job.progress();