1h#ddlZddlmZmZmZmZddlmZddlm Z ddl m Z ddl m Z ddlmZddlmZdd lmZe sed ed dd lmZmZmZmZmZmZmZmZmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3dd l4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@mAZAmBZBmCZCmDZDddlEmFZFmGZGmHZHddlImJZJddlKmLZLddlmZmZmZddlMmNZNmOZOmPZPmQZQmRZRmSZSddlTmUZUddlVmWZWeZXddgZYeXjeLjeXje eYddgdgeXje eZ\e\je ddgdgeXjeeXjdeddeXje5jdd g!eXje;jd"d#g!eXje9jd$d%g!eXje:jd&d'g!eXje>jd(d)g!eXjeAjd*d)g!eXje?jd+d,g!eXje@jd-d.g!eXje=jd/d0g!eXjeg!eXjeCjd?d@g!eXjeDjdAdBg!eXjeJjdCdDg!eXjeHjdEdFg!eXjejdGdHg!eXjejdIdJg!eXjejdKdLg!eXjejdMdNg!eXjejdOdPg!eXje jdQdRg!eXje!jdSdTg!eXje"jdUdVg!eXjejdWdXg!eXje#jdYdZg!eXje$jd[d\g!eXje%jd]d^g!eXjejd_d`g!eXje'jdadbg!eXje+jdcddg!eXje&jdedfg!eXje(jdgdhg!eXje)jdidjg!eXje*jdkdlg!eXje0jdmdng!eXje1jdodpg!eXje2jdqdrg!eXje3jdsdtg!eXje,jdudvg!eXje-jdwdxg!eXje.jdydzg!eXje/jd{d|g!eXjd}d~efdZbeXjdd~efdZceXjdd~efdZdeXjdd~efdZeeXjddZgeXjddZhdgZieXjddefdZky)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 websocketc6Kt|d{y7wN)r@rps 2C:\Suresh\moveshuttle\MDcreated\moveengine\main.pytracking_data_socketrus !) ,,, z /ws/realtimec6Kt|d{y7wrr)rArss rtrealtime_updates_socketrx $Y ///rvz/ws/historical_routec6Kt|d{y7wrr)rDrss rthistorical_route_socketr{ryrvz/ws/workforceschedule-updatesc6Kt|d{y7wrr)rErss rtrealtime_updatesr}s ' 222rvstartupcK td{tjty7"#t$r}t d|Yd}~yd}~wwxYww)Nz-Kafka not available, skipping producer start:)rBasyncio create_taskrFrGprint)es rt startup_eventrsNB"$$$134 % B =qAABs6A 64!6A6 A A AAAshutdownc4Ktd{y7wrr)rCrtshutdown_eventrs  s z 127.0.0.1httprequestcK|jj}|jjj ds%|jjj dr|t vr t dd||d{}|S7w)Nz/docsz/redoci Forbidden) status_codedetail)clienthosturlpath startswith allowed_ipsr)r call_next client_ipresponses rtrestrict_accessrsp##I{{""7+w{{/?/?/J/J8/T K 'C D Dw''H O(sBB 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