Spaces:
Runtime error
Runtime error
File size: 4,392 Bytes
cd8bd0a | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 | "use server";
import { NextResponse } from "next/server";
import { requireCliToolsAuth } from "@/lib/api/requireCliToolsAuth";
import { listBackups, restoreBackup, deleteBackup } from "@/shared/services/backupService";
import { ensureCliConfigWriteAllowed } from "@/shared/services/cliRuntime";
import { cliBackupMutationSchema } from "@/shared/validation/schemas";
import { isValidationFailure, validateBody } from "@/shared/validation/helpers";
import { sanitizeErrorMessage } from "@omniroute/open-sse/utils/error";
const VALID_TOOLS = ["claude", "codex", "droid", "openclaw", "cline", "kilo", "qwen"];
// GET /api/cli-tools/backups?tool=claude — list backups
export async function GET(request) {
const authError = await requireCliToolsAuth(request);
if (authError) return authError;
try {
const { searchParams } = new URL(request.url);
const tool = searchParams.get("tool") || searchParams.get("toolId");
if (tool && !VALID_TOOLS.includes(tool)) {
return NextResponse.json({ error: `Invalid tool: ${tool}` }, { status: 400 });
}
if (tool) {
const backups = await listBackups(tool);
return NextResponse.json({ tool, backups });
}
// List all tools
const result = {};
for (const t of VALID_TOOLS) {
result[t] = await listBackups(t);
}
return NextResponse.json({ backups: result });
} catch (error) {
console.log("Error listing backups:", error.message);
return NextResponse.json({ error: "Failed to list backups" }, { status: 500 });
}
}
// POST /api/cli-tools/backups { tool, backupId } — restore a backup
export async function POST(request) {
const authError = await requireCliToolsAuth(request);
if (authError) return authError;
let rawBody;
try {
rawBody = await request.json();
} catch {
return NextResponse.json(
{
error: {
message: "Invalid request",
details: [{ field: "body", message: "Invalid JSON body" }],
},
},
{ status: 400 }
);
}
try {
const writeGuard = ensureCliConfigWriteAllowed();
if (writeGuard) {
return NextResponse.json({ error: writeGuard }, { status: 403 });
}
const validation = validateBody(cliBackupMutationSchema, rawBody);
if (isValidationFailure(validation)) {
return NextResponse.json({ error: validation.error }, { status: 400 });
}
const tool = validation.data.tool || validation.data.toolId;
const { backupId } = validation.data;
if (!VALID_TOOLS.includes(tool)) {
return NextResponse.json({ error: `Invalid tool: ${tool}` }, { status: 400 });
}
const result = await restoreBackup(tool, backupId);
return NextResponse.json({
success: true,
message: `Backup restored for ${tool}`,
...result,
});
} catch (error) {
console.log("Error restoring backup:", error.message);
return NextResponse.json(
{
error:
sanitizeErrorMessage(error instanceof Error ? error.message : String(error)) ||
"Failed to restore backup",
},
{ status: 500 }
);
}
}
// DELETE /api/cli-tools/backups { tool, backupId } — delete a backup
export async function DELETE(request) {
const authError = await requireCliToolsAuth(request);
if (authError) return authError;
let rawBody;
try {
rawBody = await request.json();
} catch {
return NextResponse.json(
{
error: {
message: "Invalid request",
details: [{ field: "body", message: "Invalid JSON body" }],
},
},
{ status: 400 }
);
}
try {
const validation = validateBody(cliBackupMutationSchema, rawBody);
if (isValidationFailure(validation)) {
return NextResponse.json({ error: validation.error }, { status: 400 });
}
const tool = validation.data.tool || validation.data.toolId;
const { backupId } = validation.data;
if (!VALID_TOOLS.includes(tool)) {
return NextResponse.json({ error: `Invalid tool: ${tool}` }, { status: 400 });
}
const result = await deleteBackup(tool, backupId);
return NextResponse.json({
success: true,
message: `Backup deleted for ${tool}`,
...result,
});
} catch (error) {
console.log("Error deleting backup:", error.message);
return NextResponse.json({ error: "Failed to delete backup" }, { status: 500 });
}
}
|