# rubocop:disable Naming/PredicateName,Metrics/MethodLength
module BridgeCache
  module Data
    module BridgeModel
      EXCLUDED_COLUMNS = Set['id', 'created_at', 'updated_at']
      OVERRIDDEN_COLUMNS = { 'bridge_created_at' => 'created_at'.freeze,
                             'bridge_updated_at' => 'updated_at'.freeze }.freeze

      def adjusted_table_name
        if BridgeCache.use_internal_database
          table_name
        else
          to_s.demodulize.underscore.pluralize
        end
      end

      def self.extended(base)
        base.class_eval do
          scope :in_domain, ->(domain_id) { for_domain(domain_id) }
          scope :active, -> { is_active? }
          self.table_name = adjusted_table_name
        end
      end

      def format_import_row(row)
        row
      end

      def import_from_csv(file_path)
        BridgeCache::Plugins::CSVDump.dump_to_table(self, file_path)
      end

      def create_from_csv_row(row)
        BridgeCache::Plugins::CSVDump.dump_row(self, row)
      end

      def cleanup(row_ids)
        # Implement this method in your model if you want to do any sort of post creation cleanup.
        # See tagging.rb for an example.
      end

      def webhook_updated(message)
        create_or_update_from_webhook(message)
      end

      def webhook_created(message)
        create_or_update_from_webhook(message)
      end

      def webhook_deleted(message)
        message.payload_class.where(bridge_id: message.resource_object['id']).destroy_all
      end

      def webhook_completed(_message)
        raise 'Method not implemented'
      end

      def for_domain(domain_id)
        where(domain_id: domain_id)
      end

      def uniq_constraint_name
        "#{table_name.downcase}_bridge_uniq"
      end

      def unique_column_names
        %w[bridge_id]
      end

      def is_active?
        where(deleted_at: nil) if column_names.include? 'deleted_at'
      end

      def csv_mapping
        columns = column_names.as_json
        mapping = {}

        columns.each do |column|
          next if EXCLUDED_COLUMNS.include? column

          if OVERRIDDEN_COLUMNS.key?(column)
            mapping[OVERRIDDEN_COLUMNS[column]] = column
          else
            mapping[column] = column
          end
        end

        mapping['bridge_id'] = 'bridge_id'
        mapping
      end

      private

      def create_or_update_from_webhook(message)
        message.payload_class.create_from_csv_row(message.resource_object)
      end
    end
  end
end
# rubocop:enable Naming/PredicateName,Metrics/MethodLength