lib/google/cloud/compute/v1/vpn_gateways/rest/service_stub.rb in google-cloud-compute-v1-1.4.0 vs lib/google/cloud/compute/v1/vpn_gateways/rest/service_stub.rb in google-cloud-compute-v1-1.5.0

- old
+ new

@@ -53,44 +53,31 @@ # @return [::Google::Cloud::Compute::V1::VpnGatewayAggregatedList] # A result object deserialized from the server's reply def aggregated_list request_pb, options = nil raise ::ArgumentError, "request must be provided" if request_pb.nil? - uri, _body, query_string_params = transcode_aggregated_list_request request_pb - response = @client_stub.make_get_request( + verb, uri, query_string_params, body = transcode_aggregated_list_request request_pb + query_string_params = if query_string_params.any? + query_string_params.to_h { |p| p.split("=", 2) } + else + {} + end + + response = @client_stub.make_http_request( + verb, uri: uri, + body: body || "", params: query_string_params, options: options ) result = ::Google::Cloud::Compute::V1::VpnGatewayAggregatedList.decode_json response.body, ignore_unknown_fields: true yield result, response if block_given? result end ## - # GRPC transcoding helper method for the aggregated_list REST call - # - # @param request_pb [::Google::Cloud::Compute::V1::AggregatedListVpnGatewaysRequest] - # A request object representing the call parameters. Required. - # @return [Array(String, [String, nil], Hash{String => String})] - # Uri, Body, Query string parameters - def transcode_aggregated_list_request request_pb - uri = "/compute/v1/projects/#{request_pb.project}/aggregated/vpnGateways" - body = nil - query_string_params = {} - query_string_params["filter"] = request_pb.filter.to_s if request_pb.has_filter? - query_string_params["includeAllScopes"] = request_pb.include_all_scopes.to_s if request_pb.has_include_all_scopes? - query_string_params["maxResults"] = request_pb.max_results.to_s if request_pb.has_max_results? - query_string_params["orderBy"] = request_pb.order_by.to_s if request_pb.has_order_by? - query_string_params["pageToken"] = request_pb.page_token.to_s if request_pb.has_page_token? - query_string_params["returnPartialSuccess"] = request_pb.return_partial_success.to_s if request_pb.has_return_partial_success? - - [uri, body, query_string_params] - end - - ## # Baseline implementation for the delete REST call # # @param request_pb [::Google::Cloud::Compute::V1::DeleteVpnGatewayRequest] # A request object representing the call parameters. Required. # @param options [::Gapic::CallOptions] @@ -103,39 +90,31 @@ # @return [::Google::Cloud::Compute::V1::Operation] # A result object deserialized from the server's reply def delete request_pb, options = nil raise ::ArgumentError, "request must be provided" if request_pb.nil? - uri, _body, query_string_params = transcode_delete_request request_pb - response = @client_stub.make_delete_request( + verb, uri, query_string_params, body = transcode_delete_request request_pb + query_string_params = if query_string_params.any? + query_string_params.to_h { |p| p.split("=", 2) } + else + {} + end + + response = @client_stub.make_http_request( + verb, uri: uri, + body: body || "", params: query_string_params, options: options ) result = ::Google::Cloud::Compute::V1::Operation.decode_json response.body, ignore_unknown_fields: true yield result, response if block_given? result end ## - # GRPC transcoding helper method for the delete REST call - # - # @param request_pb [::Google::Cloud::Compute::V1::DeleteVpnGatewayRequest] - # A request object representing the call parameters. Required. - # @return [Array(String, [String, nil], Hash{String => String})] - # Uri, Body, Query string parameters - def transcode_delete_request request_pb - uri = "/compute/v1/projects/#{request_pb.project}/regions/#{request_pb.region}/vpnGateways/#{request_pb.vpn_gateway}" - body = nil - query_string_params = {} - query_string_params["requestId"] = request_pb.request_id.to_s if request_pb.has_request_id? - - [uri, body, query_string_params] - end - - ## # Baseline implementation for the get REST call # # @param request_pb [::Google::Cloud::Compute::V1::GetVpnGatewayRequest] # A request object representing the call parameters. Required. # @param options [::Gapic::CallOptions] @@ -148,37 +127,31 @@ # @return [::Google::Cloud::Compute::V1::VpnGateway] # A result object deserialized from the server's reply def get request_pb, options = nil raise ::ArgumentError, "request must be provided" if request_pb.nil? - uri, _body, _query_string_params = transcode_get_request request_pb - response = @client_stub.make_get_request( + verb, uri, query_string_params, body = transcode_get_request request_pb + query_string_params = if query_string_params.any? + query_string_params.to_h { |p| p.split("=", 2) } + else + {} + end + + response = @client_stub.make_http_request( + verb, uri: uri, + body: body || "", + params: query_string_params, options: options ) result = ::Google::Cloud::Compute::V1::VpnGateway.decode_json response.body, ignore_unknown_fields: true yield result, response if block_given? result end ## - # GRPC transcoding helper method for the get REST call - # - # @param request_pb [::Google::Cloud::Compute::V1::GetVpnGatewayRequest] - # A request object representing the call parameters. Required. - # @return [Array(String, [String, nil], Hash{String => String})] - # Uri, Body, Query string parameters - def transcode_get_request request_pb - uri = "/compute/v1/projects/#{request_pb.project}/regions/#{request_pb.region}/vpnGateways/#{request_pb.vpn_gateway}" - body = nil - query_string_params = {} - - [uri, body, query_string_params] - end - - ## # Baseline implementation for the get_status REST call # # @param request_pb [::Google::Cloud::Compute::V1::GetStatusVpnGatewayRequest] # A request object representing the call parameters. Required. # @param options [::Gapic::CallOptions] @@ -191,37 +164,31 @@ # @return [::Google::Cloud::Compute::V1::VpnGatewaysGetStatusResponse] # A result object deserialized from the server's reply def get_status request_pb, options = nil raise ::ArgumentError, "request must be provided" if request_pb.nil? - uri, _body, _query_string_params = transcode_get_status_request request_pb - response = @client_stub.make_get_request( + verb, uri, query_string_params, body = transcode_get_status_request request_pb + query_string_params = if query_string_params.any? + query_string_params.to_h { |p| p.split("=", 2) } + else + {} + end + + response = @client_stub.make_http_request( + verb, uri: uri, + body: body || "", + params: query_string_params, options: options ) result = ::Google::Cloud::Compute::V1::VpnGatewaysGetStatusResponse.decode_json response.body, ignore_unknown_fields: true yield result, response if block_given? result end ## - # GRPC transcoding helper method for the get_status REST call - # - # @param request_pb [::Google::Cloud::Compute::V1::GetStatusVpnGatewayRequest] - # A request object representing the call parameters. Required. - # @return [Array(String, [String, nil], Hash{String => String})] - # Uri, Body, Query string parameters - def transcode_get_status_request request_pb - uri = "/compute/v1/projects/#{request_pb.project}/regions/#{request_pb.region}/vpnGateways/#{request_pb.vpn_gateway}/getStatus" - body = nil - query_string_params = {} - - [uri, body, query_string_params] - end - - ## # Baseline implementation for the insert REST call # # @param request_pb [::Google::Cloud::Compute::V1::InsertVpnGatewayRequest] # A request object representing the call parameters. Required. # @param options [::Gapic::CallOptions] @@ -234,40 +201,31 @@ # @return [::Google::Cloud::Compute::V1::Operation] # A result object deserialized from the server's reply def insert request_pb, options = nil raise ::ArgumentError, "request must be provided" if request_pb.nil? - uri, body, query_string_params = transcode_insert_request request_pb - response = @client_stub.make_post_request( + verb, uri, query_string_params, body = transcode_insert_request request_pb + query_string_params = if query_string_params.any? + query_string_params.to_h { |p| p.split("=", 2) } + else + {} + end + + response = @client_stub.make_http_request( + verb, uri: uri, - body: body, + body: body || "", params: query_string_params, options: options ) result = ::Google::Cloud::Compute::V1::Operation.decode_json response.body, ignore_unknown_fields: true yield result, response if block_given? result end ## - # GRPC transcoding helper method for the insert REST call - # - # @param request_pb [::Google::Cloud::Compute::V1::InsertVpnGatewayRequest] - # A request object representing the call parameters. Required. - # @return [Array(String, [String, nil], Hash{String => String})] - # Uri, Body, Query string parameters - def transcode_insert_request request_pb - uri = "/compute/v1/projects/#{request_pb.project}/regions/#{request_pb.region}/vpnGateways" - body = request_pb.vpn_gateway_resource.to_json - query_string_params = {} - query_string_params["requestId"] = request_pb.request_id.to_s if request_pb.has_request_id? - - [uri, body, query_string_params] - end - - ## # Baseline implementation for the list REST call # # @param request_pb [::Google::Cloud::Compute::V1::ListVpnGatewaysRequest] # A request object representing the call parameters. Required. # @param options [::Gapic::CallOptions] @@ -280,43 +238,31 @@ # @return [::Google::Cloud::Compute::V1::VpnGatewayList] # A result object deserialized from the server's reply def list request_pb, options = nil raise ::ArgumentError, "request must be provided" if request_pb.nil? - uri, _body, query_string_params = transcode_list_request request_pb - response = @client_stub.make_get_request( + verb, uri, query_string_params, body = transcode_list_request request_pb + query_string_params = if query_string_params.any? + query_string_params.to_h { |p| p.split("=", 2) } + else + {} + end + + response = @client_stub.make_http_request( + verb, uri: uri, + body: body || "", params: query_string_params, options: options ) result = ::Google::Cloud::Compute::V1::VpnGatewayList.decode_json response.body, ignore_unknown_fields: true yield result, response if block_given? result end ## - # GRPC transcoding helper method for the list REST call - # - # @param request_pb [::Google::Cloud::Compute::V1::ListVpnGatewaysRequest] - # A request object representing the call parameters. Required. - # @return [Array(String, [String, nil], Hash{String => String})] - # Uri, Body, Query string parameters - def transcode_list_request request_pb - uri = "/compute/v1/projects/#{request_pb.project}/regions/#{request_pb.region}/vpnGateways" - body = nil - query_string_params = {} - query_string_params["filter"] = request_pb.filter.to_s if request_pb.has_filter? - query_string_params["maxResults"] = request_pb.max_results.to_s if request_pb.has_max_results? - query_string_params["orderBy"] = request_pb.order_by.to_s if request_pb.has_order_by? - query_string_params["pageToken"] = request_pb.page_token.to_s if request_pb.has_page_token? - query_string_params["returnPartialSuccess"] = request_pb.return_partial_success.to_s if request_pb.has_return_partial_success? - - [uri, body, query_string_params] - end - - ## # Baseline implementation for the set_labels REST call # # @param request_pb [::Google::Cloud::Compute::V1::SetLabelsVpnGatewayRequest] # A request object representing the call parameters. Required. # @param options [::Gapic::CallOptions] @@ -329,40 +275,31 @@ # @return [::Google::Cloud::Compute::V1::Operation] # A result object deserialized from the server's reply def set_labels request_pb, options = nil raise ::ArgumentError, "request must be provided" if request_pb.nil? - uri, body, query_string_params = transcode_set_labels_request request_pb - response = @client_stub.make_post_request( + verb, uri, query_string_params, body = transcode_set_labels_request request_pb + query_string_params = if query_string_params.any? + query_string_params.to_h { |p| p.split("=", 2) } + else + {} + end + + response = @client_stub.make_http_request( + verb, uri: uri, - body: body, + body: body || "", params: query_string_params, options: options ) result = ::Google::Cloud::Compute::V1::Operation.decode_json response.body, ignore_unknown_fields: true yield result, response if block_given? result end ## - # GRPC transcoding helper method for the set_labels REST call - # - # @param request_pb [::Google::Cloud::Compute::V1::SetLabelsVpnGatewayRequest] - # A request object representing the call parameters. Required. - # @return [Array(String, [String, nil], Hash{String => String})] - # Uri, Body, Query string parameters - def transcode_set_labels_request request_pb - uri = "/compute/v1/projects/#{request_pb.project}/regions/#{request_pb.region}/vpnGateways/#{request_pb.resource}/setLabels" - body = request_pb.region_set_labels_request_resource.to_json - query_string_params = {} - query_string_params["requestId"] = request_pb.request_id.to_s if request_pb.has_request_id? - - [uri, body, query_string_params] - end - - ## # Baseline implementation for the test_iam_permissions REST call # # @param request_pb [::Google::Cloud::Compute::V1::TestIamPermissionsVpnGatewayRequest] # A request object representing the call parameters. Required. # @param options [::Gapic::CallOptions] @@ -375,34 +312,213 @@ # @return [::Google::Cloud::Compute::V1::TestPermissionsResponse] # A result object deserialized from the server's reply def test_iam_permissions request_pb, options = nil raise ::ArgumentError, "request must be provided" if request_pb.nil? - uri, body, _query_string_params = transcode_test_iam_permissions_request request_pb - response = @client_stub.make_post_request( + verb, uri, query_string_params, body = transcode_test_iam_permissions_request request_pb + query_string_params = if query_string_params.any? + query_string_params.to_h { |p| p.split("=", 2) } + else + {} + end + + response = @client_stub.make_http_request( + verb, uri: uri, - body: body, + body: body || "", + params: query_string_params, options: options ) result = ::Google::Cloud::Compute::V1::TestPermissionsResponse.decode_json response.body, ignore_unknown_fields: true yield result, response if block_given? result end + + private + ## + # @private + # + # GRPC transcoding helper method for the aggregated_list REST call + # + # @param request_pb [::Google::Cloud::Compute::V1::AggregatedListVpnGatewaysRequest] + # A request object representing the call parameters. Required. + # @return [Array(String, [String, nil], Hash{String => String})] + # Uri, Body, Query string parameters + def transcode_aggregated_list_request request_pb + transcoder = Gapic::Rest::GrpcTranscoder.new + .with_bindings( + uri_method: :get, + uri_template: "/compute/v1/projects/{project}/aggregated/vpnGateways", + matches: [ + ["project", %r{[^/]+}, false] + ] + ) + transcoder.transcode request_pb + end + + ## + # @private + # + # GRPC transcoding helper method for the delete REST call + # + # @param request_pb [::Google::Cloud::Compute::V1::DeleteVpnGatewayRequest] + # A request object representing the call parameters. Required. + # @return [Array(String, [String, nil], Hash{String => String})] + # Uri, Body, Query string parameters + def transcode_delete_request request_pb + transcoder = Gapic::Rest::GrpcTranscoder.new + .with_bindings( + uri_method: :delete, + uri_template: "/compute/v1/projects/{project}/regions/{region}/vpnGateways/{vpn_gateway}", + matches: [ + ["project", %r{[^/]+}, false], + ["region", %r{[^/]+}, false], + ["vpn_gateway", %r{[^/]+}, false] + ] + ) + transcoder.transcode request_pb + end + + ## + # @private + # + # GRPC transcoding helper method for the get REST call + # + # @param request_pb [::Google::Cloud::Compute::V1::GetVpnGatewayRequest] + # A request object representing the call parameters. Required. + # @return [Array(String, [String, nil], Hash{String => String})] + # Uri, Body, Query string parameters + def transcode_get_request request_pb + transcoder = Gapic::Rest::GrpcTranscoder.new + .with_bindings( + uri_method: :get, + uri_template: "/compute/v1/projects/{project}/regions/{region}/vpnGateways/{vpn_gateway}", + matches: [ + ["project", %r{[^/]+}, false], + ["region", %r{[^/]+}, false], + ["vpn_gateway", %r{[^/]+}, false] + ] + ) + transcoder.transcode request_pb + end + + ## + # @private + # + # GRPC transcoding helper method for the get_status REST call + # + # @param request_pb [::Google::Cloud::Compute::V1::GetStatusVpnGatewayRequest] + # A request object representing the call parameters. Required. + # @return [Array(String, [String, nil], Hash{String => String})] + # Uri, Body, Query string parameters + def transcode_get_status_request request_pb + transcoder = Gapic::Rest::GrpcTranscoder.new + .with_bindings( + uri_method: :get, + uri_template: "/compute/v1/projects/{project}/regions/{region}/vpnGateways/{vpn_gateway}/getStatus", + matches: [ + ["project", %r{[^/]+}, false], + ["region", %r{[^/]+}, false], + ["vpn_gateway", %r{[^/]+}, false] + ] + ) + transcoder.transcode request_pb + end + + ## + # @private + # + # GRPC transcoding helper method for the insert REST call + # + # @param request_pb [::Google::Cloud::Compute::V1::InsertVpnGatewayRequest] + # A request object representing the call parameters. Required. + # @return [Array(String, [String, nil], Hash{String => String})] + # Uri, Body, Query string parameters + def transcode_insert_request request_pb + transcoder = Gapic::Rest::GrpcTranscoder.new + .with_bindings( + uri_method: :post, + uri_template: "/compute/v1/projects/{project}/regions/{region}/vpnGateways", + body: "vpn_gateway_resource", + matches: [ + ["project", %r{[^/]+}, false], + ["region", %r{[^/]+}, false] + ] + ) + transcoder.transcode request_pb + end + + ## + # @private + # + # GRPC transcoding helper method for the list REST call + # + # @param request_pb [::Google::Cloud::Compute::V1::ListVpnGatewaysRequest] + # A request object representing the call parameters. Required. + # @return [Array(String, [String, nil], Hash{String => String})] + # Uri, Body, Query string parameters + def transcode_list_request request_pb + transcoder = Gapic::Rest::GrpcTranscoder.new + .with_bindings( + uri_method: :get, + uri_template: "/compute/v1/projects/{project}/regions/{region}/vpnGateways", + matches: [ + ["project", %r{[^/]+}, false], + ["region", %r{[^/]+}, false] + ] + ) + transcoder.transcode request_pb + end + + ## + # @private + # + # GRPC transcoding helper method for the set_labels REST call + # + # @param request_pb [::Google::Cloud::Compute::V1::SetLabelsVpnGatewayRequest] + # A request object representing the call parameters. Required. + # @return [Array(String, [String, nil], Hash{String => String})] + # Uri, Body, Query string parameters + def transcode_set_labels_request request_pb + transcoder = Gapic::Rest::GrpcTranscoder.new + .with_bindings( + uri_method: :post, + uri_template: "/compute/v1/projects/{project}/regions/{region}/vpnGateways/{resource}/setLabels", + body: "region_set_labels_request_resource", + matches: [ + ["project", %r{[^/]+}, false], + ["region", %r{[^/]+}, false], + ["resource", %r{[^/]+}, false] + ] + ) + transcoder.transcode request_pb + end + + ## + # @private + # # GRPC transcoding helper method for the test_iam_permissions REST call # # @param request_pb [::Google::Cloud::Compute::V1::TestIamPermissionsVpnGatewayRequest] # A request object representing the call parameters. Required. # @return [Array(String, [String, nil], Hash{String => String})] # Uri, Body, Query string parameters def transcode_test_iam_permissions_request request_pb - uri = "/compute/v1/projects/#{request_pb.project}/regions/#{request_pb.region}/vpnGateways/#{request_pb.resource}/testIamPermissions" - body = request_pb.test_permissions_request_resource.to_json - query_string_params = {} - - [uri, body, query_string_params] + transcoder = Gapic::Rest::GrpcTranscoder.new + .with_bindings( + uri_method: :post, + uri_template: "/compute/v1/projects/{project}/regions/{region}/vpnGateways/{resource}/testIamPermissions", + body: "test_permissions_request_resource", + matches: [ + ["project", %r{[^/]+}, false], + ["region", %r{[^/]+}, false], + ["resource", %r{[^/]+}, false] + ] + ) + transcoder.transcode request_pb end end end end end