open-source/qinglong
1
0
Fork 0
mirror of https://github.com/whyour/qinglong.git synced 2025-05-28 02:16:07 +08:00
Code Issues Packages Projects Releases Wiki Activity

重启服务时自动压缩db

Browse Source
This commit is contained in:
hanhh 2021-09-29 21:40:35 +08:00
parent ecaf731ecf
commit 27f17a377a
2 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
back/loaders/initData.ts
View File

@ -26,6 +26,11 @@ export default async () => {
const cronService = Container.get(CronService); const cronService = Container.get(CronService);
const envService = Container.get(EnvService); const envService = Container.get(EnvService);
const cronDb = cronService.getDb(); const cronDb = cronService.getDb();
const envDb = cronService.getDb();
// compaction data file
cronDb.persistence.compactDatafile();
envDb.persistence.compactDatafile();
cronDb.count({}, async (err, count) => { cronDb.count({}, async (err, count) => {
if (count === 0) { if (count === 0) {
@ -92,7 +97,7 @@ export default async () => {
}; };
function randomSchedule(from: number, to: number) { function randomSchedule(from: number, to: number) {
const result = []; const result: any[] = [];
const arr = [...Array(from).keys()]; const arr = [...Array(from).keys()];
let count = arr.length; let count = arr.length;
for (let i = 0; i < to; i++) { for (let i = 0; i < to; i++) {

6
back/services/env.ts
View File

@ -16,11 +16,15 @@ export default class EnvService {
}); });
} }
public getDb(): DataStore {
return this.envDb;
}
public async create(payloads: Env[]): Promise<Env[]> { public async create(payloads: Env[]): Promise<Env[]> {
const envs = await this.envs(); const envs = await this.envs();
let position = initEnvPosition; let position = initEnvPosition;
if (envs && envs.length > 0 && envs[envs.length - 1].position) { if (envs && envs.length > 0 && envs[envs.length - 1].position) {
position = envs[envs.length - 1].position; position = envs[envs.length - 1].position as number;
} }
const tabs = payloads.map((x) => { const tabs = payloads.map((x) => {
position = position / 2; position = position / 2;