3 files changed, 38 insertions, 0 deletions
diff --git a/app/workers/ci/hip_chat_notifier_worker.rb b/app/workers/ci/hip_chat_notifier_worker.rb
new file mode 100644
index 00000000000..ebb43570e2a
--- /dev/null
+++ b/app/workers/ci/hip_chat_notifier_worker.rb
@@ -0,0 +1,19 @@
+module Ci
+  class HipChatNotifierWorker
+    include Sidekiq::Worker
+
+    def perform(message, options={})
+      room   = options.delete('room')
+      token  = options.delete('token')
+      server = options.delete('server')
+      name   = options.delete('service_name')
+      client_opts = {
+        api_version: 'v2',
+        server_url: server
+      }
+
+      client = HipChat::Client.new(token, client_opts)
+      client[room].send(name, message, options.symbolize_keys)
+    end
+  end
+end
diff --git a/app/workers/ci/slack_notifier_worker.rb b/app/workers/ci/slack_notifier_worker.rb
new file mode 100644
index 00000000000..3bbb9b4bec7
--- /dev/null
+++ b/app/workers/ci/slack_notifier_worker.rb
@@ -0,0 +1,10 @@
+module Ci
+  class SlackNotifierWorker
+    include Sidekiq::Worker
+
+    def perform(webhook_url, message, options={})
+      notifier = Slack::Notifier.new(webhook_url)
+      notifier.ping(message, options)
+    end
+  end
+end
diff --git a/app/workers/ci/web_hook_worker.rb b/app/workers/ci/web_hook_worker.rb
new file mode 100644
index 00000000000..0bb83845572
--- /dev/null
+++ b/app/workers/ci/web_hook_worker.rb
@@ -0,0 +1,9 @@
+module Ci
+  class WebHookWorker
+    include Sidekiq::Worker
+
+    def perform(hook_id, data)
+      Ci::WebHook.find(hook_id).execute data
+    end
+  end
+end