You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by di...@apache.org on 2021/07/30 01:22:11 UTC
[airavata-mft] branch develop updated: Adding a target agent to
request if not specified
This is an automated email from the ASF dual-hosted git repository.
dimuthuupe pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/airavata-mft.git
The following commit(s) were added to refs/heads/develop by this push:
new c7ecb36 Adding a target agent to request if not specified
c7ecb36 is described below
commit c7ecb36bed0f1072caaadcc92a0753d8f9da5345
Author: Dimuthu Wannipurage <di...@gmail.com>
AuthorDate: Thu Jul 29 21:21:57 2021 -0400
Adding a target agent to request if not specified
---
.../org/apache/airavata/mft/api/handler/MFTApiHandler.java | 10 ++++++++--
1 file changed, 8 insertions(+), 2 deletions(-)
diff --git a/api/service/src/main/java/org/apache/airavata/mft/api/handler/MFTApiHandler.java b/api/service/src/main/java/org/apache/airavata/mft/api/handler/MFTApiHandler.java
index 29f144b..77a1efe 100644
--- a/api/service/src/main/java/org/apache/airavata/mft/api/handler/MFTApiHandler.java
+++ b/api/service/src/main/java/org/apache/airavata/mft/api/handler/MFTApiHandler.java
@@ -201,8 +201,11 @@ public class MFTApiHandler extends MFTApiServiceGrpc.MFTApiServiceImplBase {
public void getFileResourceMetadata(FetchResourceMetadataRequest request, StreamObserver<FileMetadataResponse> responseObserver) {
try {
+
+ String targetAgent = derriveTargetAgent(request.getTargetAgentId());
+
SyncRPCRequest.SyncRPCRequestBuilder requestBuilder = SyncRPCRequest.SyncRPCRequestBuilder.builder()
- .withAgentId(request.getTargetAgentId())
+ .withAgentId(targetAgent)
.withMessageId(UUID.randomUUID().toString())
.withParameter("resourceId", request.getResourceId())
.withParameter("resourceType", request.getResourceType())
@@ -249,8 +252,11 @@ public class MFTApiHandler extends MFTApiServiceGrpc.MFTApiServiceImplBase {
@Override
public void getDirectoryResourceMetadata(FetchResourceMetadataRequest request, StreamObserver<DirectoryMetadataResponse> responseObserver) {
try {
+
+ String targetAgent = derriveTargetAgent(request.getTargetAgentId());
+
SyncRPCRequest.SyncRPCRequestBuilder requestBuilder = SyncRPCRequest.SyncRPCRequestBuilder.builder()
- .withAgentId(request.getTargetAgentId())
+ .withAgentId(targetAgent)
.withMessageId(UUID.randomUUID().toString())
.withParameter("resourceId", request.getResourceId())
.withParameter("resourceType", request.getResourceType())