diff --git a/assets/javascripts/discourse/templates/components/wizard-custom-action.hbs b/assets/javascripts/discourse/templates/components/wizard-custom-action.hbs
index 4ef128c0..59fa22ab 100644
--- a/assets/javascripts/discourse/templates/components/wizard-custom-action.hbs
+++ b/assets/javascripts/discourse/templates/components/wizard-custom-action.hbs
@@ -96,7 +96,7 @@
{{d-editor value=action.post_template
- placeholder='admin.wizard.action.post_builder.placeholder'
+ placeholder='admin.wizard.action.interpolate_fields'
classNames='post-builder-editor'}}
@@ -157,7 +157,7 @@
diff --git a/assets/stylesheets/wizard_custom_admin.scss b/assets/stylesheets/wizard_custom_admin.scss
index 832188bd..0cfb4bb7 100644
--- a/assets/stylesheets/wizard_custom_admin.scss
+++ b/assets/stylesheets/wizard_custom_admin.scss
@@ -122,6 +122,23 @@
margin-top: 5px;
padding: 5px;
}
+
+ .api-body {
+ width: 100%;
+
+ .setting-label {
+ max-width: 70px;
+ }
+
+ .setting-value {
+ width: calc(100% - 180px);
+ }
+
+ textarea {
+ width: 100%;
+ min-height: 150px;
+ }
+ }
}
.wizard-links {
@@ -312,6 +329,142 @@
}
}
-.wizard-step-contents{
- height: unset !important;
+.wizard-step-contents {
+ height: unset !important;
+}
+
+.admin-wizards-api {
+ margin-bottom: 40px;
+
+ .content-list {
+ margin-right: 20px;
+ }
+
+ .new-api {
+ margin-top: 20px;
+ }
+
+ .metadata .title input {
+ width: 400px;
+ }
+
+ .buttons {
+ text-align: right;
+ vertical-align: middle;
+
+ > .d-icon, > .spinner {
+ margin-right: 7px;
+ }
+
+ .error {
+ margin-top: 10px;
+ color: $danger;
+ }
+ }
+}
+
+.wizard-api-header {
+ &.page {
+ margin-bottom: 20px;
+ }
+
+ .buttons {
+ float: right;
+ }
+
+ .wizard-header {
+ overflow: hidden;
+ }
+}
+
+.wizard-api-authentication {
+ display: flex;
+ background-color: $primary-very-low;
+ padding: 20px;
+ margin-bottom: 20px;
+
+ .settings {
+ width: 50%;
+ max-width: 50%;
+ }
+
+ .redirect-uri .controls {
+ word-break: break-all;
+ }
+
+ .auth-type .select-kit {
+ min-width: 210px;
+ width: 210px;
+ margin-bottom: 10px;
+ }
+
+ .status {
+ border-left: 1px solid $primary;
+ margin-left: 20px;
+ padding-left: 20px;
+ width: 50%;
+ max-width: 50%;
+
+ .wizard-header {
+ overflow: hidden;
+ }
+
+ .authorization {
+ float: right;
+ }
+
+ .control-group {
+ margin-bottom: 15px;
+ }
+ }
+}
+
+.wizard-api-endpoints {
+ background-color: $primary-very-low;
+ padding: 20px;
+ margin-bottom: 20px;
+
+ .endpoint-list {
+ margin-top: 20px;
+
+ ul {
+ margin: 0;
+ list-style: none;
+ }
+ }
+
+ .endpoint {
+ display: flex;
+ margin-top: 20px;
+
+ .combo-box {
+ width: 200px;
+ margin-right: 10px;
+ margin-top: -2px;
+ width: 150px;
+ }
+
+ input {
+ margin: 0;
+ margin-right: 10px;
+ }
+
+ .endpoint-url {
+ width: 300px;
+ }
+
+ .remove-endpoint {
+ margin-left: auto;
+ }
+ }
+}
+
+.wizard-api-log {
+ background-color: #f8f8f8;
+ padding: 20px;
+ margin-bottom: 20px;
+}
+
+.wizard-step-contents{
+ height: unset !important;
}
diff --git a/config/locales/client.en.yml b/config/locales/client.en.yml
index 194e1428..7634dcc5 100644
--- a/config/locales/client.en.yml
+++ b/config/locales/client.en.yml
@@ -59,6 +59,7 @@ en:
name_required: "Wizards must have a name."
steps_required: "Wizards must have at least one step."
id_required: "All wizards, steps, fields and actions need an id."
+ invalid_api_body: "Request body JSON needs to be a valid JSON."
type_required: "All fields need a type."
after_time_need_time: "After time is enabled but no time is set."
after_time_invalid: "After time is invalid."
@@ -114,6 +115,8 @@ en:
add_fields: "{{type}} Fields"
available_fields: "* If 'Save wizard submissions' is disabled, only the fields of the current step are available to the current step's actions."
topic_attr: "Topic Attribute"
+ interpolate_fields: "Insert wizard fields using the field_id in w{}. Insert user fields using field key in u{}."
+
skip_redirect:
label: "Skip Redirect"
description: "Don't redirect the user to this {{type}} after the wizard completes"
@@ -146,6 +149,64 @@ en:
label: "Custom Category"
wizard_field: "Wizard Field"
user_field: "User Field"
+ send_to_api:
+ label: "Send to API"
+ api: "API"
+ endpoint: "Endpoint"
+ select_an_api: "Select an API"
+ select_an_endpoint: "Select an endpoint"
+ body: "Request body JSON"
+
+ api:
+ label: "API"
+ nav_label: 'APIs'
+ new: 'New Api'
+ name: "Name (can't be changed)"
+ name_placeholder: 'Underscored'
+ title: 'Title'
+ title_placeholder: 'Display name'
+ remove: 'Delete'
+ save: "Save"
+
+ auth:
+ label: "Authorization"
+ btn: 'Authorize'
+ settings: "Settings"
+ status: "Status"
+ redirect_uri: "Redirect url"
+ type: 'Type'
+ type_none: 'Select a type'
+ url: "Authorization url"
+ token_url: "Token url"
+ client_id: 'Client id'
+ client_secret: 'Client secret'
+ username: 'username'
+ password: 'password'
+ params:
+ label: 'Params'
+ new: 'New param'
+ key: 'key'
+ value: 'value'
+
+ status:
+ label: "Status"
+ authorized: 'Authorized'
+ not_authorized: "Not authorized"
+ code: "Code"
+ access_token: "Access token"
+ refresh_token: "Refresh token"
+ expires_at: "Expires at"
+ refresh_at: "Refresh at"
+
+ endpoint:
+ label: "Endpoints"
+ add: "Add endpoint"
+ name: "Endpoint name"
+ method: "Select a method"
+ url: "Enter a url"
+
+ log:
+ label: "Logs"
wizard_js:
location:
diff --git a/controllers/api.rb b/controllers/api.rb
new file mode 100644
index 00000000..a4ed8e6d
--- /dev/null
+++ b/controllers/api.rb
@@ -0,0 +1,138 @@
+class CustomWizard::ApiController < ::ApplicationController
+ before_action :ensure_logged_in
+ before_action :ensure_admin
+ skip_before_action :check_xhr, only: [:redirect]
+
+ def index
+ end
+
+ def list
+ serializer = ActiveModel::ArraySerializer.new(
+ CustomWizard::Api.list,
+ each_serializer: CustomWizard::BasicApiSerializer
+ )
+ render json: MultiJson.dump(serializer)
+ end
+
+ def find
+ render_serialized(CustomWizard::Api.get(api_params[:name]), CustomWizard::ApiSerializer, root: false)
+ end
+
+ def save
+ current = CustomWizard::Api.get(api_params[:name])
+
+ if api_params[:new] && current
+ raise Discourse::InvalidParameters, "An API with that name already exists: '#{current.title || current.name}'"
+ end
+
+ PluginStoreRow.transaction do
+ CustomWizard::Api.set(api_params[:name], title: api_params[:title])
+
+ if auth_data.present?
+ auth_data['auth_params'] = auth_data['auth_params'] || []
+ CustomWizard::Api::Authorization.set(api_params[:name], auth_data)
+ end
+
+ if api_params[:endpoints].is_a? String
+ begin
+ endpoints = JSON.parse(api_params[:endpoints])
+ endpoints.each do |endpoint|
+ CustomWizard::Api::Endpoint.set(api_params[:name], endpoint)
+ end
+ rescue => e
+ puts e
+ end
+ end
+ end
+
+ render json: success_json.merge(
+ api: CustomWizard::ApiSerializer.new(
+ CustomWizard::Api.get(api_params[:name]),
+ root: false
+ )
+ )
+ end
+
+ def remove
+ PluginStoreRow.transaction do
+ CustomWizard::Api.remove(api_params[:name])
+ CustomWizard::Api::Authorization.remove(api_params[:name])
+ CustomWizard::Api::Endpoint.remove(api_params[:name])
+ CustomWizard::Api::LogEntry.clear(api_params[:name])
+ end
+
+ render json: success_json
+ end
+
+ def authorize
+ result = CustomWizard::Api::Authorization.get_token(api_params[:name])
+
+ if result.instance_variable_defined?(:@error)
+ render json: failed_json.merge(message: result['error_description'] || result['error'])
+ else
+ render json: success_json.merge(
+ api: CustomWizard::ApiSerializer.new(
+ CustomWizard::Api.get(api_params[:name]),
+ root: false
+ )
+ )
+ end
+ end
+
+ def clearlogs
+ CustomWizard::Api::LogEntry.clear(api_params[:name])
+ render json: success_json
+ end
+
+ def redirect
+ params.require(:name)
+ params.require(:code)
+
+ CustomWizard::Api::Authorization.set(params[:name], code: params[:code])
+ CustomWizard::Api::Authorization.get_token(params[:name])
+
+ return redirect_to path('/admin/wizards/apis/' + params[:name])
+ end
+
+ private
+
+ def api_params
+ params.require(:name)
+
+ data = params.permit(
+ :name,
+ :title,
+ :auth_type,
+ :auth_url,
+ :token_url,
+ :client_id,
+ :client_secret,
+ :username,
+ :password,
+ :auth_params,
+ :endpoints,
+ :new
+ ).to_h
+
+ data[:name] = data[:name].underscore
+
+ @api_params ||= data
+ end
+
+ def auth_data
+ auth_data = api_params.slice(
+ :auth_type,
+ :auth_url,
+ :token_url,
+ :client_id,
+ :client_secret,
+ :username,
+ :password,
+ :auth_params
+ )
+
+ auth_data[:auth_params] = JSON.parse(auth_data[:auth_params]) if auth_data[:auth_params].present?
+
+ @auth_data ||= auth_data
+ end
+end
diff --git a/jobs/refresh_api_access_token.rb b/jobs/refresh_api_access_token.rb
new file mode 100644
index 00000000..54f6da55
--- /dev/null
+++ b/jobs/refresh_api_access_token.rb
@@ -0,0 +1,7 @@
+module Jobs
+ class RefreshApiAccessToken < Jobs::Base
+ def execute(args)
+ CustomWizard::Api::Authorization.get_token(args[:name], refresh: true)
+ end
+ end
+end
diff --git a/lib/api/api.rb b/lib/api/api.rb
new file mode 100644
index 00000000..a5d4c155
--- /dev/null
+++ b/lib/api/api.rb
@@ -0,0 +1,34 @@
+class CustomWizard::Api
+ include ActiveModel::SerializerSupport
+
+ attr_accessor :name,
+ :title
+
+ def initialize(name, data={})
+ @name = name
+ data.each do |k, v|
+ self.send "#{k}=", v if self.respond_to?(k)
+ end
+ end
+
+ def self.set(name, data)
+ PluginStore.set("custom_wizard_api_#{name}", "metadata", data)
+ end
+
+ def self.get(name)
+ if data = PluginStore.get("custom_wizard_api_#{name}", "metadata")
+ self.new(name, data)
+ end
+ end
+
+ def self.remove(name)
+ PluginStore.remove("custom_wizard_api_#{name}", "metadata")
+ end
+
+ def self.list
+ PluginStoreRow.where("plugin_name LIKE 'custom_wizard_api_%' AND key = 'metadata'")
+ .map do |record|
+ self.new(record['plugin_name'].sub("custom_wizard_api_", ""), ::JSON.parse(record['value']))
+ end
+ end
+end
diff --git a/lib/api/authorization.rb b/lib/api/authorization.rb
new file mode 100644
index 00000000..745ecc9b
--- /dev/null
+++ b/lib/api/authorization.rb
@@ -0,0 +1,151 @@
+require 'excon'
+
+class CustomWizard::Api::Authorization
+ include ActiveModel::SerializerSupport
+
+ attr_accessor :api_name,
+ :authorized,
+ :auth_type,
+ :auth_url,
+ :token_url,
+ :client_id,
+ :client_secret,
+ :auth_params,
+ :access_token,
+ :refresh_token,
+ :token_expires_at,
+ :token_refresh_at,
+ :code,
+ :username,
+ :password
+
+ def initialize(api_name, data={})
+ @api_name = api_name
+
+ data.each do |k, v|
+ self.send "#{k}=", v if self.respond_to?(k)
+ end
+ end
+
+ def authorized
+ @authorized ||= @access_token && @token_expires_at.to_datetime > Time.now
+ end
+
+ def self.set(api_name, new_data = {})
+
+ api_name = api_name.underscore
+
+ data = self.get(api_name, data_only: true) || {}
+
+ new_data.each do |k, v|
+ data[k.to_sym] = v
+ end
+
+ PluginStore.set("custom_wizard_api_#{api_name}", 'authorization', data)
+
+ self.get(api_name)
+ end
+
+ def self.get(api_name, opts = {})
+ api_name = api_name.underscore
+
+ if data = PluginStore.get("custom_wizard_api_#{api_name}", 'authorization')
+ if opts[:data_only]
+ data
+ else
+ self.new(api_name, data)
+ end
+ else
+ nil
+ end
+ end
+
+ def self.remove(api_name)
+ PluginStore.remove("custom_wizard_api_#{api_name}", "authorization")
+ end
+
+ def self.get_header_authorization_string(name)
+ auth = CustomWizard::Api::Authorization.get(name)
+ raise Discourse::InvalidParameters.new(:name) unless auth.present?
+
+ if auth.auth_type === "basic"
+ raise Discourse::InvalidParameters.new(:username) unless auth.username.present?
+ raise Discourse::InvalidParameters.new(:password) unless auth.password.present?
+ "Basic #{Base64.strict_encode64((auth.username + ":" + auth.password).chomp)}"
+ else
+ raise Discourse::InvalidParameters.new(auth.access_token) unless auth.access_token.present?
+ "Bearer #{auth.access_token}"
+ end
+ end
+
+ def self.get_token(name, opts = {})
+ authorization = CustomWizard::Api::Authorization.get(name)
+ type = authorization.auth_type
+
+ body = {}
+
+ if opts[:refresh] && type === 'oauth_3'
+ body['grant_type'] = 'refresh_token'
+ elsif type === 'oauth_2'
+ body['grant_type'] = 'client_credentials'
+ elsif type === 'oauth_3'
+ body['grant_type'] = 'authorization_code'
+ end
+
+ unless opts[:refresh]
+ body['client_id'] = authorization.client_id
+ body['client_secret'] = authorization.client_secret
+ end
+
+ if type === 'oauth_3'
+ body['code'] = authorization.code
+ body['redirect_uri'] = Discourse.base_url + "/admin/wizards/apis/#{name}/redirect"
+ end
+
+ connection = Excon.new(
+ authorization.token_url,
+ :headers => {
+ "Content-Type" => "application/x-www-form-urlencoded"
+ },
+ :method => 'GET',
+ :query => URI.encode_www_form(body)
+ )
+ begin
+ result = connection.request()
+ log_params = {time: Time.now, user_id: 0, status: 'SUCCESS', url: authorization.token_url, error: ""}
+ CustomWizard::Api::LogEntry.set(name, log_params)
+ rescue SystemCallError => e
+ log_params = {time: Time.now, user_id: 0, status: 'FAILURE', url: authorization.token_url, error: "Token refresh request failed: #{e.inspect}"}
+ CustomWizard::Api::LogEntry.set(name, log_params)
+ end
+
+ self.handle_token_result(name, result)
+ end
+
+ def self.handle_token_result(name, result)
+ result_data = JSON.parse(result.body)
+
+ if result_data['error']
+ return result_data
+ end
+
+ data = {}
+
+ data['access_token'] = result_data['access_token']
+ data['refresh_token'] = result_data['refresh_token'] if result_data['refresh_token']
+ data['token_type'] = result_data['token_type'] if result_data['token_type']
+
+ if result_data['expires_in']
+ data['token_expires_at'] = Time.now + result_data['expires_in'].seconds
+ data['token_refresh_at'] = data['token_expires_at'].to_time - 10.minutes
+
+ opts = {
+ name: name
+ }
+
+ Jobs.enqueue_at(data['token_refresh_at'], :refresh_api_access_token, opts)
+ end
+
+ CustomWizard::Api::Authorization.set(name, data)
+ end
+end
diff --git a/lib/api/endpoint.rb b/lib/api/endpoint.rb
new file mode 100644
index 00000000..3036a49f
--- /dev/null
+++ b/lib/api/endpoint.rb
@@ -0,0 +1,101 @@
+class CustomWizard::Api::Endpoint
+ include ActiveModel::SerializerSupport
+
+ attr_accessor :id,
+ :name,
+ :api_name,
+ :method,
+ :url
+
+ def initialize(api_name, data={})
+ @api_name = api_name
+
+ data.each do |k, v|
+ self.send "#{k}=", v if self.respond_to?(k)
+ end
+ end
+
+ def self.set(api_name, new_data)
+ if new_data['id']
+ data = self.get(api_name, new_data['id'], data_only: true)
+ endpoint_id = new_data['id']
+ else
+ data = {}
+ endpoint_id = SecureRandom.hex(3)
+ end
+
+ new_data.each do |k, v|
+ data[k.to_sym] = v
+ end
+
+ PluginStore.set("custom_wizard_api_#{api_name}", "endpoint_#{endpoint_id}", data)
+
+ self.get(api_name, endpoint_id)
+ end
+
+ def self.get(api_name, endpoint_id, opts={})
+ return nil if !endpoint_id
+
+ if data = PluginStore.get("custom_wizard_api_#{api_name}", "endpoint_#{endpoint_id}")
+ if opts[:data_only]
+ data
+ else
+ data[:id] = endpoint_id
+ self.new(api_name, data)
+ end
+ else
+ nil
+ end
+ end
+
+ def self.remove(api_name)
+ PluginStoreRow.where("plugin_name = 'custom_wizard_api_#{api_name}' AND key LIKE 'endpoint_%'").destroy_all
+ end
+
+ def self.list(api_name)
+ PluginStoreRow.where("plugin_name LIKE 'custom_wizard_api_#{api_name}' AND key LIKE 'endpoint_%'")
+ .map do |record|
+ api_name = record['plugin_name'].sub("custom_wizard_api_", "")
+ data = ::JSON.parse(record['value'])
+ data[:id] = record['key'].split('_').last
+ self.new(api_name, data)
+ end
+ end
+
+ def self.request(user, api_name, endpoint_id, body)
+ endpoint = self.get(api_name, endpoint_id)
+ auth = CustomWizard::Api::Authorization.get_header_authorization_string(api_name)
+
+ connection = Excon.new(
+ URI.parse(URI.encode(endpoint.url)).to_s,
+ :headers => {
+ "Authorization" => auth,
+ "Accept" => "application/json, */*",
+ "Content-Type" => "application/json"
+ }
+ )
+
+ params = {
+ method: endpoint.method
+ }
+
+ if body
+ body = JSON.generate(body)
+ body.delete! '\\'
+ params[:body] = body
+ end
+
+ begin
+ response = connection.request(params)
+ log_params = {time: Time.now, user_id: user.id, status: 'SUCCESS', url: endpoint.url, error: ""}
+
+ CustomWizard::Api::LogEntry.set(api_name, log_params)
+ return JSON.parse(response.body)
+ rescue
+ # TODO: improve error detail
+ log_params = {time: Time.now, user_id: user.id, status: 'FAILURE', url: endpoint.url, error: "API request failed"}
+ CustomWizard::Api::LogEntry.set(api_name, log_params)
+ return JSON.parse "[{\"error\":\"API request failed\"}]"
+ end
+ end
+end
diff --git a/lib/api/logentry.rb b/lib/api/logentry.rb
new file mode 100644
index 00000000..1408615d
--- /dev/null
+++ b/lib/api/logentry.rb
@@ -0,0 +1,88 @@
+class CustomWizard::Api::LogEntry
+ include ActiveModel::SerializerSupport
+
+ attr_accessor :log_id,
+ :time,
+ :user_id,
+ :status,
+ :url,
+ :error,
+ :username,
+ :userpath,
+ :name,
+ :avatar_template
+
+ def initialize(api_name, data={})
+ @api_name = api_name
+
+ data.each do |k, v|
+ self.send "#{k}=", v if self.respond_to?(k)
+ end
+ end
+
+ def self.set(api_name, new_data)
+ if new_data['log_id']
+ data = self.get(api_name, new_data['log_id'], data_only: true)
+ log_id = new_data['log_id']
+ else
+ data = {}
+ log_id = SecureRandom.hex(3)
+ end
+
+ new_data.each do |k, v|
+ data[k.to_sym] = v
+ end
+
+ PluginStore.set("custom_wizard_api_#{api_name}", "log_#{log_id}", data)
+
+ self.get(api_name, log_id)
+ end
+
+ def self.get(api_name, log_id, opts={})
+ return nil if !log_id
+
+ if data = PluginStore.get("custom_wizard_api_#{api_name}", "log_#{log_id}")
+ if opts[:data_only]
+ data
+ else
+ data[:log_id] = log_id
+ self.new(api_name, data)
+ end
+ else
+ nil
+ end
+ end
+
+ def self.remove(api_name)
+ PluginStoreRow.where("plugin_name = 'custom_wizard_api_#{api_name}' AND key LIKE 'log_%'").destroy_all
+ end
+
+ def self.list(api_name)
+ PluginStoreRow.where("plugin_name LIKE 'custom_wizard_api_#{api_name}' AND key LIKE 'log_%'")
+ .map do |record|
+ api_name = record['plugin_name'].sub("custom_wizard_api_", "")
+ data = ::JSON.parse(record['value'])
+ data[:log_id] = record['key'].split('_').last
+ this_user = User.find_by(id: data['user_id'])
+ unless this_user.nil?
+ data[:user_id] = this_user.id || nil
+ data[:username] = this_user.username || ""
+ data[:userpath] = "/u/#{this_user.username_lower}/activity"
+ data[:name] = this_user.name || ""
+ data[:avatar_template] = "/user_avatar/default/#{this_user.username_lower}/97/#{this_user.uploaded_avatar_id}.png"
+ else
+ data[:user_id] = nil
+ data[:username] = ""
+ data[:userpath] = ""
+ data[:name] = ""
+ data[:avatar_template] = ""
+ end
+ self.new(api_name, data)
+ end
+ end
+
+ def self.clear(api_name)
+ PluginStoreRow.where("plugin_name = 'custom_wizard_api_#{api_name}' AND key LIKE 'log_%'").destroy_all
+ end
+
+end
diff --git a/lib/builder.rb b/lib/builder.rb
index 45b191b4..8533c4c3 100644
--- a/lib/builder.rb
+++ b/lib/builder.rb
@@ -444,6 +444,28 @@ class CustomWizard::Builder
end
end
+ def send_to_api(user, action, data)
+ api_body = nil
+
+ if action['api_body'] != ""
+ begin
+ api_body_parsed = JSON.parse(action['api_body'])
+ rescue JSON::ParserError
+ raise Discourse::InvalidParameters, "Invalid API body definition: #{action['api_body']} for #{action['title']}"
+ end
+ api_body = CustomWizard::Builder.fill_placeholders(JSON.generate(api_body_parsed), user, data)
+ end
+
+ result = CustomWizard::Api::Endpoint.request(user, action['api'], action['api_endpoint'], api_body)
+
+ if error = result['error'] || (result[0] && result[0]['error'])
+ error = error['message'] || error
+ updater.errors.add(:send_to_api, error)
+ else
+ ## add validation callback
+ end
+ end
+
def add_to_group(user, action, data)
if group_id = data[action['group_id']]
if group = Group.find(group_id)
diff --git a/plugin.rb b/plugin.rb
index 231bb7e1..1709b7ea 100644
--- a/plugin.rb
+++ b/plugin.rb
@@ -54,6 +54,7 @@ after_initialize do
require_dependency 'admin_constraint'
Discourse::Application.routes.append do
mount ::CustomWizard::Engine, at: 'w'
+ post 'wizard/authorization/callback' => "custom_wizard/authorization#callback"
scope module: 'custom_wizard', constraints: AdminConstraint.new do
get 'admin/wizards' => 'admin#index'
@@ -66,6 +67,14 @@ after_initialize do
delete 'admin/wizards/custom/remove' => 'admin#remove'
get 'admin/wizards/submissions' => 'admin#index'
get 'admin/wizards/submissions/:wizard_id' => 'admin#submissions'
+ get 'admin/wizards/apis' => 'api#list'
+ get 'admin/wizards/apis/new' => 'api#index'
+ get 'admin/wizards/apis/:name' => 'api#find'
+ put 'admin/wizards/apis/:name' => 'api#save'
+ delete 'admin/wizards/apis/:name' => 'api#remove'
+ delete 'admin/wizards/apis/logs/:name' => 'api#clearlogs'
+ get 'admin/wizards/apis/:name/redirect' => 'api#redirect'
+ get 'admin/wizards/apis/:name/authorize' => 'api#authorize'
end
end
@@ -81,6 +90,19 @@ after_initialize do
load File.expand_path('../controllers/steps.rb', __FILE__)
load File.expand_path('../controllers/admin.rb', __FILE__)
+ load File.expand_path('../jobs/refresh_api_access_token.rb', __FILE__)
+ load File.expand_path('../lib/api/api.rb', __FILE__)
+ load File.expand_path('../lib/api/authorization.rb', __FILE__)
+ load File.expand_path('../lib/api/endpoint.rb', __FILE__)
+ load File.expand_path('../lib/api/logentry.rb', __FILE__)
+ load File.expand_path('../controllers/api.rb', __FILE__)
+ load File.expand_path('../serializers/api/api_serializer.rb', __FILE__)
+ load File.expand_path('../serializers/api/authorization_serializer.rb', __FILE__)
+ load File.expand_path('../serializers/api/basic_api_serializer.rb', __FILE__)
+ load File.expand_path('../serializers/api/endpoint_serializer.rb', __FILE__)
+ load File.expand_path('../serializers/api/basic_endpoint_serializer.rb', __FILE__)
+ load File.expand_path('../serializers/api/log_serializer.rb', __FILE__)
+
::UsersController.class_eval do
def wizard_path
if custom_wizard_redirect = current_user.custom_fields['redirect_to_wizard']
diff --git a/serializers/api/api_serializer.rb b/serializers/api/api_serializer.rb
new file mode 100644
index 00000000..9d7fba70
--- /dev/null
+++ b/serializers/api/api_serializer.rb
@@ -0,0 +1,34 @@
+class CustomWizard::ApiSerializer < ApplicationSerializer
+ attributes :name,
+ :title,
+ :authorization,
+ :endpoints,
+ :log
+
+ def authorization
+ if authorization = CustomWizard::Api::Authorization.get(object.name)
+ CustomWizard::Api::AuthorizationSerializer.new(
+ authorization,
+ root: false
+ )
+ end
+ end
+
+ def endpoints
+ if endpoints = CustomWizard::Api::Endpoint.list(object.name)
+ ActiveModel::ArraySerializer.new(
+ endpoints,
+ each_serializer: CustomWizard::Api::EndpointSerializer
+ )
+ end
+ end
+
+ def log
+ if log = CustomWizard::Api::LogEntry.list(object.name)
+ ActiveModel::ArraySerializer.new(
+ log,
+ each_serializer: CustomWizard::Api::LogSerializer
+ )
+ end
+ end
+end
diff --git a/serializers/api/authorization_serializer.rb b/serializers/api/authorization_serializer.rb
new file mode 100644
index 00000000..2ca347b5
--- /dev/null
+++ b/serializers/api/authorization_serializer.rb
@@ -0,0 +1,16 @@
+class CustomWizard::Api::AuthorizationSerializer < ApplicationSerializer
+ attributes :auth_type,
+ :auth_url,
+ :token_url,
+ :client_id,
+ :client_secret,
+ :authorized,
+ :auth_params,
+ :access_token,
+ :refresh_token,
+ :token_expires_at,
+ :token_refresh_at,
+ :code,
+ :username,
+ :password
+end
diff --git a/serializers/api/basic_api_serializer.rb b/serializers/api/basic_api_serializer.rb
new file mode 100644
index 00000000..d0214d65
--- /dev/null
+++ b/serializers/api/basic_api_serializer.rb
@@ -0,0 +1,14 @@
+class CustomWizard::BasicApiSerializer < ApplicationSerializer
+ attributes :name,
+ :title,
+ :endpoints
+
+ def endpoints
+ if endpoints = CustomWizard::Api::Endpoint.list(object.name)
+ ActiveModel::ArraySerializer.new(
+ endpoints,
+ each_serializer: CustomWizard::Api::BasicEndpointSerializer
+ )
+ end
+ end
+end
diff --git a/serializers/api/basic_endpoint_serializer.rb b/serializers/api/basic_endpoint_serializer.rb
new file mode 100644
index 00000000..e2cc2262
--- /dev/null
+++ b/serializers/api/basic_endpoint_serializer.rb
@@ -0,0 +1,4 @@
+class CustomWizard::Api::BasicEndpointSerializer < ApplicationSerializer
+ attributes :id,
+ :name
+end
diff --git a/serializers/api/endpoint_serializer.rb b/serializers/api/endpoint_serializer.rb
new file mode 100644
index 00000000..18c1406c
--- /dev/null
+++ b/serializers/api/endpoint_serializer.rb
@@ -0,0 +1,10 @@
+class CustomWizard::Api::EndpointSerializer < ApplicationSerializer
+ attributes :id,
+ :name,
+ :method,
+ :url
+
+ def method
+ object.send('method')
+ end
+end
diff --git a/serializers/api/log_serializer.rb b/serializers/api/log_serializer.rb
new file mode 100644
index 00000000..13ee1555
--- /dev/null
+++ b/serializers/api/log_serializer.rb
@@ -0,0 +1,12 @@
+class CustomWizard::Api::LogSerializer < ApplicationSerializer
+ attributes :log_id,
+ :time,
+ :status,
+ :url,
+ :error,
+ :user_id,
+ :username,
+ :userpath,
+ :name,
+ :avatar_template
+end