Final fixes for person socketing

This commit is contained in:
Raphael 2010-12-02 19:03:15 -08:00
parent 3c7172822e
commit 2e87bece60
4 changed files with 19 additions and 5 deletions

View file

@ -27,7 +27,7 @@ module SocketsHelper
v = render_to_string(:partial => 'shared/stream_element', :locals => post_hash)
elsif object.is_a? Person
person_hash = {
:single_aspect_form => opts[:single_aspect_form],
:single_aspect_form => opts["single_aspect_form"],
:person => object,
:aspects => user.aspects,
:contact => user.contact_for(object),

View file

@ -7,7 +7,11 @@ module Jobs
result = finger.fetch
result.socket_to_uid(user_id, opts)
rescue
Diaspora::WebSocket.queue_to_user(user_id, {:class => 'people', :status => 'fail', :query => account, :response => I18n.t('people.webfinger.fail')}.to_json)
Diaspora::WebSocket.queue_to_user(user_id,
{:class => 'people',
:status => 'fail',
:query => account,
:response => I18n.t('people.webfinger.fail', :handle => account)}.to_json)
end
end
end

View file

@ -15,7 +15,7 @@ module Diaspora
def self.push_to_user(uid, data)
Rails.logger.debug "Websocketing to #{uid}"
@channels[uid][0].push(data) if @channels[uid]
@channels[uid.to_id][0].push(data) if @channels[uid.to_id]
end
def self.subscribe(uid, ws)

View file

@ -1,7 +1,17 @@
require 'resque/tasks'
task "resque:setup" => :environment do
Dir[File.join(Rails.root, 'app', 'uploaders', '*.rb')].each { |file| require file }
Dir[File.join(Rails.root, 'app', 'models', '*.rb')].each { |file| require file }
Dir[File.join(Rails.root, 'app', 'uploaders', '*.rb')].each { |file|
classname = File.basename(file)[0..-4].camelize.constantize
unless defined?(classname)
require file
end
}
Dir[File.join(Rails.root, 'app', 'models', '*.rb')].each { |file|
classname = File.basename(file)[0..-4].camelize.constantize
unless defined?(classname)
require file
end
}
require File.join(Rails.root, 'app', 'controllers', 'application_controller.rb')
require File.join(Rails.root, 'app', 'controllers', 'sockets_controller.rb')
Rails.logger.info("event=resque_setup rails_env=#{Rails.env}")