Show local generation progress and bound stage output length

research.js

@@ -86,9 +86,15 @@ window.PocketResearch = (() => {
         let lastError;
         for(let attempt=0;attempt<2;attempt++) {
           try {
-            const result=await engine.chat.completions.create({messages:[{role:'system',content:system},{role:'user',content:JSON.stringify({question:input.question,sources:contextSources,prior_stage_outputs:prior,correction:attempt?`Previous output was invalid: ${lastError?.message || String(lastError)}. Follow the schema and exact prior IDs.`:undefined})}],temperature:0.2,max_tokens:1100});
-            if(result.choices[0].finish_reason==='length') throw new Error('Model output exceeded its token limit.');
-            const output=JSON.parse(result.choices[0].message.content.trim().replace(/^```(?:json)?\s*/, '').replace(/\s*```$/, ''));
+            const stream=await engine.chat.completions.create({messages:[{role:'system',content:system},{role:'user',content:JSON.stringify({question:input.question,sources:contextSources,prior_stage_outputs:prior,correction:attempt?`Previous output was invalid: ${lastError?.message || String(lastError)}. Follow the schema and exact prior IDs.`:undefined})}],temperature:0.2,max_tokens:stage==='framer'?350:stage==='scout'?450:850,stream:true});
+            let content='',finishReason=null,chunks=0;
+            for await(const chunk of stream) {
+              content+=chunk.choices[0]?.delta.content || '';
+              finishReason=chunk.choices[0]?.finish_reason || finishReason;
+              if(++chunks%25===0) progress(`Local AI: ${name} (${agents.length+1}/6), generating… ${chunks} chunks received`);
+            }
+            if(finishReason==='length') throw new Error('Model output exceeded its token limit.');
+            const output=JSON.parse(content.trim().replace(/^```(?:json)?\s*/, '').replace(/\s*```$/, ''));
             validate(output,schemas[stage],sourceIDs);validateLinks(stage,output,prior);
             if(stage==='gap') output.gaps.forEach(gap=>{gap.evidence_status=contextSources.some(s=>s.abstract)?'AI interpretation; source support requires review':'No excerpts in model context; speculative search target';if(!contextSources.some(s=>s.abstract))gap.confidence='low';});
             if(stage==='architect') output.hypotheses.forEach(h=>h.evidence_status='Speculative proposal; not a validated finding');