feat: allow gzip uploads for all dbms and add archive entry matcher

src/utils/common.ts

@@ -50,41 +50,83 @@ export function getFileExtension(dbType: string) {
   }
 }
 
+const GZIP_ACCEPT: Record<string, string[]> = {
+  "application/gzip": [".tar.gz", ".tgz"],
+  "application/x-gzip": [".tar.gz", ".tgz"],
+};
+
+function mergeAccept(
+  base: Record<string, string[]>,
+  extra: Record<string, string[]>,
+): Record<string, string[]> {
+  const out: Record<string, string[]> = { ...base };
+  for (const [mime, exts] of Object.entries(extra)) {
+    out[mime] = Array.from(new Set([...(out[mime] ?? []), ...exts]));
+  }
+  return out;
+}
+
 export function getFileHeadersBasedOnDbms(
   dbType: string,
 ): Record<string, string[]> {
+  let base: Record<string, string[]>;
   switch (dbType) {
     case "postgresql":
-      return {
+      base = { "application/octet-stream": [".dump"] };
-        "application/octet-stream": [".dump"],
+      break;
-      };
     case "mysql":
     case "mariadb":
-      return {
+      base = {
         "application/sql": [".sql"],
         "application/x-sql": [".sql"],
       };
+      break;
     case "mongodb":
-      return {
+      base = { "application/gzip": [".archive.gz"] };
-        "application/gzip": [".archive.gz"],
+      break;
-      };
     case "firebird":
-      return {
+      base = { "application/octet-stream": [".fbk"] };
-        "application/octet-stream": [".fbk"],
+      break;
-      };
     case "valkey":
     case "redis":
-      return {
+      base = { "application/octet-stream": [".rdb"] };
-        "application/octet-stream": [".rdb"],
+      break;
-      };
     case "sqlite":
-      return {
+      base = { "application/octet-stream": [".backup"] };
-        "application/octet-stream": [".backup"],
+      break;
-      };
     case "mssql":
-      return {
+      base = { "application/octet-stream": [".bacpac"] };
-        "application/octet-stream": [".bacpac"],
+      break;
-      };
+    default:
+      throw new Error(`Unsupported database type: ${dbType}`);
+  }
+  return mergeAccept(base, GZIP_ACCEPT);
+}
+
+/**
+ * Returns a matcher for a tar entry name that indicates the archive holds a
+ * valid backup for the given dbms. For postgres this covers both custom-format
+ * dumps (`pg_dump -Fc` → *.dump) and directory-format dumps (`pg_dump -Fd` →
+ * a `toc.dat` plus numbered data files).
+ */
+export function getArchiveEntryMatcher(dbType: string): RegExp {
+  switch (dbType) {
+    case "postgresql":
+      return /(\.dump$|\.dmp$|(^|\/)toc\.dat$)/i;
+    case "mysql":
+    case "mariadb":
+      return /\.sql$/i;
+    case "mongodb":
+      return /(\.archive(\.gz)?$|\.bson(\.gz)?$)/i;
+    case "valkey":
+    case "redis":
+      return /\.rdb$/i;
+    case "sqlite":
+      return /(\.backup$|\.sqlite$|\.db$)/i;
+    case "firebird":
+      return /\.fbk$/i;
+    case "mssql":
+      return /\.bacpac$/i;
     default:
       throw new Error(`Unsupported database type: ${dbType}`);
   }