import { Cron } from 'croner'
import { queuePendingPostExportJobs } from '../repositories/post-export-repository'

/**
 * 대기·중단된 게시물 Export 작업 실행을 요청한다.
 * @returns {Promise<void>}
 */
const queuePostExportWork = async () => {
  try {
    await queuePendingPostExportJobs()
  } catch (error) {
    console.error('[post-export] 작업 복구 확인 실패', error)
  }
}

/**
 * 서버 시작과 주기 확인으로 게시물 Export 작업을 복구한다.
 */
export default defineNitroPlugin(() => {
  if (process.env.NUXT_POST_EXPORT_WORKER === '0' || process.env.PLAYWRIGHT_TEST === '1') {
    return
  }

  queuePostExportWork()

  new Cron('*/30 * * * * *', {
    protect: true
  }, queuePostExportWork)
})