From 28884f9931bd5644167116b5be32af3b947935e2 Mon Sep 17 00:00:00 2001
From: Ana Rosas <a.rosas10@gmail.com>
Date: Fri, 13 May 2016 12:59:18 -0500
Subject: [PATCH] Enqueue build_restart event in Hub

---
 lib/travis/api/app/endpoint/builds.rb   |  8 +++++++-
 lib/travis/api/workers/build_restart.rb | 13 +++++++------
 2 files changed, 14 insertions(+), 7 deletions(-)

diff --git a/lib/travis/api/app/endpoint/builds.rb b/lib/travis/api/app/endpoint/builds.rb
index 91d375dc..37d4b317 100644
--- a/lib/travis/api/app/endpoint/builds.rb
+++ b/lib/travis/api/app/endpoint/builds.rb
@@ -54,7 +54,13 @@ class Travis::Api::App
           status 400
           result = false
         else
-          Travis::Sidekiq::BuildRestart.perform_async(id: params[:id], user_id: current_user.id)
+
+          ::Sidekiq::Client.push(
+                'queue'   => 'hub',
+                'class'   => 'Travis::Hub::Sidekiq::Worker',
+                'args'    => ["build:restart", {id: params[:id], user_id: current_user.id}]
+              )
+
           status 202
           result = true
         end
diff --git a/lib/travis/api/workers/build_restart.rb b/lib/travis/api/workers/build_restart.rb
index 427bc24b..2bf98c85 100644
--- a/lib/travis/api/workers/build_restart.rb
+++ b/lib/travis/api/workers/build_restart.rb
@@ -4,14 +4,15 @@ require 'multi_json'
 module Travis
   module Sidekiq
     class BuildRestart
-      class ProcessingError < StandardError; end
-
       include ::Sidekiq::Worker
-      sidekiq_options queue: :build_restarts
+      sidekiq_options queue: :hub
 
-      def perform(data)
-        user = User.find(data['user_id'])
-        Travis.service(:reset_model, user, build_id: data['id']).run
+      def perform(payload)
+        ::Sidekiq::Client.push(
+              'queue'   => 'hub',
+              'class'   => 'Travis::Hub::Sidekiq::Worker',
+              'args'    => ["build:restart", payload]
+            )
       end
 
     end