proffesor-for-testing
diff --git a/‎.claude/helpers/statusline-v3.cjs‎
Lines changed: 96 additions & 27 deletions b/‎.claude/helpers/statusline-v3.cjs‎
Lines changed: 96 additions & 27 deletions
diff --git a/‎.claude/hooks/post-task-sync.sh‎
Lines changed: 111 additions & 0 deletions b/‎.claude/hooks/post-task-sync.sh‎
Lines changed: 111 additions & 0 deletions
diff --git a/‎.claude/mcp.json‎
Lines changed: 3 additions & 5 deletions b/‎.claude/mcp.json‎
Lines changed: 3 additions & 5 deletions
diff --git a/‎README.md‎
Lines changed: 6 additions & 3 deletions b/‎README.md‎
Lines changed: 6 additions & 3 deletions
diff --git a/‎package.json‎
Lines changed: 1 addition & 1 deletion b/‎package.json‎
Lines changed: 1 addition & 1 deletion
@@ -31,11 +31,18 @@ const CONFIG = {
   flashAttentionTarget: '2.49x-7.47x',
   intelligenceTargetExp: 1000, // 1000 experiences = 100%
 
-  // Paths
-  memoryDb: '.agentic-qe/memory.db',
+  // Paths (V3 database takes priority - actively used)
+  memoryDbPaths: [
+    'v3/.agentic-qe/memory.db',    // V3 primary location (new schema)
+    '.agentic-qe/memory.db',        // Root fallback (old schema)
+  ],
   cveCache: '.agentic-qe/.cve-cache',
   cveCacheAge: 3600, // 1 hour
-  learningConfig: '.agentic-qe/learning-config.json',
+  learningConfigPaths: [
+    'v3/.agentic-qe/learning-config.json',      // V3 config
+    '.agentic-qe/data/learning-config.json',    // Root data dir
+    '.agentic-qe/learning-config.json',         // Root fallback
+  ],
   coverageFile: 'coverage/coverage-summary.json',
 
   // Domain list
@@ -207,25 +214,77 @@ function getTestCounts(projectDir) {
 }
 
 function getLearningMetrics(projectDir) {
-  const dbPath = path.join(projectDir, CONFIG.memoryDb);
+  // Find active database (V3 takes priority)
+  let dbPath = null;
+  let isV3Schema = false;
+
+  for (const relPath of CONFIG.memoryDbPaths) {
+    const candidate = path.join(projectDir, relPath);
+    if (fileExists(candidate)) {
+      // Check which schema this database uses
+      const hasV3Tables = sqlite3Query(candidate,
+        "SELECT name FROM sqlite_master WHERE type='table' AND name='qe_patterns'", '') !== '';
+      const hasOldTables = sqlite3Query(candidate,
+        "SELECT name FROM sqlite_master WHERE type='table' AND name='patterns'", '') !== '';
+
+      if (hasV3Tables || hasOldTables) {
+        dbPath = candidate;
+        isV3Schema = hasV3Tables;
+        break;
+      }
+    }
+  }
+
+  if (!dbPath) {
+    return {
+      patterns: 0, synthesized: 0, totalPatterns: 0, experiences: 0,
+      transfers: 0, successRate: 0, intelligencePct: 0, mode: 'off',
+      dbSource: 'none'
+    };
+  }
+
+  let patterns = 0, synthesized = 0, experiences = 0, transfers = 0, successRate = 0;
+
+  if (isV3Schema) {
+    // V3 Schema: qe_patterns, qe_trajectories, sona_patterns
+    patterns = parseInt(sqlite3Query(dbPath, 'SELECT COUNT(*) FROM qe_patterns')) || 0;
+    synthesized = parseInt(sqlite3Query(dbPath, 'SELECT COUNT(*) FROM sona_patterns')) || 0;
+
+    // Experiences: trajectories + claude-flow imported sessions
+    const trajectories = parseInt(sqlite3Query(dbPath, 'SELECT COUNT(*) FROM qe_trajectories')) || 0;
+    const cfExperiences = parseInt(sqlite3Query(dbPath,
+      "SELECT COUNT(*) FROM kv_store WHERE key LIKE 'cf:%'")) || 0;
+    experiences = trajectories + cfExperiences;
+
+    // V3 uses rl_q_values for transfer learning
+    transfers = parseInt(sqlite3Query(dbPath, 'SELECT COUNT(*) FROM rl_q_values')) || 0;
 
-  // Direct sqlite3 queries for accuracy
-  const patterns = parseInt(sqlite3Query(dbPath, 'SELECT COUNT(*) FROM patterns')) || 0;
-  const synthesized = parseInt(sqlite3Query(dbPath, 'SELECT COUNT(*) FROM synthesized_patterns')) || 0;
-  const experiences = parseInt(sqlite3Query(dbPath, 'SELECT COUNT(*) FROM learning_experiences')) || 0;
-  const transfers = parseInt(sqlite3Query(dbPath, 'SELECT COUNT(*) FROM transfer_registry')) || 0;
-  const successRate = parseFloat(sqlite3Query(dbPath,
-    'SELECT ROUND(AVG(success_rate)*100) FROM patterns WHERE success_rate > 0', '0')) || 0;
+    // Success rate from sona_patterns (claude-flow imports have outcome_success)
+    successRate = parseFloat(sqlite3Query(dbPath,
+      'SELECT ROUND(AVG(outcome_success)*100) FROM sona_patterns WHERE outcome_success > 0', '0')) || 0;
+  } else {
+    // Old Schema: patterns, learning_experiences, synthesized_patterns
+    patterns = parseInt(sqlite3Query(dbPath, 'SELECT COUNT(*) FROM patterns')) || 0;
+    synthesized = parseInt(sqlite3Query(dbPath, 'SELECT COUNT(*) FROM synthesized_patterns')) || 0;
+    experiences = parseInt(sqlite3Query(dbPath, 'SELECT COUNT(*) FROM learning_experiences')) || 0;
+    transfers = parseInt(sqlite3Query(dbPath, 'SELECT COUNT(*) FROM transfer_registry')) || 0;
+    successRate = parseFloat(sqlite3Query(dbPath,
+      'SELECT ROUND(AVG(success_rate)*100) FROM patterns WHERE success_rate > 0', '0')) || 0;
+  }
 
   // Intelligence % based on experiences (target: 1000 = 100%)
-  const intelligencePct = Math.min(100, Math.floor((experiences / CONFIG.intelligenceTargetExp) * 100));
+  const totalLearningData = patterns + synthesized + experiences;
+  const intelligencePct = Math.min(100, Math.floor((totalLearningData / CONFIG.intelligenceTargetExp) * 100));
 
-  // Get learning mode from config
+  // Get learning mode from config (check multiple paths)
   let mode = 'off';
-  const configPath = path.join(projectDir, CONFIG.learningConfig);
-  const config = readJsonFile(configPath);
-  if (config.enabled && config.scheduler?.mode) {
-    mode = config.scheduler.mode;
+  for (const relPath of CONFIG.learningConfigPaths) {
+    const configPath = path.join(projectDir, relPath);
+    const config = readJsonFile(configPath);
+    if (config.enabled && config.scheduler?.mode) {
+      mode = config.scheduler.mode;
+      break;
+    }
   }
 
   return {
@@ -237,6 +296,7 @@ function getLearningMetrics(projectDir) {
     successRate,
     intelligencePct,
     mode,
+    dbSource: isV3Schema ? 'v3' : 'root',
   };
 }
 
@@ -375,16 +435,19 @@ function getArchitectureMetrics(projectDir) {
     }
   }
 
-  // AgentDB size
+  // AgentDB size - check both V3 and root databases
   let agentDbSize = '';
-  const dbPath = path.join(projectDir, CONFIG.memoryDb);
-  if (fileExists(dbPath)) {
-    try {
-      const stats = fs.statSync(dbPath);
-      const sizeKB = Math.floor(stats.size / 1024);
-      agentDbSize = sizeKB > 1024 ? `${Math.floor(sizeKB / 1024)}M` : `${sizeKB}K`;
-    } catch {
-      // Ignore
+  for (const relPath of CONFIG.memoryDbPaths) {
+    const dbPath = path.join(projectDir, relPath);
+    if (fileExists(dbPath)) {
+      try {
+        const stats = fs.statSync(dbPath);
+        const sizeKB = Math.floor(stats.size / 1024);
+        agentDbSize = sizeKB > 1024 ? `${Math.floor(sizeKB / 1024)}M` : `${sizeKB}K`;
+        break; // Use first found database
+      } catch {
+        // Ignore
+      }
     }
   }
 
@@ -474,11 +537,14 @@ function generateStatusline(data) {
                         data.learning.mode === 'scheduled' ? `${c.yellow}◐` : `${c.dim}○`;
   const transferIndicator = data.learning.transfers > 10 ? `${c.brightGreen}●` :
                             data.learning.transfers > 0 ? `${c.yellow}◐` : `${c.dim}○`;
+  const dbSourceIndicator = data.learning.dbSource === 'v3' ? `${c.brightCyan}v3` :
+                            data.learning.dbSource === 'root' ? `${c.yellow}root` : `${c.dim}none`;
 
   let line3 = `${c.brightPurple}🎓 Learning${c.reset}     ${c.cyan}Patterns${c.reset} ${c.white}${padLeft(data.learning.totalPatterns, 4)}${c.reset}`;
   line3 += `  ${c.dim}│${c.reset}  ${c.cyan}Exp${c.reset} ${c.white}${padLeft(data.learning.experiences, 4)}${c.reset}`;
   line3 += `  ${c.dim}│${c.reset}  ${c.cyan}Mode${c.reset} ${modeIndicator}${data.learning.mode}${c.reset}`;
   line3 += `  ${c.dim}│${c.reset}  ${c.cyan}Transfer${c.reset} ${transferIndicator}${data.learning.transfers}${c.reset}`;
+  line3 += `  ${c.dim}│${c.reset}  ${c.cyan}DB${c.reset} ${dbSourceIndicator}${c.reset}`;
   lines.push(line3);
 
   // Line 4: Architecture Status
@@ -508,7 +574,10 @@ function generateJSON(data) {
     user: data.user,
     domains: data.domains,
     agents: data.agents,
-    learning: data.learning,
+    learning: {
+      ...data.learning,
+      dbSource: data.learning.dbSource,
+    },
     security: data.cve,
     context: data.context,
     architecture: data.arch,
 
@@ -0,0 +1,111 @@
+#!/bin/bash
+#
+# Post-Task Sync Hook
+# Syncs Claude Flow memories to AQE V3 database after task completion
+#
+# This ensures all learning captured by Claude Code tasks
+# is persisted to AQE's database for cross-session learning.
+#
+# Install in settings.json:
+#   "hooks": {
+#     "post-task": {
+#       "command": "bash .claude/hooks/post-task-sync.sh"
+#     }
+#   }
+
+# Configuration
+PROJECT_ROOT="$(cd "$(dirname "${BASH_SOURCE[0]}")/../.." && pwd)"
+CLAUDE_FLOW_STORE="$PROJECT_ROOT/.claude-flow/memory/store.json"
+AQE_V3_DB="$PROJECT_ROOT/v3/.agentic-qe/memory.db"
+SYNC_LOG="$PROJECT_ROOT/.agentic-qe/sync.log"
+
+# Create log directory if needed
+mkdir -p "$(dirname "$SYNC_LOG")"
+
+log() {
+  echo "[$(date '+%Y-%m-%d %H:%M:%S')] $1" >> "$SYNC_LOG"
+}
+
+# Check if files exist
+if [[ ! -f "$CLAUDE_FLOW_STORE" ]]; then
+  log "SKIP: Claude Flow store not found"
+  exit 0
+fi
+
+if [[ ! -f "$AQE_V3_DB" ]]; then
+  log "SKIP: AQE V3 database not found"
+  exit 0
+fi
+
+# Get entry counts before sync
+CF_ENTRIES=$(cat "$CLAUDE_FLOW_STORE" 2>/dev/null | jq '.entries | length // (keys | length)' 2>/dev/null || echo "0")
+AQE_CF_ENTRIES=$(sqlite3 "$AQE_V3_DB" "SELECT COUNT(*) FROM kv_store WHERE key LIKE 'cf:%'" 2>/dev/null || echo "0")
+
+# Skip if already in sync
+if [[ "$CF_ENTRIES" == "$AQE_CF_ENTRIES" ]]; then
+  log "SKIP: Already in sync ($CF_ENTRIES entries)"
+  exit 0
+fi
+
+log "SYNC: Claude Flow has $CF_ENTRIES entries, AQE has $AQE_CF_ENTRIES synced"
+
+# Run sync via Node.js if available
+if command -v node &> /dev/null; then
+  # Try TypeScript sync first
+  if [[ -f "$PROJECT_ROOT/v3/dist/sync/claude-flow-bridge.js" ]]; then
+    node -e "
+      const { syncClaudeFlowToAQE } = require('$PROJECT_ROOT/v3/dist/sync/claude-flow-bridge.js');
+      syncClaudeFlowToAQE({ projectRoot: '$PROJECT_ROOT' })
+        .then(r => console.log('Synced:', r.entriesSynced))
+        .catch(e => console.error('Sync error:', e.message));
+    " 2>> "$SYNC_LOG"
+    log "DONE: Node.js sync completed"
+    exit 0
+  fi
+fi
+
+# Fallback: Direct SQLite sync
+log "FALLBACK: Using SQLite direct sync"
+
+# Read Claude Flow entries and insert into AQE
+node << 'EOFNODE'
+const fs = require('fs');
+const path = require('path');
+
+const projectRoot = process.env.PROJECT_ROOT || process.cwd();
+const claudeFlowPath = path.join(projectRoot, '.claude-flow', 'memory', 'store.json');
+const aqeDbPath = path.join(projectRoot, 'v3', '.agentic-qe', 'memory.db');
+
+try {
+  const store = JSON.parse(fs.readFileSync(claudeFlowPath, 'utf-8'));
+  const entries = store.entries || store;
+
+  const Database = require('better-sqlite3');
+  const db = new Database(aqeDbPath);
+
+  const insert = db.prepare(`
+    INSERT OR REPLACE INTO kv_store (key, namespace, value, created_at)
+    VALUES (?, ?, ?, ?)
+  `);
+
+  let count = 0;
+  for (const [key, value] of Object.entries(entries)) {
+    if (key.startsWith('_') || key === 'version') continue;
+    insert.run(
+      'cf:' + key,
+      'claude-flow',
+      JSON.stringify(value),
+      Date.now()
+    );
+    count++;
+  }
+
+  db.close();
+  console.log('Synced', count, 'entries');
+} catch (e) {
+  console.error('Sync failed:', e.message);
+  process.exit(1);
+}
+EOFNODE
+
+log "DONE: Fallback sync completed"
@@ -1,16 +1,14 @@
 {
   "mcpServers": {
     "agentic-qe-v3": {
-      "command": "npx",
+      "command": "node",
       "args": [
-        "tsx",
-        "/workspaces/agentic-qe/v3/src/mcp/entry.ts"
+        "/workspaces/agentic-qe/v3/dist/mcp/bundle.js"
       ],
       "cwd": "/workspaces/agentic-qe/v3",
       "env": {
         "NODE_ENV": "production",
-        "NODE_NO_WARNINGS": "1",
-        "AQE_V3_RELOAD": "2026-01-10-v2"
+        "NODE_NO_WARNINGS": "1"
       }
     },
     "agentic-qe": {
 
@@ -11,7 +11,7 @@
 
 **V3 (Main)** | [V2 Documentation](v2/docs/V2-README.md) | [Changelog](CHANGELOG.md) | [Contributors](CONTRIBUTORS.md) | [Issues](https://github.com/proffesor-for-testing/agentic-qe/issues) | [Discussions](https://github.com/proffesor-for-testing/agentic-qe/discussions)
 
-> **V3** brings Domain-Driven Design architecture, 12 bounded contexts, 51 specialized QE agents, TinyDancer intelligent model routing, ReasoningBank learning with Dream cycles, HNSW vector search, mathematical Coherence verification (v3.3.0), and deep integration with [Claude Flow](https://github.com/ruvnet/claude-flow) and [Agentic Flow](https://github.com/ruvnet/agentic-flow).
+> **V3** brings Domain-Driven Design architecture, 12 bounded contexts, 51 specialized QE agents, TinyDancer intelligent model routing, ReasoningBank learning with Dream cycles, HNSW vector search, mathematical Coherence verification, full MinCut/Consensus integration across all 12 domains, and deep integration with [Claude Flow](https://github.com/ruvnet/claude-flow) and [Agentic Flow](https://github.com/ruvnet/agentic-flow).
 
 🏗️ **DDD Architecture** | 🧠 **ReasoningBank + Dream Cycles** | 🎯 **TinyDancer Model Routing** | 🔍 **HNSW Vector Search** | 👑 **Queen Coordinator** | 📊 **O(log n) Coverage** | 🔗 **Claude Flow Integration** | 🎯 **12 Bounded Contexts** | 📚 **61 QE Skills** | 🧬 **Coherence Verification** 
 
@@ -240,16 +240,19 @@ aqe hooks model-stats
 
 ---
 
-### 🔐 Consensus & MinCut Coordination
+### 🔐 Consensus & MinCut Coordination (v3.3.3)
 
-V3 includes advanced coordination mechanisms for reliable multi-agent decisions:
+V3.3.3 achieves **full MinCut/Consensus integration across all 12 domains**:
 
 | Feature | Description |
 |---------|-------------|
 | **Byzantine Consensus** | Fault-tolerant voting for critical quality decisions |
 | **MinCut Topology** | Graph-based self-healing agent coordination |
 | **Multi-Model Voting** | Aggregate decisions from multiple model tiers |
 | **Claim Verification** | Cryptographic verification of agent work claims |
+| **12/12 Domain Integration** | All domains use `verifyFinding()` for consensus |
+| **Topology-Aware Routing** | Routes tasks avoiding weak network vertices |
+| **Self-Healing Triggers** | `shouldPauseOperations()` for automatic recovery |
 
 ```bash
 # View consensus status
 
@@ -1,6 +1,6 @@
 {
   "name": "agentic-qe",
-  "version": "3.3.2",
+  "version": "3.3.3",
   "description": "Agentic Quality Engineering V3 - Domain-Driven Design Architecture with 12 Bounded Contexts, O(log n) coverage analysis, ReasoningBank learning, 51 specialized QE agents, mathematical Coherence verification, deep Claude Flow integration",
   "main": "./v3/dist/index.js",
   "types": "./v3/dist/index.d.ts",
Original file line number	Diff line number	Diff line change
`@@ -1,6 +1,6 @@`
`1`	`1`	`{`
`2`	`2`	`"name": "agentic-qe",`
`3`		`- "version": "3.3.2",`
	`3`	`+ "version": "3.3.3",`
`4`	`4`	`"description": "Agentic Quality Engineering V3 - Domain-Driven Design Architecture with 12 Bounded Contexts, O(log n) coverage analysis, ReasoningBank learning, 51 specialized QE agents, mathematical Coherence verification, deep Claude Flow integration",`
`5`	`5`	`"main": "./v3/dist/index.js",`
`6`	`6`	`"types": "./v3/dist/index.d.ts",`