chore: restore state files after revert

Made-with: Cursor

Author: jonzarecki

.cursor/plans/reddit_adapter_phase2_auth.plan.md

@@ -0,0 +1,72 @@
+# Reddit Adapter Phase 2: Authenticated Features
+
+## Prerequisites
+
+- Phase 1 complete: `browserkit-dev/adapter-reddit` published with 4 public tools (`get_subreddit`, `get_thread`, `search`, `get_user`)
+- CI passing on Phase 1
+
+## 2a. Auth detection
+
+Replace `isLoggedIn: () => true` with real detection in `src/index.ts`:
+
+```typescript
+async isLoggedIn(page: Page): Promise<boolean> {
+  // old.reddit.com shows username link in header when logged in
+  const userLink = await page.locator('#header-bottom-right .user a').count();
+  if (userLink > 0) return true;
+  // Fallback: check for login prompt text
+  const loginPrompt = await page.locator('#header-bottom-right .login-required').count();
+  return loginPrompt === 0;
+}
+```
+
+## 2b. New tools (3)
+
+| Tool | Inputs | URL pattern | Description |
+|------|--------|-------------|-------------|
+| `get_feed` | `sort?` (best/hot/new/rising/top), `count?` (1-50) | `old.reddit.com/` (logged-in front page) | Personal front page based on subscriptions |
+| `get_saved` | `count?` (1-50) | `old.reddit.com/user/{me}/saved` | Saved posts and comments |
+| `get_messages` | `section?` (inbox/unread/sent), `count?` (1-25) | `old.reddit.com/message/{section}` | Reddit inbox messages |
+
+Phase 1 tools continue to work for both authenticated and unauthenticated users. Phase 2 tools return handoff errors when not logged in (framework handles this automatically via `isLoggedIn` check before each tool call).
+
+`get_feed` reuses `scrapePostListing` from Phase 1. `get_saved` reuses the same scraper but targets the saved page. `get_messages` needs a new `scrapeMessages` function in `scraper.ts` for the message DOM.
+
+## 2c. Config
+
+```javascript
+adapters: {
+  "@browserkit/adapter-reddit": { port: 3849 },
+  // no channel: "chrome" needed — Reddit doesn't block Chromium login
+}
+```
+
+Login: `browserkit login reddit` opens old.reddit.com/login in a headed browser.
+
+## 2d. Testing
+
+**Unit tests (update `reddit.test.ts`):**
+- 3 new tool schemas validated
+- `isLoggedIn` with mocked page (logged in vs logged out HTML)
+- `scrapeMessages` pure function tests
+
+**L3 MCP protocol (update `mcp-protocol.test.ts`):**
+- Tool count increases from 6 to 9
+- `get_feed` / `get_saved` / `get_messages` dispatch correctly
+- Unauthenticated calls to auth tools return handoff error
+
+**L2 integration (`reddit.integration.test.ts`):**
+- `get_feed` returns personalized posts (requires `browserkit login reddit`)
+- `get_saved` returns saved items
+- `get_messages` returns inbox
+- Mark these as skip-in-CI (need live auth session)
+
+## 2e. Execution order
+
+1. Update `isLoggedIn` with real auth detection
+2. Add `scrapeMessages` to `scraper.ts`
+3. Add `get_feed`, `get_saved`, `get_messages` tool handlers to `index.ts`
+4. Update L1 + L3 tests for new tools
+5. Add L2 auth integration tests (excluded from CI)
+6. Push, verify CI passes
+7. Update main browserkit README if needed

packages/core/src/human-handoff.ts

@@ -208,3 +208,56 @@ function raceWithTimeout(promise: Promise<boolean>, timeoutMs: number): Promise<
 function sleep(ms: number): Promise<void> {
   return new Promise((resolve) => setTimeout(resolve, ms));
 }
