Do logic for save on cache if the notification was read or not

Author: elesbom

dbaas/notification/urls.py

@@ -8,6 +8,7 @@
     url(r"^tasks_running/$", views.running_tasks_api, name="notification:tasks_running"),
     url(r"^tasks_waiting/$", views.waiting_tasks_api, name="notification:tasks_waiting"),
     url(r"^database_tasks/(?P<database_id>\d+)/?$", views.database_tasks, name="notification:database_tasks"),
-    url(r"^(?P<username>[\w\-\_\.]+)/user_tasks/?$", views.UserTasks.as_view(), name="notification:user_tasks"),
+    # TODO: see why namespace notification: not work on templatetag {% url %}
+    url(r"^(?P<username>[\w\-\_\.]*)/user_tasks/?$", views.UserTasks.as_view(), name="notification_user_tasks"),
 
 )

dbaas/notification/views.py

@@ -76,11 +76,13 @@ def dispatch(self, request, *args, **kwargs):
 
     @staticmethod
     def get_notifications(username):
-        conn = get_redis_connection('notification')
-        keys = conn.keys("task_users:{}:*".format(username))
-        # TODO: can be better
-        tasks = map(conn.hgetall, keys) if keys else []
-        return sorted(tasks, key=lambda d: d['updated_at'], reverse=True)
+        if username:
+            conn = get_redis_connection('notification')
+            keys = conn.keys("task_users:{}:*".format(username))
+            # TODO: can be better
+            tasks = map(conn.hgetall, keys) if keys else []
+            return sorted(tasks, key=lambda d: d['updated_at'], reverse=True)
+        return []
 
     def get(self, *args, **kw):
         username = kw.get('username')
@@ -93,8 +95,15 @@ def post(self, *args, **kw):
         payload = json.loads(self.request.body)
         for task in payload.get('ids', []):
             key = "task_users:{}:{}".format(username, task['id'])
-            task_status = conn.hget(key, 'task_status')
-            if task_status == task['status']:
-                conn.hset(key, 'is_new', 0)
+            # TODO: Do all logic use fields
+            fields = task.get('fields')
+            if fields:
+                for field in fields:
+                    field_key = field.keys()[0]
+                    conn.hset(key, field_key, field[field_key])
+            else:
+                task_status = conn.hget(key, 'task_status')
+                if task_status == task['status']:
+                    conn.hset(key, 'is_new', 0)
 
         return self.render_to_response('ok')