From a259503e9f14ed8633b5b78953ea022c201fd1de Mon Sep 17 00:00:00 2001
From: dcore94 <m.lettere@gmail.com>
Date: Mon, 13 Sep 2021 16:11:26 +0200
Subject: [PATCH] Added check and eventually creation of parent folder

---
 templates/da_cache_to_shub.json.j2 | 51 ++++++++++++++++++++++++++++++
 1 file changed, 51 insertions(+)

diff --git a/templates/da_cache_to_shub.json.j2 b/templates/da_cache_to_shub.json.j2
index 0d1d52f..9bd9b0b 100644
--- a/templates/da_cache_to_shub.json.j2
+++ b/templates/da_cache_to_shub.json.j2
@@ -53,6 +53,57 @@
               }
             }
 		},
+		{
+			"name": "decision",
+			"taskReferenceName": "check_user_existance",
+			"inputParameters": {
+				"folders": "${checkfolder.output.response.body}"
+			},
+			"type": "DECISION",
+			"caseExpression": "($.folders.length === 0 ? 'create' : 'exists')",
+			"decisionCases": {
+				"create": [
+					{
+						"name" : "pyrest",
+						"taskReferenceName" : "create_parent_folder",
+						"type" : "SIMPLE",
+						"inputParameters" : {
+							"url" : "${init.input.storagehub}/workspace//items/{{workspace-root-id}}/create/FOLDER",
+							"method" : "POST",
+							"headers" : {
+								"Content-type": "application/x-www-form-urlencoded",
+								"Accept" : "text/plain"
+							},
+							"body" : {
+								"name" : "${init.input.parentfolder}", 
+								"description" : "Root folder of all Bluecloud data downloads",
+								"hidden" : "false"
+							}
+						}
+					},
+					{
+					  "name": "LAMBDA_TASK",
+					  "taskReferenceName": "extract_folder_id_1",
+					  "type": "LAMBDA",
+					  "inputParameters": {
+						"resp" : "${create_parent_folder.output.response}",
+						"scriptExpression": "return { parent_folder_id : $.resp}"
+					  }
+					}
+				],
+				"exists" : [
+					{
+					  "name": "LAMBDA_TASK",
+					  "taskReferenceName": "extract_folder_id_2",
+					  "type": "LAMBDA",
+					  "inputParameters": {
+						"resp" : "${checkfolder.output.response.body}",
+						"scriptExpression": "return { parent_folder_id : $.resp.itemlist[0].id}"
+					  }
+					}
+				]
+			}
+		},
 		{
 		  "name": "LAMBDA_TASK",
 		  "taskReferenceName": "build_transfer_tasks",