Adding nodelogging and unescaping subject for mails
This commit is contained in:
19
src/index.ts
19
src/index.ts
@ -2,6 +2,8 @@ require('https').globalAgent.options.ca = require('ssl-root-cas/latest').create(
|
||||
require('ssl-root-cas').inject();
|
||||
process.env.NODE_TLS_REJECT_UNAUTHORIZED = "0";
|
||||
|
||||
import Logging from "@hibas123/nodelogging";
|
||||
|
||||
import * as dotenv from "dotenv";
|
||||
dotenv.config();
|
||||
import rss from "rss-parser";
|
||||
@ -53,33 +55,34 @@ function calculateHash(item: FeedItem) {
|
||||
async function check() {
|
||||
try {
|
||||
let data = await fetch(process.env.FEED).then(res => res.text());
|
||||
console.log("Received Data");
|
||||
let feed: Feed = await parser.parseString(data).catch(console.error);
|
||||
Logging.log("Received Data");
|
||||
let feed: Feed = await parser.parseString(data).catch(err => Logging.error(err));
|
||||
//Check for new entries
|
||||
let items = feed.items.filter(item => {
|
||||
return db.get(calculateHash(item)).value() !== true;
|
||||
})
|
||||
for (let item of items) {
|
||||
await sendFeed(feed, item).catch(console.error)
|
||||
await sendFeed(feed, item).catch(err => Logging.error(err))
|
||||
}
|
||||
} catch (error) {
|
||||
console.error(error);
|
||||
Logging.error(error);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
import {AllHtmlEntities} from "html-entities";
|
||||
const entities = new AllHtmlEntities();
|
||||
async function sendFeed(feed: Feed, item: FeedItem) {
|
||||
console.log("Sending Mail!")
|
||||
Logging.log("Sending Mail!")
|
||||
let mailOptions = {
|
||||
from: process.env.MAIL_SENDER,
|
||||
to: process.env.MAIL_RECEIVER,
|
||||
subject: '[OSPLUS_UPDATE] ' + unescape(item.title),
|
||||
subject: '[OSPLUS_UPDATE] ' + entities.decode(item.title),
|
||||
text: item.contentSnippet,
|
||||
html: item.content
|
||||
};
|
||||
|
||||
let info = await transporter.sendMail(mailOptions);
|
||||
console.log('Message sent: %s', info.messageId);
|
||||
Logging.log('Message sent: %s', info.messageId);
|
||||
db.set(calculateHash(item), true).write();
|
||||
}
|
||||
|
||||
|
Reference in New Issue
Block a user