Deepak S
40 lines
1.0 KiB
TypeScript
40 lines
1.0 KiB
TypeScript
import { env } from "./env";
|
|
import { isCloud , isEmailCleanupEnabled } from "./utils/common";
|
|
|
|
let initialized = false;
|
|
|
|
/**
|
|
* Add things here to be executed during server startup.
|
|
*
|
|
* more details here: https://nextjs.org/docs/app/building-your-application/optimizing/instrumentation
|
|
*/
|
|
export async function register() {
|
|
// eslint-disable-next-line turbo/no-undeclared-env-vars
|
|
if (process.env.NEXT_RUNTIME === "nodejs" && !initialized) {
|
|
console.log("Registering instrumentation");
|
|
|
|
const { EmailQueueService } = await import(
|
|
"~/server/service/email-queue-service"
|
|
);
|
|
await EmailQueueService.init();
|
|
|
|
/**
|
|
* Send usage data to Stripe
|
|
*/
|
|
if (isCloud()) {
|
|
await import("~/server/jobs/usage-job");
|
|
}
|
|
|
|
if (isEmailCleanupEnabled()) {
|
|
await import("~/server/jobs/cleanup-email-bodies");
|
|
}
|
|
|
|
const { CampaignSchedulerService } = await import(
|
|
"~/server/jobs/campaign-scheduler-job"
|
|
);
|
|
await CampaignSchedulerService.start();
|
|
|
|
initialized = true;
|
|
}
|
|
}
|