Merge fdb3faa into 4c01aa5

command/CommandController.js

@@ -60,6 +60,15 @@ const articleOptions = {
   }
 };
 
+const exploreUri =
+  'https://getpocket.com/v3/getExploreFeed?locale_lang=en-US&version=2&' +
+  'consumer_key=' +
+  process.env.POCKET_KEY;
+const explorePocketOptions = {
+  uri: '',
+  method: 'GET'
+};
+
 const summaryLink =
   'https://api.smmry.com?SM_API_KEY=' + process.env.SM_API_KEY + '&SM_URL=';
 logger.info('SummaryLink Creation is: ' + summaryLink);
@@ -635,6 +644,57 @@ router.get('/search', VerifyToken, async function(req, res) {
   }
 });
 
+router.post('/trending', VerifyToken, async function(req, res) {
+  let topicArray = req.body.topic;
+  let resArray = [];
+  console.log('topic array is: ' + topicArray);
+  for (var i = 0; i < req.body.topic.length; i++) {
+    let jsonRes = await getTopicRecommendations(
+      req.body.topic[i],
+      req.body.count
+    );
+    //console.log(jsonRes);
+    resArray = resArray.concat(jsonRes);
+  }
+
+  console.log(resArray);
+  res.send(resArray);
+});
+
+async function getTopicRecommendations(topic, count) {
+  return new Promise(resolve => {
+    explorePocketOptions.uri = exploreUri + `&query=${topic}&count=${count}`;
+    // console.log(explorePocketOptions.uri);
+    rp(explorePocketOptions).then(function(body) {
+      var jsonBody = JSON.parse(body);
+      let promiseArray = [];
+      if (jsonBody.status == '1') {
+        Object.keys(jsonBody.feed).forEach(key => {
+          let item = jsonBody.feed[key].item;
+          let recItem = {
+            id: item.resolved_id,
+            image_url: item.top_image_url,
+            title: item.title,
+            url: item.resolved_url
+          };
+          if (item.domain_metadata) {
+            recItem['logo'] = item.domain_metadata.logo
+              ? item.domain_metadata.logo
+              : '';
+            recItem['domain_name'] = item.domain_metadata.name
+              ? item.domain_metadata.name
+              : '';
+          }
+
+          // console.log(recItem);
+          promiseArray.push(recItem);
+        });
+        resolve(promiseArray);
+      }
+    });
+  });
+}
+
 function logMetric(cmd, userid, agent) {
   if (process.env.GA_PROPERTY_ID) {
     logger.info('User-Agent is : ' + agent);