k8sClusters; k8sRepos 93/8293/3
authorlombardofr <lombardo@everyup.it>
Tue, 3 Dec 2019 10:23:17 +0000 (11:23 +0100)
committerlombardofr <lombardo@everyup.it>
Tue, 3 Dec 2019 10:50:10 +0000 (11:50 +0100)
Change-Id: Ife3ea193ec9479f685ff8e969335c1343a2ad1ac
Signed-off-by: lombardofr <lombardo@everyup.it>
25 files changed:
build-debpkg.sh
k8sclusterhandler/__init__.py [new file with mode: 0644]
k8sclusterhandler/apps.py [new file with mode: 0644]
k8sclusterhandler/template/k8scluster_list.html [new file with mode: 0644]
k8sclusterhandler/template/modal/k8scluster_details.html [new file with mode: 0644]
k8sclusterhandler/template/modal/k8scluster_register.html [new file with mode: 0644]
k8sclusterhandler/template/modal/k8scluster_update.html [new file with mode: 0644]
k8sclusterhandler/urls.py [new file with mode: 0644]
k8sclusterhandler/views.py [new file with mode: 0644]
k8srepohandler/__init__.py [new file with mode: 0644]
k8srepohandler/apps.py [new file with mode: 0644]
k8srepohandler/models.py [new file with mode: 0644]
k8srepohandler/template/k8srepo_list.html [new file with mode: 0644]
k8srepohandler/template/modal/k8srepo_details.html [new file with mode: 0644]
k8srepohandler/template/modal/k8srepo_register.html [new file with mode: 0644]
k8srepohandler/template/modal/k8srepo_update.html [new file with mode: 0644]
k8srepohandler/urls.py [new file with mode: 0644]
k8srepohandler/views.py [new file with mode: 0644]
lib/osm/osmclient/clientv2.py
projecthandler/template/project/osm/osm_project_left_sidebar.html
sf_t3d/settings.py
sf_t3d/urls.py
static/src/k8sclusterhandler/k8sclusters_list.js [new file with mode: 0644]
static/src/k8srepohandler/k8srepos_list.js [new file with mode: 0644]
vimhandler/views.py

index 46f5aae..90553c3 100755 (executable)
@@ -15,7 +15,7 @@
 #    under the License.
 
 
-PKG_DIRECTORIES="authosm descriptorhandler instancehandler lib projecthandler sdnctrlhandler sf_t3d static template userhandler vimhandler packagehandler netslicehandler wimhandler rolehandler"
+PKG_DIRECTORIES="authosm descriptorhandler instancehandler lib projecthandler sdnctrlhandler sf_t3d static template userhandler vimhandler packagehandler netslicehandler wimhandler rolehandler k8sclusterhandler k8srepohandler"
 PKG_FILES="bower.json django.ini LICENSE manage.py nginx-app.conf README.md requirements.txt supervisor-app.conf .bowerrc entrypoint.sh package.json"
 MDG_NAME=lightui
 DEB_INSTALL=debian/osm-${MDG_NAME}.install
