From 6bdd8f0fe387bd01e7865477e26382b0c06d6eec Mon Sep 17 00:00:00 2001
From: samarthjain2023 <samarthjain2023@vt.edu>
Date: Sat, 27 Sep 2025 19:37:04 -0400
Subject: [PATCH] flask update

---
 roadcast/__pycache__/app.cpython-312.pyc | Bin 7226 -> 8457 bytes
 roadcast/app.py                          |  80 +++++++++++++++++------
 2 files changed, 61 insertions(+), 19 deletions(-)

diff --git a/roadcast/__pycache__/app.cpython-312.pyc b/roadcast/__pycache__/app.cpython-312.pyc
index 74f3523174b5b0f1c4eb86d2916b335f748895db..cf6362d42210994ca806446d08b44b3eb554e0c1 100644
GIT binary patch
delta 3272
zcmZ`*YitwQ6}~g$*Z2`T4?Bqi<R(El-c6hk6rh2&%OeQ_HPFq2hj_^GjFZVaGv>}1
zgKJ~@tFWpBD_6T=MYa4yqCzVnRaN_=R10jYs?r2gi5*dC`}ni}45VsR{`B0LOk!RW
z<=ivpp8K71zI*N+|90n<y|F(B0$v2qU(_e_526VDlfKxGb5(ia{Ur7uhv1lF?_%bG
zyRxf|cl??|sFHNx0|N6=FG3`$+1^NC1x|1X&Ks=Y65QtK0i74TH@Mr3g(>*b>?G3c
zNNB-TQ5>BNU+HRW4*G4c5>rGArfpAP&BhiP!WLOISQoKD2uh6YA%rM4k2IeRUt}zl
zu14F(9!uO?yqfG;dn`HXyx4bQIp6duzlr7Ik<cQ9GoD4h<Yti8zLurij`vz^9d)&}
zTeb0sMMZa!D>{nKqU*N9!YJ`t#~K>1Z9u4Oz20W6k@(h0EAn<Y*ogJb+fd}!!%d<d
zr1@<~t-;pP>}EuoAo=xm4MOw!I=TfZ_Bfg>qdYp#9Y=WvfLiS3uy}LHQ@1#xwc2w<
zkDZp#Dzw#g3{*}bg=ooh(KER^=9xPDwL}3w!XU~{nYJIL$Zo@u*Cfts2PyH#(a%4x
z1F284=anQkzBS2BH&`1>cr(Q^<hq_?yff*718{_hf|SxQQF5AyXGJY9iZa&n3eGB$
ztf_cTItK<-$&r+Zld^yXQPm_lsY!~A^O81?GfB;y$S88c>&5Vlp3jOY&2$+t4gL7Y
z;mPup<$rMU@WcrINw<aBO;vz^F_GxQ-GE}MCD7|az0<9<8en{M3KLPw5n07KH903@
zNmezIOVLDCoK{E~pUp|BkMJx}@~TL%W)?D+Fad}QHoed{H7}`Hlm)YREShzwI7!p5
z%O1}v!iB`#Hu|XhKA1E6<%7w4an|6V6cCC$_xW{rF2L;H3oUoX_e|a^!?epP+VItt
zR(L$EidF<off`aGP!2J(*49A!31Bq2n9YbIIF%zA+<(k+?>~TJ`xIFdWvzeeLKdcz
z*=$BinamF?sEQoJ{Q{0zT$fW~9gEv`Ccd{ucmIwZiNSX>PJM@8bsj2}Vt8KDvLgcn
zTZdpZ{B0c>9vmDTSj{`m84gKKD~4ONk}n$$S<%Gr{s?rDtyBzALGPTxwpj%_DQ2+~
zGutUvM^Ox?B{3twP7o0of_(&T2z(<D8K7d2V!S8G=aLyoFdI@K7&ZZeAt$Q4@M2EY
z%Fy0e&MnT0L?!eRiZezqr7UKl^Un~`JOPD)*9;g^hUUpZ<4ZDDvZ9<9liIvU&ZIID
z@Ltf45apaCh;Nxoyoyx@AA%*ikBhJpb~u&HWRkNP5o`1G45d<H7EWBRN>XQ_jry>u
zC~_YbRL!!OiXzA3oXMNv5=1R2WemqW9M<nv;6P6lhThE5%%ogbCx$ksmDw2>E+VSA
zj8^D+HD`K?&M8(y;WR`Ng*a=5COavEK|-&4!?h@C^NK*|6-*kb=%Hq3I-|gG;AwA;
zk}^?<;hmv7GD@i4^k$-D2VKXHo~Kkm=NlZHVZ*bQrdLwwu};b<(Qwd<EAAuoN5gtQ
z8SYj3Ru#Z-Tl95ntC}KPVHlC@qHEs=q0$dDuKXj=T|NX_f|@#@NiLz45b^|ncJZed
zm%@+So1O+EPg?eV+r8yhZaF&qB-Z!k%yQ@MXHKrIq2@v1JohZ%Zu7oC?vSt6fC8af
z&>afZked&!G$DWU)!kQiKk{u{8oIRqNucrSu`9=}%~u1Rm&TqnMLz5Oq<882)pAq(
z(xGpBjn_LM){<NAn$cU2R)fd%6Q}gxDcy6b#=4x-%+sdUCD#|;>)xBg)wX!G>AlPD
zcbI%%1g{5gIje1nYSVz_^_r>Xbvr|U^K6Gw{VnBdhadYkug0F%TW6}lqx$iadhn#~
zIazZxI8QS**2yQn32(l6^w!*$`Frka_`v0{l?LRGTua{&9{YNpHb<AXSAMAbyZ;5+
zftzW)qrcjm(EW-3uIxgA$S(@IulqS-XdPCOKhj$#s=>qhkEhCdaO#m~s>adTmn(kc
z4?jmvXNWQ%9(x*TU+Su)Yb**MVxPGklxqiY?V()rj!@{|$iatR);L)4a%BSwwLeE3
zpZGRD_?y<{u08sRq`q)=`9rcCQ7@01B~-)xACJ}C;Pi5(1%j1nUZ-hZde{EPM<(^D
z>FSZ0<+?ritLGF1pici&RcMqy?A+74e>?iB%QYHB_c`B~7u|1&j`gAYaX*#YH;uM(
z4<ZbeQGU$LJ?Lp4W4Q;r8PFfHPAa_{#^T(=E$mp|X7sR^p)YX`7C-Fc$J@Av!)@cu
z+}8mH^sk$p<877S2XoO0h)n`i(B_3ZKv@*YVNf%7Cqln+c-Qa7iX;4)ufQ)Vf|yBU
zwfV};aF6Rlx^lYmr*LPt;WekuWZ`Nv{3*Dd;Epuk$Q1P&K@~3YgQ=rb-vYvLEWob=
z!!;*rsk}h;Q2SmGaj$up)&m=?pb;~Wi8D<dDT=|teM1g{R=FC9Ia8oy@BS|GOLiyy
zm|7Ri2xt>=Cpk?mX)4U?Wjz>YS-a@e!OFGvcBcgDr<FVHMMkW=A3YJLN7-bA&<KQ1
z*TGRFNF*ndiOQX5oA)fdGw`oYSM=zo8*e$6%9q-!%)m2tggMQ;;1D}lGu2vwsa)*1
U-Pj)3H-f$zaqefi`wRo}{}X9zga7~l

delta 2006
zcmah~ZEV{_7(Ux^5~t~stWDY_tZ`OKX3E0YfUWx|`$}n5C>@>XHg%LNb`w{L6P?{9
z6sIXafJ8#-DkEB8h$4`fG=3oM4`Td5TL%&nN|hltD-uZj;$Ox<pdk=<N!_#zX_oTb
zd+*2dK6k!zibuZK8~nDp*#^)v6TcZ>Y60M9JTV^As&U6UAN+%i5tp|S%NCazc`5X}
zvlHP0;0Y~Hbp*~4(4o*qB~S8{NL(W7bKW#Tj%YKK-@+4HkSnJ><za~??I+Jx!mj<}
z@g1Zuk@eIZp@K<=LDLx3H8KJ)fH(7&gf+?J$fPYtX}zAndbTF(8k<Qw<nia*8a#%j
znhbGr*9O_lM%fHdEJn>_yJ0oP^}0p?2~@JdJcibkqjTmwa#JdeQdbvQ3s`bi)eK##
zd2(xm&ahOAAy2X?{(HSSrXgBoR4Z@0KpGYINX{GetK&w^oj~y#2@e8D5#SUU0U3~`
zPJs+@zvw;9461d#R{Il(^#ABGYt8B{xu)sohM~ZVQH7O7DV7k}sdOS0;RT)*laZJZ
zV#C?A5LIM$A_bE>_=pl=Golh_Cq$GxAqokel_E)$9<1f(gCU)+SrDJT>421~6E%3Z
z*Q@IJK@Q>_nck!%)8qBlp~-X%;<v|<x(#a?Po{Vwp*N@NLdR?LcbS?ulvd)?9BQJ#
zh$snso~^l&+9`==x5FukeY6%rTA{3Ph?7o4&LTQnG$l=lydXsd&I$4L(`mdY8RDA-
zyD&V2y{5^ODCy>yphPpgZjvMC1f3D32?63-xDzKnh7-*~R?N$atec^bOyR6>HY%hQ
zF(tuHoIuG6<ZL=6CS$r4FE|}h;_C=(HSIO8PS+Q07y0bCk{XXDBC?Ds`K)fj!r^X2
zDC5rwyY|2)0JMa!N&C*l<ijWw!Z}0e!!Qe~W?*%^6<bKoCs!<;6^CchQVJX^wS~)$
zzHg|KW3Xf$tk_(0JBm9NEh{#5_Grc7n#&Y3b81n&aO8u5cLv@YEO9+$$G+MAn<mQ}
z{jc^HPTnwis$?_m`q8?l;%-|QogZBon;-jl+b3N9L++#Qi?5X3`wKRMX{I={IC;at
zRa(4@PnWueOTOdfmgh?+MoTTDRXfGFD)vot1I2;!@$c>a+s(kwUG$ba9$&Hg3Uooe
z)f!mpy4YTB-Bn}?RN=%e?uqmEADrxplU-`L;q3Zy_viAJy#*SrZOQ#vo?mI(Uv?a*
zn*PK4XT{O}D<BxxExWTyq4BRbU*0&c()TO*TOLC@`&G~3U^oP>2HasMd3DcW5>2k{
zbBF!pvXkizKR_@02#kIv+)Xb(OkfNVeQs)br@PN=x=v&Jx|!+QY`N|rvF#$Ty_xEB
zYv)?0y#1&NY{r0IEINnrR8oKg$P8bm-JhD!K}tjv1Sv_ovSopWyHH3w<LxvL;hN*x
z>t4SP9zwQmj|!3^K)HV4hLP)+-w5q%Z|~3uPQ}L@K8axuh65N5BH(PW8{2~zo<X3K
zyaH?Nm;)ZifEjcO3bIZJ+9_X<ei1naF2Ck`pM2pgPQc#*coM-7N5j*262VZrWsO!;
z-5bE6GYDk-w}*~)eeLGB5J{lB!Xsx&%XX;5OWN-prw8#VuWbp$U2EZWEigNhHYLH0
zTY1-d0Nt*sgwP8UC<Xs>%EQ{b{<qr~v$I>u#P-`{E8)6B0g|g?tNMucEPKh--h8wN
OT<xKc5!5w6Ap93zL*j@4

diff --git a/roadcast/app.py b/roadcast/app.py
index 1fabf27..acbde40 100644
--- a/roadcast/app.py
+++ b/roadcast/app.py
@@ -43,28 +43,67 @@ def train_endpoint():
     return jsonify({"status": "training_started"})
 
 
-@app.route('/predict', methods=['POST'])
+@app.route('/predict', methods=['POST', 'GET'])
 def predict_endpoint():
-    """Predict single uploaded image. Expects form-data with file field named 'image'."""
-    if 'image' not in request.files:
-        return jsonify({"error": "no image uploaded (field 'image')"}), 400
-    img = request.files['image']
-    tmp_path = os.path.join(os.getcwd(), 'tmp_upload.jpg')
-    img.save(tmp_path)
+    """Predict route between two points given source and destination with lat and lon.
+
+    Expectation:
+    - POST with JSON: {"source": {"lat": .., "lon": ..}, "destination": {"lat": .., "lon": ..}}
+    - GET returns usage instructions for quick browser testing.
+    """
+    if request.method == 'GET':
+        return jsonify({
+            "info": "This endpoint expects a POST with JSON body.",
+            "example": {
+                "source": {"lat": 38.9, "lon": -77.0},
+                "destination": {"lat": 38.95, "lon": -77.02}
+            },
+            "note": "Use POST to receive a prediction. Example: curl -X POST -H 'Content-Type: application/json' -d '{\"source\": {\"lat\": 38.9, \"lon\": -77.0}, \"destination\": {\"lat\": 38.95, \"lon\": -77.02}}' http://127.0.0.1:5000/predict"
+        }), 200
+
+    data = request.json or {}
+    source = data.get('source')
+    destination = data.get('destination')
+    if not source or not destination:
+        return jsonify({"error": "both 'source' and 'destination' fields are required"}), 400
+    try:
+        src_lat = float(source.get('lat'))
+        src_lon = float(source.get('lon'))
+        dst_lat = float(destination.get('lat'))
+        dst_lon = float(destination.get('lon'))
+    except (TypeError, ValueError):
+        return jsonify({"error": "invalid lat or lon values; must be numbers"}), 400
+
+    # Ensure compute_reroute exists and is callable
+    try:
+        from openweather_client import compute_reroute
+    except Exception as e:
+        return jsonify({
+            "error": "compute_reroute not found in openweather_client",
+            "detail": str(e),
+            "hint": "Provide openweather_client.compute_reroute or implement a callable that accepts (src_lat, src_lon, dst_lat, dst_lon)"
+        }), 500
+
+    if not callable(compute_reroute):
+        return jsonify({"error": "openweather_client.compute_reroute is not callable"}), 500
+
+    # Call compute_reroute with fallback strategies
     try:
-        from inference import load_model, predict_image
-        model_path = os.path.join(os.getcwd(), 'model.pth')
-        if not os.path.exists(model_path):
-            return jsonify({"error": "no trained model found (run /train first)"}), 400
-        model, idx_to_class = load_model(model_path)
-        idx, conf = predict_image(model, tmp_path)
-        label = idx_to_class.get(idx) if idx_to_class else str(idx)
-        return jsonify({"label": label, "confidence": conf})
-    finally:
         try:
-            os.remove(tmp_path)
-        except Exception:
-            pass
+            result = compute_reroute(src_lat, src_lon, dst_lat, dst_lon)
+        except TypeError:
+            # fallback: single payload dict
+            payload = {'source': {'lat': src_lat, 'lon': src_lon}, 'destination': {'lat': dst_lat, 'lon': dst_lon}}
+            result = compute_reroute(payload)
+
+        # Normalize response
+        if isinstance(result, dict):
+            return jsonify(result)
+        else:
+            return jsonify({"result": result})
+    except Exception as e:
+        return jsonify({"error": "compute_reroute invocation failed", "detail": str(e)}), 500
+
 
 @app.route('/')
 def home():
@@ -136,3 +175,6 @@ if __name__ == '__main__':
 #     ai_response = f"AI received: {user_input}"
 
 #     return jsonify({"response": ai_response})
+#     ai_response = f"AI received: {user_input}"
+
+#     return jsonify({"response": ai_response"})