Function executeSkillCommand

src/skill-command.ts:221–256

(cmd: SkillCommand, targetSkillsDir: string)

 * Throws on failure so the caller can ack(failed, error). Never retries.
 */
export async function executeSkillCommand(cmd: SkillCommand, targetSkillsDir: string): Promise<void> {
  assertSafeResourceName(cmd.skill_slug);

  switch (cmd.type) {
    case 'install_skill':
    case 'update_skill': {
      if (!cmd.download_url) {
        throw new Error(`${cmd.type} requires download_url`);
      }
      const zip = await downloadZip(cmd.download_url);
      const actualDir = await installSkillZip(zip, cmd.skill_slug, targetSkillsDir);
      log.debug(`[skill-command] ${cmd.type} ${cmd.skill_slug}@${cmd.skill_version ?? '?'} → ${targetSkillsDir}/${actualDir}`);
      return;
    }
    case 'uninstall_skill': {
      const dir = path.join(targetSkillsDir, cmd.skill_slug);
      if (await pathExists(dir)) {
        await remove(dir);
      } else {
        const map = await readSlugMap(targetSkillsDir);
        const mapped = map[cmd.skill_slug];
        if (mapped && mapped !== cmd.skill_slug) {
          const mappedDir = path.join(targetSkillsDir, mapped);
          if (await pathExists(mappedDir)) {
            await remove(mappedDir);
          }
        }
      }
      await removeSlugMapEntry(targetSkillsDir, cmd.skill_slug);
      log.debug(`[skill-command] uninstall_skill ${cmd.skill_slug} (from ${targetSkillsDir})`);
      return;
    }
    default:
      throw new Error(`unknown skill command type: ${(cmd as SkillCommand).type}`);
  }
}