diff --git a/k8sclusterhandler/__init__.py b/k8sclusterhandler/__init__.py
new file mode 100644 (file)
index 0000000..340b024
--- /dev/null
@@ -0,0 +1,15 @@
+#
+#   Copyright 2019 EveryUP Srl
+#
+#   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  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.
+#
\ No newline at end of file
diff --git a/k8sclusterhandler/apps.py b/k8sclusterhandler/apps.py
new file mode 100644 (file)
index 0000000..07d288e
--- /dev/null
@@ -0,0 +1,22 @@
+#
+#   Copyright 2019 EveryUP Srl
+#
+#   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  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.
+#
+from __future__ import unicode_literals
+
+from django.apps import AppConfig
+
+
+class K8SclusterhandlerConfig(AppConfig):
+    name = 'k8sclusterhandler'
diff --git a/k8sclusterhandler/template/k8scluster_list.html b/k8sclusterhandler/template/k8scluster_list.html
new file mode 100644 (file)
index 0000000..48201ae
--- /dev/null
@@ -0,0 +1,198 @@
+<!--
+Copyright 2019 EveryUP srl
+
+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  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.
+-->
+
+{% extends "base.html" %}
+{% load get %}
+{% load staticfiles %}
+
+
+{% block head_block %}
+    {{ block.super }}
+    <link rel="stylesheet" href="/static/node_modules/codemirror/lib/codemirror.css">
+    <link rel="stylesheet" href="/static/node_modules/codemirror/addon/fold/foldgutter.css" />
+    <link rel="stylesheet" href="/static/node_modules/codemirror/theme/neat.css">
+    <link rel="stylesheet" href="/static/node_modules/codemirror/addon/dialog/dialog.css">
+    <link rel="stylesheet" href="/static/node_modules/codemirror/addon/display/fullscreen.css">
+    <link rel="stylesheet" href="/static/node_modules/select2/dist/css/select2.min.css">
+    <link rel="stylesheet" href="/static/css/lwuitable.css">
+    <link rel="stylesheet" href="/static/node_modules/datatables.net-bs/css/dataTables.bootstrap.min.css">
+
+{% endblock %}
+{% block title_header_big %}
+    {{ block.super }}
+{% endblock %}
+{% block left_sidebar %}
+    {% include 'osm/osm_project_left_sidebar.html' %}
+{% endblock %}
+
+
+{% block breadcrumb_body %}
+    {{ block.super }}
+    <li><a href="{% url 'k8sc:list'  %}">K8s clusters</a></li>
+{% endblock %}
+
+{% block content_body %}
+    {{ block.super }}
+    {% include 'modal/k8scluster_details.html' %}
+    {% include 'modal/k8scluster_register.html' %}
+    {% csrf_token %}
+    <div class="row">
+        <div class="col-md-12">
+
+            <div class="box">
+                <div class="box-header with-border">
+                    <h3 class="box-title">Registered K8s clusters</h3>
+                    <div class="box-tools">
+                        <button type="button" class="btn btn-default" data-container="body"
+                            data-toggle="tooltip" data-placement="top" title="New K8s Cluster"
+                            onclick="javascript:openModalRegisterK8s({ 'project_id':'{{ project_id }}','vim_list_url': '{% url "vims:list"  %}'})">
+                        <i class="fa fa-plus"></i> <span> Add K8s Cluster</span>
+                        </button>
+                    </div>
+                </div>
+                <div class="box-body">
+                    <table id="k8sc_table" class="table table-bordered table-striped">
+                        <thead>
+                        <tr>
+                            <th>Name</th>
+                            <th>Identifier</th>
+                            <th>K8 Version</th>
+                            <th>Operational State</th>
+                            <th>Created</th>
+                            <th>Modified</th>
+                            <th>Actions</th>
+
+                        </tr>
+                        </thead>
+                        <tbody>
+
+                        </tbody>
+                    </table>
+                </div>
+            </div>
+        </div>
+
+    </div>
+{% endblock %}
+
+{% block resource_block %}
+    {{ block.super }}
+    <script src="/static/node_modules/select2/dist/js/select2.js"></script>
+    <script src="/static/node_modules/codemirror/lib/codemirror.js"></script>
+    <script src="/static/node_modules/codemirror/addon/fold/foldcode.js"></script>
+    <script src="/static/node_modules/codemirror/addon/fold/foldgutter.js"></script>
+    <script src="/static/node_modules/codemirror/addon/fold/brace-fold.js"></script>
+    <script src="/static/node_modules/codemirror/mode/javascript/javascript.js"></script>
+    <script src="/static/node_modules/codemirror/addon/search/searchcursor.js"></script>
+    <script src="/static/node_modules/codemirror/addon/search/search.js"></script>
+    <script src="/static/node_modules/codemirror/addon/dialog/dialog.js"></script>
+    <script src="/static/node_modules/codemirror/addon/display/autorefresh.js"></script>
+    <script src="/static/node_modules/codemirror/addon/edit/matchbrackets.js"></script>
+    <script src="/static/node_modules/codemirror/addon/edit/closebrackets.js"></script>
+    <script src="/static/node_modules/codemirror/addon/display/fullscreen.js"></script>
+    <script src="/static/node_modules/codemirror/keymap/sublime.js"></script>
+    <script src="/static/node_modules/moment/moment.js"></script>
+    <script src="/static/node_modules/datatables.net/js/jquery.dataTables.min.js"></script>
+    <script src="/static/node_modules/datatables.net-bs/js/dataTables.bootstrap.min.js"></script>
+    <script src="/static/src/k8sclusterhandler/k8sclusters_list.js"></script>
+
+     <script>
+        var table;
+        $(document).ready( function () {
+            table = $('#k8sc_table').DataTable({
+                responsive: true,
+                "ajax": {
+                    "url": "/k8scluster/list",
+                    "dataSrc": function (json) {
+                        return json['k8sc'];
+                    },
+                    statusCode: {
+                        401: function () {
+                            console.log("no auth");
+                            moveToLogin(window.location.pathname);
+                        }
+                    },
+                    "error": function (hxr, error, thrown) {
+                        console.log(hxr)
+                        console.log(thrown)
+                        console.log(error);
+                    }
+
+                },
+                "columns": [
+                    {
+                        "render": function (data, type, row) {
+                            return row["name"];
+                        },
+                        "targets": 0
+                    },
+                    {
+                        "render": function (data, type, row) {
+                            return row['_id'];
+                        },
+                        "targets": 1
+                    },
+                    {
+                        "render": function (data, type, row) {
+                            return row["k8s_version"];
+                        },
+                        "targets": 2
+                    },
+                    {
+                        "render": function (data, type, row) {
+                            return row["_admin"]["operationalState"];
+                        },
+                        "targets": 3
+                    },
+                    {
+                        "render": function (data, type, row) {
+                            return moment.unix(row['_admin']['created']).format('YYYY-MM-DD hh:mm:ss a');
+                        },
+                        "targets": 4
+                    },
+                    {
+                        "render": function (data, type, row) {
+                            return moment.unix(row['_admin']['modified']).format('YYYY-MM-DD hh:mm:ss a');
+                        },
+                        "targets": 5
+                    },
+                    {
+                        "render": function (data, type, row) {
+                            return '<div class="btn-group">' +
+                                '<button type="button" class="btn btn-default" ' +
+                                'onclick="javascript:showK8sc( \''+row['_id'] + '\', \''+row['name'] +'\')" data-toggle="tooltip" data-placement="top" data-container="body" title="Show Info"><i class="fa fa-info"></i>' +
+                            '</button>' +
+                            '<button type="button" class="btn btn-default"' +
+                            'onclick="javascript:deleteK8sc(\''+row['_id']+'\', \''+ row["name"] +'\')" data-toggle="tooltip" data-placement="top" data-container="body" title="Delete">' +
+                            '<i class="far fa-trash-alt" ></i></button></div>';
+                        },
+                        "targets": 6,
+                        "orderable": false
+                    }
+                ]
+            });
+
+            setInterval(function () {
+                    table.ajax.reload();
+                }, 10000);
+        });
+
+    </script>
+{% endblock %}
+
+{% block footer %}
+    {% include "footer.html"  %}
+{% endblock %}
\ No newline at end of file
diff --git a/k8sclusterhandler/template/modal/k8scluster_details.html b/k8sclusterhandler/template/modal/k8scluster_details.html
new file mode 100644 (file)
index 0000000..661e92e
--- /dev/null
@@ -0,0 +1,39 @@
+<!--
+Copyright 2019 EveryUP srl
+
+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  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.
+-->
+
+<div class="modal" id="modal_show_k8sc" xmlns="http://www.w3.org/1999/html">
+    <div class="modal-dialog">
+        <div class="modal-content">
+            <div class="modal-header">
+                <button type="button" class="close" data-dismiss="modal" aria-label="Close">
+                    <span aria-hidden="true">×</span></button>
+                <h4 class="modal-title" >K8s Cluster Details</h4>
+            </div>
+
+            <div class="modal-body" id="modal_show_k8sc_body">
+                    <div class="modal-body" id="modal_show_k8sc_body" >
+                            <textarea id="k8sc_view_json">
+                            </textarea>
+                        </div>
+            </div>
+            <div class="modal-footer">
+                <button type="button" class="btn btn-primary" data-dismiss="modal">Close</button>
+            </div>
+        </div>
+        <!-- /.modal-content -->
+    </div>
+    <!-- /.modal-dialog -->
+</div>
\ No newline at end of file
diff --git a/k8sclusterhandler/template/modal/k8scluster_register.html b/k8sclusterhandler/template/modal/k8scluster_register.html
new file mode 100644 (file)
index 0000000..1be648f
--- /dev/null
@@ -0,0 +1,85 @@
+<!--
+Copyright 2019 EveryUP srl
+
+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  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.
+-->
+
+<div class="modal" id="modal_new_k8sc" xmlns="http://www.w3.org/1999/html">
+    <div class="modal-dialog modal-lg">
+        <div class="modal-content">
+            <div class="modal-header">
+                <button type="button" class="close" data-dismiss="modal" aria-label="Close">
+                    <span aria-hidden="true">×</span></button>
+                <h4 class="modal-title">New K8s Cluster</h4>
+            </div>
+            <form id="formCreatek8sc" action='{% url "k8sc:create" %}'
+                  class="form-horizontal"
+                  method="post" enctype="multipart/form-data">
+                {% csrf_token %}
+                <div class="modal-body" id="modal_new_k8sc_body">
+                    <div class="form-group">
+                        <label for="k8sc_name" class="col-sm-2">Name *</label>
+                        <div class="col-sm-3">
+                            <input class="form-control" id="k8sc_name" name="name" placeholder="Name" required>
+                        </div>
+                        <label for="k8sc_vim_account" class="col-sm-2">Vim Account *</label>
+                        <div class="col-sm-3">
+                            <select required id="k8sc_vim_account" class="js-example-basic form-control" name="vim_account">
+                            </select>
+                        </div>
+                        
+                    </div> 
+                    
+
+                    <div class="form-group">
+                        <label for="k8sc_version" class="col-sm-2">K8s Version *</label>
+                        <div class="col-sm-3">
+                            <input class="form-control" id="k8sc_version" name="k8s_version"
+                                        placeholder="K8s Version" required>
+                        </div>
+                        <label for="k8sc_nets" class="col-sm-2">Nets*</label>
+                        <div class="col-sm-3">
+                            <input class="form-control" id="k8sc_nets" name="nets"
+                                        placeholder="Nets" >
+                        </div>
+                    </div>
+                    <div class="form-group">
+                        <label for="credentials" class="col-sm-3 control-label">Credentials *</label>
+                        <div class="col-sm-6">
+                            <textarea class="form-control" id="credentials" name="credentials" placeholder="Yaml"
+                                      rows="3"></textarea>
+                            <!--<p class="help-block">Or load from file</p>
+                            <input type="file" id="credentials_file" name=credentials_file">-->
+                        </div>
+                    </div>
+
+                    
+
+                </div>
+                <div class="modal-footer">
+                    <button type="button" class="btn btn-default pull-left" data-dismiss="modal">Cancel</button>
+                    <button class="btn btn-primary"
+                            data-loading-text="<i class='fa fa-circle-o-notch fa-spin'></i> Creating..."
+                            id="create_new_k8sc">Create
+                    </button>
+
+                </div>
+            </form>
+        </div>
+        <!-- /.modal-content -->
+    </div>
+    <!-- /.modal-dialog -->
+</div>
+
+
+
diff --git a/k8sclusterhandler/template/modal/k8scluster_update.html b/k8sclusterhandler/template/modal/k8scluster_update.html
new file mode 100644 (file)
index 0000000..d8dbb44
--- /dev/null
@@ -0,0 +1,15 @@
+<!--
+Copyright 2019 EveryUP srl
+
+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  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.
+-->
\ No newline at end of file
diff --git a/k8sclusterhandler/urls.py b/k8sclusterhandler/urls.py
new file mode 100644 (file)
index 0000000..f07893a
--- /dev/null
@@ -0,0 +1,26 @@
+#
+#   Copyright 2019 EveryUP Srl
+#
+#   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  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.
+#
+
+from django.conf.urls import url
+from k8sclusterhandler import views
+
+urlpatterns = [
+    url(r'^list$', views.list, name='list'),
+    url(r'^create/', views.create, name='create'),
+    url(r'^(?P<k8sc_id>[0-9a-z-]+)/delete$', views.delete, name='delete'),
+    url(r'^(?P<k8sc_id>[0-9a-z-]+)', views.show, name='show'),
+    url(r'^(?P<k8sc_id>[0-9a-z-]+)/update$', views.update, name='update'),
+]
\ No newline at end of file
diff --git a/k8sclusterhandler/views.py b/k8sclusterhandler/views.py
new file mode 100644 (file)
index 0000000..f3ee93d
--- /dev/null
@@ -0,0 +1,113 @@
+#
+#   Copyright 2019 EveryUP Srl
+#
+#   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  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.
+#
+
+from django.shortcuts import render, redirect
+from sf_t3d.decorators import login_required
+from django.http import HttpResponse
+import yaml
+import json
+import logging
+import authosm.utils as osmutils
+from lib.osm.osmclient.clientv2 import Client
+
+logging.basicConfig(level=logging.DEBUG)
+log = logging.getLogger('k8sclusterhandler/view.py')
+
+
+@login_required
+def list(request):
+    user = osmutils.get_user(request)
+    project_id = user.project_id
+    result = {'project_id': project_id}
+    raw_content_types = request.META.get('HTTP_ACCEPT', '*/*').split(',')
+    if 'application/json' not in raw_content_types:
+        return __response_handler(request, result, 'k8scluster_list.html')
+    client = Client()
+    result_client = client.k8sc_list(user.get_token())
+
+    result['k8sc'] = result_client['data'] if result_client and result_client['error'] is False else []
+
+    return __response_handler(request, result, 'k8scluster_list.html')
+
+
+@login_required
+def create(request):
+    user = osmutils.get_user(request)
+    project_id = user.project_id
+    result = {'project_id': project_id}
+    client = Client()
+    try:
+
+        new_k8sc = {
+            "name": request.POST.get('name'),
+            "credentials": yaml.load(request.POST.get('credentials')),
+            "vim_account": request.POST.get('vim_account'),
+            "k8s_version": request.POST.get('k8s_version'),
+            "nets": yaml.load(request.POST.get('nets')),
+        }
+
+        # new_k8sc['vim_account'] = get_vim_account_id(new_k8sc['vim_account'])
+
+    except Exception as e:
+        return __response_handler(request, {'status': 400, 'code': 'BAD_REQUEST', 'detail': e.message}, url=None, status=400)
+    result = client.k8sc_create(user.get_token(), new_k8sc)
+    if result['error']:
+        return __response_handler(request, result['data'], url=None, status=result['data']['status'] if 'status' in result['data'] else 500)
+    else:
+        return __response_handler(request, result, 'k8sc:list', to_redirect=True)
+
+
+@login_required
+def update(request, k8sc_id=None):
+    user = osmutils.get_user(request)
+    try:
+        update_k8sc_dict = request.POST.dict()
+        client = Client()
+        res = client.k8sc_update(user.get_token(), k8sc_id, update_k8sc_dict)
+    except Exception as e:
+        log.exception(e)
+    return __response_handler(request, res, 'k8sc:list', to_redirect=True)
+
+
+@login_required
+def show(request, k8sc_id=None):
+    user = osmutils.get_user(request)
+    project_id = user.project_id
+    client = Client()
+    result_client = client.k8sc_get(user.get_token(), k8sc_id)
+
+    return __response_handler(request, result_client)
+
+
+@login_required
+def delete(request, k8sc_id=None):
+    user = osmutils.get_user(request)
+    try:
+        client = Client()
+        del_res = client.k8sc_delete(user.get_token(), k8sc_id)
+    except Exception as e:
+        log.exception(e)
+    return __response_handler(request, del_res, 'k8sc:list', to_redirect=True)
+
+
+def __response_handler(request, data_res, url=None, to_redirect=None, *args, **kwargs):
+    raw_content_types = request.META.get('HTTP_ACCEPT', '*/*').split(',')
+    if 'application/json' in raw_content_types or url is None:
+        return HttpResponse(json.dumps(data_res), content_type="application/json", *args, **kwargs)
+    elif to_redirect:
+        return redirect(url, *args, **kwargs)
+    else:
+        return render(request, url, data_res)
diff --git a/k8srepohandler/__init__.py b/k8srepohandler/__init__.py
new file mode 100644 (file)
index 0000000..340b024
--- /dev/null
@@ -0,0 +1,15 @@
+#
+#   Copyright 2019 EveryUP Srl
+#
+#   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  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.
+#
\ No newline at end of file
diff --git a/k8srepohandler/apps.py b/k8srepohandler/apps.py
new file mode 100644 (file)
index 0000000..6efc9bd
--- /dev/null
@@ -0,0 +1,22 @@
+#
+#   Copyright 2019 EveryUP Srl
+#
+#   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  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.
+#
+from __future__ import unicode_literals
+
+from django.apps import AppConfig
+
+
+class K8SrepohandlerConfig(AppConfig):
+    name = 'k8srepohandler'
diff --git a/k8srepohandler/models.py b/k8srepohandler/models.py
new file mode 100644 (file)
index 0000000..3199b61
--- /dev/null
@@ -0,0 +1,20 @@
+#
+#   Copyright 2019 EveryUP Srl
+#
+#   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  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.
+#
+from __future__ import unicode_literals
+
+from django.db import models
+
+# Create your models here.
diff --git a/k8srepohandler/template/k8srepo_list.html b/k8srepohandler/template/k8srepo_list.html
new file mode 100644 (file)
index 0000000..889fded
--- /dev/null
@@ -0,0 +1,198 @@
+<!--
+Copyright 2019 EveryUP srl
+
+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  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.
+-->
+
+{% extends "base.html" %}
+{% load get %}
+{% load staticfiles %}
+
+
+{% block head_block %}
+    {{ block.super }}
+    <link rel="stylesheet" href="/static/node_modules/codemirror/lib/codemirror.css">
+    <link rel="stylesheet" href="/static/node_modules/codemirror/addon/fold/foldgutter.css" />
+    <link rel="stylesheet" href="/static/node_modules/codemirror/theme/neat.css">
+    <link rel="stylesheet" href="/static/node_modules/codemirror/addon/dialog/dialog.css">
+    <link rel="stylesheet" href="/static/node_modules/codemirror/addon/display/fullscreen.css">
+    <link rel="stylesheet" href="/static/node_modules/select2/dist/css/select2.min.css">
+    <link rel="stylesheet" href="/static/css/lwuitable.css">
+    <link rel="stylesheet" href="/static/node_modules/datatables.net-bs/css/dataTables.bootstrap.min.css">
+
+{% endblock %}
+{% block title_header_big %}
+    {{ block.super }}
+{% endblock %}
+{% block left_sidebar %}
+    {% include 'osm/osm_project_left_sidebar.html' %}
+{% endblock %}
+
+
+{% block breadcrumb_body %}
+    {{ block.super }}
+    <li><a href="{% url 'k8sr:list'  %}">K8s repository</a></li>
+{% endblock %}
+
+{% block content_body %}
+    {{ block.super }}
+    {% include 'modal/k8srepo_details.html' %}
+    {% include 'modal/k8srepo_register.html' %}
+    {% csrf_token %}
+    <div class="row">
+        <div class="col-md-12">
+
+            <div class="box">
+                <div class="box-header with-border">
+                    <h3 class="box-title">Registered K8s repository</h3>
+                    <div class="box-tools">
+                        <button type="button" class="btn btn-default" data-container="body"
+                            data-toggle="tooltip" data-placement="top" title="New K8s Repository"
+                            onclick="javascript:openModalRegisterK8sr({ 'project_id':'{{ project_id }}'})">
+                        <i class="fa fa-plus"></i> <span> Add K8s Repository</span>
+                        </button>
+                    </div>
+                </div>
+                <div class="box-body">
+                    <table id="k8sr_table" class="table table-bordered table-striped">
+                        <thead>
+                        <tr>
+                            <th>Name</th>
+                            <th>Identifier</th>
+                            <th>Url</th>
+                            <th>Type</th>
+                            <th>Created</th>
+                            <th>Modified</th>
+                            <th>Actions</th>
+
+                        </tr>
+                        </thead>
+                        <tbody>
+
+                        </tbody>
+                    </table>
+                </div>
+            </div>
+        </div>
+
+    </div>
+{% endblock %}
+
+{% block resource_block %}
+    {{ block.super }}
+    <script src="/static/node_modules/select2/dist/js/select2.js"></script>
+    <script src="/static/node_modules/codemirror/lib/codemirror.js"></script>
+    <script src="/static/node_modules/codemirror/addon/fold/foldcode.js"></script>
+    <script src="/static/node_modules/codemirror/addon/fold/foldgutter.js"></script>
+    <script src="/static/node_modules/codemirror/addon/fold/brace-fold.js"></script>
+    <script src="/static/node_modules/codemirror/mode/javascript/javascript.js"></script>
+    <script src="/static/node_modules/codemirror/addon/search/searchcursor.js"></script>
+    <script src="/static/node_modules/codemirror/addon/search/search.js"></script>
+    <script src="/static/node_modules/codemirror/addon/dialog/dialog.js"></script>
+    <script src="/static/node_modules/codemirror/addon/display/autorefresh.js"></script>
+    <script src="/static/node_modules/codemirror/addon/edit/matchbrackets.js"></script>
+    <script src="/static/node_modules/codemirror/addon/edit/closebrackets.js"></script>
+    <script src="/static/node_modules/codemirror/addon/display/fullscreen.js"></script>
+    <script src="/static/node_modules/codemirror/keymap/sublime.js"></script>
+    <script src="/static/node_modules/moment/moment.js"></script>
+    <script src="/static/node_modules/datatables.net/js/jquery.dataTables.min.js"></script>
+    <script src="/static/node_modules/datatables.net-bs/js/dataTables.bootstrap.min.js"></script>
+    <script src="/static/src/k8srepohandler/k8srepos_list.js"></script>
+
+     <script>
+        var table;
+        $(document).ready( function () {
+            table = $('#k8sr_table').DataTable({
+                responsive: true,
+                "ajax": {
+                    "url": "/k8srepo/list",
+                    "dataSrc": function (json) {
+                        return json['k8sr'];
+                    },
+                    statusCode: {
+                        401: function () {
+                            console.log("no auth");
+                            moveToLogin(window.location.pathname);
+                        }
+                    },
+                    "error": function (hxr, error, thrown) {
+                        console.log(hxr)
+                        console.log(thrown)
+                        console.log(error);
+                    }
+
+                },
+                "columns": [
+                    {
+                        "render": function (data, type, row) {
+                            return row["name"];
+                        },
+                        "targets": 0
+                    },
+                    {
+                        "render": function (data, type, row) {
+                            return row['_id'];
+                        },
+                        "targets": 1
+                    },
+                    {
+                        "render": function (data, type, row) {
+                            return row["url"];
+                        },
+                        "targets": 2
+                    },
+                    {
+                        "render": function (data, type, row) {
+                            return row["type"];
+                        },
+                        "targets": 3
+                    },
+                    {
+                        "render": function (data, type, row) {
+                            return moment.unix(row['_admin']['created']).format('YYYY-MM-DD hh:mm:ss a');
+                        },
+                        "targets": 4
+                    },
+                    {
+                        "render": function (data, type, row) {
+                            return moment.unix(row['_admin']['modified']).format('YYYY-MM-DD hh:mm:ss a');
+                        },
+                        "targets": 5
+                    },
+                    {
+                        "render": function (data, type, row) {
+                            return '<div class="btn-group">' +
+                            '<button type="button" class="btn btn-default" ' +
+                            'onclick="javascript:showK8sr( \''+row['_id'] + '\', \''+row['name'] +'\')" data-toggle="tooltip" data-placement="top" data-container="body" title="Show Info"><i class="fa fa-info"></i>' +
+                            '</button>' +
+                            '<button type="button" class="btn btn-default"' +
+                            'onclick="javascript:deleteK8sc(\''+row['_id']+'\', \''+ row["name"] +'\')" data-toggle="tooltip" data-placement="top" data-container="body" title="Delete">' +
+                            '<i class="far fa-trash-alt" ></i></button></div>';
+                        },
+                        "targets": 6,
+                        "orderable": false
+                    }
+                ]
+            });
+
+            setInterval(function () {
+                    table.ajax.reload();
+                }, 10000);
+        });
+
+    </script>
+{% endblock %}
+
+{% block footer %}
+    {% include "footer.html"  %}
+{% endblock %}
\ No newline at end of file
diff --git a/k8srepohandler/template/modal/k8srepo_details.html b/k8srepohandler/template/modal/k8srepo_details.html
new file mode 100644 (file)
index 0000000..e38fbe0
--- /dev/null
@@ -0,0 +1,39 @@
+<!--
+Copyright 2019 EveryUP srl
+
+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  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.
+-->
+
+<div class="modal" id="modal_show_k8sr" xmlns="http://www.w3.org/1999/html">
+    <div class="modal-dialog">
+        <div class="modal-content">
+            <div class="modal-header">
+                <button type="button" class="close" data-dismiss="modal" aria-label="Close">
+                    <span aria-hidden="true">×</span></button>
+                <h4 class="modal-title" >K8s Repository Details</h4>
+            </div>
+
+            <div class="modal-body" id="modal_show_k8sr_body">
+                    <div class="modal-body" id="modal_show_k8sr_body" >
+                            <textarea id="k8sr_view_json">
+                            </textarea>
+                        </div>
+            </div>
+            <div class="modal-footer">
+                <button type="button" class="btn btn-primary" data-dismiss="modal">Close</button>
+            </div>
+        </div>
+        <!-- /.modal-content -->
+    </div>
+    <!-- /.modal-dialog -->
+</div>
\ No newline at end of file
diff --git a/k8srepohandler/template/modal/k8srepo_register.html b/k8srepohandler/template/modal/k8srepo_register.html
new file mode 100644 (file)
index 0000000..b090bc8
--- /dev/null
@@ -0,0 +1,76 @@
+<!--
+Copyright 2019 EveryUP srl
+
+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  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.
+-->
+
+<div class="modal" id="modal_new_k8sr" xmlns="http://www.w3.org/1999/html">
+    <div class="modal-dialog modal-lg">
+        <div class="modal-content">
+            <div class="modal-header">
+                <button type="button" class="close" data-dismiss="modal" aria-label="Close">
+                    <span aria-hidden="true">×</span></button>
+                <h4 class="modal-title">New K8s Repository</h4>
+            </div>
+            <form id="formCreatek8sr" action='{% url "k8sr:create" %}'
+                  class="form-horizontal"
+                  method="post" enctype="multipart/form-data">
+                {% csrf_token %}
+                <div class="modal-body" id="modal_new_k8sr_body">
+                    <div class="form-group">
+                        <label for="k8sr_name" class="col-sm-2">Name *</label>
+                        <div class="col-sm-3">
+                            <input class="form-control" id="k8sr_name" name="name" placeholder="Name" required>
+                        </div>
+                        <label for="k8sr_type" class="col-sm-2">Type *</label>
+                        <div class="col-sm-3">
+                            <select required id="k8sr_type" name="type" class="form-control">
+                                <option value="chart">Chart</option>
+                                <option value="bundle">Bundle</option>
+                            </select>
+                        </div>
+                        
+                    </div> 
+                    
+
+                    <div class="form-group">
+                        <label for="k8sr_url" class="col-sm-2">Url *</label>
+                        <div class="col-sm-3">
+                            <input class="form-control" id="k8sr_url" name="url"
+                                        placeholder="Url" required>
+                        </div>
+                        <label for="k8sr_description" class="col-sm-2">Description</label>
+                        <div class="col-sm-3">
+                            <input class="form-control" id="k8sr_description" name="description"
+                                        placeholder="Description" >
+                        </div>
+                    </div>               
+
+                </div>
+                <div class="modal-footer">
+                    <button type="button" class="btn btn-default pull-left" data-dismiss="modal">Cancel</button>
+                    <button class="btn btn-primary"
+                            data-loading-text="<i class='fa fa-circle-o-notch fa-spin'></i> Creating..."
+                            id="create_new_k8sr">Register
+                    </button>
+
+                </div>
+            </form>
+        </div>
+        <!-- /.modal-content -->
+    </div>
+    <!-- /.modal-dialog -->
+</div>
+
+
+
diff --git a/k8srepohandler/template/modal/k8srepo_update.html b/k8srepohandler/template/modal/k8srepo_update.html
new file mode 100644 (file)
index 0000000..d8dbb44
--- /dev/null
@@ -0,0 +1,15 @@
+<!--
+Copyright 2019 EveryUP srl
+
+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  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.
+-->
\ No newline at end of file
diff --git a/k8srepohandler/urls.py b/k8srepohandler/urls.py
new file mode 100644 (file)
index 0000000..ca3b5cd
--- /dev/null
@@ -0,0 +1,26 @@
+#
+#   Copyright 2019 EveryUP Srl
+#
+#   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  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.
+#
+
+from django.conf.urls import url
+from k8srepohandler import views
+
+urlpatterns = [
+    url(r'^list$', views.list, name='list'),
+    url(r'^create/', views.create, name='create'),
+    url(r'^(?P<k8sr_id>[0-9a-z-]+)/delete$', views.delete, name='delete'),
+    url(r'^(?P<k8sr_id>[0-9a-z-]+)', views.show, name='show'),
+    url(r'^(?P<k8r_id>[0-9a-z-]+)/update$', views.update, name='update'),
+]
\ No newline at end of file
diff --git a/k8srepohandler/views.py b/k8srepohandler/views.py
new file mode 100644 (file)
index 0000000..325e7e5
--- /dev/null
@@ -0,0 +1,107 @@
+#
+#   Copyright 2019 EveryUP Srl
+#
+#   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  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.
+#
+
+from django.shortcuts import render, redirect
+from sf_t3d.decorators import login_required
+from django.http import HttpResponse
+import json
+import logging
+import authosm.utils as osmutils
+from lib.osm.osmclient.clientv2 import Client
+
+logging.basicConfig(level=logging.DEBUG)
+log = logging.getLogger('k8srepohandler/view.py')
+
+
+@login_required
+def list(request):
+    user = osmutils.get_user(request)
+    project_id = user.project_id
+    result = {'project_id': project_id}
+    raw_content_types = request.META.get('HTTP_ACCEPT', '*/*').split(',')
+    if 'application/json' not in raw_content_types:
+        return __response_handler(request, result, 'k8srepo_list.html')
+    client = Client()
+    result_client = client.k8sr_list(user.get_token())
+
+    result['k8sr'] = result_client['data'] if result_client and result_client['error'] is False else []
+
+    return __response_handler(request, result, 'k8srepo_list.html')
+
+
+@login_required
+def create(request):
+    user = osmutils.get_user(request)
+    project_id = user.project_id
+    result = {'project_id': project_id}
+    client = Client()
+    try:
+        new_k8sr = {
+            "name": request.POST.get('name'),
+            "type": request.POST.get('type'),
+            "url": request.POST.get('url'),
+            "description": request.POST.get('description'),
+        }
+    except Exception as e:
+        return __response_handler(request, {'status': 400, 'code': 'BAD_REQUEST', 'detail': e.message}, url=None, status=400)
+    result = client.k8sr_create(user.get_token(), new_k8sr)
+    if result['error']:
+        return __response_handler(request, result['data'], url=None, status=result['data']['status'] if 'status' in result['data'] else 500)
+    else:
+        return __response_handler(request, result, 'k8sr:list', to_redirect=True)
+
+
+@login_required
+def update(request, k8sr_id=None):
+    user = osmutils.get_user(request)
+    try:
+        update_k8sr_dict = request.POST.dict()
+        client = Client()
+        res = client.k8sr_update(user.get_token(), k8sr_id, update_k8sr_dict)
+    except Exception as e:
+        log.exception(e)
+    return __response_handler(request, res, 'k8sr:list', to_redirect=True)
+
+
+@login_required
+def show(request, k8sr_id=None):
+    user = osmutils.get_user(request)
+    project_id = user.project_id
+    client = Client()
+    result_client = client.k8sr_get(user.get_token(), k8sr_id)
+
+    return __response_handler(request, result_client)
+
+
+@login_required
+def delete(request, k8sr_id=None):
+    user = osmutils.get_user(request)
+    try:
+        client = Client()
+        del_res = client.k8sr_delete(user.get_token(), k8sr_id)
+    except Exception as e:
+        log.exception(e)
+    return __response_handler(request, del_res, 'k8sr:list', to_redirect=True)
+
+
+def __response_handler(request, data_res, url=None, to_redirect=None, *args, **kwargs):
+    raw_content_types = request.META.get('HTTP_ACCEPT', '*/*').split(',')
+    if 'application/json' in raw_content_types or url is None:
+        return HttpResponse(json.dumps(data_res), content_type="application/json", *args, **kwargs)
+    elif to_redirect:
+        return redirect(url, *args, **kwargs)
+    else:
+        return render(request, url, data_res)
index cee0647..8056d36 100644 (file)
@@ -114,7 +114,6 @@ class Client(object):
         headers = {"Content-Type": "application/json", "accept": "application/json",
                    'Authorization': 'Bearer {}'.format(token['id'])}
         _url = "{0}/admin/v1/roles/{1}".format(self._base_path, role_id)
