pg-обещание - не разрешает несколько запросов

Question

Я нахожусь в процессе создания массовой рассылки, которая позволяет компании отправлять шаблон электронной почты определенному плану, который содержит X количество подписчиков.

Однако, используя pg-обещание, я не могу понять, как перебрать массив, содержащий одно или несколько уникальных имен планов, которые затем будут использоваться в качестве параметров запроса для последующих запросов, чтобы собрать один массив результатов. Последующие запросы не разрешаются до того, как экспресс отправит обратно указанное сообщение об ошибке.

Например:

const selectedTemplate = await db.oneOrNone("SELECT * FROM templates WHERE userid=$1 and uniqueTemplateName=$2", [req.session.id, req.body.uniquetemplatename])

возвращает объект JSON ...

{ ...
  plans : [ 'Unique Plan 1', 'Unique Plan 2', 'Unique Plan 3'...],
  ...
}

Затем я хочу просмотреть этот массив plans, чтобы собрать электронные письма подписчиков. Поскольку массив plans selectedTemplate может содержать один или несколько уникальных планов, я пытаюсь выяснить, как заставить этот запрос работать:

let subscriberEmails = [];

await each(selectedTemplate.plans, async plan => {
  const emails = await db.any("SELECT email FROM subscribers WHERE userid=$1 AND planName=$2", [req.session.id, plan])          
  each(emails, ({email}) => subscriberEmails.push(email))           
  console.log('Found emails: ', subscriberEmails);
})

console.log('Selected emails: ', subscriberEmails);
res.status(500).json({ message: "Route not configured yet" })

Проблема, с которой я столкнулся, заключается в том, что Express не ожидает разрешения pg-обещания. Таким образом, он вызывает сообщение моего сервера 500 «Маршрут еще не настроен», затем разрешает запросы:

14:48:33 SELECT * FROM templates WHERE userid='12345' and uniqueTemplateName='example-unique-template'

        selectedTemplate: anonymous {
          id: '84efa448-b149-11e8-a7fd-3b9e4e9e5ece',
          key: 9,
          userid: '12345',
          status: 'active',
          fromsender: 'example@helpdesk.com',
          subject: 'Thank you for using our services!',
          templatename: 'Example Unique Template',
          uniquetemplatename: 'example-unique-template',
          message: '<h3>This is a test!</h3>',
          plans: [ 'Unique Plan 1', 'Unique Plan 2' ] 
        }

        Selected emails: []

POST /api/messages/create 500 28 - 34.125 ms

14:48:33 SELECT email FROM subscribers WHERE userid='12345' AND planName='Unique Plan 1'

        Found emails:  [ 
         'betatester19@example.com',
         'betatester20@example.com',
         'betatester21@example.com'
        ]

14:48:34 SELECT email FROM subscribers WHERE userid='12345' AND planName='Unique Plan 2'

        Found emails:  [ 
         'betatester19@example.com',
         'betatester20@example.com',
         'betatester21@example.com',
         'betatester1@example.com',
         'betatester2@example.com',
         'betatester3@example.com',
         'betatester4@example.com',
         'betatester5@example.com',
         'betatester6@example.com',
         'betatester7@example.com',
         'betatester8@example.com',
         'betatester9@example.com',
         'betatester10@example.com',
         'betatester11@example.com',
         'betatester12@example.com',
         'betatester13@example.com',
         'betatester14@example.com',
         'betatester15@example.com',
         'betatester16@example.com',
         'betatester17@example.com',
         'betatester18@example.com' 
        ]

Функция как есть:

async (req, res, done) => {
    if (!req.body) {
      return res.status(404).json({ message: "Missing query parameters" });
      done();
    }

    try {
      const selectedTemplate = await db.oneOrNone("SELECT * FROM templates WHERE userid=$1 and uniqueTemplateName=$2", [req.session.id, uniquetemplatename]);
      if (!selectedTemplate) {
        return res.status(404).json({ message: "Unable to locate selected template" });
        done();
      }
      console.log('selectedTemplate', selectedTemplate);

      let subscriberEmails = [];
      await each(selectedTemplate.plans, async plan => {
        const emails = await db.any("SELECT email FROM subscribers WHERE userid=$1 AND planName=$2", [req.session.id, plan])
        each(emails, ({email}) => subscriberEmails.push(email))
        console.log('Found emails: ', subscriberEmails);
      })

      console.log('Selected emails: ', subscriberEmails); 
      res.status(500).json({ message: "Route not configured yet" })
    } catch (err) { res.status(500).json({ message: err }); done(); }
  }

Значительно упрощенная структура БД:

├── Template
│   └── Plans (references an array of unique plan name(s))
|
|── Plan
|   └── PlanName (unique plan name)
|
│── Subscriber
|   └── PlanName (references a single unique plan name)
|   └── Email (unique email)

Я пытался использовать db.task(), но, опять же, запросы не разрешались до того, как Express отправил сообщение обратно.

Answer 1

Разобрался, где проблема. На тот случай, если кто-то еще наткнется на это затруднительное положение: такие функции, как «карта» и «каждый», не обрабатывают async / await. Вместо этого они просто возвращают ожидающее обещание. Поэтому вы захотите использовать библиотеку, подобную Bluebird , которая реализует функции каждой / map / etc, основанные на Promise (находятся в разделе «Коллекции»).

Исправление для работы выше:

try {
  await db.task('create-message', async t => {
    const selectedTemplate = await t.oneOrNone(findTemplateByName, [req.session.id, uniquetemplatename])
    if (!selectedTemplate) return sendError(unableToLocate('template'), res, done);
    const { fromsender, subject, message, plans, templatename } = selectedTemplate;

    let subscriberEmails = [];
    await Promise.each(plans, async plan => {
        const emails = await t.any(getAllEmailsByPlan, [req.session.id, plan]);
        each(emails, ({email}) => subscriberEmails.push(email));
    })

    if (isEmpty(subscriberEmails)) return sendError(unableToLocate('subscribers in the selected plan(s)'), res, done);

    const msg = {
        to: subscriberEmails,
        from: fromsender,
        replyTo: fromsender,
        subject: subject,
        html: message
    };

    await mailer.sendMultiple(msg);

    await t.none(createMessageTransaction, [req.session.id, templatename, fromsender, subject, currentDate, plans]);

    await t.none(createNotification, [req.session.id, 'mail_outline', `The following template: ${templatename} has been sent out to the subscibers in the following ${plans.length > 1 ? "plans" : "plan"}: ${plans}.`, date]);

    return res.status(201).send(null);
  })
} catch (err) { return sendError(err, res, done); }