summaryrefslogtreecommitdiffstats
path: root/mock-msb-k8s
diff options
context:
space:
mode:
Diffstat (limited to 'mock-msb-k8s')
-rw-r--r--mock-msb-k8s/Dockerfile11
-rw-r--r--mock-msb-k8s/README.md2
-rw-r--r--mock-msb-k8s/app/app.py284
-rw-r--r--mock-msb-k8s/requirements.txt2
4 files changed, 299 insertions, 0 deletions
diff --git a/mock-msb-k8s/Dockerfile b/mock-msb-k8s/Dockerfile
new file mode 100644
index 0000000..65efac9
--- /dev/null
+++ b/mock-msb-k8s/Dockerfile
@@ -0,0 +1,11 @@
+FROM python:3.8-alpine
+
+COPY . .
+
+WORKDIR /app
+
+RUN pip3 install -r ../requirements.txt
+
+EXPOSE 5003
+
+CMD ["python","app.py"] \ No newline at end of file
diff --git a/mock-msb-k8s/README.md b/mock-msb-k8s/README.md
new file mode 100644
index 0000000..f446fa0
--- /dev/null
+++ b/mock-msb-k8s/README.md
@@ -0,0 +1,2 @@
+# mock-msb-k8s
+
diff --git a/mock-msb-k8s/app/app.py b/mock-msb-k8s/app/app.py
new file mode 100644
index 0000000..5da64d7
--- /dev/null
+++ b/mock-msb-k8s/app/app.py
@@ -0,0 +1,284 @@
+"""MSB k8s mock application"""
+"""
+ Copyright 2023 Deutsche Telekom AG, Orange
+
+ Licensed under the Apache License, Version 2.0 (the "License");
+ you may not use this file except in compliance with the License.
+ You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+"""
+
+import http
+import json
+import uuid
+
+from flask import Flask, request
+from flask_restful import Api
+
+app = Flask(__name__)
+api = Api(app)
+
+CONNECTIVITY_INFOS = []
+DEFINITIONS = []
+CONFIGURATIONS_TEMPLATES = []
+PROFILES = []
+INSTANCES = []
+INSTANCE_EXAMPLE = {
+ "id": "ID_GENERATED_BY_K8SPLUGIN",
+ "namespace": "NAMESPACE_WHERE_INSTANCE_HAS_BEEN_DEPLOYED_AS_DERIVED_FROM_PROFILE",
+ "release-name": "RELEASE_NAME_AS_COMPUTED_BASED_ON_INSTANTIATION_REQUEST_AND_PROFILE_DEFAULT",
+ "request": {
+ "rb-name": "test-rbdef",
+ "rb-version": "v1",
+ "profile-name": "p1",
+ "cloud-region": "krd",
+ "override-values": {
+ "optionalDictOfParameters": "andTheirValues, like",
+ "global.name": "dummy-name"
+ },
+ "labels": {
+ "optionalLabelForInternalK8spluginInstancesMetadata": "dummy-value"
+ },
+ },
+ "resources": [
+ {
+ "GVK": {
+ "Group": "",
+ "Kind": "ConfigMap",
+ "Version": "v1"
+ },
+ "Name": "test-cm"
+ },
+ {
+ "GVK": {
+ "Group": "",
+ "Kind": "Service",
+ "Version": "v1"
+ },
+ "Name": "test-svc"
+ },
+ {
+ "GVK": {
+ "Group": "apps",
+ "Kind": "Deployment",
+ "Version": "v1"
+ },
+ "Name": "test-dep"
+ }
+ ]
+}
+
+
+@app.route('/api/multicloud-k8s/v1/v1/connectivity-info/<string:region_id>', methods=['GET', 'DELETE'])
+def connectivity_info_get_delete(region_id):
+ if request.method == 'GET':
+ for conninfo in CONNECTIVITY_INFOS:
+ if conninfo["cloud-region"] == region_id:
+ return conninfo, http.HTTPStatus.OK
+ else:
+ return '', http.HTTPStatus.NOT_FOUND
+ if request.method == 'DELETE':
+ for conninfo in CONNECTIVITY_INFOS:
+ if conninfo["cloud-region"] == region_id:
+ CONNECTIVITY_INFOS.remove(conninfo)
+ return '', http.HTTPStatus.OK
+ else:
+ return '', http.HTTPStatus.NOT_FOUND
+ return '', http.HTTPStatus.METHOD_NOT_ALLOWED
+
+
+@app.route('/api/multicloud-k8s/v1/v1/connectivity-info', methods=['POST'])
+def connectivity_info_create():
+ if request.method == 'POST':
+ kubeconfig = request.files['file']
+ metadata = json.loads(request.values['metadata'])
+ CONNECTIVITY_INFOS.append({
+ "cloud-region": metadata['cloud-region'],
+ "cloud-owner": metadata['cloud-region'],
+ "kubeconfig": kubeconfig.read().decode("utf-8")
+ })
+ return '', http.HTTPStatus.OK
+ return '', http.HTTPStatus.METHOD_NOT_ALLOWED
+
+
+@app.route('/api/multicloud-k8s/v1/v1/rb/definition', methods=['POST'])
+def definition_create():
+ if request.method == 'POST':
+ data = json.loads(request.data)
+ DEFINITIONS.append({
+ "rb-name": data['rb-name'],
+ "rb-version": data['rb-version'],
+ "chart-name": data['chart-name'],
+ "description": data['description'],
+ "labels": data['labels']
+ })
+ return '', http.HTTPStatus.OK
+ return '', http.HTTPStatus.METHOD_NOT_ALLOWED
+
+
+@app.route('/api/multicloud-k8s/v1/v1/rb/definition/<string:rb_name>/<string:rb_version>/content', methods=['POST'])
+def definition_upload_artifact(rb_name, rb_version):
+ if request.method == 'POST':
+ data = request.data
+ return '', http.HTTPStatus.OK
+ return '', http.HTTPStatus.METHOD_NOT_ALLOWED
+
+
+@app.route('/api/multicloud-k8s/v1/v1/rb/definition/<string:rb_name>/<string:rb_version>', methods=['GET', 'DELETE'])
+def definition_get_delete(rb_name, rb_version):
+ if request.method == 'GET':
+ for rb in DEFINITIONS:
+ if rb['rb-name'] == rb_name and rb['rb-version'] == rb_version:
+ return rb, http.HTTPStatus.OK
+ else:
+ return '', http.HTTPStatus.NOT_FOUND
+ if request.method == 'DELETE':
+ for rb in DEFINITIONS:
+ if rb['rb-name'] == rb_name and rb['rb-version'] == rb_version:
+ DEFINITIONS.remove(rb)
+ return '', http.HTTPStatus.OK
+ else:
+ return '', http.HTTPStatus.NOT_FOUND
+ return '', http.HTTPStatus.METHOD_NOT_ALLOWED
+
+
+@app.route('/api/multicloud-k8s/v1/v1/rb/definition', methods=['GET'])
+def definition_get_all():
+ if request.method == 'GET':
+ return json.dumps(DEFINITIONS), http.HTTPStatus.OK
+ return '', http.HTTPStatus.METHOD_NOT_ALLOWED
+
+
+@app.route('/api/multicloud-k8s/v1/v1/rb/definition/<string:rb_name>/<string:rb_version>/profile', methods=['POST'])
+def profile_create(**kwargs):
+ if request.method == 'POST':
+ data = json.loads(request.data)
+ PROFILES.append({
+ "rb-name": data['rb-name'],
+ "rb-version": data['rb-version'],
+ "profile-name": data['profile-name'],
+ "release-name": data['release-name'],
+ "namespace": data['namespace'],
+ "kubernetes-version": data['kubernetes-version']
+ })
+ return '', http.HTTPStatus.OK
+ return '', http.HTTPStatus.METHOD_NOT_ALLOWED
+
+
+@app.route(
+ '/api/multicloud-k8s/v1/v1/rb/definition/<string:rb_name>/<string:rb_version>/profile/<string:profile_name>/content'
+ , methods=['POST'])
+def profile_upload_artifact(rb_name, rb_version, profile_name):
+ if request.method == 'POST':
+ data = request.data
+ return '', http.HTTPStatus.OK
+ return '', http.HTTPStatus.METHOD_NOT_ALLOWED
+
+
+@app.route('/api/multicloud-k8s/v1/v1/rb/definition/<string:rb_name>/<string:rb_version>/profile/<string:profile_name>',
+ methods=['GET', 'DELETE'])
+def profile_get_delete(rb_name, rb_version, profile_name):
+ if request.method == 'GET':
+ for profile in PROFILES:
+ if profile['rb-name'] == rb_name and profile['rb-version'] == rb_version \
+ and profile["profile-name"] == profile_name:
+ return profile, http.HTTPStatus.OK
+ else:
+ return '', http.HTTPStatus.NOT_FOUND
+ if request.method == 'DELETE':
+ for profile in PROFILES:
+ if profile['rb-name'] == rb_name and profile['rb-version'] == rb_version \
+ and profile["profile-name"] == profile_name:
+ PROFILES.remove(profile)
+ return '', http.HTTPStatus.OK
+ else:
+ return '', http.HTTPStatus.NOT_FOUND
+ return '', http.HTTPStatus.METHOD_NOT_ALLOWED
+
+
+@app.route('/api/multicloud-k8s/v1/v1/rb/definition/<string:rb_name>/<string:rb_version>/profile', methods=['GET'])
+def profile_get_all(rb_name, rb_version):
+ if request.method == 'GET':
+ profiles = []
+ for profile in PROFILES:
+ if profile['rb-name'] == rb_name and profile['rb-version'] == rb_version:
+ profiles.append(profile)
+ return json.dumps(PROFILES), http.HTTPStatus.OK
+ return '', http.HTTPStatus.METHOD_NOT_ALLOWED
+
+@app.route('/api/multicloud-k8s/v1/v1/instance', methods=['POST'])
+def instance_create():
+ if request.method == 'POST':
+ data = json.loads(request.data)
+ instance_details = INSTANCE_EXAMPLE
+ instance_details["id"] = str(uuid.uuid4())
+ instance_details["request"] = data
+ INSTANCES.append(instance_details)
+ return instance_details, http.HTTPStatus.OK
+ return '', http.HTTPStatus.METHOD_NOT_ALLOWED
+
+@app.route('/api/multicloud-k8s/v1/v1/instance/<string:instance_id>', methods=['GET', 'DELETE'])
+def instance_get_delete(instance_id):
+ if request.method == 'GET':
+ for instance in INSTANCES:
+ if instance['id'] == instance_id:
+ return instance, http.HTTPStatus.OK
+ else:
+ return '', http.HTTPStatus.NOT_FOUND
+ if request.method == 'DELETE':
+ for instance in INSTANCES:
+ if instance['id'] == instance_id:
+ INSTANCES.remove(instance)
+ return '', http.HTTPStatus.OK
+ else:
+ return '', http.HTTPStatus.NOT_FOUND
+ return '', http.HTTPStatus.METHOD_NOT_ALLOWED
+
+
+@app.route('/api/multicloud-k8s/v1/v1/instance', methods=['GET'])
+def instance_get_all():
+ if request.method == 'GET':
+ return json.dumps(INSTANCES), http.HTTPStatus.OK
+ return '', http.HTTPStatus.METHOD_NOT_ALLOWED
+
+
+@app.route('/api/multicloud-k8s/v1/v1/rb/definition/<string:rb_name>/<string:rb_version>/config-template',
+ methods=["POST"])
+def configuration_template_create(rb_name, rb_version):
+ if request.method == "POST":
+ data = json.loads(request.data)
+ configuration_template = data
+ CONFIGURATIONS_TEMPLATES.append(configuration_template)
+ return '', http.HTTPStatus.OK
+ return '', http.HTTPStatus.METHOD_NOT_ALLOWED
+
+
+@app.route('/api/multicloud-k8s/v1/v1/rb/definition/<string:rb_name>/<string:rb_version>/config-template/<string:name>',
+ methods=["GET"])
+def configuration_template_get(rb_name, rb_version, name):
+ if request.method == "GET":
+ for template in CONFIGURATIONS_TEMPLATES:
+ if template['template-name'] == name:
+ return json.dumps(template), http.HTTPStatus.OK
+ else:
+ return '', http.HTTPStatus.NOT_FOUND
+ return '', http.HTTPStatus.METHOD_NOT_ALLOWED
+
+
+@app.route('/api/multicloud-k8s/v1/v1/rb/definition/<string:rb_name>/<string:rb_version>/config-template',
+ methods=["GET"])
+def configuration_template_get_all(rb_name, rb_version):
+ if request.method == 'GET':
+ return json.dumps(CONFIGURATIONS_TEMPLATES), http.HTTPStatus.OK
+ return '', http.HTTPStatus.METHOD_NOT_ALLOWED
+
+
+if __name__ == "__main__":
+ app.run(debug=True, host='0.0.0.0', port=5003)
diff --git a/mock-msb-k8s/requirements.txt b/mock-msb-k8s/requirements.txt
new file mode 100644
index 0000000..07e3f1f
--- /dev/null
+++ b/mock-msb-k8s/requirements.txt
@@ -0,0 +1,2 @@
+Flask==1.1.2
+Flask-RESTful==0.3.8