Class: CouchPotato::View::ViewQuery

Inherits:
Object
  • Object
show all
Defined in:
lib/couch_potato/view/view_query.rb

Overview

Used to query views (and create them if they don’t exist). Usually you won’t have to use this class directly. Instead it is used internally by the CouchPotato::Database.view method.

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(couchrest_database, design_document_name, view, language = :javascript) ⇒ ViewQuery

Returns a new instance of ViewQuery.



5
6
7
8
9
10
11
12
 
# File 'lib/couch_potato/view/view_query.rb', line 5

def initialize(couchrest_database, design_document_name, view, language = :javascript)
  @database = couchrest_database
  @design_document_name = design_document_name
  @view_name = view.keys[0]
  @map_function = view.values[0][:map]
  @reduce_function = view.values[0][:reduce]
  @language = language
end

Class Method Details

.__updated_views ⇒ Object 



32
33
34
35
 
# File 'lib/couch_potato/view/view_query.rb', line 32

def self.__updated_views
  @updated_views ||= {}
  @updated_views
end

.all_views ⇒ Object 



37
38
39
40
41
42
43
44
 
# File 'lib/couch_potato/view/view_query.rb', line 37

def self.all_views
  @all_views ||= CouchPotato.views.flat_map do |klass|
    specs =  klass.views.map { |view_name, view| klass.execute_view(view_name, {}) }
    specs.map do |klass_spec|
      { klass_spec.view_name => view_functions(klass_spec.map_function, klass_spec.reduce_function) }
    end
  end.inject(&:merge)
end

.all_views_digest ⇒ Object 



46
47
48
 
# File 'lib/couch_potato/view/view_query.rb', line 46

def self.all_views_digest
  @all_views_digest ||= Digest::SHA256.hexdigest(all_views.to_json)
end

.clear_cache ⇒ Object

mainly useful for testing where you drop the database between tests. only after clearing the cache design docs will be updated/re-created.



26
27
28
29
30
 
# File 'lib/couch_potato/view/view_query.rb', line 26

def self.clear_cache
  __updated_views.clear
  @all_views = nil
  @all_views_digest = nil
end

.view_functions(map_function, reduce_function) ⇒ Object 



67
68
69
 
# File 'lib/couch_potato/view/view_query.rb', line 67

def self.view_functions(map_function, reduce_function)
  {'map' => map_function, 'reduce' => reduce_function}.compact
end

Instance Method Details

#query_view!(parameters = {}) ⇒ Object 



14
15
16
17
18
19
20
21
22
 
# File 'lib/couch_potato/view/view_query.rb', line 14

def query_view!(parameters = {})
  update_view unless view_has_been_updated?
  begin
    query_view parameters
  rescue CouchRest::NotFound
    update_view
    retry
  end
end