Интеграция MongoDB и API - создайте нового пользователя, если он еще не существует

Question

Я пытаюсь сохранить таблицу пользователей на MongoDB, которая содержит выдержки из нашего канала Slack, к которым мы можем получить доступ из Slack API.В данный момент я пытаюсь проверять каждый раз, когда мы загружаем сервер, есть ли какие-либо новые члены канала и, если да, создавать нового пользователя.

Вот сценарий, который в настоящее время сообщает мне, что всеПользователи уже существуют, но моя таблица пользователей имеет только 1 запись на данный момент, и она должна была создать еще 6 пользователей.slack_data - это результаты вызова слабого API.

const Users = require('../models/users');
const _ = require('lodash');

function Database(){

}

Database.prototype.integration = function(slack_data){
  var jsonLength = Object.keys(slack_data).length;
  var i;

  for (i = 0; i <= jsonLength; i++) {
    if (Users.find({slack_id: slack_data.members[i].id}) != 'undefined'){
      console.log('User already exists');
    }
    else{
      Users.create({
        name: slack_data.members[i].real_name,
        slack_id: slack_data.members[i].id,
        slack_image: slack_data.members[i].profile.image_192,
        slack_image_48: slack_data.members[i].profile.image_48,
        slack_image_512: slack_data.members[i].profile.image_512
      })
      console.log(slack_data.members[i].real_name, " created");
    }
  }
}

module.exports = Database;

Фактический вывод console.log, который я получаю:

undefined
User already exists
User already exists
User already exists
User already exists
User already exists

Это опять-таки немного странно, какв Slack API есть 7 пользовательских записей.

Структура Slack API выглядит следующим образом:

{
ok: true,
members: [
{
id: "USLACKBOT",
team_id: "TCW7",
name: "slackbot",
deleted: false,
color: "757575",
real_name: "slackbot",
tz: null,
tz_label: "Pacific Daylight Time",
tz_offset: -25200,
profile: {
title: "",
phone: "",
skype: "",
real_name: "slackbot",
real_name_normalized: "slackbot",
display_name: "slackbot",
display_name_normalized: "slackbot",
fields: null,
status_text: "",
status_emoji: "",
status_expiration: 0,
avatar_hash: "sv1444671949",
always_active: true,
first_name: "slackbot",
last_name: "",
image_24: "https://a.slack-edge.com/0180/img/slackbot_24.png",
image_32: "https://a.slack-edge.com/7f1a0/plugins/slackbot/assets/service_32.png",
image_48: "https://a.slack-edge.com/7f1a0/plugins/slackbot/assets/service_48.png",
image_72: "https://a.slack-edge.com/0180/img/slackbot_72.png",
image_192: "https://a.slack-edge.com/66f9/img/slackbot_192.png",
image_512: "https://a.slack-edge.com/1801/img/slackbot_512.png",
status_text_canonical: "",
team: "TCW7"
},
is_admin: false,
is_owner: false,
is_primary_owner: false,
is_restricted: false,
is_ultra_restricted: false,
is_bot: false,
is_app_user: false,
updated: 0
},

Можете ли вы помочь мне выяснить, что происходит, и предложить, как я мог бы выполнитьТребуется создание пользователя?

Изменения На основе выбранного ответа ниже

Используя опцию Await, мой код теперь выглядит следующим образом:

const Users = require('../models/users');
const _ = require('lodash');

function Database(){

}

Database.prototype.integration = async (slack_data) => {
  let newUsers = [];

  for (let i = 0; i < slack_data.members.length; i++) {
    const user = await Users.findOne({slack_id: slack_data.members[i].id});

    if (!user || typeof user.slack_id === 'undefined') {
      newUsers.push({
        name: slack_data.members[i].real_name,
        slack_id: slack_data.members[i].id,
        slack_image: slack_data.members[i].profile.image_192,
        slack_image_48: slack_data.members[i].profile.image_48,
        slack_image_512: slack_data.members[i].profile.image_512
      });
    };
  }

  const newSlackUsers = await Users.insertMany(newUsers);
  console.log('New users created ', newSlackUsers);
}

  module.exports = Database;

Answer 1

Метод find() является асинхронным, и неизвестно, когда эти функции будут завершены из-за их асинхронной природы или в каком порядке они завершатся, когда вы поместите их в цикл for.

ТамЕсть несколько способов борьбы с этим.Вы можете использовать обещание по умолчанию, возвращаемое при вызове метода exec() в методах findOne() или find().

Вы также можете использовать асинхронное / ожидание, в котором асинхронная функция может быть заблокирована ожиданием / обещанием.поэтому итерация массива может быть заблокирована до ожидаемого ответа.

Другой вариант заключается в использовании немедленно вызванной анонимной функции, которая обеспечивает вызов асинхронных функций с правильным значением индексной переменной.

Давайте рассмотрим каждый вариант с примерами.

Использование обещаний

const _ = require('lodash');

Database.prototype.integration = (slack_data) => {
    let userPromises = [];

    for (let i = 0; i < slack_data.members.length; i++) {
        const user = User.findOne({slack_id: slack_data.members[i].id}).lean().exec();
        userPromises.push(user);
    }

    Promise.all(userPromises).then(users => {
        const memberIds = slack_data.members.map(s => s.id);
        const slackIds = users.map(u => u.slack_id);
        const newUserIds = _.difference(slackIds, memberIds);

        const newUsers = newUserIds.map(id => {
            const member = _.find(slack_data.members, ['id', id]);
            return {
                name: member.real_name,
                slack_id: member.id,
                slack_image: member.profile.image_192,
                slack_image_48: member.profile.image_48,
                slack_image_512: member.profile.image_512 
            }
        );

        return User.insertMany(newUsers);
    }).then(newUsers => console.log('New users created ', newUsers));

}

Использование async / await

Database.prototype.integration = async (slack_data) => {
    let newUsers = [];

    for (let i = 0; i < slack_data.members.length; i++) {
        const user = await User.findOne({slack_id: slack_data.members[i].id}).lean().exec();
        if (typeof user === 'undefined') {
            newUsers.push({
                name: slack_data.members[i].real_name,
                slack_id: slack_data.members[i].id,
                slack_image: slack_data.members[i].profile.image_192,
                slack_image_48: slack_data.members[i].profile.image_48,
                slack_image_512: slack_data.members[i].profile.image_512
            });
        };
    }

    const newSlackUsers = await User.insertMany(newUsers);
    console.log('New users created ', newSlackUsers);

}

Использование IIFE (выражение для немедленного вызова функции)

Database.prototype.integration = (slack_data) => {
    let newUsers = [];

    for (let i = 0; i < slack_data.members.length; i++) {
        (function(idx){
            User.indOne({ slack_id: slack_data.members[idx].id }, (err, user) => {
                if (typeof user === 'undefined') {
                    newUsers.push({
                        name: slack_data.members[idx].real_name,
                        slack_id: slack_data.members[idx].id,
                        slack_image: slack_data.members[idx].profile.image_192,
                        slack_image_48: slack_data.members[idx].profile.image_48,
                        slack_image_512: slack_data.members[idx].profile.image_512
                    });
                 };
            });
        }(i));
    }

    User.insertMany(newUsers, (err, newSlackUsers) => {
        console.log('New slack users created ', newSlackUsers);
    });
}

Answer 2

Вы делаете неправильно в найти

User.findOne({slack_id: slack_data.members[i].id})
        .then((user) => {
          if (user) {
             console.log('User already exists');
          } else {
              //Create new User.
          }
        })
        .catch((err) => {
          //handle Error
        });