[cron] setup app env properly when running tasks

apps/cron/20260201-000000/lib/executor.ts

@@ -1,4 +1,5 @@
 import { join } from 'path'
+import { loadAppEnv } from '@because/toes/tools'
 import type { CronJob } from './schedules'
 import { getNextRun } from './scheduler'
 
@@ -32,7 +33,7 @@ export async function executeJob(job: CronJob, onUpdate: () => void): Promise<vo
   try {
     const proc = Bun.spawn(['bun', 'run', RUNNER, job.file], {
       cwd,
-      env: { ...process.env, DATA_DIR: join(TOES_DIR, job.app) },
+      env: { ...process.env, ...loadAppEnv(job.app), DATA_DIR: join(TOES_DIR, job.app) },
       stdout: 'pipe',
       stderr: 'pipe',
     })

src/server/apps.ts

@@ -3,6 +3,7 @@ import type { Subprocess } from 'bun'
 import { DEFAULT_EMOJI } from '@types'
 import { appendFileSync, existsSync, mkdirSync, readdirSync, readFileSync, realpathSync, renameSync, symlinkSync, unlinkSync, writeFileSync } from 'fs'
 import { join, resolve } from 'path'
+import { loadAppEnv } from '../tools/env'
 import { appLog, hostLog, setApps } from './tui'
 
 export type { AppState } from '@types'
@@ -495,34 +496,6 @@ function loadApp(dir: string): LoadResult {
   }
 }
 
-function loadAppEnv(appName: string): Record<string, string> {
-  const envDir = join(TOES_DIR, 'env')
-  const env: Record<string, string> = {}
-
-  const parseEnvFile = (path: string) => {
-    if (!existsSync(path)) return
-    const content = readFileSync(path, 'utf-8')
-    for (const line of content.split('\n')) {
-      const trimmed = line.trim()
-      if (!trimmed || trimmed.startsWith('#')) continue
-      const eqIndex = trimmed.indexOf('=')
-      if (eqIndex === -1) continue
-      const key = trimmed.slice(0, eqIndex).trim()
-      let value = trimmed.slice(eqIndex + 1).trim()
-      // Remove surrounding quotes
-      if ((value.startsWith('"') && value.endsWith('"')) ||
-          (value.startsWith("'") && value.endsWith("'"))) {
-        value = value.slice(1, -1)
-      }
-      if (key) env[key] = value
-    }
-  }
-
-  parseEnvFile(join(envDir, '_global.env'))
-  parseEnvFile(join(envDir, `${appName}.env`))
-
-  return env
-}
 
 function maybeResetBackoff(app: App) {
   if (app.started && Date.now() - app.started >= STABLE_RUN_TIME) {
@@ -599,7 +572,7 @@ async function runApp(dir: string, port: number) {
   info(app, `Starting on port ${port}...`)
 
   // Load env vars from TOES_DIR/env/
-  const appEnv = loadAppEnv(dir)
+  const appEnv = loadAppEnv(dir, TOES_DIR)
 
   const proc = Bun.spawn(['bun', 'run', 'toes'], {
     cwd,

src/tools/env.ts

@@ -0,0 +1,30 @@
+import { existsSync, readFileSync } from 'fs'
+import { join } from 'path'
+
+export function loadAppEnv(appName: string, toesDir?: string): Record<string, string> {
+  const envDir = join(toesDir || process.env.TOES_DIR!, 'env')
+  const env: Record<string, string> = {}
+
+  const parseEnvFile = (path: string) => {
+    if (!existsSync(path)) return
+    const content = readFileSync(path, 'utf-8')
+    for (const line of content.split('\n')) {
+      const trimmed = line.trim()
+      if (!trimmed || trimmed.startsWith('#')) continue
+      const eqIndex = trimmed.indexOf('=')
+      if (eqIndex === -1) continue
+      const key = trimmed.slice(0, eqIndex).trim()
+      let value = trimmed.slice(eqIndex + 1).trim()
+      if ((value.startsWith('"') && value.endsWith('"')) ||
+          (value.startsWith("'") && value.endsWith("'"))) {
+        value = value.slice(1, -1)
+      }
+      if (key) env[key] = value
+    }
+  }
+
+  parseEnvFile(join(envDir, '_global.env'))
+  parseEnvFile(join(envDir, `${appName}.env`))
+
+  return env
+}

src/tools/index.ts

@@ -1,2 +1,3 @@
 export { theme } from '../client/themes'
+export { loadAppEnv } from './env'
 export { baseStyles, ToolScript } from './scripts.tsx'