# Copyright 2021 Google LLC # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. # You may obtain a copy of the License at # # https://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. require "googleauth" require "gapic/logging_concerns" require "gapic/rest/faraday_middleware" require "gapic/universe_domain_concerns" require "faraday/retry" module Gapic module Rest ## # A class for making REST calls through Faraday # ClientStub's responsibilities: # - wrap Faraday methods with a bounded explicit interface # - store service endpoint and create full url for the request # - store credentials and add auth information to the request # class ClientStub include UniverseDomainConcerns include LoggingConcerns ## # Initializes with an endpoint and credentials # # @param endpoint [String] The endpoint of the API. Overrides any endpoint_template. # @param endpoint_template [String] The endpoint of the API, where the # universe domain component of the hostname is marked by the string in # the constant {UniverseDomainConcerns::ENDPOINT_SUBSTITUTION}. # @param universe_domain [String] The universe domain in which calls # should be made. Defaults to `googleapis.com`. # @param credentials [Google::Auth::Credentials] # Credentials to send with calls in form of a googleauth credentials object. # (see the [googleauth docs](https://googleapis.dev/ruby/googleauth/latest/index.html)) # @param numeric_enums [Boolean] Whether to signal the server to JSON-encode enums as ints # @param raise_faraday_errors [Boolean] # Whether to raise Faraday errors instead of wrapping them in `Gapic::Rest::Error` # Added for backwards compatibility. # Default is `true`. All REST clients (except for old versions of `google-cloud-compute-v1`) # should explicitly set this parameter to `false`. # @param logger [Logger,:default,nil] An explicit logger to use, or one # of the values `:default` (the default) to construct a default logger, # or `nil` to disable logging explicitly. # # @yield [Faraday::Connection] # def initialize credentials:, endpoint: nil, endpoint_template: nil, universe_domain: nil, numeric_enums: false, raise_faraday_errors: true, logging_system: nil, service_name: nil, logger: :default setup_universe_domain universe_domain: universe_domain, endpoint: endpoint, endpoint_template: endpoint_template, credentials: credentials endpoint_url = self.endpoint endpoint_url = "https://#{endpoint_url}" unless /^https?:/.match? endpoint_url endpoint_url = endpoint_url.sub %r{/$}, "" setup_logging logger: logger, system_name: logging_system, service: service_name, endpoint: endpoint_url, client_id: object_id @numeric_enums = numeric_enums @raise_faraday_errors = raise_faraday_errors @connection = Faraday.new url: endpoint_url do |conn| conn.headers = { "Content-Type" => "application/json" } conn.request :google_authorization, self.credentials unless self.credentials.is_a? ::Symbol conn.request :retry conn.response :raise_error conn.adapter :net_http end yield @connection if block_given? end ## # Makes a GET request # # @param uri [String] uri to send this request to # @param params [Hash] query string parameters for the request # @param options [::Gapic::CallOptions,Hash] gapic options to be applied # to the REST call. Currently only timeout and headers are supported. # @return [Faraday::Response] def make_get_request uri:, params: {}, options: {}, method_name: nil make_http_request :get, uri: uri, body: nil, params: params, options: options, method_name: method_name end ## # Makes a DELETE request # # @param uri [String] uri to send this request to # @param params [Hash] query string parameters for the request # @param options [::Gapic::CallOptions,Hash] gapic options to be applied # to the REST call. Currently only timeout and headers are supported. # @return [Faraday::Response] def make_delete_request uri:, params: {}, options: {}, method_name: nil make_http_request :delete, uri: uri, body: nil, params: params, options: options, method_name: method_name end ## # Makes a PATCH request # # @param uri [String] uri to send this request to # @param body [String] a body to send with the request, nil for requests without a body # @param params [Hash] query string parameters for the request # @param options [::Gapic::CallOptions,Hash] gapic options to be applied # to the REST call. Currently only timeout and headers are supported. # @return [Faraday::Response] def make_patch_request uri:, body:, params: {}, options: {}, method_name: nil make_http_request :patch, uri: uri, body: body, params: params, options: options, method_name: method_name end ## # Makes a POST request # # @param uri [String] uri to send this request to # @param body [String] a body to send with the request, nil for requests without a body # @param params [Hash] query string parameters for the request # @param options [::Gapic::CallOptions,Hash] gapic options to be applied # to the REST call. Currently only timeout and headers are supported. # @return [Faraday::Response] def make_post_request uri:, body: nil, params: {}, options: {}, method_name: nil make_http_request :post, uri: uri, body: body, params: params, options: options, method_name: method_name end ## # Makes a PUT request # # @param uri [String] uri to send this request to # @param body [String] a body to send with the request, nil for requests without a body # @param params [Hash] query string parameters for the request # @param options [::Gapic::CallOptions,Hash] gapic options to be applied # to the REST call. Currently only timeout and headers are supported. # @return [Faraday::Response] def make_put_request uri:, body: nil, params: {}, options: {}, method_name: nil make_http_request :put, uri: uri, body: body, params: params, options: options, method_name: method_name end ## # @private # Sends a http request via Faraday # @param verb [Symbol] http verb # @param uri [String] uri to send this request to # @param body [String, nil] a body to send with the request, nil for requests without a body # @param params [Hash] query string parameters for the request # @param options [::Gapic::CallOptions,Hash] gapic options to be applied to the REST call. # @param is_server_streaming [Boolean] flag if method is streaming # @yieldparam chunk [String] The chunk of data received during server streaming. # @return [Faraday::Response] def make_http_request verb, uri:, body:, params:, options:, is_server_streaming: false, method_name: nil, &block # Converts hash and nil to an options object options = ::Gapic::CallOptions.new(**options.to_h) unless options.is_a? ::Gapic::CallOptions deadline = calculate_deadline options retried_exception = nil next_timeout = get_timeout deadline request_id = LoggingConcerns.random_uuid4 try_number = 1 begin log_request method_name, request_id, try_number, body, options.metadata response = base_make_http_request verb: verb, uri: uri, body: body, params: params, metadata: options.metadata, timeout: next_timeout, is_server_streaming: is_server_streaming, &block log_response method_name, request_id, try_number, response, is_server_streaming response rescue ::Faraday::TimeoutError => e log_response method_name, request_id, try_number, e, is_server_streaming raise if @raise_faraday_errors raise Gapic::Rest::DeadlineExceededError.wrap_faraday_error e, root_cause: retried_exception rescue ::Faraday::Error => e log_response method_name, request_id, try_number, e, is_server_streaming next_timeout = get_timeout deadline if check_retry?(next_timeout) && options.retry_policy.call(e) retried_exception = e try_number += 1 retry end raise if @raise_faraday_errors raise ::Gapic::Rest::Error.wrap_faraday_error e end end ## # @private # Sends a http request via Faraday # # @param verb [Symbol] http verb # @param uri [String] uri to send this request to # @param body [String, nil] a body to send with the request, nil for requests without a body # @param params [Hash] query string parameters for the request # @param metadata [Hash] additional headers for the request # @param is_server_streaming [Boolean] flag if method is streaming # @yieldparam chunk [String] The chunk of data received during server streaming. # @return [Faraday::Response] def base_make_http_request verb:, uri:, body:, params:, metadata:, timeout:, is_server_streaming: false if @numeric_enums && (!params.key?("$alt") || params["$alt"] == "json") params = params.merge({ "$alt" => "json;enum-encoding=int" }) end @connection.send verb, uri do |req| req.params = params if params.any? req.body = body unless body.nil? req.headers = req.headers.merge metadata req.options.timeout = timeout if timeout&.positive? if is_server_streaming req.options.on_data = proc do |chunk, _overall_received_bytes| yield chunk end end end end private ## # Calculates deadline # # @param options [Gapic::CallOptions] call options for this call # # @return [Numeric, nil] Deadline against a POSIX clock_gettime() def calculate_deadline options return if options.timeout.nil? return if options.timeout.negative? Process.clock_gettime(Process::CLOCK_MONOTONIC) + options.timeout end ## # Calculates timeout (seconds) to use as a Faraday timeout # # @param deadline [Numeric, nil] deadline # # @return [Numeric, nil] Timeout (seconds) def get_timeout deadline return if deadline.nil? deadline - Process.clock_gettime(Process::CLOCK_MONOTONIC) end ## # Whether the timeout should be retried # # @param timeout [Numeric, nil] # # @return [Boolean] whether the timeout should be retried def check_retry? timeout return true if timeout.nil? timeout.positive? end def log_request method_name, request_id, try_number, body, metadata return unless stub_logger stub_logger.info do |entry| entry.set_system_name entry.set_service entry.set "rpcName", method_name entry.set "retryAttempt", try_number entry.set "requestId", request_id entry.message = "Sending request to #{entry.service}.#{method_name} (try #{try_number})" end body = body.to_s metadata = metadata.to_h rescue {} return if body.empty? && metadata.empty? stub_logger.debug do |entry| entry.set "requestId", request_id entry.set "request", body entry.set "headers", metadata entry.message = "(request payload as JSON)" end end def log_response method_name, request_id, try_number, response, is_server_streaming return unless stub_logger stub_logger.info do |entry| entry.set_system_name entry.set_service entry.set "rpcName", method_name entry.set "retryAttempt", try_number entry.set "requestId", request_id if response.is_a? StandardError entry.set "exception", response.to_s entry.message = "Received error for #{entry.service}.#{method_name} (try #{try_number}): #{response}" elsif is_server_streaming entry.message = "Receiving stream for #{entry.service}.#{method_name} (try #{try_number})" else entry.message = "Received response for #{entry.service}.#{method_name} (try #{try_number})" end end return if is_server_streaming || !response.respond_to?(:body) body = response.body.to_s return if body.empty? stub_logger.debug do |entry| entry.set "requestId", request_id entry.set "response", body entry.message = "(response payload as JSON)" end end end end end