Module: Octokit::Client::PubSubHubbub
- Included in:
- Octokit::Client
- Defined in:
- lib/octokit/client/pub_sub_hubbub.rb
Overview
Methods for the PubSubHubbub API
Instance Method Summary collapse
-
#subscribe(topic, callback) ⇒ Boolean
Subscribe to a pubsub topic.
-
#subscribe_service_hook(repo, service_name, service_arguments = {}) ⇒ Object
Subscribe to a repository through pubsub.
-
#unsubscribe(topic, callback) ⇒ Boolean
Unsubscribe from a pubsub topic.
-
#unsubscribe_service_hook(repo, service_name) ⇒ Object
Unsubscribe repository through pubsub.
Instance Method Details
#subscribe(topic, callback) ⇒ Boolean
Subscribe to a pubsub topic
25 26 27 28 29 30 31 32 33 34 |
# File 'lib/octokit/client/pub_sub_hubbub.rb', line 25 def subscribe(topic, callback) = { :"hub.callback" => callback, :"hub.mode" => "subscribe", :"hub.topic" => topic } response = pub_sub_hubbub_request() response.status == 204 end |
#subscribe_service_hook(repo, service_name, service_arguments = {}) ⇒ Object
Subscribe to a repository through pubsub
67 68 69 70 71 |
# File 'lib/octokit/client/pub_sub_hubbub.rb', line 67 def subscribe_service_hook(repo, service_name, service_arguments = {}) topic = "#{Octokit.web_endpoint}#{Repository.new(repo)}/events/push" callback = "github://#{service_name}?#{service_arguments.collect{ |k,v| [ k,v ].map{ |p| URI.encode_www_form_component(p) }.join("=") }.join("&") }" subscribe(topic, callback) end |
#unsubscribe(topic, callback) ⇒ Boolean
Unsubscribe from a pubsub topic
45 46 47 48 49 50 51 52 53 54 |
# File 'lib/octokit/client/pub_sub_hubbub.rb', line 45 def unsubscribe(topic, callback) = { :"hub.callback" => callback, :"hub.mode" => "unsubscribe", :"hub.topic" => topic } response = pub_sub_hubbub_request() response.status == 204 end |
#unsubscribe_service_hook(repo, service_name) ⇒ Object
Unsubscribe repository through pubsub
82 83 84 85 86 |
# File 'lib/octokit/client/pub_sub_hubbub.rb', line 82 def unsubscribe_service_hook(repo, service_name) topic = "#{Octokit.web_endpoint}#{Repository.new(repo)}/events/push" callback = "github://#{service_name}" unsubscribe(topic, callback) end |