1h#SSKrSSKJrJrJrJr SSKJr SSKJ r SSK J r SSK J r SSKJr SSKJr SS KJr \ "5(d\"S 5 \"S 5 SS KJrJrJrJrJrJrJrJrJrJ r J!r!J"r"J#r#J$r$J%r%J&r&J'r'J(r(J)r)J*r*J+r+J,r,J-r-J.r.J/r/J0r0J1r1J2r2J3r3 SS K4J5r5J6r6J7r7J8r8J9r9J:r:J;r;Jr>J?r?J@r@JArAJBrBJCrCJDrD SSKEJFrFJGrGJHrH SSKIJJrJ SSKKJLrL SSKJrJrJr SSKMJNrNJOrOJPrPJQrQJRrRJSrS SSKTJUrU SSKVJWrW \"5rXSS/rY\XR\LR5 \XR\ \YSS/S/S9 \XR\ 5 \"5r\\\R\ SS/S/S9 \XR\5 \XRS\"SS9SS9 \XR\5RSS /S!9 \XR\;RS"S#/S!9 \XR\9RS$S%/S!9 \XR\:RS&S'/S!9 \XR\>RS(S)/S!9 \XR\ARS*S)/S!9 \XR\?RS+S,/S!9 \XR\@RS-S./S!9 \XR\=RS/S0/S!9 \XR\/S!9 \XR\CRS?S@/S!9 \XR\DRSASB/S!9 \XR\JRSCSD/S!9 \XR\HRSESF/S!9 \XR\RSGSH/S!9 \XR\RSISJ/S!9 \XR\RSKSL/S!9 \XR\RSMSN/S!9 \XR\RSOSP/S!9 \XR\ RSQSR/S!9 \XR\!RSSST/S!9 \XR\"RSUSV/S!9 \XR\RSWSX/S!9 \XR\#RSYSZ/S!9 \XR\$RS[S\/S!9 \XR\%RS]S^/S!9 \XR\RS_S`/S!9 \XR\'RSaSb/S!9 \XR\+RScSd/S!9 \XR\&RSeSf/S!9 \XR\(RSgSh/S!9 \XR\)RSiSj/S!9 \XR\*RSkSl/S!9 \XR\0RSmSn/S!9 \XR\1RSoSp/S!9 \XR\2RSqSr/S!9 \XR\3RSsSt/S!9 \XR\,RSuSv/S!9 \XR\-RSwSx/S!9 \XR\.RSySz/S!9 \XR\/RS{S|/S!9 \XRS}5S~\4Sj5rb\XRS5S~\4Sj5rc\XRS5S~\4Sj5rd\XRS5S~\4Sj5re\XRS5S5rg\XRS5S5rhS/ri\XRS5S\4Sj5rkg)N)FastAPIRequest HTTPException WebSocket)RedirectResponse)CORSMiddleware) load_dotenv)InputSanitizationMiddleware) StaticFiles)BaseHTTPMiddleware)rzSCould not load .env file or it is empty. Please check if it exists and is readable.)booking customers marketplaceservices workforceworkforcecategory pricingrulesvehiclesfleetsvendorsworkforcevehicleworkforcetimesheetcustomer_accountstasks schedulespayment availabilityapplinksui monitoring communication iotdevices geofences geofencerulesgeofence_rule_mapping integrationslanguage_regionalaccount_settings subscription)accounts subscriptionssupportsupportcustomerusersroleslogin dashboardauditrbacappflowpartnerscommoninvoicesactivitycommunication_email)crmcommticket)crud)auth)rrr)websocket_tracking_datawebsocket_realtime_updatesstart_kafka_producerstop_kafka_producerwebsocket_historical_routewebsocket_workforce_schedules)consume_tracking_data)KafkaConnectionErrorzhttp://localhost:3000zhttps://www.movex.aiT*) allow_originsallow_credentials allow_methods allow_headers)rJrKrLz/publicpublic) directory)namez /v1/accountsAccounts)prefixtagsz/v1/authLoginz /v1/usersUsersz /v1/rolesRolesz/v1/rbacRBACz /v1/commonz /v1/appflowAppsz /v1/partnersPartnersz /v1/auditAuditz /v1/dashboard Dashboardz/v1/saaszsubscription-typesz/v1/subscriptions Subscriptionsz /v1/invoicesz SaaS Invoicesz /v1/supportSupportz/v1/supportcustomerzCustomer Supportz /v1/cx/crmCRMz /v1/activityActivityz /v1/emailszCommunication Emailz/v1/crudr>z /v1/ticketTicketz /v1/servicesServicesz /v1/workforce Workforcez/v1/workforcecategoryzWorkforce Categoryz/v1/vehicle-modelsVehiclesz /v1/fleetsFleetsz /v1/vendorsVendorsz/v1/workforcevehiclezWorkforce Vehiclez/v1/workforcetimesheetzWorkforce Timesheetz /v1/customers Customersz/v1/customer_accountszCustomer Accountsz /v1/tasksTasksz /v1/schedules Schedulesz/v1/pricingrulesz Pricing Rulesz/v1/availability Availabilityz/v1/communication Communicationz /v1/paymentPaymentz /v1/applinksz App Linksz/v1/uiUIz/v1/monitoring Monitoringz/v1/integrations Integrationsz/v1/language_regionalzLanguage & Regionalz/v1/account_settingszAccount Settingsz/v1/subscription Subscriptionz/v1/iotdevicesz IoT Devicesz /v1/geofences Geofencesz/v1/geofenceruleszGeofence Rulesz/v1/geofence_rule_mappingzGeofence Rule Mappingz/ws/tracking_data websocketc6# [U5IShvN gN7fN)r@rps 2C:\Suresh\moveshuttle\MDcreated\moveengine\main.pytracking_data_socketrus !) ,,, z /ws/realtimec6# [U5IShvN gN7frr)rArss rtrealtime_updates_socketrx $Y ///rvz/ws/historical_routec6# [U5IShvN gN7frr)rDrss rthistorical_route_socketr{ryrvz/ws/workforceschedule-updatesc6# [U5IShvN gN7frr)rErss rtrealtime_updatesr}s ' 222rvstartupc# [5IShvN [R"[55 gN#![an[ SU5 SnAgSnAff=f7f)Nz-Kafka not available, skipping producer start:)rBasyncio create_taskrFrGprint)es rt startup_eventrsMB"$$$134 % B =qAABs7A 75"7A7 A A AAAshutdownc4# [5IShvN gN7frr)rCrtshutdown_eventrs  s z 127.0.0.1httprequestc.# URRnURRR S5(d*URRR S5(aU[ ;a [ SSS9eU"U5IShvN nU$N7f)Nz/docsz/redoci Forbidden) status_codedetail)clienthosturlpath startswith allowed_ipsr)r call_next client_ipresponses rtrestrict_accessrsu##I{{""7++w{{/?/?/J/J8/T/T K 'C D Dw''H O(sB B B B)lrfastapirrrrfastapi.responsesrfastapi.middleware.corsrdotenvr app.middlewarer fastapi.staticfilesr starlette.middleware.baser starlette.exceptionsStarletteHTTPExceptionrexitapp.v1.routers.platformrrrrrrrrrrrrrrrrrrr r!r"r#r$r%r&r'r(r)r*app.v1.routers.saasr+r,r-r.r/r0r1r2r3r4r5r6r7r8r9r:app.v1.routers.cxr;r<r=app.v1.routersr>app.v1.dependenciesr?app.v1.sockets.tracking_datar@rArBrCrDrEapp.v1.consumers.kafka_consumerrFaiokafka.errorsrGapporiginsadd_middlewareAuthMiddlewareopen_cors_routerexception_handlermountinclude_routerrouterrprurxr{r}on_eventrrr middlewarerrrrtrs>>.26+8H}} _`G0/ B0 i  4&&'%% ./9%%  ,- )[848 D8??> M5<< 'C5<< 7)D5<< 7)D4;;zA6==VHE7>>-vhG8??> M5<< 7)D9##O;-P='' BVAWX=''0C?J[\8??>@QR7>>-ykJ?))2GOaNbc3::l%A8??> M&--lJ_I`a4;;zA6==XJG8??> M9##O;-P$++4KSgRhi8??+?zlS6==XJG7>>-ykJ#**3IQdPef%,,5MUjTkl9##O;-P$++4KSfRgh5<< 7)D9##O;-P<&&/AHYZ<&&/AHXY=''0C?J[\7>>-ykJ8??> N299XTF;:$$-=\NS<&&/AHXY$++4KShRij#**3IQcPde<&&/AHXY:$$-=]OT9##O;-P=''0CK[J\](//8S[rZst"#-)-$-~0Y00%&0Y0'0./3i303iBBj  m 7r