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
|
module HTTPService extend self
Timeout = Faraday::TimeoutError
def get_resource(host:, path:, token: nil, params: {}, parse_json: false)
Faraday.new(url: host) do |c|
c.headers['Authorization'] = "Token token=#{token.inspect}" if token
c.adapter Faraday.default_adapter
resp = c.get path, params
if resp.status == 200
return parse_json ? JSON.parse(resp.body) : resp.body
else
raise "Error on api request status : #{resp.status} => #{resp.body}"
end
end
end
# host: 'http://localhost:3000',
# path: '/api/v1/netex_imports.json',
# resource_name: 'netex_import',
# token: '13-74009c36638f587c9eafb1ce46e95585',
# params: {referential_id: 13, workbench_id: 1},
# upload: {file: [StringIO.new('howdy'), 'application/zip', 'greeting']})
def post_resource(host:, path:, resource_name:, token: nil, params: {}, upload: nil)
Faraday.new(url: host) do |c|
c.headers['Authorization'] = "Token token=#{token.inspect}" if token
c.request :multipart
c.request :url_encoded
c.adapter Faraday.default_adapter
if upload
name = upload.keys.first
value, mime_type, as_name = upload.values.first
params.update( name => Faraday::UploadIO.new(value, mime_type, as_name ) )
end
c.post path, resource_name => params
end
end
end
|
