v1.1.0: Fix CLI flags, lock verification, init SKILL.md copy

- Fix: enqueue CLI now accepts --files, --skills, --depends-on, --dag-id
- Fix: startExecution() re-verifies lock conflicts (prevents double-acquire)
- Fix: init copies bundled SKILL.md guides to target directory
- Add: lock conflict rejection test (13/13 tests pass)
- Bump: v1.0.0 → v1.1.0

Author: ShunsukeHayashi

package.json

@@ -1,6 +1,6 @@
 {
   "name": "agent-skill-bus",
-  "version": "1.0.0",
+  "version": "1.1.0",
   "description": "Self-improving task orchestration framework for AI agent systems",
   "type": "module",
   "main": "src/index.js",

src/cli.js

@@ -53,7 +53,9 @@ switch (command) {
   case 'init': {
     // Initialize skill-bus in current directory
     const initDir = getFlag('dir', process.cwd());
-    const { mkdirSync, writeFileSync: wf, existsSync: ex } = await import('node:fs');
+    const { mkdirSync, writeFileSync: wf, existsSync: ex, readFileSync: rf } = await import('node:fs');
+    const { dirname: dn, join: jn } = await import('node:path');
+    const { fileURLToPath } = await import('node:url');
 
     const dirs = [
       'skills/prompt-request-bus',
@@ -66,6 +68,7 @@ switch (command) {
       mkdirSync(full, { recursive: true });
     }
 
+    // Data files (empty/default)
     const files = {
       'skills/prompt-request-bus/prompt-request-queue.jsonl': '',
       'skills/prompt-request-bus/active-locks.jsonl': '',
@@ -87,23 +90,50 @@ switch (command) {
       }
     }
 
+    // Copy bundled SKILL.md files from package
+    const pkgDir = dn(dn(fileURLToPath(import.meta.url)));
+    const skillMds = [
+      'skills/prompt-request-bus/SKILL.md',
+      'skills/self-improving-skills/SKILL.md',
+      'skills/knowledge-watcher/SKILL.md',
+    ];
+
+    for (const s of skillMds) {
+      const dest = resolve(initDir, s);
+      const src = jn(pkgDir, s);
+      if (!ex(dest) && ex(src)) {
+        wf(dest, rf(src, 'utf-8'));
+        created++;
+      }
+    }
+
     output({
       status: 'initialized',
       directory: initDir,
       filesCreated: created,
-      message: `Agent Skill Bus initialized. Run 'skill-bus stats' to verify.`,
+      message: `Agent Skill Bus initialized with data files and SKILL.md guides. Run 'skill-bus stats' to verify.`,
     });
     break;
   }
 
   case 'enqueue': {
+    // Parse comma-separated list flags
+    const parseList = (name) => {
+      const val = getFlag(name, '');
+      return val ? val.split(',').map(s => s.trim()).filter(Boolean) : [];
+    };
+
     const pr = queue.enqueue({
       source: getFlag('source', 'human'),
       priority: getFlag('priority', 'medium'),
       agent: getFlag('agent', 'default'),
       task: getFlag('task', ''),
       context: getFlag('context', ''),
       deadline: getFlag('deadline', 'none'),
+      affectedFiles: parseList('files'),
+      affectedSkills: parseList('skills'),
+      dependsOn: parseList('depends-on'),
+      dagId: getFlag('dag-id', null),
     });
     if (pr) {
       output({ status: 'enqueued', pr });
@@ -209,7 +239,7 @@ switch (command) {
   }
 
   default:
-    console.log(`Agent Skill Bus v1.0.0
+    console.log(`Agent Skill Bus v1.1.0
 
 Usage: skill-bus <command> [options]
        npx agent-skill-bus <command> [options]

src/queue.js

@@ -137,8 +137,16 @@ export class PromptRequestQueue {
     const pr = all.find(p => p.id === prId);
     if (!pr) throw new Error(`PR not found: ${prId}`);
 
-    // Acquire file locks
+    // Re-verify lock conflicts at execution time (not just dispatch time)
     if (pr.affectedFiles.length > 0) {
+      const currentLocks = this.readLocks();
+      const lockedFiles = new Set(currentLocks.flatMap(l => l.files));
+      const conflicts = pr.affectedFiles.filter(f => lockedFiles.has(f));
+      if (conflicts.length > 0) {
+        throw new Error(`Lock conflict: files [${conflicts.join(', ')}] are already locked. PR ${prId} cannot start.`);
+      }
+
+      // Acquire file locks
       const lock = {
         agent: pr.agent,
         files: pr.affectedFiles,

src/queue.test.js

@@ -107,6 +107,18 @@ describe('PromptRequestQueue', () => {
     assert.strictEqual(pr2.status, 'blocked');
   });
 
+  it('should reject startExecution when files are already locked', () => {
+    const pr1 = queue.enqueue({ source: 'r1', agent: 'a', task: 'edit main', affectedFiles: ['src/main.ts'] });
+    const pr2 = queue.enqueue({ source: 'r2', agent: 'b', task: 'also edit main', affectedFiles: ['src/main.ts'] });
+
+    queue.startExecution(pr1.id);
+
+    // pr2 should throw on start because src/main.ts is locked
+    assert.throws(() => {
+      queue.startExecution(pr2.id);
+    }, /Lock conflict/);
+  });
+
   it('should return stats', () => {
     queue.enqueue({ source: 's1', agent: 'a', task: 'task 1' });
     queue.enqueue({ source: 's2', agent: 'b', task: 'task 2' });