mikehuntington/neovibe-bots
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fixing image uploading

Browse Source
This commit is contained in:
Michael (GP) 2022-12-12 17:43:00 -05:00
parent d267b0d248
commit 12dfb3562e
1 changed files with 11 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
bot.js
View File

@ -11,17 +11,17 @@ let Parser = require("rss-parser");
let parser = new Parser(); let parser = new Parser();
let maxPostPerScan = process.env.MAX_POST_PER_SCAN; let maxPostPerScan = process.env.MAX_POST_PER_SCAN;
const download_image = (url, image_path) => { const download_image = async (url, image_path) => {
return axios({ let response = await axios({
url, url,
responseType: "stream", responseType: "stream",
}).then((response) => { });
return new Promise((resolve, reject) => {
response.data return new Promise((resolve, reject) => {
.pipe(fs.createWriteStream(image_path)) response.data
.on("finish", () => resolve()) .pipe(fs.createWriteStream(image_path))
.on("error", (e) => reject(e)); .on("finish", () => resolve())
}); .on("error", (e) => reject(e));
}); });
}; };
@ -56,7 +56,7 @@ async function postFeed() {
feed.items.every(async (item) => { feed.items.every(async (item) => {
let pubDate = new Date(item.pubDate); let pubDate = new Date(item.pubDate);
if (pubDate > postDate) { if (pubDate < postDate) {
let currentCount = ++count; let currentCount = ++count;
if (currentCount > maxPostPerScan) return false; if (currentCount > maxPostPerScan) return false;
@ -79,6 +79,7 @@ async function postFeed() {
status: `${item.title}\n\n#NeoVibe #${process.env.POST_HASHTAG}\n\n${item.link}`, status: `${item.title}\n\n#NeoVibe #${process.env.POST_HASHTAG}\n\n${item.link}`,
media_ids: [mediaup.data.id], media_ids: [mediaup.data.id],
}); });
return true; return true;
} }