refactor: cron plugin

Author: winverse

apps/cron/Dockerfile

@@ -27,7 +27,7 @@ ARG TURBO_TOKEN
 ENV TURBO_TOKEN=${TURBO_TOKEN}
 
 ARG TURBO_REMOTE_CACHE_SIGNATURE_KEY
-ENV TURBO_REMOTE_CACHE_SIGNATURE_KEY=${TURBO_REMOTE_CACHE_SIGNATURE_KEY}
+ENV TURBO_REMOTE_CACHE_SIGNATURE_KEY=$TURBO_REMOTE_CACHE_SIGNATURE_KEY
 
 ENV APP_NAME="cron"
 ENV APP_DIR="apps/${APP_NAME}"

apps/cron/src/common/plugins/global/cronPlugin.mts

@@ -90,22 +90,21 @@ const cronPlugin: FastifyPluginAsync = async (fastfiy) => {
   }
 
   const initializeJobs = async () => {
+    console.log('Initializing cron jobs...')
     if (ENV.appEnv !== 'production') {
-      console.log('start')
-      const immediateRunJobs = jobDescription.filter((job) => !!job.isImmediateExecute)
-      await Promise.all(immediateRunJobs.map(createTick))
-      const crons = immediateRunJobs.map(createJob)
+      const immediateRunJobs = jobDescription.filter((job) => job.isImmediateExecute)
+      const crons = await Promise.all(immediateRunJobs.map(createJob))
       for (const cron of crons) {
-        console.log(`${cron.name} is registered`)
         cron.start()
+        console.log(`${cron.name} is registered`)
       }
     }
 
-    if (ENV.dockerEnv === 'production') {
-      const crons = jobDescription.map(createJob)
+    if (['production', 'stage'].includes(ENV.dockerEnv)) {
+      const crons = await Promise.all(jobDescription.map(createJob))
       for (const cron of crons) {
-        console.log(`${cron.name} is registered`)
         cron.start()
+        console.log(`${cron.name} is registered`)
       }
     }
   }

infrastructure/Pulumi.production.yaml

@@ -1,4 +1,4 @@
 config:
   aws:region: ap-northeast-2
   velog:DOCKER_ENV: production
-  velog:target: server
+  velog:target: cron

infrastructure/Pulumi.stage.yaml

@@ -1,4 +1,4 @@
 config:
   aws:region: ap-northeast-2
   velog:DOCKER_ENV: stage
-  velog:target: server
+  velog:target: cron