feat: ✨ implemented api, implemented creating driver and vehicle entity, added db models for entities
This commit is contained in:
parent
2f86b4c434
commit
c4de1d11ec
4
.vscode/settings.json
vendored
4
.vscode/settings.json
vendored
@ -1,5 +1,9 @@
|
|||||||
{
|
{
|
||||||
"cSpell.words": [
|
"cSpell.words": [
|
||||||
"sessionmaker"
|
"sessionmaker"
|
||||||
|
],
|
||||||
|
"python.analysis.extraPaths": [
|
||||||
|
"./class/model",
|
||||||
|
"./class"
|
||||||
]
|
]
|
||||||
}
|
}
|
133
app.py
133
app.py
@ -1,59 +1,144 @@
|
|||||||
|
from driverHandler import DriverHandler
|
||||||
from gpxInterpreter import GPXHandler
|
from gpxInterpreter import GPXHandler
|
||||||
|
from vehicleHandler import VehicleHandler
|
||||||
from dotenv import load_dotenv
|
from dotenv import load_dotenv
|
||||||
from flask import Flask, send_from_directory, jsonify, request
|
from flask import Flask, app, send_from_directory, request
|
||||||
from sqlalchemy import create_engine
|
from sqlalchemy import NullPool, create_engine
|
||||||
from sqlalchemy.orm import sessionmaker
|
from sqlalchemy.orm import sessionmaker, Session
|
||||||
|
from geoObjects import createTables
|
||||||
|
|
||||||
Session: Session
|
__session: Session
|
||||||
app: any
|
FlaskApp: app
|
||||||
|
__gpxHandler: GPXHandler
|
||||||
|
__driverHandler: DriverHandler
|
||||||
|
__vehicleHandler: VehicleHandler
|
||||||
|
|
||||||
def entry():
|
|
||||||
|
def entryPoint():
|
||||||
print("load environment")
|
print("load environment")
|
||||||
load_dotenv()
|
load_dotenv()
|
||||||
|
|
||||||
print("create flask application")
|
print("create flask application")
|
||||||
app = Flask(__name__, static_folder='web/dist')
|
FlaskApp = Flask(__name__, static_folder='web/dist')
|
||||||
|
|
||||||
# TODO: all the sqlalchemy stuff should be moved out of app.py
|
|
||||||
Base = declarative_base()
|
|
||||||
|
|
||||||
def db_connect(connectionPath):
|
def db_connect(connectionPath):
|
||||||
return create_engine(connectionPath, poolclass=NullPool)
|
return create_engine(connectionPath, poolclass=NullPool)
|
||||||
|
|
||||||
Base.metadata.create_all(db_connect)
|
__session = sessionmaker(bind=db_connect())()
|
||||||
session = sessionmaker(bind=db_connect())()
|
|
||||||
|
|
||||||
# handler class for all gpx files
|
# handler classes
|
||||||
# handles parsing files and interacting with database
|
# handles parsing files and interacting with database
|
||||||
gpxHandler = GPXHandler(session)
|
__gpxHandler = GPXHandler(__session)
|
||||||
|
__driverHandler = DriverHandler(__session)
|
||||||
|
__vehicleHandler = VehicleHandler(__session)
|
||||||
|
|
||||||
|
# creating tables
|
||||||
|
createTables(__session)
|
||||||
|
|
||||||
app.run(debug=True)
|
app.run(debug=True)
|
||||||
|
|
||||||
# TODO: move functional parts out to api package if not handled by other classes
|
# TODO: move functional parts out to api package if not handled by other classes
|
||||||
@app.route('/')
|
|
||||||
def serve_vue_app():
|
|
||||||
return send_from_directory(app.static_folder, 'index.html')
|
|
||||||
|
|
||||||
@app.route("/route", method=['GET'])
|
|
||||||
|
@FlaskApp.route('/')
|
||||||
|
def serve_vue_app():
|
||||||
|
return send_from_directory(FlaskApp.static_folder, 'index.html')
|
||||||
|
|
||||||
|
|
||||||
|
@FlaskApp.route("/route", method=['GET'])
|
||||||
def getRoute():
|
def getRoute():
|
||||||
# TODO: will contact gpx handler to get geoJSON from
|
# TODO: will contact gpx handler to get geoJSON from
|
||||||
return "not implemented", 500
|
return "not implemented", 500
|
||||||
|
|
||||||
@app.route('/upload', methods=['POST'])
|
|
||||||
|
@FlaskApp.route("/driver", methods=['GET', 'POST'])
|
||||||
|
def handleDriverRoute():
|
||||||
|
|
||||||
|
if request.method == "GET":
|
||||||
|
if 'driver' in request.args:
|
||||||
|
|
||||||
|
try:
|
||||||
|
__driverHandler.getVehicle(int(request.args["driver"]))
|
||||||
|
# return drivers, 200
|
||||||
|
except Exception as e:
|
||||||
|
return "error" + " " + str(e), 500
|
||||||
|
|
||||||
|
else:
|
||||||
|
|
||||||
|
try:
|
||||||
|
__driverHandler.getVehicles()
|
||||||
|
# return drivers, 200
|
||||||
|
except Exception as e:
|
||||||
|
return "error" + " " + str(e), 500
|
||||||
|
|
||||||
|
elif request.method == "POST":
|
||||||
|
if "name" not in request.args:
|
||||||
|
return "missing name", 400
|
||||||
|
|
||||||
|
# handle creating vehicle
|
||||||
|
try:
|
||||||
|
__driverHandler.createVehicle(request.args["name"])
|
||||||
|
except Exception as e:
|
||||||
|
return "error" + " " + str(e), 500
|
||||||
|
|
||||||
|
return "not implemented", 500
|
||||||
|
|
||||||
|
|
||||||
|
@FlaskApp.route("/vehicle", methods=['GET', 'POST'])
|
||||||
|
def handleVehicleRoute():
|
||||||
|
|
||||||
|
if request.method == "GET":
|
||||||
|
if 'vehicle' in request.args:
|
||||||
|
|
||||||
|
try:
|
||||||
|
__vehicleHandler.getVehicle(int(request.args["driver"]))
|
||||||
|
# return drivers, 200
|
||||||
|
except Exception as e:
|
||||||
|
return "error" + " " + str(e), 500
|
||||||
|
|
||||||
|
else:
|
||||||
|
|
||||||
|
try:
|
||||||
|
__vehicleHandler.getVehicles()
|
||||||
|
# return drivers, 200
|
||||||
|
except Exception as e:
|
||||||
|
return "error" + " " + str(e), 500
|
||||||
|
|
||||||
|
elif request.method == "POST":
|
||||||
|
if "name" not in request.args:
|
||||||
|
return "missing name", 400
|
||||||
|
|
||||||
|
if "type" not in request.args:
|
||||||
|
return "missing type", 400
|
||||||
|
|
||||||
|
# handle creating vehicle
|
||||||
|
try:
|
||||||
|
__vehicleHandler.createVehicle(
|
||||||
|
request.args["name"], request.args["type"])
|
||||||
|
except Exception as e:
|
||||||
|
return "error" + " " + str(e), 500
|
||||||
|
|
||||||
|
return "not implemented", 500
|
||||||
|
|
||||||
|
|
||||||
|
@FlaskApp.route('/upload', methods=['POST'])
|
||||||
def uploadFile():
|
def uploadFile():
|
||||||
if 'file' not in request.files:
|
if 'file' not in request.files:
|
||||||
return "no file provided", 400
|
return "no file provided", 400
|
||||||
|
|
||||||
|
if request.args["routeName"] == '':
|
||||||
|
return "no routename provided", 400
|
||||||
|
|
||||||
file = request.files['file']
|
file = request.files['file']
|
||||||
if file.filename == '':
|
if file.filename == '':
|
||||||
return "no file selected", 400
|
return "no file selected", 400
|
||||||
|
|
||||||
try:
|
try:
|
||||||
gpx_handler = GPXHandler(file.stream)
|
__gpxHandler.parse(file, request.args["routeName"])
|
||||||
gpx_handler.parse()
|
|
||||||
return "file stored succesfull", 200
|
return "file stored succesfull", 200
|
||||||
except Exception as e:
|
except Exception as e:
|
||||||
return "error" + " " + str(e), 500
|
return "error" + " " + str(e), 500
|
||||||
|
|
||||||
|
|
||||||
if __name__ == '__main__':
|
if __name__ == '__main__':
|
||||||
entry()
|
entryPoint()
|
||||||
|
29
class/driverHandler.py
Normal file
29
class/driverHandler.py
Normal file
@ -0,0 +1,29 @@
|
|||||||
|
from sqlalchemy.orm import Session
|
||||||
|
|
||||||
|
from geoObjects import Driver
|
||||||
|
|
||||||
|
class DriverHandler:
|
||||||
|
__dbSession: Session
|
||||||
|
|
||||||
|
def __init__(self, session:Session):
|
||||||
|
self.__dbSession = session
|
||||||
|
pass
|
||||||
|
|
||||||
|
# handles creating a driver in the database
|
||||||
|
def createDriver(self, name:str):
|
||||||
|
|
||||||
|
# makes sure that a name always is provided
|
||||||
|
if not name:
|
||||||
|
raise ValueError("name is empty")
|
||||||
|
|
||||||
|
self.__dbSession.add(Driver(name=name))
|
||||||
|
self.__dbSession.commit()
|
||||||
|
pass
|
||||||
|
|
||||||
|
# handles getting a driver by its id from the database
|
||||||
|
def getDriver(self, id:int):
|
||||||
|
pass
|
||||||
|
|
||||||
|
# handles getting all drivers from the database
|
||||||
|
def getDrivers(self):
|
||||||
|
pass
|
@ -1,5 +1,6 @@
|
|||||||
import gpxpy
|
import gpxpy
|
||||||
import gpxpy.gpx
|
import gpxpy.gpx
|
||||||
|
from sqlalchemy.orm import Session
|
||||||
|
|
||||||
class GPXHandler:
|
class GPXHandler:
|
||||||
__dbSession: Session
|
__dbSession: Session
|
||||||
@ -16,7 +17,7 @@ class GPXHandler:
|
|||||||
# handles a route from db and converting it into geoJSON
|
# handles a route from db and converting it into geoJSON
|
||||||
def getRoute(self, route):
|
def getRoute(self, route):
|
||||||
pass
|
pass
|
||||||
|
|
||||||
# handles storing a route in db
|
# handles calculating the distance between two points
|
||||||
def saveInDB():
|
def calcDist(self, p1, p2):
|
||||||
pass
|
pass
|
@ -16,8 +16,8 @@ class Track(Base):
|
|||||||
__tablename__ = 'track'
|
__tablename__ = 'track'
|
||||||
id = Column(Integer, primary_key=True, autoincrement=True)
|
id = Column(Integer, primary_key=True, autoincrement=True)
|
||||||
trackName = Column(String(200), nullable=True)
|
trackName = Column(String(200), nullable=True)
|
||||||
vehicle = Column(Integer, ForeignKey('vehicle.id'), nullable=False)
|
vehicle = Column(Integer, ForeignKey('vehicle.id'), nullable=False, default=1)
|
||||||
driver = Column(Integer, ForeignKey('driver.id'), nullable=False)
|
driver = Column(Integer, ForeignKey('driver.id'), nullable=False, default=1)
|
||||||
date = Column(Date, nullable=True)
|
date = Column(Date, nullable=True)
|
||||||
distance = Column(Float, nullable=False, default=0)
|
distance = Column(Float, nullable=False, default=0)
|
||||||
speed = Column(Float, nullable=False, default=0)
|
speed = Column(Float, nullable=False, default=0)
|
||||||
|
30
class/vehicleHandler.py
Normal file
30
class/vehicleHandler.py
Normal file
@ -0,0 +1,30 @@
|
|||||||
|
from sqlalchemy.orm import Session
|
||||||
|
|
||||||
|
from geoObjects import Vehicle
|
||||||
|
|
||||||
|
class VehicleHandler:
|
||||||
|
__dbSession: Session
|
||||||
|
|
||||||
|
def __init__(self, session:Session):
|
||||||
|
self.__dbSession = session
|
||||||
|
pass
|
||||||
|
|
||||||
|
# handles creating a vehicle and storing it in the database
|
||||||
|
def createVehicle(self, name:str, type:str):
|
||||||
|
if not name:
|
||||||
|
raise ValueError("name is empty")
|
||||||
|
|
||||||
|
if not type:
|
||||||
|
raise ValueError("vehicle is empty")
|
||||||
|
|
||||||
|
self.__dbSession.add(Vehicle(name, type))
|
||||||
|
self.__dbSession.commit()
|
||||||
|
pass
|
||||||
|
|
||||||
|
# handles getting a vehicle identified with its id from the database
|
||||||
|
def getVehicle(self, id:int):
|
||||||
|
pass
|
||||||
|
|
||||||
|
# handles getting all vehicles from database
|
||||||
|
def getVehicles(self):
|
||||||
|
pass
|
@ -13,7 +13,7 @@ services:
|
|||||||
networks:
|
networks:
|
||||||
- backend
|
- backend
|
||||||
|
|
||||||
web:
|
GeoTrack:
|
||||||
build: .
|
build: .
|
||||||
ports:
|
ports:
|
||||||
- "8000:5000"
|
- "8000:5000"
|
||||||
|
Loading…
x
Reference in New Issue
Block a user