56 lines
1.5 KiB
JavaScript
56 lines
1.5 KiB
JavaScript
const path = require('path');
|
|
require('dotenv').config({ path: path.resolve(__dirname, '../../../.env') });
|
|
const { MongoClient } = require('mongodb');
|
|
|
|
const { createNewsNode } = require('./create-news-node');
|
|
const { db } = require('../../../config/secrets');
|
|
|
|
exports.sourceNodes = function sourceChallengesSourceNodes(
|
|
{ actions, reporter },
|
|
pluginOptions
|
|
) {
|
|
function handleError(err, client, reject) {
|
|
if (err) {
|
|
if (client) {
|
|
client.close();
|
|
}
|
|
reject(err);
|
|
reporter.panic(err);
|
|
}
|
|
}
|
|
const { maximumStaticRenderCount = 100 } = pluginOptions;
|
|
const { createNode } = actions;
|
|
|
|
return new Promise((resolve, reject) =>
|
|
MongoClient.connect(
|
|
db,
|
|
{ useNewUrlParser: true },
|
|
async function(err, client) {
|
|
handleError(err, client, reject);
|
|
|
|
reporter.info('fcc-source-news connected successfully to mongo');
|
|
const db = client.db('freecodecamp');
|
|
const articleCollection = db.collection('article');
|
|
|
|
articleCollection
|
|
.aggregate([
|
|
{ $match: { featured: true } },
|
|
{ $sort: { firstPublishedDate: -1 } },
|
|
{ $limit: maximumStaticRenderCount }
|
|
])
|
|
.toArray((err, articles) => {
|
|
handleError(err, client, reject);
|
|
|
|
articles
|
|
.map(article => createNewsNode(article))
|
|
.map(node => createNode(node));
|
|
|
|
client.close();
|
|
reporter.info('fcc-source-news mongo connection closed');
|
|
return resolve();
|
|
});
|
|
}
|
|
)
|
|
);
|
|
};
|