diff --git a/app/models/post.rb b/app/models/post.rb index 0aba89918..683083b30 100644 --- a/app/models/post.rb +++ b/app/models/post.rb @@ -5,6 +5,7 @@ class Post include ROXML include Diaspora::Webhooks + xml_accessor :_id key :person_id, ObjectId belongs_to :person, :class_name => 'Person' diff --git a/app/models/status_message.rb b/app/models/status_message.rb index 195d5a73e..96c9c689e 100644 --- a/app/models/status_message.rb +++ b/app/models/status_message.rb @@ -3,7 +3,7 @@ class StatusMessage < Post xml_name :status_message xml_accessor :message - + key :message, String diff --git a/app/views/blogs/_blog.html.haml b/app/views/blogs/_blog.html.haml index 366f5ad85..e0f63e52d 100644 --- a/app/views/blogs/_blog.html.haml +++ b/app/views/blogs/_blog.html.haml @@ -1,4 +1,4 @@ -%li.message{:class => ("mine" if mine?(post))} +%li.message{:id => post.id, :class => ("mine" if mine?(post))} %span.from = link_to_person post.person %b wrote a new blog post diff --git a/app/views/bookmarks/_bookmark.html.haml b/app/views/bookmarks/_bookmark.html.haml index 03fd47c0f..88208a619 100644 --- a/app/views/bookmarks/_bookmark.html.haml +++ b/app/views/bookmarks/_bookmark.html.haml @@ -1,4 +1,4 @@ -%li.message{:class => ("mine" if mine?(post))} +%li.message{:id => post.id, :class => ("mine" if mine?(post))} %span.from = link_to_person post.person %b shared a link diff --git a/app/views/comments/_comment.html.haml b/app/views/comments/_comment.html.haml index 74c1f3c6b..3cf43c723 100644 --- a/app/views/comments/_comment.html.haml +++ b/app/views/comments/_comment.html.haml @@ -1,4 +1,4 @@ -%li.comment +%li.comment{:id => comment.id} %span.from = link_to_person comment.person = comment.text diff --git a/app/views/layouts/application.html.haml b/app/views/layouts/application.html.haml index 0a5ad669c..a6fde39ea 100644 --- a/app/views/layouts/application.html.haml +++ b/app/views/layouts/application.html.haml @@ -33,18 +33,12 @@ if((location.href.indexOf(obj['class']) != -1 ) || (location.pathname == '/')) { $("#stream").prepend($(obj['html']).fadeIn("fast")); }; - } - ws.onclose = function() { debug("socket closed"); }; - ws.onopen = function() { - debug("connected..."); - }; - - - $('#show_filters').hover( function() { - $("#stream_filters").fadeIn(80); - }, - function() { - $("#stream_filters").fadeOut(100); + } + ws.onclose = function() { debug("socket closed"); }; + ws.onopen = function() { + ws.send(location.pathname); + debug("connected..."); + }; }); }); %body diff --git a/app/views/status_messages/_status_message.html.haml b/app/views/status_messages/_status_message.html.haml index d1c6611c1..a0dc4336b 100644 --- a/app/views/status_messages/_status_message.html.haml +++ b/app/views/status_messages/_status_message.html.haml @@ -1,4 +1,4 @@ -%li.message{:class => ("mine" if mine?(post))} +%li.message{:id => post.id, :class => ("mine" if mine?(post))} %span.from = link_to_person post.person = post.message diff --git a/config/initializers/socket.rb b/config/initializers/socket.rb index 9e6d7ff59..de5eb3f3c 100644 --- a/config/initializers/socket.rb +++ b/config/initializers/socket.rb @@ -13,11 +13,11 @@ module WebSocket end end - EventMachine::WebSocket.start(:host => "0.0.0.0", :port => 8080, :debug => true) do |ws| + EventMachine::WebSocket.start(:host => "0.0.0.0", :port => 8080, :debug =>false) do |ws| ws.onopen { sid = @channel.subscribe { |msg| ws.send msg } - ws.onmessage { |msg| @channel.push msg} + ws.onmessage { |msg|}#@channel.push msg; puts msg} ws.onclose { @channel.unsubscribe(sid) } } @@ -29,10 +29,12 @@ module WebSocket end def self.view_hash(object) - {:class =>object.class.to_s.underscore.pluralize, :html => WebSocket.view_for(object)} + v = WebSocket.view_for(object) + puts v + {:class =>object.class.to_s.underscore.pluralize, :html => v} end def self.view_for(object) - @view.render(:partial => @view.type_partial(object), :locals => {:post => object}) + @view.render @view.type_partial(object), :post => object end -end \ No newline at end of file +end