github/node-DeepResearch
1
0
Fork 0
mirror of https://github.com/jina-ai/node-DeepResearch.git synced 2026-03-22 07:29:35 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: streaming and query gen

Browse Source
This commit is contained in:
Han Xiao
2025-02-18 13:47:37 +08:00
parent 840913c898
commit acb05dbeee
2 changed files with 10 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/agent.ts
View File

@@ -35,7 +35,7 @@ function getSchema(allowReflect: boolean, allowRead: boolean, allowAnswer: boole
if (allowSearch) {
actions.push("search");
properties.searchQuery = z.string().max(30)
.describe("Required when action='search'. Must be a short, keyword-based query that BM25, tf-idf based search engines can understand. Existing queries must be avoided").optional();
.describe("Required when action='search'. Must be a short, keyword-based query that BM25, tf-idf based search engines can understand. Must in ${languageStyle}.").optional();
}
if (allowCoding) {

16
src/app.ts
View File

@@ -226,22 +226,22 @@ function calculateDelay(chunk: string, burstMode: boolean): number {
// Special handling for URLs
if (chunk.match(/^https?:\/\//)) {
return Math.random() * 50 + 100; // Slower typing for URLs
return Math.random() * 50 + 10; // Slower typing for URLs
}
// Special handling for CJK characters
if (/^[\u4e00-\u9fff\u3040-\u30ff\uac00-\ud7af]$/.test(chunk)) {
return Math.random() * 100 + 10; // Longer delay for individual CJK characters
return Math.random() * 50 + 10; // Longer delay for individual CJK characters
}
// Base delay calculation
let baseDelay;
if (burstMode) {
baseDelay = Math.random() * 30 + 20;
baseDelay = Math.random() * 30 + 10;
} else {
const effectiveLength = getEffectiveLength(chunk);
const perCharacterDelay = Math.max(10, 40 - effectiveLength * 2);
baseDelay = Math.random() * perCharacterDelay + perCharacterDelay;
baseDelay = Math.random() * perCharacterDelay + 10;
}
// Add variance based on chunk characteristics
@@ -250,14 +250,14 @@ function calculateDelay(chunk: string, burstMode: boolean): number {
}
if (/[^a-zA-Z\s]/.test(chunk)) {
baseDelay += Math.random() * 30 + 15;
baseDelay += Math.random() * 30 + 10;
}
// Add pauses for punctuation
if (/[.!?]$/.test(chunk)) {
baseDelay += Math.random() * 350 + 200;
baseDelay += Math.random() * 200 + 10;
} else if (/[,;:]$/.test(chunk)) {
baseDelay += Math.random() * 150 + 100;
baseDelay += Math.random() * 100 + 10;
}
return baseDelay;
@@ -550,6 +550,8 @@ app.post('/v1/chat/completions', (async (req: Request, res: Response) => {
if (step.think) {
const content = step.think;
await new Promise<void>(resolve => {
streamingState.currentlyStreaming = false;
streamingState.queue.push({
content,
resolve