Class: Travis::Client::Session

Inherits:
Object
  • Object
show all
Includes:
Methods
Defined in:
lib/travis/client/session.rb

Constant Summary collapse

PRIMITIVE = 
[nil, false, true]
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, #hooks, #job, #lint, #listen, #repo, #repos, #restart, #user

Constructor Details

#initialize(options = Travis::Client::ORG_URI) ⇒ Session

Returns a new instance of Session.

Raises:

  • (ArgumentError) 


26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
 
# File 'lib/travis/client/session.rb', line 26

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
  headers['Accept'] = 'application/vnd.travis-ci.2+json'
  set_user_agent
  check_ssl
end

Instance Attribute Details

#access_token ⇒ Object

Returns the value of attribute access_token.



23
24
25
 
# File 'lib/travis/client/session.rb', line 23

def access_token
  @access_token
end

#agent_info ⇒ Object

Returns the value of attribute agent_info.



23
24
25
 
# File 'lib/travis/client/session.rb', line 23

def agent_info
  @agent_info
end

#connection ⇒ Object

Returns the value of attribute connection.



23
24
25
 
# File 'lib/travis/client/session.rb', line 23

def connection
  @connection
end

#debug_http ⇒ Object

Returns the value of attribute debug_http.



24
25
26
 
# File 'lib/travis/client/session.rb', line 24

def debug_http
  @debug_http
end

#faraday_adapter ⇒ Object

Returns the value of attribute faraday_adapter.



23
24
25
 
# File 'lib/travis/client/session.rb', line 23

def faraday_adapter
  @faraday_adapter
end

#headers ⇒ Object

Returns the value of attribute headers.



23
24
25
 
# File 'lib/travis/client/session.rb', line 23

def headers
  @headers
end

#instruments ⇒ Object (readonly)

Returns the value of attribute instruments.



23
24
25
 
# File 'lib/travis/client/session.rb', line 23

def instruments
  @instruments
end

#ssl ⇒ Object

Returns the value of attribute ssl.



23
24
25
 
# File 'lib/travis/client/session.rb', line 23

def ssl
  @ssl
end

Instance Method Details

#clear_cache ⇒ Object 



234
235
236
237
238
 
# File 'lib/travis/client/session.rb', line 234

def clear_cache
  reset_entities
  clear_find_cache
  self
end

#clear_cache! ⇒ Object 



240
241
242
243
244
 
# File 'lib/travis/client/session.rb', line 240

def clear_cache!
  reset_entities
  @cache.clear
  self
end

#config ⇒ Object 



133
134
135
 
# File 'lib/travis/client/session.rb', line 133

def config
  @config ||= get_raw('/config')['config'] || {}
end

#delete(*args) ⇒ Object 



169
170
171
 
# File 'lib/travis/client/session.rb', line 169

def delete(*args)
  load delete_raw(*args)
end

#delete_raw(*args) ⇒ Object 



201
202
203
 
# File 'lib/travis/client/session.rb', line 201

def delete_raw(*args)
  raw(:delete, *args)
end

#find_many(entity, args = {}) ⇒ Object

Raises:



100
101
102
103
 
# File 'lib/travis/client/session.rb', line 100

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

Raises:



94
95
96
97
98
 
# File 'lib/travis/client/session.rb', line 94

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

Raises:



105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
 
# File 'lib/travis/client/session.rb', line 105

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 



165
166
167
 
# File 'lib/travis/client/session.rb', line 165

def get(*args)
  load get_raw(*args)
end

#get_raw(*args) ⇒ Object 



185
186
187
 
# File 'lib/travis/client/session.rb', line 185

def get_raw(*args)
  raw(:get, *args)
end

#inspect ⇒ Object 



230
231
232
 
# File 'lib/travis/client/session.rb', line 230

def inspect
  "#<#{self.class}: #{uri}>"
end

#instrument(&block) ⇒ Object 



250
251
252
 
# File 'lib/travis/client/session.rb', line 250

def instrument(&block)
  instruments << block
end

#load(data) ⇒ Object 



137
138
139
140
141
142
143
144
 
# File 'lib/travis/client/session.rb', line 137

def load(data)
  result = {}
  (data || {}).each_pair do |key, value|
    entity      = load_entity(key, value)
    result[key] = entity if entity
  end
  result
end

