| } | } | ||||
| } | } | ||||
| await collection.updateOne({ _id: _id }, { $set: { status: "done", result: properties } }); | |||||
| await collection.updateOne({ _id: _id }, { $set: { status: "done", result: properties, endDate: new Date() } }); | |||||
| console.log(`${_id} scraped.`); | console.log(`${_id} scraped.`); | ||||
| return done(); | return done(); | ||||
| } catch (err) { | } catch (err) { | ||||
| let collection = dbo.collection('scrapes'); | let collection = dbo.collection('scrapes'); | ||||
| var o_id = new ObjectID(id); | var o_id = new ObjectID(id); | ||||
| var newvalues = { $set: { status: "pending" } }; | |||||
| var newvalues = { $set: { status: "pending", startDate: new Date() } }; | |||||
| await collection.updateOne({ _id: o_id }, newvalues); | await collection.updateOne({ _id: o_id }, newvalues); | ||||
| agenda.now('scrape', { _id: o_id }); | agenda.now('scrape', { _id: o_id }); | ||||
| return res.status(204).json(); | return res.status(204).json(); |