Compare commits
12 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
 Alex Newman
|
7f88b7fa5e | ||
|
Alex Newman
|
4ddc5a01bb | ||
|
Alex Newman
|
c422ea133f | ||
|
Alex Newman
|
25b7408a42 | ||
|
Alex Newman
|
15c0813655 | ||
|
Alex Newman
|
f1da66e4f1 | ||
|
Alex Newman
|
71fe43f290 | ||
|
Alex Newman
|
830f16df46 | ||
|
Alex Newman
|
ad75ca7c4c | ||
|
Alex Newman
|
65fb8d1ed2 | ||
|
Copilot
|
e7380adb2f | ||
|
Alex Newman
|
245c85a580 |
@@ -10,7 +10,7 @@
|
||||
"plugins": [
|
||||
{
|
||||
"name": "claude-mem",
|
||||
"version": "7.1.14",
|
||||
"version": "7.2.1",
|
||||
"source": "./plugin",
|
||||
"description": "Persistent memory system for Claude Code - context compression across sessions"
|
||||
}
|
||||
|
||||
@@ -1,38 +1,68 @@
|
||||
---
|
||||
name: Bug report
|
||||
about: Create a report to help us improve
|
||||
about: Use the automated bug report tool for best results
|
||||
title: ''
|
||||
labels: ''
|
||||
labels: 'bug, needs-triage'
|
||||
assignees: ''
|
||||
|
||||
---
|
||||
|
||||
**Describe the bug**
|
||||
A clear and concise description of what the bug is.
|
||||
## ⚡ Quick Bug Report (Recommended)
|
||||
|
||||
**To Reproduce**
|
||||
Steps to reproduce the behavior:
|
||||
**Use the automated bug report generator** for comprehensive diagnostics:
|
||||
|
||||
```bash
|
||||
# Navigate to the plugin directory
|
||||
cd ~/.claude/plugins/marketplaces/thedotmack
|
||||
|
||||
# Run the bug report tool
|
||||
npm run bug-report
|
||||
```
|
||||
|
||||
**Plugin Paths:**
|
||||
- **macOS/Linux**: `~/.claude/plugins/marketplaces/thedotmack`
|
||||
- **Windows**: `%USERPROFILE%\.claude\plugins\marketplaces\thedotmack`
|
||||
|
||||
**Features:**
|
||||
- 🌎 Auto-translates any language to English
|
||||
- 📊 Collects all diagnostics automatically
|
||||
- 🤖 AI-formatted professional issue
|
||||
- 🔒 Privacy-safe (paths sanitized, `--no-logs` option)
|
||||
- 🌐 Auto-opens GitHub with pre-filled issue
|
||||
|
||||
---
|
||||
|
||||
## 📝 Manual Bug Report
|
||||
|
||||
If you prefer to file manually or can't access the plugin directory:
|
||||
|
||||
### Bug Description
|
||||
A clear description of what the bug is.
|
||||
|
||||
### Steps to Reproduce
|
||||
1. Go to '...'
|
||||
2. Click on '....'
|
||||
3. Scroll down to '....'
|
||||
4. See error
|
||||
2. Click on '...'
|
||||
3. See error
|
||||
|
||||
**Expected behavior**
|
||||
A clear and concise description of what you expected to happen.
|
||||
### Expected Behavior
|
||||
What you expected to happen.
|
||||
|
||||
**Screenshots**
|
||||
If applicable, add screenshots to help explain your problem.
|
||||
### Environment
|
||||
- **Claude-mem version**:
|
||||
- **Claude Code version**:
|
||||
- **OS**:
|
||||
- **Platform**:
|
||||
|
||||
**Desktop (please complete the following information):**
|
||||
- OS: [e.g. iOS]
|
||||
- Browser [e.g. chrome, safari]
|
||||
- Version [e.g. 22]
|
||||
### Logs
|
||||
Worker logs are located at:
|
||||
- **Path**: `~/.claude-mem/logs/worker-YYYY-MM-DD.log`
|
||||
- **Example**: `~/.claude-mem/logs/worker-2025-12-14.log`
|
||||
|
||||
**Smartphone (please complete the following information):**
|
||||
- Device: [e.g. iPhone6]
|
||||
- OS: [e.g. iOS8.1]
|
||||
- Browser [e.g. stock browser, safari]
|
||||
- Version [e.g. 22]
|
||||
Please paste relevant log entries (last 50 lines or error messages):
|
||||
|
||||
**Additional context**
|
||||
Add any other context about the problem here.
|
||||
```
|
||||
[Paste logs here]
|
||||
```
|
||||
|
||||
### Additional Context
|
||||
Any other context about the problem.
|
||||
|
||||
@@ -2,7 +2,7 @@
|
||||
name: Feature request
|
||||
about: Suggest an idea for this project
|
||||
title: ''
|
||||
labels: 'feature-request'
|
||||
labels: feature-request
|
||||
assignees: ''
|
||||
|
||||
---
|
||||
|
||||
+148
@@ -4,6 +4,154 @@ 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/).
|
||||
|
||||
## [7.2.0] - 2025-12-14
|
||||
|
||||
## 🎉 New Features
|
||||
|
||||
### Automated Bug Report Generator
|
||||
|
||||
Added comprehensive bug report tool that streamlines issue reporting with AI assistance:
|
||||
|
||||
- **Command**: `npm run bug-report`
|
||||
- **🌎 Multi-language Support**: Write in ANY language, auto-translates to English
|
||||
- **📊 Smart Diagnostics**: Automatically collects:
|
||||
- Version information (claude-mem, Claude Code, Node.js, Bun)
|
||||
- Platform details (OS, version, architecture)
|
||||
- Worker status (running state, PID, port, uptime, stats)
|
||||
- Last 50 lines of logs (worker + silent debug)
|
||||
- Database info and configuration settings
|
||||
- **🤖 AI-Powered**: Uses Claude Agent SDK to generate professional GitHub issues
|
||||
- **📝 Interactive**: Multiline input support with intuitive prompts
|
||||
- **🔒 Privacy-Safe**:
|
||||
- Auto-sanitizes all file paths (replaces home directory with ~)
|
||||
- Optional `--no-logs` flag to exclude logs
|
||||
- **⚡ Streaming Progress**: Real-time character count and animated spinner
|
||||
- **🌐 One-Click Submit**: Auto-opens GitHub with pre-filled title and body
|
||||
|
||||
### Usage
|
||||
|
||||
From the plugin directory:
|
||||
```bash
|
||||
cd ~/.claude/plugins/marketplaces/thedotmack
|
||||
npm run bug-report
|
||||
```
|
||||
|
||||
**Plugin Paths:**
|
||||
- macOS/Linux: `~/.claude/plugins/marketplaces/thedotmack`
|
||||
- Windows: `%USERPROFILE%\.claude\plugins\marketplaces\thedotmack`
|
||||
|
||||
**Options:**
|
||||
```bash
|
||||
npm run bug-report --no-logs # Skip logs for privacy
|
||||
npm run bug-report --verbose # Show all diagnostics
|
||||
npm run bug-report --help # Show help
|
||||
```
|
||||
|
||||
## 📚 Documentation
|
||||
|
||||
- Updated README with bug report section and usage instructions
|
||||
- Enhanced GitHub issue template to feature automated tool
|
||||
- Added platform-specific directory paths
|
||||
|
||||
## 🔧 Technical Details
|
||||
|
||||
**Files Added:**
|
||||
- `scripts/bug-report/cli.ts` - Interactive CLI entry point
|
||||
- `scripts/bug-report/index.ts` - Core logic with Agent SDK integration
|
||||
- `scripts/bug-report/collector.ts` - System diagnostics collector
|
||||
|
||||
**Files Modified:**
|
||||
- `package.json` - Added bug-report script
|
||||
- `README.md` - New Bug Reports section
|
||||
- `.github/ISSUE_TEMPLATE/bug_report.md` - Updated with automated tool instructions
|
||||
|
||||
---
|
||||
|
||||
**Full Changelog**: https://github.com/thedotmack/claude-mem/compare/v7.1.15...v7.2.0
|
||||
|
||||
## [7.1.15] - 2025-12-14
|
||||
|
||||
## 🐛 Bug Fixes
|
||||
|
||||
**Worker Service Initialization**
|
||||
- Fixed 404 error on `/api/context/inject` during worker startup
|
||||
- Route is now registered immediately instead of after database initialization
|
||||
- Prevents race condition on fresh installs and restarts
|
||||
- Added integration test for early context inject route access
|
||||
|
||||
## Technical Details
|
||||
|
||||
The context hook was failing with `Cannot GET /api/context/inject` because the route was registered only after database initialization completed. This created a race condition where the hook could attempt to access the endpoint before it existed.
|
||||
|
||||
**Implementation:**
|
||||
- Added `initializationComplete` Promise to track async background initialization
|
||||
- Register `/api/context/inject` route immediately in `setupRoutes()`
|
||||
- Early handler blocks requests until initialization resolves (30s timeout)
|
||||
- Route handler duplicates logic from `SearchRoutes.handleContextInject` by design to prevent 404s
|
||||
|
||||
**Testing:**
|
||||
- Added integration test verifying route registration and timeout handling
|
||||
|
||||
Fixes #305
|
||||
Related: PR #310
|
||||
|
||||
## [7.1.14] - 2025-12-14
|
||||
|
||||
## Enhanced Error Handling & Logging
|
||||
|
||||
This patch release improves error message quality and logging across the claude-mem system.
|
||||
|
||||
### Error Message Improvements
|
||||
|
||||
**Standardized Hook Error Handling**
|
||||
- Created shared error handlers (`handleFetchError`, `handleWorkerError`) for consistent error messages
|
||||
- Platform-aware restart instructions (macOS, Linux, Windows) with correct commands
|
||||
- Migrated all hooks (context, new, save, summary) to use standardized handlers
|
||||
- Enhanced error logging with actionable context before throwing restart instructions
|
||||
|
||||
**ChromaSync Error Standardization**
|
||||
- Consistent client initialization checks across all methods
|
||||
- Enhanced error messages with troubleshooting steps and restart instructions
|
||||
- Better context about which operation failed
|
||||
|
||||
**Worker Service Improvements**
|
||||
- Enhanced version endpoint error logging with status codes and response text
|
||||
- Improved worker restart error messages with PM2 commands
|
||||
- Better context in all worker-related error scenarios
|
||||
|
||||
### Bug Fixes
|
||||
|
||||
- **Issue #260**: Fixed `happy_path_error__with_fallback` misuse in save-hook causing false "Missing cwd" errors
|
||||
- Removed unnecessary `happy_path_error` calls from SDKAgent that were masking real error messages
|
||||
- Cleaned up migration logging to use `console.log` instead of `console.error` for non-error events
|
||||
|
||||
### Logging Improvements
|
||||
|
||||
**Timezone-Aware Timestamps**
|
||||
- Worker logs now use local machine timezone instead of UTC
|
||||
- Maintains same format (`YYYY-MM-DD HH:MM:SS.mmm`) but reflects local time
|
||||
- Easier debugging and log correlation with system events
|
||||
- Enhanced worker-cli logging output format
|
||||
|
||||
### Test Coverage
|
||||
|
||||
Added comprehensive test suites:
|
||||
- `tests/error-handling/hook-error-logging.test.ts` - 12 tests for hook error handler behavior
|
||||
- `tests/services/chroma-sync-errors.test.ts` - ChromaSync error message consistency
|
||||
- `tests/integration/hook-execution-environments.test.ts` - Bun PATH resolution across shells
|
||||
- `docs/context/TEST_AUDIT_2025-12-13.md` - Comprehensive audit report
|
||||
|
||||
### Files Changed
|
||||
|
||||
27 files changed: 1,435 additions, 200 deletions
|
||||
|
||||
**What's Changed**
|
||||
* Standardize and enhance error handling across hooks and worker service by @thedotmack in #295
|
||||
* Timezone-aware logging for worker service and CLI
|
||||
* Complete build with all plugin files included
|
||||
|
||||
**Full Changelog**: https://github.com/thedotmack/claude-mem/compare/v7.1.12...v7.1.14
|
||||
|
||||
## [7.1.13] - 2025-12-14
|
||||
|
||||
## Enhanced Error Handling & Logging
|
||||
|
||||
@@ -6,7 +6,7 @@
|
||||
|
||||
Claude-mem is a Claude Code plugin providing persistent memory across sessions. It captures tool usage, compresses observations using the Claude Agent SDK, and injects relevant context into future sessions.
|
||||
|
||||
**Current Version**: 7.1.14
|
||||
**Current Version**: 7.2.1
|
||||
|
||||
## Architecture
|
||||
|
||||
|
||||
@@ -404,6 +404,37 @@ See [Troubleshooting Guide](https://docs.claude-mem.ai/troubleshooting) for comp
|
||||
|
||||
---
|
||||
|
||||
## Bug Reports
|
||||
|
||||
**Automated Bug Report Generator** - Create comprehensive bug reports with one command:
|
||||
|
||||
```bash
|
||||
# From the plugin directory
|
||||
cd ~/.claude/plugins/marketplaces/thedotmack
|
||||
npm run bug-report
|
||||
```
|
||||
|
||||
The bug report tool will:
|
||||
- 🌎 **Auto-translate** - Write in ANY language, automatically translates to English
|
||||
- 📊 **Collect diagnostics** - Gathers versions, platform info, worker status, logs, and configuration
|
||||
- 📝 **Interactive prompts** - Guides you through describing the issue with multiline support
|
||||
- 🤖 **AI formatting** - Uses Claude Agent SDK to generate professional GitHub issues
|
||||
- 🔒 **Privacy-safe** - Auto-sanitizes paths, optional `--no-logs` flag
|
||||
- 🌐 **Auto-submit** - Opens GitHub with pre-filled title and body
|
||||
|
||||
**Plugin Directory Paths:**
|
||||
- **macOS/Linux**: `~/.claude/plugins/marketplaces/thedotmack`
|
||||
- **Windows**: `%USERPROFILE%\.claude\plugins\marketplaces\thedotmack`
|
||||
|
||||
**Options:**
|
||||
```bash
|
||||
npm run bug-report --no-logs # Skip logs for privacy
|
||||
npm run bug-report --verbose # Show all diagnostics
|
||||
npm run bug-report --help # Show help
|
||||
```
|
||||
|
||||
---
|
||||
|
||||
## Contributing
|
||||
|
||||
Contributions are welcome! Please:
|
||||
|
||||
+8
-2
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"name": "claude-mem",
|
||||
"version": "7.1.14",
|
||||
"version": "7.2.1",
|
||||
"description": "Memory compression system for Claude Code - persist context across sessions",
|
||||
"keywords": [
|
||||
"claude",
|
||||
@@ -47,7 +47,13 @@
|
||||
"changelog:generate": "node scripts/generate-changelog.js",
|
||||
"usage:analyze": "node scripts/analyze-usage.js",
|
||||
"usage:today": "node scripts/analyze-usage.js $(date +%Y-%m-%d)",
|
||||
"translate-readme": "npx tsx scripts/translate-readme/cli.ts -v README.md zh ko ja"
|
||||
"translate-readme": "bun scripts/translate-readme/cli.ts -v -o docs/i18n README.md",
|
||||
"translate:tier1": "npm run translate-readme -- zh ja pt-br ko es de fr",
|
||||
"translate:tier2": "npm run translate-readme -- he ar ru pl cs nl tr uk",
|
||||
"translate:tier3": "npm run translate-readme -- vi id th hi bn ro sv",
|
||||
"translate:tier4": "npm run translate-readme -- it el hu fi da no",
|
||||
"translate:all": "npm run translate:tier1 && npm run translate:tier2 && npm run translate:tier3 && npm run translate:tier4",
|
||||
"bug-report": "npx tsx scripts/bug-report/cli.ts"
|
||||
},
|
||||
"dependencies": {
|
||||
"@anthropic-ai/claude-agent-sdk": "^0.1.67",
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"name": "claude-mem",
|
||||
"version": "7.1.14",
|
||||
"version": "7.2.1",
|
||||
"description": "Persistent memory system for Claude Code - seamlessly preserve context across sessions",
|
||||
"author": {
|
||||
"name": "Alex Newman"
|
||||
|
||||
+1
-1
@@ -1,6 +1,6 @@
|
||||
{
|
||||
"name": "claude-mem-plugin",
|
||||
"version": "7.1.14",
|
||||
"version": "7.1.15",
|
||||
"private": true,
|
||||
"description": "Runtime dependencies for claude-mem bundled hooks",
|
||||
"type": "module",
|
||||
|
||||
File diff suppressed because one or more lines are too long
@@ -7,7 +7,8 @@ ${t.stack}`:t.message;if(Array.isArray(t))return`[${t.length} items]`;let e=Obje
|
||||
`,u+=`1. Exit Claude Code completely
|
||||
`,u+=`2. Open ${a}
|
||||
`,u+=`3. Navigate to: ${i}
|
||||
`,u+="4. Run: npm run worker:restart",e&&(u+=`
|
||||
`,u+=`4. Run: npm run worker:restart
|
||||
`,u+="5. Restart Claude Code",e&&(u+=`
|
||||
|
||||
If that doesn't work, try: /troubleshoot`),o&&(u=`Worker Error: ${o}
|
||||
|
||||
|
||||
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
@@ -7,7 +7,8 @@ ${t.stack}`:t.message;if(Array.isArray(t))return`[${t.length} items]`;let e=Obje
|
||||
`,u+=`1. Exit Claude Code completely
|
||||
`,u+=`2. Open ${a}
|
||||
`,u+=`3. Navigate to: ${i}
|
||||
`,u+="4. Run: npm run worker:restart",e&&(u+=`
|
||||
`,u+=`4. Run: npm run worker:restart
|
||||
`,u+="5. Restart Claude Code",e&&(u+=`
|
||||
|
||||
If that doesn't work, try: /troubleshoot`),n&&(u=`Worker Error: ${n}
|
||||
|
||||
|
||||
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
File diff suppressed because one or more lines are too long
@@ -0,0 +1,275 @@
|
||||
#!/usr/bin/env npx tsx
|
||||
|
||||
import { generateBugReport } from "./index.ts";
|
||||
import { collectDiagnostics } from "./collector.ts";
|
||||
import * as fs from "fs/promises";
|
||||
import * as path from "path";
|
||||
import * as os from "os";
|
||||
import * as readline from "readline";
|
||||
import { exec } from "child_process";
|
||||
import { promisify } from "util";
|
||||
|
||||
const execAsync = promisify(exec);
|
||||
|
||||
interface CliArgs {
|
||||
output?: string;
|
||||
verbose: boolean;
|
||||
noLogs: boolean;
|
||||
help: boolean;
|
||||
}
|
||||
|
||||
function parseArgs(): CliArgs {
|
||||
const args = process.argv.slice(2);
|
||||
const parsed: CliArgs = {
|
||||
verbose: false,
|
||||
noLogs: false,
|
||||
help: false,
|
||||
};
|
||||
|
||||
for (let i = 0; i < args.length; i++) {
|
||||
const arg = args[i];
|
||||
switch (arg) {
|
||||
case "-h":
|
||||
case "--help":
|
||||
parsed.help = true;
|
||||
break;
|
||||
case "-v":
|
||||
case "--verbose":
|
||||
parsed.verbose = true;
|
||||
break;
|
||||
case "--no-logs":
|
||||
parsed.noLogs = true;
|
||||
break;
|
||||
case "-o":
|
||||
case "--output":
|
||||
parsed.output = args[++i];
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
return parsed;
|
||||
}
|
||||
|
||||
function printHelp(): void {
|
||||
console.log(`
|
||||
bug-report - Generate bug reports for claude-mem
|
||||
|
||||
USAGE:
|
||||
npm run bug-report [options]
|
||||
|
||||
OPTIONS:
|
||||
-o, --output <file> Save report to file (default: stdout + timestamped file)
|
||||
-v, --verbose Show all collected diagnostics
|
||||
--no-logs Skip log collection (for privacy)
|
||||
-h, --help Show this help message
|
||||
|
||||
DESCRIPTION:
|
||||
This script collects system diagnostics, prompts you for issue details,
|
||||
and generates a formatted GitHub issue for claude-mem using the Claude Agent SDK.
|
||||
|
||||
The generated report will be saved to ~/bug-report-YYYY-MM-DD-HHMMSS.md
|
||||
and displayed in your terminal for easy copy-pasting to GitHub.
|
||||
|
||||
EXAMPLES:
|
||||
# Generate a bug report interactively
|
||||
npm run bug-report
|
||||
|
||||
# Generate without including logs (for privacy)
|
||||
npm run bug-report --no-logs
|
||||
|
||||
# Save to a specific file
|
||||
npm run bug-report --output ~/my-bug-report.md
|
||||
|
||||
# Show all diagnostic details during collection
|
||||
npm run bug-report --verbose
|
||||
`);
|
||||
}
|
||||
|
||||
async function promptUser(question: string): Promise<string> {
|
||||
const rl = readline.createInterface({
|
||||
input: process.stdin,
|
||||
output: process.stdout,
|
||||
});
|
||||
|
||||
return new Promise((resolve) => {
|
||||
rl.question(question, (answer) => {
|
||||
rl.close();
|
||||
resolve(answer.trim());
|
||||
});
|
||||
});
|
||||
}
|
||||
|
||||
async function promptMultiline(prompt: string): Promise<string> {
|
||||
console.log(prompt);
|
||||
console.log("(Press Enter on an empty line to finish)\n");
|
||||
|
||||
const rl = readline.createInterface({
|
||||
input: process.stdin,
|
||||
output: process.stdout,
|
||||
});
|
||||
|
||||
const lines: string[] = [];
|
||||
|
||||
return new Promise((resolve) => {
|
||||
rl.on("line", (line) => {
|
||||
// Empty line means we're done
|
||||
if (line.trim() === "" && lines.length > 0) {
|
||||
rl.close();
|
||||
resolve(lines.join("\n"));
|
||||
} else if (line.trim() !== "") {
|
||||
// Only add non-empty lines (or preserve empty lines in the middle)
|
||||
lines.push(line);
|
||||
}
|
||||
});
|
||||
|
||||
rl.on("close", () => {
|
||||
resolve(lines.join("\n"));
|
||||
});
|
||||
});
|
||||
}
|
||||
|
||||
async function main() {
|
||||
const args = parseArgs();
|
||||
|
||||
if (args.help) {
|
||||
printHelp();
|
||||
process.exit(0);
|
||||
}
|
||||
|
||||
console.log("🌎 Leave report in ANY language, and it will auto translate to English\n");
|
||||
console.log("🔍 Collecting system diagnostics...");
|
||||
|
||||
// Collect diagnostics
|
||||
const diagnostics = await collectDiagnostics({
|
||||
includeLogs: !args.noLogs,
|
||||
});
|
||||
|
||||
console.log("✓ Version information collected");
|
||||
console.log("✓ Platform details collected");
|
||||
console.log("✓ Worker status checked");
|
||||
if (!args.noLogs) {
|
||||
console.log(
|
||||
`✓ Logs extracted (last ${diagnostics.logs.workerLog.length + diagnostics.logs.silentLog.length} lines)`
|
||||
);
|
||||
}
|
||||
console.log("✓ Configuration loaded\n");
|
||||
|
||||
// Show summary
|
||||
console.log("📋 System Summary:");
|
||||
console.log(` Claude-mem: v${diagnostics.versions.claudeMem}`);
|
||||
console.log(` Claude Code: ${diagnostics.versions.claudeCode}`);
|
||||
console.log(
|
||||
` Platform: ${diagnostics.platform.osVersion} (${diagnostics.platform.arch})`
|
||||
);
|
||||
console.log(
|
||||
` Worker: ${diagnostics.worker.running ? `Running (PID ${diagnostics.worker.pid}, port ${diagnostics.worker.port})` : "Not running"}\n`
|
||||
);
|
||||
|
||||
if (args.verbose) {
|
||||
console.log("📊 Detailed Diagnostics:");
|
||||
console.log(JSON.stringify(diagnostics, null, 2));
|
||||
console.log();
|
||||
}
|
||||
|
||||
// Prompt for issue details
|
||||
const issueDescription = await promptMultiline(
|
||||
"Please describe the issue you're experiencing:"
|
||||
);
|
||||
|
||||
if (!issueDescription.trim()) {
|
||||
console.error("❌ Issue description is required");
|
||||
process.exit(1);
|
||||
}
|
||||
|
||||
console.log();
|
||||
const expectedBehavior = await promptMultiline(
|
||||
"Expected behavior (leave blank to skip):"
|
||||
);
|
||||
|
||||
console.log();
|
||||
const stepsToReproduce = await promptMultiline(
|
||||
"Steps to reproduce (leave blank to skip):"
|
||||
);
|
||||
|
||||
console.log();
|
||||
const confirm = await promptUser(
|
||||
"Generate bug report? (y/n): "
|
||||
);
|
||||
|
||||
if (confirm.toLowerCase() !== "y" && confirm.toLowerCase() !== "yes") {
|
||||
console.log("❌ Bug report generation cancelled");
|
||||
process.exit(0);
|
||||
}
|
||||
|
||||
console.log("\n🤖 Generating bug report with Claude...");
|
||||
|
||||
// Generate the bug report
|
||||
const result = await generateBugReport({
|
||||
issueDescription,
|
||||
expectedBehavior: expectedBehavior.trim() || undefined,
|
||||
stepsToReproduce: stepsToReproduce.trim() || undefined,
|
||||
includeLogs: !args.noLogs,
|
||||
});
|
||||
|
||||
if (!result.success) {
|
||||
console.error("❌ Failed to generate bug report:", result.error);
|
||||
process.exit(1);
|
||||
}
|
||||
|
||||
console.log("✓ Issue formatted successfully\n");
|
||||
|
||||
// Generate output file path
|
||||
const timestamp = new Date()
|
||||
.toISOString()
|
||||
.replace(/:/g, "")
|
||||
.replace(/\..+/, "")
|
||||
.replace("T", "-");
|
||||
const defaultOutputPath = path.join(
|
||||
os.homedir(),
|
||||
`bug-report-${timestamp}.md`
|
||||
);
|
||||
const outputPath = args.output || defaultOutputPath;
|
||||
|
||||
// Save to file
|
||||
await fs.writeFile(outputPath, result.body, "utf-8");
|
||||
|
||||
// Build GitHub URL with pre-filled title and body
|
||||
const encodedTitle = encodeURIComponent(result.title);
|
||||
const encodedBody = encodeURIComponent(result.body);
|
||||
const githubUrl = `https://github.com/thedotmack/claude-mem/issues/new?title=${encodedTitle}&body=${encodedBody}`;
|
||||
|
||||
// Display the report
|
||||
console.log("─".repeat(60));
|
||||
console.log("📋 BUG REPORT GENERATED");
|
||||
console.log("─".repeat(60));
|
||||
console.log();
|
||||
console.log(result.body);
|
||||
console.log();
|
||||
console.log("─".repeat(60));
|
||||
console.log("Suggested labels: bug, needs-triage");
|
||||
console.log(`Report saved to: ${outputPath}`);
|
||||
console.log("─".repeat(60));
|
||||
console.log();
|
||||
|
||||
// Open GitHub issue in browser
|
||||
console.log("🌐 Opening GitHub issue form in your browser...");
|
||||
try {
|
||||
const openCommand =
|
||||
process.platform === "darwin"
|
||||
? "open"
|
||||
: process.platform === "win32"
|
||||
? "start"
|
||||
: "xdg-open";
|
||||
|
||||
await execAsync(`${openCommand} "${githubUrl}"`);
|
||||
console.log("✓ Browser opened successfully");
|
||||
} catch (error) {
|
||||
console.error("❌ Failed to open browser. Please visit:");
|
||||
console.error(githubUrl);
|
||||
}
|
||||
}
|
||||
|
||||
main().catch((error) => {
|
||||
console.error("Fatal error:", error);
|
||||
process.exit(1);
|
||||
});
|
||||
@@ -0,0 +1,364 @@
|
||||
import * as fs from "fs/promises";
|
||||
import * as path from "path";
|
||||
import { exec } from "child_process";
|
||||
import { promisify } from "util";
|
||||
import * as os from "os";
|
||||
|
||||
const execAsync = promisify(exec);
|
||||
|
||||
export interface SystemDiagnostics {
|
||||
versions: {
|
||||
claudeMem: string;
|
||||
claudeCode: string;
|
||||
node: string;
|
||||
bun: string;
|
||||
};
|
||||
platform: {
|
||||
os: string;
|
||||
osVersion: string;
|
||||
arch: string;
|
||||
};
|
||||
paths: {
|
||||
pluginPath: string;
|
||||
dataDir: string;
|
||||
cwd: string;
|
||||
isDevMode: boolean;
|
||||
};
|
||||
worker: {
|
||||
running: boolean;
|
||||
pid?: number;
|
||||
port?: number;
|
||||
uptime?: number;
|
||||
version?: string;
|
||||
health?: any;
|
||||
stats?: any;
|
||||
};
|
||||
logs: {
|
||||
workerLog: string[];
|
||||
silentLog: string[];
|
||||
};
|
||||
database: {
|
||||
path: string;
|
||||
exists: boolean;
|
||||
size?: number;
|
||||
counts?: {
|
||||
observations: number;
|
||||
sessions: number;
|
||||
summaries: number;
|
||||
};
|
||||
};
|
||||
config: {
|
||||
settingsPath: string;
|
||||
settingsExist: boolean;
|
||||
settings?: Record<string, any>;
|
||||
};
|
||||
}
|
||||
|
||||
function sanitizePath(filePath: string): string {
|
||||
const homeDir = os.homedir();
|
||||
return filePath.replace(homeDir, "~");
|
||||
}
|
||||
|
||||
async function getClaudememVersion(): Promise<string> {
|
||||
try {
|
||||
const packageJsonPath = path.join(process.cwd(), "package.json");
|
||||
const content = await fs.readFile(packageJsonPath, "utf-8");
|
||||
const pkg = JSON.parse(content);
|
||||
return pkg.version || "unknown";
|
||||
} catch (error) {
|
||||
return "unknown";
|
||||
}
|
||||
}
|
||||
|
||||
async function getClaudeCodeVersion(): Promise<string> {
|
||||
try {
|
||||
const { stdout } = await execAsync("claude --version");
|
||||
return stdout.trim();
|
||||
} catch (error) {
|
||||
return "not installed or not in PATH";
|
||||
}
|
||||
}
|
||||
|
||||
async function getBunVersion(): Promise<string> {
|
||||
try {
|
||||
const { stdout } = await execAsync("bun --version");
|
||||
return stdout.trim();
|
||||
} catch (error) {
|
||||
return "not installed";
|
||||
}
|
||||
}
|
||||
|
||||
async function getOsVersion(): Promise<string> {
|
||||
try {
|
||||
if (process.platform === "darwin") {
|
||||
const { stdout } = await execAsync("sw_vers -productVersion");
|
||||
return `macOS ${stdout.trim()}`;
|
||||
} else if (process.platform === "linux") {
|
||||
const { stdout } = await execAsync("uname -sr");
|
||||
return stdout.trim();
|
||||
} else if (process.platform === "win32") {
|
||||
const { stdout } = await execAsync("ver");
|
||||
return stdout.trim();
|
||||
}
|
||||
return "unknown";
|
||||
} catch (error) {
|
||||
return "unknown";
|
||||
}
|
||||
}
|
||||
|
||||
async function checkWorkerHealth(port: number): Promise<any> {
|
||||
try {
|
||||
const response = await fetch(`http://127.0.0.1:${port}/health`, {
|
||||
signal: AbortSignal.timeout(2000),
|
||||
});
|
||||
return await response.json();
|
||||
} catch (error) {
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
async function getWorkerStats(port: number): Promise<any> {
|
||||
try {
|
||||
const response = await fetch(`http://127.0.0.1:${port}/api/stats`, {
|
||||
signal: AbortSignal.timeout(2000),
|
||||
});
|
||||
return await response.json();
|
||||
} catch (error) {
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
async function readPidFile(dataDir: string): Promise<any> {
|
||||
try {
|
||||
const pidPath = path.join(dataDir, "worker.pid");
|
||||
const content = await fs.readFile(pidPath, "utf-8");
|
||||
return JSON.parse(content);
|
||||
} catch (error) {
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
async function readLogLines(logPath: string, lines: number): Promise<string[]> {
|
||||
try {
|
||||
const content = await fs.readFile(logPath, "utf-8");
|
||||
const allLines = content.split("\n").filter((line) => line.trim());
|
||||
return allLines.slice(-lines);
|
||||
} catch (error) {
|
||||
return [];
|
||||
}
|
||||
}
|
||||
|
||||
async function getSettings(
|
||||
dataDir: string
|
||||
): Promise<{ exists: boolean; settings?: Record<string, any> }> {
|
||||
try {
|
||||
const settingsPath = path.join(dataDir, "settings.json");
|
||||
const content = await fs.readFile(settingsPath, "utf-8");
|
||||
const settings = JSON.parse(content);
|
||||
return { exists: true, settings };
|
||||
} catch (error) {
|
||||
return { exists: false };
|
||||
}
|
||||
}
|
||||
|
||||
async function getDatabaseInfo(
|
||||
dataDir: string
|
||||
): Promise<{ exists: boolean; size?: number }> {
|
||||
try {
|
||||
const dbPath = path.join(dataDir, "claude-mem.db");
|
||||
const stats = await fs.stat(dbPath);
|
||||
return { exists: true, size: stats.size };
|
||||
} catch (error) {
|
||||
return { exists: false };
|
||||
}
|
||||
}
|
||||
|
||||
export async function collectDiagnostics(
|
||||
options: { includeLogs?: boolean } = {}
|
||||
): Promise<SystemDiagnostics> {
|
||||
const homeDir = os.homedir();
|
||||
const dataDir = path.join(homeDir, ".claude-mem");
|
||||
const pluginPath = path.join(
|
||||
homeDir,
|
||||
".claude",
|
||||
"plugins",
|
||||
"marketplaces",
|
||||
"thedotmack"
|
||||
);
|
||||
const cwd = process.cwd();
|
||||
const isDevMode = cwd.includes("claude-mem") && !cwd.includes(".claude");
|
||||
|
||||
// Collect version information
|
||||
const [claudeMem, claudeCode, bun, osVersion] = await Promise.all([
|
||||
getClaudememVersion(),
|
||||
getClaudeCodeVersion(),
|
||||
getBunVersion(),
|
||||
getOsVersion(),
|
||||
]);
|
||||
|
||||
const versions = {
|
||||
claudeMem,
|
||||
claudeCode,
|
||||
node: process.version,
|
||||
bun,
|
||||
};
|
||||
|
||||
const platform = {
|
||||
os: process.platform,
|
||||
osVersion,
|
||||
arch: process.arch,
|
||||
};
|
||||
|
||||
const paths = {
|
||||
pluginPath: sanitizePath(pluginPath),
|
||||
dataDir: sanitizePath(dataDir),
|
||||
cwd: sanitizePath(cwd),
|
||||
isDevMode,
|
||||
};
|
||||
|
||||
// Check worker status
|
||||
const pidInfo = await readPidFile(dataDir);
|
||||
const workerPort = pidInfo?.port || 37777;
|
||||
|
||||
const [health, stats] = await Promise.all([
|
||||
checkWorkerHealth(workerPort),
|
||||
getWorkerStats(workerPort),
|
||||
]);
|
||||
|
||||
const worker = {
|
||||
running: health !== null,
|
||||
pid: pidInfo?.pid,
|
||||
port: workerPort,
|
||||
uptime: stats?.worker?.uptime,
|
||||
version: stats?.worker?.version,
|
||||
health,
|
||||
stats,
|
||||
};
|
||||
|
||||
// Collect logs if requested
|
||||
let workerLog: string[] = [];
|
||||
let silentLog: string[] = [];
|
||||
|
||||
if (options.includeLogs !== false) {
|
||||
const today = new Date().toISOString().split("T")[0];
|
||||
const workerLogPath = path.join(dataDir, "logs", `worker-${today}.log`);
|
||||
const silentLogPath = path.join(dataDir, "silent.log");
|
||||
|
||||
[workerLog, silentLog] = await Promise.all([
|
||||
readLogLines(workerLogPath, 50),
|
||||
readLogLines(silentLogPath, 50),
|
||||
]);
|
||||
}
|
||||
|
||||
const logs = {
|
||||
workerLog: workerLog.map(sanitizePath),
|
||||
silentLog: silentLog.map(sanitizePath),
|
||||
};
|
||||
|
||||
// Database info
|
||||
const dbInfo = await getDatabaseInfo(dataDir);
|
||||
const database = {
|
||||
path: sanitizePath(path.join(dataDir, "claude-mem.db")),
|
||||
exists: dbInfo.exists,
|
||||
size: dbInfo.size,
|
||||
// TODO: Add table counts if we want to query the database
|
||||
};
|
||||
|
||||
// Configuration
|
||||
const settingsInfo = await getSettings(dataDir);
|
||||
const config = {
|
||||
settingsPath: sanitizePath(path.join(dataDir, "settings.json")),
|
||||
settingsExist: settingsInfo.exists,
|
||||
settings: settingsInfo.settings,
|
||||
};
|
||||
|
||||
return {
|
||||
versions,
|
||||
platform,
|
||||
paths,
|
||||
worker,
|
||||
logs,
|
||||
database,
|
||||
config,
|
||||
};
|
||||
}
|
||||
|
||||
export function formatDiagnostics(diagnostics: SystemDiagnostics): string {
|
||||
let output = "";
|
||||
|
||||
output += "## Environment\n\n";
|
||||
output += `- **Claude-mem**: ${diagnostics.versions.claudeMem}\n`;
|
||||
output += `- **Claude Code**: ${diagnostics.versions.claudeCode}\n`;
|
||||
output += `- **Node.js**: ${diagnostics.versions.node}\n`;
|
||||
output += `- **Bun**: ${diagnostics.versions.bun}\n`;
|
||||
output += `- **OS**: ${diagnostics.platform.osVersion} (${diagnostics.platform.arch})\n`;
|
||||
output += `- **Platform**: ${diagnostics.platform.os}\n\n`;
|
||||
|
||||
output += "## Paths\n\n";
|
||||
output += `- **Plugin**: ${diagnostics.paths.pluginPath}\n`;
|
||||
output += `- **Data Directory**: ${diagnostics.paths.dataDir}\n`;
|
||||
output += `- **Current Directory**: ${diagnostics.paths.cwd}\n`;
|
||||
output += `- **Dev Mode**: ${diagnostics.paths.isDevMode ? "Yes" : "No"}\n\n`;
|
||||
|
||||
output += "## Worker Status\n\n";
|
||||
output += `- **Running**: ${diagnostics.worker.running ? "Yes" : "No"}\n`;
|
||||
if (diagnostics.worker.running) {
|
||||
output += `- **PID**: ${diagnostics.worker.pid || "unknown"}\n`;
|
||||
output += `- **Port**: ${diagnostics.worker.port}\n`;
|
||||
if (diagnostics.worker.uptime !== undefined) {
|
||||
const uptimeMinutes = Math.floor(diagnostics.worker.uptime / 60);
|
||||
output += `- **Uptime**: ${uptimeMinutes} minutes\n`;
|
||||
}
|
||||
if (diagnostics.worker.stats) {
|
||||
output += `- **Active Sessions**: ${diagnostics.worker.stats.worker?.activeSessions || 0}\n`;
|
||||
output += `- **SSE Clients**: ${diagnostics.worker.stats.worker?.sseClients || 0}\n`;
|
||||
}
|
||||
}
|
||||
output += "\n";
|
||||
|
||||
output += "## Database\n\n";
|
||||
output += `- **Path**: ${diagnostics.database.path}\n`;
|
||||
output += `- **Exists**: ${diagnostics.database.exists ? "Yes" : "No"}\n`;
|
||||
if (diagnostics.database.size) {
|
||||
const sizeKB = (diagnostics.database.size / 1024).toFixed(2);
|
||||
output += `- **Size**: ${sizeKB} KB\n`;
|
||||
}
|
||||
output += "\n";
|
||||
|
||||
output += "## Configuration\n\n";
|
||||
output += `- **Settings File**: ${diagnostics.config.settingsPath}\n`;
|
||||
output += `- **Settings Exist**: ${diagnostics.config.settingsExist ? "Yes" : "No"}\n`;
|
||||
if (diagnostics.config.settings) {
|
||||
output += "- **Key Settings**:\n";
|
||||
const keySettings = [
|
||||
"CLAUDE_MEM_MODEL",
|
||||
"CLAUDE_MEM_WORKER_PORT",
|
||||
"CLAUDE_MEM_WORKER_HOST",
|
||||
"CLAUDE_MEM_LOG_LEVEL",
|
||||
"CLAUDE_MEM_CONTEXT_OBSERVATIONS",
|
||||
];
|
||||
for (const key of keySettings) {
|
||||
if (diagnostics.config.settings[key]) {
|
||||
output += ` - ${key}: ${diagnostics.config.settings[key]}\n`;
|
||||
}
|
||||
}
|
||||
}
|
||||
output += "\n";
|
||||
|
||||
// Add logs if present
|
||||
if (diagnostics.logs.workerLog.length > 0) {
|
||||
output += "## Recent Worker Logs (Last 50 Lines)\n\n";
|
||||
output += "```\n";
|
||||
output += diagnostics.logs.workerLog.join("\n");
|
||||
output += "\n```\n\n";
|
||||
}
|
||||
|
||||
if (diagnostics.logs.silentLog.length > 0) {
|
||||
output += "## Silent Debug Log (Last 50 Lines)\n\n";
|
||||
output += "```\n";
|
||||
output += diagnostics.logs.silentLog.join("\n");
|
||||
output += "\n```\n\n";
|
||||
}
|
||||
|
||||
return output;
|
||||
}
|
||||
@@ -0,0 +1,195 @@
|
||||
import {
|
||||
query,
|
||||
type SDKMessage,
|
||||
type SDKResultMessage,
|
||||
} from "@anthropic-ai/claude-agent-sdk";
|
||||
import {
|
||||
collectDiagnostics,
|
||||
formatDiagnostics,
|
||||
type SystemDiagnostics,
|
||||
} from "./collector.ts";
|
||||
|
||||
export interface BugReportInput {
|
||||
issueDescription: string;
|
||||
expectedBehavior?: string;
|
||||
stepsToReproduce?: string;
|
||||
includeLogs?: boolean;
|
||||
}
|
||||
|
||||
export interface BugReportResult {
|
||||
title: string;
|
||||
body: string;
|
||||
success: boolean;
|
||||
error?: string;
|
||||
}
|
||||
|
||||
export async function generateBugReport(
|
||||
input: BugReportInput
|
||||
): Promise<BugReportResult> {
|
||||
try {
|
||||
// Collect system diagnostics
|
||||
const diagnostics = await collectDiagnostics({
|
||||
includeLogs: input.includeLogs !== false,
|
||||
});
|
||||
|
||||
const formattedDiagnostics = formatDiagnostics(diagnostics);
|
||||
|
||||
// Build the prompt
|
||||
const prompt = buildPrompt(
|
||||
formattedDiagnostics,
|
||||
input.issueDescription,
|
||||
input.expectedBehavior,
|
||||
input.stepsToReproduce
|
||||
);
|
||||
|
||||
// Use Agent SDK to generate formatted issue
|
||||
let generatedMarkdown = "";
|
||||
let charCount = 0;
|
||||
const startTime = Date.now();
|
||||
|
||||
const stream = query({
|
||||
prompt,
|
||||
options: {
|
||||
model: "sonnet",
|
||||
systemPrompt: `You are a GitHub issue formatter. Format bug reports clearly and professionally.`,
|
||||
permissionMode: "bypassPermissions",
|
||||
allowDangerouslySkipPermissions: true,
|
||||
includePartialMessages: true,
|
||||
},
|
||||
});
|
||||
|
||||
// Progress spinner frames
|
||||
const spinnerFrames = ["⠋", "⠙", "⠹", "⠸", "⠼", "⠴", "⠦", "⠧", "⠇", "⠏"];
|
||||
let spinnerIdx = 0;
|
||||
|
||||
// Stream the response
|
||||
for await (const message of stream) {
|
||||
if (message.type === "stream_event") {
|
||||
const event = message.event as { type: string; delta?: { type: string; text?: string } };
|
||||
if (event.type === "content_block_delta" && event.delta?.type === "text_delta" && event.delta.text) {
|
||||
generatedMarkdown += event.delta.text;
|
||||
charCount += event.delta.text.length;
|
||||
|
||||
const elapsed = ((Date.now() - startTime) / 1000).toFixed(1);
|
||||
const spinner = spinnerFrames[spinnerIdx++ % spinnerFrames.length];
|
||||
process.stdout.write(`\r ${spinner} Generating... ${charCount} chars (${elapsed}s)`);
|
||||
}
|
||||
}
|
||||
|
||||
// Handle full assistant messages (fallback)
|
||||
if (message.type === "assistant") {
|
||||
for (const block of message.message.content) {
|
||||
if (block.type === "text" && !generatedMarkdown) {
|
||||
generatedMarkdown = block.text;
|
||||
charCount = generatedMarkdown.length;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// Handle result
|
||||
if (message.type === "result") {
|
||||
const result = message as SDKResultMessage;
|
||||
if (result.subtype === "success" && !generatedMarkdown && result.result) {
|
||||
generatedMarkdown = result.result;
|
||||
charCount = generatedMarkdown.length;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// Clear the progress line
|
||||
process.stdout.write("\r" + " ".repeat(60) + "\r");
|
||||
|
||||
// Extract title from markdown (first heading)
|
||||
const titleMatch = generatedMarkdown.match(/^#\s+(.+)$/m);
|
||||
const title = titleMatch ? titleMatch[1] : "Bug Report";
|
||||
|
||||
return {
|
||||
title,
|
||||
body: generatedMarkdown,
|
||||
success: true,
|
||||
};
|
||||
} catch (error) {
|
||||
// Fallback to template-based generation
|
||||
console.error("Agent SDK failed, using template fallback:", error);
|
||||
return generateTemplateFallback(input);
|
||||
}
|
||||
}
|
||||
|
||||
function buildPrompt(
|
||||
diagnostics: string,
|
||||
issueDescription: string,
|
||||
expectedBehavior?: string,
|
||||
stepsToReproduce?: string
|
||||
): string {
|
||||
let prompt = `You are a GitHub issue formatter. Given system diagnostics and a user's bug description, create a well-structured GitHub issue for the claude-mem repository.
|
||||
|
||||
SYSTEM DIAGNOSTICS:
|
||||
${diagnostics}
|
||||
|
||||
USER DESCRIPTION:
|
||||
${issueDescription}
|
||||
`;
|
||||
|
||||
if (expectedBehavior) {
|
||||
prompt += `\nEXPECTED BEHAVIOR:
|
||||
${expectedBehavior}
|
||||
`;
|
||||
}
|
||||
|
||||
if (stepsToReproduce) {
|
||||
prompt += `\nSTEPS TO REPRODUCE:
|
||||
${stepsToReproduce}
|
||||
`;
|
||||
}
|
||||
|
||||
prompt += `
|
||||
|
||||
IMPORTANT: If any part of the user's description is in a language other than English, translate it to English while preserving technical accuracy and meaning.
|
||||
|
||||
Create a GitHub issue with:
|
||||
1. Clear, descriptive title (max 80 chars) in English - start with a single # heading
|
||||
2. Problem statement summarizing the issue in English
|
||||
3. Environment section (versions, platform) from the diagnostics
|
||||
4. Steps to reproduce (if provided) in English
|
||||
5. Expected vs actual behavior in English
|
||||
6. Relevant logs (formatted as code blocks) if present in diagnostics
|
||||
7. Any additional context that would help diagnose the issue
|
||||
|
||||
Format the output as valid GitHub Markdown. Make sure the title is a single # heading at the very top.
|
||||
Do NOT add meta-commentary like "Here's a formatted issue" - just output the raw markdown.
|
||||
All content must be in English for the GitHub issue.
|
||||
`;
|
||||
|
||||
return prompt;
|
||||
}
|
||||
|
||||
async function generateTemplateFallback(
|
||||
input: BugReportInput
|
||||
): Promise<BugReportResult> {
|
||||
const diagnostics = await collectDiagnostics({
|
||||
includeLogs: input.includeLogs !== false,
|
||||
});
|
||||
const formattedDiagnostics = formatDiagnostics(diagnostics);
|
||||
|
||||
let body = `# Bug Report\n\n`;
|
||||
body += `## Description\n\n`;
|
||||
body += `${input.issueDescription}\n\n`;
|
||||
|
||||
if (input.expectedBehavior) {
|
||||
body += `## Expected Behavior\n\n`;
|
||||
body += `${input.expectedBehavior}\n\n`;
|
||||
}
|
||||
|
||||
if (input.stepsToReproduce) {
|
||||
body += `## Steps to Reproduce\n\n`;
|
||||
body += `${input.stepsToReproduce}\n\n`;
|
||||
}
|
||||
|
||||
body += formattedDiagnostics;
|
||||
|
||||
return {
|
||||
title: "Bug Report",
|
||||
body,
|
||||
success: true,
|
||||
};
|
||||
}
|
||||
@@ -1,4 +1,4 @@
|
||||
#!/usr/bin/env npx tsx
|
||||
#!/usr/bin/env bun
|
||||
|
||||
import { translateReadme, SUPPORTED_LANGUAGES } from "./index.ts";
|
||||
|
||||
@@ -11,6 +11,8 @@ interface CliArgs {
|
||||
model?: string;
|
||||
maxBudget?: number;
|
||||
verbose: boolean;
|
||||
force: boolean;
|
||||
parallel: number;
|
||||
help: boolean;
|
||||
listLanguages: boolean;
|
||||
}
|
||||
@@ -39,6 +41,8 @@ OPTIONS:
|
||||
-m, --model <model> Claude model to use (default: sonnet)
|
||||
--max-budget <usd> Maximum budget in USD
|
||||
-v, --verbose Show detailed progress
|
||||
-f, --force Force re-translation ignoring cache
|
||||
--parallel <n> Run n translations concurrently (default: 1)
|
||||
-h, --help Show this help message
|
||||
--list-languages List all supported language codes
|
||||
|
||||
@@ -59,40 +63,46 @@ SUPPORTED LANGUAGES:
|
||||
|
||||
function printLanguages(): void {
|
||||
const LANGUAGE_NAMES: Record<string, string> = {
|
||||
ar: "Arabic",
|
||||
bg: "Bulgarian",
|
||||
cs: "Czech",
|
||||
da: "Danish",
|
||||
de: "German",
|
||||
el: "Greek",
|
||||
es: "Spanish",
|
||||
et: "Estonian",
|
||||
fi: "Finnish",
|
||||
fr: "French",
|
||||
he: "Hebrew",
|
||||
hi: "Hindi",
|
||||
hu: "Hungarian",
|
||||
id: "Indonesian",
|
||||
it: "Italian",
|
||||
// Tier 1 - No-brainers
|
||||
zh: "Chinese (Simplified)",
|
||||
ja: "Japanese",
|
||||
ko: "Korean",
|
||||
lt: "Lithuanian",
|
||||
lv: "Latvian",
|
||||
nl: "Dutch",
|
||||
no: "Norwegian",
|
||||
pl: "Polish",
|
||||
pt: "Portuguese",
|
||||
"pt-br": "Brazilian Portuguese",
|
||||
ro: "Romanian",
|
||||
ko: "Korean",
|
||||
es: "Spanish",
|
||||
de: "German",
|
||||
fr: "French",
|
||||
// Tier 2 - Strong tech scenes
|
||||
he: "Hebrew",
|
||||
ar: "Arabic",
|
||||
ru: "Russian",
|
||||
sk: "Slovak",
|
||||
sl: "Slovenian",
|
||||
sv: "Swedish",
|
||||
th: "Thai",
|
||||
pl: "Polish",
|
||||
cs: "Czech",
|
||||
nl: "Dutch",
|
||||
tr: "Turkish",
|
||||
uk: "Ukrainian",
|
||||
// Tier 3 - Emerging/Growing fast
|
||||
vi: "Vietnamese",
|
||||
zh: "Chinese (Simplified)",
|
||||
id: "Indonesian",
|
||||
th: "Thai",
|
||||
hi: "Hindi",
|
||||
bn: "Bengali",
|
||||
ro: "Romanian",
|
||||
sv: "Swedish",
|
||||
// Tier 4 - Why not
|
||||
it: "Italian",
|
||||
el: "Greek",
|
||||
hu: "Hungarian",
|
||||
fi: "Finnish",
|
||||
da: "Danish",
|
||||
no: "Norwegian",
|
||||
// Other supported
|
||||
bg: "Bulgarian",
|
||||
et: "Estonian",
|
||||
lt: "Lithuanian",
|
||||
lv: "Latvian",
|
||||
pt: "Portuguese",
|
||||
sk: "Slovak",
|
||||
sl: "Slovenian",
|
||||
"zh-tw": "Chinese (Traditional)",
|
||||
};
|
||||
|
||||
@@ -112,6 +122,8 @@ function parseArgs(argv: string[]): CliArgs {
|
||||
languages: [],
|
||||
preserveCode: true,
|
||||
verbose: false,
|
||||
force: false,
|
||||
parallel: 1,
|
||||
help: false,
|
||||
listLanguages: false,
|
||||
};
|
||||
@@ -134,6 +146,10 @@ function parseArgs(argv: string[]): CliArgs {
|
||||
case "--verbose":
|
||||
args.verbose = true;
|
||||
break;
|
||||
case "-f":
|
||||
case "--force":
|
||||
args.force = true;
|
||||
break;
|
||||
case "--no-preserve-code":
|
||||
args.preserveCode = false;
|
||||
break;
|
||||
@@ -152,6 +168,13 @@ function parseArgs(argv: string[]): CliArgs {
|
||||
case "--max-budget":
|
||||
args.maxBudget = parseFloat(argv[++i]);
|
||||
break;
|
||||
case "--parallel":
|
||||
args.parallel = parseInt(argv[++i], 10);
|
||||
if (isNaN(args.parallel) || args.parallel < 1) {
|
||||
console.error("Error: --parallel must be a positive integer");
|
||||
process.exit(1);
|
||||
}
|
||||
break;
|
||||
default:
|
||||
if (arg.startsWith("-")) {
|
||||
console.error(`Unknown option: ${arg}`);
|
||||
@@ -215,6 +238,8 @@ async function main(): Promise<void> {
|
||||
model: args.model,
|
||||
maxBudgetUsd: args.maxBudget,
|
||||
verbose: args.verbose,
|
||||
force: args.force,
|
||||
parallel: args.parallel,
|
||||
});
|
||||
|
||||
// Exit with error code if any translations failed
|
||||
|
||||
@@ -1,6 +1,34 @@
|
||||
import { query, type SDKMessage, type SDKResultMessage } from "@anthropic-ai/claude-agent-sdk";
|
||||
import * as fs from "fs/promises";
|
||||
import * as path from "path";
|
||||
import { createHash } from "crypto";
|
||||
|
||||
interface TranslationCache {
|
||||
sourceHash: string;
|
||||
lastUpdated: string;
|
||||
translations: Record<string, {
|
||||
hash: string;
|
||||
translatedAt: string;
|
||||
costUsd: number;
|
||||
}>;
|
||||
}
|
||||
|
||||
function hashContent(content: string): string {
|
||||
return createHash("sha256").update(content).digest("hex").slice(0, 16);
|
||||
}
|
||||
|
||||
async function readCache(cachePath: string): Promise<TranslationCache | null> {
|
||||
try {
|
||||
const data = await fs.readFile(cachePath, "utf-8");
|
||||
return JSON.parse(data);
|
||||
} catch {
|
||||
return null;
|
||||
}
|
||||
}
|
||||
|
||||
async function writeCache(cachePath: string, cache: TranslationCache): Promise<void> {
|
||||
await fs.writeFile(cachePath, JSON.stringify(cache, null, 2), "utf-8");
|
||||
}
|
||||
|
||||
export interface TranslationOptions {
|
||||
/** Source README file path */
|
||||
@@ -19,6 +47,10 @@ export interface TranslationOptions {
|
||||
maxBudgetUsd?: number;
|
||||
/** Verbose output */
|
||||
verbose?: boolean;
|
||||
/** Force re-translation even if cached */
|
||||
force?: boolean;
|
||||
/** Number of concurrent translations (default: 1) */
|
||||
parallel?: number;
|
||||
}
|
||||
|
||||
export interface TranslationResult {
|
||||
@@ -27,6 +59,8 @@ export interface TranslationResult {
|
||||
success: boolean;
|
||||
error?: string;
|
||||
costUsd?: number;
|
||||
/** Whether this was served from cache */
|
||||
cached?: boolean;
|
||||
}
|
||||
|
||||
export interface TranslationJobResult {
|
||||
@@ -37,40 +71,46 @@ export interface TranslationJobResult {
|
||||
}
|
||||
|
||||
const LANGUAGE_NAMES: Record<string, string> = {
|
||||
ar: "Arabic",
|
||||
bg: "Bulgarian",
|
||||
cs: "Czech",
|
||||
da: "Danish",
|
||||
de: "German",
|
||||
el: "Greek",
|
||||
es: "Spanish",
|
||||
et: "Estonian",
|
||||
fi: "Finnish",
|
||||
fr: "French",
|
||||
he: "Hebrew",
|
||||
hi: "Hindi",
|
||||
hu: "Hungarian",
|
||||
id: "Indonesian",
|
||||
it: "Italian",
|
||||
// Tier 1 - No-brainers
|
||||
zh: "Chinese (Simplified)",
|
||||
ja: "Japanese",
|
||||
ko: "Korean",
|
||||
lt: "Lithuanian",
|
||||
lv: "Latvian",
|
||||
nl: "Dutch",
|
||||
no: "Norwegian",
|
||||
pl: "Polish",
|
||||
pt: "Portuguese",
|
||||
"pt-br": "Brazilian Portuguese",
|
||||
ro: "Romanian",
|
||||
ko: "Korean",
|
||||
es: "Spanish",
|
||||
de: "German",
|
||||
fr: "French",
|
||||
// Tier 2 - Strong tech scenes
|
||||
he: "Hebrew",
|
||||
ar: "Arabic",
|
||||
ru: "Russian",
|
||||
sk: "Slovak",
|
||||
sl: "Slovenian",
|
||||
sv: "Swedish",
|
||||
th: "Thai",
|
||||
pl: "Polish",
|
||||
cs: "Czech",
|
||||
nl: "Dutch",
|
||||
tr: "Turkish",
|
||||
uk: "Ukrainian",
|
||||
// Tier 3 - Emerging/Growing fast
|
||||
vi: "Vietnamese",
|
||||
zh: "Chinese (Simplified)",
|
||||
id: "Indonesian",
|
||||
th: "Thai",
|
||||
hi: "Hindi",
|
||||
bn: "Bengali",
|
||||
ro: "Romanian",
|
||||
sv: "Swedish",
|
||||
// Tier 4 - Why not
|
||||
it: "Italian",
|
||||
el: "Greek",
|
||||
hu: "Hungarian",
|
||||
fi: "Finnish",
|
||||
da: "Danish",
|
||||
no: "Norwegian",
|
||||
// Other supported
|
||||
bg: "Bulgarian",
|
||||
et: "Estonian",
|
||||
lt: "Lithuanian",
|
||||
lv: "Latvian",
|
||||
pt: "Portuguese",
|
||||
sk: "Slovak",
|
||||
sl: "Slovenian",
|
||||
"zh-tw": "Chinese (Traditional)",
|
||||
};
|
||||
|
||||
@@ -107,6 +147,7 @@ Guidelines:
|
||||
- Preserve technical accuracy
|
||||
- Use appropriate technical terminology for ${languageName}
|
||||
- Keep proper nouns (product names, company names) unchanged unless they have official translations
|
||||
- Add a small note at the very top of the document (before any other content) in ${languageName}: "🌐 This is an automated translation. Community corrections are welcome!"
|
||||
|
||||
Here is the README content to translate:
|
||||
|
||||
@@ -114,7 +155,12 @@ Here is the README content to translate:
|
||||
${content}
|
||||
---
|
||||
|
||||
Output ONLY the translated README content, nothing else. Do not include any preamble or explanation.`;
|
||||
CRITICAL OUTPUT RULES:
|
||||
- Output ONLY the raw translated markdown content
|
||||
- Do NOT wrap output in \`\`\`markdown code fences
|
||||
- Do NOT add any preamble, explanation, or commentary
|
||||
- Start directly with the translation note, then the content
|
||||
- The output will be saved directly to a .md file`;
|
||||
|
||||
let translation = "";
|
||||
let costUsd = 0;
|
||||
@@ -182,7 +228,21 @@ Always output only the translated content without any surrounding explanation.`,
|
||||
process.stdout.write("\r" + " ".repeat(60) + "\r");
|
||||
}
|
||||
|
||||
return { translation: translation.trim(), costUsd };
|
||||
// Strip markdown code fences if Claude wrapped the output
|
||||
let cleaned = translation.trim();
|
||||
if (cleaned.startsWith("```markdown")) {
|
||||
cleaned = cleaned.slice("```markdown".length);
|
||||
} else if (cleaned.startsWith("```md")) {
|
||||
cleaned = cleaned.slice("```md".length);
|
||||
} else if (cleaned.startsWith("```")) {
|
||||
cleaned = cleaned.slice(3);
|
||||
}
|
||||
if (cleaned.endsWith("```")) {
|
||||
cleaned = cleaned.slice(0, -3);
|
||||
}
|
||||
cleaned = cleaned.trim();
|
||||
|
||||
return { translation: cleaned, costUsd };
|
||||
}
|
||||
|
||||
export async function translateReadme(
|
||||
@@ -197,6 +257,8 @@ export async function translateReadme(
|
||||
model,
|
||||
maxBudgetUsd,
|
||||
verbose = false,
|
||||
force = false,
|
||||
parallel = 1,
|
||||
} = options;
|
||||
|
||||
// Read source file
|
||||
@@ -207,6 +269,12 @@ export async function translateReadme(
|
||||
const outDir = outputDir ? path.resolve(outputDir) : path.dirname(sourcePath);
|
||||
await fs.mkdir(outDir, { recursive: true });
|
||||
|
||||
// Compute content hash and load cache
|
||||
const sourceHash = hashContent(content);
|
||||
const cachePath = path.join(outDir, ".translation-cache.json");
|
||||
const cache = await readCache(cachePath);
|
||||
const isHashMatch = cache?.sourceHash === sourceHash;
|
||||
|
||||
const results: TranslationResult[] = [];
|
||||
let totalCostUsd = 0;
|
||||
|
||||
@@ -214,24 +282,28 @@ export async function translateReadme(
|
||||
console.log(`📖 Source: ${sourcePath}`);
|
||||
console.log(`📂 Output: ${outDir}`);
|
||||
console.log(`🌍 Languages: ${languages.join(", ")}`);
|
||||
if (parallel > 1) {
|
||||
console.log(`⚡ Parallel: ${parallel} concurrent translations`);
|
||||
}
|
||||
console.log("");
|
||||
}
|
||||
|
||||
for (const lang of languages) {
|
||||
// Check budget
|
||||
if (maxBudgetUsd && totalCostUsd >= maxBudgetUsd) {
|
||||
results.push({
|
||||
language: lang,
|
||||
outputPath: "",
|
||||
success: false,
|
||||
error: "Budget exceeded",
|
||||
});
|
||||
continue;
|
||||
}
|
||||
|
||||
// Worker function for a single language
|
||||
async function translateLang(lang: string): Promise<TranslationResult> {
|
||||
const outputFilename = pattern.replace("{lang}", lang);
|
||||
const outputPath = path.join(outDir, outputFilename);
|
||||
|
||||
// Check cache (unless --force)
|
||||
if (!force && isHashMatch && cache?.translations[lang]) {
|
||||
const outputExists = await fs.access(outputPath).then(() => true).catch(() => false);
|
||||
if (outputExists) {
|
||||
if (verbose) {
|
||||
console.log(` ✅ ${outputFilename} (cached, unchanged)`);
|
||||
}
|
||||
return { language: lang, outputPath, success: true, cached: true, costUsd: 0 };
|
||||
}
|
||||
}
|
||||
|
||||
if (verbose) {
|
||||
console.log(`🔄 Translating to ${getLanguageName(lang)} (${lang})...`);
|
||||
}
|
||||
@@ -240,37 +312,81 @@ export async function translateReadme(
|
||||
const { translation, costUsd } = await translateToLanguage(content, lang, {
|
||||
preserveCode,
|
||||
model,
|
||||
verbose,
|
||||
verbose: verbose && parallel === 1, // Only show progress spinner for sequential
|
||||
});
|
||||
|
||||
await fs.writeFile(outputPath, translation, "utf-8");
|
||||
totalCostUsd += costUsd;
|
||||
|
||||
results.push({
|
||||
language: lang,
|
||||
outputPath,
|
||||
success: true,
|
||||
costUsd,
|
||||
});
|
||||
|
||||
if (verbose) {
|
||||
console.log(` ✅ Saved to ${outputFilename} ($${costUsd.toFixed(4)})`);
|
||||
}
|
||||
|
||||
return { language: lang, outputPath, success: true, costUsd };
|
||||
} catch (error) {
|
||||
const errorMessage = error instanceof Error ? error.message : String(error);
|
||||
results.push({
|
||||
language: lang,
|
||||
outputPath,
|
||||
success: false,
|
||||
error: errorMessage,
|
||||
});
|
||||
|
||||
if (verbose) {
|
||||
console.log(` ❌ Failed: ${errorMessage}`);
|
||||
console.log(` ❌ ${lang} failed: ${errorMessage}`);
|
||||
}
|
||||
return { language: lang, outputPath, success: false, error: errorMessage };
|
||||
}
|
||||
}
|
||||
|
||||
// Run with concurrency limit
|
||||
async function runWithConcurrency<T>(items: T[], limit: number, fn: (item: T) => Promise<TranslationResult>): Promise<TranslationResult[]> {
|
||||
const results: TranslationResult[] = [];
|
||||
const executing: Promise<void>[] = [];
|
||||
|
||||
for (const item of items) {
|
||||
// Check budget before starting new translation
|
||||
if (maxBudgetUsd && totalCostUsd >= maxBudgetUsd) {
|
||||
results.push({
|
||||
language: String(item),
|
||||
outputPath: "",
|
||||
success: false,
|
||||
error: "Budget exceeded",
|
||||
});
|
||||
continue;
|
||||
}
|
||||
|
||||
const p = fn(item).then((result) => {
|
||||
results.push(result);
|
||||
if (result.costUsd) {
|
||||
totalCostUsd += result.costUsd;
|
||||
}
|
||||
});
|
||||
|
||||
executing.push(p.then(() => {
|
||||
executing.splice(executing.indexOf(p.then(() => {})), 1);
|
||||
}));
|
||||
|
||||
if (executing.length >= limit) {
|
||||
await Promise.race(executing);
|
||||
}
|
||||
}
|
||||
|
||||
await Promise.all(executing);
|
||||
return results;
|
||||
}
|
||||
|
||||
const translationResults = await runWithConcurrency(languages, parallel, translateLang);
|
||||
results.push(...translationResults);
|
||||
|
||||
// Save updated cache
|
||||
const newCache: TranslationCache = {
|
||||
sourceHash,
|
||||
lastUpdated: new Date().toISOString(),
|
||||
translations: {
|
||||
...(isHashMatch ? cache?.translations : {}),
|
||||
...Object.fromEntries(
|
||||
results.filter(r => r.success && !r.cached).map(r => [
|
||||
r.language,
|
||||
{ hash: sourceHash, translatedAt: new Date().toISOString(), costUsd: r.costUsd || 0 }
|
||||
])
|
||||
),
|
||||
},
|
||||
};
|
||||
await writeCache(cachePath, newCache);
|
||||
|
||||
const successful = results.filter((r) => r.success).length;
|
||||
const failed = results.filter((r) => !r.success).length;
|
||||
|
||||
|
||||
+100
-26
@@ -60,9 +60,18 @@ export class WorkerService {
|
||||
private searchRoutes: SearchRoutes | null;
|
||||
private settingsRoutes: SettingsRoutes;
|
||||
|
||||
// Initialization tracking
|
||||
private initializationComplete: Promise<void>;
|
||||
private resolveInitialization!: () => void;
|
||||
|
||||
constructor() {
|
||||
this.app = express();
|
||||
|
||||
// Initialize the promise that will resolve when background initialization completes
|
||||
this.initializationComplete = new Promise((resolve) => {
|
||||
this.resolveInitialization = resolve;
|
||||
});
|
||||
|
||||
// Initialize domain services
|
||||
this.dbManager = new DatabaseManager();
|
||||
this.sessionManager = new SessionManager(this.dbManager);
|
||||
@@ -155,6 +164,60 @@ export class WorkerService {
|
||||
this.dataRoutes.setupRoutes(this.app);
|
||||
// searchRoutes is set up after database initialization in initializeBackground()
|
||||
this.settingsRoutes.setupRoutes(this.app);
|
||||
|
||||
// Register early handler for /api/context/inject to avoid 404 during startup
|
||||
// This handler waits for initialization to complete before delegating to SearchRoutes
|
||||
// NOTE: This duplicates logic from SearchRoutes.handleContextInject by design,
|
||||
// as we need the route available immediately before SearchRoutes is initialized
|
||||
this.app.get('/api/context/inject', async (req, res, next) => {
|
||||
try {
|
||||
// Wait for initialization to complete (with timeout)
|
||||
const timeoutMs = 30000; // 30 second timeout
|
||||
const timeoutPromise = new Promise((_, reject) =>
|
||||
setTimeout(() => reject(new Error('Initialization timeout')), timeoutMs)
|
||||
);
|
||||
|
||||
await Promise.race([this.initializationComplete, timeoutPromise]);
|
||||
|
||||
// If searchRoutes is still null after initialization, something went wrong
|
||||
if (!this.searchRoutes) {
|
||||
res.status(503).json({ error: 'Search routes not initialized' });
|
||||
return;
|
||||
}
|
||||
|
||||
// Delegate to the proper handler by re-processing the request
|
||||
// Since we're already in the middleware chain, we need to call the handler directly
|
||||
const projectName = req.query.project as string;
|
||||
const useColors = req.query.colors === 'true';
|
||||
|
||||
if (!projectName) {
|
||||
res.status(400).json({ error: 'Project parameter is required' });
|
||||
return;
|
||||
}
|
||||
|
||||
// Import context generator (runs in worker, has access to database)
|
||||
const { generateContext } = await import('./context-generator.js');
|
||||
|
||||
// Use project name as CWD (generateContext uses path.basename to get project)
|
||||
const cwd = `/context/${projectName}`;
|
||||
|
||||
// Generate context
|
||||
const contextText = await generateContext(
|
||||
{
|
||||
session_id: 'context-inject-' + Date.now(),
|
||||
cwd: cwd
|
||||
},
|
||||
useColors
|
||||
);
|
||||
|
||||
// Return as plain text
|
||||
res.setHeader('Content-Type', 'text/plain; charset=utf-8');
|
||||
res.send(contextText);
|
||||
} catch (error) {
|
||||
logger.error('WORKER', 'Context inject handler failed', {}, error as Error);
|
||||
res.status(500).json({ error: error instanceof Error ? error.message : 'Internal server error' });
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
|
||||
@@ -228,36 +291,47 @@ export class WorkerService {
|
||||
* Background initialization - runs after HTTP server is listening
|
||||
*/
|
||||
private async initializeBackground(): Promise<void> {
|
||||
// Clean up any orphaned chroma-mcp processes BEFORE starting our own
|
||||
await this.cleanupOrphanedProcesses();
|
||||
try {
|
||||
// Clean up any orphaned chroma-mcp processes BEFORE starting our own
|
||||
await this.cleanupOrphanedProcesses();
|
||||
|
||||
// Initialize database (once, stays open)
|
||||
await this.dbManager.initialize();
|
||||
// Initialize database (once, stays open)
|
||||
await this.dbManager.initialize();
|
||||
|
||||
// Initialize search services (requires initialized database)
|
||||
const formattingService = new FormattingService();
|
||||
const timelineService = new TimelineService();
|
||||
const searchManager = new SearchManager(
|
||||
this.dbManager.getSessionSearch(),
|
||||
this.dbManager.getSessionStore(),
|
||||
this.dbManager.getChromaSync(),
|
||||
formattingService,
|
||||
timelineService
|
||||
);
|
||||
this.searchRoutes = new SearchRoutes(searchManager);
|
||||
this.searchRoutes.setupRoutes(this.app); // Setup search routes now that SearchManager is ready
|
||||
logger.info('WORKER', 'SearchManager initialized and search routes registered');
|
||||
// Initialize search services (requires initialized database)
|
||||
const formattingService = new FormattingService();
|
||||
const timelineService = new TimelineService();
|
||||
const searchManager = new SearchManager(
|
||||
this.dbManager.getSessionSearch(),
|
||||
this.dbManager.getSessionStore(),
|
||||
this.dbManager.getChromaSync(),
|
||||
formattingService,
|
||||
timelineService
|
||||
);
|
||||
this.searchRoutes = new SearchRoutes(searchManager);
|
||||
this.searchRoutes.setupRoutes(this.app); // Setup search routes now that SearchManager is ready
|
||||
logger.info('WORKER', 'SearchManager initialized and search routes registered');
|
||||
|
||||
// Connect to MCP server
|
||||
const mcpServerPath = path.join(__dirname, 'mcp-server.cjs');
|
||||
const transport = new StdioClientTransport({
|
||||
command: 'node',
|
||||
args: [mcpServerPath],
|
||||
env: process.env
|
||||
});
|
||||
// Connect to MCP server
|
||||
const mcpServerPath = path.join(__dirname, 'mcp-server.cjs');
|
||||
const transport = new StdioClientTransport({
|
||||
command: 'node',
|
||||
args: [mcpServerPath],
|
||||
env: process.env
|
||||
});
|
||||
|
||||
await this.mcpClient.connect(transport);
|
||||
logger.success('WORKER', 'Connected to MCP server');
|
||||
await this.mcpClient.connect(transport);
|
||||
logger.success('WORKER', 'Connected to MCP server');
|
||||
|
||||
// Signal that initialization is complete
|
||||
this.resolveInitialization();
|
||||
logger.info('SYSTEM', 'Background initialization complete');
|
||||
} catch (error) {
|
||||
logger.error('SYSTEM', 'Background initialization failed', {}, error as Error);
|
||||
// Still resolve to prevent hanging requests, but they'll see searchRoutes is null
|
||||
this.resolveInitialization();
|
||||
throw error;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
|
||||
@@ -45,7 +45,8 @@ export function getWorkerRestartInstructions(
|
||||
message += `1. Exit Claude Code completely\n`;
|
||||
message += `2. Open ${terminal}\n`;
|
||||
message += `3. Navigate to: ${pluginDir}\n`;
|
||||
message += `4. Run: npm run worker:restart`;
|
||||
message += `4. Run: npm run worker:restart\n`;
|
||||
message += `5. Restart Claude Code`;
|
||||
|
||||
if (includeSkillFallback) {
|
||||
message += `\n\nIf that doesn't work, try: /troubleshoot`;
|
||||
|
||||
@@ -0,0 +1,53 @@
|
||||
/**
|
||||
* Integration Test: Context Inject Early Access
|
||||
*
|
||||
* Tests that /api/context/inject endpoint is available immediately
|
||||
* when worker starts, even before background initialization completes.
|
||||
*
|
||||
* This prevents the 404 error described in the issue where the hook
|
||||
* tries to access the endpoint before SearchRoutes are registered.
|
||||
*/
|
||||
import { describe, it, expect } from 'vitest';
|
||||
import fs from 'fs';
|
||||
import path from 'path';
|
||||
|
||||
describe('Context Inject Early Access', () => {
|
||||
const workerPath = path.join(__dirname, '../../plugin/scripts/worker-service.cjs');
|
||||
|
||||
it('should have /api/context/inject route available immediately on startup', async () => {
|
||||
// This test verifies the fix by checking that:
|
||||
// 1. The route exists immediately (no 404)
|
||||
// 2. The route waits for initialization before processing
|
||||
// 3. Requests don't fail with "Cannot GET /api/context/inject"
|
||||
|
||||
// The fix adds an early handler that:
|
||||
// - Registers the route in setupRoutes() (called during construction)
|
||||
// - Waits for initializationComplete promise
|
||||
// - Processes the request after initialization
|
||||
|
||||
// Since we can't easily spin up a full worker in tests,
|
||||
// we verify the code structure is correct by checking
|
||||
// the compiled output contains the necessary pieces
|
||||
|
||||
const workerCode = fs.readFileSync(workerPath, 'utf-8');
|
||||
|
||||
// Verify initialization promise exists
|
||||
expect(workerCode).toContain('initializationComplete');
|
||||
expect(workerCode).toContain('resolveInitialization');
|
||||
|
||||
// Verify early route handler is registered in setupRoutes
|
||||
expect(workerCode).toContain('/api/context/inject');
|
||||
expect(workerCode).toContain('Promise.race');
|
||||
|
||||
// Verify the promise is resolved after initialization
|
||||
expect(workerCode).toContain('this.resolveInitialization()');
|
||||
});
|
||||
|
||||
it('should handle timeout if initialization takes too long', () => {
|
||||
const workerCode = fs.readFileSync(workerPath, 'utf-8');
|
||||
|
||||
// Verify timeout protection (30 seconds)
|
||||
expect(workerCode).toContain('3e4'); // 30000 in scientific notation
|
||||
expect(workerCode).toContain('Initialization timeout');
|
||||
});
|
||||
});
|
||||
Reference in New Issue
Block a user