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

Nick:

Browse Source
This commit is contained in:
Nicolas 2025-02-20 10:50:22 -03:00
parent acf1e60608
commit 7db2d25efa
3 changed files with 25 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/api/src/lib/deep-research/deep-research-service.ts
View File

@ -94,7 +94,7 @@ export async function performDeepResearch(options: DeepResearchServiceOptions) {
teamId: options.teamId,
plan: options.plan as PlanType,
origin: "deep-research",
timeout: 15000,
timeout: 10000,
scrapeOptions: {
formats: ["markdown"],
onlyMainContent: true,

2
apps/js-sdk/firecrawl/package.json
View File

@ -1,6 +1,6 @@
{
"name": "@mendable/firecrawl-js",
"version": "1.18.2",
"version": "1.18.3-beta.1",
"description": "JavaScript SDK for Firecrawl API",
"main": "dist/index.js",
"types": "dist/index.d.ts",

27
apps/js-sdk/firecrawl/src/index.ts
View File

@ -1391,10 +1391,22 @@ export default class FirecrawlApp {
/**
* Initiates a deep research operation on a given topic and polls until completion.
* @param topic - The topic to research.
* @param params - Parameters for the deep research operation.
* @param onActivity - Optional callback to receive activity updates in real-time.
* @returns The final research results.
*/
async __deepResearch(topic: string, params: DeepResearchParams): Promise<DeepResearchStatusResponse | ErrorResponse> {
async __deepResearch(
topic: string,
params: DeepResearchParams,
onActivity?: (activity: {
type: string;
status: string;
message: string;
timestamp: string;
depth: number;
}) => void
): Promise<DeepResearchStatusResponse | ErrorResponse> {
try {
const response = await this.__asyncDeepResearch(topic, params);
@ -1408,16 +1420,24 @@ export default class FirecrawlApp {
const jobId = response.id;
let researchStatus;
let lastActivityCount = 0;
while (true) {
// console.log("Checking research status...");
researchStatus = await this.__checkDeepResearchStatus(jobId);
// console.log("Research status:", researchStatus);
if ('error' in researchStatus && !researchStatus.success) {
return researchStatus;
}
// Stream new activities through the callback if provided
if (onActivity && researchStatus.activities) {
const newActivities = researchStatus.activities.slice(lastActivityCount);
for (const activity of newActivities) {
onActivity(activity);
}
lastActivityCount = researchStatus.activities.length;
}
if (researchStatus.status === "completed") {
return researchStatus;
}
@ -1435,7 +1455,6 @@ export default class FirecrawlApp {
await new Promise(resolve => setTimeout(resolve, 2000));
}
// console.log("Research status finished:", researchStatus);
return { success: false, error: "Research job terminated unexpectedly" };
} catch (error: any) {