Merge pull request #29 from DIMO-Network/DVR-647

Vehicle Events --> Vehicle Triggers

Author: barrettk8090

dimo/api/vehicle_events.py renamed to dimo/api/vehicle_triggers.py

@@ -1,7 +1,7 @@
 from dimo.errors import check_type
 
 
-class VehicleEvents:
+class VehicleTriggers:
 
     def __init__(self, request_method, get_auth_headers):
         self._request = request_method
@@ -14,7 +14,7 @@ def list_all_webhooks(self, developer_jwt: str):
         check_type("developer_jwt", developer_jwt, str)
         url = f"/v1/webhooks"
         return self._request(
-            "GET", "VehicleEvents", url, headers=self._get_auth_headers(developer_jwt)
+            "GET", "VehicleTriggers", url, headers=self._get_auth_headers(developer_jwt)
         )
 
     def register_webhook(self, developer_jwt: str, request: object):
@@ -26,7 +26,7 @@ def register_webhook(self, developer_jwt: str, request: object):
         url = f"/v1/webhooks"
         return self._request(
             "POST",
-            "VehicleEvents",
+            "VehicleTriggers",
             url,
             headers=self._get_auth_headers(developer_jwt),
             data=request,
@@ -39,29 +39,29 @@ def webhook_signals(self, developer_jwt: str):
         check_type("developer_jwt", developer_jwt, str)
         url = f"/v1/webhooks/signals"
         return self._request(
-            "GET", "VehicleEvents", url, headers=self._get_auth_headers(developer_jwt)
+            "GET", "VehicleTriggers", url, headers=self._get_auth_headers(developer_jwt)
         )
 
-    def list_vehicle_subscriptions(self, developer_jwt: str, token_id: str):
+    def list_vehicle_subscriptions(self, developer_jwt: str, token_did: str):
         """
         Lists all webhooks that a specified vehicle token id is subscribed to
         """
         check_type("developer_jwt", developer_jwt, str)
-        check_type("token_id", token_id, str)
-        url = f"/v1/webhooks/vehicles/{token_id}"
+        check_type("token_id", token_did, str)
+        url = f"/v1/webhooks/vehicles/{token_did}"
         return self._request(
-            "GET", "VehicleEvents", url, headers=self._get_auth_headers(developer_jwt)
+            "GET", "VehicleTriggers", url, headers=self._get_auth_headers(developer_jwt)
         )
 
-    def list_vehicle_subscriptions_by_event(self, developer_jwt: str, webhook_id: str):
+    def list_vehicle_subscriptions_by_trigger(self, developer_jwt: str, webhook_id: str):
         """
         Lists all vehicle subscriptions for a given webhook id
         """
         check_type("developer_jwt", developer_jwt, str)
         check_type("webhook_id", webhook_id, str)
         url = f"/v1/webhooks/{webhook_id}"
         return self._request(
-            "GET", "VehicleEvents", url, headers=self._get_auth_headers(developer_jwt)
+            "GET", "VehicleTriggers", url, headers=self._get_auth_headers(developer_jwt)
         )
 
     def update_webhook(self, developer_jwt: str, webhook_id: str, request: object):
@@ -74,7 +74,7 @@ def update_webhook(self, developer_jwt: str, webhook_id: str, request: object):
         url = f"/v1/webhooks/{webhook_id}"
         return self._request(
             "PUT",
-            "VehicleEvents",
+            "VehicleTriggers",
             url,
             headers=self._get_auth_headers(developer_jwt),
             data=request,
@@ -89,7 +89,7 @@ def delete_webhook(self, developer_jwt: str, webhook_id: str):
         url = f"/v1/webhooks/{webhook_id}"
         return self._request(
             "DELETE",
-            "VehicleEvents",
+            "VehicleTriggers",
             url,
             headers=self._get_auth_headers(developer_jwt),
         )
@@ -102,19 +102,19 @@ def subscribe_all_vehicles(self, developer_jwt: str, webhook_id: str):
         check_type("webhook_id", webhook_id, str)
         url = f"/v1/webhooks/{webhook_id}/subscribe/all"
         return self._request(
-            "POST", "VehicleEvents", url, headers=self._get_auth_headers(developer_jwt)
+            "POST", "VehicleTriggers", url, headers=self._get_auth_headers(developer_jwt)
         )
 
-    def subscribe_vehicle(self, developer_jwt: str, token_id: str, webhook_id: str):
+    def subscribe_vehicle(self, developer_jwt: str, token_did: str, webhook_id: str):
         """
         Subscribes a single vehicle to a specified webhook
         """
         check_type("developer_jwt", developer_jwt, str)
-        check_type("token_id", token_id, str)
+        check_type("token_id", token_did, str)
         check_type("webhook_id", webhook_id, str)
-        url = f"/v1/webhooks/{webhook_id}/subscribe/{token_id}"
+        url = f"/v1/webhooks/{webhook_id}/subscribe/{token_did}"
         return self._request(
-            "POST", "VehicleEvents", url, headers=self._get_auth_headers(developer_jwt)
+            "POST", "VehicleTriggers", url, headers=self._get_auth_headers(developer_jwt)
         )
 
     def unsubscribe_all_vehicles(self, developer_jwt: str, webhook_id: str):
@@ -126,22 +126,22 @@ def unsubscribe_all_vehicles(self, developer_jwt: str, webhook_id: str):
         url = f"/v1/webhooks/{webhook_id}/unsubscribe/all"
         return self._request(
             "DELETE",
-            "VehicleEvents",
+            "VehicleTriggers",
             url,
             headers=self._get_auth_headers(developer_jwt),
         )
 
-    def unsubscribe_vehicle(self, developer_jwt: str, token_id: str, webhook_id: str):
+    def unsubscribe_vehicle(self, developer_jwt: str, token_did: str, webhook_id: str):
         """
         Unsubscribes a single vehicle from a specified webhook
         """
         check_type("developer_jwt", developer_jwt, str)
-        check_type("token_id", token_id, str)
+        check_type("token_id", token_did, str)
         check_type("webhook_id", webhook_id, str)
-        url = f"/v1/webhooks/{webhook_id}/unsubscribe/{token_id}"
+        url = f"/v1/webhooks/{webhook_id}/unsubscribe/{token_did}"
         return self._request(
             "DELETE",
-            "VehicleEvents",
+            "VehicleTriggers",
             url,
             headers=self._get_auth_headers(developer_jwt),
         )

dimo/dimo.py

@@ -6,7 +6,7 @@
 from .api.token_exchange import TokenExchange
 from .api.trips import Trips
 from .api.valuations import Valuations
-from .api.vehicle_events import VehicleEvents
+from .api.vehicle_triggers import VehicleTriggers
 
 from .graphql.identity import Identity
 from .graphql.telemetry import Telemetry
@@ -84,7 +84,7 @@ def __getattr__(self, name: str) -> Any:
             "valuations": (Valuations, ("request", "_get_auth_headers")),
             "identity": (Identity, ("self",)),
             "telemetry": (Telemetry, ("self",)),
-            "vehicle_events": (VehicleEvents, ("request", "_get_auth_headers")),
+            "vehicle_triggers": (VehicleTriggers, ("request", "_get_auth_headers")),
         }
         if name in mapping:
             cls, deps = mapping[name]

dimo/environments.py

@@ -9,7 +9,7 @@
         "Trips": "https://trips-api.dimo.zone",
         "User": "https://users-api.dimo.zone",
         "Valuations": "https://valuations-api.dimo.zone",
-        "VehicleEvents": "https://vehicle-events-api.dimo.zone",
+        "VehicleTriggers": "https://vehicle-triggers-api.dimo.zone",
     },
     "Dev": {
         "Attestation": "https://attestation-api.dev.dimo.zone",
@@ -21,6 +21,6 @@
         "Trips": "https://trips-api.dev.dimo.zone",
         "User": "https://users-api.dev.dimo.zone",
         "Valuations": "https://valuations-api.dev.dimo.zone",
-        "VehicleEvents": "https://vehicle-events-api.dev.dimo.zone",
+        "VehicleTriggers": "https://vehicle-triggers-api.dev.dimo.zone",
     },
 }