1 class ArvadosBase < ActiveRecord::Base
2 self.abstract_class = true
3 attr_accessor :attribute_sortkey
5 def self.uuid_infix_object_kind
6 @@uuid_infix_object_kind ||= {
7 '4zz18' => 'arvados#collection',
8 'tpzed' => 'arvados#user',
9 'ozdt8' => 'arvados#api_client',
10 '8i9sb' => 'arvados#job',
11 'o0j2j' => 'arvados#link',
12 '57u5n' => 'arvados#log',
13 'j58dm' => 'arvados#specimen',
14 'p5p6p' => 'arvados#pipeline_template',
15 'mxsvm' => 'arvados#pipeline_template', # legacy Pipeline objects
16 'd1hrv' => 'arvados#pipeline_instance',
17 'uo14g' => 'arvados#pipeline_instance', # legacy PipelineInstance objects
18 'j7d0g' => 'arvados#group',
19 'ldvyl' => 'arvados#group' # only needed for legacy Project objects
25 @attribute_sortkey ||= {
29 'created_at' => '002',
30 'modified_at' => '003',
31 'modified_by_user' => '004',
32 'modified_by_client' => '005',
39 'updated_at' => 'zzz-999'
44 return @columns unless @columns.nil?
46 return @columns if $arvados_api_client.arvados_schema[self.to_s.to_sym].nil?
47 $arvados_api_client.arvados_schema[self.to_s.to_sym].each do |coldef|
48 k = coldef[:name].to_sym
49 if coldef[:type] == coldef[:type].downcase
50 @columns << column(k, coldef[:type].to_sym)
52 @columns << column(k, :text)
53 serialize k, coldef[:type].constantize
61 def self.column(name, sql_type = nil, default = nil, null = true)
62 ActiveRecord::ConnectionAdapters::Column.new(name.to_s, default, sql_type.to_s, null)
65 if uuid.class != String or uuid.length < 27 then
66 raise 'argument to find() must be a uuid string. Acceptable formats: warehouse locator or string with format xxxxx-xxxxx-xxxxxxxxxxxxxxx'
68 new.private_reload(uuid)
71 ArvadosResourceList.new(self).where(*args)
74 ArvadosResourceList.new(self).limit(*args)
77 ArvadosResourceList.new(self).eager(*args)
80 ArvadosResourceList.new(self).all(*args)
84 self.class.columns.each do |col|
85 obdata[col.name.to_sym] = self.send(col.name.to_sym)
88 postdata = { self.class.to_s.underscore => obdata }
90 postdata['_method'] = 'PUT'
92 resp = $arvados_api_client.api(self.class, '/' + uuid, postdata)
94 resp = $arvados_api_client.api(self.class, '', postdata)
96 return false if !resp[:etag] || !resp[:uuid]
98 # set read-only non-database attributes
102 # these attrs can be modified by "save" -- we should update our copies
103 %w(uuid owner created_at
104 modified_at modified_by_user modified_by_client
106 self.send(attr + '=', resp[attr.to_sym])
112 self.save or raise Exception.new("Save failed")
116 o.merge!(args.pop) if args[-1].is_a? Hash
117 o[:link_class] ||= args.shift
118 o[:name] ||= args.shift
119 o[:head_kind] ||= args.shift
120 o[:tail_kind] = self.kind
121 o[:tail_uuid] = self.uuid
123 return all_links.select do |m|
128 if (v.respond_to?(:uuid) ? v.uuid : v.to_s) != (test_v.respond_to?(:uuid) ? test_v.uuid : test_v.to_s)
136 @links = $arvados_api_client.api Link, '', { _method: 'GET', where: o, eager: true }
137 @links = $arvados_api_client.unpack_api_response(@links)
140 return @all_links if @all_links
141 res = $arvados_api_client.api Link, '', {
144 tail_kind: self.kind,
149 @all_links = $arvados_api_client.unpack_api_response(res)
152 private_reload(self.uuid)
154 def private_reload(uuid_or_hash)
155 raise "No such object" if !uuid_or_hash
156 if uuid_or_hash.is_a? Hash
159 hash = $arvados_api_client.api(self.class, '/' + uuid_or_hash)
162 if self.respond_to?(k.to_s + '=')
163 self.send(k.to_s + '=', v)
165 # When ArvadosApiClient#schema starts telling us what to expect
166 # in API responses (not just the server side database
167 # columns), this sort of awfulness can be avoided:
168 self.instance_variable_set('@' + k.to_s, v)
169 if !self.respond_to? k
170 singleton = class << self; self end
171 singleton.send :define_method, k, lambda { instance_variable_get('@' + k.to_s) }
182 def attributes_for_display
183 self.attributes.reject { |k,v|
184 attribute_sortkey.has_key?(k) and !attribute_sortkey[k]
186 attribute_sortkey[k] or k
192 (current_user.is_admin or
193 current_user.uuid == self.owner))
196 def attribute_editable?(attr)
197 if "created_at modified_at modified_by_user modified_by_client updated_at".index(attr.to_s)
199 elsif "uuid owner".index(attr.to_s)
200 current_user and current_user.is_admin
206 def self.resource_class_for_uuid(uuid, opts={})
207 if uuid.is_a? ArvadosBase
210 unless uuid.is_a? String
213 if opts[:class].is_a? Class
216 if uuid.match /^[0-9a-f]{32}(\+[^,]+)*(,[0-9a-f]{32}(\+[^,]+)*)*$/
220 uuid.match /^[0-9a-z]{5}-([0-9a-z]{5})-[0-9a-z]{15}$/ do |re|
221 resource_class ||= $arvados_api_client.
222 kind_class(self.uuid_infix_object_kind[re[1]])
224 if opts[:referring_object] and
225 opts[:referring_attr] and
226 opts[:referring_attr].match /_uuid$/
227 resource_class ||= $arvados_api_client.
228 kind_class(opts[:referring_object].
229 attributes[opts[:referring_attr].
230 sub(/_uuid$/, '_kind')])
244 Thread.current[:user]