module DirectoryDiff
  module Transformer
    class InMemory 
      attr_reader :current_directory, :new_directory
      attr_reader :transforms, :transforms_index
      attr_reader :options

      def initialize(current_directory)
        @current_directory = current_directory
        @transforms = []
        @transforms_index = {}
      end

      def into(new_directory, options={})
        raise ArgumentError unless new_directory.respond_to?(:each)
        @new_directory = new_directory
        @options = options || {}

        new_employees.each do |email, employee|
          process_employee(email, employee)
        end

        unseen_employees.each do |email, employee|
          process_employee(email, employee)
        end

        transforms
      end

      protected

      def process_employee(email, assistant_owner)
        new_employee = find_new_employee(email)
        old_employee = find_current_employee(email)

        # cycle detection
        if transforms_index.has_key?(email)
          return
        end
        transforms_index[email] = nil

        if new_employee.nil?
          add_transform(:delete, old_employee)
          assistants_string = assistant_owner[3].to_s.split(",").reject do |assistant|
                                assistant == email
                              end.join(",")
          assistant_owner[3] = assistants_string == "" ? nil : assistants_string
        else
          own_email = new_employee[1]
          assistant_emails = new_employee[3].to_s.split(",")
          assistant_emails.delete(own_email)

          assistant_emails.each do |assistant_email|
            process_employee(assistant_email, new_employee)
          end

          # assistant_emails may be nil. we only use the csv to *set*
          # assistants. if it was nil, we backfill from current employee so that
          # the new record appears to be the same as the current record
          if assistant_emails.empty?
            original_assistant_value = nil
            new_employee[3] = old_employee&.fetch(3) 
          else
            original_assistant_value = new_employee[3]
          end

          # phone_number may be nil. we only use the csv to *set* phone numbers if
          # it has a value. if it was nil, we backfill from current employee so that
          # the new record apperas to the be same as the current record
          phone_number = new_employee[2].presence
          if phone_number.nil?
            original_phone_number_value = nil
            new_employee[2] = old_employee&.fetch(2)
          else
            original_phone_number_value = new_employee[2]
          end

          if old_employee.nil?
            add_transform(:insert, new_employee)
          elsif new_employee[0, 4] == old_employee[0, 4]
            # restore assistant value after cleanup like missing assistants and own email
            new_employee[3] = original_assistant_value
            # restore phone number value
            new_employee[2] = original_phone_number_value
            add_transform(:noop, new_employee) unless options[:skip_noop]
          else
            add_transform(:update, new_employee)
          end
        end
      end

      def add_transform(op, employee)
        return if employee.nil?
        email = employee[1]
        existing_operation = transforms_index[email]
        if existing_operation.nil?
          operation = [op, *employee]
          transforms_index[email] = operation
          transforms << operation
        end
      end

      def find_new_employee(email)
        new_employees[email]
      end

      def find_current_employee(email)
        current_employees[email]
      end

      def new_employees
        @new_employees ||= build_index(new_directory)
      end

      def current_employees
        @current_employees ||= build_index(current_directory)
      end

      def unseen_employees
        emails = current_employees.keys - new_employees.keys
        emails.map do |email|
          [email, current_employees[email]]
        end
      end

      def build_index(directory)
        accum = {}
        directory.each do |employee|
          # Item at index 1 is email, so downcase it
          employee[1] = employee[1].downcase unless employee[1].nil?
          email = employee[1]
          accum[email] = employee
        end

        accum
      end
    end
  end
end