Error notifications and dedicated Notifier object

Makefile

@@ -39,6 +39,7 @@ SRCS = \
 	src/FeedsView.cpp, \
 	src/MainWindow.cpp, \
 	src/Mimetypes.cpp, \
+	src/Notifier.cpp, \
 	src/ProtocolListener.cpp, \
 	src/RssFeed.cpp, \
 	src/UpdatesView.cpp, \

src/App.cpp

@@ -18,6 +18,7 @@
 #include "FeedController.h"
 #include "MainWindow.h"
 #include "Mimetypes.h"
+#include "Notifier.h"
 #include "RssFeed.h"
 #include "Util.h"
 
@@ -40,6 +41,7 @@ App::App() : BApplication("application/x-vnd.Pogger")
 	cfg->Load();
 
 	fMainWindow = new MainWindow();
+	fNotifier = new Notifier();
 	fFeedController = new FeedController();
 	fMainWindow->Show();
 
@@ -69,13 +71,22 @@ App::MessageReceived(BMessage* msg)
 		{
 			break;
 		}
-		case kQueueProgress:
+		case kParseFail:
 		{
-			fMainWindow->MessageReceived(msg);
+			fNotifier->MessageReceived(msg);
+			fFeedController->MessageReceived(msg);
+			break;
+		}
+		case kDownloadFail:
+		{
+			fNotifier->MessageReceived(msg);
+			fFeedController->MessageReceived(msg);
+			break;
 		}
 		case kDownloadComplete:
 		{
 			fFeedController->MessageReceived(msg);
+			break;
 		}
 		default:
 		{

src/App.h

@@ -15,6 +15,7 @@ class BMessageRunner;
 class Config;
 class FeedController;
 class MainWindow;
+class Notifier;
 
 
 class App : public BApplication
@@ -28,6 +29,7 @@ public:
 	Config* cfg;
 	MainWindow* fMainWindow;
 	BMessageRunner* fUpdateRunner;
+	Notifier* fNotifier;
 
 private:
 	FeedController* fFeedController;

src/Feed.cpp

@@ -93,21 +93,19 @@ Feed::_PostParse()
 
 
 // Download a remote feed's XML to the cache path.
-BString
+bool
 Feed::Fetch()
 {
 	BFile cacheFile = BFile(cachePath, B_READ_WRITE | B_CREATE_FILE);
 
 	cacheFile.ReadAttrString("Feed:hash", &lastHash);
 
-	fetch(xmlUrl, &cacheFile, &hash, 30);
+	int32 result = fetch(xmlUrl, &cacheFile, &hash, 30);
 	cacheFile.WriteAttrString("Feed:hash", &hash);
 
-	if (hash == lastHash)
-		updated = false;
-
-	fetched = true;
-	return cachePath;
+	if (result == 0)
+		return true;
+	return false;
 }
 
 

src/Feed.h

@@ -31,7 +31,7 @@ public:
 	BList	GetEntries();
 	BList	GetNewEntries();
 
-	BString	Fetch();
+	bool	Fetch();
 
 	bool	IsRss();
 	bool	IsAtom();

src/FeedController.cpp

@@ -105,14 +105,17 @@ FeedController::_DownloadLoop(void* ignored)
 		printf( "Downloading feed from %s...\n",
 			feedBuffer->GetXmlUrl().UrlString().String());
 
-		feedBuffer->Fetch();
-
+		if (feedBuffer->Fetch()) {
 			BMessage* downloaded = new BMessage(kDownloadComplete);
 			downloaded->AddData("feeds", B_RAW_TYPE, feedBuffer, sizeof(Feed));
-
 			((App*)be_app)->MessageReceived(downloaded);
 		}
-
+		else {
+			BMessage* failure = new BMessage(kDownloadFail);
+			failure->AddString("feed_url", feedBuffer->GetXmlUrl().UrlString());
+			((App*)be_app)->MessageReceived(failure);
+		}
+	}
 	delete(feedBuffer);
 	return 0;
 }
