#Authors: Oulis Evangelos, Oulis Nikolaos, Drosos Katsibras #=================================================================== # using flask restful from flask import Flask, request, jsonify from flask_restful import Resource, Api from json import dumps import json from flask_cors import CORS import mysql.connector from base64 import b64encode from os import urandom import time # ================================================================== # ================================================================== # creating the flask app app = Flask(__name__) CORS(app) # Session list sessions = [] # Chart values chart = [] # creating an API object api = Api(app) # Initialize the database Connection (Classified) class mySqlConnect: def __init__(self): self.con = con = mysql.connector.connect( host = "127.0.0.1",#"q2gen47hi68k1yrb.chr7pe7iynqr.eu-west-1.rds.amazonaws.com", user = "root",#"zsgmj50h7zgz9ioq", password = "rootP",#"omk5l1hrwsgvlcez", database = "PARKING"#"g0s9cnmdkziq6fsp" ) self.cur = self.con.cursor(); def __del__(self): self.cur.close() self.con.close() @property def cursor(self): return self.cur @property def connection(self): return self.con # ================================== # Define our functions. # Define a function that gets the parking status # for all parking codes. def getParkings(): parks = [] sql = mySqlConnect() myCursor = sql.cur myCursor.execute("SELECT * FROM PARKING") myRes = myCursor.fetchall() for res in myRes: if res[1] == 1: parks.append({"no": res[0], "status": True}) else: parks.append({"no": res[0], "status": False}) return parks # Define function that return the usage of parking from whole day. def getUsageParking(): usage = [] sql = mySqlConnect() myCursor = sql.cur values = (time.strftime('%Y-%m-%d') + ' 00:00:00', time.strftime('%Y-%m-%d') + ' 23:59:59') myCursor.execute("SELECT * FROM PARKING_USAGE WHERE PARKING_DATE BETWEEN %s AND %s", values) myRes = myCursor.fetchall() for res in myRes: usage.append({"usage": res[1], "time": str(res[2])}) return usage # Define a function that get if a user with exiting credencials # username and password is authenticated. def isMember(username, password): mysql = mySqlConnect() myCursor = mysql.cur myCursor.execute("SELECT * FROM USERS") myRes = myCursor.fetchall() isValid = False for res in myRes: if res[1] == username and res[2] == password: isValid = True break return isValid # Function that return if the requested user is authenticated # or not (True / False). def isAuthenticated(data): try: if data['cookie'] in sessions: return True else: return False except KeyError as e: return False # For the chart Data. def updateChart(): parks = getParkings() all_parks = len(parks) mysql = mySqlConnect() myCursor = mysql.cur freeParks = 0 for park in parks: if park['status'] == True: freeParks += 1 values = (freeParks, time.strftime('%Y-%m-%d %H:%M:%S')) myCursor.execute("INSERT INTO PARKING_USAGE (PARKING_METER, PARKING_DATE) VALUES (%s, %s)", values) mysql.con.commit() return True # ================================================================== # making a class for a particular resource # the get, post methods correspond to get and post requests # they are automatically mapped by flask_restful. # other methods include put, delete, etc. # Resource that returns th whole parking status in a JSON class Parking(Resource): def get(self): parks = None try: parks = getParkings() except (mysql.connector.errors.DatabaseError, mysql.connector.errors.InterfaceError) as e: print ("An error") return parks, 200 # Update parking status resource from authenticated only Node class ParkingStatus(Resource): def get(self): return """ ERROR

Not get at '/parkingStatus'.

""" def post(self): # Gets the data into as a JSON Object from HTTP request. data = json.loads(request.data) if isAuthenticated(data): try: # SQL get all Parking places status. parks = getParkings() except mysql.connector.errors.DatabaseError as e: mydb.reconnect(attempts=1, delay=0) currentParking = {} for park in parks: if park['no'] == data['no']: currentParking = park break; thereIs = False toUpdate = False try: if currentParking['status'] != data['status']: toUpdate = True thereIs = True except IndexError: # handle Index Error thereIs = False toUpdate = False except KeyError: # handle the KeyError thereIs = False toUpdate = False try: mysql = mySqlConnect() myCursor = mysql.cur con = mysql.con if not thereIs: # Make a new insert entry for a new Parking Code. values = (int(data['no']), int(data['status'])) myCursor.execute("INSERT INTO PARKING (PARKING_CODE, PARKING_STATUS) VALUES (%s, %s)", values) con.commit() parks = getParkings() updateChart() elif toUpdate: # Make an Update status for Parking Code that availability changed. values = (int(data['status']), int(data['no'])) myCursor.execute("UPDATE PARKING SET PARKING_STATUS=%s WHERE PARKING_CODE=%s", values) con.commit() parks = getParkings() updateChart() except (mysql.connector.errors.DatabaseError, mysql.connector.errors.InterfaceError) as e: print ("An error") return currentParking, 201 else: return "Error! You aren't authenticated. [POST] /authenticate first.", 403 # Authentication resource. class Authenticate(Resource): def post(self): try: #Get the credencial from body of request. data = json.loads(request.data) if data['username'] != None and data['password'] != None and data['device'] != None: isValid = isMember(data['username'], data['password']) if isValid: session_key = str(b64encode(urandom(32)).decode('utf-8')) # Send the cookie value back to clinet. session = {"cookie": session_key} sessions.append(session_key) return session, 200 else: return "Not Authenticative device", 403 else: return "Error authentication", 403 except (mysql.connector.errors.DatabaseError, mysql.connector.errors.InterfaceError) as e: print ("An error") # Chart class Chart(Resource): def get(self): result = getUsageParking() return result, 200 # ================================================================== # matches the defined resources to their corresponding urls to REST APIs api.add_resource(Parking, '/') api.add_resource(ParkingStatus, '/parkingStatus') api.add_resource(Authenticate, '/authenticate') api.add_resource(Chart, '/chart') # ================================================================== # ===========================MAIN CLASS============================= # driver function "Main Class" if __name__ == '__main__': app.run( debug=True, host=app.config.get("HOST", "localhost"), port=app.config.get("PORT", "8080") ) # END