apunkt/rowboat
1
0
Fork 0
mirror of https://github.com/rowboatlabs/rowboat.git synced 2026-04-25 16:36:22 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

add migrate agents script

Browse source
This commit is contained in:
Ramnique Singh 2025-12-18 11:43:42 +05:30
parent e40c767336
commit da20e280f4
3 changed files with 28 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
apps/cli/src/agents/repo.ts
View file

@ -77,7 +77,9 @@ export class FSAgentsRepo implements IAgentsRepo {
}
async create(agent: z.infer<typeof Agent>): Promise<void> {
await fs.writeFile(path.join(this.agentsDir, `${agent.name}.md`), agent.instructions);
const { instructions, ...rest } = agent;
const contents = `---\n${stringify(rest)}\n---\n${instructions}`;
await fs.writeFile(path.join(this.agentsDir, `${agent.name}.md`), contents);
}
async update(id: string, agent: z.infer<typeof UpdateAgentSchema>): Promise<void> {

23
apps/cli/src/scripts/migrate-agents.ts Normal file
View file

@ -0,0 +1,23 @@
import { Agent } from "../agents/agents.js";
import { IAgentsRepo } from "../agents/repo.js";
import { WorkDir } from "../config/config.js";
import container from "../di/container.js";
import { glob, readFile } from "node:fs/promises";
import path from "path";
const main = async () => {
const agentsRepo = container.resolve<IAgentsRepo>("agentsRepo");
const matches = await Array.fromAsync(glob("**/*.json", { cwd: path.join(WorkDir, "agents") }));
for (const file of matches) {
try {
const agent = Agent.parse(JSON.parse(await readFile(path.join(WorkDir, "agents", file), "utf8")));
await agentsRepo.create(agent);
console.error(`migrated agent ${file}`);
} catch (error) {
console.error(`Error parsing agent ${file}: ${error instanceof Error ? error.message : String(error)}`);
continue;
}
}
}
main();