summaryrefslogtreecommitdiff
path: root/files/couch-doc-update
blob: 45d9f876249b77cfdb38cb5b8f0daf0d51669dbf (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
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
#!/usr/bin/ruby

#
# This script will update the values of a particular couchdb document. The benefit of this little script over
# using a simple curl command for updating a document is this:
#
#   * exit non-zero status if document was not updated.
#   * updates existing documents easily, taking care of the _rev id for you.
#   * if document doesn't exist, it is created
#
# REQUIREMENTS
#
#   gem 'couchrest'
#
# USAGE
#
#   couch-doc-update --port <port> --db <db> --id <doc_id> --data <json>
#
# EXAMPLE
#
#   create a new user:
#     couch-doc-update --db _users --id org.couchdb.user:ca_daemon --data '{"type": "user", "name": "ca_daemon", "roles": ["certs"], "password": "sshhhh"}'
#
#   update a user:
#     couch-doc-update --db _users --id org.couchdb.user:ca_daemon --data '{"password":"sssshhh"}'
#
# To update the _users DB on bigcouch, you must connect to port 5986 instead of the default couchdb port 5984
#

begin; require 'rubygems'; rescue LoadError; end # optionally load rubygems
require 'couchrest'
require 'json'

def main
  #
  # parse options
  #
  @port       = "5984" 
  @db_name    = nil
  @doc_id     = nil
  @new_data   = nil
  loop do
    case ARGV[0]
      when '--port' then ARGV.shift; @port     = ARGV.shift
      when '--db'   then ARGV.shift; @db_name  = ARGV.shift
      when '--id'   then ARGV.shift; @doc_id   = ARGV.shift
      when '--data' then ARGV.shift; @new_data = ARGV.shift
      when /^-/     then usage("Unknown option: #{ARGV[0].inspect}")
      else break
    end
  end
  usage("Missing required option") unless @db_name && @doc_id && @new_data
  @new_data = JSON.parse(@new_data)
	
  #
  # update document
  #
  begin
    @db  = CouchRest.database(connection_string(@db_name, @port))
    @doc = get_document(@db, @doc_id)
    result = if @doc
      update_document(@db, @doc, @new_data)
    else
      create_document(@db, @doc_id, @new_data)
    end
    exit 0 if result['ok']
    raise StandardError.new(result.inspect)
  rescue StandardError => exc
    puts "ERROR: " + exc.to_s
    exit 1
  end
end

def get_document(db, doc_id)
  begin
    db.get(doc_id)
  rescue RestClient::ResourceNotFound
    nil
  end
end

def update_document(db, doc, data)
  data.each do |key, value|
    doc[key] = value
  end
  db.save_doc(doc)
end

def create_document(db, doc_id, data)
  data["_id"] = doc_id
  db.save_doc(data)
end

def connection_string(database, port)
  protocol  = "http"
  hostname  = "127.0.0.1"
  #port      = "5984"
  username  = "admin"
  password  = ""

  netrc = File.read('/etc/couchdb/couchdb.netrc')
  netrc.scan(/\w+ [\w\.]+/).each do |key_value|
    key, value = key_value.split ' '
    case key
      when "machine"  then hostname = value
      when "login"    then username = value
      when "password" then password = value
    end
  end

  "%s://%s:%s@%s:%s/%s" % [protocol, username, password, hostname, port, database]
end

def usage(s)
  $stderr.puts(s)
  $stderr.puts("Usage: #{File.basename($0)} --port <port> --db <db> --id <doc_id> --data <json>")
  exit(2)
end

main()