Repo creation

Author: numbersixnz

.gitignore

@@ -0,0 +1,3 @@
+graft lab/static
+graft lab/templates
+global-exclude *.pyc

MANIFEST.in

@@ -0,0 +1,5 @@
+import os
+
+class Config(object):
+    SECRET_KEY = os.environ.get('SECRET_KEY') or 'some strong secret string'
+

config.py

@@ -0,0 +1,63 @@
+import os
+
+from flask import Flask
+from flask_assets import Environment, Bundle
+
+from .util import apiclient
+from config import Config
+
+def create_app(test_config=None):
+    # create and configure the app
+    app = Flask(__name__, instance_relative_config=True)
+
+    assets = Environment(app)
+
+    home_css = Bundle(
+        'css/lib/reset.css',
+        'css/lib/built-in.css',
+        'css/lib/jquery-ui-custom.css',
+        'css/lib/jq.gridster.css',
+        'css/lib/jq.jqplot.css',
+        'css/ntnx.css'
+    )
+
+    home_js = Bundle(
+        'js/lib/jquery-2.1.3.min.js',
+        'js/lib/classie.min.js',
+        'js/lib/ntnx-bootstrap.min.js',
+        'js/lib/modernizr.custom.min.js',
+        'js/lib/jquery.jqplot.min.js',
+        'js/lib/jqplot.logAxisRenderer.js',
+        'js/lib/jqplot.categoryAxisRenderer.js',
+        'js/lib/jqplot.canvasAxisLabelRenderer.js',
+        'js/lib/jqplot.canvasTextRenderer.js',
+        'js/lib/jquery.gridster.min.js',
+        'js/ntnx.js'
+    )
+
+    assets.register('home_css',home_css)
+    assets.register('home_js',home_js)
+
+    app.config.from_object(Config)
+
+    if test_config is None:
+        # load the instance config, if it exists, when not testing
+        app.config.from_pyfile('config.py', silent=True)
+    else:
+        # load the test config if passed in
+        app.config.from_mapping(test_config)
+
+    # ensure the instance folder exists
+    try:
+        os.makedirs(app.instance_path)
+    except OSError:
+        pass
+
+    from . import index
+    app.register_blueprint(index.bp)
+
+    from . import ajax
+    app.register_blueprint(ajax.bp)
+
+    return app
+

lab/__init__.py

@@ -0,0 +1,106 @@
+import os
+import json
+import base64
+import sys
+from datetime import datetime
+from datetime import timedelta
+import time
+
+from flask import (
+    Blueprint, flash, g, redirect, render_template, request, session, url_for, jsonify
+)
+from werkzeug.security import check_password_hash, generate_password_hash
+
+from .util import apiclient
+
+bp = Blueprint('ajax', __name__, url_prefix='/ajax')
+
+"""
+get the form POST data provided by the user
+"""
+def get_form():
+    global form_data
+    global cvmAddress
+    global username
+    global password
+    form_data = request.form
+    cvmAddress = form_data['_cvmAddress']
+    username = form_data['_username']
+    password = form_data['_password']
+
+"""
+load the default layout at app startup
+"""
+@bp.route('/load-layout',methods=['POST'])
+def load_layout():
+    site_root = os.path.realpath(os.path.dirname(__file__))
+    layout_path = 'static/layouts'
+    dashboard_file = 'dashboard.json'
+    with open( f'{site_root}/{layout_path}/{dashboard_file}','r') as f:
+        raw_json = json.loads(f.read())
+        return base64.b64decode(raw_json['layout']).decode('utf-8')
+
+"""
+get some high level cluster info
+"""
+@bp.route('/cluster-info',methods=['POST'])
+def cluster_info():
+    # get the request's POST data
+    get_form()
+    client = apiclient.ApiClient('post', cvmAddress,'clusters/list','{"kind":"cluster"}',username,password)
+    results = client.get_info()
+    return jsonify(results)
+
+"""
+get the vm count
+"""
+@bp.route('/vm-info',methods=['GET','POST'])
+def vm_info():
+    # get the request's POST data
+    get_form()
+    client = apiclient.ApiClient('get', cvmAddress,'vms','',username,password,'v2.0')
+    results = client.get_info()
+    return jsonify(results)
+
+"""
+get the cluster's physical info e.g. # of hosts, host serial numbers
+"""
+@bp.route('/physical-info',methods=['POST'])
+def physical_info():
+    # get the request's POST data
+    get_form()
+    client = apiclient.ApiClient('get', cvmAddress,'hosts','',username,password,'v2.0')
+    results = client.get_info()
+    return jsonify(results)
+
+"""
+get the cluster's storage performance
+"""
+@bp.route('/storage-performance',methods=['POST'])
+def storage_performance():
+    # get the request's POST data
+    get_form()
+
+    # get the current time then substract 4 hours
+    # this is used for the storage performance chart
+    endTime = datetime.now()
+    delta = timedelta(hours=-4)
+    startTime = endTime + delta
+    endTime = round(time.mktime(endTime.timetuple()) * 1000 * 1000)
+    startTime = round(time.mktime(startTime.timetuple()) * 1000 * 1000)
+
+    client = apiclient.ApiClient('get',cvmAddress,f'cluster/stats/?metrics=controller_avg_io_latency_usecs&startTimeInUsecs={startTime}&endTimeInUsecs={endTime}&intervalInSecs=30','',username,password,'v1','PrismGateway/services/rest')
+    results = client.get_info()
+    return jsonify(results)
+
+"""
+get the container info e.g. # of containers
+"""
+@bp.route('/container-info',methods=['POST'])
+def containers():
+    # get the request's POST data
+    get_form()
+    client = apiclient.ApiClient('get',cvmAddress,f'storage_containers','',username,password,'v2.0')
+    results = client.get_info()
+    return jsonify(results)
+

lab/ajax.py

@@ -0,0 +1,13 @@
+from flask_wtf import FlaskForm
+from wtforms import StringField, PasswordField, BooleanField, SubmitField
+from wtforms.validators import DataRequired
+
+"""
+The clusterForm class is used to identify the properties used when submitted cluster details
+"""
+class clusterForm(FlaskForm):
+    cvmAddress = StringField('cvmAddress', validators=[DataRequired()])
+    username = StringField('username', validators=[DataRequired()])
+    password = PasswordField('password', validators=[DataRequired()])
+    submit = SubmitField('Go!', id="goButton")
+

lab/forms.py

@@ -0,0 +1,15 @@
+from lab.forms import clusterForm
+
+from flask import (
+    Blueprint, flash, g, redirect, render_template, request, session, url_for
+)
+from werkzeug.security import check_password_hash, generate_password_hash
+
+bp = Blueprint('index', __name__, url_prefix='/')
+
+@bp.route('/')
+def index():
+    # make sure we are using the form that's been generated in forms.py
+    form = clusterForm()
+    return render_template('index.html', form=form)
+