mirror of
https://github.com/ajayyy/SponsorBlockServer.git
synced 2025-12-12 14:37:17 +03:00
if in mirror mode, import CSV files
This commit is contained in:
@@ -3,7 +3,7 @@ import { Sqlite } from "./Sqlite";
|
|||||||
import { Mysql } from "./Mysql";
|
import { Mysql } from "./Mysql";
|
||||||
import { Postgres } from "./Postgres";
|
import { Postgres } from "./Postgres";
|
||||||
import { IDatabase } from "./IDatabase";
|
import { IDatabase } from "./IDatabase";
|
||||||
|
import { readdirSync } from "fs";
|
||||||
|
|
||||||
let db: IDatabase;
|
let db: IDatabase;
|
||||||
let privateDB: IDatabase;
|
let privateDB: IDatabase;
|
||||||
@@ -68,6 +68,14 @@ async function initDb(): Promise<void> {
|
|||||||
// Attach private db to main db
|
// Attach private db to main db
|
||||||
(db as Sqlite).attachDatabase(config.privateDB, "privateDB");
|
(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);`);
|
||||||
|
});
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
export {
|
export {
|
||||||
|
|||||||
Reference in New Issue
Block a user