Experimental Windows support

Author: canova

src/profile-query-cli/README.md

@@ -9,7 +9,7 @@ A command-line interface for querying Firefox Profiler profiles with persistent
 - **Daemon process**: Long-running background process that loads a profile via `ProfileQuerier` and keeps it in memory
 - **Client process**: Short-lived process that sends commands to the daemon and prints results
 
-**IPC:** Unix domain sockets with line-delimited JSON messages
+**IPC:** Unix domain sockets (named pipes on Windows) with line-delimited JSON messages
 
 **Session storage:** `~/.pq/` (or `$PQ_SESSION_DIR` for development)
 
@@ -94,17 +94,19 @@ npm publish
 ```
 ~/.pq/
 ├── current                    # Symlink to current session socket
-├── <session-id>.sock          # Unix domain socket for IPC
+├── <session-id>.sock          # Unix domain socket for IPC (Unix only)
 ├── <session-id>.json          # Session metadata (PID, profile path, timestamps)
 └── <session-id>.log           # Daemon logs (kept for debugging)
 ```
 
+On Windows, IPC uses a named pipe (`\\.\pipe\pq-<session-id>`) instead of a `.sock` file.
+
 **Session metadata example:**
 
 ```json
 {
   "id": "abc123xyz",
-  "socketPath": "/Users/user/.pq/abc123xyz.sock",
+  "socketPath": "/Users/user/.pq/abc123xyz.sock", // or \\.\pipe\pq-abc123xyz on Windows
   "logPath": "/Users/user/.pq/abc123xyz.log",
   "pid": 12345,
   "profilePath": "/path/to/profile.json",
@@ -181,7 +183,7 @@ type ServerResponse =
 **Session validation (session.ts):**
 
 - Check PID is running (`process.kill(pid, 0)`)
-- Check socket file exists
+- Check socket file exists (Unix only — named pipes on Windows are not filesystem files)
 - Auto-cleanup stale sessions
 
 **Symlinks:**
@@ -194,7 +196,7 @@ type ServerResponse =
 **Implemented:**
 
 - ✅ Persistent daemon with profile loading
-- ✅ Unix socket IPC
+- ✅ Unix socket IPC (named pipes on Windows)
 - ✅ Multiple concurrent sessions
 - ✅ Session management (current session, explicit session IDs)
 - ✅ Environment variable isolation (`PQ_SESSION_DIR`)

src/profile-query-cli/client.ts

@@ -58,7 +58,11 @@ async function sendRawMessage(
     ? getSocketPath(sessionDir, sessionId)
     : getCurrentSocketPath(sessionDir);
 
-  if (!socketPath || !fs.existsSync(socketPath)) {
+  // On Windows, named pipes are not filesystem files so existsSync always returns false
+  if (
+    !socketPath ||
+    (process.platform !== 'win32' && !fs.existsSync(socketPath))
+  ) {
     throw new Error(`Socket not found for session ${resolvedSessionId}`);
   }
 

src/profile-query-cli/daemon.ts

@@ -1,6 +1,6 @@
 /**
  * Daemon process for pq.
- * Loads a profile and listens for commands on a Unix socket.
+ * Loads a profile and listens for commands on a Unix socket (or named pipe on Windows).
  */
 
 import * as net from 'net';
@@ -90,8 +90,8 @@ export class Daemon {
       // Create Unix socket server BEFORE loading the profile
       this.server = net.createServer((socket) => this.handleConnection(socket));
 
-      // Remove stale socket if it exists
-      if (fs.existsSync(this.socketPath)) {
+      // Remove stale socket if it exists (Unix only — named pipes on Windows are not filesystem files)
+      if (process.platform !== 'win32' && fs.existsSync(this.socketPath)) {
         fs.unlinkSync(this.socketPath);
       }
 

src/profile-query-cli/session.ts

@@ -29,8 +29,12 @@ export function generateSessionId(): string {
 
 /**
  * Get the socket path for a session.
+ * On Windows, returns a named pipe path. On Unix, returns a .sock file path.
  */
 export function getSocketPath(sessionDir: string, sessionId: string): string {
+  if (process.platform === 'win32') {
+    return `\\\\.\\pipe\\pq-${sessionId}`;
+  }
   return path.join(sessionDir, `${sessionId}.sock`);
 }
 
@@ -143,8 +147,8 @@ export function cleanupSession(sessionDir: string, sessionId: string): void {
   // Note: We intentionally don't delete the log file for debugging purposes
   // const logPath = getLogPath(sessionDir, sessionId);
 
-  // Remove socket file
-  if (fs.existsSync(socketPath)) {
+  // Remove socket file (Unix only — named pipes on Windows are not filesystem files)
+  if (process.platform !== 'win32' && fs.existsSync(socketPath)) {
     fs.unlinkSync(socketPath);
   }
 
@@ -181,8 +185,8 @@ export function validateSession(
     return null;
   }
 
-  // Check if socket exists
-  if (!fs.existsSync(metadata.socketPath)) {
+  // Check if socket exists (Unix only — named pipes on Windows are not filesystem files)
+  if (process.platform !== 'win32' && !fs.existsSync(metadata.socketPath)) {
     // console.error(`Session ${sessionId} socket not found. Cleaning up.`);
     return null;
   }

src/profile-query-cli/tests/daemon-startup.test.ts

@@ -12,6 +12,7 @@ import {
   pqFail,
   type PqTestContext,
 } from './utils';
+import { getSocketPath } from '../session';
 
 describe('daemon startup (two-phase)', () => {
   let ctx: PqTestContext;
@@ -102,10 +103,13 @@ describe('daemon startup (two-phase)', () => {
     const sessionId = match![1];
 
     // Verify both socket and metadata exist (validateSession checks both)
-    const socketPath = join(ctx.sessionDir, `${sessionId}.sock`);
+    const socketPath = getSocketPath(ctx.sessionDir, sessionId);
     const metadataPath = join(ctx.sessionDir, `${sessionId}.json`);
 
-    await expect(access(socketPath)).resolves.toBeUndefined();
+    // Named pipes on Windows are not filesystem files, skip the access check there
+    if (process.platform !== 'win32') {
+      await expect(access(socketPath)).resolves.toBeUndefined();
+    }
     await expect(access(metadataPath)).resolves.toBeUndefined();
 
     // Process should be running (metadata contains PID)