Class: Travis::Client::Session
- Inherits:
-
Object
- Object
- Travis::Client::Session
show all
- Includes:
- Methods
- Defined in:
- lib/travis/client/session.rb
Constant Summary
collapse
- SSL_OPTIONS =
{ :ca_file => Tools::Assets['cacert.pem'] }
Instance Attribute Summary collapse
Instance Method Summary
collapse
Methods included from Methods
#account, #accounts, #api_endpoint, #api_endpoint=, #artifact, #broadcasts, #build, #cancel, #explicit_api_endpoint?, #github_auth, #job, #listen, #repo, #repos, #restart, #user, #worker, #workers
Constructor Details
#initialize(options = Travis::Client::ORG_URI) ⇒ Session
Returns a new instance of Session.
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
|
# File 'lib/travis/client/session.rb', line 24
def initialize(options = Travis::Client::ORG_URI)
@headers = {}
@cache = {}
@instruments = []
@agent_info = []
@config = nil
@faraday_adapter = defined?(Typhoeus) ? :typhoeus : :net_http
@ssl = SSL_OPTIONS
options = { :uri => options } unless options.respond_to? :each_pair
options.each_pair { |key, value| public_send("#{key}=", value) }
raise ArgumentError, "neither :uri nor :connection specified" unless connection
['Accept'] = 'application/json; version=2'
set_user_agent
end
|
Instance Attribute Details
#access_token ⇒ Object
Returns the value of attribute access_token.
22
23
24
|
# File 'lib/travis/client/session.rb', line 22
def access_token
@access_token
end
|
#agent_info ⇒ Object
Returns the value of attribute agent_info.
22
23
24
|
# File 'lib/travis/client/session.rb', line 22
def agent_info
@agent_info
end
|
#connection ⇒ Object
Returns the value of attribute connection.
22
23
24
|
# File 'lib/travis/client/session.rb', line 22
def connection
@connection
end
|
#faraday_adapter ⇒ Object
Returns the value of attribute faraday_adapter.
22
23
24
|
# File 'lib/travis/client/session.rb', line 22
def faraday_adapter
@faraday_adapter
end
|
Returns the value of attribute headers.
22
23
24
|
# File 'lib/travis/client/session.rb', line 22
def
@headers
end
|
#instruments ⇒ Object
Returns the value of attribute instruments.
22
23
24
|
# File 'lib/travis/client/session.rb', line 22
def instruments
@instruments
end
|
#ssl ⇒ Object
Returns the value of attribute ssl.
22
23
24
|
# File 'lib/travis/client/session.rb', line 22
def ssl
@ssl
end
|
Instance Method Details
#clear_cache ⇒ Object
178
179
180
181
182
|
# File 'lib/travis/client/session.rb', line 178
def clear_cache
reset_entities
clear_find_cache
self
end
|
#clear_cache! ⇒ Object
184
185
186
187
188
|
# File 'lib/travis/client/session.rb', line 184
def clear_cache!
reset_entities
@cache.clear
self
end
|
#config ⇒ Object
132
133
134
|
# File 'lib/travis/client/session.rb', line 132
def config
@config ||= get_raw('/config')['config'] || {}
end
|
#find_many(entity, args = {}) ⇒ Object
99
100
101
102
|
# File 'lib/travis/client/session.rb', line 99
def find_many(entity, args = {})
raise Travis::Client::Error, "cannot fetch #{entity}" unless entity.respond_to?(:many) and entity.many
cached(entity, :many, args) { fetch_many(entity, args) }
end
|
#find_one(entity, id = nil) ⇒ Object
93
94
95
96
97
|
# File 'lib/travis/client/session.rb', line 93
def find_one(entity, id = nil)
raise Travis::Client::Error, "cannot fetch #{entity}" unless entity.respond_to?(:many) and entity.many
return create_entity(entity, entity.id_field => id) if entity.id? id
cached(entity, :by, id) { fetch_one(entity, id) }
end
|
#find_one_or_many(entity, args = nil) ⇒ Object
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
|
# File 'lib/travis/client/session.rb', line 104
def find_one_or_many(entity, args = nil)
raise Travis::Client::Error, "cannot fetch #{entity}" unless entity.respond_to?(:many) and entity.many
cached(entity, :one_or_many, args) do
path = "/#{entity.many}"
path, args = "#{path}/#{args}", {} unless args.is_a? Hash
result = get(path, args)
one = result[entity.one]
if result.include? entity.many
Array(one) + Array(result[entity.many])
else
one
end
end
end
|
#get(*args) ⇒ Object
149
150
151
|
# File 'lib/travis/client/session.rb', line 149
def get(*args)
load get_raw(*args)
end
|
#get_raw(*args) ⇒ Object
153
154
155
|
# File 'lib/travis/client/session.rb', line 153
def get_raw(*args)
raw(:get, *args)
end
|
#inspect ⇒ Object
174
175
176
|
# File 'lib/travis/client/session.rb', line 174
def inspect
"#<#{self.class}: #{uri}>"
end
|
#instrument(&block) ⇒ Object
194
195
196
|
# File 'lib/travis/client/session.rb', line 194
def instrument(&block)
instruments << block
end
|
#load(data) ⇒ Object
136
137
138
139
140
141
142
143
144
145
146
147
|
# File 'lib/travis/client/session.rb', line 136
def load(data)
result = {}
(data || {}).each_pair do |key, value|
type = Entity.subclass_for(key)
if value.respond_to? :to_ary
result[key] = value.to_ary.map { |e| create_entity(type, e) }
else
result[key] = create_entity(type, value)
end
end
result
end
|
#post_raw(*args) ⇒ Object
157
158
159
|
# File 'lib/travis/client/session.rb', line 157
def post_raw(*args)
raw(:post, *args)
end
|
#private_channels? ⇒ Boolean
198
199
200
|
# File 'lib/travis/client/session.rb', line 198
def private_channels?
access_token and user.channels != ['common']
end
|
#put_raw(*args) ⇒ Object
161
162
163
|
# File 'lib/travis/client/session.rb', line 161
def put_raw(*args)
raw(:put, *args)
end
|
#raw(verb, url, *args) ⇒ Object
165
166
167
168
169
170
171
172
|
# File 'lib/travis/client/session.rb', line 165
def raw(verb, url, *args)
url = url.sub(/^\//, '')
result = instrumented(verb.to_s.upcase, url, *args) { connection.public_send(verb, url, *args) }
raise Travis::Client::Error, 'SSL error: could not verify peer' if result.status == 0
result.body
rescue Faraday::Error::ClientError => e
handle_error(e)
end
|
#reload(entity) ⇒ Object
125
126
127
128
129
130
|
# File 'lib/travis/client/session.rb', line 125
def reload(entity)
reset(entity)
result = fetch_one(entity.class, entity.id)
entity.update_attributes(result.attributes) if result.attributes != entity.attributes
result
end
|
#reset(entity) ⇒ Object
120
121
122
123
|
# File 'lib/travis/client/session.rb', line 120
def reset(entity)
entity.attributes.clear
entity
end
|
#session ⇒ Object
190
191
192
|
# File 'lib/travis/client/session.rb', line 190
def session
self
end
|
#uri ⇒ Object
41
42
43
|
# File 'lib/travis/client/session.rb', line 41
def uri
connection.url_prefix.to_s if connection
end
|
#uri=(uri) ⇒ Object
55
56
57
58
59
60
61
62
63
64
|
# File 'lib/travis/client/session.rb', line 55
def uri=(uri)
clear_cache!
self.connection = Faraday.new(:url => uri, :ssl => ssl) do |faraday|
faraday.request :url_encoded
faraday.response :json
faraday.response :follow_redirects
faraday.response :raise_error
faraday.adapter(*faraday_adapter)
end
end
|