Contents

module BridgeCache::Data
  module BridgeModel
    EXCLUDED_COLUMNS = %w[created_at updated_at].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 is_active?
      where(deleted_at: nil) if column_names.include? 'deleted_at'
    end

    def csv_mapping
      columns = column_names.as_json
      mapping = {}
      columns.each { |column| mapping[column] = column unless EXCLUDED_COLUMNS.include?(column) }
      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

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
bridge_cache-0.3.6	app/lib/bridge_cache/data/bridge_model.rb
bridge_cache-0.3.5	app/lib/bridge_cache/data/bridge_model.rb
bridge_cache-0.3.4	app/lib/bridge_cache/data/bridge_model.rb
bridge_cache-0.3.3	app/lib/bridge_cache/data/bridge_model.rb
bridge_cache-0.3.2	app/lib/bridge_cache/data/bridge_model.rb
bridge_cache-0.3.01	app/lib/bridge_cache/data/bridge_model.rb
bridge_cache-0.3.0	app/lib/bridge_cache/data/bridge_model.rb