require_dependency 'rest_client' require_dependency 'version' module DiscourseHub class UsernameUnavailable < RuntimeError def initialize(username) @username = username end def response_message { success: false, message: I18n.t( "login.errors", errors:I18n.t( "login.not_available", suggestion: UserNameSuggester.suggest(@username) ) ) } end end def self.username_available?(username) json = get('/users/username_available', {username: username}) [json['available'], json['suggestion']] end def self.username_match?(username, email) json = get('/users/username_match', {username: username, email: email}) [json['match'], json['available'] || false, json['suggestion']] end def self.username_for_email(email) json = get('/users/username_match', {email: email}) json['suggestion'] end def self.register_username(username, email) json = post('/users', {username: username, email: email}) if json.has_key?('success') true else raise UsernameUnavailable.new(username) # TODO: report ALL the errors end end def self.unregister_username(username) json = delete('/memberships/' + username) json.has_key?('success') end def self.change_username(current_username, new_username) json = put("/users/#{current_username}/username", {username: new_username}) if json.has_key?('success') true else raise UsernameUnavailable.new(new_username) # TODO: report ALL the errors end end def self.version_check_payload { installed_version: Discourse::VERSION::STRING, forum_title: SiteSetting.title, forum_description: SiteSetting.site_description, forum_url: Discourse.base_url, contact_email: SiteSetting.contact_email, topic_count: Topic.listable_topics.count, post_count: Post.count, user_count: User.count, topics_7_days: Topic.listable_topics.where('created_at > ?', 7.days.ago).count, posts_7_days: Post.where('created_at > ?', 7.days.ago).count, users_7_days: User.where('created_at > ?', 7.days.ago).count, login_required: SiteSetting.login_required, locale: SiteSetting.default_locale } end def self.discourse_version_check get('/version_check', version_check_payload) end private 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 RestClient.send(action, "#{hub_base_url}#{rel_url}", {params: {access_token: access_token}.merge(params), accept: accepts } ) end def self.collection_action(action, rel_url, params={}) JSON.parse RestClient.send(action, "#{hub_base_url}#{rel_url}", {access_token: access_token}.merge(params), content_type: :json, accept: accepts ) end def self.hub_base_url if Rails.env == 'production' 'http://api.discourse.org/api' else ENV['HUB_BASE_URL'] || 'http://local.hub:3000/api' end end def self.access_token SiteSetting.discourse_org_access_key end def self.accepts [:json, 'application/vnd.discoursehub.v1'] end def self.username_operation if SiteSetting.call_discourse_hub? begin yield rescue DiscourseHub::UsernameUnavailable false rescue => e Rails.logger.error e.message + "\n" + e.backtrace.join("\n") end end end end