mirror of
https://github.com/Homebrew/brew.git
synced 2025-07-14 16:09:03 +08:00
98 lines
3.5 KiB
Ruby
98 lines
3.5 KiB
Ruby
# typed: false
|
|
# frozen_string_literal: true
|
|
|
|
require "api/analytics"
|
|
require "api/cask"
|
|
require "api/formula"
|
|
require "extend/cachable"
|
|
|
|
module Homebrew
|
|
# Helper functions for using Homebrew's formulae.brew.sh API.
|
|
#
|
|
# @api private
|
|
module API
|
|
extend T::Sig
|
|
|
|
extend Cachable
|
|
|
|
module_function
|
|
|
|
HOMEBREW_CACHE_API = (HOMEBREW_CACHE/"api").freeze
|
|
|
|
# Timeout values to check for dead connections
|
|
# We don't use --max-time to support slow connections
|
|
JSON_API_SPEED_MARGIN = 100 # bytes/sec
|
|
JSON_API_SPEED_TIME = 10 # seconds of downloading under the margin
|
|
|
|
sig { params(endpoint: String).returns(Hash) }
|
|
def fetch(endpoint)
|
|
return cache[endpoint] if cache.present? && cache.key?(endpoint)
|
|
|
|
api_url = "#{Homebrew::EnvConfig.api_domain}/#{endpoint}"
|
|
output = Utils::Curl.curl_output("--fail", api_url)
|
|
if !output.success? && Homebrew::EnvConfig.api_domain != HOMEBREW_API_DEFAULT_DOMAIN
|
|
# Fall back to the default API domain and try again
|
|
api_url = "#{HOMEBREW_API_DEFAULT_DOMAIN}/#{endpoint}"
|
|
output = Utils::Curl.curl_output("--fail", api_url)
|
|
end
|
|
raise ArgumentError, "No file found at #{Tty.underline}#{api_url}#{Tty.reset}" unless output.success?
|
|
|
|
cache[endpoint] = JSON.parse(output.stdout)
|
|
rescue JSON::ParserError
|
|
raise ArgumentError, "Invalid JSON file: #{Tty.underline}#{api_url}#{Tty.reset}"
|
|
end
|
|
|
|
sig { params(endpoint: String, target: Pathname).returns(Hash) }
|
|
def fetch_json_api_file(endpoint, target:)
|
|
retry_count = 0
|
|
url = "#{Homebrew::EnvConfig.api_domain}/#{endpoint}"
|
|
default_url = "#{HOMEBREW_API_DEFAULT_DOMAIN}/#{endpoint}"
|
|
curl_args = %W[--compressed --speed-limit #{JSON_API_SPEED_MARGIN} --speed-time #{JSON_API_SPEED_TIME}]
|
|
curl_args.prepend("--silent") unless Context.current.debug?
|
|
curl_args.prepend("--time-cond", target) if target.exist? && !target.empty?
|
|
|
|
begin
|
|
begin
|
|
# Disable retries here, we handle them ourselves below.
|
|
Utils::Curl.curl_download(*curl_args, url, to: target, retries: 0, show_error: false)
|
|
rescue ErrorDuringExecution
|
|
if url == default_url
|
|
raise unless target.exist?
|
|
raise if target.empty?
|
|
elsif retry_count.zero? || !target.exist? || target.empty?
|
|
# Fall back to the default API domain and try again
|
|
# This block will be executed only once, because we set `url` to `default_url`
|
|
url = default_url
|
|
target.unlink if target.exist? && target.empty?
|
|
|
|
retry
|
|
end
|
|
|
|
opoo "#{target.basename}: update failed, falling back to cached version."
|
|
end
|
|
|
|
JSON.parse(target.read)
|
|
rescue JSON::ParserError
|
|
target.unlink
|
|
retry_count += 1
|
|
odie "Cannot download non-corrupt #{url}!" if retry_count > Homebrew::EnvConfig.curl_retries.to_i
|
|
|
|
retry
|
|
end
|
|
end
|
|
|
|
sig { params(filepath: String, repo: String, git_head: T.nilable(String)).returns(String) }
|
|
def fetch_file_source(filepath, repo:, git_head: nil)
|
|
git_head ||= "master"
|
|
endpoint = "#{git_head}/#{filepath}"
|
|
return cache[endpoint] if cache.present? && cache.key?(endpoint)
|
|
|
|
raw_url = "https://raw.githubusercontent.com/#{repo}/#{endpoint}"
|
|
output = Utils::Curl.curl_output("--fail", raw_url)
|
|
raise ArgumentError, "No file found at #{Tty.underline}#{raw_url}#{Tty.reset}" unless output.success?
|
|
|
|
cache[endpoint] = output.stdout
|
|
end
|
|
end
|
|
end
|