Nessuna descrizione http://j1x-huginn.herokuapp.com

webhook_agent.rb 3.9KB

    module Agents class WebhookAgent < Agent include WebRequestConcern cannot_be_scheduled! cannot_receive_events! description do <<-MD The Webhook Agent will create events by receiving webhooks from any source. In order to create events with this agent, make a POST request to: ``` https://#{ENV['DOMAIN']}/users/#{user.id}/web_requests/#{id || ':id'}/#{options['secret'] || ':secret'} ``` #{'The placeholder symbols above will be replaced by their values once the agent is saved.' unless id} Options: * `secret` - A token that the host will provide for authentication. * `expected_receive_period_in_days` - How often you expect to receive events this way. Used to determine if the agent is working. * `payload_path` - JSONPath of the attribute in the POST body to be used as the Event payload. Set to `.` to return the entire message. If `payload_path` points to an array, Events will be created for each element. * `verbs` - Comma-separated list of http verbs your agent will accept. For example, "post,get" will enable POST and GET requests. Defaults to "post". * `response` - The response message to the request. Defaults to 'Event Created'. * `recaptcha_secret` - Setting this to a reCAPTCHA "secret" key makes your agent verify incoming requests with reCAPTCHA. Don't forget to embed a reCAPTCHA snippet including your "site" key in the originating form(s). * `recaptcha_send_remote_addr` - Set this to true if your server is properly configured to set REMOTE_ADDR to the IP address of each visitor (instead of that of a proxy server). MD end event_description do <<-MD The event payload is based on the value of the `payload_path` option, which is set to `#{interpolated['payload_path']}`. MD end def default_options { "secret" => "supersecretstring", "expected_receive_period_in_days" => 1, "payload_path" => "some_key" } end def receive_web_request(params, method, format) # check the secret secret = params.delete('secret') return ["Not Authorized", 401] unless secret == interpolated['secret'] # check the verbs verbs = (interpolated['verbs'] || 'post').split(/,/).map { |x| x.strip.downcase }.select { |x| x.present? } return ["Please use #{verbs.join('/').upcase} requests only", 401] unless verbs.include?(method) # check the reCAPTCHA response if required if recaptcha_secret = interpolated['recaptcha_secret'].presence recaptcha_response = params.delete('g-recaptcha-response') or return ["Not Authorized", 401] parameters = { secret: recaptcha_secret, response: recaptcha_response, } if boolify(interpolated['recaptcha_send_remote_addr']) parameters[:remoteip] = request.env['REMOTE_ADDR'] end begin response = faraday.post('https://www.google.com/recaptcha/api/siteverify', parameters) rescue => e error "Verification failed: #{e.message}" return ["Not Authorized", 401] end JSON.parse(response.body)['success'] or return ["Not Authorized", 401] end [payload_for(params)].flatten.each do |payload| create_event(payload: payload) end [response_message, 201] end def working? event_created_within?(interpolated['expected_receive_period_in_days']) && !recent_error_logs? end def validate_options unless options['secret'].present? errors.add(:base, "Must specify a secret for 'Authenticating' requests") end end def payload_for(params) Utils.value_at(params, interpolated['payload_path']) || {} end def response_message interpolated['response'] || 'Event Created' end end end