module Spaceship::ConnectAPI::FileUploader
Public Class Methods
client()
click to toggle source
# File spaceship/lib/spaceship/connect_api/file_uploader.rb, line 69 def self.client options = { request: { timeout: (ENV["SPACESHIP_TIMEOUT"] || 300).to_i, open_timeout: (ENV["SPACESHIP_TIMEOUT"] || 300).to_i } } @client ||= Faraday.new(options) do |c| c.response(:json, content_type: /\bjson$/) c.response(:plist, content_type: /\bplist$/) c.adapter(Faraday.default_adapter) if ENV['SPACESHIP_DEBUG'] # for debugging only # This enables tracking of networking requests using Charles Web Proxy c.proxy = "https://127.0.0.1:8888" c.ssl[:verify_mode] = OpenSSL::SSL::VERIFY_NONE elsif ENV["SPACESHIP_PROXY"] c.proxy = ENV["SPACESHIP_PROXY"] c.ssl[:verify_mode] = OpenSSL::SSL::VERIFY_NONE if ENV["SPACESHIP_PROXY_SSL_VERIFY_NONE"] end if ENV["DEBUG"] puts("To run spaceship through a local proxy, use SPACESHIP_DEBUG") end end end
upload(upload_operations, bytes)
click to toggle source
# File spaceship/lib/spaceship/connect_api/file_uploader.rb, line 12 def self.upload(upload_operations, bytes) # { # "method": "PUT", # "url": "https://some-url-apple-gives-us", # "length": 57365, # "offset": 0, # "requestHeaders": [ # { # "name": "Content-Type", # "value": "image/png" # } # ] # } upload_operations.each_with_index do |upload_operation, index| headers = {} upload_operation["requestHeaders"].each do |hash| headers[hash["name"]] = hash["value"] end offset = upload_operation["offset"] length = upload_operation["length"] puts("Uploading file (part #{index + 1})...") if Spaceship::Globals.verbose? with_retry do client.send( upload_operation["method"].downcase, upload_operation["url"], bytes[offset, length], headers ) end end puts("Uploading complete!") if Spaceship::Globals.verbose? end
with_retry(tries = 5) { || ... }
click to toggle source
# File spaceship/lib/spaceship/connect_api/file_uploader.rb, line 48 def self.with_retry(tries = 5, &_block) tries = 1 if Object.const_defined?("SpecHelper") response = yield tries -= 1 unless (200...300).cover?(response.status) msg = "Received status of #{response.status}! Retrying after 3 seconds (remaining: #{tries})..." raise msg end return response rescue => error puts(error) if Spaceship::Globals.verbose? if tries.zero? raise "Failed to upload file after retries... Received #{response.status}" else retry end end