This app is written in Node.JS and it:
- queries a local mongoDB database for news
- queries feedly API for RSS feeds, and then parses them for news
It is mean to communicate via SSE/Marvin only:
- it subscribes to task manager
- when task manager sends message to the app to start it:
- creates a topic (/marvin/eventbus/topics/news) if it doesn't exist
- it publishes to it the resources it requires for the task manager to notify them to start listening to the app's topic
- it controlls the resources via properly formated messages
It will reply in a stream of multiple messages, by using:
{
"replyId" : "uid",
"reply" : [
{
"author" : "...",
"title" : "...",
"content" : "...",
"published" : "...",
"lang" : "...",
},
{ ... }
]
}Notes:
The content might contain HTML entities.