discourse/lib/discourse_hub.rb

91 lines
2.3 KiB
Ruby
Raw Normal View History

require_dependency 'version'
require_dependency 'site_setting'
2013-02-05 14:16:51 -05:00
module DiscourseHub
2013-02-05 14:16:51 -05:00
STATS_FETCHED_AT_KEY = "stats_fetched_at"
2014-05-11 19:06:28 -04:00
def self.version_check_payload
2017-07-27 21:20:09 -04:00
default_payload = { installed_version: Discourse::VERSION::STRING }.merge!(Discourse.git_branch == "unknown" ? {} : { branch: Discourse.git_branch })
default_payload.merge!(get_payload)
2014-05-11 19:06:28 -04:00
end
def self.discourse_version_check
get('/version_check', version_check_payload)
2013-02-05 14:16:51 -05:00
end
def self.stats_fetched_at=(time_with_zone)
$redis.set STATS_FETCHED_AT_KEY, time_with_zone.to_i
end
2013-02-05 14:16:51 -05:00
def self.get_payload
SiteSetting.share_anonymized_statistics && stats_fetched_at < 7.days.ago ? About.fetch_cached_stats.symbolize_keys : {}
end
2017-07-27 21:20:09 -04:00
def self.get(rel_url, params = {})
singular_action :get, rel_url, params
2013-02-05 14:16:51 -05:00
end
2017-07-27 21:20:09 -04:00
def self.post(rel_url, params = {})
collection_action :post, rel_url, params
2013-02-05 14:16:51 -05:00
end
2017-07-27 21:20:09 -04:00
def self.put(rel_url, params = {})
collection_action :put, rel_url, params
end
2017-07-27 21:20:09 -04:00
def self.delete(rel_url, params = {})
singular_action :delete, rel_url, params
end
2017-07-27 21:20:09 -04:00
def self.singular_action(action, rel_url, params = {})
connect_opts = connect_opts(params)
JSON.parse(Excon.send(action,
"#{hub_base_url}#{rel_url}",
{
headers: { 'Referer' => referer, 'Accept' => accepts.join(', ') },
query: params,
omit_default_port: true
}.merge(connect_opts)
).body)
end
2017-07-27 21:20:09 -04:00
def self.collection_action(action, rel_url, params = {})
connect_opts = connect_opts(params)
JSON.parse(Excon.send(action,
"#{hub_base_url}#{rel_url}",
{
body: JSON[params],
headers: { 'Referer' => referer, 'Accept' => accepts.join(', '), "Content-Type" => "application/json" },
omit_default_port: true
}.merge(connect_opts)
).body)
end
def self.connect_opts(params = {})
params.delete(:connect_opts)&.except(:body, :headers, :query) || {}
end
def self.hub_base_url
if Rails.env.production?
2017-01-06 17:54:38 -05:00
ENV['HUB_BASE_URL'] || 'https://api.discourse.org/api'
2013-02-05 14:16:51 -05:00
else
ENV['HUB_BASE_URL'] || 'http://local.hub:3000/api'
2013-02-05 14:16:51 -05:00
end
end
def self.accepts
['application/json', 'application/vnd.discoursehub.v1']
2013-02-05 14:16:51 -05:00
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