From 4e6f5d3d05e806b98a62c883151a7870821bd69a Mon Sep 17 00:00:00 2001
From: Hurng-Chun Lee <h.lee@donders.ru.nl>
Date: Thu, 8 Aug 2024 16:29:03 +0200
Subject: [PATCH] fixed data structure for stager POST jobs

---
 streamer/lib/modalityMEG.js  | 12 ++++++++----
 streamer/lib/modalityMRI.js  |  6 ++++--
 streamer/lib/modalityUSER.js | 12 ++++++++----
 3 files changed, 20 insertions(+), 10 deletions(-)

diff --git a/streamer/lib/modalityMEG.js b/streamer/lib/modalityMEG.js
index 6731e3c..2ba9e26 100644
--- a/streamer/lib/modalityMEG.js
+++ b/streamer/lib/modalityMEG.js
@@ -389,9 +389,13 @@ var _execStreamerJob = function(name, config, job, cb_remove, cb_done) {
 
                 // here we get the collection namespace for the project
                 var rpost_args = {
-                    headers: { 'Accept': 'application/json',
-                               'Content-Type': 'application/json' },
-                    data: []
+                    headers: {
+                        'Accept': 'application/json',
+                        'Content-Type': 'application/json'
+                    },
+                    data: {
+                        jobs: []
+                    }
                 };
 
                 if ( src_list.length == 0 ) {
@@ -412,7 +416,7 @@ var _execStreamerJob = function(name, config, job, cb_remove, cb_done) {
 
                 for( var i=0; i<src_list.length; i++ ) {
                     // add job data to post_args
-                    rpost_args.data.push({
+                    rpost_args.data.jobs.push({
                         "drUser": utility.getOuFromCollName(rdata.collName) + "-stager@ru.nl",
                         "dstURL": dst_list[i],
                         "srcURL": src_list[i],
diff --git a/streamer/lib/modalityMRI.js b/streamer/lib/modalityMRI.js
index 6768c9a..5a2d3b0 100644
--- a/streamer/lib/modalityMRI.js
+++ b/streamer/lib/modalityMRI.js
@@ -402,8 +402,10 @@ var _execStreamerJob = function(name, config, job, cb_remove, cb_done) {
             }
 
             var rpost_args = {
-                headers: { 'Accept': 'application/json',
-                           'Content-Type': 'application/json' },
+                headers: {
+                    'Accept': 'application/json',
+                    'Content-Type': 'application/json'
+                },
                 data: {
                     "drUser": utility.getOuFromCollName(rdata.collName) + "-stager@ru.nl",
                     "dstURL": _mkDst(src, rdata.collName),
diff --git a/streamer/lib/modalityUSER.js b/streamer/lib/modalityUSER.js
index 10c7bd2..fb32c0e 100644
--- a/streamer/lib/modalityUSER.js
+++ b/streamer/lib/modalityUSER.js
@@ -271,9 +271,13 @@ var _execStreamerJob = function(name, config, job, cb_remove, cb_done) {
 
             // here we get the collection namespace for the project
             var rpost_args = {
-                headers: { 'Accept': 'application/json',
-                           'Content-Type': 'application/json' },
-                data: []
+                headers: {
+                    'Accept': 'application/json',
+                    'Content-Type': 'application/json'
+                },
+                data: {
+                    jobs: []
+                }
             };
 
             // construct destination collection
@@ -298,7 +302,7 @@ var _execStreamerJob = function(name, config, job, cb_remove, cb_done) {
             }
 
             // compose POST data for submitting stager jobs
-            rpost_args.data.push({
+            rpost_args.data.jobs.push({
                 "drUser": utility.getOuFromCollName(rdata.collName) + "-stager@ru.nl",
                 "dstURL": dst,
                 "srcURL": src,