Ntp.cpp

#include "Ntp.h"
#include <ESPAsyncUDP.h>


char * NtpClient::TimeServerName;
int8_t NtpClient::timezone;
time_t NtpClient::syncInterval;
IPAddress NtpClient::timeServer;

AsyncUDP NtpClient::udpListener;

byte NtpClient::NTPpacket[NTP_PACKET_SIZE];

void ICACHE_FLASH_ATTR NtpClient::Ntp(const char * server, int8_t tz, time_t syncSecs) {
	TimeServerName = strdup(server);
	timezone = tz;
	syncInterval = syncSecs;
	WiFi.hostByName(TimeServerName, timeServer);
	setSyncProvider(getNtpTime);
	setSyncInterval(syncInterval);
}

ICACHE_FLASH_ATTR NtpClient::~NtpClient() {
	udpListener.close();
}

// send an NTP request to the time server at the given address
time_t ICACHE_FLASH_ATTR NtpClient::getNtpTime() {
	memset(NTPpacket, 0, sizeof(NTPpacket));
	NTPpacket[0] = 0b11100011;
	NTPpacket[1] = 0;
	NTPpacket[2] = 6;
	NTPpacket[3] = 0xEC;
	NTPpacket[12] = 49;
	NTPpacket[13] = 0x4E;
	NTPpacket[14] = 49;
	NTPpacket[15] = 52;
	if (udpListener.connect(timeServer, 123)) {
		udpListener.onPacket([](AsyncUDPPacket packet) {
			unsigned long highWord = word(packet.data()[40], packet.data()[41]);
			unsigned long lowWord = word(packet.data()[42], packet.data()[43]);
			time_t UnixUTCtime = (highWord << 16 | lowWord) - 2208988800UL;
			setTime(UnixUTCtime);
		});
	}
	else {

	}
	udpListener.write(NTPpacket, sizeof(NTPpacket));
	// ugly
	return 0;
}

bool ICACHE_FLASH_ATTR NtpClient::processTime() {

	timeStatus_t ts = timeStatus();

	switch (ts) {
	case timeNeedsSync:
		return false;
		break;
	case timeSet:
		return true;
		break;
	default:
		return false;
	}
}

String ICACHE_FLASH_ATTR NtpClient::zeroPaddedIntVal(int val) {
	if (val < 10)
		return "0" + String(val);
	else
		return String(val);
}

//returns the current date/time as a string in iso8601 format
String ICACHE_FLASH_ATTR NtpClient::iso8601DateTime() {

	String hyphen = "-";
	String colon = ":";

	return	String(year()) + hyphen +
	        zeroPaddedIntVal(month()) + hyphen +
	        zeroPaddedIntVal(day()) + "T" +
	        zeroPaddedIntVal(hour()) + colon +
	        zeroPaddedIntVal(minute()) + colon +
	        zeroPaddedIntVal(second()) +
	        (timezone == 0 ? "Z" : String(timezone));
}

time_t NtpClient::getUptimeSec() {
	_uptimesec = _uptimesec + (millis () - _uptimesec);
	return _uptimesec / 1000;
}

deviceUptime ICACHE_FLASH_ATTR NtpClient::getDeviceUptime() {

	unsigned long currentmillis = millis();

	deviceUptime uptime;
	uptime.secs  = (long)((currentmillis / 1000) % 60);
	uptime.mins  = (long)((currentmillis / 60000) % 60);
	uptime.hours = (long)((currentmillis / 3600000) % 24);
	uptime.days  = (long)((currentmillis / 86400000) % 10);

	return uptime;

}

String ICACHE_FLASH_ATTR NtpClient::getDeviceUptimeString() {

	deviceUptime uptime = getDeviceUptime();

	return	String(uptime.days) + " days, " +
	        String(uptime.hours) + " hours, " +
	        String(uptime.mins) + " mins, " +
	        String(uptime.secs) + " secs";

}

/*
 * returns the current time as UTC (timezone offset removed)
 */
ICACHE_FLASH_ATTR time_t NtpClient::getUtcTimeNow() {

	return now() - timezone;

}