Notifications - issue #165

piplmesh/account/models.py

@@ -23,6 +23,10 @@ class Connection(mongoengine.EmbeddedDocument):
     http_if_modified_since = mongoengine.StringField()
     channel_id = mongoengine.StringField()
 
+class Notification(mongoengine.EmbeddedDocument):
+    read = mongoengine.BooleanField()
+    comment = mongoengine.IntField()
+
 class User(auth.User):
     username = mongoengine.StringField(
         max_length=30,
@@ -48,6 +52,8 @@ class User(auth.User):
     connections = mongoengine.ListField(mongoengine.EmbeddedDocumentField(Connection))
     connection_last_unsubscribe = mongoengine.DateTimeField()
     is_online = mongoengine.BooleanField(default=False)
+
+    notifications = mongoengine.ListField(mongoengine.EmbeddedDocumentField(Notification), default=lambda: [], required=False)
 
     def get_image_url(self, request):
         if self.twitter_id:

piplmesh/api/base.py

@@ -14,4 +14,4 @@ class AuthoredDocument(mongoengine.Document):
 
     meta = {
         'abstract': True,
-    }
+    }

piplmesh/api/models.py

@@ -4,6 +4,8 @@
 
 import mongoengine
 
+from piplmesh.account import models as account_models
+
 from . import base
 
 POST_MESSAGE_MAX_LENGTH = 500
@@ -33,6 +35,7 @@ class Post(base.AuthoredDocument):
     comments = mongoengine.ListField(mongoengine.EmbeddedDocumentField(Comment), default=lambda: [], required=False)
     attachments = mongoengine.ListField(mongoengine.EmbeddedDocumentField(Attachment), default=lambda: [], required=False)
 
+    subscribers = mongoengine.ListField(mongoengine.ReferenceField(account_models.User), default=lambda: [], required=False)
     # TODO: Prevent posting comments if post is not published
     # TODO: Prevent adding attachments if post is published
     # TODO: Prevent marking post as unpublished once it was published
@@ -65,4 +68,4 @@ class LinkAttachment(Attachment):
 
     link_url = mongoengine.URLField(required=True)
     link_caption = mongoengine.StringField(default='', required=True)
-    link_description = mongoengine.StringField(default='', required=True)
+    link_description = mongoengine.StringField(default='', required=True)

piplmesh/api/resources.py

@@ -26,6 +26,15 @@ def hydrate(self, bundle):
         return bundle
 
 class CommentResource(AuthoredResource):
+    def obj_create(self, bundle, request=None, **kwargs):
+        obj = super(CommentResource, self).obj_create(bundle, request=request, **kwargs)
+
+        print obj.obj.author
+        #self.parent.fields['subscribers'].append(obj.obj.author)
+
+        #obj.obj.save()
+        #print list((name, obj, " \n\n") for name, obj in self.parent.fields.iteritems())
+        return obj
     class Meta:
         object_class = api_models.Comment
         allowed_methods = ('get', 'post', 'put', 'patch', 'delete')
@@ -63,9 +72,14 @@ class PostResource(AuthoredResource):
 
     comments = fields.EmbeddedListField(of='piplmesh.api.resources.CommentResource', attribute='comments', default=lambda: [], null=True, full=False)
     attachments = fields.EmbeddedListField(of='piplmesh.api.resources.AttachmentResource', attribute='attachments', default=lambda: [], null=True, full=True)
-
+    def obj_create(self, bundle, request=None, **kwargs):
+        obj = super(PostResource, self).obj_create(bundle, request=request, **kwargs)
+        obj.obj.subscribers.append(bundle.request.user)
+        obj.obj.save()
+        return obj
     class Meta:
         queryset = api_models.Post.objects.all()
+        #print queryset
         allowed_methods = ('get', 'post', 'put', 'patch', 'delete')
         # TODO: Make proper authorization, current implementation is for development use only
         authorization = tastypie_authorization.Authorization()

piplmesh/frontend/static/piplmesh/css/style.css

