basic webhook on job complete

Author: joshlarsen

docker/app/jobs/runner_job.rb

@@ -81,6 +81,7 @@ def perform
       puts "Processing results finished - #{guid}"
 
       job.complete!
+      job.send_webhook
       puts "Runner job finished - #{guid}"
     rescue StandardError => e
       job.failed!

docker/app/models/job.rb

@@ -1,3 +1,8 @@
+# frozen_string_literal: true
+
+#
+# Generic Job
+#
 class Job < ApplicationRecord
   has_many :results
 
@@ -13,4 +18,29 @@ class Job < ApplicationRecord
     parse: 3,
     cleanup: 4
   }, _prefix: :job
+
+  #
+  # Send an external webhook
+  #
+  def send_webhook
+    config = Rails.application.config_for(:webhooks)
+
+    return unless config.webhooks
+
+    config.webhooks.each do |_k, webhook|
+      next if webhook.nil?
+
+      url = URI(webhook)
+      headers = {'content-type' => 'application/json'}
+      payload = {
+        'job_id' => id,
+        'job_type' => kind,
+        'status' => status,
+        'results' => results.count
+      }.to_json
+      res = Net::HTTP.post(URI(url), payload, headers)
+
+      res.code
+    end
+  end
 end

docker/config/webhooks.yml

@@ -0,0 +1,6 @@
+development:
+  webhooks:
+    runner_job: <%= ENV['JOB_WEBHOOK_URL'] %>
+production:
+  webhooks:
+    runner_job: <%= ENV['JOB_WEBHOOK_URL'] %>