Блог

Я создаю CronJob, который вызывает API и сохраняет его ответ в базе данных:

 const CronJob = require("cron").CronJob;
const btc_price_ticker = require("../../controllers/BtcExchange/Ticker");
const currency = require("../../controllers/Currencies/CurrenciesController");

module.exports = new CronJob("* * * * * *", async function() {
  const {
    ticker: { sell }
  } = await btc_price_ticker.getBtcPrice();
  currency
    .update({
      params: {
        id: "5cbdf078f5bcec257fcec792"
      },
      body: {
        exchange_rate: sell,
        lastUpdate: Date.now()
      }
    })
    .catch(error => console.log(error));
});
  

Это работает нормально, однако я получаю TypeError: Cannot read property 'json' of undefined

Я использую ту же функцию для обновления базы данных, которую я использую при обновлении моим API:

 module.exports = {
  async update(req, res) {
    const currency = await Currency.findByIdAndUpdate(req.params.id, req.body, {
      new: true
    });
    return res.json(currency);
  }
};
  

TypeError Происходит в return res.json(currency) , и это происходит только тогда, когда оно вызывается CronJob. Когда я добавляю новую информацию с помощью API, она не показывает никакой ошибки.

Я думаю, это происходит потому, что когда я вызываю функцию в CronJob , я просто передаю req параметр by, но я не знаю, как это решить. Что я должен делать?

Заранее спасибо!

Есть известное высказывание, в котором говорится, что вы можете решить практически любую проблему в CS, добавив еще один уровень косвенности. Это один из таких случаев:

Вместо объявления вашего модуля как:

 module.exports = {
  async update(req, res) {
    const currency = await Currency.findByIdAndUpdate(req.params.id, req.body, {
      new: true
    });
    return res.json(currency);
  }
};
  

Отделите логику от логики маршрута:

 module.exports = {

  async getCurrency(id, params) {
      const currency = await Currency.findByIdAndUpdate(id, params, {
        new: true
      });
      return currency;
  }

  async update(req, res) {
    const currency = await getCurrency(req.params.id, req.body);
    return res.json(currency);
  }
};
  

Теперь маршрут может вызывать update() , а cron-задание может вызывать getCurrency() напрямую.

Хорошо, возможно, мой подход не самый лучший, но поскольку я передаю неопределенный объект в update() , и мне не нужен ответ, я отредактировал update функцию:

 async update(req, res) {
    const currency = await Currency.findByIdAndUpdate(req.params.id, req.body, {
      new: true
    });
    if (res !== undefined) {
      return res.json(currency);
    }
  }
  

Итак, поскольку значение res не определено, оно ничего не возвращает.

Это потому, что оба req и res являются undefined (или, по крайней мере, не являются надлежащим request объектом response ), когда маршрут не запрашивается клиентом (что имеет место здесь).

Самое простое решение, о котором я могу подумать, — это имитировать (или выполнить фактический вызов) вызов клиента в вашей cron работе, используя такие модули, как axios , request , request-promise (с Promise оболочкой поверх запроса), например:

 const rp = require('request-promise')

module.exports = new CronJob("* * * * * *", async function() {
  try {
    const {
      ticker: { sell }
    } = await btc_price_ticker.getBtcPrice();
    // assuming your server is running in localhost, port 3000 and route is 'myapi/:id'
    const url = "http://localhost:3000/myapi/5cbdf078f5bcec257fcec792";
    const options = {
      method: 'GET',
      uri : url,
      json: true,
      body: {
        exchange_rate: sell,
        lastUpdate: Date.now()
      }
    }
    const response = await rp(url);
  } catch(error) {
    console.log(error);
  }
});
  

Поскольку вы можете выполнять db методы, более простой альтернативой было бы прямое выполнение Currency.findByIdAndUpdate в вашем cron задании. Я не вижу никаких причин, по которым вы хотели бы вызвать свой route в своем коде.