Мелкий рефакторинг
This commit is contained in:
@@ -1,4 +1,3 @@
|
|||||||
const fs = require('fs-extra');
|
|
||||||
const utils = require('./utils');
|
const utils = require('./utils');
|
||||||
const sqlite = require('sqlite');
|
const sqlite = require('sqlite');
|
||||||
|
|
||||||
@@ -11,7 +10,6 @@ class SqliteConnectionPool {
|
|||||||
}
|
}
|
||||||
|
|
||||||
async init() {
|
async init() {
|
||||||
fs.ensureDirSync(this.config.dataDir);
|
|
||||||
const dbFileName = this.config.dataDir + '/' + this.config.dbFileName;
|
const dbFileName = this.config.dataDir + '/' + this.config.dbFileName;
|
||||||
|
|
||||||
this.connections = [];
|
this.connections = [];
|
||||||
|
|||||||
@@ -4,14 +4,23 @@ const {initLogger, getLog} = require('./core/getLogger');
|
|||||||
initLogger(config);
|
initLogger(config);
|
||||||
const log = getLog();
|
const log = getLog();
|
||||||
|
|
||||||
|
const fs = require('fs-extra');
|
||||||
const express = require('express');
|
const express = require('express');
|
||||||
const compression = require('compression');
|
const compression = require('compression');
|
||||||
|
|
||||||
const SqliteConnectionPool = require('./core/SqliteConnectionPool');
|
const SqliteConnectionPool = require('./core/SqliteConnectionPool');
|
||||||
|
|
||||||
|
async function init() {
|
||||||
|
await fs.ensureDir(config.dataDir);
|
||||||
|
await fs.ensureDir(config.tempDir);
|
||||||
|
}
|
||||||
|
|
||||||
async function main() {
|
async function main() {
|
||||||
const connPool = new SqliteConnectionPool(20, config);
|
const connPool = new SqliteConnectionPool(20, config);
|
||||||
|
|
||||||
|
log('Initializing');
|
||||||
|
await init();
|
||||||
|
|
||||||
log('Opening database');
|
log('Opening database');
|
||||||
await connPool.init();
|
await connPool.init();
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user