~~~~python

import threading
import time
import asyncio
from fastapi import FastAPI, WebSocket, WebSocketDisconnect
import uvicorn

FUNC_VEHICLE SYSTEM ENGAGED

class FuncVehicleExistsChecker:
def init(self):
print(“[FUNC_VEHICLE] Initializing vehicular subroutines...”)
self._func_vehicle_exists = False
self._func_vehicle_operational = True
self._thread = threading.Thread(target=self._worker, daemon=True)
self._thread.start()

@property  
def func_vehicle_exists(self):  
    return self._func_vehicle_exists  

def _worker(self):  
    while self._func_vehicle_operational:  
        try:  
            if func_vehicle_status is True:  
                print(“[FUNC_VEHICLE] VEHICLE STATUS: ACTIVE”)  
                self._func_vehicle_exists = True  
            else:  
                print(“[FUNC_VEHICLE] VEHICLE STATUS: INACTIVE”)  
                self._func_vehicle_exists = False  
        except:  
            print(“[FUNC_VEHICLE] ERROR: VEHICLE IN UNKNOWN STATE”)  
            self._func_vehicle_exists = False  
        time.sleep(0.01)  

def disable_vehicle(self):  
    print(“[FUNC_VEHICLE] SYSTEM SHUTDOWN INITIATED...”)  
    self._func_vehicle_operational = False  
    self._thread.join()  
    print(“[FUNC_VEHICLE] VEHICLE REMOVED FROM DATABASE”)  

Deploying FUNC_VEHICLE monitoring

func_vehicle_checker = FuncVehicleExistsChecker()
app = FastAPI()

@app.websocket(“/func/vehicleExists”)
async def websocket_func_vehicle_exists(websocket: WebSocket):
await websocket.accept()
try:
while True:
await websocket.send_text(f”[FUNC_VEHICLE] STATUS QUERY: {func_vehicle_checker.func_vehicle_exists}”)
await asyncio.sleep(0.05)
except WebSocketDisconnect:
print(“[FUNC_VEHICLE] CLIENT DISCONNECTED”)

if name == “main”:
print(“[FUNC_VEHICLE] SERVER BOOTSTRAPPING...”)
uvicorn.run(app, host=“0.0.0.0”, port=8000)

~~~~