summaryrefslogtreecommitdiff
path: root/packages/backend/src
diff options
context:
space:
mode:
authordakkar <dakkar@thenautilus.net>2024-12-21 16:35:51 +0000
committerdakkar <dakkar@thenautilus.net>2024-12-21 16:35:51 +0000
commit5eca807e19f55c99ae5ca4d4e3c2179c3c908368 (patch)
treea7774cd40f4fa90cd8c1fe60e644e075806034f3 /packages/backend/src
parentmerge: Sync charts one-at-a-time to reduce database contention and timeouts (... (diff)
parentRevert "Synchronize server startup" (diff)
downloadsharkey-5eca807e19f55c99ae5ca4d4e3c2179c3c908368.tar.gz
sharkey-5eca807e19f55c99ae5ca4d4e3c2179c3c908368.tar.bz2
sharkey-5eca807e19f55c99ae5ca4d4e3c2179c3c908368.zip
merge: Revert "Synchronize server startup" (!831)
View MR for information: https://activitypub.software/TransFem-org/Sharkey/-/merge_requests/831 Approved-by: dakkar <dakkar@thenautilus.net> Approved-by: Charlotte <timo.herngreen@gmail.com>
Diffstat (limited to 'packages/backend/src')
-rw-r--r--packages/backend/src/boot/common.ts17
-rw-r--r--packages/backend/src/daemons/QueueStatsService.ts4
-rw-r--r--packages/backend/src/daemons/ServerStatsService.ts2
3 files changed, 11 insertions, 12 deletions
diff --git a/packages/backend/src/boot/common.ts b/packages/backend/src/boot/common.ts
index 9ff1efb3c2..ad59a55688 100644
--- a/packages/backend/src/boot/common.ts
+++ b/packages/backend/src/boot/common.ts
@@ -19,18 +19,17 @@ export async function server() {
logger: new NestLogger(),
});
+ const serverService = app.get(ServerService);
+ await serverService.launch();
+
if (process.env.NODE_ENV !== 'test') {
- await app.get(ChartManagementService).start();
+ app.get(ChartManagementService).start();
}
if (!envOption.noDaemons) {
- await app.get(QueueStatsService).start();
- await app.get(ServerStatsService).start();
+ app.get(QueueStatsService).start();
+ app.get(ServerStatsService).start();
}
- // Start server last so the other services can register hooks first
- const serverService = app.get(ServerService);
- await serverService.launch();
-
return app;
}
@@ -39,8 +38,8 @@ export async function jobQueue() {
logger: new NestLogger(),
});
- await jobQueue.get(QueueProcessorService).start();
- await jobQueue.get(ChartManagementService).start();
+ jobQueue.get(QueueProcessorService).start();
+ jobQueue.get(ChartManagementService).start();
return jobQueue;
}
diff --git a/packages/backend/src/daemons/QueueStatsService.ts b/packages/backend/src/daemons/QueueStatsService.ts
index 77fcd71337..ede104b9fe 100644
--- a/packages/backend/src/daemons/QueueStatsService.ts
+++ b/packages/backend/src/daemons/QueueStatsService.ts
@@ -33,7 +33,7 @@ export class QueueStatsService implements OnApplicationShutdown {
* Report queue stats regularly
*/
@bindThis
- public async start(): Promise<void> {
+ public start(): void {
const log = [] as any[];
ev.on('requestQueueStatsLog', x => {
@@ -82,7 +82,7 @@ export class QueueStatsService implements OnApplicationShutdown {
activeInboxJobs = 0;
};
- await tick();
+ tick();
this.intervalId = setInterval(tick, interval);
}
diff --git a/packages/backend/src/daemons/ServerStatsService.ts b/packages/backend/src/daemons/ServerStatsService.ts
index 2ab087477a..6e9d29dcbd 100644
--- a/packages/backend/src/daemons/ServerStatsService.ts
+++ b/packages/backend/src/daemons/ServerStatsService.ts
@@ -68,7 +68,7 @@ export class ServerStatsService implements OnApplicationShutdown {
if (log.length > 200) log.pop();
};
- await tick();
+ tick();
this.intervalId = setInterval(tick, interval);
}