only locally socket comments
This commit is contained in:
parent
8f1f01f0a3
commit
36d6864b40
1 changed files with 6 additions and 3 deletions
|
|
@ -18,9 +18,12 @@ class Postzord::Dispatch
|
||||||
def post(opts = {})
|
def post(opts = {})
|
||||||
unless @subscribers == nil
|
unless @subscribers == nil
|
||||||
remote_people, local_people = @subscribers.partition{ |person| person.owner_id.nil? }
|
remote_people, local_people = @subscribers.partition{ |person| person.owner_id.nil? }
|
||||||
user_ids = [*local_people].map{|x| x.owner_id }
|
|
||||||
local_users = User.all(:id.in => user_ids, :fields => ['person_id, username, language, email'])
|
if @object.is_a?(Comment)
|
||||||
self.socket_to_users(local_users)
|
user_ids = [*local_people].map{|x| x.owner_id }
|
||||||
|
local_users = User.all(:id.in => user_ids, :fields => ['person_id, username, language, email'])
|
||||||
|
self.socket_to_users(local_users)
|
||||||
|
end
|
||||||
self.deliver_to_remote(remote_people)
|
self.deliver_to_remote(remote_people)
|
||||||
self.deliver_to_local(local_people)
|
self.deliver_to_local(local_people)
|
||||||
end
|
end
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue