mirror of
https://github.com/Portabase/portabase.git
synced 2026-07-14 11:16:13 +02:00
chore(release): 1.2.5-rc.2
This commit is contained in:
charlesgauthereau
@@ -1,169 +1,289 @@
|
||||
import {NextResponse} from "next/server";
|
||||
import {isUuidv4} from "@/utils/verify-uuid";
|
||||
import {v4 as uuidv4} from "uuid";
|
||||
// import {NextResponse} from "next/server";
|
||||
// import {isUuidv4} from "@/utils/verify-uuid";
|
||||
// import {v4 as uuidv4} from "uuid";
|
||||
// import * as drizzleDb from "@/db";
|
||||
// import {db} from "@/db";
|
||||
// import {Backup} from "@/db/schema/07_database";
|
||||
// import {and, eq} from "drizzle-orm";
|
||||
// import {withUpdatedAt} from "@/db/utils";
|
||||
// import {decryptedDump, getFileExtension} from "./helpers";
|
||||
// import {sendNotificationsBackupRestore} from "@/features/notifications/helpers";
|
||||
// import {storeBackupFiles} from "@/features/storages/helpers";
|
||||
// import {eventEmitter} from "@/features/shared/event";
|
||||
//
|
||||
// export async function POST(
|
||||
// request: Request,
|
||||
// {params}: { params: Promise<{ agentId: string }> }
|
||||
// ) {
|
||||
// try {
|
||||
// const contentType = request.headers.get("Content-Type");
|
||||
//
|
||||
// if (!contentType || !contentType.includes("multipart/form-data")) {
|
||||
// return NextResponse.json(
|
||||
// {error: "Unsupported or missing Content-Type"},
|
||||
// {status: 400}
|
||||
// );
|
||||
// }
|
||||
//
|
||||
// eventEmitter.emit('modification', {update: true});
|
||||
//
|
||||
// const agentId = (await params).agentId;
|
||||
// const formData = await request.formData();
|
||||
// const aesKeyHex = formData.get("aes_key") as string;
|
||||
// const ivHex = formData.get("iv") as string;
|
||||
// const generatedId = formData.get("generatedId") as string | null;
|
||||
// const method = formData.get("method") as string | null;
|
||||
//
|
||||
//
|
||||
// if (!generatedId || !isUuidv4(generatedId)) {
|
||||
// return NextResponse.json(
|
||||
// {error: "generatedId is not a valid UUID"},
|
||||
// {status: 400}
|
||||
// );
|
||||
// }
|
||||
//
|
||||
// const agent = await db.query.agent.findFirst({
|
||||
// where: eq(drizzleDb.schemas.agent.id, agentId),
|
||||
// });
|
||||
//
|
||||
// if (!agent) {
|
||||
// return NextResponse.json(
|
||||
// {error: "Agent not found"},
|
||||
// {status: 404}
|
||||
// );
|
||||
// }
|
||||
//
|
||||
// const database = await db.query.database.findFirst({
|
||||
// where: eq(drizzleDb.schemas.database.agentDatabaseId, generatedId),
|
||||
// with: {
|
||||
// project: true,
|
||||
// alertPolicies: true,
|
||||
// storagePolicies: true
|
||||
// }
|
||||
// });
|
||||
//
|
||||
// if (!database) {
|
||||
// return NextResponse.json(
|
||||
// {error: "Database associated with generatedId not found"},
|
||||
// {status: 404}
|
||||
// );
|
||||
// }
|
||||
//
|
||||
// let backup: Backup | null | undefined = null;
|
||||
//
|
||||
// if (method === "automatic") {
|
||||
// [backup] = await db
|
||||
// .insert(drizzleDb.schemas.backup)
|
||||
// .values({
|
||||
// status: 'ongoing',
|
||||
// databaseId: database.id,
|
||||
// })
|
||||
// .returning();
|
||||
//
|
||||
//
|
||||
// if (!backup) {
|
||||
// return NextResponse.json(
|
||||
// {error: "Unable to create an automatic backup"},
|
||||
// {status: 500}
|
||||
// );
|
||||
// }
|
||||
// } else {
|
||||
// backup = await db.query.backup.findFirst({
|
||||
// where: and(
|
||||
// eq(drizzleDb.schemas.backup.status, 'ongoing'),
|
||||
// eq(drizzleDb.schemas.backup.databaseId, database.id),
|
||||
// ),
|
||||
// });
|
||||
//
|
||||
//
|
||||
// if (!backup) {
|
||||
// return NextResponse.json(
|
||||
// {error: "Unable to find the corresponding backup"},
|
||||
// {status: 404}
|
||||
// );
|
||||
// }
|
||||
// }
|
||||
//
|
||||
// const status = formData.get("status") as string | null;
|
||||
//
|
||||
// if (status === "success") {
|
||||
// const file = formData.get("file") as File | null;
|
||||
// const extension = formData.get("extension") as string | null;
|
||||
// if (!aesKeyHex || !ivHex) {
|
||||
// return NextResponse.json({error: "Missing fields"}, {status: 400});
|
||||
// }
|
||||
//
|
||||
//
|
||||
// if (!file) {
|
||||
// return NextResponse.json(
|
||||
// {error: "File is required for successful backup"},
|
||||
// {status: 400}
|
||||
// );
|
||||
// }
|
||||
// const fileSizeBytes = file.size;
|
||||
// // const fileExtension = '.' + (file.name.split('.').pop()?.toLowerCase() || '');
|
||||
// const fileExtension = extension ? extension : getFileExtension(database.dbms)
|
||||
// const decryptedFile = await decryptedDump(file, aesKeyHex, ivHex, fileExtension);
|
||||
// const uuid = uuidv4();
|
||||
// const fileName = `${uuid}${fileExtension}`;
|
||||
// const buffer = Buffer.from(await decryptedFile.arrayBuffer());
|
||||
//
|
||||
//
|
||||
// const storageResults = await storeBackupFiles(backup, database, buffer, fileName)
|
||||
// eventEmitter.emit('modification', {update: true});
|
||||
//
|
||||
// await sendNotificationsBackupRestore(database, "success_backup");
|
||||
//
|
||||
// return NextResponse.json(
|
||||
// {
|
||||
// message: "Backup successfully uploaded",
|
||||
// },
|
||||
// {status: 200}
|
||||
// );
|
||||
// } else {
|
||||
//
|
||||
// await db
|
||||
// .update(drizzleDb.schemas.backup)
|
||||
// .set(withUpdatedAt({status: 'failed'}))
|
||||
// .where(eq(drizzleDb.schemas.backup.id, backup.id));
|
||||
//
|
||||
// eventEmitter.emit('modification', {update: true});
|
||||
//
|
||||
// await sendNotificationsBackupRestore(database, "error_backup");
|
||||
//
|
||||
//
|
||||
// return NextResponse.json(
|
||||
// {
|
||||
// message: "Backup successfully updated with status failed",
|
||||
// },
|
||||
// {status: 200}
|
||||
// );
|
||||
// }
|
||||
// } catch (error) {
|
||||
// console.error("Error in POST handler:", error);
|
||||
// return NextResponse.json(
|
||||
// {error: "Internal server error"},
|
||||
// {status: 500}
|
||||
// );
|
||||
// }
|
||||
// }
|
||||
|
||||
|
||||
import { NextResponse } from "next/server";
|
||||
import { v4 as uuidv4 } from "uuid";
|
||||
import { and, eq } from "drizzle-orm";
|
||||
import * as drizzleDb from "@/db";
|
||||
import {db} from "@/db";
|
||||
import {Backup} from "@/db/schema/07_database";
|
||||
import {and, eq} from "drizzle-orm";
|
||||
import {withUpdatedAt} from "@/db/utils";
|
||||
import {decryptedDump, getFileExtension} from "./helpers";
|
||||
import {sendNotificationsBackupRestore} from "@/features/notifications/helpers";
|
||||
import {storeBackupFiles} from "@/features/storages/helpers";
|
||||
import {eventEmitter} from "@/features/shared/event";
|
||||
import { db } from "@/db";
|
||||
import { isUuidv4 } from "@/utils/verify-uuid";
|
||||
import uploadTempFileToProviders, { createDecryptionStream } from "@/features/api/upload/helpers/common";
|
||||
import { getFileExtension, saveStreamToTempFile } from "@/features/api/upload/helpers/file";
|
||||
import { Backup } from "@/db/schema/07_database";
|
||||
import { withUpdatedAt } from "@/db/utils";
|
||||
import { eventEmitter } from "@/features/shared/event";
|
||||
import { sendNotificationsBackupRestore } from "@/features/notifications/helpers";
|
||||
import {Readable} from "node:stream";
|
||||
|
||||
export async function POST(
|
||||
request: Request,
|
||||
{params}: { params: Promise<{ agentId: string }> }
|
||||
) {
|
||||
export async function POST(request: Request, { params }: { params: Promise<{ agentId: string }> }) {
|
||||
try {
|
||||
const contentType = request.headers.get("Content-Type");
|
||||
const agentId = (await params).agentId;
|
||||
const headers = request.headers;
|
||||
|
||||
if (!contentType || !contentType.includes("multipart/form-data")) {
|
||||
return NextResponse.json(
|
||||
{error: "Unsupported or missing Content-Type"},
|
||||
{status: 400}
|
||||
);
|
||||
const generatedId = headers.get("x-generated-id");
|
||||
const status = headers.get("x-status");
|
||||
const encryptedAesKeyHex = headers.get("x-aes-key");
|
||||
const ivHex = headers.get("x-iv");
|
||||
const method = headers.get("x-method") ?? "manual";
|
||||
const extension = headers.get("x-extension");
|
||||
|
||||
if (!agentId || !generatedId || !status || !encryptedAesKeyHex || !ivHex) {
|
||||
return NextResponse.json({ error: "Missing required headers/params" }, { status: 400 });
|
||||
}
|
||||
|
||||
eventEmitter.emit('modification', {update: true});
|
||||
|
||||
const agentId = (await params).agentId;
|
||||
const formData = await request.formData();
|
||||
const aesKeyHex = formData.get("aes_key") as string;
|
||||
const ivHex = formData.get("iv") as string;
|
||||
const generatedId = formData.get("generatedId") as string | null;
|
||||
const method = formData.get("method") as string | null;
|
||||
|
||||
|
||||
if (!generatedId || !isUuidv4(generatedId)) {
|
||||
return NextResponse.json(
|
||||
{error: "generatedId is not a valid UUID"},
|
||||
{status: 400}
|
||||
);
|
||||
if (!isUuidv4(generatedId)) {
|
||||
return NextResponse.json({ error: "generatedId is not a valid UUID" }, { status: 400 });
|
||||
}
|
||||
|
||||
const agent = await db.query.agent.findFirst({
|
||||
where: eq(drizzleDb.schemas.agent.id, agentId),
|
||||
});
|
||||
|
||||
if (!agent) {
|
||||
return NextResponse.json(
|
||||
{error: "Agent not found"},
|
||||
{status: 404}
|
||||
);
|
||||
return NextResponse.json({ error: "Agent not found" }, { status: 404 });
|
||||
}
|
||||
|
||||
const database = await db.query.database.findFirst({
|
||||
where: eq(drizzleDb.schemas.database.agentDatabaseId, generatedId),
|
||||
with: {
|
||||
project: true,
|
||||
alertPolicies: true,
|
||||
storagePolicies: true
|
||||
}
|
||||
with: { project: true, storagePolicies: true },
|
||||
});
|
||||
|
||||
if (!database) {
|
||||
return NextResponse.json(
|
||||
{error: "Database associated with generatedId not found"},
|
||||
{status: 404}
|
||||
);
|
||||
return NextResponse.json({ error: "Database not found" }, { status: 404 });
|
||||
}
|
||||
|
||||
let backup: Backup | null | undefined = null;
|
||||
|
||||
if (method === "automatic") {
|
||||
[backup] = await db
|
||||
.insert(drizzleDb.schemas.backup)
|
||||
.values({
|
||||
status: 'ongoing',
|
||||
databaseId: database.id,
|
||||
})
|
||||
.values({ status: "ongoing", databaseId: database.id })
|
||||
.returning();
|
||||
|
||||
|
||||
if (!backup) {
|
||||
return NextResponse.json(
|
||||
{error: "Unable to create an automatic backup"},
|
||||
{status: 500}
|
||||
);
|
||||
}
|
||||
} else {
|
||||
backup = await db.query.backup.findFirst({
|
||||
where: and(
|
||||
eq(drizzleDb.schemas.backup.status, 'ongoing'),
|
||||
eq(drizzleDb.schemas.backup.databaseId, database.id),
|
||||
eq(drizzleDb.schemas.backup.status, "ongoing")
|
||||
),
|
||||
});
|
||||
|
||||
|
||||
if (!backup) {
|
||||
return NextResponse.json(
|
||||
{error: "Unable to find the corresponding backup"},
|
||||
{status: 404}
|
||||
);
|
||||
}
|
||||
}
|
||||
|
||||
const status = formData.get("status") as string | null;
|
||||
if (!backup) {
|
||||
return NextResponse.json({ error: "Backup not found" }, { status: 404 });
|
||||
}
|
||||
|
||||
if (status === "success") {
|
||||
const file = formData.get("file") as File | null;
|
||||
const extension = formData.get("extension") as string | null;
|
||||
if (!aesKeyHex || !ivHex) {
|
||||
return NextResponse.json({error: "Missing fields"}, {status: 400});
|
||||
|
||||
const decipher = createDecryptionStream(encryptedAesKeyHex, ivHex);
|
||||
const fileExt = extension || getFileExtension(database.dbms);
|
||||
const fileName = `${uuidv4()}${fileExt}`;
|
||||
|
||||
// const nodeStream = webStreamToNode(request.body as any);
|
||||
|
||||
// const tmpPath = await new Promise<string | null>((resolve, reject) => {
|
||||
// pipeline(nodeStream, decipher, async (err) => {
|
||||
// if (err) return reject(err);
|
||||
// try {
|
||||
// const path = await saveStreamToTempFile(decipher, fileName);
|
||||
// resolve(path);
|
||||
// } catch (e) {
|
||||
// reject(e);
|
||||
// }
|
||||
// });
|
||||
// });
|
||||
|
||||
const tmpPath = await saveStreamToTempFile(decipher, fileName);
|
||||
|
||||
if (!tmpPath) {
|
||||
return NextResponse.json({ error: "Unable to save temporary backup file" }, { status: 500 });
|
||||
}
|
||||
|
||||
uploadTempFileToProviders(backup, database, tmpPath, fileName);
|
||||
|
||||
if (!file) {
|
||||
return NextResponse.json(
|
||||
{error: "File is required for successful backup"},
|
||||
{status: 400}
|
||||
);
|
||||
}
|
||||
const fileSizeBytes = file.size;
|
||||
// const fileExtension = '.' + (file.name.split('.').pop()?.toLowerCase() || '');
|
||||
const fileExtension = extension ? extension : getFileExtension(database.dbms)
|
||||
const decryptedFile = await decryptedDump(file, aesKeyHex, ivHex, fileExtension);
|
||||
const uuid = uuidv4();
|
||||
const fileName = `${uuid}${fileExtension}`;
|
||||
const buffer = Buffer.from(await decryptedFile.arrayBuffer());
|
||||
|
||||
|
||||
const storageResults = await storeBackupFiles(backup, database, buffer, fileName)
|
||||
eventEmitter.emit('modification', {update: true});
|
||||
|
||||
await sendNotificationsBackupRestore(database, "success_backup");
|
||||
|
||||
return NextResponse.json(
|
||||
{
|
||||
message: "Backup successfully uploaded",
|
||||
},
|
||||
{status: 200}
|
||||
);
|
||||
return NextResponse.json({ success: true });
|
||||
} else {
|
||||
|
||||
await db
|
||||
.update(drizzleDb.schemas.backup)
|
||||
.set(withUpdatedAt({status: 'failed'}))
|
||||
.set(withUpdatedAt({ status: "failed" }))
|
||||
.where(eq(drizzleDb.schemas.backup.id, backup.id));
|
||||
|
||||
eventEmitter.emit('modification', {update: true});
|
||||
|
||||
eventEmitter.emit("modification", { update: true });
|
||||
await sendNotificationsBackupRestore(database, "error_backup");
|
||||
|
||||
|
||||
return NextResponse.json(
|
||||
{
|
||||
message: "Backup successfully updated with status failed",
|
||||
},
|
||||
{status: 200}
|
||||
);
|
||||
return NextResponse.json({ message: "Backup updated with status failed" }, { status: 200 });
|
||||
}
|
||||
} catch (error) {
|
||||
console.error("Error in POST handler:", error);
|
||||
return NextResponse.json(
|
||||
{error: "Internal server error"},
|
||||
{status: 500}
|
||||
);
|
||||
} catch (err: any) {
|
||||
console.error("Upload error:", err);
|
||||
return NextResponse.json({ error: "Upload failed", detail: err.message }, { status: 500 });
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
function webStreamToNode(stream: ReadableStream<Uint8Array>) {
|
||||
return Readable.fromWeb(stream);
|
||||
}
|
||||
Reference in New Issue
Block a user