import { DAG } from '@ruvector/rudag';

const dag = new DAG();

// Add nodes
dag.addNode('compile', { weight: 10, label: 'Compile source' });
dag.addNode('test', { weight: 5, label: 'Run tests' });
dag.addNode('deploy', { weight: 3, label: 'Deploy' });

// Add edges (dependencies)
dag.addEdge('compile', 'test');   // test depends on compile
dag.addEdge('test', 'deploy');    // deploy depends on test

// Remove
dag.removeNode('deploy');
dag.removeEdge('compile', 'test');

// Query
const hasNode = dag.hasNode('compile');   // true
const hasEdge = dag.hasEdge('compile', 'test'); // true

// Topological sort
const order = dag.topologicalSort();   // ['compile', 'test', 'deploy']

// Critical path (longest path through weighted DAG)
const path = dag.criticalPath();
// { path: ['compile', 'test', 'deploy'], totalWeight: 18 }

// Cycle detection
const hasCycle = dag.hasCycle();        // false

// Dependencies (ancestors)
const deps = dag.dependencies('deploy'); // ['compile', 'test']

// Dependents (descendants)
const dependents = dag.dependents('compile'); // ['test', 'deploy']

// All paths between nodes
const paths = dag.allPaths('compile', 'deploy');

// Parallel execution levels
const levels = dag.parallelLevels();
// [['compile'], ['test'], ['deploy']]

// Get execution order respecting dependencies
const schedule = dag.schedule({ maxParallel: 4 });
// [['compile'], ['test', 'lint'], ['deploy']]

// Execute with async runner
await dag.execute(async (nodeId, data) => {
  console.log(`Running ${nodeId}`);
  return await runTask(nodeId);
}, { maxParallel: 4 });

const dag = new DAG();
dag.addNode('src', { weight: 2 });
dag.addNode('types', { weight: 1 });
dag.addNode('bundle', { weight: 5 });
dag.addNode('test', { weight: 3 });
dag.addEdge('src', 'bundle');
dag.addEdge('types', 'bundle');
dag.addEdge('bundle', 'test');
const order = dag.topologicalSort(); // ['src', 'types', 'bundle', 'test']

const pipeline = new DAG();
pipeline.addNode('lint'); pipeline.addNode('test'); pipeline.addNode('build');
pipeline.addNode('deploy-staging'); pipeline.addNode('deploy-prod');
pipeline.addEdge('lint', 'build');
pipeline.addEdge('test', 'build');
pipeline.addEdge('build', 'deploy-staging');
pipeline.addEdge('deploy-staging', 'deploy-prod');
const levels = pipeline.parallelLevels();
// [['lint', 'test'], ['build'], ['deploy-staging'], ['deploy-prod']]

const deps = new DAG();
deps.addNode('express'); deps.addNode('body-parser'); deps.addNode('qs');
deps.addEdge('body-parser', 'express');
deps.addEdge('qs', 'body-parser');
const installOrder = deps.topologicalSort(); // ['qs', 'body-parser', 'express']