Разрешить обещание внутри цепи - PullRequest
0 голосов
/ 09 июня 2018

У меня проблемы с выполнением обещаний внутри цепочки.В JSBin ниже вы можете увидеть код, который у меня есть (NodeJS и mongo).Как я могу вернуть данные с 2 уровней вниз по цепочке?Вот код и JSBIN

function test(url) {
  return new Promise((resolve, reject) => {
  return scrapeIt({
    url: url,
    headers: { 'User-agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/66.0.3359.139 Safari/537.36' }
  }, {
      urls: {
        listItem: '#list',
        data: {
          url: {
            selector: "span[data-label='url']"
          }
        }
      },
      currentPage: {
        selector: 'span.current',
        convert: x => parseInt(x)
      },
      pages: {
        selector: 'span.pages',
        convert: x => parseInt(x)
      }
    }).then(({ data, response }) => {
      return MongoClient.connect(config.db.serverUrl, function (err, db) {
        var dbo = db.db(config.db.name)
        var urlsToInsert = data.urls

        return dbo.collection(config.db.collection).find({ 'url': { '$in': data.urls } }, { projection: { _id: 0 } }).toArray(function (err, res) {
          if (res && res.length > 0) {
            // Exclude properties already in DB
            urlsToInsert = urlsToInsert.filter(x => !res.some(y => x.url == y.url))
            if (urlsToInsert && urlsToInsert.length > 0)
              return dbo.collection(config.db.collection).insertMany(urlsToInsert, function (err, res) {
                console.log("Number of documents inserted: " + res.insertedCount)

                db.close()
                return urlsToInsert
              })
          }
        })
      })
    })
})
}

test('https://www.google.com').then(({ data, response }) => {
  console.log(data)
}).catch((error) => {
  console.log(error)
})

Фрагмент JSBin

Обновление 1

Мой фактический код намного длиннее, поэтому я вынул многокод, который не был необходим для решения проблемы.Я исправил проблему с нулем urlsToInsert.Также возвращаемся теперь urlsToInsert.

1 Ответ

0 голосов
/ 09 июня 2018

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

Вы возвращаете propertiesToInsert, который никогда не определялсяв любом месте вашего кода.

.then(
  ({ data, response }) =>
    new Promise(
      (resolve,reject)=>
        MongoClient.connect(config.db.serverUrl,(err, db) =>
          (err, db) =>
            (err)
              ? reject(err)
              : resolve(db.db(config.db.name))
        )
    )
).then(
  dbo=>
    new Promise(
      (resolve,reject)=>
        dbo.collection(config.db.collection).find(
          { 'url': { '$in': data.urls } },
          { projection: { _id: 0 } }
        ).toArray((err, res) =>
          (err)
            ? reject(err)
            : resolve(res)
        )
    ).then(
      res=>{
        var urlsToInsert = [];
        if (res && res.length > 0) {
          // Exclude properties already in DB THIS MAKES NO SENSE, FILTERING AN EMPTY ARRAY
          urlsToInsert = urlsToInsert.filter(x => !res.some(y => x.url == y.url))
          if (urlsToInsert && urlsToInsert.length > 0) {
            return new Promise(
              (resolve,reject)=>
                dbo.collection(config.db.collection).insertMany(urlsToInsert, function (err, res) {
                  if(err){reject(err);}//this never happens anyway
                  console.log("Number of documents inserted: " + res.insertedCount);    
                  db.close();
                  //what are you returning here?
                  resolve(propertiesToInsert)
                })
            )
          } 
          return [];//what to return if there are no urls to insert (always because you're filtering empty array)
        }
      }
    )
)
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...