Sha256: 42bb964ff25326ee1fe80e262d707fcf2b7936a0e7bf868c241994b55d3b88b1
Contents?: true
Size: 1.74 KB
Versions: 12
Compression:
Stored size: 1.74 KB
Contents
require 'yaml' require 'rest-client' require 'time' module Localeapp class Poller include ::Localeapp::ApiCall # when we last asked the service for updates attr_accessor :polled_at # the last time the service had updates for us attr_accessor :updated_at def initialize @sync_file = SyncFile.new( Localeapp.configuration.synchronization_data_file ) @polled_at = sync_data.polled_at @updated_at = sync_data.updated_at end def sync_data sync_file.refresh sync_file.data end def write_synchronization_data!(polled_at, updated_at) sync_file.write(polled_at, updated_at) end def needs_polling? sync_data.polled_at < (Time.now.to_i - Localeapp.configuration.poll_interval) end def needs_reloading? sync_data.updated_at != @updated_at end def poll! api_call :translations, :url_options => { :query => { :updated_at => updated_at }}, :success => :handle_success, :failure => :handle_failure, :max_connection_attempts => 1 @success end def handle_success(response) Localeapp.log_with_time "poll success" @success = true Localeapp.updater.update(Localeapp.load_yaml(response)) write_synchronization_data!(current_time, Time.parse(response.headers[:date])) end def handle_failure(response) if response.code == 304 Localeapp.log_with_time "No new data" # Nothing new, update synchronization files write_synchronization_data!(current_time, updated_at) end @success = false end private # a SyncFile object representing the synchronization file attr_reader :sync_file def current_time Time.now end end end
Version data entries
12 entries across 12 versions & 1 rubygems