chore: Bump version to 6.0.9

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude <noreply@anthropic.com>

.claude-plugin/marketplace.json

@@ -10,7 +10,7 @@
   "plugins": [
     {
       "name": "claude-mem",
-      "version": "6.0.8",
+      "version": "6.0.9",
       "source": "./plugin",
       "description": "Persistent memory system for Claude Code - context compression across sessions"
     }

CHANGELOG.md

@@ -4,6 +4,29 @@ All notable changes to this project will be documented in this file.
 
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/).
 
+## [6.0.8] - 2025-11-17
+
+## Critical Fix
+
+This patch release fixes a critical bug where the PM2 worker process would start from the wrong directory (development folder instead of marketplace folder), causing the plugin to malfunction when installed via the marketplace.
+
+### What's Fixed
+
+- **Worker Startup Path Resolution** (`src/shared/worker-utils.ts:61`)  
+  Added `cwd: pluginRoot` option to `execSync` when starting PM2
+  
+  This ensures the worker always starts from the correct marketplace directory (`~/.claude/plugins/marketplaces/thedotmack/`), regardless of where the hook is invoked from.
+
+### Impact
+
+Users will no longer experience issues with the worker starting from the wrong location. The plugin now works correctly when installed via marketplace without manual intervention.
+
+### Verification
+
+Run `pm2 info claude-mem-worker` to verify:
+- **exec cwd** should be: `/Users/[username]/.claude/plugins/marketplaces/thedotmack`
+- **script path** should be: `/Users/[username]/.claude/plugins/marketplaces/thedotmack/plugin/scripts/worker-service.cjs`
+
 ## [6.0.7] - 2025-11-17
 
 ## Critical Hotfix: Database Migration Issue (#121)

CLAUDE.md

@@ -6,7 +6,7 @@ Claude-mem is a Claude Code plugin providing persistent memory across sessions.
 
 **Your Role**: You are working on the plugin itself. When users interact with Claude Code with this plugin installed, your observations get captured and become their persistent memory.
 
-**Current Version**: 6.0.8
+**Current Version**: 6.0.9
 
 ## IMPORTANT: Skills Are Auto-Invoked
 

package.json

@@ -1,6 +1,6 @@
 {
   "name": "claude-mem",
-  "version": "6.0.8",
+  "version": "6.0.9",
   "description": "Memory compression system for Claude Code - persist context across sessions",
   "keywords": [
     "claude",

plugin/.claude-plugin/plugin.json

@@ -1,6 +1,6 @@
 {
   "name": "claude-mem",
-  "version": "6.0.8",
+  "version": "6.0.9",
   "description": "Persistent memory system for Claude Code - seamlessly preserve context across sessions",
   "author": {
     "name": "Alex Newman"

plugin/ui/viewer.html

@@ -376,6 +376,36 @@
       animation: spin 1.5s linear infinite;
     }
 
+    .queue-bubble {
+      position: absolute;
+      top: -8px;
+      right: -8px;
+      background: var(--color-accent-primary);
+      color: var(--color-text-button);
+      font-size: 10px;
+      font-weight: 600;
+      font-family: 'Monaspace Radon', monospace;
+      min-width: 18px;
+      height: 18px;
+      border-radius: 9px;
+      display: flex;
+      align-items: center;
+      justify-content: center;
+      padding: 0 5px;
+      box-shadow: 0 2px 4px rgba(0, 0, 0, 0.2);
+      animation: pulse 2s ease-in-out infinite;
+      z-index: 10;
+    }
+
+    @keyframes pulse {
+      0%, 100% {
+        transform: scale(1);
+      }
+      50% {
+        transform: scale(1.1);
+      }
+    }
+
     .logo-text {
       font-family: 'Monaspace Radon', monospace;
       font-weight: 100;

src/services/worker-service.ts

@@ -322,9 +322,11 @@ export class WorkerService {
 
     // Send initial processing status (based on queue depth + active generators)
     const isProcessing = this.sessionManager.isAnySessionProcessing();
+    const queueDepth = this.sessionManager.getTotalActiveWork(); // Includes queued + actively processing
     this.sseBroadcaster.broadcast({
       type: 'processing_status',
-      isProcessing
+      isProcessing,
+      queueDepth
     });
   }
 
@@ -806,11 +808,12 @@ export class WorkerService {
   }
 
   /**
-   * Get processing status (for viewer UI spinner)
+   * Get processing status (for viewer UI spinner and queue indicator)
    */
   private handleGetProcessingStatus(req: Request, res: Response): void {
     const isProcessing = this.sessionManager.isAnySessionProcessing();
-    res.json({ isProcessing });
+    const queueDepth = this.sessionManager.getTotalActiveWork(); // Includes queued + actively processing
+    res.json({ isProcessing, queueDepth });
   }
 
   // ============================================================================
@@ -823,7 +826,7 @@ export class WorkerService {
    */
   broadcastProcessingStatus(): void {
     const isProcessing = this.sessionManager.isAnySessionProcessing();
-    const queueDepth = this.sessionManager.getTotalQueueDepth();
+    const queueDepth = this.sessionManager.getTotalActiveWork(); // Includes queued + actively processing
     const activeSessions = this.sessionManager.getActiveSessionCount();
 
     logger.info('WORKER', 'Broadcasting processing status', {
@@ -834,7 +837,8 @@ export class WorkerService {
 
     this.sseBroadcaster.broadcast({
       type: 'processing_status',
-      isProcessing
+      isProcessing,
+      queueDepth
     });
   }
 

src/services/worker/SessionManager.ts

@@ -256,6 +256,23 @@ export class SessionManager {
     return total;
   }
 
+  /**
+   * Get total active work (queued + currently processing)
+   * Counts both pending messages and items actively being processed by SDK agents
+   */
+  getTotalActiveWork(): number {
+    let total = 0;
+    for (const session of this.sessions.values()) {
+      // Count queued messages
+      total += session.pendingMessages.length;
+      // Count currently processing item (1 per active generator)
+      if (session.generatorPromise !== null) {
+        total += 1;
+      }
+    }
+    return total;
+  }
+
   /**
    * Check if any session is actively processing (has pending messages OR active generator)
    * Used for activity indicator to prevent spinner from stopping while SDK is processing

src/ui/viewer-template.html

@@ -376,6 +376,36 @@
       animation: spin 1.5s linear infinite;
     }
 
+    .queue-bubble {
+      position: absolute;
+      top: -8px;
+      right: -8px;
+      background: var(--color-accent-primary);
+      color: var(--color-text-button);
+      font-size: 10px;
+      font-weight: 600;
+      font-family: 'Monaspace Radon', monospace;
+      min-width: 18px;
+      height: 18px;
+      border-radius: 9px;
+      display: flex;
+      align-items: center;
+      justify-content: center;
+      padding: 0 5px;
+      box-shadow: 0 2px 4px rgba(0, 0, 0, 0.2);
+      animation: pulse 2s ease-in-out infinite;
+      z-index: 10;
+    }
+
+    @keyframes pulse {
+      0%, 100% {
+        transform: scale(1);
+      }
+      50% {
+        transform: scale(1.1);
+      }
+    }
+
     .logo-text {
       font-family: 'Monaspace Radon', monospace;
       font-weight: 100;

src/ui/viewer/App.tsx

@@ -17,7 +17,7 @@ export function App() {
   const [paginatedSummaries, setPaginatedSummaries] = useState<Summary[]>([]);
   const [paginatedPrompts, setPaginatedPrompts] = useState<UserPrompt[]>([]);
 
-  const { observations, summaries, prompts, projects, isProcessing, isConnected } = useSSE();
+  const { observations, summaries, prompts, projects, isProcessing, queueDepth, isConnected } = useSSE();
   const { settings, saveSettings, isSaving, saveStatus } = useSettings();
   const { stats, refreshStats } = useStats();
   const { preference, resolvedTheme, setThemePreference } = useTheme();
@@ -96,6 +96,7 @@ export function App() {
           onSettingsToggle={toggleSidebar}
           sidebarOpen={sidebarOpen}
           isProcessing={isProcessing}
+          queueDepth={queueDepth}
           themePreference={preference}
           onThemeChange={setThemePreference}
         />

src/ui/viewer/components/Header.tsx

@@ -10,6 +10,7 @@ interface HeaderProps {
   onSettingsToggle: () => void;
   sidebarOpen: boolean;
   isProcessing: boolean;
+  queueDepth: number;
   themePreference: ThemePreference;
   onThemeChange: (theme: ThemePreference) => void;
 }
@@ -22,13 +23,21 @@ export function Header({
   onSettingsToggle,
   sidebarOpen,
   isProcessing,
+  queueDepth,
   themePreference,
   onThemeChange
 }: HeaderProps) {
   return (
     <div className="header">
       <h1>
-        <img src="claude-mem-logomark.webp" alt="" className={`logomark ${isProcessing ? 'spinning' : ''}`} />
+        <div style={{ position: 'relative', display: 'inline-block' }}>
+          <img src="claude-mem-logomark.webp" alt="" className={`logomark ${isProcessing ? 'spinning' : ''}`} />
+          {queueDepth > 0 && (
+            <div className="queue-bubble">
+              {queueDepth}
+            </div>
+          )}
+        </div>
         <span className="logo-text">claude-mem</span>
       </h1>
       <div className="status">

src/ui/viewer/hooks/useSSE.ts

@@ -10,6 +10,7 @@ export function useSSE() {
   const [projects, setProjects] = useState<string[]>([]);
   const [isConnected, setIsConnected] = useState(false);
   const [isProcessing, setIsProcessing] = useState(false);
+  const [queueDepth, setQueueDepth] = useState(0);
   const eventSourceRef = useRef<EventSource | null>(null);
   const reconnectTimeoutRef = useRef<NodeJS.Timeout>();
 
@@ -83,8 +84,9 @@ export function useSSE() {
 
             case 'processing_status':
               if (typeof data.isProcessing === 'boolean') {
-                console.log('[SSE] Processing status:', data.isProcessing);
+                console.log('[SSE] Processing status:', data.isProcessing, 'Queue depth:', data.queueDepth);
                 setIsProcessing(data.isProcessing);
+                setQueueDepth(data.queueDepth || 0);
               }
               break;
           }
@@ -107,5 +109,5 @@ export function useSSE() {
     };
   }, []);
 
-  return { observations, summaries, prompts, projects, isProcessing, isConnected };
+  return { observations, summaries, prompts, projects, isProcessing, queueDepth, isConnected };
 }