1- #frozen_string_literal: true
1+ # frozen_string_literal: true
22
33require 'net/http'
44require 'uri'
@@ -7,15 +7,14 @@ require 'cgi'
77
88module {{ spec .info .title | caseUcfirst }}
99 class Client
10-
1110 def initialize
12- @chunk_size = 5* 1024* 1024
11+ @chunk_size = 5 * 1024 * 1024
1312 @headers = {
1413 'user-agent' => RUBY_PLATFORM + ':{{ language .name | caseLower }}-' + RUBY_VERSION,
15- 'x-sdk-name'=> '{{ sdk .name }}',
16- 'x-sdk-platform'=> '{{ sdk .platform }}',
17- 'x-sdk-language'=> '{{ language .name | caseLower }}',
18- 'x-sdk-version'=> '{{ sdk .version }}'{% if defaultHeaders | length > 0 %},{% endif %}
14+ 'x-sdk-name' => '{{ sdk .name }}',
15+ 'x-sdk-platform' => '{{ sdk .platform }}',
16+ 'x-sdk-language' => '{{ language .name | caseLower }}',
17+ 'x-sdk-version' => '{{ sdk .version }}'{% if defaultHeaders | length > 0 %},{% endif %}
1918
2019{% for key ,header in defaultHeaders %}
2120 '{{key }}' => '{{header }}'{% if not loop .last %},{% endif %}
@@ -225,13 +224,14 @@ module {{ spec.info.title | caseUcfirst }}
225224 chunks_uploaded.to_i >= chunks_total.to_i
226225 end
227226
228- on_progress.call( {
227+ progress = {
229228 id: result['$id'],
230- progress: uploaded_size.to_f/ size.to_f * 100.0,
229+ progress: uploaded_size.to_f / size.to_f * 100.0,
231230 size_uploaded: uploaded_size,
232231 chunks_total: result['chunksTotal'] || total_chunks,
233232 chunks_uploaded: result['chunksUploaded'] || completed_count
234- }) unless on_progress.nil?
233+ }
234+ on_progress.call(progress) unless on_progress.nil?
235235
236236 mutex = Mutex.new
237237 queue = Queue.new
@@ -263,13 +263,14 @@ module {{ spec.info.title | caseUcfirst }}
263263 uploaded_size += chunk[:ending] - chunk[:start]
264264 last_result = chunk_result
265265 completed_result = chunk_result if upload_complete.call(chunk_result)
266- on_progress.call( {
266+ progress = {
267267 id: upload_id,
268- progress: uploaded_size.to_f/ size.to_f * 100.0,
268+ progress: uploaded_size.to_f / size.to_f * 100.0,
269269 size_uploaded: uploaded_size,
270270 chunks_total: chunk_result['chunksTotal'] || total_chunks,
271271 chunks_uploaded: chunk_result['chunksUploaded'] || completed_count
272- }) unless on_progress.nil?
272+ }
273+ on_progress.call(progress) unless on_progress.nil?
273274 end
274275 end
275276 end
@@ -308,13 +309,13 @@ module {{ spec.info.title | caseUcfirst }}
308309 @boundary = "----A30#3ad1"
309310 if method != "GET"
310311 case headers[:'content-type']
311- when 'application/json'
312- payload = params.to_json
313- when 'multipart/form-data'
314- payload = encode_form_data(params) + "--#{@boundary}--\r\n"
315- headers[:'content-type'] = "multipart/form-data; boundary=#{@boundary}"
316- else
317- payload = encode(params)
312+ when 'application/json'
313+ payload = params.to_json
314+ when 'multipart/form-data'
315+ payload = encode_form_data(params) + "--#{@boundary}--\r\n"
316+ headers[:'content-type'] = "multipart/form-data; boundary=#{@boundary}"
317+ else
318+ payload = encode(params)
318319 end
319320 end
320321
@@ -371,10 +372,10 @@ module {{ spec.info.title | caseUcfirst }}
371372 return response
372373 end
373374
374- def encode_form_data(value, key= nil)
375+ def encode_form_data(value, key = nil)
375376 case value
376377 when Hash
377- value.map { |k,v| encode_form_data(v,k) }.join
378+ value.map { |k, v| encode_form_data(v, k) }.join
378379 when Array
379380 value.map { |v| encode_form_data(v, "#{key}[]") }.join
380381 when nil
@@ -399,11 +400,11 @@ module {{ spec.info.title | caseUcfirst }}
399400
400401 def encode(value, key = nil)
401402 case value
402- when Hash then value.map { |k,v| encode(v, append_key(key,k)) }.join('& ')
403+ when Hash then value.map { |k, v| encode(v, append_key(key, k)) }.join('& ')
403404 when Array then value.map { |v| encode(v, "#{key}[]") }.join('& ')
404405 when nil then ''
405406 else
406- "#{key}=#{CGI.escape(value.to_s)}"
407+ "#{key}=#{CGI.escape(value.to_s)}"
407408 end
408409 end
409410
0 commit comments