Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- #!/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 do
- begin
- Identity.find(:all, :conditions => ["service = 'fireeagle' and identifier is not null"]).map { |i|
- puts i.identifier
- @config[:oauth_token] = i.identifier
- @config[:oauth_token_secret] = 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)
- if !subs.is_a? Array
- subs = [subs]
- end
- 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!
Add Comment
Please, Sign In to add comment