+
+// ── loginViaConnect ───────────────────────────────────────────────────────────
+
+/**
+ * Attaches to an already-running Chrome instance via CDP, checks whether the
+ * adapter reports a logged-in state, and — if so — saves the storageState to
+ * disk so `SessionManager` can pick it up on next start.
+ *
+ * Use this with `browserkit login --connect` to avoid opening a second browser
+ * when the user already has Chrome running and logged in.
+ */
+export async function loginViaConnect(
+  sessionManager: Pick<SessionManager, "getProfileDir" | "injectStorageState">,
+  config: Pick<SessionConfig, "site" | "domain" | "authStrategy" | "profileDir">,
+  adapter: Pick<SiteAdapter, "isLoggedIn">,
+  cdpEndpoint: string
+): Promise<{ outcome: "success" | "timeout"; durationMs: number }> {
+  const start = Date.now();
+
+  const browser = await chromium.connectOverCDP(cdpEndpoint);
+  try {
+    const context = browser.contexts()[0];
+    if (!context) return { outcome: "timeout", durationMs: Date.now() - start };
+
+    const pages = context.pages();
+    const page = pages[0];
+    if (!page) return { outcome: "timeout", durationMs: Date.now() - start };
+
+    const loggedIn = await adapter.isLoggedIn(page as never);
+    if (!loggedIn) return { outcome: "timeout", durationMs: Date.now() - start };
+
+    // Logged in — persist the storageState
+    const state = await context.storageState();
+    if (config.authStrategy === "storage-state") {
+      const profileDir = sessionManager.getProfileDir(config.site ?? config.profileDir);
+      fs.mkdirSync(profileDir, { recursive: true });
+      fs.writeFileSync(
+        path.join(profileDir, "storage-state.json"),
+        JSON.stringify(state, null, 2)
+      );
+    } else {
+      await sessionManager.injectStorageState(
+        config.site,
+        state.cookies as never,
+        state.origins as never
+      );
+    }
+
+    return { outcome: "success", durationMs: Date.now() - start };
+  } finally {
+    await browser.close();
+  }
+}

packages/core/src/session-manager.ts

@@ -382,3 +382,70 @@ export function getDefaultDataDir(): string {
 function isProcessRunning(pid: number): boolean {
   try { process.kill(pid, 0); return true; } catch { return false; }
 }
+
+// ── autoDiscoverCdpEndpoint ───────────────────────────────────────────────────
+
+/**
+ * Scans well-known Chrome user-data directories for a `DevToolsActivePort`
+ * file written by a running Chrome process (requires `--remote-debugging-port`).
+ *
+ * Returns the first valid CDP WebSocket URL found, e.g.
+ *   `ws://127.0.0.1:9222/devtools/browser/<id>`
+ *
+ * Throws if no running Chrome instance is discovered.
+ */
+export async function autoDiscoverCdpEndpoint(expectedPort?: number): Promise<string> {
+  const candidates: string[] = [];
+
+  switch (process.platform) {
+    case "darwin":
+      candidates.push(
+        path.join(os.homedir(), "Library", "Application Support", "Google", "Chrome"),
+        path.join(os.homedir(), "Library", "Application Support", "Google", "Chrome Beta"),
+        path.join(os.homedir(), "Library", "Application Support", "Chromium"),
+        path.join(os.homedir(), "Library", "Application Support", "BraveSoftware", "Brave-Browser"),
+      );
+      break;
+    case "linux":
+      candidates.push(
+        path.join(os.homedir(), ".config", "google-chrome"),
+        path.join(os.homedir(), ".config", "chromium"),
+      );
+      break;
+    case "win32":
+      candidates.push(
+        path.join(os.homedir(), "AppData", "Local", "Google", "Chrome", "User Data"),
+        path.join(os.homedir(), "AppData", "Local", "Chromium", "User Data"),
+      );
+      break;
+  }
+
+  for (const dir of candidates) {
+    // DevToolsActivePort can appear in the root or inside a profile subfolder
+    for (const sub of ["", "Default"]) {
+      const file = path.join(dir, sub, "DevToolsActivePort");
+      try {
+        const contents = fs.readFileSync(file, "utf8");
+        const ws = parseDevToolsActivePort(contents, expectedPort);
+        if (ws) return ws;
+      } catch {
+        // file not found or unreadable — keep scanning
+      }
+    }
+  }
+
+  throw new Error(
+    "Could not auto-discover a running Chrome instance with remote debugging enabled. " +
+    "Launch Chrome with --remote-debugging-port=<port> first, or pass the CDP URL explicitly."
+  );
+}
+
+function parseDevToolsActivePort(contents: string, expectedPort?: number): string | null {
+  const lines = contents.split(/\r?\n/).map((l) => l.trim()).filter((l) => l.length > 0);
+  const port = Number.parseInt(lines[0] ?? "", 10);
+  const wsPath = lines[1] ?? "";
+  if (!Number.isInteger(port) || port < 1 || port > 65_535) return null;
+  if (expectedPort !== undefined && port !== expectedPort) return null;
+  if (!wsPath.startsWith("/devtools/browser/")) return null;
+  return `ws://127.0.0.1:${port}${wsPath}`;
+}