feat: implement pg dump export

Author: openscript

apps/backend/src/system/export/export.controller.ts

@@ -24,12 +24,16 @@ export class ExportController {
       },
     },
   })
-  get(@Response() res: FastifyReply) {
-    const data = this.exportService.fullDatabaseDump();
-    const buffer = Buffer.from(data, "utf-8");
-    res.header("Content-Disposition", "attachment; filename=dump.sql");
-    res.header("Content-Type", "text/sql");
-    res.header("Content-Length", buffer.byteLength);
-    res.send(data);
+  async get(@Response() res: FastifyReply) {
+    try {
+      const data = await this.exportService.fullDatabaseDump();
+      const buffer = Buffer.from(data, "utf-8");
+      res.header("Content-Disposition", "attachment; filename=dump.sql");
+      res.header("Content-Type", "text/sql");
+      res.header("Content-Length", buffer.byteLength.toString());
+      res.send(buffer);
+    } catch (error) {
+      res.status(500).send(error.message);
+    }
   }
 }

apps/backend/src/system/export/export.service.ts

@@ -1,8 +1,31 @@
 import { Injectable } from "@nestjs/common";
+import { exec } from "node:child_process";
+import { promisify } from "node:util";
+import { ConfigService } from "../../config/config.service";
+
+const execPromise = promisify(exec);
 
 @Injectable()
 export class ExportService {
-  fullDatabaseDump() {
-    return "Hoi";
+  constructor(private readonly configService: ConfigService) {}
+
+  async fullDatabaseDump() {
+    try {
+      const user = this.configService.get("database.user");
+      const database = this.configService.get("database.name");
+      const password = this.configService.get("database.password");
+      const host = this.configService.get("database.host");
+      const port = this.configService.get("database.port");
+
+      const command = `PGPASSWORD=${password} pg_dump -U ${user} -h ${host} -p ${port} ${database}`;
+
+      const { stdout, stderr } = await execPromise(command);
+      if (stderr) {
+        throw new Error(stderr);
+      }
+      return stdout;
+    } catch (error) {
+      throw new Error(`Database dump failed: ${error.message}`);
+    }
   }
 }

apps/backend/src/system/system.module.ts

@@ -13,9 +13,10 @@ import { TerminusModule } from "@nestjs/terminus";
 import { StatusController } from "./status/status.controller";
 import { ExportController } from "./export/export.controller";
 import { ExportService } from "./export/export.service";
+import { ConfigModule } from "../config/config.module";
 
 @Module({
-  imports: [MikroOrmModule.forFeature([User]), TerminusModule],
+  imports: [MikroOrmModule.forFeature([User]), TerminusModule, ConfigModule],
   controllers: [UsersController, SessionController, HealthController, StatusController, ExportController],
   providers: [
     UsersService,

apps/frontend/src/routes/_auth/administration/export/index.tsx

@@ -3,10 +3,12 @@ import { createFileRoute } from "@tanstack/react-router";
 import { $api } from "../../../../stores/api";
 
 function AdministrationExportIndex() {
-  const { downloadFile } = $api.useDownload("/export", "dump.sql");
+  const { isDownloading, downloadFile } = $api.useDownload("/export", "dump.sql");
   return (
     <div>
-      <Button onClick={() => downloadFile()}>Download</Button>
+      <Button loading={isDownloading} onClick={() => downloadFile()}>
+        Download
+      </Button>
     </div>
   );
 }