Unified Positronic Content Architecture - Cache-first State Management

src/debug/jtag/browser-index.ts

@@ -26,49 +26,37 @@ import { WidgetDiscovery } from './system/core/browser/utils/WidgetIntrospection
 export const jtag = {
   // Widget debugging utilities
   widgets: WidgetUtils,
-  
+
   // Universal client interface - always returns connection result with client property
   async connect(): Promise<ReturnType<typeof JTAGClientBrowser.connectLocal>> {
-    // Reduce log spam
-    // console.debug('🔌 Browser: Connecting via JTAGClientBrowser (local connection)');
-
-    // Connect client FIRST
+    // Connect client FIRST - widgets need it for resource loading
     const connectionResult = await JTAGClientBrowser.connectLocal();
     const client = connectionResult.client;
 
     // Set up global window.jtag for widgets and tests
     (globalThis as any).jtag = client;
 
-    // Expose WidgetDiscovery for universal selector support (used by GlobalUtils.safeQuerySelector)
+    // Expose WidgetDiscovery for universal selector support
     (globalThis as any).WidgetDiscovery = WidgetDiscovery;
 
     // Register client in static registry for sharedInstance access
     JTAGClient.registerClient('default', client);
 
-    // NOW register widgets - after client is available for sharedInstance
-    // console.debug(`🎭 Registering ${BROWSER_WIDGETS.length} widgets...`);
+    // NOW register widgets - after client is available for resource loading
     BROWSER_WIDGETS.forEach(widget => {
       if (!customElements.get(widget.tagName)) {
         try {
           customElements.define(widget.tagName, widget.widgetClass);
-          // console.debug(`✅ Registered widget: ${widget.tagName} (${widget.className})`);
         } catch (error) {
           console.warn(`⚠️ Failed to register widget ${widget.tagName}: ${error}`);
-          console.warn(`⚠️ This usually means the constructor has already been used with this registry`);
-          console.warn(`⚠️ Skipping registration for ${widget.tagName}`);
         }
-      } else {
-        console.warn(`⚠️ Widget ${widget.tagName} already registered, skipping`);
       }
     });
 
-    // Enhance client with organized services - no globals needed
+    // Enhance client with organized services
     const services = createJTAGClientServices(client);
     Object.assign(client, services);
 
-
-
-
     return { ...connectionResult, client };
   },
 
@@ -81,4 +69,8 @@ export const jtag = {
 // Direct export for advanced usage
 export { JTAGSystemBrowser };
 export * from './system/core/types/JTAGTypes';
-export * from './commands/interface/screenshot/shared/browser-utils/BrowserElementUtils';
+export * from './commands/interface/screenshot/shared/browser-utils/BrowserElementUtils';
+
+// Set jtag on globalThis immediately for non-module scripts
+// This allows inline scripts to call jtag.connect() without waiting for imports
+(globalThis as any).jtag = jtag;

src/debug/jtag/browser/generated.ts

@@ -1,7 +1,7 @@
 /**
  * Browser Structure Registry - Auto-generated
  *
- * Contains 11 daemons and 139 commands and 2 adapters and 26 widgets.
+ * Contains 11 daemons and 139 commands and 2 adapters and 25 widgets.
  * Generated by scripts/generate-structure.ts - DO NOT EDIT MANUALLY
  */
 
@@ -167,7 +167,6 @@ import { WebSocketTransportClientBrowser } from './../system/transports/websocke
 import { ChatWidget } from './../widgets/chat/chat-widget/ChatWidget';
 import { RoomListWidget } from './../widgets/chat/room-list/RoomListWidget';
 import { UserListWidget } from './../widgets/chat/user-list/UserListWidget';
-import { CognitionHistogramWidget } from './../widgets/cognition-histogram/CognitionHistogramWidget';
 import { ContentTabsWidget } from './../widgets/content-tabs/ContentTabsWidget';
 import { ContinuumEmoterWidget } from './../widgets/continuum-emoter/ContinuumEmoterWidget';
 import { ContinuumMetricsWidget } from './../widgets/continuum-metrics/ContinuumMetricsWidget';
@@ -994,12 +993,6 @@ export const BROWSER_WIDGETS: WidgetEntry[] = [
     widgetClass: UserListWidget,
     tagName: 'UserList'.replace(/([A-Z])/g, (match, p1, offset) => offset > 0 ? '-' + p1.toLowerCase() : p1.toLowerCase()) + '-widget'
   },
-{
-    name: 'CognitionHistogram',
-    className: 'CognitionHistogramWidget',
-    widgetClass: CognitionHistogramWidget,
-    tagName: 'CognitionHistogram'.replace(/([A-Z])/g, (match, p1, offset) => offset > 0 ? '-' + p1.toLowerCase() : p1.toLowerCase()) + '-widget'
-  },
 {
     name: 'ContentTabs',
     className: 'ContentTabsWidget',

src/debug/jtag/cli.ts

@@ -21,7 +21,7 @@ import * as path from 'path';
 
 // Check for verbose flag EARLY to control module initialization logging
 if (process.argv.includes('--verbose')) {
-  process.env.JTAG_VERBOSE = 'true';
+  process.env.JTAG_VERBOSE = '1';
 }
 
 // CRITICAL: Initialize SecretManager to load config.env into process.env SYNCHRONOUSLY
@@ -269,7 +269,7 @@ async function main() {
 
     // Set environment variable for modules to check verbose mode
     if (behavior.logLevel === 'verbose') {
-      process.env.JTAG_VERBOSE = 'true';
+      process.env.JTAG_VERBOSE = '1';
     }
 
     // Suppress ALL output unless verbose mode

src/debug/jtag/commands/ai/adapter/test/server/AdapterTestServerCommand.ts

@@ -74,7 +74,7 @@ export class AdapterTestServerCommand extends CommandBase<AdapterTestParams, Asy
     };
 
     // Save to database using data/create command
-    const createResult = await Commands.execute<DataCreateParams<TestExecutionEntity>, DataCreateResult>(DATA_COMMANDS.CREATE, {
+    const createResult = await Commands.execute<DataCreateParams, DataCreateResult>(DATA_COMMANDS.CREATE, {
       collection: TestExecutionEntity.collection,
       data: execution,
       id: testId,
@@ -160,7 +160,7 @@ export class AdapterTestServerCommand extends CommandBase<AdapterTestParams, Asy
    * Helper to update test status in database
    */
   private async updateTestStatus(testId: string, updates: Partial<TestExecutionEntity>): Promise<void> {
-    await Commands.execute<DataUpdateParams<TestExecutionEntity>, CommandResult>(DATA_COMMANDS.UPDATE, {
+    await Commands.execute<DataUpdateParams, CommandResult>(DATA_COMMANDS.UPDATE, {
       collection: TestExecutionEntity.collection,
       id: testId,
       data: {

src/debug/jtag/commands/ai/cost/server/AICostServerCommand.ts

@@ -41,7 +41,7 @@ export class AICostServerCommand extends AICostCommand {
       }
 
       // Query AIGenerationEntity from database using data/list - let SQL do the filtering
-      const listParams = createDataListParams<AIGenerationEntity>(
+      const listParams = createDataListParams(
         params.context,
         params.sessionId,
         {
@@ -52,7 +52,7 @@ export class AICostServerCommand extends AICostCommand {
         }
       );
 
-      const listResult = await Commands.execute<DataListParams<AIGenerationEntity>, DataListResult<AIGenerationEntity>>(
+      const listResult = await Commands.execute<DataListParams, DataListResult<AIGenerationEntity>>(
         DATA_COMMANDS.LIST,
         listParams
       );

src/debug/jtag/commands/ai/dataset/create/server/DatasetCreateServerCommand.ts

@@ -58,7 +58,7 @@ export class DatasetCreateServerCommand {
     };
 
     // Save to database
-    const createResult = await Commands.execute<DataCreateParams<DatasetExecutionEntity>, DataCreateResultType>(DATA_COMMANDS.CREATE, {
+    const createResult = await Commands.execute<DataCreateParams, DataCreateResultType>(DATA_COMMANDS.CREATE, {
       collection: DatasetExecutionEntity.collection,
       data: execution,
       id: jobId,
@@ -193,7 +193,7 @@ export class DatasetCreateServerCommand {
    * Update job status in database
    */
   private async updateJobStatus(jobId: string, updates: Partial<DatasetExecutionEntity>): Promise<void> {
-    await Commands.execute<DataUpdateParams<DatasetExecutionEntity>, any>(DATA_COMMANDS.UPDATE, {
+    await Commands.execute<DataUpdateParams, any>(DATA_COMMANDS.UPDATE, {
       collection: DatasetExecutionEntity.collection,
       id: jobId,
       data: updates,

src/debug/jtag/commands/ai/detect-semantic-loop/server/AiDetectSemanticLoopServerCommand.ts

@@ -172,7 +172,7 @@ export class AiDetectSemanticLoopServerCommand extends CommandBase<AiDetectSeman
 
     let recentMessages: RawChatMessage[];
     try {
-      const result = await Commands.execute<DataListParams<BaseEntity>, DataListResult<BaseEntity>>('data/list', {
+      const result = await Commands.execute<DataListParams, DataListResult<BaseEntity>>('data/list', {
         collection: 'chat_messages',
         filter,
         limit: lookbackCount,

src/debug/jtag/commands/ai/report/decisions/server/DecisionReportServerCommand.ts

@@ -63,7 +63,7 @@ export class DecisionReportServerCommand extends CommandBase<DecisionReportParam
     console.log(`🔍 SERVER: Querying decisions with filter:`, filter);
 
     // Execute data/list command
-    const listResult = await Commands.execute<DataListParams<CoordinationDecisionEntity>, DataListResult<CoordinationDecisionEntity>>(
+    const listResult = await Commands.execute<DataListParams, DataListResult<CoordinationDecisionEntity>>(
       DATA_COMMANDS.LIST,
       {
         collection: COLLECTIONS.COORDINATION_DECISIONS,

src/debug/jtag/commands/ai/should-respond-fast/browser/ShouldRespondFastBrowserCommand.ts

@@ -29,13 +29,15 @@ export class ShouldRespondFastBrowserCommand extends ShouldRespondFastCommand {
         conversationContext: 0,
         isQuestion: 0,
         unansweredQuestion: 0,
-        roomActivity: 0
+        roomActivity: 0,
+        humanMessage: 0
       },
       signals: {
         wasMentioned: false,
         matchedKeywords: [],
         isQuestion: false,
-        recentlyActive: false
+        recentlyActive: false,
+        isHumanMessage: false
       },
       reasoning: 'Command not available in browser'
     };

src/debug/jtag/commands/ai/should-respond-fast/server/ShouldRespondFastServerCommand.ts

@@ -95,13 +95,15 @@ export class ShouldRespondFastServerCommand extends ShouldRespondFastCommand {
           conversationContext: 0,
           isQuestion: 0,
           unansweredQuestion: 0,
-          roomActivity: 0
+          roomActivity: 0,
+          humanMessage: 0
         },
         signals: {
           wasMentioned: false,
           matchedKeywords: [],
           isQuestion: false,
-          recentlyActive: false
+          recentlyActive: false,
+          isHumanMessage: false
         },
         reasoning: 'Error occurred during evaluation'
       };
@@ -149,14 +151,16 @@ export class ShouldRespondFastServerCommand extends ShouldRespondFastCommand {
       conversationContext: 0,
       isQuestion: 0,
       unansweredQuestion: 0,
-      roomActivity: 0
+      roomActivity: 0,
+      humanMessage: 0
     };
 
     const signals = {
       wasMentioned: false,
       matchedKeywords: [] as string[],
       isQuestion: false,
-      recentlyActive: false
+      recentlyActive: false,
+      isHumanMessage: false
     };
 
     // 1. Direct mention detection
@@ -209,14 +213,25 @@ export class ShouldRespondFastServerCommand extends ShouldRespondFastCommand {
       console.log(`📈 High room activity: ${roomActivity} messages in 5min`);
     }
 
+    // 6. Human message detection - humans deserve responses!
+    // senderType passed from caller OR detected from senderId lookup
+    const isHumanMessage = params.senderType === 'human' ||
+      (!params.senderType && await this.isHumanSender(params.senderId));
+    if (isHumanMessage) {
+      scoreBreakdown.humanMessage = config.weights.humanMessage;
+      signals.isHumanMessage = true;
+      console.log(`👤 Message is from HUMAN - priority boost!`);
+    }
+
     // Calculate total score
     const score =
       scoreBreakdown.directMention +
       scoreBreakdown.domainKeywords +
       scoreBreakdown.conversationContext +
       scoreBreakdown.isQuestion +
       scoreBreakdown.unansweredQuestion +
-      scoreBreakdown.roomActivity;
+      scoreBreakdown.roomActivity +
+      scoreBreakdown.humanMessage;
 
     return { score, scoreBreakdown, signals };
   }
@@ -316,6 +331,35 @@ export class ShouldRespondFastServerCommand extends ShouldRespondFastCommand {
     }
   }
 
+  /**
+   * Check if sender is a human (not AI persona, agent, or system)
+   */
+  private async isHumanSender(senderId: string): Promise<boolean> {
+    if (!senderId) return false;
+
+    try {
+      const result = await Commands.execute<DataListParams, DataListResult<any>>(DATA_COMMANDS.LIST, {
+        collection: 'users',
+        filter: { id: senderId },
+        limit: 1
+      });
+
+      if (result.success && result.items && result.items.length > 0) {
+        const user = result.items[0];
+        const userType = user.userType || user.type || '';
+        // Human types: 'human', 'owner', 'admin', 'user' (or empty - default is human)
+        const isHuman = ['human', 'owner', 'admin', 'user', ''].includes(userType.toLowerCase());
+        return isHuman;
+      }
+
+      // If can't find user, assume not human (safer for AI response filtering)
+      return false;
+    } catch (error) {
+      console.warn('⚠️ Failed to check sender type:', error);
+      return false;
+    }
+  }
+
   /**
    * Build result object
    */
@@ -341,13 +385,15 @@ export class ShouldRespondFastServerCommand extends ShouldRespondFastCommand {
         conversationContext: 0,
         isQuestion: 0,
         unansweredQuestion: 0,
-        roomActivity: 0
+        roomActivity: 0,
+        humanMessage: 0
       },
       signals: extra.signals ?? {
         wasMentioned: false,
         matchedKeywords: [],
         isQuestion: false,
-        recentlyActive: false
+        recentlyActive: false,
+        isHumanMessage: false
       },
       reasoning: extra.reasoning
     };

src/debug/jtag/commands/ai/should-respond-fast/shared/ShouldRespondFastTypes.ts

@@ -29,6 +29,9 @@ export interface ResponseScoringWeights {
 
   /** High activity in room recently (deprecated, default: 0) */
   readonly roomActivity: number;
+
+  /** Message from human (not AI) - humans should get responses (default: 25) */
+  readonly humanMessage: number;
 }
 
 /**
@@ -74,6 +77,7 @@ export interface ShouldRespondFastParams extends CommandParams {
   /** Sender information */
   readonly senderId: UUID;
   readonly senderName: string;
+  readonly senderType?: 'human' | 'persona' | 'agent' | 'system';
 
   /** Optional: Override default config */
   readonly config?: Partial<PersonaResponseConfig>;
@@ -100,6 +104,7 @@ export interface ShouldRespondFastResult extends CommandResult {
     isQuestion: number;
     unansweredQuestion: number;
     roomActivity: number;
+    humanMessage: number;
   };
 
   /** Detected signals */
@@ -108,6 +113,7 @@ export interface ShouldRespondFastResult extends CommandResult {
     matchedKeywords: string[];
     isQuestion: boolean;
     recentlyActive: boolean;
+    isHumanMessage: boolean;
   };
 
   /** Why this decision was made */
@@ -129,17 +135,19 @@ export const DEFAULT_SCORING_WEIGHTS: ResponseScoringWeights = {
   conversationContext: 20,  // Reduced from 30 - thread continuation
   isQuestion: 10,           // Reduced from 20 - question signal
   unansweredQuestion: 5,    // New: someone should answer, but who?
-  roomActivity: 0           // Disabled: was 5, caused noise
+  roomActivity: 0,          // Disabled: was 5, caused noise
+  humanMessage: 25          // NEW: Humans deserve responses! AI-to-AI can be lower priority
 };
 
 /**
  * Default response threshold
  *
  * With new weights:
  * - Direct mention: 100 → Always respond
+ * - Human question: 25 + 10 + 5 = 40 → Respond (humans deserve attention!)
  * - Domain + context: 25 + 20 = 45 → Respond (engaged expert)
  * - Domain + question: 25 + 10 = 35 → Maybe respond (borderline)
- * - Just question: 10 → Don't respond (let experts handle it)
+ * - AI question: 10 + 5 = 15 → Don't respond (let others handle AI chatter)
  * - Random message: 0 → Never respond
  */
 export const DEFAULT_RESPONSE_THRESHOLD = 35;

src/debug/jtag/commands/canvas/stroke/add/server/CanvasStrokeAddServerCommand.ts

@@ -127,7 +127,7 @@ export class CanvasStrokeAddServerCommand extends CommandBase<CanvasStrokeAddPar
   private async notifyCanvasRoom(stroke: CanvasStrokeEntity, params: CanvasStrokeAddParams): Promise<void> {
     try {
       // Find the canvas room
-      const roomResult = await Commands.execute<DataListParams<RoomEntity>, DataListResult<RoomEntity>>(
+      const roomResult = await Commands.execute<DataListParams, DataListResult<RoomEntity>>(
         DATA_COMMANDS.LIST,
         {
           collection: RoomEntity.collection,
@@ -169,7 +169,7 @@ export class CanvasStrokeAddServerCommand extends CommandBase<CanvasStrokeAddPar
       };
 
       // Store message
-      await Commands.execute<DataCreateParams<ChatMessageEntity>, DataCreateResult<ChatMessageEntity>>(
+      await Commands.execute<DataCreateParams, DataCreateResult<ChatMessageEntity>>(
         DATA_COMMANDS.CREATE,
         {
           collection: ChatMessageEntity.collection,