supernets/hardlounge
supernets/hardlounge
5
Fork 0
Code Issues 1 Pull Requests Packages Projects Releases Wiki Activity

sqlite: convert migrations to async

Browse Source 
This removes quite a bunch of indention and callbacks
This commit is contained in:
Reto Brunner 2022-10-10 21:43:30 +02:00
parent bbe81bb2fa
commit f068fd4290
1 changed files with 36 additions and 41 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

77
server/plugins/messageStorage/sqlite.ts
View File

@ -63,52 +63,47 @@ class SqliteMessageStorage implements ISqliteMessageStorage {
this.database = new sqlite3.Database(sqlitePath); this.database = new sqlite3.Database(sqlitePath);
this.run_migrations() this.run_migrations().catch((err) => {
log.error("Migration failed", String(err));
this.isEnabled = false;
});
} }
private run_migrations() { async run_migrations() {
this.database.serialize(() => { for (const stmt of schema) {
schema.forEach((line) => this.run(line)); await this.serialize_run(stmt, []);
}
this.database.get( const version = await this.serialize_get(
"SELECT value FROM options WHERE name = 'schema_version'", "SELECT value FROM options WHERE name = 'schema_version'"
(err, row) => { );
if (err) {
return log.error(`Failed to retrieve schema version: ${err.toString()}`);
}
// New table if (version === undefined) {
if (row === undefined) { // new table
this.run( await this.serialize_run(
"INSERT INTO options (name, value) VALUES ('schema_version', ?)", "INSERT INTO options (name, value) VALUES ('schema_version', ?)",
currentSchemaVersion [currentSchemaVersion]
);
return;
}
const storedSchemaVersion = parseInt(row.value, 10);
if (storedSchemaVersion === currentSchemaVersion) {
return;
}
if (storedSchemaVersion > currentSchemaVersion) {
return log.error(
`sqlite messages schema version is higher than expected (${storedSchemaVersion} > ${currentSchemaVersion}). Is The Lounge out of date?`
);
}
log.info(
`sqlite messages schema version is out of date (${storedSchemaVersion} < ${currentSchemaVersion}). Running migrations if any.`
);
this.run(
"UPDATE options SET value = ? WHERE name = 'schema_version'",
currentSchemaVersion
);
}
); );
}); return;
}
const storedSchemaVersion = parseInt(version.value, 10);
if (storedSchemaVersion === currentSchemaVersion) {
return;
}
if (storedSchemaVersion > currentSchemaVersion) {
throw `sqlite messages schema version is higher than expected (${storedSchemaVersion} > ${currentSchemaVersion}). Is The Lounge out of date?`;
}
log.info(
`sqlite messages schema version is out of date (${storedSchemaVersion} < ${currentSchemaVersion}). Running migrations if any.`
);
await this.serialize_run("UPDATE options SET value = ? WHERE name = 'schema_version'", [
currentSchemaVersion,
]);
} }
close(callback?: (error?: Error | null) => void) { close(callback?: (error?: Error | null) => void) {