Support Energy Meter Reading

evnex/api.py

@@ -24,6 +24,7 @@
     EvnexGetChargePointDetailResponse,
     EvnexGetChargePointsResponse,
     EvnexChargePointStatusResponse,
+    EvnexChargePointEnergyMeterReadingResponse,
 )
 from evnex.schema.commands import EvnexCommandResponse
 from evnex.schema.org import (
@@ -343,6 +344,25 @@ async def get_charge_point_status(
 
         return EvnexChargePointStatusResponse.model_validate(json_data)
 
+    @retry(
+        wait=wait_random_exponential(multiplier=1, max=60),
+        retry=retry_if_not_exception_type((ValidationError, NotAuthorizedException)),
+    )
+    async def get_charge_point_energy_meter_reading(
+        self, charge_point_id: str
+    ) -> EvnexChargePointEnergyMeterReadingResponse:
+        """
+        :param charge_point_id:
+        :raises: ReadTimeout if the charge point is offline.
+        """
+        r = await self.httpx_client.post(
+            f"https://client-api.evnex.io/charge-points/{charge_point_id}/commands/get-energy-meter-reading",
+            headers=self._common_headers,
+        )
+        json_data = await self._check_api_response(r)
+
+        return EvnexChargePointEnergyMeterReadingResponse.model_validate(json_data)
+
     @retry(
         wait=wait_random_exponential(multiplier=1, max=60),
         retry=retry_if_not_exception_type((ValidationError, NotAuthorizedException)),

evnex/schema/charge_points.py

@@ -129,6 +129,17 @@ class EvnexChargePointStatusResponse(BaseModel):
     data: EvnexChargePointStatus
 
 
+class EvnexChargePointEnergyMeterReading(BaseModel):
+    timestamp: datetime
+    chargingActivePower: float
+    supplyActivePower: float
+
+
+class EvnexChargePointEnergyMeterReadingResponse(BaseModel):
+    data: EvnexChargePointEnergyMeterReading
+    status: str
+
+
 class EvnexChargePointBase(BaseModel):
     # Attributes shared by brief and detail endpoints
     id: str

examples/get_charge_point_detail.py

@@ -84,6 +84,12 @@ async def main():
             # override = await evnex.get_charge_point_override(charge_point_id=charge_point.id)
             # print(override)
 
+            print("Getting energy meter reading")
+            charge_reading = await evnex.get_charge_point_energy_meter_reading(
+                charge_point_id=charge_point.id
+            )
+            print(charge_reading)
+
             print()
             print("Getting transactions")
             transactions = await evnex.get_charge_point_sessions(