#load_entity(key, value) ⇒ Object 



146
147
148
149
150
151
152
153
154
 
# File 'lib/travis/client/session.rb', line 146

def load_entity(key, value)
  type = Entity.subclass_for(key)
  if value.respond_to? :to_ary
    value.to_ary.map { |e| create_entity(type, e) }
  else
    create_entity(type, value)
  end
rescue IndexError
end

#patch(*args) ⇒ Object 



173
174
175
 
# File 'lib/travis/client/session.rb', line 173

def patch(*args)
  load patch_raw(*args)
end

#patch_raw(*args) ⇒ Object 



197
198
199
 
# File 'lib/travis/client/session.rb', line 197

def patch_raw(*args)
  raw(:patch, *args)
end

#post(*args) ⇒ Object 



177
178
179
 
# File 'lib/travis/client/session.rb', line 177

def post(*args)
  load post_raw(*args)
end

#post_raw(*args) ⇒ Object 



189
190
191
 
# File 'lib/travis/client/session.rb', line 189

def post_raw(*args)
  raw(:post, *args)
end

#preload(list) ⇒ Object 



156
157
158
159
160
161
162
163
 
# File 'lib/travis/client/session.rb', line 156

def preload(list)
  list.group_by(&:class).each do |type, instances|
    next unless type.preloadable?
    ids = instances.map { |e| e.id unless e.complete? }.compact
    find_many(type, :ids => ids) if ids.any?
  end
  list
end

#private_channels? ⇒ Boolean

Returns:

  • (Boolean) 


254
255
256
 
# File 'lib/travis/client/session.rb', line 254

def private_channels?
  !!config['pusher']['private']
end

#put(*args) ⇒ Object 



181
182
183
 
# File 'lib/travis/client/session.rb', line 181

def put(*args)
  load put_raw(*args)
end

#put_raw(*args) ⇒ Object 



193
194
195
 
# File 'lib/travis/client/session.rb', line 193

def put_raw(*args)
  raw(:put, *args)
end

#raw(verb, url, *args) ⇒ Object 



205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
 
# File 'lib/travis/client/session.rb', line 205

def raw(verb, url, *args)
  url     = url.sub(/^\//, '')
  result  = instrumented(verb.to_s.upcase, url, *args) do
    if url !~ /^https?:/ or url.start_with? api_endpoint
      connection.public_send(verb, url, *args)
    else
      Faraday.public_send(verb, url, *args) { |r| r.headers.delete("Authorization") }
    end
  end

  case result.status
  when 0             then raise Travis::Client::SSLError, 'SSL error: could not verify peer'
  when 200..299      then JSON.parse(result.body) rescue result.body
  when 301, 303      then raw(:get, result.headers['Location'])
  when 302, 307, 308 then raw(verb, result.headers['Location'])
  when 401           then raise Travis::Client::NotLoggedIn,      'not logged in'
  when 403           then raise Travis::Client::NotLoggedIn,      'invalid access token'
  when 404           then raise Travis::Client::NotFound,         result.body
  when 422           then raise Travis::Client::ValidationFailed, result.body
  when 400..499      then raise Travis::Client::Error,            "%s: %p" % [result.status, result.body]
  when 500..599      then raise Travis::Client::Error,            "server error (%s: %p)" % [result.status, result.body]
  else raise Travis::Client::Error, "unhandled status code #{result.status}"
  end
end

#reload(entity) ⇒ Object 



126
127
128
129
130
131
 
# File 'lib/travis/client/session.rb', line 126

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 



121
122
123
124
 
# File 'lib/travis/client/session.rb', line 121

def reset(entity)
  entity.attributes.clear
  entity
end

#session ⇒ Object 



246
247
248
 
# File 'lib/travis/client/session.rb', line 246

def session
  self
end

#uri ⇒ Object 



44
45
46
 
# File 'lib/travis/client/session.rb', line 44

def uri
  connection.url_prefix.to_s if connection
end

#uri=(uri) ⇒ Object 



58
59
60
61
62
63
64
65
 
# File 'lib/travis/client/session.rb', line 58

def uri=(uri)
  clear_cache!
  self.connection = Faraday.new(:url => uri, :ssl => ssl) do |faraday|
    faraday.request  :url_encoded
    faraday.response :logger if debug_http
    faraday.adapter(*faraday_adapter)
  end
end