nocebo/diaspora
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

MS fixed lots of debug messages

Browse source
This commit is contained in:
maxwell 2010-07-29 10:05:02 -07:00
parent 7a0db375ab
commit 2040c0d347
4 changed files with 1 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

BIN
gpg/diaspora-test/pubring.gpg
View file

Binary file not shown.

BIN
gpg/diaspora-test/trustdb.gpg
View file

Binary file not shown.

3
lib/diaspora/webhooks.rb
View file

@ -28,12 +28,9 @@ module Diaspora
end end
def push_to(recipients) def push_to(recipients)
puts "FOOBATT"
@@queue.add_hub_notification(APP_CONFIG[:pubsub_server], User.owner.url + self.class.to_s.pluralize.underscore + '.atom') @@queue.add_hub_notification(APP_CONFIG[:pubsub_server], User.owner.url + self.class.to_s.pluralize.underscore + '.atom')
unless recipients.empty? unless recipients.empty?
recipients.map!{|x| x = x.url + "receive/"} recipients.map!{|x| x = x.url + "receive/"}
puts self.class
puts "made it in here!"
xml = self.class.build_xml_for(self) xml = self.class.build_xml_for(self)
Rails.logger.info("Adding xml for #{self} to message queue to #{recipients}") Rails.logger.info("Adding xml for #{self} to message queue to #{recipients}")
@@queue.add_post_request( recipients, xml ) @@queue.add_post_request( recipients, xml )

2
lib/message_handler.rb
View file

@ -46,7 +46,7 @@ class MessageHandler
case query.type case query.type
when :post when :post
http = EventMachine::HttpRequest.new(query.destination).post :timeout => TIMEOUT, :body =>{:xml => query.body} http = EventMachine::HttpRequest.new(query.destination).post :timeout => TIMEOUT, :body =>{:xml => query.body}
http.callback { puts query.destination; puts query.body; process; process} http.callback { process; process}
when :get when :get
http = EventMachine::HttpRequest.new(query.destination).get :timeout => TIMEOUT http = EventMachine::HttpRequest.new(query.destination).get :timeout => TIMEOUT
http.callback {send_to_seed(query, http.response); process} http.callback {send_to_seed(query, http.response); process}