Fixing bugs for alternating traffic and incorrect geometry directions

Author: jacob6838

wzdx/raw_to_standard/planned_events.py

@@ -563,15 +563,17 @@ def get_lane_impacts(
             )
 
 
-def all_lanes_open(lanes: list[dict]) -> bool:
-    """Check if all lanes are open
+def all_lanes_open(lanes: list[dict], description: str) -> bool:
+    """Check if all lanes are open, or if the description indicates alternating traffic
 
     Args:
         lanes (list[dict]): WZDx lanes list
 
     Returns:
         bool: whether all lanes are open
     """
+    if "alternating traffic" in description.lower():
+        return False
     for i in lanes:
         if i["status"] != "open":
             return False
@@ -748,6 +750,8 @@ def get_route_details_for_coordinates_lngLat(
         route_details_end = get_route_details(
             cdotGeospatialApi, coordinates[-1][1], coordinates[-1][0]
         )
+    print("Route details start:", route_details_start)
+    print("Route details end:", route_details_end)
 
     # Update route IDs based on directionality
     if route_details_start and route_details_end:
@@ -759,7 +763,7 @@ def get_route_details_for_coordinates_lngLat(
             )
             return route_details_start, route_details_end
         else:
-            if route_details_start["Measure"] > route_details_end["Measure"]:
+            if route_details_start["Measure"] < route_details_end["Measure"]:
                 route_details_start["Route"] = route_details_start["Route"].replace(
                     "_DEC", ""
                 )
@@ -836,14 +840,31 @@ def create_rtdh_standard_msg(
         beginning_milepost = pd.get("properties/startMarker")
         ending_milepost = pd.get("properties/endMarker")
         recorded_direction = pd.get("properties/recorded_direction")
+        geometry_direction = geospatial_tools.get_road_direction_from_coordinates(
+            coordinates
+        )
+
+        lane_impacts = get_lane_impacts(
+            pd.get("properties/laneImpacts"), pd.get("properties/direction")
+        )
+        if direction != recorded_direction and all_lanes_open(
+            lane_impacts, description
+        ):
+            logging.info(
+                f'Unable to retrieve geometry coordinates for event: {pd.get("properties/id", default="")}'
+            )
+            return {}
+
+        print(f"{direction}, {recorded_direction}, {geometry_direction}")
         if (
-            direction == REVERSED_DIRECTION_MAP.get(recorded_direction)
+            direction == REVERSED_DIRECTION_MAP.get(geometry_direction)
             and direction != "unknown"
         ):
+            print("reversing coordinates")
             coordinates.reverse()
             beginning_milepost = pd.get("properties/endMarker")
             ending_milepost = pd.get("properties/startMarker")
-
+        print(f"{beginning_milepost}, {ending_milepost}")
         roadName = wzdx_translator.remove_direction_from_street_name(
             pd.get("properties/routeName")
         )
@@ -892,15 +913,6 @@ def create_rtdh_standard_msg(
 
         condition_1 = event_status in ["active", "pending", "planned"]
 
-        lane_impacts = get_lane_impacts(
-            pd.get("properties/laneImpacts"), pd.get("properties/direction")
-        )
-        if direction != recorded_direction and all_lanes_open(lane_impacts):
-            logging.info(
-                f'Unable to retrieve geometry coordinates for event: {pd.get("properties/id", default="")}'
-            )
-            return {}
-
         route_details_start, route_details_end = (
             get_route_details_for_coordinates_lngLat(cdotGeospatialApi, coordinates)
         )

wzdx/sample_files/cwz/i70_noise_wall_replacement_westbound_2025_08_08.json

@@ -0,0 +1,83 @@
+{
+  "feed_info": {
+    "publisher": "CDOT",
+    "version": "1.0",
+    "license": "https://creativecommons.org/publicdomain/zero/1.0/",
+    "data_sources": [
+      {
+        "data_source_id": "409ce0f7-e260-4cbb-bc51-a9d2e86e71e3",
+        "organization_name": "CDOT",
+        "update_date": "2025-08-07T21:20:04Z",
+        "update_frequency": 300,
+        "contact_name": "Heather Pickering-Hilgers",
+        "contact_email": "heather.pickeringhilgers@state.co.us"
+      }
+    ],
+    "update_date": "2025-08-07T21:20:04Z",
+    "update_frequency": 300,
+    "contact_name": "Heather Pickering-Hilgers",
+    "contact_email": "heather.pickeringhilgers@state.co.us"
+  },
+  "type": "FeatureCollection",
+  "features": [
+    {
+      "id": "33661cfa-5362-5527-a4f8-74bf7c38e5a1",
+      "type": "Feature",
+      "properties": {
+        "core_details": {
+          "event_type": "work-zone",
+          "data_source_id": "409ce0f7-e260-4cbb-bc51-a9d2e86e71e3",
+          "road_names": ["I-70"],
+          "direction": "westbound",
+          "name": "OpenTMS-Event26569868512_westbound",
+          "description": "Between Exit 273: Pecos Street and Exit 271B: Lowell Boulevard (Denver) from Mile Point 272.1 to Mile Point 272. Wall maintenance. Starting today at 6:00PM MDT until tomorrow at about 5:30AM MDT. Full schedule below: • August 7, 6:00PM - August 8, 5:30AM Comment: WB I-70 off-ramp closure with detour route in place",
+          "update_date": "2025-08-07T21:13:29Z"
+        },
+        "start_date": "2025-08-08T00:00:00Z",
+        "end_date": "2025-08-08T11:30:00Z",
+        "is_start_date_verified": false,
+        "is_end_date_verified": false,
+        "is_start_position_verified": false,
+        "is_end_position_verified": false,
+        "location_method": "channel-device-method",
+        "work_zone_type": "static",
+        "vehicle_impact": "all-lanes-open",
+        "lanes": [
+          { "order": 1, "type": "exit-ramp", "status": "open" },
+          { "order": 2, "type": "general", "status": "open" },
+          { "order": 3, "type": "general", "status": "open" }
+        ],
+        "beginning_cross_street": "Pecos Street",
+        "ending_cross_street": "Lowell Boulevard",
+        "types_of_work": [{ "type_name": "barrier-work", "is_architectural_change": false }],
+        "beginning_milepost": 272.0,
+        "ending_milepost": 272.131,
+        "route_details_start": {
+          "Route": "070A_DEC",
+          "Measure": 272.0,
+          "MMin": 0.0,
+          "MMax": 449.589,
+          "Distance": 0.73
+        },
+        "route_details_end": {
+          "Route": "070A_DEC",
+          "Measure": 272.131,
+          "MMin": 0.0,
+          "MMax": 449.589,
+          "Distance": 0.44
+        },
+        "condition_1": true
+      },
+      "geometry": {
+        "type": "LineString",
+        "coordinates": [
+          [-105.02552069299998, 39.784365911000066],
+          [-105.02420656199996, 39.78435750400007],
+          [-105.02337293199997, 39.784291523000036],
+          [-105.02278930299997, 39.78418364700008]
+        ]
+      }
+    }
+  ],
+  "condition_1": true
+}