Major changes: - Organized Python v1 implementation into v1/ subdirectory - Created Rust workspace with 9 modular crates: - wifi-densepose-core: Core types, traits, errors - wifi-densepose-signal: CSI processing, phase sanitization, FFT - wifi-densepose-nn: Neural network inference (ONNX/Candle/tch) - wifi-densepose-api: Axum-based REST/WebSocket API - wifi-densepose-db: SQLx database layer - wifi-densepose-config: Configuration management - wifi-densepose-hardware: Hardware abstraction - wifi-densepose-wasm: WebAssembly bindings - wifi-densepose-cli: Command-line interface Documentation: - ADR-001: Workspace structure - ADR-002: Signal processing library selection - ADR-003: Neural network inference strategy - DDD domain model with bounded contexts Testing: - 69 tests passing across all crates - Signal processing: 45 tests - Neural networks: 21 tests - Core: 3 doc tests Performance targets: - 10x faster CSI processing (~0.5ms vs ~5ms) - 5x lower memory usage (~100MB vs ~500MB) - WASM support for browser deployment
128 lines
3.4 KiB
JavaScript
128 lines
3.4 KiB
JavaScript
#!/usr/bin/env node
|
|
/**
|
|
* Claude Flow Session Manager
|
|
* Handles session lifecycle: start, restore, end
|
|
*/
|
|
|
|
const fs = require('fs');
|
|
const path = require('path');
|
|
|
|
const SESSION_DIR = path.join(process.cwd(), '.claude-flow', 'sessions');
|
|
const SESSION_FILE = path.join(SESSION_DIR, 'current.json');
|
|
|
|
const commands = {
|
|
start: () => {
|
|
const sessionId = `session-${Date.now()}`;
|
|
const session = {
|
|
id: sessionId,
|
|
startedAt: new Date().toISOString(),
|
|
cwd: process.cwd(),
|
|
context: {},
|
|
metrics: {
|
|
edits: 0,
|
|
commands: 0,
|
|
tasks: 0,
|
|
errors: 0,
|
|
},
|
|
};
|
|
|
|
fs.mkdirSync(SESSION_DIR, { recursive: true });
|
|
fs.writeFileSync(SESSION_FILE, JSON.stringify(session, null, 2));
|
|
|
|
console.log(`Session started: ${sessionId}`);
|
|
return session;
|
|
},
|
|
|
|
restore: () => {
|
|
if (!fs.existsSync(SESSION_FILE)) {
|
|
console.log('No session to restore');
|
|
return null;
|
|
}
|
|
|
|
const session = JSON.parse(fs.readFileSync(SESSION_FILE, 'utf-8'));
|
|
session.restoredAt = new Date().toISOString();
|
|
fs.writeFileSync(SESSION_FILE, JSON.stringify(session, null, 2));
|
|
|
|
console.log(`Session restored: ${session.id}`);
|
|
return session;
|
|
},
|
|
|
|
end: () => {
|
|
if (!fs.existsSync(SESSION_FILE)) {
|
|
console.log('No active session');
|
|
return null;
|
|
}
|
|
|
|
const session = JSON.parse(fs.readFileSync(SESSION_FILE, 'utf-8'));
|
|
session.endedAt = new Date().toISOString();
|
|
session.duration = Date.now() - new Date(session.startedAt).getTime();
|
|
|
|
// Archive session
|
|
const archivePath = path.join(SESSION_DIR, `${session.id}.json`);
|
|
fs.writeFileSync(archivePath, JSON.stringify(session, null, 2));
|
|
fs.unlinkSync(SESSION_FILE);
|
|
|
|
console.log(`Session ended: ${session.id}`);
|
|
console.log(`Duration: ${Math.round(session.duration / 1000 / 60)} minutes`);
|
|
console.log(`Metrics: ${JSON.stringify(session.metrics)}`);
|
|
|
|
return session;
|
|
},
|
|
|
|
status: () => {
|
|
if (!fs.existsSync(SESSION_FILE)) {
|
|
console.log('No active session');
|
|
return null;
|
|
}
|
|
|
|
const session = JSON.parse(fs.readFileSync(SESSION_FILE, 'utf-8'));
|
|
const duration = Date.now() - new Date(session.startedAt).getTime();
|
|
|
|
console.log(`Session: ${session.id}`);
|
|
console.log(`Started: ${session.startedAt}`);
|
|
console.log(`Duration: ${Math.round(duration / 1000 / 60)} minutes`);
|
|
console.log(`Metrics: ${JSON.stringify(session.metrics)}`);
|
|
|
|
return session;
|
|
},
|
|
|
|
update: (key, value) => {
|
|
if (!fs.existsSync(SESSION_FILE)) {
|
|
console.log('No active session');
|
|
return null;
|
|
}
|
|
|
|
const session = JSON.parse(fs.readFileSync(SESSION_FILE, 'utf-8'));
|
|
session.context[key] = value;
|
|
session.updatedAt = new Date().toISOString();
|
|
fs.writeFileSync(SESSION_FILE, JSON.stringify(session, null, 2));
|
|
|
|
return session;
|
|
},
|
|
|
|
metric: (name) => {
|
|
if (!fs.existsSync(SESSION_FILE)) {
|
|
return null;
|
|
}
|
|
|
|
const session = JSON.parse(fs.readFileSync(SESSION_FILE, 'utf-8'));
|
|
if (session.metrics[name] !== undefined) {
|
|
session.metrics[name]++;
|
|
fs.writeFileSync(SESSION_FILE, JSON.stringify(session, null, 2));
|
|
}
|
|
|
|
return session;
|
|
},
|
|
};
|
|
|
|
// CLI
|
|
const [,, command, ...args] = process.argv;
|
|
|
|
if (command && commands[command]) {
|
|
commands[command](...args);
|
|
} else {
|
|
console.log('Usage: session.js <start|restore|end|status|update|metric> [args]');
|
|
}
|
|
|
|
module.exports = commands;
|