Something went wrong. Try again.
Monorepo for Aesthetic.Computer aesthetic.computer
Something went wrong. Try again.
JavaScript
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393#!/usr/bin/env node/** * 🎹 DAW Debug - CDP bridge for M4L jweb~ debugging * * Connects to the Chrome DevTools Protocol exposed by Max's jweb~ * and forwards console logs to artery-tui or stdout. * * Usage: * node daw-debug.mjs # Connect and show console logs * node daw-debug.mjs --json # Output as JSON (for piping) * node daw-debug.mjs --eval "code" # Evaluate JS in jweb~ */
import WebSocket from 'ws';import http from 'http';
const RESET = '\x1b[0m';const BOLD = '\x1b[1m';const DIM = '\x1b[2m';const FG_RED = '\x1b[31m';const FG_GREEN = '\x1b[32m';const FG_YELLOW = '\x1b[33m';const FG_BLUE = '\x1b[34m';const FG_MAGENTA = '\x1b[35m';const FG_CYAN = '\x1b[36m';const FG_GRAY = '\x1b[90m';
// Default port for jweb~ CDP (can be overridden)const DAW_CDP_PORT = parseInt(process.env.DAW_CDP_PORT || '9229');
// Check if we're in a containerconst IN_CONTAINER = process.env.REMOTE_CONTAINERS === 'true' || process.env.CODESPACES === 'true' || process.env.container === 'true';
// Try multiple hostsconst CDP_HOSTS = IN_CONTAINER ? ['host.docker.internal', '172.17.0.1', 'localhost'] : ['localhost', '127.0.0.1'];
class DAWDebugger { constructor(options = {}) { this.ws = null; this.msgId = 1; this.pending = new Map(); this.host = null; this.port = DAW_CDP_PORT; this.connected = false; this.targetInfo = null; this.jsonOutput = options.json || false; this.onLog = options.onLog || this.defaultLogHandler.bind(this); this.onConnect = options.onConnect || (() => {}); this.onDisconnect = options.onDisconnect || (() => {}); }
log(msg) { if (!this.jsonOutput) { console.log(msg); } }
defaultLogHandler(entry) { const { type, text, timestamp, source } = entry; const time = new Date(timestamp).toLocaleTimeString('en-US', { hour12: false, hour: '2-digit', minute: '2-digit', second: '2-digit', fractionalSecondDigits: 3 }); if (this.jsonOutput) { console.log(JSON.stringify(entry)); return; }
let color = FG_GRAY; let prefix = ' '; switch (type) { case 'error': color = FG_RED; prefix = '❌'; break; case 'warning': color = FG_YELLOW; prefix = '⚠️ '; break; case 'info': color = FG_CYAN; prefix = 'ℹ️ '; break; case 'log': color = FG_GREEN; prefix = '📝'; break; case 'debug': color = FG_MAGENTA; prefix = '🔍'; break; }
const sourceTag = source ? `${FG_GRAY}[${source}]${RESET} ` : ''; console.log(`${DIM}${time}${RESET} ${prefix} ${sourceTag}${color}${text}${RESET}`); }
async findCDPHost() { for (const host of CDP_HOSTS) { try { const targets = await this.fetchTargets(host, this.port); if (targets && targets.length > 0) { return { host, targets }; } } catch (e) { // Try next host } } return null; }
fetchTargets(host, port) { return new Promise((resolve, reject) => { const req = http.get({ hostname: host, port: port, path: '/json', timeout: 2000, headers: { 'Host': 'localhost' } // Required for CDP }, (res) => { let data = ''; res.on('data', chunk => data += chunk); res.on('end', () => { try { resolve(JSON.parse(data)); } catch (e) { reject(e); } }); }); req.on('error', reject); req.on('timeout', () => { req.destroy(); reject(new Error('Timeout')); }); }); }
async connect() { this.log(`${FG_CYAN}🎹 DAW Debug - Searching for jweb~ on port ${this.port}...${RESET}`); const result = await this.findCDPHost(); if (!result) { this.log(`${FG_RED}❌ No jweb~ CDP found on port ${this.port}${RESET}`); this.log(`${FG_YELLOW} Make sure Ableton is running with an AC M4L device loaded${RESET}`); return false; }
const { host, targets } = result; this.host = host; // Find the page target (should be metronome or other AC piece) const pageTarget = targets.find(t => t.type === 'page'); if (!pageTarget) { this.log(`${FG_RED}❌ No page target found in CDP${RESET}`); return false; }
this.targetInfo = pageTarget; this.log(`${FG_GREEN}✓ Found: ${pageTarget.title}${RESET}`); this.log(`${FG_GRAY} URL: ${pageTarget.url}${RESET}`); // Build WebSocket URL let wsUrl = pageTarget.webSocketDebuggerUrl; if (wsUrl.includes('localhost') && host !== 'localhost') { // Fix host in WebSocket URL for container access wsUrl = wsUrl.replace(/ws:\/\/localhost/, `ws://${host}:${this.port}`); } this.log(`${FG_GRAY} Connecting to: ${wsUrl}${RESET}`); return new Promise((resolve, reject) => { this.ws = new WebSocket(wsUrl); this.ws.on('open', async () => { this.connected = true; this.log(`${FG_GREEN}✓ Connected to jweb~ debugger${RESET}\n`); // Enable console and runtime await this.send('Runtime.enable'); await this.send('Console.enable'); await this.send('Log.enable'); this.onConnect(this.targetInfo); resolve(true); }); this.ws.on('message', (data) => { const msg = JSON.parse(data.toString()); // Handle pending responses if (msg.id && this.pending.has(msg.id)) { this.pending.get(msg.id)(msg); this.pending.delete(msg.id); return; } // Handle events this.handleEvent(msg); }); this.ws.on('close', () => { this.connected = false; this.log(`${FG_YELLOW}⚠️ Disconnected from jweb~${RESET}`); this.onDisconnect(); }); this.ws.on('error', (err) => { this.log(`${FG_RED}❌ WebSocket error: ${err.message}${RESET}`); reject(err); }); setTimeout(() => reject(new Error('Connection timeout')), 5000); }); }
handleEvent(msg) { if (!msg.method) return; switch (msg.method) { case 'Console.messageAdded': { const m = msg.params.message; this.onLog({ type: m.level, text: m.text, timestamp: Date.now(), source: m.source, url: m.url, line: m.line }); break; } case 'Runtime.consoleAPICalled': { const { type, args, timestamp } = msg.params; const text = args.map(a => { if (a.type === 'string') return a.value; if (a.type === 'number') return a.value; if (a.type === 'boolean') return a.value; if (a.type === 'undefined') return 'undefined'; if (a.type === 'object' && a.preview) { return JSON.stringify(a.preview.properties?.reduce((acc, p) => { acc[p.name] = p.value; return acc; }, {}) || a.description); } return a.description || a.value || `[${a.type}]`; }).join(' '); this.onLog({ type, text, timestamp: timestamp / 1000, // Convert from microseconds source: 'console' }); break; } case 'Runtime.exceptionThrown': { const { exceptionDetails } = msg.params; this.onLog({ type: 'error', text: exceptionDetails.text + (exceptionDetails.exception?.description || ''), timestamp: Date.now(), source: 'exception', url: exceptionDetails.url, line: exceptionDetails.lineNumber }); break; } case 'Log.entryAdded': { const { entry } = msg.params; this.onLog({ type: entry.level, text: entry.text, timestamp: entry.timestamp, source: entry.source, url: entry.url }); break; } } }
send(method, params = {}) { return new Promise((resolve, reject) => { if (!this.ws || !this.connected) { reject(new Error('Not connected')); return; } const id = this.msgId++; const timer = setTimeout(() => { this.pending.delete(id); reject(new Error('Timeout')); }, 10000); this.pending.set(id, (msg) => { clearTimeout(timer); if (msg.error) { reject(new Error(msg.error.message)); } else { resolve(msg.result); } }); this.ws.send(JSON.stringify({ id, method, params })); }); }
async evaluate(expression) { const result = await this.send('Runtime.evaluate', { expression, returnByValue: true, awaitPromise: true }); return result.result?.value; }
async getDAWState() { return this.evaluate(` (function() { if (typeof $commonApi !== 'undefined' && $commonApi.sound) { const daw = $commonApi.sound.daw; return daw ? { bpm: daw.bpm, playing: daw.playing, time: daw.time, sampleRate: daw.sampleRate } : null; } return null; })() `); }
disconnect() { if (this.ws) { this.ws.close(); this.ws = null; } this.connected = false; }}
// CLI usageif (import.meta.url === `file://${process.argv[1]}`) { const args = process.argv.slice(2); const jsonOutput = args.includes('--json'); const evalCode = args.includes('--eval') ? args[args.indexOf('--eval') + 1] : null; const stateCheck = args.includes('--state'); const debugger_ = new DAWDebugger({ json: jsonOutput }); try { await debugger_.connect(); if (evalCode) { // One-shot eval const result = await debugger_.evaluate(evalCode); console.log(jsonOutput ? JSON.stringify(result) : result); debugger_.disconnect(); process.exit(0); } else if (stateCheck) { // One-shot state check const state = await debugger_.getDAWState(); console.log(jsonOutput ? JSON.stringify(state) : state); debugger_.disconnect(); process.exit(0); } else { // Stream console logs console.log(`${FG_CYAN}📡 Streaming console logs from jweb~... (Ctrl+C to stop)${RESET}\n`); // Keep process alive process.on('SIGINT', () => { debugger_.disconnect(); process.exit(0); }); } } catch (err) { console.error(`${FG_RED}Error: ${err.message}${RESET}`); process.exit(1); }}
export default DAWDebugger;