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
|
require "fog/core/deprecated_connection_accessors"
require "fog/core/cache"
module Fog
class Model
extend Fog::Attributes::ClassMethods
include Fog::Attributes::InstanceMethods
include Fog::Core::DeprecatedConnectionAccessors
attr_accessor :collection
attr_reader :service
def initialize(new_attributes = {})
# TODO: Remove compatibility with old connection option
attribs = new_attributes.clone
@service = attribs.delete(:service)
if @service.nil? && attribs[:connection]
Fog::Logger.deprecation("Passing :connection option is deprecated, use :service instead [light_black](#{caller.first})[/]")
@service = attribs[:connection]
end
merge_attributes(attribs)
end
# Creates new or updates existing model
# @return [self]
def save
persisted? ? update : create
end
# Creates new entity from model
# @raise [Fog::Errors::NotImplemented] you must implement #create method in child class and return self
# @return [self]
def create
raise Fog::Errors::NotImplemented, "Implement method #create for #{self.class}. Method must return self"
end
# Updates new entity with model
# @raise [Fog::Errors::NotImplemented] you must implement #update method in child class and return self
# @return [self]
def update
raise Fog::Errors::NotImplemented, "Implement method #update for #{self.class}. Method must return self"
end
# Destroys entity by model identity
# @raise [Fog::Errors::NotImplemented] you must implement #destroy method in child class and return self
# @return [self]
def destroy
raise Fog::Errors::NotImplemented, "Implement method #destroy for #{self.class}. Method must return self"
end
def cache
Fog::Cache.new(self)
end
def inspect
Fog::Formatador.format(self)
end
def ==(o)
unless o.is_a?(Fog::Model)
super
else
if (o.identity.nil? and self.identity.nil?)
o.object_id == self.object_id
else
o.class == self.class and o.identity == self.identity
end
end
end
# @return [self] if model successfully reloaded
# @return [nil] if something went wrong or model was not found
def reload
requires :identity
object = collection.get(identity)
return unless object
merge_attributes(object.all_associations_and_attributes)
self
rescue Excon::Errors::SocketError
nil
end
def to_json(_options = {})
Fog::JSON.encode(attributes)
end
def symbolize_keys(hash)
return nil if hash.nil?
hash.reduce({}) do |options, (key, value)|
options[(key.to_sym rescue key) || key] = value
options
end
end
def wait_for(timeout = Fog.timeout, interval = Fog.interval, &block)
reload_has_succeeded = false
duration = Fog.wait_for(timeout, interval) do # Note that duration = false if it times out
if reload
reload_has_succeeded = true
instance_eval(&block)
else
false
end
end
raise Fog::Errors::Error, "Reload failed, #{self.class} #{identity} not present." unless reload_has_succeeded
duration # false if timeout; otherwise {:duration => elapsed time }
end
end
end
|
