const mq = require('./index')
const { assertRunforgeTaskIngress, publishRunforgeTask } = require('./runforgeTaskMq')

async function enqueueLepaoSyncAccountInfo(studentNum, logger) {
    if (!studentNum) return
    try {
        const channel = await mq.getChannel('lepao_account_sync')
        await assertRunforgeTaskIngress(channel, logger)
        const taskId = `lepao:sync-account:${Date.now()}:${studentNum}`
        publishRunforgeTask(channel, {
            id: taskId,
            type: 'lepao.syncAccountInfo',
            data: {
                taskId,
                student_num: studentNum
            },
            retry: 0
        })
    } catch (e) {
        logger?.error?.(`投递乐跑账号同步任务失败 ${studentNum}: ${e.message || e}`)
    }
}

module.exports = { enqueueLepaoSyncAccountInfo }