blob: 50694b7df31520883144109104df54c921e13889 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
|
require 'couchrest'
require 'json'
module Tapicero
class UserDatabase
def initialize(host, name)
@host = host
@name = name
end
def create
CouchRest.new(host).create_db(name)
Tapicero.logger.debug "database created successfully."
rescue RestClient::PreconditionFailed # database already existed
end
def secure(security)
# let's not overwrite if we have a security doc already
return if secured? && !Tapicero::FLAGS.include?('--overwrite-security')
Tapicero.logger.info "Writing Security to #{security_url}"
Tapicero.logger.debug security.to_json
CouchRest.put security_url, security
end
def add_design_docs
pattern = BASE_DIR + 'designs' + '*.json'
Tapicero.logger.debug "looking for design docs in #{pattern}"
Pathname.glob(pattern).each do |file|
upload_design_doc(file)
end
end
def upload_design_doc(file)
url = design_url(file.basename('.json'))
CouchRest.put url, JSON.parse(file.read)
Tapicero.logger.debug "uploaded design doc #{file.basename} to #{url}"
rescue RestClient::Conflict
end
def destroy
db = CouchRest.new(host).database(name)
db.delete! if db
Tapicero.logger.debug "database deleted successfully."
rescue RestClient::ResourceNotFound # no database found
end
protected
def secured?
CouchRest.get(security_url).keys.any?
end
def security_url
"#{host}/#{name}/_security"
end
def design_url(doc_name)
"#{host}/#{name}/_design/#{doc_name}"
end
attr_reader :host, :name
end
end
|