-        
         try:
             r = requests.patch(_url, json=role_data, verify=False, headers=headers)
         except Exception as e:
@@ -1531,6 +1530,178 @@ class Client(object):
         result['data'] = Util.json_loads_byteified(r.text)
         return result
 
+    def k8sc_get(self, token, id):
+        result = {'error': True, 'data': ''}
+        headers = {"accept": "application/json",
+                   'Authorization': 'Bearer {}'.format(token['id'])}
+        _url = "{0}/admin/v1/k8sclusters/{1}".format(self._base_path, id)
+        try:
+            r = requests.get(_url, params=None, verify=False, stream=True, headers=headers)
+        except Exception as e:
+            log.exception(e)
+            result['data'] = str(e)
+            return result
+        if r.status_code in (200, 201, 202, 204):
+            result['error'] = False
+        result['data'] = Util.json_loads_byteified(r.text)
+        return result
+    
+    def k8sc_list(self, token):
+        result = {'error': True, 'data': ''}
+        headers = {"accept": "application/json",
+                   'Authorization': 'Bearer {}'.format(token['id'])}
+        _url = "{0}/admin/v1/k8sclusters".format(self._base_path)
+        try:
+            r = requests.get(_url, params=None, verify=False, stream=True, headers=headers)
+        except Exception as e:
+            log.exception(e)
+            result['data'] = str(e)
+            return result
+        if r.status_code in (200, 201, 202, 204):
+            result['error'] = False
+        result['data'] = Util.json_loads_byteified(r.text)
+        return result
+
+    def k8sc_create(self, token, cluster_data):
+        result = {'error': True, 'data': ''}
+        headers = {"Content-Type": "application/json", "accept": "application/json",
+                   'Authorization': 'Bearer {}'.format(token['id'])}
+
+        _url = "{0}/admin/v1/k8sclusters".format(self._base_path)
+
+        try:
+            r = requests.post(_url, json=cluster_data, verify=False, headers=headers)
+        except Exception as e:
+            log.exception(e)
+            result['data'] = str(e)
+            return result
+        if r.status_code in (200, 201, 202, 204):
+            result['error'] = False
+        result['data'] = Util.json_loads_byteified(r.text)
+        return result
+
+    def k8sc_update(self, token, id, cluster_data):
+        result = {'error': True, 'data': ''}
+        headers = {"Content-Type": "application/json", "accept": "application/json",
+                   'Authorization': 'Bearer {}'.format(token['id'])}
+
+        _url = "{0}/admin/v1/k8sclusters/{1}".format(self._base_path, id)
+        try:
+            r = requests.patch(_url, json=cluster_data, verify=False, headers=headers)
+        except Exception as e:
+            log.exception(e)
+            result['data'] = str(e)
+            return result
+        if r.status_code in (200, 201, 202, 204):
+            result['error'] = False
+        else:
+            result['data'] = Util.json_loads_byteified(r.text)
+        return result
+
+    def k8sc_delete(self, token, id):
+        result = {'error': True, 'data': ''}
+        headers = {"Content-Type": "application/yaml", "accept": "application/json",
+                   'Authorization': 'Bearer {}'.format(token['id'])}
+
+        _url = "{0}/admin/v1/k8sclusters/{1}".format(self._base_path, id)
+        try:
+            r = requests.delete(_url, params=None, verify=False, headers=headers)
+        except Exception as e:
+            log.exception(e)
+            result['data'] = str(e)
+            return result
+        if r.status_code in (200, 201, 202, 204):
+            result['error'] = False
+        else:
+            result['data'] = Util.json_loads_byteified(r.text)
+        return result
+
+    def k8sr_get(self, token, id):
+        result = {'error': True, 'data': ''}
+        headers = {"accept": "application/json",
+                   'Authorization': 'Bearer {}'.format(token['id'])}
+        _url = "{0}/admin/v1/k8srepos/{1}".format(self._base_path, id)
+        try:
+            r = requests.get(_url, params=None, verify=False, stream=True, headers=headers)
+        except Exception as e:
+            log.exception(e)
+            result['data'] = str(e)
+            return result
+        if r.status_code in (200, 201, 202, 204):
+            result['error'] = False
+        result['data'] = Util.json_loads_byteified(r.text)
+        return result
+
+    def k8sr_list(self, token):
+        result = {'error': True, 'data': ''}
+        headers = {"accept": "application/json",
+                   'Authorization': 'Bearer {}'.format(token['id'])}
+        _url = "{0}/admin/v1/k8srepos".format(self._base_path)
+        try:
+            r = requests.get(_url, params=None, verify=False, stream=True, headers=headers)
+        except Exception as e:
+            log.exception(e)
+            result['data'] = str(e)
+            return result
+        if r.status_code in (200, 201, 202, 204):
+            result['error'] = False
+        result['data'] = Util.json_loads_byteified(r.text)
+        return result
+
+    def k8sr_create(self, token, cluster_data):
+        result = {'error': True, 'data': ''}
+        headers = {"Content-Type": "application/json", "accept": "application/json",
+                   'Authorization': 'Bearer {}'.format(token['id'])}
+
+        _url = "{0}/admin/v1/k8srepos".format(self._base_path)
+
+        try:
+            r = requests.post(_url, json=cluster_data, verify=False, headers=headers)
+        except Exception as e:
+            log.exception(e)
+            result['data'] = str(e)
+            return result
+        if r.status_code in (200, 201, 202, 204):
+            result['error'] = False
+        result['data'] = Util.json_loads_byteified(r.text)
+        return result
+
+    def k8sr_update(self, token, id, cluster_data):
+        result = {'error': True, 'data': ''}
+        headers = {"Content-Type": "application/json", "accept": "application/json",
+                   'Authorization': 'Bearer {}'.format(token['id'])}
+
+        _url = "{0}/admin/v1/k8srepos/{1}".format(self._base_path, id)
+        try:
+            r = requests.patch(_url, json=cluster_data, verify=False, headers=headers)
+        except Exception as e:
+            log.exception(e)
+            result['data'] = str(e)
+            return result
+        if r.status_code in (200, 201, 202, 204):
+            result['error'] = False
+        else:
+            result['data'] = Util.json_loads_byteified(r.text)
+        return result
+
+    def k8sr_delete(self, token, id):
+        result = {'error': True, 'data': ''}
+        headers = {"Content-Type": "application/yaml", "accept": "application/json",
+                   'Authorization': 'Bearer {}'.format(token['id'])}
+
+        _url = "{0}/admin/v1/k8srepos/{1}".format(self._base_path, id)
+        try:
+            r = requests.delete(_url, params=None, verify=False, headers=headers)
+        except Exception as e:
+            log.exception(e)
+            result['data'] = str(e)
+            return result
+        if r.status_code in (200, 201, 202, 204):
+            result['error'] = False
+        else:
+            result['data'] = Util.json_loads_byteified(r.text)
+        return result
+
     @staticmethod
     def md5(f):
         hash_md5 = hashlib.md5()
