88
99#if USE_FACADE
1010
11- #include " OcppEngine.h"
12- #include " MeteringService.h"
13- #include " SmartChargingService.h"
14- #include " ChargePointStatusService.h"
15- #include " SimpleOcppOperationFactory.h"
16- #include " Configuration.h"
17-
18- #include " Authorize.h"
19- #include " BootNotification.h"
20- #include " StartTransaction.h"
21- #include " StopTransaction.h"
22- #include " OcppOperationTimeout.h"
11+ #include < ArduinoOcpp/Core/ OcppEngine.h>
12+ #include < ArduinoOcpp/Tasks/Metering/ MeteringService.h>
13+ #include < ArduinoOcpp/Tasks/SmartCharging/ SmartChargingService.h>
14+ #include < ArduinoOcpp/Tasks/ChargePointStatus/ ChargePointStatusService.h>
15+ #include < ArduinoOcpp/ SimpleOcppOperationFactory.h>
16+ #include < ArduinoOcpp/Core/ Configuration.h>
17+
18+ #include < ArduinoOcpp/MessagesV16/ Authorize.h>
19+ #include < ArduinoOcpp/MessagesV16/ BootNotification.h>
20+ #include < ArduinoOcpp/MessagesV16/ StartTransaction.h>
21+ #include < ArduinoOcpp/MessagesV16/ StopTransaction.h>
22+ #include < ArduinoOcpp/Core/ OcppOperationTimeout.h>
2323
2424namespace ArduinoOcpp {
2525namespace Facade {
@@ -40,6 +40,7 @@ OnLimitChange onLimitChange;
4040#define OCPP_ID_OF_CP 0
4141boolean OCPP_initialized = false ;
4242
43+ #if 0 //moved to OcppConnection
4344/*
4445 Called by Websocket library on incoming message on the internet link
4546*/
@@ -82,10 +83,14 @@ void webSocketEvent(WStype_t type, uint8_t * payload, size_t length) {
8283 }
8384}
8485
86+ #endif // moved to OcppConnection
87+
8588} // end namespace ArduinoOcpp::Facade
8689} // end namespace ArduinoOcpp
8790
91+ using namespace ArduinoOcpp ;
8892using namespace ArduinoOcpp ::Facade;
93+ using namespace ArduinoOcpp ::Ocpp16;
8994
9095void OCPP_initialize (String CS_hostname, uint16_t CS_port, String CS_url) {
9196 if (OCPP_initialized) {
@@ -99,7 +104,7 @@ void OCPP_initialize(String CS_hostname, uint16_t CS_port, String CS_url) {
99104 webSocket.begin (CS_hostname, CS_port, CS_url, " ocpp1.6" );
100105
101106 // event handler
102- webSocket.onEvent (webSocketEvent);
107+ // webSocket.onEvent(webSocketEvent); //will be set in ocppEngine_initialize()
103108
104109 // use HTTP Basic Authorization this is optional remove if not needed
105110 // webSocket.setAuthorization("user", "Password");
@@ -198,7 +203,7 @@ void setOnResetSendConf(void listener(JsonObject payload)) {
198203}
199204
200205void authorize (String &idTag, OnReceiveConfListener onConf, OnAbortListener onAbort, OnTimeoutListener onTimeout, OnReceiveErrorListener onError) {
201- OcppOperation *authorize = makeOcppOperation (&webSocket,
206+ OcppOperation *authorize = makeOcppOperation (
202207 new Authorize (idTag));
203208 initiateOcppOperation (authorize);
204209 if (onConf)
@@ -213,7 +218,7 @@ void authorize(String &idTag, OnReceiveConfListener onConf, OnAbortListener onAb
213218}
214219
215220void bootNotification (String chargePointModel, String chargePointVendor, OnReceiveConfListener onConf, OnAbortListener onAbort, OnTimeoutListener onTimeout, OnReceiveErrorListener onError) {
216- OcppOperation *bootNotification = makeOcppOperation (&webSocket,
221+ OcppOperation *bootNotification = makeOcppOperation (
217222 new BootNotification (chargePointModel, chargePointVendor));
218223 initiateOcppOperation (bootNotification);
219224 if (onConf)
@@ -228,15 +233,15 @@ void bootNotification(String chargePointModel, String chargePointVendor, OnRecei
228233}
229234
230235void bootNotification (String &chargePointModel, String &chargePointVendor, String &chargePointSerialNumber, OnReceiveConfListener onConf) {
231- OcppOperation *bootNotification = makeOcppOperation (&webSocket,
236+ OcppOperation *bootNotification = makeOcppOperation (
232237 new BootNotification (chargePointModel, chargePointVendor, chargePointSerialNumber));
233238 initiateOcppOperation (bootNotification);
234239 bootNotification->setOnReceiveConfListener (onConf);
235240 bootNotification->setTimeout (new SuppressedTimeout ());
236241}
237242
238243void startTransaction (OnReceiveConfListener onConf, OnAbortListener onAbort, OnTimeoutListener onTimeout, OnReceiveErrorListener onError) {
239- OcppOperation *startTransaction = makeOcppOperation (&webSocket,
244+ OcppOperation *startTransaction = makeOcppOperation (
240245 new StartTransaction (OCPP_ID_OF_CONNECTOR ));
241246 initiateOcppOperation (startTransaction);
242247 if (onConf)
@@ -251,15 +256,15 @@ void startTransaction(OnReceiveConfListener onConf, OnAbortListener onAbort, OnT
251256}
252257
253258void startTransaction (String &idTag, OnReceiveConfListener onConf) {
254- OcppOperation *startTransaction = makeOcppOperation (&webSocket,
259+ OcppOperation *startTransaction = makeOcppOperation (
255260 new StartTransaction (OCPP_ID_OF_CONNECTOR , idTag));
256261 initiateOcppOperation (startTransaction);
257262 startTransaction->setOnReceiveConfListener (onConf);
258263 startTransaction->setTimeout (new FixedTimeout (20000 ));
259264}
260265
261266void stopTransaction (OnReceiveConfListener onConf, OnAbortListener onAbort, OnTimeoutListener onTimeout, OnReceiveErrorListener onError) {
262- OcppOperation *stopTransaction = makeOcppOperation (&webSocket,
267+ OcppOperation *stopTransaction = makeOcppOperation (
263268 new StopTransaction (OCPP_ID_OF_CONNECTOR ));
264269 initiateOcppOperation (stopTransaction);
265270 if (onConf)
0 commit comments