You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
111 lines
2.9 KiB
111 lines
2.9 KiB
/*
|
|
|
|
NTP MODULE
|
|
|
|
Copyright (C) 2016-2018 by Xose Pérez <xose dot perez at gmail dot com>
|
|
|
|
*/
|
|
|
|
#if NTP_SUPPORT
|
|
|
|
#include <TimeLib.h>
|
|
#include <NtpClientLib.h>
|
|
#include <WiFiClient.h>
|
|
#include <Ticker.h>
|
|
|
|
Ticker _ntp_delay;
|
|
|
|
// -----------------------------------------------------------------------------
|
|
// NTP
|
|
// -----------------------------------------------------------------------------
|
|
|
|
void _ntpWebSocketOnSend(JsonObject& root) {
|
|
root["time"] = ntpDateTime();
|
|
root["ntpVisible"] = 1;
|
|
root["ntpStatus"] = ntpSynced();
|
|
root["ntpServer1"] = getSetting("ntpServer1", NTP_SERVER);
|
|
root["ntpServer2"] = getSetting("ntpServer2");
|
|
root["ntpServer3"] = getSetting("ntpServer3");
|
|
root["ntpOffset"] = getSetting("ntpOffset", NTP_TIME_OFFSET).toInt();
|
|
root["ntpDST"] = getSetting("ntpDST", NTP_DAY_LIGHT).toInt() == 1;
|
|
}
|
|
|
|
void _ntpUpdate() {
|
|
#if WEB_SUPPORT
|
|
wsSend(_ntpWebSocketOnSend);
|
|
#endif
|
|
DEBUG_MSG_P(PSTR("[NTP] Time: %s\n"), (char *) ntpDateTime().c_str());
|
|
}
|
|
|
|
void _ntpConfigure() {
|
|
NTP.begin(
|
|
getSetting("ntpServer1", NTP_SERVER),
|
|
getSetting("ntpOffset", NTP_TIME_OFFSET).toInt(),
|
|
getSetting("ntpDST", NTP_DAY_LIGHT).toInt() == 1
|
|
);
|
|
if (getSetting("ntpServer2")) NTP.setNtpServerName(getSetting("ntpServer2"), 1);
|
|
if (getSetting("ntpServer3")) NTP.setNtpServerName(getSetting("ntpServer3"), 2);
|
|
NTP.setInterval(NTP_UPDATE_INTERVAL);
|
|
}
|
|
|
|
// -----------------------------------------------------------------------------
|
|
|
|
bool ntpSynced() {
|
|
return (timeStatus() == timeSet);
|
|
}
|
|
|
|
String ntpDateTime() {
|
|
if (!ntpSynced()) return String();
|
|
char buffer[20];
|
|
time_t t = now();
|
|
snprintf_P(buffer, sizeof(buffer),
|
|
PSTR("%04d-%02d-%02d %02d:%02d:%02d"),
|
|
year(t), month(t), day(t), hour(t), minute(t), second(t)
|
|
);
|
|
return String(buffer);
|
|
}
|
|
|
|
void ntpSetup() {
|
|
|
|
NTP.onNTPSyncEvent([](NTPSyncEvent_t error) {
|
|
if (error) {
|
|
#if WEB_SUPPORT
|
|
wsSend_P(PSTR("{\"ntpStatus\": false}"));
|
|
#endif
|
|
if (error == noResponse) {
|
|
DEBUG_MSG_P(PSTR("[NTP] Error: NTP server not reachable\n"));
|
|
} else if (error == invalidAddress) {
|
|
DEBUG_MSG_P(PSTR("[NTP] Error: Invalid NTP server address\n"));
|
|
}
|
|
} else {
|
|
_ntp_delay.once_ms(100, _ntpUpdate);
|
|
}
|
|
});
|
|
|
|
_ntpConfigure();
|
|
|
|
#if WEB_SUPPORT
|
|
wsOnSendRegister(_ntpWebSocketOnSend);
|
|
wsOnAfterParseRegister(_ntpConfigure);
|
|
#endif
|
|
|
|
// Register loop
|
|
espurnaRegisterLoop(ntpLoop);
|
|
|
|
}
|
|
|
|
void ntpLoop() {
|
|
|
|
now();
|
|
|
|
#if BROKER_SUPPORT
|
|
static unsigned char last_minute = 60;
|
|
if (ntpSynced() && (minute() != last_minute)) {
|
|
last_minute = minute();
|
|
brokerPublish(MQTT_TOPIC_DATETIME, ntpDateTime().c_str());
|
|
}
|
|
#endif
|
|
|
|
}
|
|
|
|
#endif // NTP_SUPPORT
|