Workspace API

// Get workspace context for the UI
interface WorkspaceContext {
cwd: string;
platform: string;
arch: string;
nodeVersion: string;
homedir: string;
}

const context: WorkspaceContext = await fetch('/api/workspace/context')
.then((r: Response) => r.json());

console.log(`CWD: ${context.cwd}`);
console.log(`Platform: ${context.platform} (${context.arch})`);
console.log(`Node: ${context.nodeVersion}`);
console.log(`Home: ${context.homedir}`);

// Discover project directories
interface DiscoveredProject {
path: string;
name: string;
markers: string[];
alreadyImported: boolean;
}

const { projects }: { projects: DiscoveredProject[] } = await fetch('/api/workspace/discover', {
method: 'POST',
headers: { 'Content-Type': 'application/json' },
body: JSON.stringify({
  parentDir: '~/Developer',
  maxDepth: 2,
}),
}).then((r: Response) => r.json());

// Show discovered projects, highlighting new ones
projects.forEach((p: DiscoveredProject) => {
const status: string = p.alreadyImported ? 'imported' : 'NEW';
console.log(`[${status}] ${p.name} — ${p.path} (${p.markers.join(', ')})`);
});

const newProjects: DiscoveredProject[] = projects.filter((p) => !p.alreadyImported);
console.log(`${newProjects.length} new projects ready to import`);

// Apply data-dir isolation for a domain clone — run once after cloning
const res: Response = await fetch('http://localhost:3000/api/workspace/fix-data-dir', {
method: 'POST',
});

if (res.ok) {
const result: { success: boolean; dataDir: string; envLocalPath: string; needsRestart: boolean } =
  await res.json();
console.log(`Data dir set to: ${result.dataDir}`);
console.log(`Updated: ${result.envLocalPath}`);
if (result.needsRestart) {
  console.log('Restart the dev server to activate the new database path');
}
} else {
const { error }: { error: string } = await res.json();
console.error(`Fix not needed: ${error}`);
}

// Import projects with streamed progress
const res: Response = await fetch('/api/workspace/import', {
method: 'POST',
headers: { 'Content-Type': 'application/json' },
body: JSON.stringify({
  projects: [
    { path: '/Users/team/Developer/my-app', name: 'My App' },
    { path: '/Users/team/Developer/rust-cli', name: 'Rust CLI' },
  ],
}),
});

// Read the SSE stream
const reader: ReadableStreamDefaultReader<Uint8Array> = res.body!.getReader();
const decoder: TextDecoder = new TextDecoder();

while (true) {
const { done, value } = await reader.read();
if (done) break;

const text: string = decoder.decode(value);
for (const line of text.split('\n')) {
  if (line.startsWith('data: ')) {
    const event: Record<string, unknown> = JSON.parse(line.slice(6));

    if (event.type === 'progress') {
      if (event.status === 'creating') {
        console.log(`Importing ${event.name}...`);
      } else if (event.status === 'done') {
        console.log(`  Done: ${event.projectId} (${event.artifactCount} artifacts)`);
      } else if (event.status === 'failed') {
        console.error(`  Failed: ${event.error}`);
      }
    } else if (event.type === 'complete') {
      console.log(`Import complete: ${event.created} created, ${event.failed} failed`);
    }
  }
}
}