4 # arv tag add tag1 [tag2 ...] --object obj_uuid1 [--object obj_uuid2 ...]
5 # arv tag remove tag1 [tag2 ...] --object obj_uuid1 [--object obj_uuid2 ...]
6 # arv tag remove tag1 [tag2 ...] --all
10 "arv tag add tag1 [tag2 ...] --object object_uuid1 [object_uuid2...]\n" +
11 "arv tag remove tag1 [tag2 ...] --object object_uuid1 [object_uuid2...]\n" +
12 "arv tag remove --all\n"
19 def api_call(method, parameters:{}, request_body:{})
20 result = $client.execute(:api_method => method,
21 :parameters => parameters,
22 :body_object => request_body,
23 :authenticated => false,
25 authorization: "OAuth2 #{ENV['ARVADOS_API_TOKEN']}",
29 results = JSON.parse result.body
30 rescue JSON::ParserError => e
31 abort "Failed to parse server response:\n" + e.to_s
35 abort "Error: #{results["errors"][0]}"
41 def tag_add(tag, obj_uuid)
42 return api_call($arvados.links.create,
47 :head_uuid => obj_uuid,
52 def tag_remove(tag, obj_uuids=nil)
53 # If we got a list of objects to untag, look up the uuids for the
54 # links that need to be deleted.
57 obj_uuids.each do |uuid|
58 link = api_call($arvados.links.list,
66 if link['items_available'] > 0
67 link_uuids.push link['items'][0]['uuid']
71 all_tag_links = api_call($arvados.links.list,
78 link_uuids = all_tag_links['items'].map { |obj| obj['uuid'] }
83 link_uuids.each do |uuid|
84 results.push api_call($arvados.links.delete, parameters:{ :uuid => uuid })
87 $stderr.puts "no tags found to remove"
93 if RUBY_VERSION < '1.9.3' then
95 #{$0.gsub(/^\.\//,'')} requires Ruby version 1.9.3 or higher.
99 $arvados_api_version = ENV['ARVADOS_API_VERSION'] || 'v1'
100 $arvados_api_host = ENV['ARVADOS_API_HOST'] or
101 abort "#{$0}: fatal: ARVADOS_API_HOST environment variable not set."
102 $arvados_api_token = ENV['ARVADOS_API_TOKEN'] or
103 abort "#{$0}: fatal: ARVADOS_API_TOKEN environment variable not set."
104 $arvados_api_host_insecure = ENV['ARVADOS_API_HOST_INSECURE'] == 'yes'
108 require 'google/api_client'
115 #{$0}: fatal: some runtime dependencies are missing.
116 Try: gem install pp google-api-client json trollop
120 def debuglog(message, verbosity=1)
121 $stderr.puts "#{File.split($0).last} #{$$}: #{message}" if $debuglevel >= verbosity
125 def suppress_warnings
126 original_verbosity = $VERBOSE
129 $VERBOSE = original_verbosity
134 if $arvados_api_host_insecure or $arvados_api_host.match /local/
135 # You probably don't care about SSL certificate checks if you're
136 # testing with a dev server.
137 suppress_warnings { OpenSSL::SSL::VERIFY_PEER = OpenSSL::SSL::VERIFY_NONE }
140 class Google::APIClient
141 def discovery_document(api, version)
143 return @discovery_documents["#{api}:#{version}"] ||=
145 response = self.execute!(
146 :http_method => :get,
147 :uri => self.discovery_uri(api, version),
148 :authenticated => false
150 response.body.class == String ? JSON.parse(response.body) : response.body
155 global_opts = Trollop::options do
158 opt :dry_run, "Don't actually do anything", :short => "-n"
159 opt :verbose, "Print some things on stderr", :short => "-v"
160 opt :uuid, "Return the UUIDs of the objects in the response, one per line (default)", :short => nil
161 opt :json, "Return the entire response received from the API server, as a JSON object", :short => "-j"
162 opt :human, "Return the response received from the API server, as a JSON object with whitespace added for human consumption", :short => "-h"
163 opt :pretty, "Synonym of --human", :short => nil
164 opt :yaml, "Return the response received from the API server, in YAML format", :short => "-y"
165 stop_on ['add', 'remove']
168 p = Trollop::Parser.new do
170 "Remove this tag from all objects under your ownership. Only valid with `tag remove'.",
173 "The UUID of an object to which this tag operation should be applied.",
179 $options = Trollop::with_standard_exception_handling p do
183 if $options[:all] and ARGV[0] != 'remove'
187 # Set up the API client.
189 $client ||= Google::APIClient.
190 new(:host => $arvados_api_host,
191 :application_name => File.split($0).last,
192 :application_version => $application_version.to_s)
193 $arvados = $client.discovered_api('arvados', $arvados_api_version)
205 $options[:object].each do |obj|
206 results.push(tag_add(tag, obj))
211 if $options[:all] then
212 results.concat tag_remove(tag)
214 results.concat tag_remove(tag, $options[:object])
221 if global_opts[:human] or global_opts[:pretty] then
222 puts Oj.dump(results, :indent => 1)
223 elsif global_opts[:yaml] then
225 elsif global_opts[:json] then
226 puts Oj.dump(results)
230 abort("Response did not include a uuid:\n" +
231 Oj.dump(r, :indent => 1) +