Mirror/SponsorBlockServer
1
0
Fork 0
mirror of https://github.com/ajayyy/SponsorBlockServer.git synced 2025-12-11 22:17:14 +03:00
Code Issues Packages Projects Releases Wiki Activity

import without fs

Browse Source
This commit is contained in:
Michael C
2021-10-21 23:15:36 -04:00
parent 0163a52e55
commit c6428bf9e4
1 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/databases/databases.ts
View File

@@ -3,7 +3,6 @@ import { Sqlite } from "./Sqlite";
import { Mysql } from "./Mysql";
import { Postgres } from "./Postgres";
import { IDatabase } from "./IDatabase";
import { readdirSync } from "fs";
let db: IDatabase;
let privateDB: IDatabase;
@@ -69,12 +68,13 @@ async function initDb(): Promise<void> {
(db as Sqlite).attachDatabase(config.privateDB, "privateDB");
}
if (config.mode === "mirror") {
readdirSync("/mirror").forEach(async file => {
const fileName = file.slice(0,-4);
const filePath = `/mirror/${file}`;
await db.prepare("run", `COPY "${fileName}" FROM '${filePath}' WITH (FORMAT CSV, HEADER true);`);
});
if (config.mode === "mirror" && db instanceof Postgres) {
const tables = config?.dumpDatabase?.tables ?? [];
const tableNames = tables.map(table => table.name);
for (const table of tableNames) {
const filePath = `${config?.dumpDatabase?.postgresExportPath}/${table}.csv`;
await db.prepare("run", `COPY "${table}" FROM '${filePath}' WITH (FORMAT CSV, HEADER true);`);
}
}
}