index a16d86e..5fdaf57 100644 (file)
@@ -114,6 +114,30 @@ limitations under the License.
                 </a>
             </li>
 
+            {% url "k8sc:list"   as  k8sc_list_url %}
+            <li {% if request.get_full_path == k8sc_list_url %} class="active treeview menu-open" {% else %} class="treeview  menu-open" {% endif %} >
+                <a href="#">
+                    <i class="fa fa-paper-plane fa-fw"></i> <span>K8s</span>
+                    <span class="pull-right-container">
+                        <i class="fa fa-angle-left pull-right"></i>
+                    </span>
+                </a>
+                <ul class="treeview-menu" style="display: block;">
+                        {% url "k8sc:list"   as  k8sc_list_url %}
+                        <li {% if request.get_full_path == k8sc_list_url %} class="active" {% endif %} >
+                            <a href='{% url "k8sc:list"   %}'>
+                                <b>K8s</b> <span>Clusters</span>
+                            </a>
+                        </li>
+                        {% url "k8sr:list"   as  k8srepo_list_url %}
+                        <li {% if request.get_full_path == k8srepo_list_url %} class="active" {% endif %} >
+                            <a href='{% url "k8sr:list"   %}'>
+                                <b>K8s</b> <span>Repos</span>
+                            </a>
+                        </li>
+                </ul>
+            </li>
+
             {% url "wims:list"   as  wim_list_url %}
             <li {% if request.get_full_path == wim_list_url %} class="active" {% endif %}>
                 <a href='{% url "wims:list"   %}'>
