af83/chouette-core

module Chouette
  module Sync
    class Referential
      attr_reader :target, :options

      def initialize(target, options = {})
        @target = target
        @options = options
      end

      attr_accessor :source, :code_space, :strict_mode, :default_provider, :event_handler
      alias strict_mode? strict_mode

      def synchronize_with(sync_class)
        sync_classes << sync_class
      end

      def update_or_create
        syncs.each do |sync|
          sync.code_space = code_space
          sync.default_provider = default_provider

          sync.update_or_create
        end
      end

      def delete_after_update_or_create
        syncs.each do |sync|
          sync.code_space = code_space
          sync.default_provider = default_provider

          sync.delete_after_update_or_create
        end
      end

      def after_synchronisation
        syncs.each(&:after_synchronisation)
      end

      def delete(resource_type, deleted_ids)
        syncs.each do |sync|
          sync.delete deleted_ids if sync.resource_type == resource_type
        end
      end

      def synchronize
        syncs.each(&:synchronize)
      end

      def sync_for(sync_class)
        syncs.find { |sync| sync.instance_of?(sync_class) }
      end

      protected

      def sync_classes
        @sync_classes ||= []
      end

      def syncs
        @syncs ||= sync_classes.map do |sync_class|
          create_sync sync_class
        end
      end

      def sync_options
        options.merge({
                        event_handler: event_handler,
                        target: target,
                        source: source,
                        code_space: code_space,
                        default_provider: default_provider,
                        strict_mode: strict_mode?
                      })
      end

      def create_sync(sync_class)
        sync_class.new sync_options
      end
    end
  end
end