Front end notification listener

couchpotato/core/notifications/core/main.py

@@ -13,9 +13,9 @@ class CoreNotifier(Plugin):
     messages = []
 
     def __init__(self):
+
         addEvent('notify', self.notify)
-        addEvent('notify.core_notifier', self.notify)
+        addEvent('notify.core', self.frontend)
-        addEvent('core_notifier.frontend', self.frontend)
 
         addApiView('core_notifier.listener', self.listener)
 
@@ -29,7 +29,6 @@ class CoreNotifier(Plugin):
         })
 
     def frontend(self, type = 'notification', data = {}):
-
         self.messages.append({
             'time': time.time(),
             'type': type,
@@ -38,12 +37,15 @@ class CoreNotifier(Plugin):
 
     def listener(self):
 
+        messages = []
         for message in self.messages:
+            print message['time'], (time.time() - 5)
             #delete message older then 15s
-            if message['time'] < (time.time() - 15):
+            if message['time'] > (time.time() - 15):
-                del message
+                messages.append(message)
 
+        self.messages = []
         return jsonified({
             'success': True,
-            'result': self.messages,
+            'result': messages,
         })

couchpotato/core/notifications/core/static/notification.js

@@ -7,7 +7,7 @@ var NotificationBase = new Class({
 		var self = this;
 		self.setOptions(options);
 
-		//App.addEvent('load', self.request.bind(self));
+		App.addEvent('load', self.request.bind(self));
 
 		self.addEvent('notification', self.notify.bind(self))
 
@@ -33,7 +33,7 @@ var NotificationBase = new Class({
 		var self = this;
 
 		Array.each(json.result, function(result){
-			self.fireEvent(result.type, result.data)
+			App.fireEvent(result.type, result.data)
 		})
 	}
 

couchpotato/core/plugins/library/main.py

@@ -100,5 +100,6 @@ class LibraryPlugin(Plugin):
                     #log.debug('Failed to attach to library: %s' % traceback.format_exc())
 
         fireEvent('library.update.after')
+        fireEvent('notify.core', type = 'library.update', data = library_dict)
 
         return library.to_dict({'titles': {}, 'files':{}})