index 0beb212..528929d 100644 (file)
@@ -64,7 +64,9 @@ INSTALLED_APPS = [
     'sdnctrlhandler',
     'userhandler',
     'rolehandler',
-    'netslicehandler'
+    'netslicehandler',
+    'k8sclusterhandler',
+    'k8srepohandler'
 
 ]
 
@@ -105,6 +107,8 @@ TEMPLATES = [
             os.path.join(BASE_DIR, 'sdnctrlhandler', 'template'),
             os.path.join(BASE_DIR, 'userhandler', 'templates'),
             os.path.join(BASE_DIR, 'netslicehandler', 'template'),
+            os.path.join(BASE_DIR, 'k8sclusterhandler', 'template'),
+            os.path.join(BASE_DIR, 'k8srepohandler', 'template'),
         ],
         'APP_DIRS': True,
         'OPTIONS': {
index 9c821b1..a908c13 100644 (file)
@@ -26,6 +26,8 @@ urlpatterns = [
     url(r'^projects/', include('projecthandler.urls.project', namespace='projects'), name='projects_base'),
     url(r'^sdn/', include('sdnctrlhandler.urls', namespace='sdns'), name='sdns_base'),
     url(r'^vims/', include('vimhandler.urls', namespace='vims'), name='vims_base'),
+    url(r'^k8scluster/', include('k8sclusterhandler.urls', namespace='k8sc'), name='k8sc_base'),
+    url(r'^k8srepo/', include('k8srepohandler.urls', namespace='k8sr'), name='k8sr_base'),
     url(r'^wims/', include('wimhandler.urls', namespace='wims'), name='wims_base'),
     url(r'^packages/', include('packagehandler.urls', namespace='packages'), name='packages_base'),
     url(r'^instances/', include('instancehandler.urls', namespace='instances'), name='instances_base'),
diff --git a/static/src/k8sclusterhandler/k8sclusters_list.js b/static/src/k8sclusterhandler/k8sclusters_list.js
new file mode 100644 (file)
index 0000000..5b1167f
--- /dev/null
@@ -0,0 +1,169 @@
+/*
+   Copyright 2019 EveryUP srl
+
+   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  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.
+*/
+
+function openModalRegisterK8s(args) {
+    // load vim account list
+    select2_groups = $('#k8sc_vim_account').select2({
+        placeholder: 'Select VIM',
+        width: '100%',
+        ajax: {
+            url: args.vim_list_url,
+            dataType: 'json',
+            processResults: function (data) {
+                vims = [];
+                if (data['datacenters']) {
+                    for (d in data['datacenters']) {
+                        var datacenter = data['datacenters'][d];
+                        vims.push({ id: datacenter['_id'], text: datacenter['name'] })
+                    }
+                }
+
+                return {
+                    results: vims
+                };
+            }
+        }
+    });
+
+
+    $('#modal_new_k8sc').modal('show');
+}
+
+function showK8sc(k8sc_id, k8sc_name) {
+    var url_info = '/k8scluster/' + k8sc_id;
+    var dialog = bootbox.dialog({
+        message: '<div class="text-center"><i class="fa fa-spin fa-spinner"></i> Loading...</div>',
+        closeButton: true
+    });
+    $.ajax({
+        url: url_info,
+        type: 'GET',
+        dataType: "json",
+        contentType: "application/json;charset=utf-8",
+        success: function (result) {
+
+            if (result['data'] !== undefined) {
+                editorJSON.setValue(JSON.stringify(result['data'], null, "\t"));
+                editorJSON.setOption("autoRefresh", true);
+                dialog.modal('hide');
+                $('#modal_show_k8sc').modal('show');
+            }
+            else {
+                dialog.modal('hide');
+                bootbox.alert("An error occurred while retrieving the information.");
+            }
+        },
+        error: function (result) {
+            dialog.modal('hide');
+            bootbox.alert("An error occurred while retrieving the information.");
+        }
+    });
+}
+
+function deleteK8sc(k8sc_id, k8sc_name) {
+    var url = "/k8scluster/"+k8sc_id+"/delete";
+    bootbox.confirm("Are you sure want to delete " + k8sc_name + "?", function (result) {
+        if (result) {
+            var dialog = bootbox.dialog({
+                message: '<div class="text-center"><i class="fa fa-spin fa-spinner"></i> Loading...</div>',
+                closeButton: true
+            });
+            $.ajax({
+                url: url,
+                type: 'GET',
+                dataType: "json",
+                contentType: "application/json;charset=utf-8",
+                success: function (result) {
+                    if (result['error'] == true) {
+                        dialog.modal('hide');
+                        bootbox.alert("An error occurred.");
+                    }
+                    else {
+                        table.ajax.reload();
+                        dialog.modal('hide');
+                    }
+                },
+                error: function (error) {
+                    dialog.modal('hide');
+                    bootbox.alert("An error occurred.");
+                }
+            });
+        }
+    })
+}
+
+var editorJSON;
+
+$(document).ready(function () {
+
+    var json_editor_settings = {
+        mode: "javascript",
+        showCursorWhenSelecting: true,
+        autofocus: true,
+        lineNumbers: true,
+        lineWrapping: true,
+        foldGutter: true,
+        gutters: ["CodeMirror-linenumbers", "CodeMirror-foldgutter"],
+        autoCloseBrackets: true,
+        matchBrackets: true,
+        extraKeys: {
+            "F11": function (cm) {
+                cm.setOption("fullScreen", !cm.getOption("fullScreen"));
+            },
+            "Esc": function (cm) {
+                if (cm.getOption("fullScreen")) cm.setOption("fullScreen", false);
+            },
+            "Ctrl-Q": function (cm) {
+                cm.foldCode(cm.getCursor());
+            }
+        },
+        theme: "neat",
+        keyMap: "sublime"
+    };
+    var myJsonTextArea = document.getElementById("k8sc_view_json");
+    editorJSON = CodeMirror(function (elt) {
+        myJsonTextArea.parentNode.replaceChild(elt, myJsonTextArea);
+    }, json_editor_settings);
+
+    $("#formCreatek8sc").submit(function (event) {
+        event.preventDefault(); //prevent default action
+        var post_url = $(this).attr("action"); //get form action url
+        var request_method = $(this).attr("method"); //get form GET/POST method
+        var form_data = new FormData(this); //Encode form elements for submission
+        $.ajax({
+            url: post_url,
+            type: request_method,
+            data: form_data,
+            headers: {
+                "Accept": 'application/json'
+            },
+            contentType: false,
+            processData: false
+        }).done(function (response, textStatus, jqXHR) {
+            table.ajax.reload();
+            $('#modal_new_k8sc').modal('hide');
+        }).fail(function (result) {
+            var data = result.responseJSON;
+            var title = "Error " + (data.code ? data.code : 'unknown');
+            var message = data.detail ? data.detail : 'No detail available.';
+            bootbox.alert({
+                title: title,
+                message: message
+            });
+        });
+    });
+
+});
\ No newline at end of file
diff --git a/static/src/k8srepohandler/k8srepos_list.js b/static/src/k8srepohandler/k8srepos_list.js
new file mode 100644 (file)
index 0000000..5c3fa09
--- /dev/null
@@ -0,0 +1,146 @@
+/*
+   Copyright 2019 EveryUP srl
+
+   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  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.
+*/
+
+function openModalRegisterK8sr(args) {
+    $('#modal_new_k8sr').modal('show');
+}
+
+function showK8sr(k8sr_id, k8sr_name) {
+    var url_info = '/k8srepo/' + k8sr_id;
+    var dialog = bootbox.dialog({
+        message: '<div class="text-center"><i class="fa fa-spin fa-spinner"></i> Loading...</div>',
+        closeButton: true
+    });
+    $.ajax({
+        url: url_info,
+        type: 'GET',
+        dataType: "json",
+        contentType: "application/json;charset=utf-8",
+        success: function (result) {
+
+            if (result['data'] !== undefined) {
+                editorJSON.setValue(JSON.stringify(result['data'], null, "\t"));
+                editorJSON.setOption("autoRefresh", true);
+                dialog.modal('hide');
+                $('#modal_show_k8sr').modal('show');
+            }
+            else {
+                dialog.modal('hide');
+                bootbox.alert("An error occurred while retrieving the information.");
+            }
+        },
+        error: function (result) {
+            dialog.modal('hide');
+            bootbox.alert("An error occurred while retrieving the information.");
+        }
+    });
+}
+
+function deleteK8sc(k8sr_id, k8sr_name) {
+    var url = "/k8srepo/"+k8sr_id+"/delete";
+    bootbox.confirm("Are you sure want to delete " + k8sr_name + "?", function (result) {
+        if (result) {
+            var dialog = bootbox.dialog({
+                message: '<div class="text-center"><i class="fa fa-spin fa-spinner"></i> Loading...</div>',
+                closeButton: true
+            });
+            $.ajax({
+                url: url,
+                type: 'GET',
+                dataType: "json",
+                contentType: "application/json;charset=utf-8",
+                success: function (result) {
+                    if (result['error'] == true) {
+                        dialog.modal('hide');
+                        bootbox.alert("An error occurred.");
+                    }
+                    else {
+                        table.ajax.reload();
+                        dialog.modal('hide');
+                    }
+                },
+                error: function (error) {
+                    dialog.modal('hide');
+                    bootbox.alert("An error occurred.");
+                }
+            });
+        }
+    })
+}
+
+
+var editorJSON;
+
+$(document).ready(function () {
+
+    var json_editor_settings = {
+        mode: "javascript",
+        showCursorWhenSelecting: true,
+        autofocus: true,
+        lineNumbers: true,
+        lineWrapping: true,
+        foldGutter: true,
+        gutters: ["CodeMirror-linenumbers", "CodeMirror-foldgutter"],
+        autoCloseBrackets: true,
+        matchBrackets: true,
+        extraKeys: {
+            "F11": function (cm) {
+                cm.setOption("fullScreen", !cm.getOption("fullScreen"));
+            },
+            "Esc": function (cm) {
+                if (cm.getOption("fullScreen")) cm.setOption("fullScreen", false);
+            },
+            "Ctrl-Q": function (cm) {
+                cm.foldCode(cm.getCursor());
+            }
+        },
+        theme: "neat",
+        keyMap: "sublime"
+    };
+    var myJsonTextArea = document.getElementById("k8sr_view_json");
+    editorJSON = CodeMirror(function (elt) {
+        myJsonTextArea.parentNode.replaceChild(elt, myJsonTextArea);
+    }, json_editor_settings);
+
+    $("#formCreatek8sr").submit(function (event) {
+        event.preventDefault(); //prevent default action
+        var post_url = $(this).attr("action"); //get form action url
+        var request_method = $(this).attr("method"); //get form GET/POST method
+        var form_data = new FormData(this); //Encode form elements for submission
+        $.ajax({
+            url: post_url,
+            type: request_method,
+            data: form_data,
+            headers: {
+                "Accept": 'application/json'
+            },
+            contentType: false,
+            processData: false
+        }).done(function (response, textStatus, jqXHR) {
+            table.ajax.reload();
+            $('#modal_new_k8sr').modal('hide');
+        }).fail(function (result) {
+            var data = result.responseJSON;
+            var title = "Error " + (data.code ? data.code : 'unknown');
+            var message = data.detail ? data.detail : 'No detail available.';
+            bootbox.alert({
+                title: title,
+                message: message
+            });
+        });
+    });
+
+});
\ No newline at end of file
index 2a0d07e..ff1f2ae 100644 (file)
@@ -78,6 +78,7 @@ def create(request):
         # TODO  'vim:show', to_redirect=True, vim_id=vim_id
         return __response_handler(request, result, 'vims:list', to_redirect=True, )
 
+
 @login_required
 def delete(request, vim_id=None):
     user = osmutils.get_user(request)
@@ -88,6 +89,7 @@ def delete(request, vim_id=None):
         log.exception(e)
     return __response_handler(request, del_res, 'vims:list', to_redirect=True, )
 
+   
 @login_required
 def show(request, vim_id=None):
     user = osmutils.get_user(request)