Skip to content

Instantly share code, notes, and snippets.

@mojodna

mojodna/gist:22224

Forked from mattb/gist:22223
Created Nov 4, 2008
Embed
What would you like to do?
#!/usr/bin/env ruby
require '/Users/mattb/Work/Dopplr/code/dopplr/config/environment'
require 'fire_hydrant'
config = YAML.load(File.read("fire_hydrant.yml"))
hydrant = FireHydrant.new(config, false)
hydrant.jack!(OAuthPubSubJack)
hydrant.on_startup do
defer :subscribed, 0 do
begin
Identity.find(:all, :conditions => ["service = 'fireeagle' and identifier is not null"]).map { |i|
puts i.identifier
@oauth_token = OAuth::Token.new(i.identifier, i.extra[:secret])
[i, pubsub.subscribe_to("/api/0.1/user/#{@oauth_token.token}", @oauth_consumer, @oauth_token)]
}
rescue Jabber::ServerError => e
puts e
end
end
# define here or as hydrant.subscriptions_received
def subscribed(subs)
subs.each { |identity, subscription|
if subscription.subscription == :subscribed
puts "#{identity.traveller.name}: Subscribe successful."
else
puts "#{identity.traveller.name}: Subscribe failed!"
end
}
end
end
hydrant.run!
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
You can’t perform that action at this time.