Refactoring StopAreaReferentialSync

Refs #1710

1 files changed, 23 insertions, 0 deletions

diff --git a/app/workers/stop_area_referential_sync_worker.rb b/app/workers/stop_area_referential_sync_worker.rb
new file mode 100644
index 000000000..662652831
--- /dev/null
+++ b/app/workers/stop_area_referential_sync_worker.rb
@@ -0,0 +1,23 @@
+class StopAreaReferentialSyncWorker
+  include Sidekiq::Worker
+  sidekiq_options :retry => false
+
+  def process_time
+    Process.clock_gettime(Process::CLOCK_MONOTONIC, :second)
+  end
+
+  def perform(stop_area_ref_sync_id)
+    start_time    = process_time
+    stop_ref_sync = StopAreaReferentialSync.find stop_area_ref_sync_id
+    stop_ref_sync.run
+    begin
+      info = Stif::ReflexSynchronization.synchronize
+      stop_ref_sync.successful info.merge({processing_time: process_time - start_time})
+    rescue Exception => e
+      stop_ref_sync.failed({
+        error: e.message,
+        processing_time: process_time - start_time
+      })
+    end
+  end
+end