Skip to content
Permalink
Browse files
Removing google dependencies from the protobuf stubs
  • Loading branch information
DImuthuUpe committed Apr 11, 2022
1 parent 079306f commit 8e3b03a95aad6db0dabbacab286fc6fee4d10608
Showing 109 changed files with 982 additions and 1,777 deletions.
@@ -3,8 +3,6 @@ syntax = "proto3";
option java_multiple_files = true;
package org.apache.airavata.mft.api.service;

import "google/api/annotations.proto";
import "google/protobuf/empty.proto";
import "CredCommon.proto";

message CallbackEndpoint {
@@ -126,47 +124,19 @@ message FetchResourceMetadataRequest {

service MFTTransferService {

rpc submitTransfer(TransferApiRequest) returns (TransferApiResponse) {
option (google.api.http) = {
post: "/v1.0/api/transfer"
};
}
rpc submitTransfer(TransferApiRequest) returns (TransferApiResponse);

rpc submitHttpUpload(HttpUploadApiRequest) returns (HttpUploadApiResponse) {
option (google.api.http) = {
post: "/v1.0/api/http-upload"
};
}
rpc submitHttpUpload(HttpUploadApiRequest) returns (HttpUploadApiResponse);

rpc submitHttpDownload(HttpDownloadApiRequest) returns (HttpDownloadApiResponse) {
option (google.api.http) = {
post: "/v1.0/api/http-download"
};
}
rpc submitHttpDownload(HttpDownloadApiRequest) returns (HttpDownloadApiResponse);

rpc getTransferStates(TransferStateApiRequest) returns (stream TransferStateApiResponse) {
option (google.api.http) = {
get: "/v1.0/api/transfer/states"
};
}
rpc getTransferStates(TransferStateApiRequest) returns (stream TransferStateApiResponse);

rpc getTransferState(TransferStateApiRequest) returns (TransferStateApiResponse) {
option (google.api.http) = {
get: "/v1.0/api/transfer/state"
};
}
rpc getTransferState(TransferStateApiRequest) returns (TransferStateApiResponse);

rpc getResourceAvailability(ResourceAvailabilityRequest) returns (ResourceAvailabilityResponse) {}
rpc getResourceAvailability(ResourceAvailabilityRequest) returns (ResourceAvailabilityResponse);

rpc getFileResourceMetadata(FetchResourceMetadataRequest) returns (FileMetadataResponse) {
option (google.api.http) = {
get: "/v1.0/api/resource/metadata/file"
};
}
rpc getFileResourceMetadata(FetchResourceMetadataRequest) returns (FileMetadataResponse);

rpc getDirectoryResourceMetadata(FetchResourceMetadataRequest) returns (DirectoryMetadataResponse) {
option (google.api.http) = {
get: "/v1.0/api/resource/metadata/directory"
};
}
rpc getDirectoryResourceMetadata(FetchResourceMetadataRequest) returns (DirectoryMetadataResponse);
}

Large diffs are not rendered by default.

Some generated files are not rendered by default. Learn more.

Some generated files are not rendered by default. Learn more.

@@ -3,7 +3,6 @@
import grpc

from airavata_mft_sdk.azure import AzureCredential_pb2 as azure_dot_AzureCredential__pb2
from airavata_mft_sdk.google.protobuf import empty_pb2 as google_dot_protobuf_dot_empty__pb2


class AzureSecretServiceStub(object):
@@ -28,12 +27,12 @@ def __init__(self, channel):
self.updateAzureSecret = channel.unary_unary(
'/org.apache.airavata.mft.credential.service.azure.AzureSecretService/updateAzureSecret',
request_serializer=azure_dot_AzureCredential__pb2.AzureSecretUpdateRequest.SerializeToString,
response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
response_deserializer=azure_dot_AzureCredential__pb2.AzureSecretUpdateResponse.FromString,
)
self.deleteAzureSecret = channel.unary_unary(
'/org.apache.airavata.mft.credential.service.azure.AzureSecretService/deleteAzureSecret',
request_serializer=azure_dot_AzureCredential__pb2.AzureSecretDeleteRequest.SerializeToString,
response_deserializer=google_dot_protobuf_dot_empty__pb2.Empty.FromString,
response_deserializer=azure_dot_AzureCredential__pb2.AzureSecretDeleteResponse.FromString,
)


@@ -80,12 +79,12 @@ def add_AzureSecretServiceServicer_to_server(servicer, server):
'updateAzureSecret': grpc.unary_unary_rpc_method_handler(
servicer.updateAzureSecret,
request_deserializer=azure_dot_AzureCredential__pb2.AzureSecretUpdateRequest.FromString,
response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
response_serializer=azure_dot_AzureCredential__pb2.AzureSecretUpdateResponse.SerializeToString,
),
'deleteAzureSecret': grpc.unary_unary_rpc_method_handler(
servicer.deleteAzureSecret,
request_deserializer=azure_dot_AzureCredential__pb2.AzureSecretDeleteRequest.FromString,
response_serializer=google_dot_protobuf_dot_empty__pb2.Empty.SerializeToString,
response_serializer=azure_dot_AzureCredential__pb2.AzureSecretDeleteResponse.SerializeToString,
),
}
generic_handler = grpc.method_handlers_generic_handler(
@@ -144,7 +143,7 @@ def updateAzureSecret(request,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/org.apache.airavata.mft.credential.service.azure.AzureSecretService/updateAzureSecret',
azure_dot_AzureCredential__pb2.AzureSecretUpdateRequest.SerializeToString,
google_dot_protobuf_dot_empty__pb2.Empty.FromString,
azure_dot_AzureCredential__pb2.AzureSecretUpdateResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

@@ -161,6 +160,6 @@ def deleteAzureSecret(request,
metadata=None):
return grpc.experimental.unary_unary(request, target, '/org.apache.airavata.mft.credential.service.azure.AzureSecretService/deleteAzureSecret',
azure_dot_AzureCredential__pb2.AzureSecretDeleteRequest.SerializeToString,
google_dot_protobuf_dot_empty__pb2.Empty.FromString,
azure_dot_AzureCredential__pb2.AzureSecretDeleteResponse.FromString,
options, channel_credentials,
insecure, call_credentials, compression, wait_for_ready, timeout, metadata)

Some generated files are not rendered by default. Learn more.

0 comments on commit 8e3b03a

Please sign in to comment.