Finally working

Berksfile

@@ -0,0 +1,3 @@
+source 'https://supermarket.chef.io'
+
+metadata

README.md

@@ -0,0 +1,4 @@
+# aar
+
+TODO: Enter the cookbook description here.
+

attributes/default.rb

@@ -0,0 +1,18 @@
+default['aar']['required-packages'] = [ 'unzip',
+                                        'curl',
+                                        'apache2',
+                                        'mysql-server',
+                                        'libapache2-mod-wsgi',
+                                        'python-mysqldb',
+                                        'python-pip' ]
+
+# Usernames and passwords; should refactor to databag or vault
+default['aar']['web-user'] = 'www-data'
+default['aar']['web-group'] = 'www-data'
+default['aar']['mysql-host'] = 'localhost'
+default['aar']['mysql-root-user'] = 'root'
+default['aar']['mysql-root-password'] = '' # Using default MySQL root password; should be changed and refactored
+default['aar']['app-db'] = 'AARdb'
+default['aar']['app-db-user'] = 'aarapp'
+default['aar']['app-db-password'] = 'Also5uper5ecret'
+default['aar']['app-db-secret'] = 'Really5uper5ecret'

chefignore

@@ -0,0 +1,102 @@
+# Put files/directories that should be ignored in this file when uploading
+# to a chef-server or supermarket.
+# Lines that start with '# ' are comments.
+
+# OS generated files #
+######################
+.DS_Store
+Icon?
+nohup.out
+ehthumbs.db
+Thumbs.db
+
+# SASS #
+########
+.sass-cache
+
+# EDITORS #
+###########
+\#*
+.#*
+*~
+*.sw[a-z]
+*.bak
+REVISION
+TAGS*
+tmtags
+*_flymake.*
+*_flymake
+*.tmproj
+.project
+.settings
+mkmf.log
+
+## COMPILED ##
+##############
+a.out
+*.o
+*.pyc
+*.so
+*.com
+*.class
+*.dll
+*.exe
+*/rdoc/
+
+# Testing #
+###########
+.watchr
+.rspec
+spec/*
+spec/fixtures/*
+test/*
+features/*
+examples/*
+Guardfile
+Procfile
+.kitchen*
+.rubocop.yml
+spec/*
+Rakefile
+.travis.yml
+.foodcritic
+.codeclimate.yml
+
+# SCM #
+#######
+.git
+*/.git
+.gitignore
+.gitmodules
+.gitconfig
+.gitattributes
+.svn
+*/.bzr/*
+*/.hg/*
+*/.svn/*
+
+# Berkshelf #
+#############
+Berksfile
+Berksfile.lock
+cookbooks/*
+tmp
+
+# Cookbooks #
+#############
+CONTRIBUTING*
+CHANGELOG*
+TESTING*
+MAINTAINERS.toml
+
+# Strainer #
+############
+Colanderfile
+Strainerfile
+.colander
+.strainer
+
+# Vagrant #
+###########
+.vagrant
+Vagrantfile

files/default/AAR/awesomeapp.py

@@ -0,0 +1,216 @@
+#!/usr/bin/python
+# -*- coding: utf-8 -*-
+
+#### copyright, Opscode Inc. ####
+# Apache License
+# Version 2.0, January 2004
+# http://www.apache.org/licenses/
+#################################
+
+from functools import wraps
+from hashlib import sha1
+from pprint import pprint
+from flask import Flask, request, flash, Response, session, g, jsonify, redirect, url_for, abort, render_template
+import MySQLdb
+from AAR_config import SECRET_KEY, CONNECTION_ARGS, DB_VALUES
+
+app = Flask(__name__)
+app.config['SECRET_KEY'] = SECRET_KEY
+
+def logged_in(f):
+    @wraps(f)
+    def decorated_function(*args, **kwargs):
+        if session.get('logged_in') is not None:
+            return f(*args, **kwargs)
+        else:
+            flash('Please log in first...', 'error')
+            return redirect(url_for('login'))
+
+    return decorated_function
+
+@app.route('/logout')
+def logout():
+    session.pop('username', None)
+    session.pop('role', None)
+    session.pop('logged_in', None)
+    return redirect(url_for('login'))
+
+def populate_db(ip):
+    db = MySQLdb.connect(**CONNECTION_ARGS)
+    cur = db.cursor()
+    for x in DB_VALUES:
+        cur.execute("insert into jobs (j_ip,cid, make, appliance, appointment, job_status, description) values (%s,%s,%s,%s,%s,%s,%s)", (ip,x[0],x[1],x[2],x[3],x[4],x[5]))
+    db.commit()
+    cur.close()
+
+@app.route('/resetdb', methods=['POST'])
+def resetdb():
+    IPadd = request.environ['REMOTE_ADDR']
+    db = MySQLdb.connect(**CONNECTION_ARGS)
+    cur = db.cursor()
+    cur.execute("select j_ip from jobs where j_ip = %s limit 1", IPadd)
+    if cur.fetchone() > 0:
+        rows = cur.execute("delete from jobs where j_ip = %s", (IPadd))
+        db.commit()
+        cur.close()
+
+        populate_db(IPadd)
+        return jsonify({'IP': IPadd,'rows_deleted': rows})
+    else:
+        return jsonify({'no_action': True})
+
+@app.route('/', methods=['GET', 'POST'])
+def login():
+    login_error = '''I'm sorry. I can't find that combination of credentials in my database. Perhaps you mis-typed your password?'''
+    error = None
+    IPadd = request.environ['REMOTE_ADDR']
+    db = MySQLdb.connect(**CONNECTION_ARGS)
+    cur = db.cursor()
+
+    if request.method == 'POST':
+        uname = request.form['username']
+        upswd = request.form['password']
+        upw = sha1(upswd).hexdigest()
+
+        rows = cur.execute("select uname, pw, role from users where uname = %s",(uname,))
+
+        if rows > 0:
+            users_name, pw_hash, role = cur.fetchone()
+        if rows == 0 or uname != users_name or upw != pw_hash:
+            error = login_error
+        else:
+            session['logged_in'] = True
+            session['username'] = uname
+            session['role'] = role
+
+            cur.execute("select j_ip from jobs where j_ip = %s limit 1", IPadd)
+            if not cur.fetchone() > 0:
+                populate_db(IPadd)
+
+            if session['role'] == 'admin':
+                return redirect(url_for('dispatcher'))
+            elif session['role'] == 'customer':
+                return redirect(url_for('repairRequest'))
+        cur.close()
+    return render_template('login.html', error=error)
+
+@app.route('/dispatcher', methods=['GET', 'POST'])
+@logged_in
+def dispatcher():
+    error = None
+    db = MySQLdb.connect(**CONNECTION_ARGS)
+    cur = db.cursor()
+    IPadd = request.environ['REMOTE_ADDR']
+    if session.get('role') != 'admin':
+        flash( 'please log in first' )
+        return logout()
+
+
+    ##POST
+    if request.method == 'POST':
+        jid = request.form['job_id']
+        field = request.form['field_value']
+        new_value = request.form['new_value']
+        set_job_status = "update jobs set job_status = %s where j_id=%s and j_ip=%s"
+        set_appointment = "update jobs set appointment = %s where j_id=%s and j_ip=%s"
+
+        if new_value.upper() == 'NULL' or new_value.upper() == 'NONE': new_value = None
+        query = set_job_status if field == 'job_status' else set_appointment
+
+        try:
+            affected_count = cur.execute(query, (new_value, jid, IPadd))
+            db.commit()
+            if affected_count > 0: flash( 'your update was successful' )
+        except MySQLdb.IntegrityError:
+            error = "failed to update job ID: %s" % (jid,)
+        finally:
+            cur.close()
+
+        return redirect(url_for('dispatcher'))
+
+    ##GET
+    else:
+        cur.execute("select j.j_id, c.cid, c.lname, j.make, j.appliance, j.job_status, j.appointment, j.description from jobs j, customer c where j.cid = c.cid and j.j_ip=%s", IPadd)
+        result = cur.fetchall()
+
+        return render_template("dispatcher.html",
+            error = error,
+            title = "Dispatcher Interface",
+            user = session['username'],
+            result = result)
+
+@app.route('/repairRequest', methods=['GET', 'POST'])
+@logged_in
+def repairRequest():
+    if session.get('role') != 'customer':
+        flash( 'please log in first' )
+        return logout()
+
+    session.permanent = False
+    error = None
+    user = session.get('username')
+    IPadd = request.environ['REMOTE_ADDR']
+    db = MySQLdb.connect(**CONNECTION_ARGS)
+    cur = db.cursor()
+    rows = cur.execute("select c.fname, c.lname, u.cid from customer c, users u where u.uname = %s and u.cid = c.cid",(user,))
+    if rows > 0:
+        fname, lname, cid = cur.fetchone()
+    else:
+        return logout()
+
+    #POST
+    if request.method == 'POST':
+        make = request.form['make'].strip()
+        type = request.form['type'].strip()
+        description = request.form['description'].strip()
+        appointment = None
+        job_status = 'pending'
+
+        rows = cur.execute("insert into jobs (j_ip,cid, make, appliance, appointment, job_status, description) values\
+            (%s, %s, %s, %s, %s, %s, %s)", (IPadd, cid, make, type, appointment, job_status, description))
+        db.commit()
+        if rows == 0:
+            error = "Your repair request failed."
+
+        rows = cur.execute("select j_id, make, appliance, job_status, appointment from jobs where cid = %s and j_ip = %s", (cid, IPadd))
+        result = cur.fetchall()
+        cur.close()
+        flash("Your request has been added to the database.")
+
+        return render_template("repairRequest.html",
+            title = "Repair Request",
+            user = user,
+            fname = fname,
+            lname = lname,
+            result = result,
+            error = error)
+
+    #GET
+    else:
+        cur.execute("select j_id, make, appliance, job_status, appointment from jobs where j_ip = %s and cid = %s", (IPadd, cid))
+        result = cur.fetchall()
+
+        return render_template("repairRequest.html",
+            title = "Repair Request",
+            user = user,
+            fname = fname,
+            lname = lname,
+            error = error,
+            result = result)
+        cur.close()
+
+##### Shut down the simple server from the browser address bar #####
+def shutdown_server():
+    func = request.environ.get('werkzeug.server.shutdown')
+    if func is None:
+        raise RuntimeError('Not running with the Werkzeug Server')
+    func()
+
+@app.route('/shutdown', methods=['GET'])
+def shutdown():
+    shutdown_server()
+    return 'Server shutting down...'
+
+if __name__ == "__main__":
+    app.config['DEBUG'] = True 
+    app.run(port=9229)

files/default/AAR/awesomeapp.wsgi

@@ -0,0 +1,7 @@
+#!/usr/bin/python
+# -*- coding: utf-8 -*-
+
+import sys
+sys.path.insert(0, '/var/www/AAR')
+from awesomeapp import app as application
+

files/default/AAR/robots.txt

@@ -0,0 +1,2 @@
+User-agent: *
+Disallow: /