Прослушивание для завершения работы Повестки дня - PullRequest
Новая
       23

Прослушивание для завершения работы Повестки дня

0 голосов
/ 27 мая 2018

Я пытаюсь создать криптографическую систему вывода, и мне нужно убедиться, что система не дублируется и т. Д., Поэтому я решил использовать Agenda, чтобы выручить меня.Проблема, с которой я столкнулся, заключается в том, что мне нужно прослушивать завершение работы, чтобы извлечь идентификатор транзакции из вновь отправленной транзакции.Это будет доступно только после завершения работы, и я не могу найти ничего об использовании слушателя для одной работы.

Вот раздел моего кода: 

let pendingUserWithdrawJob = await Job.count({ name: "withdraw_order", "data.userId": user._id, completed: { $ne: true } });
    if (pendingUserWithdrawJob > 0) return 1;

    const job = global.agenda.create('withdraw_order', {userId: user._id, recipientAddress: addr, amount, txid: null });
    job.save((err) => {
        if (err) return false;

        return msg.reply('Successfully withdrawn! TXID: ' + job.attrs.data.txid);
    });

Этоперед любым видом проверки на завершение, и txid возвращает ноль, что и ожидается.

Вот мой код определения повестки дня: 

agenda.define('withdraw_order', async function(job, done) {
    let result = await paymentProcessor.performWithdraw(job);
    if (result.error) return done(result.error);
    done();
});

Рассматриваемая функция executeWithdraw: 

async performWithdraw(options) {
    try {
        await this.withdraw(options);
        return { success: true };
    } catch(e) {
        this.reportException(e);
        return { error: e };
    }
}

this.withdraw: 

async withdraw(job) {
    // parameters
    const userId            = job.attrs.data.userId;
    const recipientAddress  = job.attrs.data.recipientAddress;
    const amount            = job.attrs.data.amount;

    // Validate if user is present
    let user = await models.User.findById(userId);
    if (!user) throw new Error(`User ${userId} not found`);
    await models.User.validateWithdrawAmount(user, amount);

    // Step 1: Process transaction
    let sendID;

    if (job.attrs.sendStepCompleted) {
        sendID = job.attrs.txid;
    } else {
        const sent = await this.pivxClient.send(recipientAddress, amount);
        if (sent.error) throw new Error(sent.error);
        await models.Job.findOneAndUpdate({ _id: job.attrs._id} , { "data.sendStepCompleted": true, "data.txid": sent.txid });
    }

    // Step 2: Update user balance
    if (!job.attrs.userStepCompleted) {
        await models.User.withdraw(user, amount);
        await models.Job.findByIdAndUpdate(job.attrs._id, { "data.userStepCompleted": true });
    }

    // Step 3: Record Transaction
    if (!job.attrs.transactionStepCompleted) {
        await models.Transaction.create({ userId: userId, withdraw: amount, txid: sendID });
        await models.Job.findByIdAndUpdate(job.attrs._id, { "data.transactionStepCompleted": true });
    }

    return sendID;
}

Заранее извиняюсь за беспорядок кода, я просто хотел убедиться, что я не пропустил ничего, что могло бы быть важным.Как я могу прослушать выполнение задания, не используя setInterval и не проверяя наличие транзакцииStepCompleted?

1 Ответ

0 голосов
/ 22 февраля 2019

Использование событий очереди заданий

Экземпляр повестки дня будет генерировать следующие события:

start - вызывается непосредственно перед началом задания

start: имя задания - вызывается непосредственно перед началом указанного задания

complete - вызывается при завершении задания, независимо от того, выполнено ли оно или не удается

complete: имя задания - вызывается призадание завершается независимо от того, успешно оно или нет

https://github.com/agenda/agenda#job-queue-events


agenda.on('start', job => {
  console.log('Job %s starting', job.attrs.name);
});

agenda.on('complete', job => {
  console.log(`Job ${job.attrs.name} finished`);
});
...