module CouchPotato
  class Database
    
    class ValidationsFailedError < ::Exception; end
  
    def initialize(couchrest_database)
      @database = couchrest_database
    end
    
    def view(spec)
      results = CouchPotato::View::ViewQuery.new(database,
        spec.design_document, spec.view_name, spec.map_function,
        spec.reduce_function).query_view!(spec.view_parameters)
      spec.process_results results
    end
  
    def save_document(document)
      return unless document.dirty?
      if document.new?
        create_document document
      else
        update_document document
      end
    end
    alias_method :save, :save_document
  
    def save_document!(document)
      save_document(document) || raise(ValidationsFailedError.new(document.errors.full_messages))
    end
    alias_method :save!, :save_document!
  
    def destroy_document(document)
      document.run_callbacks(:before_destroy)
      document._deleted = true
      database.delete_doc document.to_hash
      document.run_callbacks(:after_destroy)
      document._id = nil
      document._rev = nil
    end
    alias_method :destroy, :destroy_document
  
    def load_document(id)
      begin
        json = database.get(id)
        Class.const_get(json['ruby_class']).json_create json
      rescue(RestClient::ResourceNotFound)
        nil
      end
    end
    alias_method :load, :load_document
  
    def inspect
      "#<CouchPotato::Database>"
    end
  
    private
  
    def create_document(document)
      document.run_callbacks :before_validation_on_save
      document.run_callbacks :before_validation_on_create
      return unless document.valid?
      document.run_callbacks :before_save
      document.run_callbacks :before_create
      res = database.save_doc document.to_hash
      document._rev = res['rev']
      document._id = res['id']
      document.run_callbacks :after_save
      document.run_callbacks :after_create
      true
    end
  
    def update_document(document)
      document.run_callbacks(:before_validation_on_save)
      document.run_callbacks(:before_validation_on_update)
      return unless document.valid?
      document.run_callbacks :before_save
      document.run_callbacks :before_update
      res = database.save_doc document.to_hash
      document._rev = res['rev']
      document.run_callbacks :after_save
      document.run_callbacks :after_update
      true
    end
  
    def database
      @database
    end
  
  end
end