1 files changed, 146 insertions, 0 deletions
diff --git a/tests/testnotification.cc b/tests/testnotification.cc
new file mode 100644
index 0000000..e36391f
--- /dev/null
+++ b/tests/testnotification.cc
@@ -0,0 +1,146 @@
+    /*
+
+    Copyright (C) 2001 Stefan Westerfeld
+                       stefan@space.twc.de
+
+    This library is free software; you can redistribute it and/or
+    modify it under the terms of the GNU Library General Public
+    License as published by the Free Software Foundation; either
+    version 2 of the License, or (at your option) any later version.
+  
+    This library is distributed in the hope that it will be useful,
+    but WITHOUT ANY WARRANTY; without even the implied warranty of
+    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+    Library General Public License for more details.
+   
+    You should have received a copy of the GNU Library General Public License
+    along with this library; see the file COPYING.LIB.  If not, write to
+    the Free Software Foundation, Inc., 59 Temple Place - Suite 330,
+    Boston, MA 02111-1307, USA.
+
+    */
+
+#include "notification.h"
+#include "dispatcher.h"
+#include "test.h"
+
+using namespace Arts;
+using namespace std;
+
+static string messagesReceived;
+static long messagesAlive;
+
+static void destroyString(const Notification& n)
+{
+	messagesAlive--;
+	delete (string *)n.data;
+}
+
+class Receiver : public NotificationClient {
+private:
+	long alive;
+
+public:
+	Receiver() { alive = 42; }
+	virtual ~Receiver() {
+		NotificationManager::the()->removeClient(this);
+		alive = 0;
+	}
+
+	void notify(const Notification& n) {
+		if(alive != 42) messagesReceived += "<dead>";
+
+		string *data = (string *)n.data;
+		messagesReceived += *data;
+		destroyString(n);
+
+		if(alive != 42) messagesReceived += "</dead>";
+	}
+};
+
+struct TestNotification : public TestCase
+{
+	TESTCASE(TestNotification);
+
+	Dispatcher dispatcher;
+
+	void setUp() {
+		messagesReceived = "";
+		messagesAlive = 0;
+	}
+	void tearDown() {
+	}
+	void sendNotification(Receiver& r, string text)
+	{
+		messagesAlive++;
+		Notification n;
+		n.receiver = &r;
+		n.data = new string(text);
+		n.internal = 0;
+		n.setDestroy(destroyString);
+		NotificationManager::the()->send(n);
+	}
+
+	/* sending a notification (should be asynchronous) */
+	TEST(send) {
+		Receiver r1;
+		sendNotification(r1,"r1");
+
+		testEquals(1,messagesAlive);
+		testEquals("",messagesReceived);
+		testEquals(true, NotificationManager::the()->pending());
+
+		NotificationManager::the()->run();
+
+		testEquals("r1",messagesReceived);
+		testEquals(false, NotificationManager::the()->pending());
+		testEquals(0,messagesAlive);
+	}
+
+	/* order of sending notifications (first-in-first-out) */
+	TEST(sendOrder) {
+		Receiver r1,r2;
+
+		sendNotification(r1,"r1");
+		sendNotification(r2,"r2");
+
+		testEquals(2,messagesAlive);
+		testEquals("",messagesReceived);
+		testEquals(true, NotificationManager::the()->pending());
+
+		NotificationManager::the()->run();
+
+		testEquals(false, NotificationManager::the()->pending());
+		testEquals(0,messagesAlive);
+		testEquals("r1r2",messagesReceived);
+	}
+
+	/* deletion of unprocessed notifications once a client dies */
+	TEST(clientDeletion) {
+		Receiver *r1 = new Receiver,
+		         *r2 = new Receiver,
+		         *r3 = new Receiver,
+				 *r4 = new Receiver;
+
+		sendNotification(*r1,"r1");
+		sendNotification(*r2,"r2");
+		sendNotification(*r3,"r3");
+		sendNotification(*r4,"r4");
+
+		testEquals(4,messagesAlive);
+		testEquals("",messagesReceived);
+
+		delete r2;
+		delete r4;
+
+		testEquals(2,messagesAlive);
+		testEquals("",messagesReceived);
+
+		NotificationManager::the()->run();
+
+		testEquals("r1r3",messagesReceived);
+		testEquals(0,messagesAlive);
+	}
+};
+
+TESTMAIN(TestNotification);