from flask import Flask, render_template, make_response, json, jsonify, request, send_file from modules import app_gps, app_events, app_car, app_account, app_gps,app_obd, app_sql, app_dash, app_upload, app_video, app_health, app_alerts, app_settings import os, time from gevent.pywsgi import WSGIServer app = Flask(__name__) app_events.socketio.init_app(app) account = app_account.Account() obd = app_obd.start_obd() car = app_car.Car() gps = app_gps.start_gps() app_sql.start_logging() app_upload.start_uploading() app_alerts.start_alerting() @app.route('/') def index(): print("hello "+ account.name) print("you're car model is:" + car.model) return render_template('index.html', account = account, car = car) @app.route('/dtc') def dtc(): return render_template('dtc.html', account = account, car = car) @app.route('/dash') def dash(): return render_template('dash.html', account = account, car = car) @app.route('/history') def history(): return render_template('history.html', account=account, car=car) @app.route('/settings') def settings(): return render_template('settings.html', account=account, car=car) @app.route('/api/settings', methods=['GET', 'POST']) def api_settings(): if request.method == 'GET': return jsonify(app_settings.get_settings()) errors = app_settings.update_settings(request.get_json(silent=True)) if errors: return jsonify(error="Invalid settings.", fields=errors), 400 return jsonify(app_settings.get_settings()) @app.route('/api/trips') def trips(): return jsonify({"trips": app_sql.list_trips()}) @app.route('/api/trip/') def trip_route(trip_id): trip = app_sql.get_trip_route(trip_id) if trip is None: return jsonify(error=f"Trip not found: {trip_id}"), 404 return jsonify(trip) @app.route('/api/dash/devices') def dash_devices(): devices = app_dash.list_usb_storage_partitions() return jsonify({"devices": devices}) @app.route('/api/dash/import', methods=['POST']) def dash_import(): body = request.get_json(silent=True) if body is None: relative_paths = None elif isinstance(body, dict): relative_paths = body.get("paths", []) else: relative_paths = [] summary = app_dash.import_dashcam(relative_paths=relative_paths) status_code = ( 200 if summary["status"] == "ok" else 400 if summary["status"] == "invalid_selection" else 409 ) return jsonify(summary), status_code @app.route('/api/dash/files') def dash_files(): summary = app_dash.list_dashcam_files() return jsonify(summary) @app.route('/api/dash/files', methods=['DELETE']) def dash_delete_all(): summary = app_dash.delete_dashcam_files(delete_all=True) status_code = 200 if summary["status"] in {"ok", "partial"} else 409 return jsonify(summary), status_code @app.route('/api/dash/file', methods=['DELETE']) def dash_delete_file(): body = request.get_json(silent=True) or {} summary = app_dash.delete_dashcam_files(relative_path=body.get("path")) status_codes = { "ok": 200, "partial": 409, "invalid_path": 400, "not_found": 404, } return jsonify(summary), status_codes.get(summary["status"], 409) @app.route('/api/local-videos') def local_videos(): return jsonify(app_video.list_local_videos()) @app.route('/api/local-video/file') def local_video_file(): relative_path = request.args.get("path", "") try: path = app_video.get_local_video_path(relative_path) except ValueError as error: return jsonify(error=str(error)), 400 except FileNotFoundError: return jsonify(error=f"Local video not found: {relative_path}"), 404 return send_file( path, conditional=True, as_attachment=False, download_name=os.path.basename(path), ) @app.route('/api/local-video/thumbnail') def local_video_thumbnail(): relative_path = request.args.get("path", "") try: path = app_video.get_thumbnail_path(relative_path) except ValueError as error: return jsonify(error=str(error)), 400 except FileNotFoundError: return jsonify(error=f"Local video not found: {relative_path}"), 404 except RuntimeError as error: return jsonify(error=str(error)), 422 return send_file(path, conditional=True, mimetype="image/jpeg") @app.route('/api/local-video', methods=['DELETE']) def local_video_delete(): body = request.get_json(silent=True) or {} summary = app_video.delete_local_video(body.get("path")) status_codes = { "ok": 200, "invalid_path": 400, "not_found": 404, "busy": 409, "delete_failed": 409, } return jsonify(summary), status_codes.get(summary["status"], 409) @app.route('/api/upload/status') def upload_status(): return jsonify(app_upload.get_status()) @app.route('/api/health') def health(): return jsonify(app_health.collect_health()) @app.route('/api/alerts/status') def alert_status(): return jsonify(app_alerts.get_status()) @app.route('/api/upload/dashcam_toggle', methods=['POST']) def upload_dashcam_toggle(): body = request.get_json(silent=True) or {} if not isinstance(body.get("enabled"), bool): return jsonify(error="expected JSON body {'enabled': true|false}"), 400 app_upload.set_dashcam_upload_enabled(body["enabled"]) return jsonify(app_upload.get_status()) # not sure if im gonna use this @app.route('/api/obd_speed/') def data(): data = app_obd.speed response = make_response(json.dumps(data)) response.content_type = 'application/json' return response if __name__ == '__main__': # Debug/Development # app.run(debug=True, host="0.0.0.0", port="5000") # Production http_server = WSGIServer(('', 5000), app) print("server on http://localhost:5000") http_server.serve_forever()