mirror of
https://activitypub.software/TransFem-org/Sharkey
synced 2024-12-29 11:01:17 +00:00
Synchronize server startup
This prevents an edge case where the server begins processing inbound API / AP requests before any of the chart / management daemons are ready, potentially leading to incorrect chart statistics.
This commit is contained in:
parent
f59af78d8a
commit
ffbdfa9123
3 changed files with 12 additions and 11 deletions
packages/backend/src
|
@ -19,17 +19,18 @@ export async function server() {
|
||||||
logger: new NestLogger(),
|
logger: new NestLogger(),
|
||||||
});
|
});
|
||||||
|
|
||||||
const serverService = app.get(ServerService);
|
|
||||||
await serverService.launch();
|
|
||||||
|
|
||||||
if (process.env.NODE_ENV !== 'test') {
|
if (process.env.NODE_ENV !== 'test') {
|
||||||
app.get(ChartManagementService).start();
|
await app.get(ChartManagementService).start();
|
||||||
}
|
}
|
||||||
if (!envOption.noDaemons) {
|
if (!envOption.noDaemons) {
|
||||||
app.get(QueueStatsService).start();
|
await app.get(QueueStatsService).start();
|
||||||
app.get(ServerStatsService).start();
|
await 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;
|
return app;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -38,8 +39,8 @@ export async function jobQueue() {
|
||||||
logger: new NestLogger(),
|
logger: new NestLogger(),
|
||||||
});
|
});
|
||||||
|
|
||||||
jobQueue.get(QueueProcessorService).start();
|
await jobQueue.get(QueueProcessorService).start();
|
||||||
jobQueue.get(ChartManagementService).start();
|
await jobQueue.get(ChartManagementService).start();
|
||||||
|
|
||||||
return jobQueue;
|
return jobQueue;
|
||||||
}
|
}
|
||||||
|
|
|
@ -33,7 +33,7 @@ export class QueueStatsService implements OnApplicationShutdown {
|
||||||
* Report queue stats regularly
|
* Report queue stats regularly
|
||||||
*/
|
*/
|
||||||
@bindThis
|
@bindThis
|
||||||
public start(): void {
|
public async start(): Promise<void> {
|
||||||
const log = [] as any[];
|
const log = [] as any[];
|
||||||
|
|
||||||
ev.on('requestQueueStatsLog', x => {
|
ev.on('requestQueueStatsLog', x => {
|
||||||
|
@ -82,7 +82,7 @@ export class QueueStatsService implements OnApplicationShutdown {
|
||||||
activeInboxJobs = 0;
|
activeInboxJobs = 0;
|
||||||
};
|
};
|
||||||
|
|
||||||
tick();
|
await tick();
|
||||||
|
|
||||||
this.intervalId = setInterval(tick, interval);
|
this.intervalId = setInterval(tick, interval);
|
||||||
}
|
}
|
||||||
|
|
|
@ -68,7 +68,7 @@ export class ServerStatsService implements OnApplicationShutdown {
|
||||||
if (log.length > 200) log.pop();
|
if (log.length > 200) log.pop();
|
||||||
};
|
};
|
||||||
|
|
||||||
tick();
|
await tick();
|
||||||
|
|
||||||
this.intervalId = setInterval(tick, interval);
|
this.intervalId = setInterval(tick, interval);
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue