zammad/lib/sequencer/unit/import/ldap/users/sub_sequence.rb

# Copyright (C) 2012-2024 Zammad Foundation, https://zammad-foundation.org/

class Sequencer::Unit::Import::Ldap::Users::SubSequence < Sequencer::Unit::Base
  include ::Sequencer::Unit::Import::Common::SubSequence::Mixin::ImportJob

  uses :ldap_config, :ldap_connection, :dn_roles, :model_class, :external_sync_source
  provides :found_ids

  def process
    ldap_connection.search(ldap_config[:user_filter], attributes: relevant_attributes) do |entry|

      result = sequence_resource(entry)

      next if result[:instance].blank?

      found_ids.push(result[:instance].id)
    end

    state.provide(:found_ids, found_ids)
  end

  private

  def found_ids
    @found_ids ||= []
  end

  def default_params
    super.merge(
      dn_roles:             dn_roles,
      ldap_config:          ldap_config,
      model_class:          model_class,
      external_sync_source: external_sync_source,
      signup_role_ids:      signup_role_ids,
      found_ids:            found_ids,
    )
  end

  def signup_role_ids
    @signup_role_ids ||= Role.signup_role_ids.sort
  end

  def sequence
    'Import::Ldap::User'
  end

  def relevant_attributes
    # limit the fetched attributes for an entry to only
    # those which are needed to improve the performance
    attributes = ldap_config[:user_attributes].keys
    attributes.push('dn')
    attributes.push(ldap_config[:user_uid])
    attributes.uniq
  end
end