v1.5.4

changelog.md

@@ -1,5 +1,22 @@
 # Changelog
 
+## 2026-01-20 - 1.5.4 - fix(driveragent)
+prevent duplicate thinking/output markers during token streaming and mark transitions
+
+- Add isInThinkingMode flag to track thinking vs output state
+- Emit "\n[THINKING] " only when transitioning into thinking mode (avoids repeated thinking markers)
+- Emit "\n[OUTPUT] " when transitioning out of thinking mode to mark content output
+- Reset thinking state after response completes to ensure correct markers for subsequent responses
+- Applied the same streaming marker logic to both response handling paths
+
+## 2026-01-20 - 1.5.3 - fix(driveragent)
+prefix thinking tokens with [THINKING] when forwarding streaming chunks to onToken
+
+- Wraps chunk.thinking with '[THINKING] ' before calling onToken to mark thinking tokens
+- Forwards chunk.content unchanged
+- Change applied in ts/smartagent.classes.driveragent.ts for both initial and subsequent assistant streaming responses
+- No API signature changes; only the token payloads sent to onToken are altered
+
 ## 2026-01-20 - 1.5.2 - fix()
 no changes in this diff; nothing to release
 

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@push.rocks/smartagent",
-  "version": "1.5.2",
+  "version": "1.5.4",
   "private": false,
   "description": "an agentic framework built on top of @push.rocks/smartai",
   "main": "dist_ts/index.js",

ts/00_commitinfo_data.ts

@@ -3,6 +3,6 @@
  */
 export const commitinfo = {
   name: '@push.rocks/smartagent',
-  version: '1.5.2',
+  version: '1.5.4',
   description: 'an agentic framework built on top of @push.rocks/smartai'
 }

ts/smartagent.classes.driveragent.ts

@@ -25,6 +25,7 @@ export class DriverAgent {
   private messageHistory: plugins.smartai.ChatMessage[] = [];
   private tools: Map<string, BaseToolWrapper> = new Map();
   private onToken?: (token: string) => void;
+  private isInThinkingMode = false;  // Track thinking/content state for markers
 
   constructor(
     provider: plugins.smartai.MultiModalModel,
@@ -491,13 +492,30 @@ Your complete output here
         images: images,
         tools: tools.length > 0 ? tools : undefined,
       },
-      // Pass onToken callback through onChunk for streaming
+      // Pass onToken callback through onChunk for streaming with thinking markers
       this.onToken ? (chunk: any) => {
-        if (chunk.thinking && this.onToken) this.onToken(chunk.thinking);
-        if (chunk.content && this.onToken) this.onToken(chunk.content);
+        if (chunk.thinking && this.onToken) {
+          // Add marker only when transitioning INTO thinking mode
+          if (!this.isInThinkingMode) {
+            this.onToken('\n[THINKING] ');
+            this.isInThinkingMode = true;
+          }
+          this.onToken(chunk.thinking);
+        }
+        if (chunk.content && this.onToken) {
+          // Add marker when transitioning OUT of thinking mode
+          if (this.isInThinkingMode) {
+            this.onToken('\n[OUTPUT] ');
+            this.isInThinkingMode = false;
+          }
+          this.onToken(chunk.content);
+        }
       } : undefined
     );
 
+    // Reset thinking state after response completes
+    this.isInThinkingMode = false;
+
     // Add assistant response to history
     const historyMessage: plugins.smartai.ChatMessage = {
       role: 'assistant',
@@ -574,13 +592,30 @@ Your complete output here
         messageHistory: historyForChat,
         tools: tools.length > 0 ? tools : undefined,
       },
-      // Pass onToken callback through onChunk for streaming
+      // Pass onToken callback through onChunk for streaming with thinking markers
       this.onToken ? (chunk: any) => {
-        if (chunk.thinking && this.onToken) this.onToken(chunk.thinking);
-        if (chunk.content && this.onToken) this.onToken(chunk.content);
+        if (chunk.thinking && this.onToken) {
+          // Add marker only when transitioning INTO thinking mode
+          if (!this.isInThinkingMode) {
+            this.onToken('\n[THINKING] ');
+            this.isInThinkingMode = true;
+          }
+          this.onToken(chunk.thinking);
+        }
+        if (chunk.content && this.onToken) {
+          // Add marker when transitioning OUT of thinking mode
+          if (this.isInThinkingMode) {
+            this.onToken('\n[OUTPUT] ');
+            this.isInThinkingMode = false;
+          }
+          this.onToken(chunk.content);
+        }
       } : undefined
     );
 
+    // Reset thinking state after response completes
+    this.isInThinkingMode = false;
+
     // Add assistant response to history
     this.messageHistory.push({
       role: 'assistant',