81 lines
2.0 KiB
Ruby
81 lines
2.0 KiB
Ruby
require_dependency 'version'
|
|
|
|
module DiscourseHub
|
|
|
|
STATS_FETCHED_AT_KEY = "stats_fetched_at"
|
|
|
|
def self.version_check_payload
|
|
default_payload = { installed_version: Discourse::VERSION::STRING }.merge!(Discourse.git_branch == "unknown" ? {} : {branch: Discourse.git_branch})
|
|
default_payload.merge!(get_payload)
|
|
end
|
|
|
|
def self.discourse_version_check
|
|
get('/version_check', version_check_payload)
|
|
end
|
|
|
|
def self.stats_fetched_at=(time_with_zone)
|
|
$redis.set STATS_FETCHED_AT_KEY, time_with_zone.to_i
|
|
end
|
|
|
|
private
|
|
|
|
def self.get_payload
|
|
SiteSetting.share_anonymized_statistics && stats_fetched_at < 7.days.ago ? About.fetch_cached_stats.symbolize_keys : {}
|
|
end
|
|
|
|
def self.get(rel_url, params={})
|
|
singular_action :get, rel_url, params
|
|
end
|
|
|
|
def self.post(rel_url, params={})
|
|
collection_action :post, rel_url, params
|
|
end
|
|
|
|
def self.put(rel_url, params={})
|
|
collection_action :put, rel_url, params
|
|
end
|
|
|
|
def self.delete(rel_url, params={})
|
|
singular_action :delete, rel_url, params
|
|
end
|
|
|
|
def self.singular_action(action, rel_url, params={})
|
|
JSON.parse(Excon.send(action,
|
|
"#{hub_base_url}#{rel_url}",
|
|
headers: { 'Referer' => referer, 'Accept' => accepts.join(', ') },
|
|
:query => params,
|
|
:omit_default_port => true
|
|
).body)
|
|
end
|
|
|
|
def self.collection_action(action, rel_url, params={})
|
|
JSON.parse(Excon.send(action,
|
|
"#{hub_base_url}#{rel_url}",
|
|
body: params,
|
|
headers: { 'Referer' => referer, 'Accept' => accepts.join(', '), 'Content-Type' => 'applicaton/json' }
|
|
).body)
|
|
end
|
|
|
|
def self.hub_base_url
|
|
if Rails.env.production?
|
|
ENV['HUB_BASE_URL'] || 'https://api.discourse.org/api'
|
|
else
|
|
ENV['HUB_BASE_URL'] || 'http://local.hub:3000/api'
|
|
end
|
|
end
|
|
|
|
def self.accepts
|
|
['application/json', 'application/vnd.discoursehub.v1']
|
|
end
|
|
|
|
def self.referer
|
|
Discourse.base_url
|
|
end
|
|
|
|
def self.stats_fetched_at
|
|
t = $redis.get(STATS_FETCHED_AT_KEY)
|
|
t ? Time.zone.at(t.to_i) : 1.year.ago
|
|
end
|
|
|
|
end
|