synchronizations_controller.rb in maestrano-connector-rails-2.3.3

- old
+ new
@@ -1,82 +1,7 @@
-class Maestrano::SynchronizationsController < Maestrano::Rails::WebHookController
-  def show
-    tenant = params[:tenant]
-    uid = params[:id]
-    organization = Maestrano::Connector::Rails::Organization.find_by(uid: uid, tenant: tenant)
-    return render json: {errors: [{message: 'Organization not found', code: 404}]}, status: :not_found unless organization
+# frozen_string_literal: true
 
-    status = organization_status organization
-
-    render_organization_sync(organization, status, 200)
+module Maestrano
+  class SynchronizationsController < Maestrano::Rails::WebHookController
+    include Maestrano::Concerns::SynchronizationsController
   end
-
-  def create
-    tenant = params[:tenant]
-    uid = params[:group_id]
-    opts = params[:opts] || {}
-    organization = Maestrano::Connector::Rails::Organization.find_by(uid: uid, tenant: tenant)
-    return render json: {errors: [{message: 'Organization not found', code: 404}]}, status: :not_found unless organization
-
-    organization.sync_enabled = organization.synchronized_entities.values.any? { |settings| settings.values.any? { |v| v } }
-    organization.save if organization.sync_enabled_changed?
-
-    status = organization_status(organization)
-
-    unless %w[RUNNING ENQUEUED].include?(status)
-      Maestrano::Connector::Rails::SynchronizationJob.perform_later(organization.id, opts.with_indifferent_access)
-      status = 'ENQUEUED'
-    end
-
-    render_organization_sync(organization, status, 201)
-  end
-
-  def update_metadata
-    tenant = params[:tenant]
-    uid = params[:group_id]
-    organization = Maestrano::Connector::Rails::Organization.find_by(uid: uid, tenant: tenant)
-    return render json: {errors: [{message: 'Organization not found', code: 404}]}, status: :not_found unless organization
-
-    organization.set_instance_metadata
-    organization.reset_synchronized_entities
-    render_organization_sync(organization, status, 200)
-  end
-
-  def toggle_sync
-    tenant = params[:tenant]
-    uid = params[:group_id]
-    organization = Maestrano::Connector::Rails::Organization.find_by(uid: uid, tenant: tenant)
-    return render json: {errors: [{message: 'Organization not found', code: 404}]}, status: :not_found unless organization
-
-    organization.toggle(:sync_enabled)
-    organization.save
-    status = organization_status organization
-    render_organization_sync(organization, status, 200)
-  end
-
-  private
-
-    def render_organization_sync(organization, status, code)
-      h = {
-        group_id: organization.uid,
-        sync_enabled: organization.sync_enabled,
-        status: status
-      }
-      last_sync = organization.synchronizations.last
-      if last_sync
-        h[:message] = last_sync.message
-        h[:updated_at] = last_sync.updated_at
-      end
-
-      render json: h, status: code
-    end
-
-    def organization_status(organization)
-      if Maestrano::Connector::Rails::SynchronizationJob.find_running_job(organization.id)
-        'RUNNING'
-      elsif Maestrano::Connector::Rails::SynchronizationJob.find_job(organization.id)
-        'ENQUEUED'
-      else
-        organization.synchronizations.last&.status || 'DISABLED'
-      end
-    end
 end