Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
44 changes: 22 additions & 22 deletions dimo/api/vehicle_events.py → dimo/api/vehicle_triggers.py
Original file line number Diff line number Diff line change
@@ -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
Expand All @@ -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):
Expand All @@ -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,
Expand All @@ -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):
Expand All @@ -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,
Expand All @@ -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),
)
Expand All @@ -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):
Expand All @@ -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),
)
4 changes: 2 additions & 2 deletions dimo/dimo.py
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down Expand Up @@ -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]
Expand Down
4 changes: 2 additions & 2 deletions dimo/environments.py
Original file line number Diff line number Diff line change
Expand Up @@ -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",
Expand All @@ -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",
},
}