@@ -145,6 +145,34 @@ form input[type="submit"], form input[type="reset"] {
     white-space: nowrap;
 }
 
+.notifications {
+    padding: 5px;
+    border: 1px solid #999;
+    cursor: pointer;
+}
+
+.close_notif_box {
+    background: #eee;
+    clear: both;
+    cursor: pointer;
+}
+
+#notif_box {
+    background: #ffffff;
+    display: none;
+    position: absolute;
+    border: 1px solid #999;
+}
+
+#notif_content {
+    padding: 5px;
+}
+
+.close_notif_box {
+    text-align: right;
+    padding-right: 5px;	
+}
+
 #header .user li.last { 
     border-right: none; 
 }

piplmesh/frontend/static/piplmesh/js/notifications.js

@@ -0,0 +1,57 @@
+$(document).ready(function() {
+    $(".notifications").click(function (){
+        if ($("#notif_box").hasClass('show')) {
+            $("#notif_box").slideUp('fast');
+            $("#notif_box").toggleClass('show');
+        } else {
+            $("#notif_box").slideDown('fast');
+            $("#notif_box").toggleClass('show');
+        }
+    });
+    $(".close_notif_box").click(function (){
+        if ($("#notif_box").hasClass('show')) {
+            $("#notif_box").slideUp('fast');
+            $("#notif_box").toggleClass('show');
+        }
+    });
+    $("#addPost").click(function (){
+        addPost("Bla bla bla bla Post...");
+    });
+    $("#addCom").click(function (){
+        addComment("Bla bla bla bla");
+    });
+});
+
+function addPost(message) {
+    $.ajax({
+        type: 'POST',
+        url: '/api/v1/post/',
+        data: JSON.stringify({'message': message, 'is_published': true}),
+        contentType: 'application/json',
+        dataType: "json",
+        success: function () {
+            alert("Post napisan.");
+        },
+        error: function (error) {
+            console.log(error);
+            alert("Oops, something went wrong... ");
+        }
+    });
+}
+
+function addComment(comment) {
+    $.ajax({
+        type: 'POST',
+        url: '/api/v1/post/4fd23f8cc91da109b8000001/comments/',
+        data: JSON.stringify({'message': comment}),
+        contentType: 'application/json',
+        dataType: "json",
+        success: function () {
+            alert("Komentar napisan.");
+        },
+        error: function (error) {
+            console.log(error);
+            alert("Oops, something went wrong... ");
+        }
+    });
+}

piplmesh/frontend/templates/base.html

@@ -10,6 +10,7 @@
         <script src="{% url django.views.i18n.javascript_catalog %}" type="text/javascript"></script>
         <script src="{% static "pushserver/updates.js" %}" type="text/javascript"></script>
         <script src="{% static "piplmesh/js/home.js" %}" type="text/javascript"></script>
+        <script src="{% static "piplmesh/js/notifications.js" %}" type="text/javascript"></script>
         <script type="text/javascript">
             $.updates.subscribe({
                 'home_channel': '{% filter escapejs %}{% channel_url HOME_CHANNEL_ID %}{% endfilter %}'

piplmesh/frontend/templates/header.html

@@ -27,6 +27,21 @@
                     If user is already logged in, logout link is shown instead.
                 {% endcomment %}
                 {% if user.is_authenticated %}
+                    <li>
+                        <div class="notifications">
+                            1
+                        </div>
+                        <div id="notif_box" class="hide">
+                            <div id="notif_content">
+                            Bla bla bla.<br />
+                            Bla bla bla.<br />
+                            </div>
+                            <div class='close_notif_box'>
+                                <div id="addPost">Add p</div>
+                                <div id="addCom">Add c</div> Close
+                            </div>
+                        </div>
+                    </li>
                     <li class="image">
                         {% user_image %}
                     </li>

src/pip-delete-this-directory.txt

@@ -0,0 +1,5 @@
+This file is placed here by pip to indicate the source was put
+here by pip.
+
+Once this package is successfully installed this source code will be
+deleted (unless you remove this file).