summaryrefslogtreecommitdiff
path: root/packages/backend/src/daemons
diff options
context:
space:
mode:
authorsyuilo <Syuilotan@yahoo.co.jp>2022-12-04 15:03:09 +0900
committersyuilo <Syuilotan@yahoo.co.jp>2022-12-04 15:03:09 +0900
commitbbb49457f9fb5d46402e913c92ebf77722cad6ff (patch)
tree8ef285bcbab2c3a4a89d0a624a802d76a2864fed /packages/backend/src/daemons
parent:art: (diff)
downloadsharkey-bbb49457f9fb5d46402e913c92ebf77722cad6ff.tar.gz
sharkey-bbb49457f9fb5d46402e913c92ebf77722cad6ff.tar.bz2
sharkey-bbb49457f9fb5d46402e913c92ebf77722cad6ff.zip
refactor: introduce bindThis decorator to bind this automaticaly
Diffstat (limited to 'packages/backend/src/daemons')
-rw-r--r--packages/backend/src/daemons/JanitorService.ts3
-rw-r--r--packages/backend/src/daemons/QueueStatsService.ts3
-rw-r--r--packages/backend/src/daemons/ServerStatsService.ts3
3 files changed, 9 insertions, 0 deletions
diff --git a/packages/backend/src/daemons/JanitorService.ts b/packages/backend/src/daemons/JanitorService.ts
index dbad576abe..8cdfb703f1 100644
--- a/packages/backend/src/daemons/JanitorService.ts
+++ b/packages/backend/src/daemons/JanitorService.ts
@@ -2,6 +2,7 @@ import { Inject, Injectable } from '@nestjs/common';
import { LessThan } from 'typeorm';
import { DI } from '@/di-symbols.js';
import type { AttestationChallengesRepository } from '@/models/index.js';
+import { bindThis } from '@/decorators.js';
import type { OnApplicationShutdown } from '@nestjs/common';
const interval = 30 * 60 * 1000;
@@ -19,6 +20,7 @@ export class JanitorService implements OnApplicationShutdown {
/**
* Clean up database occasionally
*/
+ @bindThis
public start(): void {
const tick = async () => {
await this.attestationChallengesRepository.delete({
@@ -31,6 +33,7 @@ export class JanitorService implements OnApplicationShutdown {
this.intervalId = setInterval(tick, interval);
}
+ @bindThis
public onApplicationShutdown(signal?: string | undefined) {
clearInterval(this.intervalId);
}
diff --git a/packages/backend/src/daemons/QueueStatsService.ts b/packages/backend/src/daemons/QueueStatsService.ts
index 931de19067..7b47d78a17 100644
--- a/packages/backend/src/daemons/QueueStatsService.ts
+++ b/packages/backend/src/daemons/QueueStatsService.ts
@@ -2,6 +2,7 @@ import { Inject, Injectable } from '@nestjs/common';
import Xev from 'xev';
import { DI } from '@/di-symbols.js';
import { QueueService } from '@/core/QueueService.js';
+import { bindThis } from '@/decorators.js';
import type { OnApplicationShutdown } from '@nestjs/common';
const ev = new Xev();
@@ -20,6 +21,7 @@ export class QueueStatsService implements OnApplicationShutdown {
/**
* Report queue stats regularly
*/
+ @bindThis
public start(): void {
const log = [] as any[];
@@ -71,6 +73,7 @@ export class QueueStatsService implements OnApplicationShutdown {
this.intervalId = setInterval(tick, interval);
}
+ @bindThis
public onApplicationShutdown(signal?: string | undefined) {
clearInterval(this.intervalId);
}
diff --git a/packages/backend/src/daemons/ServerStatsService.ts b/packages/backend/src/daemons/ServerStatsService.ts
index e40912442d..7971f9e810 100644
--- a/packages/backend/src/daemons/ServerStatsService.ts
+++ b/packages/backend/src/daemons/ServerStatsService.ts
@@ -3,6 +3,7 @@ import si from 'systeminformation';
import Xev from 'xev';
import * as osUtils from 'os-utils';
import { DI } from '@/di-symbols.js';
+import { bindThis } from '@/decorators.js';
import type { OnApplicationShutdown } from '@nestjs/common';
const ev = new Xev();
@@ -23,6 +24,7 @@ export class ServerStatsService implements OnApplicationShutdown {
/**
* Report server stats regularly
*/
+ @bindThis
public start(): void {
const log = [] as any[];
@@ -61,6 +63,7 @@ export class ServerStatsService implements OnApplicationShutdown {
this.intervalId = setInterval(tick, interval);
}
+ @bindThis
public onApplicationShutdown(signal?: string | undefined) {
clearInterval(this.intervalId);
}