From 7bb53c64da2dcf88894bfd31503accdd81498f3d Mon Sep 17 00:00:00 2001
From: Thomas Duval <thomas.duval@orange.com>
Date: Wed, 3 Jun 2020 10:06:52 +0200
Subject: Update to new version 5.4

Signed-off-by: Thomas Duval <thomas.duval@orange.com>
Change-Id: Idcd868133d75928a1ffd74d749ce98503e0555ea
---
 .../moon_engine/api/orchestration/pipeline.py      | 51 ++++++++++++++++++++++
 1 file changed, 51 insertions(+)
 create mode 100644 moon_engine/moon_engine/api/orchestration/pipeline.py

(limited to 'moon_engine/moon_engine/api/orchestration/pipeline.py')

diff --git a/moon_engine/moon_engine/api/orchestration/pipeline.py b/moon_engine/moon_engine/api/orchestration/pipeline.py
new file mode 100644
index 00000000..47a84409
--- /dev/null
+++ b/moon_engine/moon_engine/api/orchestration/pipeline.py
@@ -0,0 +1,51 @@
+# Software Name: MOON
+
+# Version: 5.4
+
+# SPDX-FileCopyrightText: Copyright (c) 2018-2020 Orange and its contributors
+# SPDX-License-Identifier: Apache-2.0
+
+# This software is distributed under the 'Apache License 2.0',
+# the text of which is available at 'http://www.apache.org/licenses/LICENSE-2.0.txt'
+# or see the "LICENSE" file for more details.
+
+
+from uuid import uuid4
+import logging
+from moon_utilities.security_functions import enforce
+from moon_engine.api.orchestration.managers import Managers
+
+logger = logging.getLogger("moon.engine.api.orchestration.pipeline")
+
+
+class PipelineManager(Managers):
+
+    def __init__(self, connector=None):
+        self.driver = connector.driver
+        Managers.PipelineManager = self
+
+    @enforce(("read", "write"), "pipelines")
+    def update_pipeline(self, moon_user_id, pipeline_id, data):
+        return self.driver.update_pipeline(pipeline_id=pipeline_id, data=data)
+
+    @enforce("write", "pipelines")
+    def delete_pipeline(self, moon_user_id, pipeline_id):
+        return self.driver.delete_pipeline(pipeline_id=pipeline_id)
+
+    @enforce("write", "pipelines")
+    def add_pipeline(self, moon_user_id, pipeline_id=None, data=None):
+        if not pipeline_id:
+            pipeline_id = uuid4().hex
+        if data is None:
+            data = {}
+        if "plugins" not in data:
+            data["plugins"] = ["moon_engine.plugins.authz"]
+        return self.driver.add_pipeline(pipeline_id=pipeline_id, data=data)
+
+    @enforce("read", "pipelines")
+    def get_pipelines(self, moon_user_id, pipeline_id=None):
+        return self.driver.get_pipelines(pipeline_id=pipeline_id)
+
+    @enforce("read", "pipelines")
+    def get_pipeline_api_key(self, moon_user_id, pipeline_id):
+        return self.driver.get_pipeline_api_key(pipeline_id=pipeline_id)
-- 
cgit 1.2.3-korg