forked from matth-x/MicroOcpp
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathBootNotification.cpp
More file actions
140 lines (115 loc) · 4.67 KB
/
Copy pathBootNotification.cpp
File metadata and controls
140 lines (115 loc) · 4.67 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
// matth-x/ArduinoOcpp
// Copyright Matthias Akstaller 2019 - 2021
// MIT License
#include <Variants.h>
#include <ArduinoOcpp/MessagesV16/BootNotification.h>
#include <ArduinoOcpp/Core/OcppEngine.h>
#include <ArduinoOcpp/Core/Configuration.h>
#include <string.h>
#include <ArduinoOcpp/Core/OcppTime.h>
using ArduinoOcpp::Ocpp16::BootNotification;
BootNotification::BootNotification() {
}
BootNotification::BootNotification(String &cpModel, String &cpVendor) {
chargePointModel = String(cpModel);
chargePointVendor = String(cpVendor);
}
BootNotification::BootNotification(String &cpModel, String &cpVendor, String &cpSerialNumber) {
chargePointModel = String(cpModel);
chargePointVendor = String(cpVendor);
chargePointSerialNumber = String(cpSerialNumber);
}
BootNotification::BootNotification(String &cpModel, String &cpVendor, String &cpSerialNumber, String &fwVersion) {
chargePointModel = String(cpModel);
chargePointVendor = String(cpVendor);
chargePointSerialNumber = String(cpSerialNumber);
firmwareVersion = String(fwVersion);
}
BootNotification::BootNotification(DynamicJsonDocument *payload) {
this->overridePayload = payload;
}
BootNotification::~BootNotification() {
if (overridePayload != NULL)
delete overridePayload;
}
const char* BootNotification::getOcppOperationType(){
return "BootNotification";
}
DynamicJsonDocument* BootNotification::createReq() {
if (overridePayload != NULL) {
DynamicJsonDocument *result = new DynamicJsonDocument(*overridePayload);
return result;
}
DynamicJsonDocument *doc = new DynamicJsonDocument(JSON_OBJECT_SIZE(4)
+ chargePointModel.length() + 1
+ chargePointVendor.length() + 1
+ chargePointSerialNumber.length() + 1
+ firmwareVersion.length() + 1);
JsonObject payload = doc->to<JsonObject>();
payload["chargePointModel"] = chargePointModel;
payload["chargePointVendor"] = chargePointVendor;
if (!chargePointSerialNumber.isEmpty()) {
payload["chargePointSerialNumber"] = chargePointSerialNumber;
}
if (!firmwareVersion.isEmpty()) {
payload["firmwareVersion"] = firmwareVersion;
}
return doc;
}
void BootNotification::processConf(JsonObject payload){
const char* currentTime = payload["currentTime"] | "Invalid";
if (strcmp(currentTime, "Invalid")) {
OcppTime *ocppTime = getOcppTime();
if (ocppTime && ocppTime->setOcppTime(currentTime)) {
//success
} else {
Serial.print(F("[BootNotification] Error reading time string. Expect format like 2020-02-01T20:53:32.486Z\n"));
}
} else {
Serial.print(F("[BootNotification] Error reading time string. Missing attribute currentTime of type string\n"));
}
int interval = payload["interval"] | -1;
//only write if in valid range
if (interval >= 1) {
std::shared_ptr<Configuration<int>> intervalConf = declareConfiguration<int>("HeartbeatInterval", 86400);
if (intervalConf && interval != *intervalConf) {
*intervalConf = interval;
configuration_save();
}
}
const char* status = payload["status"] | "Invalid";
if (!strcmp(status, "Accepted")) {
if (DEBUG_OUT) Serial.print(F("[BootNotification] Request has been accepted!\n"));
if (getChargePointStatusService() != NULL) {
getChargePointStatusService()->boot();
}
} else {
Serial.print(F("[BootNotification] Request unsuccessful!\n"));
}
}
void BootNotification::processReq(JsonObject payload){
/*
* Ignore Contents of this Req-message, because this is for debug purposes only
*/
}
DynamicJsonDocument* BootNotification::createConf(){
DynamicJsonDocument* doc = new DynamicJsonDocument(JSON_OBJECT_SIZE(3) + (JSONDATE_LENGTH + 1));
JsonObject payload = doc->to<JsonObject>();
//safety mechanism; in some test setups the library has to answer BootNotifications without valid system time
OcppTimestamp ocppTimeReference = OcppTimestamp(2019,10,0,11,59,55);
OcppTimestamp ocppSelect = ocppTimeReference;
OcppTime *ocppTime = getOcppTime();
if (ocppTime) {
OcppTimestamp ocppNow = ocppTime->getOcppTimestampNow();
if (ocppNow > ocppTimeReference) {
//time has already been set
ocppSelect = ocppNow;
}
}
char ocppNowJson [JSONDATE_LENGTH + 1] = {'\0'};
ocppSelect.toJsonString(ocppNowJson, JSONDATE_LENGTH + 1);
payload["currentTime"] = ocppNowJson;
payload["interval"] = 86400; //heartbeat send interval - not relevant for JSON variant of OCPP so send dummy value that likely won't break
payload["status"] = "Accepted";
return doc;
}