zoriya/flood
1
0
Fork 0
mirror of https://github.com/zoriya/flood.git synced 2025-12-05 23:06:20 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: run compaction every interval (#834)

Browse Source
This commit is contained in:
Liu Xiaoyi
2024-12-18 02:47:40 +08:00
committed by GitHub
parent 059c3b4ebb
commit 99a1b6bbd0
4 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
server/models/Users.ts
View File

@@ -31,6 +31,7 @@ class Users {
}); });
db.ensureIndex({fieldName: 'username', unique: true}); db.ensureIndex({fieldName: 'username', unique: true});
db.setAutocompactionInterval(config.dbCleanInterval);
return db; return db;
})(); })();

1
server/services/feedService.ts
View File

@@ -21,6 +21,7 @@ class FeedService extends BaseService<Record<string, never>> {
constructor(...args: ConstructorParameters<typeof BaseService>) { constructor(...args: ConstructorParameters<typeof BaseService>) {
super(...args); super(...args);
this.db.setAutocompactionInterval(config.dbCleanInterval);
this.onServicesUpdated = async () => { this.onServicesUpdated = async () => {
// Execute once only. // Execute once only.

1
server/services/notificationService.ts
View File

@@ -26,6 +26,7 @@ class NotificationService extends BaseService<NotificationServiceEvents> {
constructor(...args: ConstructorParameters<typeof BaseService>) { constructor(...args: ConstructorParameters<typeof BaseService>) {
super(...args); super(...args);
this.db.setAutocompactionInterval(config.dbCleanInterval);
(async () => { (async () => {
const notifications = await this.db.findAsync<Notification>({}).catch(() => undefined); const notifications = await this.db.findAsync<Notification>({}).catch(() => undefined);

5
server/services/settingService.ts
View File

@@ -21,6 +21,11 @@ class SettingService extends BaseService<SettingServiceEvents> {
filename: path.join(config.dbPath, this.user._id, 'settings', 'settings.db'), filename: path.join(config.dbPath, this.user._id, 'settings', 'settings.db'),
}); });
constructor(...args: ConstructorParameters<typeof BaseService>) {
super(...args);
this.db.setAutocompactionInterval(config.dbCleanInterval);
}
async destroy(drop: boolean) { async destroy(drop: boolean) {
if (drop) { if (drop) {
await this.db.dropDatabaseAsync(); await this.db.dropDatabaseAsync();