mirror of
https://github.com/snapotter-hq/SnapOtter.git
synced 2026-08-03 07:46:42 +02:00
81 lines
2.7 KiB
TypeScript
81 lines
2.7 KiB
TypeScript
import type { FastifyInstance, FastifyRequest, FastifyReply } from "fastify";
|
|||
|
|
import { randomUUID } from "node:crypto";
|
||
|
|
import { writeFile } from "node:fs/promises";
|
||
|
|
import { join, basename } from "node:path";
|
||
|
|
import { removeBackground } from "@stirling-image/ai";
|
||
|
|
import { createWorkspace } from "../../lib/workspace.js";
|
||
|
|
|
||
|
|
/**
|
||
|
|
* AI background removal route.
|
||
|
|
* Uses Python + rembg under the hood.
|
||
|
|
*/
|
||
|
|
export function registerRemoveBackground(app: FastifyInstance) {
|
||
|
|
app.post(
|
||
|
|
"/api/v1/tools/remove-background",
|
||
|
|
async (request: FastifyRequest, reply: FastifyReply) => {
|
||
|
|
let fileBuffer: Buffer | null = null;
|
||
|
|
let filename = "image";
|
||
|
|
let settingsRaw: string | null = null;
|
||
|
|
|
||
|
|
try {
|
||
|
|
const parts = request.parts();
|
||
|
|
for await (const part of parts) {
|
||
|
|
if (part.type === "file") {
|
||
|
|
const chunks: Buffer[] = [];
|
||
|
|
for await (const chunk of part.file) {
|
||
|
|
chunks.push(chunk);
|
||
|
|
}
|
||
|
|
fileBuffer = Buffer.concat(chunks);
|
||
|
|
filename = basename(part.filename ?? "image");
|
||
|
|
} else if (part.fieldname === "settings") {
|
||
|
|
settingsRaw = part.value as string;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
} catch (err) {
|
||
|
|
return reply.status(400).send({
|
||
|
|
error: "Failed to parse multipart request",
|
||
|
|
details: err instanceof Error ? err.message : String(err),
|
||
|
|
});
|
||
|
|
}
|
||
|
|
|
||
|
|
if (!fileBuffer || fileBuffer.length === 0) {
|
||
|
|
return reply.status(400).send({ error: "No image file provided" });
|
||
|
|
}
|
||
|
|
|
||
|
|
try {
|
||
|
|
const settings = settingsRaw ? JSON.parse(settingsRaw) : {};
|
||
|
|
const jobId = randomUUID();
|
||
|
|
const workspacePath = await createWorkspace(jobId);
|
||
|
|
|
||
|
|
// Save input
|
||
|
|
const inputPath = join(workspacePath, "input", filename);
|
||
|
|
await writeFile(inputPath, fileBuffer);
|
||
|
|
|
||
|
|
// Process
|
||
|
|
const resultBuffer = await removeBackground(
|
||
|
|
fileBuffer,
|
||
|
|
join(workspacePath, "output"),
|
||
|
|
{ model: settings.model },
|
||
|
|
);
|
||
|
|
|
||
|
|
// Save output
|
||
|
|
const outputFilename = filename.replace(/\.[^.]+$/, "") + "_nobg.png";
|
||
|
|
const outputPath = join(workspacePath, "output", outputFilename);
|
||
|
|
await writeFile(outputPath, resultBuffer);
|
||
|
|
|
||
|
|
return reply.send({
|
||
|
|
jobId,
|
||
|
|
downloadUrl: `/api/v1/download/${jobId}/${encodeURIComponent(outputFilename)}`,
|
||
|
|
originalSize: fileBuffer.length,
|
||
|
|
processedSize: resultBuffer.length,
|
||
|
|
});
|
||
|
|
} catch (err) {
|
||
|
|
return reply.status(422).send({
|
||
|
|
error: "Background removal failed",
|
||
|
|
details: err instanceof Error ? err.message : "Unknown error",
|
||
|
|
});
|
||
|
|
}
|
||
|
|
},
|
||
|
|
);
|
||
|
|
}
|