// DigitalOcean Function invoked by scheduler triggers (see functions/project.yml).
// Calls the app's protected cron endpoint (`daily`, `late-fees`, `follow-ups`,
// `webhooks`, or `gdpr`, chosen by the trigger body) with the CRON_SECRET bearer token.
// nodejs:18 has global fetch.
async function main(args) {
  const base = (process.env.APP_BASE_URL || "").replace(/\/+$/, "")
  const secret = process.env.CRON_SECRET
  const requested = args && args.job
  const allowed = ["daily", "late-fees", "follow-ups", "webhooks", "gdpr"]
  const job = allowed.includes(requested) ? requested : "daily"

  if (!base || !secret) {
    return { statusCode: 500, body: "APP_BASE_URL or CRON_SECRET not configured" }
  }

  const res = await fetch(`${base}/api/cron/${job}`, {
    method: "GET",
    headers: { Authorization: `Bearer ${secret}` },
  })
  const body = await res.text()
  console.log(`cron ${job} -> ${res.status}: ${body.slice(0, 500)}`)

  return { statusCode: res.status, body }
}

exports.main = main