@@ -126,7 +129,8 @@ FeedController::_ParseLoop(void* ignored)
 
 	while (receive_data(&sender, (void*)feedBuffer, sizeof(Feed)) != 0) {
 		BList entries;
-		BString title;
+		BString feedTitle;
+		BUrl feedUrl = feedBuffer->GetXmlUrl();
 		BDirectory outDir = BDirectory(((App*)be_app)->cfg->outDir);
 
 		if (feedBuffer->IsAtom()) {
@@ -134,7 +138,7 @@ FeedController::_ParseLoop(void* ignored)
 			feed = new AtomFeed(feedBuffer);
 			feed->Parse();
 			entries = feed->GetNewEntries();
-			title = feed->GetTitle();
+			feedTitle = feed->GetTitle();
 			delete(feed);
 		}
 		else if (feedBuffer->IsRss()) {
@@ -142,29 +146,24 @@ FeedController::_ParseLoop(void* ignored)
 			feed = new RssFeed(feedBuffer);
 			feed->Parse();
 			entries = feed->GetNewEntries();
-			title = feed->GetTitle();
+			feedTitle = feed->GetTitle();
 			delete(feed);
 		}
 
-		if ((feedBuffer->IsAtom() || feedBuffer->IsRss())
-			&& entries.CountItems() > 0)
-		{
+
+		if (feedBuffer->IsAtom() || feedBuffer->IsRss()) {
 			for (int i = 0; i < entries.CountItems(); i++)
 				((Entry*)entries.ItemAt(i))->Filetize(outDir);
 
-			BNotification notifyNew = (B_INFORMATION_NOTIFICATION);
-			BString notifyLabel("New Feed Entries");
-			BString notifyText("%n% new entries from %source%");
-
-			BString numStr("");
-			numStr << entries.CountItems();
-			notifyText.ReplaceAll("%source%", title);
-			notifyText.ReplaceAll("%n%", numStr);
-
-
-			notifyNew.SetTitle(notifyLabel);
-			notifyNew.SetContent(notifyText);
-			notifyNew.Send();
+			BMessage* complete = new BMessage(kParseComplete);
+			complete->AddString("feed_name", feedTitle);
+			complete->AddInt32("entry_count", entries.CountItems());
+			((App*)be_app)->MessageReceived(complete);
+		}
+		else {
+			BMessage* failure = new BMessage(kParseFail);
+			failure->AddString("feed_url", feedUrl.UrlString());
+			((App*)be_app)->MessageReceived(failure);
 		}
 	}
 	

src/FeedController.h

@@ -15,8 +15,10 @@ enum
 {
 	kEnqueueFeed		= 'fenq',
 	kClearQueue			= 'frmq',
-	kDownloadComplete	= 'fdpr',
-	kQueueProgress		= 'fqpr',
+	kDownloadComplete	= 'fdlc',
+	kDownloadFail		= 'fdlf',
+	kParseComplete		= 'fpec',
+	kParseFail			= 'fpef',
 	kUpdateSubscribed	= 'fups'
 };
 

src/Notifier.cpp

@@ -0,0 +1,97 @@
+/*
+ * Copyright 2020, Jaidyn Levesque <jadedctrl@teknik.io>
+ * All rights reserved. Distributed under the terms of the MIT license.
+ */
+
+#include <Message.h>
+#include <Notification.h>
+
+#include "FeedController.h"
+
+#include "Notifier.h"
+
+
+void
+Notifier::MessageReceived(BMessage* msg)
+{
+	switch (msg->what)
+	{
+		case kParseComplete:
+		{
+			BString feedName;
+			int32 entryCount;
+
+			if (msg->FindString("feed_name", &feedName) == B_OK
+				&& msg->FindInt32("entry_count", &entryCount) == B_OK)
+			{
+				_NewEntryNotification(feedName, entryCount);
+			}
+			break;
+		}
+		case kParseFail:
+		{
+			BString feedUrl = msg->GetString("feed_url", "");
+			_ParseFailNotification(feedUrl);
+			break;
+		}
+		case kDownloadFail:
+		{
+			BString feedUrl = msg->GetString("feed_url", "");
+			_DownloadFailNotification(feedUrl);
+		}
+	}
+}
+
+
+void
+Notifier::_NewEntryNotification(BString feedName, int32 entryCount)
+{
+	BNotification notifyNew(B_INFORMATION_NOTIFICATION);
+	BString notifyLabel("New Feed Entries");
+	BString notifyText("%n% new entries from %source%");
+
+	BString numStr("");
+	numStr << entryCount;
+	notifyText.ReplaceAll("%source%", feedName);
+	notifyText.ReplaceAll("%n%", numStr);
+
+	notifyNew.SetTitle(notifyLabel);
+	notifyNew.SetContent(notifyText);
+	notifyNew.Send();
+}
+
+
+void
+Notifier::_ParseFailNotification(BString feedUrl)
+{
+	BNotification notifyError(B_ERROR_NOTIFICATION);
+	BString notifyText("Failed to parse feed from %url%");
+
+	if (feedUrl.IsEmpty())
+		notifyText = "Failed to parse a feed";
+
+	notifyText.ReplaceAll("%url%", feedUrl);
+
+	notifyError.SetTitle("Parse Failure");
+	notifyError.SetContent(notifyText);
+	notifyError.Send();
+}
+
+
+void
+Notifier::_DownloadFailNotification(BString feedUrl)
+{
+	BNotification notifyError(B_ERROR_NOTIFICATION);
+	BString notifyText("Failed to download feed from %url%");
+
+	if (feedUrl.IsEmpty())
+		notifyText = "Failed to download a feed";
+
+	notifyText.ReplaceAll("%url%", feedUrl);
+
+	notifyError.SetTitle("Download Failure");
+	notifyError.SetContent(notifyText);
+	notifyError.Send();
+}
+
+

src/Notifier.h

@@ -0,0 +1,26 @@
+/*
+ * Copyright 2020, Jaidyn Levesque <jadedctrl@teknik.io>
+ * All rights reserved. Distributed under the terms of the MIT license.
+ */
+#ifndef NOTIFIER_H
+#define NOTIFIER_H
+
+#include <SupportDefs.h>
+
+class BString;
+
+
+class Notifier {
+public:
+	void MessageReceived(BMessage* msg);
+
+private:
+	void _NewEntryNotification(BString feedName, int32 feedCount);
+	void _ParseFailNotification(BString feedUrl);
+	void _DownloadFailNotification(BString feedUrl);
+
+};
+
+
+#endif // NOTIFIER_H
+