From 31c44baac67064b6a0b9e2bd247808c97b296d13 Mon Sep 17 00:00:00 2001
From: Sonia Zorba <sonia.zorba@inaf.it>
Date: Tue, 19 Jan 2021 17:48:53 +0100
Subject: [PATCH] Minor changes to allow pushToVoSpace operation

---
 src/main/java/it/inaf/oats/vospace/JobService.java | 6 ++++--
 src/main/java/it/inaf/oats/vospace/UriService.java | 3 ++-
 2 files changed, 6 insertions(+), 3 deletions(-)

diff --git a/src/main/java/it/inaf/oats/vospace/JobService.java b/src/main/java/it/inaf/oats/vospace/JobService.java
index 9beca1e..9e90f41 100644
--- a/src/main/java/it/inaf/oats/vospace/JobService.java
+++ b/src/main/java/it/inaf/oats/vospace/JobService.java
@@ -22,6 +22,7 @@ public class JobService {
     enum JobType {
         pullToVoSpace,
         pullFromVoSpace,
+        pushToVoSpace,
         moveNode,
         copyNode
     }
@@ -47,7 +48,8 @@ public class JobService {
                 handlePullToVoSpace(job);
                 break;
             case pullFromVoSpace:
-                handlePullFromVoSpace(job);
+            case pushToVoSpace:
+                handleVoSpaceUrlsListResult(job);
                 break;
             default:
                 throw new UnsupportedOperationException("Not implemented yet");
@@ -59,7 +61,7 @@ public class JobService {
         tapeService.startJob(job);
     }
 
-    private void handlePullFromVoSpace(JobSummary job) {
+    private void handleVoSpaceUrlsListResult(JobSummary job) {
         job.setPhase(ExecutionPhase.EXECUTING);
         uriService.setTransferJobResult(job);
         jobDAO.updateJob(job);
diff --git a/src/main/java/it/inaf/oats/vospace/UriService.java b/src/main/java/it/inaf/oats/vospace/UriService.java
index 4a2cb53..d1dfb6f 100644
--- a/src/main/java/it/inaf/oats/vospace/UriService.java
+++ b/src/main/java/it/inaf/oats/vospace/UriService.java
@@ -52,7 +52,8 @@ public class UriService {
 
         Protocol protocol = transfer.getProtocols().get(0);
 
-        if (!"ivo://ivoa.net/vospace/core#httpget".equals(protocol.getUri())) {
+        if (!"ivo://ivoa.net/vospace/core#httpget".equals(protocol.getUri())
+                && !"ivo://ivoa.net/vospace/core#httpput".equals(protocol.getUri())) {
             throw new IllegalStateException("Unsupported protocol " + protocol.getUri());
         }
         protocol.setEndpoint(getEndpoint(job));
-- 
GitLab