adjusting check for null feed

This commit is contained in:
John Facey
2022-06-26 18:33:46 -05:00
parent 893916d3cd
commit f169fda24d

View File

@@ -123,13 +123,13 @@ exports.loadFeeds = function () {
linkFlayerCats = []; linkFlayerCats = [];
base(userTable) base(userTable)
.select().firstPage(function(err, records) { .select().firstPage(function (err, records) {
try { try {
records.forEach(function (record) { records.forEach(function (record) {
console.log('Retrieved title: ', record.get('title')); console.log('Retrieved title: ', record.get('title'));
console.log('Retrieved link:', record.get('link')); console.log('Retrieved link:', record.get('link'));
console.log('Retrieved category:', record.get('category')); console.log('Retrieved category:', record.get('category'));
var feedData = { var feedData = {
title: `${unescape(record.get('title'))}`, title: `${unescape(record.get('title'))}`,
@@ -169,12 +169,13 @@ exports.loadFeeds = function () {
feeds.forEach(feedBlock => { feeds.forEach(feedBlock => {
(async () => { (async () => {
const feed = parser.parseURL(feedBlock.link, function (err, feed) { const feed = parser.parseURL(feedBlock.link, function (err, feed) {
if (err) { if (err) {
console.log(err + " " + feedBlock.link); console.log(err + " " + feedBlock.link);
//return; //return;
} }
if (feed.items !== null) {
if (feed !== null) {
feed.items.forEach(item => { feed.items.forEach(item => {
var foundFeed = false; var foundFeed = false;
linkFlayerMap.forEach(linkFlay => { linkFlayerMap.forEach(linkFlay => {
@@ -195,8 +196,8 @@ exports.loadFeeds = function () {
}); });
} }
}) })
})().then(); })().then();
}); });
return; return;
@@ -207,7 +208,7 @@ exports.loadFeeds = function () {
} }
exports.getAnswer = async function (question) { exports.getAnswer = async function (question) {
var answerURL = `https://api.duckduckgo.com/?q=${question}&format=json&pretty=1`; var answerURL = `https://api.duckduckgo.com/?q=${question}&format=json&pretty=1`;
console.log(answerURL); console.log(answerURL);
answerData = { answerData = {
@@ -249,14 +250,14 @@ exports.getSlang = async function (question) {
await axios.get(answerURL) await axios.get(answerURL)
.then(response => { .then(response => {
console.log(response.data.list[0]); console.log(response.data.list[0]);
slangData = { slangData = {
definition: `${unescape(response.data.list[0].definition)}`, definition: `${unescape(response.data.list[0].definition)}`,
example: `${unescape(response.data.list[0].example)}`, example: `${unescape(response.data.list[0].example)}`,
thumbs_down: `${unescape(response.data.list[0].thumbs_down)}`, thumbs_down: `${unescape(response.data.list[0].thumbs_down)}`,
thumbs_up: `${unescape(response.data.list[0].thumbs_up)}` thumbs_up: `${unescape(response.data.list[0].thumbs_up)}`
} }
return slangData; return slangData;
}) })
.catch(error => { .catch(error => {
@@ -284,20 +285,20 @@ exports.getStock = async function (stock) {
await axios.get(answerURL) await axios.get(answerURL)
.then(response => { .then(response => {
//console.log(response.data.list[0]); //console.log(response.data.list[0]);
stockData = { stockData = {
symbol: `${unescape(response.data["Global Quote"]['01. symbol'])}`, symbol: `${unescape(response.data["Global Quote"]['01. symbol'])}`,
open: `${unescape(response.data["Global Quote"]['02. open'])}`, open: `${unescape(response.data["Global Quote"]['02. open'])}`,
high: `${unescape(response.data["Global Quote"]['03. high'])}`, high: `${unescape(response.data["Global Quote"]['03. high'])}`,
low: `${unescape(response.data["Global Quote"]['04. low'])}`, low: `${unescape(response.data["Global Quote"]['04. low'])}`,
price: `${unescape(response.data["Global Quote"]['05. price'])}`, price: `${unescape(response.data["Global Quote"]['05. price'])}`,
volume: `${unescape(response.data["Global Quote"]['06. volume'])}`, volume: `${unescape(response.data["Global Quote"]['06. volume'])}`,
latest: `${unescape(response.data["Global Quote"]['07. latest trading day'])}`, latest: `${unescape(response.data["Global Quote"]['07. latest trading day'])}`,
previous: `${unescape(response.data["Global Quote"]['08. previous close'])}`, previous: `${unescape(response.data["Global Quote"]['08. previous close'])}`,
change: `${unescape(response.data["Global Quote"]['09. change'])}`, change: `${unescape(response.data["Global Quote"]['09. change'])}`,
percent: `${unescape(response.data["Global Quote"]['10. change percent'])}` percent: `${unescape(response.data["Global Quote"]['10. change percent'])}`
} }
return stockData; return stockData;
}) })
.catch(error => { .catch(error => {
@@ -320,21 +321,21 @@ exports.getSources = function () {
* getQuotes - Returns libFlayer feed quotes * getQuotes - Returns libFlayer feed quotes
* @constructor * @constructor
*/ */
exports.getQuotes = async function (quote_url) { exports.getQuotes = async function (quote_url) {
var data = []; var data = [];
await axios.get(quote_url) await axios.get(quote_url)
.then(response => { .then(response => {
console.log(response.data[0].q); console.log(response.data[0].q);
console.log(response.data[0].a); console.log(response.data[0].a);
data = response.data; data = response.data;
return data; return data;
}) })
.catch(error => { .catch(error => {
console.log(error); console.log(error);
}); });
return data; return data;
} }
/** /**
@@ -351,4 +352,4 @@ exports.getCategories = function () {
*/ */
exports.sleep = (ms) => new Promise((resolve) => { exports.sleep = (ms) => new Promise((resolve) => {
setTimeout(resolve, ms); setTimeout(resolve, ms);
}) })