4 from datetime
import datetime
, timezone
6 from ocpp
.routing
import on
7 from ocpp
.v201
import ChargePoint
as cp
8 from ocpp
.v201
import call_result
9 from ocpp
.v201
.enums
import RegistrationStatusType
, GenericDeviceModelStatusType
11 # Setting up the logging configuration to display debug level messages.
12 logging
.basicConfig(level
=logging
.DEBUG
)
14 # Define a ChargePoint class inheriting from the OCPP 2.0.1 ChargePoint class.
15 class ChargePoint(cp
):
16 # Define a handler for the BootNotification message.
17 @on('BootNotification')
18 async def on_boot_notification(self
, charging_station
, reason
, **kwargs
):
19 logging
.info("Received BootNotification")
20 # Create and return a BootNotification response with the current time,
21 # an interval of 10 seconds, and an accepted status.
22 return call_result
.BootNotification(
23 current_time
= datetime
.now(timezone
.utc
).isoformat(),
25 status
=RegistrationStatusType
.accepted
28 # Define a handler for the GetBaseReport message.
30 async def on_get_base_report(self
, request_id
, report_base
, **kwargs
):
32 logging
.info(f
"Received GetBaseReport request with RequestId: {request_id} and ReportBase: {report_base}")
34 # Create a mock response for demonstration purposes, indicating the report is accepted.
35 response
= call_result
.GetBaseReport(
36 status
=GenericDeviceModelStatusType
.accepted
39 logging
.info(f
"Sending GetBaseReport response: {response}")
41 except Exception as e
:
42 # Log any errors that occur while handling the GetBaseReport request.
43 logging
.error(f
"Error handling GetBaseReport request: {e}", exc_info
=True)
44 # Return a rejected status in case of error.
45 return call_result
.GetBaseReport(
46 status
=GenericDeviceModelStatusType
.rejected
49 # Function to handle new WebSocket connections.
50 async def on_connect(websocket
, path
):
51 """ For every new charge point that connects, create a ChargePoint instance and start listening for messages. """
53 requested_protocols
= websocket
.request_headers
['Sec-WebSocket-Protocol']
55 logging
.info("Client hasn't requested any Subprotocol. Closing Connection")
56 return await websocket
.close()
58 if websocket
.subprotocol
:
59 logging
.info("Protocols Matched: %s", websocket
.subprotocol
)
61 logging
.warning('Protocols Mismatched | Expected Subprotocols: %s,'
62 ' but client supports %s | Closing connection',
63 websocket
.available_subprotocols
,
65 return await websocket
.close()
67 charge_point_id
= path
.strip('/')
68 cp
= ChargePoint(charge_point_id
, websocket
)
70 # Start the ChargePoint instance to listen for incoming messages.
73 # Main function to start the WebSocket server.
75 # Create the WebSocket server and specify the handler for new connections.
76 server
= await websockets
.serve(
78 '0.0.0.0', # Listen on loopback.
80 subprotocols
=['ocpp2.0', 'ocpp2.0.1'] # Specify OCPP 2.0.1 subprotocols.
82 logging
.info("WebSocket Server Started")
83 # Wait for the server to close (runs indefinitely).
84 await server
.wait_closed()
86 # Entry point of the script.
87 if __name__
== '__main__':
88 # Run the main function to start the server.