Sha256: 1c04c0b855107d40b5eaf8b41d8c23785bce059c77789216e37f5b62f0ca492c
Contents?: true
Size: 1.44 KB
Versions: 7
Compression:
Stored size: 1.44 KB
Contents
require 'evma_httpserver'
require 'multi_json'
module Weeter
module Plugins
module Subscription
class Http
def initialize(client_app_config)
@config = client_app_config
end
def get_initial_filters(&block)
http = Weeter::Plugins::Net::OauthHttp.get(@config, @config.subscriptions_url)
http.callback {
filter_params = {}
if http.response_header.status == 200
yield MultiJson.decode(http.response)
else
Weeter.logger.error "Initial filters request failed with response code #{http.response_header.status}."
yield
end
}
end
def listen_for_filter_update(tweet_consumer)
port = @config.subscription_updates_port || Weeter::Configuration::ClientAppConfig::DEFAULT_SUBSCRIPTIONS_UPDATE_PORT
EM.start_server('localhost', port, UpdateServer) do |conn|
conn.tweet_consumer = tweet_consumer
end
end
class UpdateServer < EM::Connection
include EM::HttpServer
attr_accessor :tweet_consumer
def process_http_request
Weeter.logger.info("Reconnecting Twitter stream")
filter_params = MultiJson.decode(@http_post_content)
tweet_consumer.reconnect(filter_params)
EM::DelegatedHttpResponse.new(self).send_response
end
end
end
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems