Class: Maestrano::Connector::Rails::SynchronizationJob

Inherits:
ActiveJob::Base
  • Object
show all
Defined in:
app/jobs/maestrano/connector/rails/synchronization_job.rb

Instance Method Summary collapse

Instance Method Details

#perform(organization, opts) ⇒ Object

Supported options:

* :forced => true  synchronization has been triggered manually (for logging purposes only)
* :only_entities => [person, tasks_list]
* :full_sync => true  synchronization is performed without date filtering
* :connec_preemption => true|false : preemption is always|never given to connec in case of conflict (if not set, the most recently updated entity is kept)



10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
 
# File 'app/jobs/maestrano/connector/rails/synchronization_job.rb', line 10

def perform(organization, opts)
  return unless organization.sync_enabled

  # Check if previous synchronization is still running
  if Synchronization.where(organization_id: organization.id, status: 'RUNNING').where(created_at: (30.minutes.ago..Time.now)).exists?
    ConnectorLogger.log('info', organization, "Synchronization skipped: Previous synchronization is still running")
    return
  end

  # Check if recovery mode: last 3 synchronizations have failed
  if Synchronization.where(organization_id: organization.id, status: 'ERROR').order(created_at: :desc).limit(3).count == 3 \
      && Synchronization.where(organization_id: organization.id).order(created_at: :desc).limit(1).first.updated_at > 1.day.ago
    ConnectorLogger.log('info', organization, "Synchronization skipped: Recovery mode (three previous synchronizations have failed)")
    return
  end

  # Trigger synchronization
  ConnectorLogger.log('info', organization, "Start synchronization, opts=#{opts}")
  current_synchronization = Synchronization.create_running(organization)

  begin
    last_synchronization = Synchronization.where(organization_id: organization.id, status: 'SUCCESS', partial: false).order(updated_at: :desc).first
    connec_client = Maestrano::Connec::Client[organization.tenant].new(organization.uid)
    external_client = External.get_client(organization)

    if opts[:only_entities]
      ConnectorLogger.log('info', organization, "Synchronization is partial and will synchronize only #{opts[:only_entities].join(' ')}")
      # The synchronization is marked as partial and will not be considered as the last-synchronization for the next sync
      current_synchronization.set_partial
      opts[:only_entities].each do |entity|
        sync_entity(entity, organization, connec_client, external_client, last_synchronization, opts)
      end
    else
      organization.synchronized_entities.select{|k, v| v}.keys.each do |entity|
        sync_entity(entity.to_s, organization, connec_client, external_client, last_synchronization, opts)
      end
    end

    ConnectorLogger.log('info', organization, "Finished synchronization, organization=#{organization.uid}, status=success")
    current_synchronization.set_success
  rescue => e
    ConnectorLogger.log('info', organization, "Finished synchronization, organization=#{organization.uid}, status=error, message=#{e.message} backtrace=#{e.backtrace.join("\n\t")}")
    current_synchronization.set_error(e.message)
  end
end

#sync_entity(entity_name, organization, connec_client, external_client, last_synchronization, opts) ⇒ Object 



56
57
58
59
60
61
62
63
64
65
66
 
# File 'app/jobs/maestrano/connector/rails/synchronization_job.rb', line 56

def sync_entity(entity_name, organization, connec_client, external_client, last_synchronization, opts)
  entity_instance = "Entities::#{entity_name.titleize.split.join}".constantize.new

  entity_instance.before_sync(connec_client, external_client, last_synchronization, organization, opts)
  external_entities = entity_instance.get_external_entities(external_client, last_synchronization, organization, opts)
  connec_entities = entity_instance.get_connec_entities(connec_client, last_synchronization, organization, opts)
  mapped_entities = entity_instance.consolidate_and_map_data(connec_entities, external_entities, organization, opts)
  entity_instance.push_entities_to_external(external_client, mapped_entities[:connec_entities], organization)
  entity_instance.push_entities_to_connec(connec_client, mapped_entities[:external_entities], organization)
  entity_instance.after_sync(connec_client, external_client, last_synchronization, organization, opts)
end