PB_Emma_Ethernet - able to subscribe for >10hrs and still running

Users » bonchenko » Code » PB_Emma_Ethernet

able to subscribe for >10hrs and still running

Dependencies: ADE7758_v1 Crypto DHT11 MQTT MbedJSONValue SDFileSystem SPI_TFT_ILI9341 SWSPI SetRTC TFT_fonts Touch W5500Interface mbed-rtos mbed-src tuanpm

Fork of PB_emma_controller_mbed_src by Emma

emmaCode.cpp@10:1dc69e0ce7fd, 2015-07-13 (annotated)

Committer:: arsenalist
Date:: Mon Jul 13 06:25:58 2015 +0000
Revision:: 10:1dc69e0ce7fd
Parent:: 9:a58c04da4476
Child:: 11:2311b2d5157d

Working wifi config mode.; Not working operational mode with eth.

Who changed what in which revision?

User	Revision	Line number	New contents of line
arsenalist	0:f4e449fa34d7	1	#include "emmaCode.h"
arsenalist	0:f4e449fa34d7	2
arsenalist	0:f4e449fa34d7	3	//init debug port
arsenalist	0:f4e449fa34d7	4	Serial DBG(PA_9, PA_10); //tx, rx
arsenalist	0:f4e449fa34d7	5
arsenalist	0:f4e449fa34d7	6	//init wifi port
arsenalist	0:f4e449fa34d7	7	Serial _ESP(PA_2, PA_3); //tx, rx
arsenalist	8:51a0ca9079ca	8	//init espduino - without ch_pd pin
arsenalist	8:51a0ca9079ca	9	ESP esp(&_ESP, &DBG, ESP_BAUD);
arsenalist	0:f4e449fa34d7	10	//init wifi mqtt
arsenalist	0:f4e449fa34d7	11	ESPMQTT mqtt(&esp);
arsenalist	0:f4e449fa34d7	12	//init wifi rest
arsenalist	0:f4e449fa34d7	13	REST rest(&esp);
arsenalist	0:f4e449fa34d7	14
arsenalist	0:f4e449fa34d7	15	//init eth port
arsenalist	0:f4e449fa34d7	16	SPI spi(PB_15, PB_14, PB_13); //mosi, miso, sck
arsenalist	0:f4e449fa34d7	17	MQTTEthernet ipstack(&spi, PB_12, PC_6); //spi, cs, reset
arsenalist	0:f4e449fa34d7	18	MQTT::Client<MQTTEthernet, Countdown, MQTT_MAX_PACKET_SIZE> client(ipstack);
arsenalist	0:f4e449fa34d7	19
arsenalist	0:f4e449fa34d7	20	//init sd card
arsenalist	8:51a0ca9079ca	21	SDFileSystem sd(PA_7, PA_6, PA_5, PB_3, "sd"); //mosi, miso, sck, cs
arsenalist	0:f4e449fa34d7	22
arsenalist	8:51a0ca9079ca	23	//init ade7758 - without cs pin
arsenalist	8:51a0ca9079ca	24	ADE7758 ADE(PB_6, PB_4, PB_5, PB_2); //mosi, miso, sck, irq
arsenalist	0:f4e449fa34d7	25
arsenalist	0:f4e449fa34d7	26	//emma settings
arsenalist	0:f4e449fa34d7	27	string emmaUID;
arsenalist	4:76ab12e2f8a3	28	string hmac;
arsenalist	0:f4e449fa34d7	29	string platformDOMAIN;
arsenalist	0:f4e449fa34d7	30	string platformKEY;
arsenalist	0:f4e449fa34d7	31	string platformSECRET;
arsenalist	0:f4e449fa34d7	32	string wifiSSID;
arsenalist	0:f4e449fa34d7	33	string wifiPASS;
arsenalist	0:f4e449fa34d7	34	string gprsAPN;
arsenalist	0:f4e449fa34d7	35	string proxySERVER;
arsenalist	0:f4e449fa34d7	36	string proxyPORT;
arsenalist	0:f4e449fa34d7	37	string proxyAUTH;
arsenalist	0:f4e449fa34d7	38
arsenalist	4:76ab12e2f8a3	39	//nodes settings
arsenalist	4:76ab12e2f8a3	40	class NODES {
arsenalist	4:76ab12e2f8a3	41	public:
arsenalist	4:76ab12e2f8a3	42	REST *restConn;
arsenalist	4:76ab12e2f8a3	43	NODES(REST *r);
arsenalist	4:76ab12e2f8a3	44	string macAddr;
arsenalist	4:76ab12e2f8a3	45	string ipAddr;
arsenalist	4:76ab12e2f8a3	46	};
arsenalist	4:76ab12e2f8a3	47	NODES::NODES(REST *r) {
arsenalist	4:76ab12e2f8a3	48	restConn = r;
arsenalist	4:76ab12e2f8a3	49	}
arsenalist	4:76ab12e2f8a3	50	REST restObj[NODES_MAX] = {REST(&esp),REST(&esp),REST(&esp),REST(&esp),REST(&esp)};
arsenalist	4:76ab12e2f8a3	51	NODES nodes[NODES_MAX] = {NODES(&restObj[0]),NODES(&restObj[1]),NODES(&restObj[2]),NODES(&restObj[3]),NODES(&restObj[4])};
arsenalist	4:76ab12e2f8a3	52
arsenalist	0:f4e449fa34d7	53	//ade7758 variables
arsenalist	0:f4e449fa34d7	54	uint16_t AWattHrValue, BWattHrValue, CWattHrValue;
arsenalist	0:f4e449fa34d7	55	uint16_t AVAHrValue, BVAHrValue, CVAHrValue;
arsenalist	0:f4e449fa34d7	56	long AWattHrSum = 0;
arsenalist	0:f4e449fa34d7	57	long BWattHrSum = 0;
arsenalist	0:f4e449fa34d7	58	long CWattHrSum = 0;
arsenalist	0:f4e449fa34d7	59	float AWattHr, BWattHr, CWattHr;
arsenalist	4:76ab12e2f8a3	60	float AVrms, BVrms, CVrms;
arsenalist	4:76ab12e2f8a3	61	float AIrms, BIrms, CIrms;
arsenalist	4:76ab12e2f8a3	62	float AWatt, BWatt, CWatt;
arsenalist	4:76ab12e2f8a3	63	float XWattHr,XVrms,XWatt;
arsenalist	0:f4e449fa34d7	64
arsenalist	0:f4e449fa34d7	65	//variables
arsenalist	0:f4e449fa34d7	66	bool ethAvailable = false;
arsenalist	0:f4e449fa34d7	67	bool wifiAvailable = false;
arsenalist	0:f4e449fa34d7	68	bool gprsAvailable = false;
arsenalist	0:f4e449fa34d7	69	bool ethConnected = false;
arsenalist	0:f4e449fa34d7	70	bool wifiConnected = false;
arsenalist	9:a58c04da4476	71	bool gprsConnected = false;
arsenalist	0:f4e449fa34d7	72	bool useProxy = false;
arsenalist	0:f4e449fa34d7	73	bool newCommand = false;
arsenalist	0:f4e449fa34d7	74	string globalCommand;
arsenalist	4:76ab12e2f8a3	75	string rxBuf;
arsenalist	0:f4e449fa34d7	76
arsenalist	0:f4e449fa34d7	77	void emmaInit(void) {
arsenalist	4:76ab12e2f8a3	78	char s[64];
arsenalist	0:f4e449fa34d7	79	DBG.baud(19200);
arsenalist	0:f4e449fa34d7	80	DBG.printf("\r\nemmaInit\r\n");
arsenalist	0:f4e449fa34d7	81
arsenalist	0:f4e449fa34d7	82	//read settings
arsenalist	0:f4e449fa34d7	83	//readSetting("emmaUID"); //sd card need to be read once before working correctly
arsenalist	9:a58c04da4476	84	emmaUID = readSetting("emmaUID");
arsenalist	9:a58c04da4476	85	//emmaUID = "066eff575349896767073038";
arsenalist	0:f4e449fa34d7	86	DBG.printf("emmaUID:%s\r\n",emmaUID.c_str());
arsenalist	4:76ab12e2f8a3	87	//calculate hmac
arsenalist	4:76ab12e2f8a3	88	for(int i=0; i<sizeof(s); i++) {
arsenalist	4:76ab12e2f8a3	89	s[i]=0; }
arsenalist	4:76ab12e2f8a3	90	sprintf(s,"emma-%s",emmaUID.c_str());
arsenalist	4:76ab12e2f8a3	91	hmac = calculateMD5(s);
arsenalist	4:76ab12e2f8a3	92	DBG.printf("hmac:%s\r\n",hmac.c_str());
arsenalist	9:a58c04da4476	93	platformDOMAIN = readSetting("platformDOMAIN");
arsenalist	9:a58c04da4476	94	//platformDOMAIN = "testdulu";
arsenalist	0:f4e449fa34d7	95	DBG.printf("platformDOMAIN:%s\r\n",platformDOMAIN.c_str());
arsenalist	9:a58c04da4476	96	platformKEY = readSetting("platformKEY");
arsenalist	9:a58c04da4476	97	//platformKEY = "5980e444-81dd-47ba-8222-6a40bc94fdce";
arsenalist	0:f4e449fa34d7	98	DBG.printf("platformKEY:%s\r\n",platformKEY.c_str());
arsenalist	9:a58c04da4476	99	platformSECRET = readSetting("platformSECRET");
arsenalist	9:a58c04da4476	100	//platformSECRET = "3ca8ec0239fda2b6d12ba1580c91a052";
arsenalist	0:f4e449fa34d7	101	DBG.printf("platformSECRET:%s\r\n",platformSECRET.c_str());
arsenalist	9:a58c04da4476	102	proxySERVER = readSetting("proxySERVER");
arsenalist	0:f4e449fa34d7	103	DBG.printf("proxySERVER:%s\r\n",proxySERVER.c_str());
arsenalist	9:a58c04da4476	104	proxyPORT = readSetting("proxyPORT");
arsenalist	0:f4e449fa34d7	105	DBG.printf("proxyPORT:%s\r\n",proxyPORT.c_str());
arsenalist	9:a58c04da4476	106	proxyAUTH = readSetting("proxyAUTH");
arsenalist	0:f4e449fa34d7	107	DBG.printf("proxyAUTH:%s\r\n",proxyAUTH.c_str());
arsenalist	0:f4e449fa34d7	108
arsenalist	0:f4e449fa34d7	109	//check proxy
arsenalist	0:f4e449fa34d7	110	if(!proxySERVER.empty() && !proxyPORT.empty() && !proxyAUTH.empty()) {
arsenalist	0:f4e449fa34d7	111	useProxy = true;
arsenalist	0:f4e449fa34d7	112	} else {
arsenalist	0:f4e449fa34d7	113	useProxy = false;
arsenalist	0:f4e449fa34d7	114	}
arsenalist	0:f4e449fa34d7	115	//testing purpose
arsenalist	0:f4e449fa34d7	116	useProxy = false;
arsenalist	0:f4e449fa34d7	117	DBG.printf("proxy:%d\r\n",useProxy);
arsenalist	0:f4e449fa34d7	118
arsenalist	8:51a0ca9079ca	119	//check available interface
arsenalist	8:51a0ca9079ca	120	isEthAvailable(); //check whether cable is connected
arsenalist	9:a58c04da4476	121	wifiAvailable = true; //we assume wifi will always available
arsenalist	8:51a0ca9079ca	122	DBG.printf("eth:%d\r\n",ethAvailable);
arsenalist	8:51a0ca9079ca	123	DBG.printf("wifi:%d\r\n",wifiAvailable);
arsenalist	8:51a0ca9079ca	124	DBG.printf("gprs:%d\r\n",gprsAvailable);
arsenalist	0:f4e449fa34d7	125	}
arsenalist	0:f4e449fa34d7	126	void emmaModeWiFiConfig(void) {
arsenalist	0:f4e449fa34d7	127	string str;
arsenalist	0:f4e449fa34d7	128
arsenalist	0:f4e449fa34d7	129	if(wifiAvailable) {
arsenalist	0:f4e449fa34d7	130	DBG.printf("emmaModeWiFiConfig\r\n");
arsenalist	0:f4e449fa34d7	131
arsenalist	0:f4e449fa34d7	132	//set wifi module to configuration
arsenalist	0:f4e449fa34d7	133	_ESP.printf("MODE=C");
arsenalist	0:f4e449fa34d7	134	while(1) {
arsenalist	0:f4e449fa34d7	135	char rcv[128] = {};
arsenalist	0:f4e449fa34d7	136	rcvReply(rcv,3000);
arsenalist	0:f4e449fa34d7	137	str = rcv;
arsenalist	0:f4e449fa34d7	138	if(str.find("SC_STATUS_FIND_CHANNEL") != std::string::npos)
arsenalist	0:f4e449fa34d7	139	break;
arsenalist	0:f4e449fa34d7	140	}
arsenalist	0:f4e449fa34d7	141	DBG.printf("entering wifi configuration mode\r\n");
arsenalist	0:f4e449fa34d7	142	while(1) {
arsenalist	0:f4e449fa34d7	143	char rcv[128] = {};
arsenalist	0:f4e449fa34d7	144	rcvReply(rcv,3000);
arsenalist	0:f4e449fa34d7	145	str = rcv;
arsenalist	0:f4e449fa34d7	146	if(str.find("MODE=C OK") != std::string::npos) {
arsenalist	0:f4e449fa34d7	147	//save wifiSSID and wifiPASS
arsenalist	0:f4e449fa34d7	148	if(str.find("[") != std::string::npos && str.find("]") != std::string::npos) {
arsenalist	0:f4e449fa34d7	149	str.erase(str.begin(),str.begin()+str.find("[")+1);
arsenalist	0:f4e449fa34d7	150	str.erase(str.begin()+str.find("]"),str.end());
arsenalist	0:f4e449fa34d7	151
arsenalist	0:f4e449fa34d7	152	MbedJSONValue jsonValue;
arsenalist	0:f4e449fa34d7	153	parse(jsonValue,str.c_str());
arsenalist	0:f4e449fa34d7	154
arsenalist	0:f4e449fa34d7	155	char *parameter[2] = {"wifiSSID","wifiPASS"};
arsenalist	0:f4e449fa34d7	156
arsenalist	0:f4e449fa34d7	157	for(int i=0; i<2; i++) {
arsenalist	0:f4e449fa34d7	158	if(jsonValue.hasMember(parameter[i])) {
arsenalist	0:f4e449fa34d7	159	string val = jsonValue[parameter[i]].get<std::string>();
arsenalist	4:76ab12e2f8a3	160	//int st = writeSetting(parameter[i],val.c_str());
arsenalist	4:76ab12e2f8a3	161	//if(st) {
arsenalist	4:76ab12e2f8a3	162	// DBG.printf("%s is saved\r\n",parameter[i]);
arsenalist	4:76ab12e2f8a3	163	//} else {
arsenalist	4:76ab12e2f8a3	164	// DBG.printf("%s is not saved\r\n",parameter[i]);
arsenalist	4:76ab12e2f8a3	165	//}
arsenalist	0:f4e449fa34d7	166	}
arsenalist	0:f4e449fa34d7	167	}
arsenalist	0:f4e449fa34d7	168	}
arsenalist	0:f4e449fa34d7	169	}
arsenalist	0:f4e449fa34d7	170	}
arsenalist	0:f4e449fa34d7	171	} else {
arsenalist	0:f4e449fa34d7	172	DBG.printf("no wifi found\r\n");
arsenalist	0:f4e449fa34d7	173	}
arsenalist	0:f4e449fa34d7	174	}
arsenalist	0:f4e449fa34d7	175	void emmaModeSettings(void) {
arsenalist	0:f4e449fa34d7	176	bool clientIsConnected = false;
arsenalist	0:f4e449fa34d7	177	bool serverIsListened = false;
arsenalist	0:f4e449fa34d7	178	char s[32];
arsenalist	0:f4e449fa34d7	179	string str;
arsenalist	0:f4e449fa34d7	180
arsenalist	8:51a0ca9079ca	181	//create settings dir
arsenalist	0:f4e449fa34d7	182	mkdir("/sd/settings",0777);
arsenalist	8:51a0ca9079ca	183
arsenalist	0:f4e449fa34d7	184	//get and write emmaUID
arsenalist	0:f4e449fa34d7	185	string uid = getUID();
arsenalist	0:f4e449fa34d7	186	sprintf(s,"(%s)",uid.c_str());
arsenalist	0:f4e449fa34d7	187	uid = s;
arsenalist	0:f4e449fa34d7	188	writeSetting("emmaUID",uid);
arsenalist	0:f4e449fa34d7	189
arsenalist	8:51a0ca9079ca	190	if(ethAvailable) {
arsenalist	0:f4e449fa34d7	191	DBG.printf("emmaModeSettings - eth\r\n");
arsenalist	0:f4e449fa34d7	192
arsenalist	0:f4e449fa34d7	193	TCPSocketServer svr;
arsenalist	0:f4e449fa34d7	194	TCPSocketConnection clientSock;
arsenalist	0:f4e449fa34d7	195
arsenalist	0:f4e449fa34d7	196	if(svr.bind(SERVER_PORT) < 0) {
arsenalist	0:f4e449fa34d7	197	DBG.printf("tcp server bind failed\r\n");
arsenalist	0:f4e449fa34d7	198	} else {
arsenalist	0:f4e449fa34d7	199	DBG.printf("tcp server bind success\r\n");
arsenalist	0:f4e449fa34d7	200	serverIsListened = true;
arsenalist	0:f4e449fa34d7	201	}
arsenalist	0:f4e449fa34d7	202
arsenalist	0:f4e449fa34d7	203	DBG.printf("please connect to %s\r\n",ipstack.getEth().getIPAddress());
arsenalist	0:f4e449fa34d7	204
arsenalist	0:f4e449fa34d7	205	if(svr.listen(1) < 0) {
arsenalist	0:f4e449fa34d7	206	DBG.printf("tcp server listen failed\r\n");
arsenalist	0:f4e449fa34d7	207	} else {
arsenalist	0:f4e449fa34d7	208	DBG.printf("tcp server is listening...\r\n");
arsenalist	0:f4e449fa34d7	209	}
arsenalist	0:f4e449fa34d7	210
arsenalist	0:f4e449fa34d7	211	clientSock.set_blocking(false,30000); //timeout after 30sec
arsenalist	0:f4e449fa34d7	212
arsenalist	0:f4e449fa34d7	213	//listening
arsenalist	0:f4e449fa34d7	214	while (serverIsListened) {
arsenalist	0:f4e449fa34d7	215	if(svr.accept(clientSock) < 0) {
arsenalist	0:f4e449fa34d7	216	DBG.printf("failed to accept connection\r\n");
arsenalist	0:f4e449fa34d7	217	} else {
arsenalist	0:f4e449fa34d7	218	DBG.printf("connection success!\r\nIP: %s\r\n",clientSock.get_address());
arsenalist	0:f4e449fa34d7	219	clientIsConnected = true;
arsenalist	0:f4e449fa34d7	220
arsenalist	0:f4e449fa34d7	221	while(clientIsConnected) {
arsenalist	0:f4e449fa34d7	222	char buffer[1024] = {};
arsenalist	0:f4e449fa34d7	223	switch(clientSock.receive(buffer,1023)) {
arsenalist	0:f4e449fa34d7	224	case 0:
arsenalist	0:f4e449fa34d7	225	DBG.printf("received buffer is empty\r\n");
arsenalist	0:f4e449fa34d7	226	clientIsConnected = false;
arsenalist	0:f4e449fa34d7	227	break;
arsenalist	0:f4e449fa34d7	228	case -1:
arsenalist	0:f4e449fa34d7	229	DBG.printf("failed to read data from client\r\n");
arsenalist	0:f4e449fa34d7	230	clientIsConnected = false;
arsenalist	0:f4e449fa34d7	231	break;
arsenalist	0:f4e449fa34d7	232	default:
arsenalist	0:f4e449fa34d7	233	//DBG.printf("received data: %d\r\n%s\r\n",strlen(buffer),buffer);
arsenalist	0:f4e449fa34d7	234	DBG.printf("\r\n");
arsenalist	0:f4e449fa34d7	235
arsenalist	0:f4e449fa34d7	236	str = buffer;
arsenalist	0:f4e449fa34d7	237	if(str.find("[") != std::string::npos && str.find("]") != std::string::npos) {
arsenalist	0:f4e449fa34d7	238	str.erase(str.begin(),str.begin()+str.find("[")+1);
arsenalist	0:f4e449fa34d7	239	str.erase(str.begin()+str.find("]"),str.end());
arsenalist	0:f4e449fa34d7	240
arsenalist	0:f4e449fa34d7	241	MbedJSONValue jsonValue;
arsenalist	0:f4e449fa34d7	242	parse(jsonValue,str.c_str());
arsenalist	0:f4e449fa34d7	243
arsenalist	0:f4e449fa34d7	244	char *parameter[4] = {"gprsAPN","proxySERVER","proxyPORT","proxyAUTH"};
arsenalist	0:f4e449fa34d7	245
arsenalist	0:f4e449fa34d7	246	for(int i=0; i<4; i++) {
arsenalist	0:f4e449fa34d7	247	if(jsonValue.hasMember(parameter[i])) {
arsenalist	0:f4e449fa34d7	248	string val = jsonValue[parameter[i]].get<std::string>();
arsenalist	0:f4e449fa34d7	249	int st = writeSetting(parameter[i],val.c_str());
arsenalist	0:f4e449fa34d7	250	if(st) {
arsenalist	0:f4e449fa34d7	251	DBG.printf("%s: %s is saved\r\n",parameter[i],val.c_str());
arsenalist	0:f4e449fa34d7	252	} else {
arsenalist	0:f4e449fa34d7	253	DBG.printf("%s is not saved\r\n",parameter[i]);
arsenalist	0:f4e449fa34d7	254	}
arsenalist	0:f4e449fa34d7	255	}
arsenalist	0:f4e449fa34d7	256	}
arsenalist	0:f4e449fa34d7	257	}
arsenalist	0:f4e449fa34d7	258	break;
arsenalist	0:f4e449fa34d7	259	}
arsenalist	0:f4e449fa34d7	260	}
arsenalist	0:f4e449fa34d7	261	DBG.printf("close connection\r\n");
arsenalist	0:f4e449fa34d7	262	clientSock.close();
arsenalist	0:f4e449fa34d7	263	}
arsenalist	0:f4e449fa34d7	264	}
arsenalist	8:51a0ca9079ca	265	} else if(wifiAvailable) {
arsenalist	8:51a0ca9079ca	266	DBG.printf("emmaModeSettings - wifi\r\n");
arsenalist	8:51a0ca9079ca	267
arsenalist	8:51a0ca9079ca	268	_ESP.printf("MODE=S");
arsenalist	8:51a0ca9079ca	269	while(1) {
arsenalist	8:51a0ca9079ca	270	char rcv[128] = {};
arsenalist	8:51a0ca9079ca	271	rcvReply(rcv,3000);
arsenalist	8:51a0ca9079ca	272	str = rcv;
arsenalist	8:51a0ca9079ca	273	if(str.find("MODE=S_OK") != std::string::npos)
arsenalist	8:51a0ca9079ca	274	break;
arsenalist	8:51a0ca9079ca	275	}
arsenalist	8:51a0ca9079ca	276	DBG.printf("entering settings mode\r\n");
arsenalist	8:51a0ca9079ca	277	while(1) {
arsenalist	8:51a0ca9079ca	278	char rcv[512] = {};
arsenalist	8:51a0ca9079ca	279	rcvReply(rcv,3000);
arsenalist	8:51a0ca9079ca	280	//DBG.printf("rcv:%s\r\n",rcv);
arsenalist	8:51a0ca9079ca	281	str = rcv;
arsenalist	8:51a0ca9079ca	282	if(str.find("MODE=S_Config") != std::string::npos) {
arsenalist	8:51a0ca9079ca	283	//save gprs and proxy setting
arsenalist	8:51a0ca9079ca	284	if(str.find("[") != std::string::npos && str.find("]") != std::string::npos) {
arsenalist	8:51a0ca9079ca	285	str.erase(str.begin(),str.begin()+str.find("[")+1);
arsenalist	8:51a0ca9079ca	286	str.erase(str.begin()+str.find("]"),str.end());
arsenalist	8:51a0ca9079ca	287
arsenalist	8:51a0ca9079ca	288	MbedJSONValue jsonValue;
arsenalist	8:51a0ca9079ca	289	parse(jsonValue,str.c_str());
arsenalist	8:51a0ca9079ca	290
arsenalist	8:51a0ca9079ca	291	char *parameter[4] = {"gprsAPN","proxySERVER","proxyPORT","proxyAUTH"};
arsenalist	8:51a0ca9079ca	292
arsenalist	8:51a0ca9079ca	293	for(int i=0; i<4; i++) {
arsenalist	8:51a0ca9079ca	294	if(jsonValue.hasMember(parameter[i])) {
arsenalist	8:51a0ca9079ca	295	string val = jsonValue[parameter[i]].get<std::string>();
arsenalist	8:51a0ca9079ca	296	int st = writeSetting(parameter[i],val.c_str());
arsenalist	8:51a0ca9079ca	297	if(st) {
arsenalist	8:51a0ca9079ca	298	DBG.printf("%s: %s is saved\r\n",parameter[i],val.c_str());
arsenalist	8:51a0ca9079ca	299	} else {
arsenalist	8:51a0ca9079ca	300	DBG.printf("%s is not saved\r\n",parameter[i]);
arsenalist	8:51a0ca9079ca	301	}
arsenalist	8:51a0ca9079ca	302	}
arsenalist	8:51a0ca9079ca	303	}
arsenalist	8:51a0ca9079ca	304	}
arsenalist	8:51a0ca9079ca	305	} else if(str.find("connect") != std::string::npos) {
arsenalist	8:51a0ca9079ca	306	DBG.printf("connection success!\r\n");
arsenalist	8:51a0ca9079ca	307	}
arsenalist	8:51a0ca9079ca	308	}
arsenalist	0:f4e449fa34d7	309	} else {
arsenalist	9:a58c04da4476	310	DBG.printf("no eth or wifi is available\r\n");
arsenalist	0:f4e449fa34d7	311	}
arsenalist	0:f4e449fa34d7	312	}
arsenalist	0:f4e449fa34d7	313	void emmaModeRegister(void) {
arsenalist	0:f4e449fa34d7	314	bool emmaGetRegKey = false;
arsenalist	0:f4e449fa34d7	315	bool emmaRegistered = false;
arsenalist	0:f4e449fa34d7	316	char s[512];
arsenalist	0:f4e449fa34d7	317	char r[256];
arsenalist	0:f4e449fa34d7	318	int connPort;
arsenalist	0:f4e449fa34d7	319	int loop = 0;
arsenalist	0:f4e449fa34d7	320	string connData;
arsenalist	0:f4e449fa34d7	321	string connHost;
arsenalist	4:76ab12e2f8a3	322	//string hmac;
arsenalist	0:f4e449fa34d7	323	string str;
arsenalist	0:f4e449fa34d7	324	string regKey;
arsenalist	0:f4e449fa34d7	325	Timer t;
arsenalist	0:f4e449fa34d7	326
arsenalist	0:f4e449fa34d7	327	//check connected interface
arsenalist	8:51a0ca9079ca	328	//connectedIface();
arsenalist	8:51a0ca9079ca	329	isEthConnected();
arsenalist	8:51a0ca9079ca	330	isWiFiConnected();
arsenalist	8:51a0ca9079ca	331	isGprsConnected();
arsenalist	0:f4e449fa34d7	332	DBG.printf("ethConnected:%d\r\n",ethConnected);
arsenalist	0:f4e449fa34d7	333	DBG.printf("wifiConnected:%d\r\n",wifiConnected);
arsenalist	0:f4e449fa34d7	334
arsenalist	0:f4e449fa34d7	335	//calculate hmac
arsenalist	4:76ab12e2f8a3	336	//for(int i=0; i<sizeof(s); i++) {
arsenalist	4:76ab12e2f8a3	337	// s[i]=0; }
arsenalist	4:76ab12e2f8a3	338	//sprintf(s,"emma-%s",emmaUID.c_str());
arsenalist	4:76ab12e2f8a3	339	//hmac = calculateMD5(s);
arsenalist	4:76ab12e2f8a3	340	//DBG.printf("hmac:%s\r\n",hmac.c_str());
arsenalist	0:f4e449fa34d7	341
arsenalist	9:a58c04da4476	342	if(ethConnected) {
arsenalist	9:a58c04da4476	343	DBG.printf("emmaModeRegister - eth\r\n");
arsenalist	9:a58c04da4476	344
arsenalist	9:a58c04da4476	345	//set connHost, connPort, connData
arsenalist	9:a58c04da4476	346	if(useProxy) {
arsenalist	9:a58c04da4476	347	DBG.printf("use proxy\r\n");
arsenalist	9:a58c04da4476	348	connHost = proxySERVER;
arsenalist	9:a58c04da4476	349	sscanf(proxyPORT.c_str(),"%d",&connPort);
arsenalist	9:a58c04da4476	350	for(int i=0; i<sizeof(s); i++) {
arsenalist	9:a58c04da4476	351	s[i]=0; }
arsenalist	9:a58c04da4476	352	sprintf(s,"GET http://%s:%d/emma/api/controller/register?uid=%s&hmac=%s HTTP/1.0\nHost: %s\r\n\r\n",EMMA_SERVER_HOST,EMMA_SERVER_PORT,emmaUID.c_str(),hmac.c_str(),EMMA_SERVER_HOST);
arsenalist	9:a58c04da4476	353	connData = s;
arsenalist	9:a58c04da4476	354	} else {
arsenalist	9:a58c04da4476	355	DBG.printf("no proxy\r\n");
arsenalist	9:a58c04da4476	356	connHost = EMMA_SERVER_HOST;
arsenalist	9:a58c04da4476	357	connPort = EMMA_SERVER_PORT;
arsenalist	9:a58c04da4476	358	for(int i=0; i<sizeof(s); i++) {
arsenalist	9:a58c04da4476	359	s[i]=0; }
arsenalist	9:a58c04da4476	360	sprintf(s,"GET /emma/api/controller/register?uid=%s&hmac=%s HTTP/1.0\nHost: %s\r\n\r\n",emmaUID.c_str(),hmac.c_str(),EMMA_SERVER_HOST);
arsenalist	9:a58c04da4476	361	connData = s;
arsenalist	9:a58c04da4476	362	}
arsenalist	9:a58c04da4476	363
arsenalist	9:a58c04da4476	364	//register
arsenalist	9:a58c04da4476	365	while(!emmaGetRegKey) {
arsenalist	9:a58c04da4476	366	str = "";
arsenalist	9:a58c04da4476	367	str = ethGET(connHost,connPort,connData);
arsenalist	9:a58c04da4476	368	DBG.printf("rsp reg:%s\r\n",str.c_str());
arsenalist	9:a58c04da4476	369
arsenalist	9:a58c04da4476	370	//check and save platform setting
arsenalist	9:a58c04da4476	371	if(str.find("[") != std::string::npos && str.find("]") != std::string::npos) {
arsenalist	9:a58c04da4476	372	str.erase(str.begin(),str.begin()+str.find("[")+1);
arsenalist	9:a58c04da4476	373	str.erase(str.begin()+str.find("]"),str.end());
arsenalist	9:a58c04da4476	374
arsenalist	9:a58c04da4476	375	MbedJSONValue jsonValue;
arsenalist	9:a58c04da4476	376	parse(jsonValue,str.c_str());
arsenalist	9:a58c04da4476	377
arsenalist	9:a58c04da4476	378	char *parameter[4] = {"platformDOMAIN","platformKEY","platformSECRET","registrationKey"};
arsenalist	9:a58c04da4476	379
arsenalist	9:a58c04da4476	380	//save platform parameter
arsenalist	9:a58c04da4476	381	writeSetting(parameter[0],"()"); //sd card need to be initialized
arsenalist	9:a58c04da4476	382	for(int i=0; i<3; i++) {
arsenalist	9:a58c04da4476	383	if(jsonValue.hasMember(parameter[i])) {
arsenalist	9:a58c04da4476	384	string val = jsonValue[parameter[i]].get<std::string>();
arsenalist	9:a58c04da4476	385	int st = writeSetting(parameter[i],val.c_str());
arsenalist	9:a58c04da4476	386	if(st) {
arsenalist	9:a58c04da4476	387	DBG.printf("%s: %s is saved\r\n",parameter[i],val.c_str());
arsenalist	9:a58c04da4476	388	} else {
arsenalist	9:a58c04da4476	389	DBG.printf("%s is not saved\r\n",parameter[i]);
arsenalist	9:a58c04da4476	390	}
arsenalist	9:a58c04da4476	391	}
arsenalist	9:a58c04da4476	392	}
arsenalist	9:a58c04da4476	393
arsenalist	9:a58c04da4476	394	//get registrationKey
arsenalist	9:a58c04da4476	395	if(jsonValue.hasMember(parameter[3])) {
arsenalist	9:a58c04da4476	396	string val = jsonValue[parameter[3]].get<std::string>();
arsenalist	9:a58c04da4476	397	if(val.find("(") != std::string::npos && val.find(")") != std::string::npos) {
arsenalist	9:a58c04da4476	398	val.erase(val.begin(),val.begin()+val.find("(")+1);
arsenalist	9:a58c04da4476	399	val.erase(val.begin()+val.find(")"),val.end());
arsenalist	9:a58c04da4476	400	regKey = val;
arsenalist	9:a58c04da4476	401	DBG.printf("%s: %s\r\n",parameter[3],regKey.c_str());
arsenalist	9:a58c04da4476	402	emmaGetRegKey = true;
arsenalist	9:a58c04da4476	403	}
arsenalist	9:a58c04da4476	404	}
arsenalist	9:a58c04da4476	405	}
arsenalist	9:a58c04da4476	406	}
arsenalist	9:a58c04da4476	407
arsenalist	9:a58c04da4476	408	//calculate hmac
arsenalist	9:a58c04da4476	409	for(int i=0; i<sizeof(r); i++) {
arsenalist	9:a58c04da4476	410	r[i]=0; }
arsenalist	9:a58c04da4476	411	sprintf(r,"emma-%s-%s",emmaUID.c_str(),regKey.c_str());
arsenalist	9:a58c04da4476	412	hmac = calculateMD5(r);
arsenalist	9:a58c04da4476	413	DBG.printf("hmac:%s\r\n",hmac.c_str());
arsenalist	9:a58c04da4476	414
arsenalist	9:a58c04da4476	415	//set connData
arsenalist	9:a58c04da4476	416	if(useProxy) {
arsenalist	9:a58c04da4476	417	DBG.printf("use proxy\r\n");
arsenalist	9:a58c04da4476	418	for(int i=0; i<sizeof(s); i++) {
arsenalist	9:a58c04da4476	419	s[i]=0; }
arsenalist	9:a58c04da4476	420	sprintf(s,"GET http://%s:%d/emma/api/controller/verify?uid=%s&registrationKey=%s&hmac=%s HTTP/1.0\nHost: %s\r\n\r\n",EMMA_SERVER_HOST,EMMA_SERVER_PORT,emmaUID.c_str(),regKey.c_str(),hmac.c_str(),EMMA_SERVER_HOST);
arsenalist	9:a58c04da4476	421	connData = s;
arsenalist	9:a58c04da4476	422	} else {
arsenalist	9:a58c04da4476	423	DBG.printf("no proxy\r\n");
arsenalist	9:a58c04da4476	424	for(int i=0; i<sizeof(s); i++) {
arsenalist	9:a58c04da4476	425	s[i]=0; }
arsenalist	9:a58c04da4476	426	sprintf(s,"GET /emma/api/controller/verify?uid=%s&registrationKey=%s&hmac=%s HTTP/1.0\nHost: %s\r\n\r\n",emmaUID.c_str(),regKey.c_str(),hmac.c_str(),EMMA_SERVER_HOST);
arsenalist	9:a58c04da4476	427	connData = s;
arsenalist	9:a58c04da4476	428	}
arsenalist	9:a58c04da4476	429
arsenalist	9:a58c04da4476	430	//verify registration
arsenalist	9:a58c04da4476	431	while(!emmaRegistered && loop < 12){
arsenalist	9:a58c04da4476	432	str.clear();
arsenalist	9:a58c04da4476	433	str = ethGET(connHost,connPort,connData);
arsenalist	9:a58c04da4476	434	DBG.printf("rsp vrf:%s\r\n",str.c_str());
arsenalist	9:a58c04da4476	435
arsenalist	9:a58c04da4476	436	//check verification
arsenalist	9:a58c04da4476	437	if(str.find("[") != std::string::npos && str.find("]") != std::string::npos) {
arsenalist	9:a58c04da4476	438	str.erase(str.begin(),str.begin()+str.find("[")+1);
arsenalist	9:a58c04da4476	439	str.erase(str.begin()+str.find("]"),str.end());
arsenalist	9:a58c04da4476	440
arsenalist	9:a58c04da4476	441	MbedJSONValue jsonValue;
arsenalist	9:a58c04da4476	442	parse(jsonValue,str.c_str());
arsenalist	9:a58c04da4476	443	if(jsonValue.hasMember("user")) {
arsenalist	9:a58c04da4476	444	string val = jsonValue["user"].get<std::string>();
arsenalist	9:a58c04da4476	445	DBG.printf("%s is registered\r\n",val.c_str());
arsenalist	9:a58c04da4476	446	emmaRegistered = true;
arsenalist	9:a58c04da4476	447	}
arsenalist	9:a58c04da4476	448	}
arsenalist	9:a58c04da4476	449	wait(5);
arsenalist	9:a58c04da4476	450	loop++;
arsenalist	9:a58c04da4476	451	}
arsenalist	9:a58c04da4476	452
arsenalist	9:a58c04da4476	453	//check whether registration success
arsenalist	9:a58c04da4476	454	if(emmaRegistered) {
arsenalist	9:a58c04da4476	455	DBG.printf("registration successful\r\n");
arsenalist	9:a58c04da4476	456	} else {
arsenalist	9:a58c04da4476	457	DBG.printf("registration unsuccessful\r\n");
arsenalist	9:a58c04da4476	458	}
arsenalist	9:a58c04da4476	459	while(1);
arsenalist	9:a58c04da4476	460
arsenalist	9:a58c04da4476	461	} else if(wifiConnected) {
arsenalist	0:f4e449fa34d7	462	DBG.printf("emmaModeRegister - wifi\r\n");
arsenalist	0:f4e449fa34d7	463
arsenalist	0:f4e449fa34d7	464	_ESP.printf("MODE=B");
arsenalist	0:f4e449fa34d7	465	wait(1);
arsenalist	0:f4e449fa34d7	466	while(!esp.ready());
arsenalist	0:f4e449fa34d7	467
arsenalist	0:f4e449fa34d7	468	//set connHost, connPort
arsenalist	0:f4e449fa34d7	469	if(useProxy) {
arsenalist	0:f4e449fa34d7	470	connHost = proxySERVER;
arsenalist	0:f4e449fa34d7	471	sscanf(proxyPORT.c_str(),"%d",&connPort);
arsenalist	0:f4e449fa34d7	472	} else {
arsenalist	0:f4e449fa34d7	473	connHost = EMMA_SERVER_HOST;
arsenalist	0:f4e449fa34d7	474	connPort = EMMA_SERVER_PORT;
arsenalist	0:f4e449fa34d7	475	}
arsenalist	0:f4e449fa34d7	476
arsenalist	0:f4e449fa34d7	477	//rest begin
arsenalist	0:f4e449fa34d7	478	if(!rest.begin(connHost.c_str(),connPort,false)) {
arsenalist	0:f4e449fa34d7	479	DBG.printf("EMMA: fail to setup rest");
arsenalist	0:f4e449fa34d7	480	while(1);
arsenalist	0:f4e449fa34d7	481	}
arsenalist	0:f4e449fa34d7	482	//wifiConnected = true; //with custom firmware, wifi module should connect automatically
arsenalist	0:f4e449fa34d7	483
arsenalist	0:f4e449fa34d7	484	esp.process();
arsenalist	0:f4e449fa34d7	485	if(wifiConnected) {
arsenalist	0:f4e449fa34d7	486	//set connData
arsenalist	0:f4e449fa34d7	487	if(useProxy) {
arsenalist	0:f4e449fa34d7	488	for(int i=0; i<sizeof(s); i++) {
arsenalist	0:f4e449fa34d7	489	s[i]=0; }
arsenalist	0:f4e449fa34d7	490	sprintf(s,"http://%s:%d/emma/api/controller/register?uid=%s&hmac=%s",EMMA_SERVER_HOST,EMMA_SERVER_PORT,emmaUID.c_str(),hmac.c_str());
arsenalist	0:f4e449fa34d7	491	connData = s;
arsenalist	0:f4e449fa34d7	492	} else {
arsenalist	0:f4e449fa34d7	493	for(int i=0; i<sizeof(s); i++) {
arsenalist	0:f4e449fa34d7	494	s[i]=0; }
arsenalist	0:f4e449fa34d7	495	sprintf(s,"/emma/api/controller/register?uid=%s&hmac=%s",emmaUID.c_str(),hmac.c_str());
arsenalist	0:f4e449fa34d7	496	connData = s;
arsenalist	0:f4e449fa34d7	497	}
arsenalist	0:f4e449fa34d7	498
arsenalist	0:f4e449fa34d7	499	//register
arsenalist	0:f4e449fa34d7	500	while(!emmaGetRegKey) {
arsenalist	0:f4e449fa34d7	501	rest.get(connData.c_str());
arsenalist	0:f4e449fa34d7	502	for(int i=0; i<sizeof(s); i++) {
arsenalist	0:f4e449fa34d7	503	s[i]=0; }
arsenalist	0:f4e449fa34d7	504	rest.getResponse(s,sizeof(s));
arsenalist	0:f4e449fa34d7	505	DBG.printf("rsp reg:%s\r\n",s);
arsenalist	0:f4e449fa34d7	506
arsenalist	0:f4e449fa34d7	507	//check and save platform setting
arsenalist	0:f4e449fa34d7	508	str = s;
arsenalist	0:f4e449fa34d7	509	if(str.find("[") != std::string::npos && str.find("]") != std::string::npos) {
arsenalist	0:f4e449fa34d7	510	str.erase(str.begin(),str.begin()+str.find("[")+1);
arsenalist	0:f4e449fa34d7	511	str.erase(str.begin()+str.find("]"),str.end());
arsenalist	0:f4e449fa34d7	512
arsenalist	0:f4e449fa34d7	513	MbedJSONValue jsonValue;
arsenalist	0:f4e449fa34d7	514	parse(jsonValue,str.c_str());
arsenalist	0:f4e449fa34d7	515
arsenalist	0:f4e449fa34d7	516	char *parameter[4] = {"platformDOMAIN","platformKEY","platformSECRET","registrationKey"};
arsenalist	0:f4e449fa34d7	517
arsenalist	0:f4e449fa34d7	518	//save platform parameter
arsenalist	0:f4e449fa34d7	519	writeSetting(parameter[0],"()"); //sd card need to be initialized
arsenalist	0:f4e449fa34d7	520	for(int i=0; i<3; i++) {
arsenalist	0:f4e449fa34d7	521	if(jsonValue.hasMember(parameter[i])) {
arsenalist	0:f4e449fa34d7	522	string val = jsonValue[parameter[i]].get<std::string>();
arsenalist	0:f4e449fa34d7	523	int st = writeSetting(parameter[i],val.c_str());
arsenalist	0:f4e449fa34d7	524	if(st) {
arsenalist	0:f4e449fa34d7	525	DBG.printf("%s: %s is saved\r\n",parameter[i],val.c_str());
arsenalist	0:f4e449fa34d7	526	} else {
arsenalist	0:f4e449fa34d7	527	DBG.printf("%s is not saved\r\n",parameter[i]);
arsenalist	0:f4e449fa34d7	528	}
arsenalist	0:f4e449fa34d7	529	}
arsenalist	0:f4e449fa34d7	530	}
arsenalist	0:f4e449fa34d7	531
arsenalist	0:f4e449fa34d7	532	//get registrationKey
arsenalist	0:f4e449fa34d7	533	if(jsonValue.hasMember(parameter[3])) {
arsenalist	0:f4e449fa34d7	534	string val = jsonValue[parameter[3]].get<std::string>();
arsenalist	0:f4e449fa34d7	535	if(val.find("(") != std::string::npos && val.find(")") != std::string::npos) {
arsenalist	0:f4e449fa34d7	536	val.erase(val.begin(),val.begin()+val.find("(")+1);
arsenalist	0:f4e449fa34d7	537	val.erase(val.begin()+val.find(")"),val.end());
arsenalist	0:f4e449fa34d7	538	regKey = val;
arsenalist	0:f4e449fa34d7	539	DBG.printf("%s: %s\r\n",parameter[3],regKey.c_str());
arsenalist	0:f4e449fa34d7	540	emmaGetRegKey = true;
arsenalist	0:f4e449fa34d7	541	}
arsenalist	0:f4e449fa34d7	542	}
arsenalist	0:f4e449fa34d7	543	}
arsenalist	0:f4e449fa34d7	544	}
arsenalist	0:f4e449fa34d7	545
arsenalist	0:f4e449fa34d7	546	//calculate hmac
arsenalist	0:f4e449fa34d7	547	for(int i=0; i<sizeof(r); i++) {
arsenalist	0:f4e449fa34d7	548	r[i]=0; }
arsenalist	0:f4e449fa34d7	549	sprintf(r,"emma-%s-%s",emmaUID.c_str(),regKey.c_str());
arsenalist	0:f4e449fa34d7	550	hmac = calculateMD5(r);
arsenalist	0:f4e449fa34d7	551	DBG.printf("hmac:%s\r\n",hmac.c_str());
arsenalist	0:f4e449fa34d7	552
arsenalist	0:f4e449fa34d7	553	//set connData
arsenalist	0:f4e449fa34d7	554	if(useProxy) {
arsenalist	0:f4e449fa34d7	555	for(int i=0; i<sizeof(s); i++) {
arsenalist	0:f4e449fa34d7	556	s[i]=0; }
arsenalist	0:f4e449fa34d7	557	sprintf(s,"http://%s:%d/emma/api/controller/verify?uid=%s&registrationKey=%s&hmac=%s",EMMA_SERVER_HOST,EMMA_SERVER_PORT,emmaUID.c_str(),regKey.c_str(),hmac.c_str());
arsenalist	0:f4e449fa34d7	558	connData = s;
arsenalist	0:f4e449fa34d7	559	} else {
arsenalist	0:f4e449fa34d7	560	for(int i=0; i<sizeof(s); i++) {
arsenalist	0:f4e449fa34d7	561	s[i]=0; }
arsenalist	0:f4e449fa34d7	562	sprintf(s,"/emma/api/controller/verify?uid=%s&registrationKey=%s&hmac=%s",emmaUID.c_str(),regKey.c_str(),hmac.c_str());
arsenalist	0:f4e449fa34d7	563	connData = s;
arsenalist	0:f4e449fa34d7	564	}
arsenalist	0:f4e449fa34d7	565
arsenalist	0:f4e449fa34d7	566	//verify registration
arsenalist	0:f4e449fa34d7	567	while(!emmaRegistered && loop < 12){
arsenalist	0:f4e449fa34d7	568	rest.get(connData.c_str());
arsenalist	0:f4e449fa34d7	569	for(int i=0; i<sizeof(s); i++) {
arsenalist	0:f4e449fa34d7	570	s[i]=0; }
arsenalist	0:f4e449fa34d7	571	rest.getResponse(s,sizeof(s));
arsenalist	0:f4e449fa34d7	572	DBG.printf("rsp vrf:%s\r\n",s);
arsenalist	0:f4e449fa34d7	573
arsenalist	0:f4e449fa34d7	574	//check verification
arsenalist	0:f4e449fa34d7	575	str = s;
arsenalist	0:f4e449fa34d7	576	if(str.find("[") != std::string::npos && str.find("]") != std::string::npos) {
arsenalist	0:f4e449fa34d7	577	str.erase(str.begin(),str.begin()+str.find("[")+1);
arsenalist	0:f4e449fa34d7	578	str.erase(str.begin()+str.find("]"),str.end());
arsenalist	0:f4e449fa34d7	579
arsenalist	0:f4e449fa34d7	580	MbedJSONValue jsonValue;
arsenalist	0:f4e449fa34d7	581	parse(jsonValue,str.c_str());
arsenalist	0:f4e449fa34d7	582	if(jsonValue.hasMember("user")) {
arsenalist	0:f4e449fa34d7	583	string val = jsonValue["user"].get<std::string>();
arsenalist	0:f4e449fa34d7	584	DBG.printf("%s is registered\r\n",val.c_str());
arsenalist	0:f4e449fa34d7	585	emmaRegistered = true;
arsenalist	0:f4e449fa34d7	586	}
arsenalist	0:f4e449fa34d7	587	}
arsenalist	0:f4e449fa34d7	588	wait(5);
arsenalist	0:f4e449fa34d7	589	loop++;
arsenalist	0:f4e449fa34d7	590	}
arsenalist	0:f4e449fa34d7	591
arsenalist	0:f4e449fa34d7	592	//check whether registration success
arsenalist	0:f4e449fa34d7	593	if(emmaRegistered) {
arsenalist	0:f4e449fa34d7	594	DBG.printf("registration successful\r\n");
arsenalist	0:f4e449fa34d7	595	} else {
arsenalist	0:f4e449fa34d7	596	DBG.printf("registration unsuccessful\r\n");
arsenalist	0:f4e449fa34d7	597	}
arsenalist	0:f4e449fa34d7	598	while(1);
arsenalist	0:f4e449fa34d7	599	}
arsenalist	0:f4e449fa34d7	600
arsenalist	9:a58c04da4476	601	} else if(gprsConnected) {
arsenalist	0:f4e449fa34d7	602	DBG.printf("emmaModeRegister - gprs\r\n");
arsenalist	0:f4e449fa34d7	603
arsenalist	0:f4e449fa34d7	604	} else {
arsenalist	9:a58c04da4476	605	DBG.printf("no eth, wifi, or gprs is connected\r\n");
arsenalist	0:f4e449fa34d7	606	}
arsenalist	0:f4e449fa34d7	607	}
arsenalist	0:f4e449fa34d7	608
arsenalist	0:f4e449fa34d7	609	void emmaModeOperation(void) {
arsenalist	0:f4e449fa34d7	610	char mqttClientId[32];
arsenalist	4:76ab12e2f8a3	611	char r[32];
arsenalist	0:f4e449fa34d7	612	char s[512];
arsenalist	0:f4e449fa34d7	613	int loop=0;
arsenalist	4:76ab12e2f8a3	614	//string hmac;
arsenalist	0:f4e449fa34d7	615	string str;
arsenalist	0:f4e449fa34d7	616	Timer t;
arsenalist	4:76ab12e2f8a3	617	Timer tNodes;
arsenalist	0:f4e449fa34d7	618
arsenalist	0:f4e449fa34d7	619	//check connected interface
arsenalist	8:51a0ca9079ca	620	//connectedIface();
arsenalist	8:51a0ca9079ca	621	isEthConnected();
arsenalist	8:51a0ca9079ca	622	isWiFiConnected();
arsenalist	8:51a0ca9079ca	623	isGprsConnected();
arsenalist	0:f4e449fa34d7	624	DBG.printf("ethConnected:%d\r\n",ethConnected);
arsenalist	0:f4e449fa34d7	625	DBG.printf("wifiConnected:%d\r\n",wifiConnected);
arsenalist	0:f4e449fa34d7	626
arsenalist	0:f4e449fa34d7	627	//calculate hmac
arsenalist	4:76ab12e2f8a3	628	//for(int j=0; j<sizeof(s); j++) {
arsenalist	4:76ab12e2f8a3	629	// s[j]=0; }
arsenalist	4:76ab12e2f8a3	630	//sprintf(s,"emma-%s",emmaUID.c_str());
arsenalist	4:76ab12e2f8a3	631	//hmac = calculateMD5(s);
arsenalist	4:76ab12e2f8a3	632	//DBG.printf("hmac:%s\r\n",hmac.c_str());
arsenalist	0:f4e449fa34d7	633
arsenalist	10:1dc69e0ce7fd	634	if(ethConnected) {
arsenalist	10:1dc69e0ce7fd	635	DBG.printf("emmaModeOperation - eth\r\n");
arsenalist	10:1dc69e0ce7fd	636	//DBG.printf("IP Address:%s\r\n",ipstack.getEth().getIPAddress());
arsenalist	10:1dc69e0ce7fd	637	//DBG.printf("MAC Address:%s\r\n",ipstack.getEth().getMACAddress());
arsenalist	10:1dc69e0ce7fd	638	ethMQTTAttemptConnect(&client, &ipstack);
arsenalist	10:1dc69e0ce7fd	639	//t.start();
arsenalist	10:1dc69e0ce7fd	640	DBG.printf("start\r\n");
arsenalist	10:1dc69e0ce7fd	641	while(true) {
arsenalist	10:1dc69e0ce7fd	642	//if(!ipstack.getEth().linkstatus()) {
arsenalist	10:1dc69e0ce7fd	643	// NVIC_SystemReset();
arsenalist	10:1dc69e0ce7fd	644	//}
arsenalist	10:1dc69e0ce7fd	645	//if(t.read_ms() > 5000) {
arsenalist	10:1dc69e0ce7fd	646	// if(publish(&client,&ipstack) != 0)
arsenalist	10:1dc69e0ce7fd	647	// ethMQTTAttemptConnect(&client, &ipstack);
arsenalist	10:1dc69e0ce7fd	648	// t.reset();
arsenalist	10:1dc69e0ce7fd	649	//}
arsenalist	10:1dc69e0ce7fd	650
arsenalist	10:1dc69e0ce7fd	651	//check for new command
arsenalist	10:1dc69e0ce7fd	652	if(newCommand) {
arsenalist	10:1dc69e0ce7fd	653	DBG.printf("newCommand\r\n");
arsenalist	10:1dc69e0ce7fd	654	//DBG.printf("globalCommand: %s\r\n",globalCommand.c_str());
arsenalist	10:1dc69e0ce7fd	655	//string qw(globCmd);
arsenalist	10:1dc69e0ce7fd	656
arsenalist	10:1dc69e0ce7fd	657	//if(cmd.find("[") != std::string::npos && cmd.find("]") != std::string::npos) {
arsenalist	10:1dc69e0ce7fd	658	// cmd.erase(cmd.begin(),cmd.begin()+cmd.find("[")+1);
arsenalist	10:1dc69e0ce7fd	659	// cmd.erase(cmd.begin()+cmd.find("]"),cmd.end());
arsenalist	10:1dc69e0ce7fd	660	//globalCommand = cmd;
arsenalist	10:1dc69e0ce7fd	661	//newCommand = true;
arsenalist	10:1dc69e0ce7fd	662	//}
arsenalist	10:1dc69e0ce7fd	663	/*
arsenalist	10:1dc69e0ce7fd	664	MbedJSONValue jsonValue;
arsenalist	10:1dc69e0ce7fd	665	parse(jsonValue,globalCommand.c_str());
arsenalist	10:1dc69e0ce7fd	666	char *parameter[5] = {"id","nType","nAddr","dType","cmd"};
arsenalist	10:1dc69e0ce7fd	667
arsenalist	10:1dc69e0ce7fd	668	//check if command is valid
arsenalist	10:1dc69e0ce7fd	669	bool validCommand = true;
arsenalist	10:1dc69e0ce7fd	670	for(int i=0; i<5; i++) {
arsenalist	10:1dc69e0ce7fd	671	validCommand = validCommand && jsonValue.hasMember(parameter[i]);
arsenalist	10:1dc69e0ce7fd	672	}
arsenalist	10:1dc69e0ce7fd	673	DBG.printf("command validity:%d\r\n",validCommand);
arsenalist	10:1dc69e0ce7fd	674
arsenalist	10:1dc69e0ce7fd	675	if(validCommand) {
arsenalist	10:1dc69e0ce7fd	676	string commandId = jsonValue[parameter[0]].get<std::string>();
arsenalist	10:1dc69e0ce7fd	677	string commandNType = jsonValue[parameter[1]].get<std::string>();
arsenalist	10:1dc69e0ce7fd	678	string commandNAddr = jsonValue[parameter[2]].get<std::string>();
arsenalist	10:1dc69e0ce7fd	679	string commandDType = jsonValue[parameter[3]].get<std::string>();
arsenalist	10:1dc69e0ce7fd	680	string commandCmd = jsonValue[parameter[4]].get<std::string>();
arsenalist	10:1dc69e0ce7fd	681
arsenalist	10:1dc69e0ce7fd	682	if(commandNType == "0") { //switch on panel controller
arsenalist	10:1dc69e0ce7fd	683	DBG.printf("command for switch\r\n");
arsenalist	10:1dc69e0ce7fd	684	}
arsenalist	10:1dc69e0ce7fd	685	else if(commandNType == "1") { //node with mac address
arsenalist	10:1dc69e0ce7fd	686	DBG.printf("command for node\r\n");
arsenalist	10:1dc69e0ce7fd	687	//get node ip address based on node mac address
arsenalist	10:1dc69e0ce7fd	688	string nodeIP = readNodeIP(commandNAddr);
arsenalist	10:1dc69e0ce7fd	689	DBG.printf("nodeIP: %s\r\n",nodeIP.c_str());
arsenalist	10:1dc69e0ce7fd	690
arsenalist	10:1dc69e0ce7fd	691	//get cmd string based on device type and command number
arsenalist	10:1dc69e0ce7fd	692	string nodeCmd = readNodeCmd(commandDType,commandCmd);
arsenalist	10:1dc69e0ce7fd	693	DBG.printf("nodeCmd: %s\r\n",nodeCmd.c_str());
arsenalist	10:1dc69e0ce7fd	694
arsenalist	10:1dc69e0ce7fd	695	//execute command
arsenalist	10:1dc69e0ce7fd	696	int trial=0;
arsenalist	10:1dc69e0ce7fd	697	string execStatus="failed";
arsenalist	10:1dc69e0ce7fd	698
arsenalist	10:1dc69e0ce7fd	699	while(1) {
arsenalist	10:1dc69e0ce7fd	700	sprintf(s,"<?xml version=\"1.0\" encoding=\"utf-8\"?><app_cmd cmd=\"5\" /><app_data code=\"%s\"/>\r\n",nodeCmd.c_str());
arsenalist	10:1dc69e0ce7fd	701	str = s;
arsenalist	10:1dc69e0ce7fd	702	string rcv = ethGET(nodeIP,REMOTE_TCP_PORT,str);
arsenalist	10:1dc69e0ce7fd	703	DBG.printf("response:%s\r\n",rcv.c_str());
arsenalist	10:1dc69e0ce7fd	704	str = rcv;
arsenalist	10:1dc69e0ce7fd	705	if(str.find("OK") != std::string::npos) {
arsenalist	10:1dc69e0ce7fd	706	DBG.printf("cmd executed\r\n");
arsenalist	10:1dc69e0ce7fd	707	execStatus = "success";
arsenalist	10:1dc69e0ce7fd	708	break;
arsenalist	10:1dc69e0ce7fd	709	}
arsenalist	10:1dc69e0ce7fd	710	if(trial>0) { //two times trial
arsenalist	10:1dc69e0ce7fd	711	DBG.printf("cmd is not executed\r\n");
arsenalist	10:1dc69e0ce7fd	712	break;
arsenalist	10:1dc69e0ce7fd	713	}
arsenalist	10:1dc69e0ce7fd	714	trial++;
arsenalist	10:1dc69e0ce7fd	715	wait(3);
arsenalist	10:1dc69e0ce7fd	716	}
arsenalist	10:1dc69e0ce7fd	717
arsenalist	10:1dc69e0ce7fd	718	//send execution status
arsenalist	10:1dc69e0ce7fd	719	}
arsenalist	10:1dc69e0ce7fd	720	}
arsenalist	10:1dc69e0ce7fd	721	*/
arsenalist	10:1dc69e0ce7fd	722	newCommand = false;
arsenalist	10:1dc69e0ce7fd	723	}
arsenalist	10:1dc69e0ce7fd	724	client.yield(100); //allow MQTT client to receive message
arsenalist	10:1dc69e0ce7fd	725	}
arsenalist	10:1dc69e0ce7fd	726	} else if(wifiConnected) {
arsenalist	0:f4e449fa34d7	727	DBG.printf("emmaModeOperation - wifi\r\n");
arsenalist	0:f4e449fa34d7	728
arsenalist	0:f4e449fa34d7	729	//do not delete code below - indicator that esp need to MODE=B and esp.ready() to work
arsenalist	0:f4e449fa34d7	730	//_ESP.printf("MODE=B");
arsenalist	0:f4e449fa34d7	731	//wait(1);
arsenalist	0:f4e449fa34d7	732	//while(!esp.ready());
arsenalist	0:f4e449fa34d7	733
arsenalist	0:f4e449fa34d7	734	DBG.printf("emma: setup mqtt client\r\n");
arsenalist	0:f4e449fa34d7	735	sprintf(mqttClientId,"emma/%s",emmaUID.c_str());
arsenalist	0:f4e449fa34d7	736
arsenalist	0:f4e449fa34d7	737	if(mqtt.begin(mqttClientId, platformKEY.c_str(), platformSECRET.c_str(), 120, 1)) {
arsenalist	4:76ab12e2f8a3	738	//mqtt.lwt("/lwt", "offline", 0, 0);
arsenalist	0:f4e449fa34d7	739	mqtt.connectedCb.attach(&mqttConnected);
arsenalist	0:f4e449fa34d7	740	mqtt.disconnectedCb.attach(&mqttDisconnected);
arsenalist	4:76ab12e2f8a3	741	//mqtt.publishedCb.attach(&mqttPublished);
arsenalist	4:76ab12e2f8a3	742	//mqtt.dataCb.attach(&mqttData);
arsenalist	0:f4e449fa34d7	743	mqtt.connect(MQTT_HOST,MQTT_PORT,false);
arsenalist	0:f4e449fa34d7	744	DBG.printf("emma: success to setup mqtt\r\n");
arsenalist	0:f4e449fa34d7	745	}
arsenalist	0:f4e449fa34d7	746	DBG.printf("emma: system started\r\n");
arsenalist	0:f4e449fa34d7	747
arsenalist	4:76ab12e2f8a3	748	t.start();
arsenalist	4:76ab12e2f8a3	749	while(t.read_ms() < 5000) {
arsenalist	4:76ab12e2f8a3	750	esp.process();
arsenalist	4:76ab12e2f8a3	751	}
arsenalist	4:76ab12e2f8a3	752	t.stop();
arsenalist	4:76ab12e2f8a3	753	t.reset();
arsenalist	0:f4e449fa34d7	754
arsenalist	0:f4e449fa34d7	755	//set ade7758 parameter
arsenalist	0:f4e449fa34d7	756	ADE.begin();
arsenalist	0:f4e449fa34d7	757	ADE.AVRMSCalib = 1526873.00;
arsenalist	0:f4e449fa34d7	758	ADE.BVRMSCalib = 534202.00;
arsenalist	0:f4e449fa34d7	759	ADE.CVRMSCalib = 456990.00;
arsenalist	0:f4e449fa34d7	760	ADE.AIRMSCalib = 39248.00;
arsenalist	0:f4e449fa34d7	761	ADE.BIRMSCalib = 654.00;
arsenalist	0:f4e449fa34d7	762	ADE.CIRMSCalib = 111.00;
arsenalist	0:f4e449fa34d7	763
arsenalist	0:f4e449fa34d7	764	ADE.writeRMSOffset(AIRMSOFFSET, BIRMSOFFSET, CIRMSOFFSET, AVRMSOFFSET, BVRMSOFFSET, CVRMSOFFSET);
arsenalist	0:f4e449fa34d7	765
arsenalist	0:f4e449fa34d7	766	ADE.write16bits(AWG, 0);
arsenalist	0:f4e449fa34d7	767	ADE.write16bits(BWG, 0);
arsenalist	0:f4e449fa34d7	768	ADE.write16bits(CWG, 0);
arsenalist	0:f4e449fa34d7	769	ADE.write16bits(AVAG, 0);
arsenalist	0:f4e449fa34d7	770	ADE.write16bits(BVAG, 0);
arsenalist	0:f4e449fa34d7	771	ADE.write16bits(CVAG, 0);
arsenalist	0:f4e449fa34d7	772
arsenalist	4:76ab12e2f8a3	773	ADE.AWhLSB = 0.00006025556;
arsenalist	0:f4e449fa34d7	774	ADE.BWhLSB = 0.25075167;
arsenalist	0:f4e449fa34d7	775	ADE.CWhLSB = 0.25075167;
arsenalist	0:f4e449fa34d7	776
arsenalist	0:f4e449fa34d7	777	ADE.AVAhLSB = 0.00008370;
arsenalist	0:f4e449fa34d7	778	ADE.BVAhLSB = 0;
arsenalist	0:f4e449fa34d7	779	ADE.CVAhLSB = 0;
arsenalist	0:f4e449fa34d7	780
arsenalist	4:76ab12e2f8a3	781	//init rest to server
arsenalist	7:7e8c6ad3fd64	782	if(rest.begin(EMMA_SERVER_HOST,EMMA_SERVER_PORT,false)) {
arsenalist	4:76ab12e2f8a3	783	DBG.printf("rest to server is created\r\n");
arsenalist	4:76ab12e2f8a3	784	} else {
arsenalist	4:76ab12e2f8a3	785	DBG.printf("rest to server is NOT created\r\n");
arsenalist	4:76ab12e2f8a3	786	}
arsenalist	4:76ab12e2f8a3	787
arsenalist	7:7e8c6ad3fd64	788	//check firmware update
arsenalist	7:7e8c6ad3fd64	789
arsenalist	7:7e8c6ad3fd64	790	//execute last state of switches on board
arsenalist	7:7e8c6ad3fd64	791
arsenalist	7:7e8c6ad3fd64	792	//get list of nodes from server
arsenalist	7:7e8c6ad3fd64	793	sprintf(s,"/emma/api/controller/remotes?uid=%s&hmac=%s",emmaUID.c_str(),hmac.c_str());
arsenalist	7:7e8c6ad3fd64	794	rest.get(s);
arsenalist	7:7e8c6ad3fd64	795	for(int i=0; i<sizeof(s); i++) {
arsenalist	7:7e8c6ad3fd64	796	s[i]=0; }
arsenalist	7:7e8c6ad3fd64	797	rest.getResponse(s,sizeof(s));
arsenalist	7:7e8c6ad3fd64	798	str = s;
arsenalist	7:7e8c6ad3fd64	799	if(str.rfind("[{\"mac\"") != std::string::npos) {
arsenalist	7:7e8c6ad3fd64	800	DBG.printf("get nodes from server\r\n");
arsenalist	7:7e8c6ad3fd64	801	str.erase(str.begin(),str.begin()+str.rfind("[{\"mac\""));
arsenalist	7:7e8c6ad3fd64	802	str.erase(str.begin()+str.rfind("}]")+2,str.end());
arsenalist	7:7e8c6ad3fd64	803
arsenalist	7:7e8c6ad3fd64	804	MbedJSONValue jsonValue;
arsenalist	7:7e8c6ad3fd64	805	parse(jsonValue,str.c_str());
arsenalist	7:7e8c6ad3fd64	806	char *parameter[2] = {"mac","ip"};
arsenalist	7:7e8c6ad3fd64	807
arsenalist	7:7e8c6ad3fd64	808	//check whether nodes valid
arsenalist	7:7e8c6ad3fd64	809	bool validNodes = true;
arsenalist	7:7e8c6ad3fd64	810	for(int i=0; i<jsonValue.size(); i++) {
arsenalist	7:7e8c6ad3fd64	811	for(int j=0; j<2; j++) {
arsenalist	7:7e8c6ad3fd64	812	validNodes = validNodes && jsonValue[i].hasMember(parameter[j]);
arsenalist	7:7e8c6ad3fd64	813	}
arsenalist	7:7e8c6ad3fd64	814	}
arsenalist	7:7e8c6ad3fd64	815	DBG.printf("nodes validity:%d\r\n",validNodes);
arsenalist	7:7e8c6ad3fd64	816
arsenalist	7:7e8c6ad3fd64	817	if(validNodes) {
arsenalist	7:7e8c6ad3fd64	818	for(int i=0; i<jsonValue.size(); i++) {
arsenalist	7:7e8c6ad3fd64	819	string macValue = jsonValue[i][parameter[0]].get<std::string>();
arsenalist	7:7e8c6ad3fd64	820	string ipValue = jsonValue[i][parameter[1]].get<std::string>();
arsenalist	7:7e8c6ad3fd64	821	nodes[i].macAddr = macValue;
arsenalist	7:7e8c6ad3fd64	822	nodes[i].ipAddr = ipValue;
arsenalist	7:7e8c6ad3fd64	823	DBG.printf("nodes[%d]-mac:%s\r\n",i,nodes[i].macAddr.c_str());
arsenalist	7:7e8c6ad3fd64	824	DBG.printf("nodes[%d]-ip:%s\r\n",i,nodes[i].ipAddr.c_str());
arsenalist	7:7e8c6ad3fd64	825	}
arsenalist	7:7e8c6ad3fd64	826	}
arsenalist	7:7e8c6ad3fd64	827
arsenalist	7:7e8c6ad3fd64	828	} else {
arsenalist	7:7e8c6ad3fd64	829	DBG.printf("no nodes from server\r\n");
arsenalist	7:7e8c6ad3fd64	830	}
arsenalist	7:7e8c6ad3fd64	831
arsenalist	7:7e8c6ad3fd64	832
arsenalist	4:76ab12e2f8a3	833	//preset nodes' macAddr and ipAddr
arsenalist	7:7e8c6ad3fd64	834	//nodes[0].macAddr = "002629034222";
arsenalist	7:7e8c6ad3fd64	835	//nodes[0].ipAddr = "192.168.2.15";
arsenalist	7:7e8c6ad3fd64	836	//nodes[1].macAddr = "00262903424e";
arsenalist	7:7e8c6ad3fd64	837	//nodes[1].ipAddr = "192.168.2.32";
arsenalist	4:76ab12e2f8a3	838
arsenalist	4:76ab12e2f8a3	839	//init rest to remotes
arsenalist	4:76ab12e2f8a3	840	for(int i=0; i<NODES_MAX; i++) {
arsenalist	4:76ab12e2f8a3	841	if(!nodes[i].ipAddr.empty()) {
arsenalist	4:76ab12e2f8a3	842	DBG.printf("restConn nodes[%d] is created\r\n",i);
arsenalist	4:76ab12e2f8a3	843	nodes[i].restConn->begin(nodes[i].ipAddr.c_str(),16038,false);
arsenalist	4:76ab12e2f8a3	844	wait(1);
arsenalist	4:76ab12e2f8a3	845	} else {
arsenalist	4:76ab12e2f8a3	846	DBG.printf("restConn nodes[%d] is NOT created\r\n",i);
arsenalist	4:76ab12e2f8a3	847	wait(1);
arsenalist	4:76ab12e2f8a3	848	}
arsenalist	4:76ab12e2f8a3	849	}
arsenalist	4:76ab12e2f8a3	850
arsenalist	4:76ab12e2f8a3	851	_ESP.attach(&rxInterrupt,Serial::RxIrq);
arsenalist	4:76ab12e2f8a3	852
arsenalist	4:76ab12e2f8a3	853	//define thread
arsenalist	4:76ab12e2f8a3	854	osThreadDef(energyThread, osPriorityBelowNormal, (4*DEFAULT_STACK_SIZE));
arsenalist	0:f4e449fa34d7	855	//create thread
arsenalist	2:fdfdeb5fd6fd	856	osThreadCreate(osThread(energyThread),NULL);
arsenalist	0:f4e449fa34d7	857
arsenalist	0:f4e449fa34d7	858	t.start();
arsenalist	4:76ab12e2f8a3	859	tNodes.start();
arsenalist	4:76ab12e2f8a3	860	wait(1);
arsenalist	0:f4e449fa34d7	861	while(1) {
arsenalist	4:76ab12e2f8a3	862	checkRxBuffer();
arsenalist	4:76ab12e2f8a3	863	checkVoltagePower();
arsenalist	4:76ab12e2f8a3	864	//panelEnergy, panelVoltage, and panelPower
arsenalist	4:76ab12e2f8a3	865	if(t.read_ms() > 10000) {
arsenalist	4:76ab12e2f8a3	866	DBG.printf("[%d]WattHR for each phase: %.2f, %.2f, %.2f\r\n", loop, AWattHr, BWattHr, CWattHr);
arsenalist	4:76ab12e2f8a3	867	DBG.printf("VRMS for each phase: %.2f, %.2f, %.2f\r\n", AVrms, BVrms, CVrms);
arsenalist	4:76ab12e2f8a3	868	DBG.printf("Watt for each phase: %.2f, %.2f, %.2f\r\n", AWatt, BWatt, CWatt);
arsenalist	4:76ab12e2f8a3	869
arsenalist	4:76ab12e2f8a3	870	//for(int i=1; i<4; i++) {
arsenalist	4:76ab12e2f8a3	871	for(int i=1; i<2; i++) {
arsenalist	4:76ab12e2f8a3	872	DBG.printf("sending channel: %d\r\n",i);
arsenalist	4:76ab12e2f8a3	873	if(i==1){
arsenalist	4:76ab12e2f8a3	874	XWattHr = AWattHr;
arsenalist	4:76ab12e2f8a3	875	XVrms = AVrms;
arsenalist	4:76ab12e2f8a3	876	XWatt = AWatt;
arsenalist	4:76ab12e2f8a3	877	} else if(i==2) {
arsenalist	4:76ab12e2f8a3	878	XWattHr = BWattHr;
arsenalist	4:76ab12e2f8a3	879	XVrms = BVrms;
arsenalist	4:76ab12e2f8a3	880	XWatt = BWatt;
arsenalist	4:76ab12e2f8a3	881	} else {
arsenalist	4:76ab12e2f8a3	882	XWattHr = CWattHr;
arsenalist	4:76ab12e2f8a3	883	XVrms = CVrms;
arsenalist	4:76ab12e2f8a3	884	XWatt = CWatt;
arsenalist	4:76ab12e2f8a3	885	}
arsenalist	4:76ab12e2f8a3	886	sprintf(r,"/emma/api/controller/energy/%d",i);
arsenalist	4:76ab12e2f8a3	887	sprintf(s,"{\"uid\":\"%s\",\"hmac\":\"%s\",\"time\":\"2015-06-09 12:32:12\",\"energy\":%.2f,\"voltage\":%.2f,\"power\":%.2f}",
arsenalist	4:76ab12e2f8a3	888	emmaUID.c_str(),hmac.c_str(),XWattHr,XVrms,XWatt);
arsenalist	4:76ab12e2f8a3	889	rest.post(r,s);
arsenalist	4:76ab12e2f8a3	890	wait(2);
arsenalist	4:76ab12e2f8a3	891	if(rxBuf.find("\"status\":\"success\"") != std::string::npos) {
arsenalist	4:76ab12e2f8a3	892	DBG.printf("send channel: %d success\r\n",i);
arsenalist	4:76ab12e2f8a3	893	} else {
arsenalist	4:76ab12e2f8a3	894	DBG.printf("send channel: %d failed\r\n",i);
arsenalist	4:76ab12e2f8a3	895	}
arsenalist	0:f4e449fa34d7	896	}
arsenalist	4:76ab12e2f8a3	897	t.reset();
arsenalist	4:76ab12e2f8a3	898	loop++;
arsenalist	0:f4e449fa34d7	899	}
arsenalist	0:f4e449fa34d7	900
arsenalist	5:d00233dd36f5	901	checkRxBuffer();
arsenalist	5:d00233dd36f5	902	checkVoltagePower();
arsenalist	0:f4e449fa34d7	903	//nodeTemp
arsenalist	5:d00233dd36f5	904	if(tNodes.read_ms() > 30000) {
arsenalist	5:d00233dd36f5	905	DBG.printf("getNodesTemperature\r\n");
arsenalist	5:d00233dd36f5	906
arsenalist	5:d00233dd36f5	907	for(int i=0; i<NODES_MAX; i++) {
arsenalist	5:d00233dd36f5	908	if(!nodes[i].ipAddr.empty()) {
arsenalist	5:d00233dd36f5	909	//get node's temp
arsenalist	5:d00233dd36f5	910	string temp;
arsenalist	5:d00233dd36f5	911	nodes[i].restConn->get("/","<?xml version=\"1.0\" encoding=\"utf-8\"?><app_cmd cmd=\"2\"/>\r\n");
arsenalist	5:d00233dd36f5	912	wait(2);
arsenalist	5:d00233dd36f5	913	temp = rxBuf;
arsenalist	5:d00233dd36f5	914	if(temp.rfind(nodes[i].ipAddr) != std::string::npos) {
arsenalist	5:d00233dd36f5	915	temp.erase(temp.begin(),temp.begin()+temp.rfind(nodes[i].ipAddr));
arsenalist	5:d00233dd36f5	916	if(temp.rfind("temp=") != std::string::npos) {
arsenalist	5:d00233dd36f5	917	temp.erase(temp.begin(),temp.begin()+temp.rfind("temp=")+6);
arsenalist	5:d00233dd36f5	918	temp.erase(temp.begin()+temp.find("\""),temp.end());
arsenalist	5:d00233dd36f5	919	} else {
arsenalist	5:d00233dd36f5	920	temp = "0"; //connect to node, but receive none
arsenalist	5:d00233dd36f5	921	}
arsenalist	5:d00233dd36f5	922	} else {
arsenalist	5:d00233dd36f5	923	temp = "0"; //not connected to node
arsenalist	5:d00233dd36f5	924	}
arsenalist	0:f4e449fa34d7	925
arsenalist	5:d00233dd36f5	926	DBG.printf("nodeTemp[%d]:%s\r\n",i,temp.c_str());
arsenalist	5:d00233dd36f5	927
arsenalist	5:d00233dd36f5	928	//send node's temp
arsenalist	0:f4e449fa34d7	929	sprintf(s,"{\"uid\":\"%s\",\"hmac\":\"%s\",\"time\":\"2015-06-09 12:32:12\",\"mac\":\"%s\",\"value\":%s}",
arsenalist	5:d00233dd36f5	930	emmaUID.c_str(),hmac.c_str(),nodes[i].macAddr.c_str(),temp.c_str());
arsenalist	0:f4e449fa34d7	931	rest.post("/emma/api/controller/nodetemp",s);
arsenalist	5:d00233dd36f5	932	wait(2);
arsenalist	5:d00233dd36f5	933	temp = rxBuf;
arsenalist	5:d00233dd36f5	934	if(temp.rfind("/nodetemp") != std::string::npos) {
arsenalist	5:d00233dd36f5	935	temp.erase(temp.begin(),temp.begin()+temp.rfind("/nodetemp"));
arsenalist	5:d00233dd36f5	936	if(temp.find("\"status\":\"success\"") != std::string::npos) {
arsenalist	5:d00233dd36f5	937	DBG.printf("send nodeTemp success\r\n");
arsenalist	5:d00233dd36f5	938	} else {
arsenalist	5:d00233dd36f5	939	DBG.printf("send nodeTemp failed\r\n");
arsenalist	5:d00233dd36f5	940	}
arsenalist	5:d00233dd36f5	941	}
arsenalist	6:45f50f1177db	942	checkRxBuffer();
arsenalist	6:45f50f1177db	943	checkVoltagePower();
arsenalist	5:d00233dd36f5	944	}
arsenalist	0:f4e449fa34d7	945	}
arsenalist	5:d00233dd36f5	946	}
arsenalist	5:d00233dd36f5	947	checkRxBuffer();
arsenalist	5:d00233dd36f5	948	checkVoltagePower();
arsenalist	5:d00233dd36f5	949	//command
arsenalist	0:f4e449fa34d7	950	if(newCommand) {
arsenalist	5:d00233dd36f5	951	DBG.printf("newCommand:\r\n%s\r\n",globalCommand.c_str());
arsenalist	0:f4e449fa34d7	952	MbedJSONValue jsonValue;
arsenalist	0:f4e449fa34d7	953	parse(jsonValue,globalCommand.c_str());
arsenalist	0:f4e449fa34d7	954	char *parameter[5] = {"id","nType","nAddr","dType","cmd"};
arsenalist	0:f4e449fa34d7	955
arsenalist	7:7e8c6ad3fd64	956	//check whether command is valid
arsenalist	0:f4e449fa34d7	957	bool validCommand = true;
arsenalist	0:f4e449fa34d7	958	for(int i=0; i<5; i++) {
arsenalist	0:f4e449fa34d7	959	validCommand = validCommand && jsonValue.hasMember(parameter[i]);
arsenalist	0:f4e449fa34d7	960	}
arsenalist	0:f4e449fa34d7	961	DBG.printf("command validity:%d\r\n",validCommand);
arsenalist	0:f4e449fa34d7	962
arsenalist	0:f4e449fa34d7	963	if(validCommand) {
arsenalist	0:f4e449fa34d7	964	string commandId = jsonValue[parameter[0]].get<std::string>();
arsenalist	0:f4e449fa34d7	965	string commandNType = jsonValue[parameter[1]].get<std::string>();
arsenalist	0:f4e449fa34d7	966	string commandNAddr = jsonValue[parameter[2]].get<std::string>();
arsenalist	0:f4e449fa34d7	967	string commandDType = jsonValue[parameter[3]].get<std::string>();
arsenalist	0:f4e449fa34d7	968	string commandCmd = jsonValue[parameter[4]].get<std::string>();
arsenalist	0:f4e449fa34d7	969
arsenalist	0:f4e449fa34d7	970	if(commandNType == "0") { //switch on panel controller
arsenalist	0:f4e449fa34d7	971	DBG.printf("command for switch\r\n");
arsenalist	0:f4e449fa34d7	972	}
arsenalist	0:f4e449fa34d7	973	else if(commandNType == "1") { //node with mac address
arsenalist	0:f4e449fa34d7	974	DBG.printf("command for node\r\n");
arsenalist	0:f4e449fa34d7	975	//get node ip address based on node mac address
arsenalist	5:d00233dd36f5	976	//string nodeIP;
arsenalist	1:d314a43ae6f7	977	//nodeIp = readNodeIP(commandNAddr);
arsenalist	5:d00233dd36f5	978	//nodeIP = "192.168.2.15";
arsenalist	0:f4e449fa34d7	979	//DBG.printf("nodeIP: %s\r\n",nodeIP.c_str());
arsenalist	5:d00233dd36f5	980
arsenalist	5:d00233dd36f5	981	//get index of node list based on mac address
arsenalist	5:d00233dd36f5	982	int idx = NODES_INVALID;
arsenalist	5:d00233dd36f5	983	for(int i=0; i<NODES_MAX; i++) {
arsenalist	5:d00233dd36f5	984	if(!nodes[i].macAddr.compare(commandNAddr)) {
arsenalist	5:d00233dd36f5	985	idx = i;
arsenalist	5:d00233dd36f5	986	}
arsenalist	5:d00233dd36f5	987	}
arsenalist	5:d00233dd36f5	988
arsenalist	5:d00233dd36f5	989	//execution process
arsenalist	5:d00233dd36f5	990	int trial;
arsenalist	5:d00233dd36f5	991	string execResult = "notExecuted";
arsenalist	5:d00233dd36f5	992	if(idx != NODES_INVALID) {
arsenalist	5:d00233dd36f5	993	DBG.printf("index found at %d\r\n",idx);
arsenalist	0:f4e449fa34d7	994
arsenalist	5:d00233dd36f5	995	//get cmd string based on device type and command number
arsenalist	5:d00233dd36f5	996	string nodeCmd;
arsenalist	5:d00233dd36f5	997	//nodeCmd = readNodeCmd(commandDType,commandCmd);
arsenalist	5:d00233dd36f5	998	nodeCmd = "020129A0163B161315131613153C151316131514143C153C16141414141415151315141414141514141415141414143D1514143D141415141414143D14000D"; //turn off
arsenalist	5:d00233dd36f5	999	//DBG.printf("nodeCmd: %s\r\n",nodeCmd.c_str());
arsenalist	0:f4e449fa34d7	1000
arsenalist	5:d00233dd36f5	1001	//execute command
arsenalist	5:d00233dd36f5	1002	DBG.printf("executing command\r\n");
arsenalist	0:f4e449fa34d7	1003	sprintf(s,"<?xml version=\"1.0\" encoding=\"utf-8\"?><app_cmd cmd=\"5\" /><app_data code=\"%s\"/>\r\n",nodeCmd.c_str());
arsenalist	0:f4e449fa34d7	1004
arsenalist	5:d00233dd36f5	1005	trial=0;
arsenalist	0:f4e449fa34d7	1006	while(1) {
arsenalist	5:d00233dd36f5	1007	//cmdExecuted = false;
arsenalist	5:d00233dd36f5	1008	if(trial>=2) { //two times trial
arsenalist	0:f4e449fa34d7	1009	DBG.printf("cmd is not executed\r\n");
arsenalist	0:f4e449fa34d7	1010	break;
arsenalist	0:f4e449fa34d7	1011	}
arsenalist	5:d00233dd36f5	1012	nodes[idx].restConn->get("/",s);
arsenalist	5:d00233dd36f5	1013	wait(2);
arsenalist	5:d00233dd36f5	1014	if(rxBuf.find("REST: Sent") != std::string::npos) {
arsenalist	5:d00233dd36f5	1015	DBG.printf("cmd executed\r\n");
arsenalist	5:d00233dd36f5	1016	execResult = "executed";
arsenalist	5:d00233dd36f5	1017	break;
arsenalist	5:d00233dd36f5	1018	}
arsenalist	0:f4e449fa34d7	1019	trial++;
arsenalist	5:d00233dd36f5	1020	}
arsenalist	5:d00233dd36f5	1021	}
arsenalist	5:d00233dd36f5	1022
arsenalist	5:d00233dd36f5	1023	wait(2);
arsenalist	5:d00233dd36f5	1024	//send execution result
arsenalist	5:d00233dd36f5	1025	DBG.printf("send execution result\r\n");
arsenalist	5:d00233dd36f5	1026	sprintf(s,"{\"id\":\"%s\",\"nType\":\"%s\",\"nAddr\":\"%s\",\"dType\":\"%s\",\"cmd\":\"%s\",\"result\":\"%s\"}",
arsenalist	5:d00233dd36f5	1027	commandId.c_str(),commandNType.c_str(),commandNAddr.c_str(),commandDType.c_str(),commandCmd.c_str(),execResult.c_str());
arsenalist	5:d00233dd36f5	1028
arsenalist	5:d00233dd36f5	1029	trial=0;
arsenalist	5:d00233dd36f5	1030	while(1) {
arsenalist	5:d00233dd36f5	1031	if(trial>=2) { //two times trial
arsenalist	5:d00233dd36f5	1032	DBG.printf("send execution result failed\r\n");
arsenalist	5:d00233dd36f5	1033	break;
arsenalist	0:f4e449fa34d7	1034	}
arsenalist	5:d00233dd36f5	1035	rest.post("/emma/api/controller/test",s);
arsenalist	5:d00233dd36f5	1036	wait(2);
arsenalist	5:d00233dd36f5	1037	if(rxBuf.find("\"status\":\"OK\"") != std::string::npos) {
arsenalist	5:d00233dd36f5	1038	DBG.printf("send execution result success\r\n");
arsenalist	5:d00233dd36f5	1039	break;
arsenalist	0:f4e449fa34d7	1040	}
arsenalist	5:d00233dd36f5	1041	trial++;
arsenalist	0:f4e449fa34d7	1042	}
arsenalist	0:f4e449fa34d7	1043	}
arsenalist	0:f4e449fa34d7	1044	}
arsenalist	0:f4e449fa34d7	1045	newCommand = false;
arsenalist	2:fdfdeb5fd6fd	1046	}
arsenalist	4:76ab12e2f8a3	1047	osDelay(5000);
arsenalist	0:f4e449fa34d7	1048	}
arsenalist	0:f4e449fa34d7	1049	}
arsenalist	0:f4e449fa34d7	1050	}
arsenalist	0:f4e449fa34d7	1051	void emmaModeFirmwareDownload(void) {
arsenalist	0:f4e449fa34d7	1052	bool emmaGetFirmwareParam = false;
arsenalist	0:f4e449fa34d7	1053
arsenalist	0:f4e449fa34d7	1054	DBG.printf("emmaModeFirmwareDownload\r\n");
arsenalist	0:f4e449fa34d7	1055
arsenalist	0:f4e449fa34d7	1056	char s[384];
arsenalist	0:f4e449fa34d7	1057	string str;
arsenalist	0:f4e449fa34d7	1058	string connData;
arsenalist	0:f4e449fa34d7	1059	string chunk;
arsenalist	0:f4e449fa34d7	1060
arsenalist	0:f4e449fa34d7	1061	//firmware parameter
arsenalist	0:f4e449fa34d7	1062	string firmwareVer;
arsenalist	0:f4e449fa34d7	1063	string firmwareName;
arsenalist	0:f4e449fa34d7	1064	int numPart;
arsenalist	0:f4e449fa34d7	1065
arsenalist	0:f4e449fa34d7	1066	//downloading
arsenalist	0:f4e449fa34d7	1067	string firmwarePart;
arsenalist	0:f4e449fa34d7	1068	string calcMD5;
arsenalist	0:f4e449fa34d7	1069	string srvrMD5;
arsenalist	0:f4e449fa34d7	1070	bool nextPart;
arsenalist	0:f4e449fa34d7	1071
arsenalist	0:f4e449fa34d7	1072	//set wifi to mode bridge
arsenalist	0:f4e449fa34d7	1073	_ESP.printf("MODE=B");
arsenalist	0:f4e449fa34d7	1074	DBG.printf("set mode bridge\r\n");
arsenalist	0:f4e449fa34d7	1075	while(1) {
arsenalist	0:f4e449fa34d7	1076	char rcv[128] = {};
arsenalist	0:f4e449fa34d7	1077	rcvReply(rcv,3000);
arsenalist	0:f4e449fa34d7	1078	str = rcv;
arsenalist	0:f4e449fa34d7	1079	if(str.find("MODE=B_OK") != std::string::npos)
arsenalist	0:f4e449fa34d7	1080	break;
arsenalist	0:f4e449fa34d7	1081	}
arsenalist	0:f4e449fa34d7	1082	DBG.printf("MODE=B\r\n");
arsenalist	0:f4e449fa34d7	1083
arsenalist	0:f4e449fa34d7	1084	esp.enable();
arsenalist	0:f4e449fa34d7	1085	wait(1);
arsenalist	0:f4e449fa34d7	1086	while(!esp.ready());
arsenalist	0:f4e449fa34d7	1087
arsenalist	0:f4e449fa34d7	1088	if(!rest.begin("candra.tritronik.com",3128,false)) {
arsenalist	0:f4e449fa34d7	1089	DBG.printf("EMMA: fail to setup rest");
arsenalist	0:f4e449fa34d7	1090	while(1);
arsenalist	0:f4e449fa34d7	1091	}
arsenalist	0:f4e449fa34d7	1092
arsenalist	0:f4e449fa34d7	1093	//wifiConnected = true; //with custom firmware, panel should connect wifi automatically
arsenalist	0:f4e449fa34d7	1094	useProxy = true;
arsenalist	0:f4e449fa34d7	1095
arsenalist	0:f4e449fa34d7	1096	esp.process();
arsenalist	0:f4e449fa34d7	1097	//set connData
arsenalist	0:f4e449fa34d7	1098	if(useProxy) {
arsenalist	0:f4e449fa34d7	1099	for(int i=0; i<sizeof(s); i++) {
arsenalist	0:f4e449fa34d7	1100	s[i]=0; }
arsenalist	0:f4e449fa34d7	1101	//sprintf(s,"http://%s:%d/emma/api/controller/register?uid=%s&hmac=%s",EMMA_SERVER_HOST,EMMA_SERVER_PORT,emmaUID.c_str(),hmac.c_str());
arsenalist	0:f4e449fa34d7	1102	sprintf(s,"http://192.168.128.69/emmaController/firmware/firmwareParameter");
arsenalist	0:f4e449fa34d7	1103	connData = s;
arsenalist	0:f4e449fa34d7	1104	} else {
arsenalist	0:f4e449fa34d7	1105	for(int i=0; i<sizeof(s); i++) {
arsenalist	0:f4e449fa34d7	1106	s[i]=0; }
arsenalist	0:f4e449fa34d7	1107	//sprintf(s,"/emma/api/controller/register?uid=%s&hmac=%s",emmaUID.c_str(),hmac.c_str());
arsenalist	0:f4e449fa34d7	1108	sprintf(s,"/emmaController/firmware/firmwareParameter");
arsenalist	0:f4e449fa34d7	1109	connData = s;
arsenalist	0:f4e449fa34d7	1110	}
arsenalist	0:f4e449fa34d7	1111
arsenalist	0:f4e449fa34d7	1112	//get parameter of firmware to be downloaded
arsenalist	0:f4e449fa34d7	1113	while(!emmaGetFirmwareParam) {
arsenalist	0:f4e449fa34d7	1114	rest.get(connData.c_str());
arsenalist	0:f4e449fa34d7	1115	for(int i=0; i<sizeof(s); i++) {
arsenalist	0:f4e449fa34d7	1116	s[i]=0; }
arsenalist	0:f4e449fa34d7	1117	rest.getResponse(s,sizeof(s));
arsenalist	0:f4e449fa34d7	1118	//DBG.printf("rsp param:%s\r\n",s);
arsenalist	0:f4e449fa34d7	1119
arsenalist	0:f4e449fa34d7	1120	str = s;
arsenalist	0:f4e449fa34d7	1121	if(str.find("[") != std::string::npos && str.find("]") != std::string::npos) {
arsenalist	0:f4e449fa34d7	1122	str.erase(str.begin(),str.begin()+str.find("[")+1);
arsenalist	0:f4e449fa34d7	1123	str.erase(str.begin()+str.find("]"),str.end());
arsenalist	0:f4e449fa34d7	1124
arsenalist	0:f4e449fa34d7	1125	MbedJSONValue jsonValue;
arsenalist	0:f4e449fa34d7	1126	parse(jsonValue,str.c_str());
arsenalist	0:f4e449fa34d7	1127
arsenalist	0:f4e449fa34d7	1128	char *parameter[2] = {"firmwareVer","numPart"};
arsenalist	0:f4e449fa34d7	1129
arsenalist	0:f4e449fa34d7	1130	for(int i=0; i<2; i++) {
arsenalist	0:f4e449fa34d7	1131	if(jsonValue.hasMember(parameter[i])) {
arsenalist	0:f4e449fa34d7	1132	string val = jsonValue[parameter[i]].get<std::string>();
arsenalist	0:f4e449fa34d7	1133	if(i==0) {
arsenalist	0:f4e449fa34d7	1134	firmwareVer = val;
arsenalist	0:f4e449fa34d7	1135	} else if(i==1) {
arsenalist	0:f4e449fa34d7	1136	sscanf(val.c_str(),"%d",&numPart);
arsenalist	0:f4e449fa34d7	1137	}
arsenalist	0:f4e449fa34d7	1138	}
arsenalist	0:f4e449fa34d7	1139	}
arsenalist	0:f4e449fa34d7	1140
arsenalist	0:f4e449fa34d7	1141	if(!firmwareVer.empty() && numPart!=0) {
arsenalist	0:f4e449fa34d7	1142	emmaGetFirmwareParam = true;
arsenalist	0:f4e449fa34d7	1143	}
arsenalist	0:f4e449fa34d7	1144	}
arsenalist	0:f4e449fa34d7	1145	}
arsenalist	0:f4e449fa34d7	1146	DBG.printf("firmwareVer:%s\r\n",firmwareVer.c_str());
arsenalist	0:f4e449fa34d7	1147	DBG.printf("numPart:%d\r\n",numPart);
arsenalist	0:f4e449fa34d7	1148
arsenalist	0:f4e449fa34d7	1149	//clear firmware file
arsenalist	0:f4e449fa34d7	1150	while(1) {
arsenalist	0:f4e449fa34d7	1151	if(clearFirmware()){
arsenalist	0:f4e449fa34d7	1152	DBG.printf("clear firmware on sd card\r\n\r\n");
arsenalist	0:f4e449fa34d7	1153	break;
arsenalist	0:f4e449fa34d7	1154	}
arsenalist	0:f4e449fa34d7	1155	wait(1);
arsenalist	0:f4e449fa34d7	1156	}
arsenalist	0:f4e449fa34d7	1157
arsenalist	0:f4e449fa34d7	1158	//set connData
arsenalist	0:f4e449fa34d7	1159	if(useProxy) {
arsenalist	0:f4e449fa34d7	1160	for(int i=0; i<sizeof(s); i++) {
arsenalist	0:f4e449fa34d7	1161	s[i]=0; }
arsenalist	0:f4e449fa34d7	1162	sprintf(s,"http://192.168.128.69/emmaController/firmware/%s",firmwareVer.c_str());
arsenalist	0:f4e449fa34d7	1163	connData = s;
arsenalist	0:f4e449fa34d7	1164	} else {
arsenalist	0:f4e449fa34d7	1165	for(int i=0; i<sizeof(s); i++) {
arsenalist	0:f4e449fa34d7	1166	s[i]=0; }
arsenalist	0:f4e449fa34d7	1167	sprintf(s,"/emmaController/firmware/%s",firmwareVer.c_str());
arsenalist	0:f4e449fa34d7	1168	connData = s;
arsenalist	0:f4e449fa34d7	1169	}
arsenalist	0:f4e449fa34d7	1170
arsenalist	0:f4e449fa34d7	1171	//download firmware
arsenalist	0:f4e449fa34d7	1172	for(int n=0; n<numPart; n++) {
arsenalist	0:f4e449fa34d7	1173	nextPart = false;
arsenalist	0:f4e449fa34d7	1174	while(!nextPart) {
arsenalist	0:f4e449fa34d7	1175	for(int i=0; i<sizeof(s); i++) {
arsenalist	0:f4e449fa34d7	1176	s[i]=0; }
arsenalist	0:f4e449fa34d7	1177	sprintf(s,"%s/firmware_Hex_%s_%d",connData.c_str(),firmwareVer.c_str(),n);
arsenalist	0:f4e449fa34d7	1178	rest.get(s);
arsenalist	0:f4e449fa34d7	1179	for(int i=0; i<sizeof(s); i++) {
arsenalist	0:f4e449fa34d7	1180	s[i]=0; }
arsenalist	0:f4e449fa34d7	1181	rest.getResponse(s,sizeof(s));
arsenalist	0:f4e449fa34d7	1182	//DBG.printf("rsp[%d]:%s\r\n",n,s);
arsenalist	0:f4e449fa34d7	1183
arsenalist	0:f4e449fa34d7	1184	str = s;
arsenalist	0:f4e449fa34d7	1185	if(str.find("{") != std::string::npos && str.find("}") != std::string::npos) {
arsenalist	0:f4e449fa34d7	1186	str.erase(str.begin(),str.begin()+str.find("{")+1);
arsenalist	0:f4e449fa34d7	1187	str.erase(str.begin()+str.find("}"),str.end());
arsenalist	0:f4e449fa34d7	1188	//DBG.printf("firmwarePart[%d]:%s\r\n",n,str.c_str());
arsenalist	0:f4e449fa34d7	1189	firmwarePart = str;
arsenalist	0:f4e449fa34d7	1190
arsenalist	0:f4e449fa34d7	1191	//calculated MD5
arsenalist	0:f4e449fa34d7	1192	calcMD5 = calculateMD5(firmwarePart);
arsenalist	0:f4e449fa34d7	1193	//DBG.printf("calcMD5[%d]:%s\r\n",n,calcMD5.c_str());
arsenalist	0:f4e449fa34d7	1194
arsenalist	0:f4e449fa34d7	1195	//MD5 from server
arsenalist	0:f4e449fa34d7	1196	for(int i=0; i<sizeof(s); i++) {
arsenalist	0:f4e449fa34d7	1197	s[i]=0; }
arsenalist	0:f4e449fa34d7	1198	sprintf(s,"%s/MD5/firmware_MD5_%s_%d",connData.c_str(),firmwareVer.c_str(),n);
arsenalist	0:f4e449fa34d7	1199	rest.get(s);
arsenalist	0:f4e449fa34d7	1200	for(int i=0; i<sizeof(s); i++) {
arsenalist	0:f4e449fa34d7	1201	s[i]=0; }
arsenalist	0:f4e449fa34d7	1202	rest.getResponse(s,sizeof(s));
arsenalist	0:f4e449fa34d7	1203
arsenalist	0:f4e449fa34d7	1204	str = s;
arsenalist	0:f4e449fa34d7	1205	if(str.find("{") != std::string::npos && str.find("}") != std::string::npos) {
arsenalist	0:f4e449fa34d7	1206	str.erase(str.begin(),str.begin()+str.find("{")+1);
arsenalist	0:f4e449fa34d7	1207	str.erase(str.begin()+str.find("}"),str.end());
arsenalist	0:f4e449fa34d7	1208	srvrMD5 = str;
arsenalist	0:f4e449fa34d7	1209	//DBG.printf("srvrMD5[%d]:%s\r\n",n,srvrMD5.c_str());
arsenalist	0:f4e449fa34d7	1210
arsenalist	0:f4e449fa34d7	1211	//compare original MD5 vs MD5 from server
arsenalist	0:f4e449fa34d7	1212	if(strcmp(calcMD5.c_str(),srvrMD5.c_str()) == 0) {
arsenalist	0:f4e449fa34d7	1213	//DBG.printf("MD5 correct\r\n");
arsenalist	0:f4e449fa34d7	1214
arsenalist	0:f4e449fa34d7	1215	//save to sd card
arsenalist	0:f4e449fa34d7	1216	int st = writeFirmwareHexToChar(firmwarePart);
arsenalist	0:f4e449fa34d7	1217	if(st) {
arsenalist	0:f4e449fa34d7	1218	DBG.printf("firmwarePart[%d/%d] written\r\n",n,numPart-1);
arsenalist	0:f4e449fa34d7	1219	nextPart = true;
arsenalist	0:f4e449fa34d7	1220	}
arsenalist	0:f4e449fa34d7	1221
arsenalist	0:f4e449fa34d7	1222	} else {
arsenalist	0:f4e449fa34d7	1223	DBG.printf("MD5 incorrect\r\n");
arsenalist	0:f4e449fa34d7	1224	}
arsenalist	0:f4e449fa34d7	1225	}
arsenalist	0:f4e449fa34d7	1226	} else {
arsenalist	0:f4e449fa34d7	1227	DBG.printf("retry to fetch firmwarePart[%d]\r\n",n);
arsenalist	0:f4e449fa34d7	1228	}
arsenalist	0:f4e449fa34d7	1229	wait(0.5);
arsenalist	0:f4e449fa34d7	1230	}
arsenalist	0:f4e449fa34d7	1231	}
arsenalist	0:f4e449fa34d7	1232	DBG.printf("download finished\r\n");
arsenalist	0:f4e449fa34d7	1233	}
arsenalist	0:f4e449fa34d7	1234
arsenalist	4:76ab12e2f8a3	1235	/start energy related/
arsenalist	0:f4e449fa34d7	1236	void energyThread(void const*) {
arsenalist	0:f4e449fa34d7	1237	while(1) {
arsenalist	0:f4e449fa34d7	1238	//DBG.printf("insideEnergyThread\r\n");
arsenalist	0:f4e449fa34d7	1239	//osDelay(5000);
arsenalist	0:f4e449fa34d7	1240
arsenalist	0:f4e449fa34d7	1241	//calculate energy
arsenalist	4:76ab12e2f8a3	1242	DBG.printf("energyThread-start\r\n");
arsenalist	0:f4e449fa34d7	1243	float period = 0;
arsenalist	0:f4e449fa34d7	1244	AWattHrSum = 0;
arsenalist	0:f4e449fa34d7	1245	BWattHrSum = 0;
arsenalist	0:f4e449fa34d7	1246	CWattHrSum = 0;
arsenalist	0:f4e449fa34d7	1247	while(period < 1*60.0) {
arsenalist	0:f4e449fa34d7	1248	period += ADE.getAccumulationTime(PHASE_A);
arsenalist	0:f4e449fa34d7	1249	ADE.getAccumulatedEnergy(PHASE_A, &AWattHrValue, &BWattHrValue, &CWattHrValue, &AVAHrValue, &BVAHrValue, &CVAHrValue);
arsenalist	0:f4e449fa34d7	1250	AWattHrSum += AWattHrValue;
arsenalist	0:f4e449fa34d7	1251	BWattHrSum += BWattHrValue;
arsenalist	0:f4e449fa34d7	1252	CWattHrSum += CWattHrValue;
arsenalist	0:f4e449fa34d7	1253	}
arsenalist	0:f4e449fa34d7	1254	AWattHr = AWattHrSum * ADE.AWhLSB;
arsenalist	0:f4e449fa34d7	1255	BWattHr = BWattHrSum * ADE.BWhLSB;
arsenalist	0:f4e449fa34d7	1256	CWattHr = CWattHrSum * ADE.CWhLSB;
arsenalist	0:f4e449fa34d7	1257
arsenalist	4:76ab12e2f8a3	1258	DBG.printf("energyThread-finish\r\n");
arsenalist	0:f4e449fa34d7	1259	}
arsenalist	0:f4e449fa34d7	1260	}
arsenalist	4:76ab12e2f8a3	1261	void checkVoltagePower() {
arsenalist	4:76ab12e2f8a3	1262	//check if voltage or power violates threshold
arsenalist	4:76ab12e2f8a3	1263	char s[256];
arsenalist	4:76ab12e2f8a3	1264	string str;
arsenalist	4:76ab12e2f8a3	1265
arsenalist	4:76ab12e2f8a3	1266	//DBG.printf("checkVoltagePower-start\r\n");
arsenalist	4:76ab12e2f8a3	1267
arsenalist	4:76ab12e2f8a3	1268	AVrms = ADE.VRMS(PHASE_A) * 2*0.000158; //constants are from calculateVRMS function
arsenalist	4:76ab12e2f8a3	1269	BVrms = ADE.VRMS(PHASE_B) * 2*0.000157;
arsenalist	4:76ab12e2f8a3	1270	CVrms = ADE.VRMS(PHASE_C) * 2*0.000156;
arsenalist	4:76ab12e2f8a3	1271
arsenalist	4:76ab12e2f8a3	1272	AIrms = ADE.IRMS(PHASE_A) * 0.0000125; //constants are from calculateIRMS function
arsenalist	4:76ab12e2f8a3	1273	BIrms = ADE.IRMS(PHASE_B) * 0.0000123;
arsenalist	4:76ab12e2f8a3	1274	CIrms = ADE.IRMS(PHASE_C) * 0.0000124;
arsenalist	4:76ab12e2f8a3	1275
arsenalist	4:76ab12e2f8a3	1276	AWatt = AVrms * AIrms;
arsenalist	4:76ab12e2f8a3	1277	BWatt = BVrms * BIrms;
arsenalist	4:76ab12e2f8a3	1278	CWatt = CVrms * CIrms;
arsenalist	4:76ab12e2f8a3	1279
arsenalist	4:76ab12e2f8a3	1280	if(AVrms > VRMSTHRESHOLD \|\| AWatt > WATTTHRESHOLD) {
arsenalist	4:76ab12e2f8a3	1281	DBG.printf("alert on ch1\r\n");
arsenalist	4:76ab12e2f8a3	1282	sprintf(s,"{\"uid\":\"%s\",\"hmac\":\"%s\",\"time\":\"2015-06-09 12:32:12\",\"voltage\":%.2f,\"power\":%.2f}",
arsenalist	4:76ab12e2f8a3	1283	emmaUID.c_str(),hmac.c_str(),AVrms,AWatt);
arsenalist	4:76ab12e2f8a3	1284	rest.post("/emma/api/controller/alert/1",s);
arsenalist	4:76ab12e2f8a3	1285	wait(2);
arsenalist	4:76ab12e2f8a3	1286	str = rxBuf;
arsenalist	4:76ab12e2f8a3	1287	if(str.rfind("/alert/1") != std::string::npos) {
arsenalist	4:76ab12e2f8a3	1288	str.erase(str.begin(),str.begin()+str.rfind("/alert/1"));
arsenalist	4:76ab12e2f8a3	1289	if(str.find("\"status\":\"success\"") != std::string::npos) {
arsenalist	4:76ab12e2f8a3	1290	DBG.printf("send alert ch1 success\r\n");
arsenalist	4:76ab12e2f8a3	1291	} else {
arsenalist	4:76ab12e2f8a3	1292	DBG.printf("send alert ch1 failed\r\n");
arsenalist	4:76ab12e2f8a3	1293	}
arsenalist	4:76ab12e2f8a3	1294	}
arsenalist	4:76ab12e2f8a3	1295	}
arsenalist	4:76ab12e2f8a3	1296
arsenalist	4:76ab12e2f8a3	1297	if(BVrms > VRMSTHRESHOLD \|\| BWatt > WATTTHRESHOLD) {
arsenalist	4:76ab12e2f8a3	1298	DBG.printf("alert on ch2\r\n");
arsenalist	4:76ab12e2f8a3	1299	sprintf(s,"{\"uid\":\"%s\",\"hmac\":\"%s\",\"time\":\"2015-06-09 12:32:12\",\"voltage\":%.2f,\"power\":%.2f}",
arsenalist	4:76ab12e2f8a3	1300	emmaUID.c_str(),hmac.c_str(),BVrms,BWatt);
arsenalist	4:76ab12e2f8a3	1301	rest.post("/emma/api/controller/alert/2",s);
arsenalist	4:76ab12e2f8a3	1302	wait(2);
arsenalist	4:76ab12e2f8a3	1303	str = rxBuf;
arsenalist	4:76ab12e2f8a3	1304	if(str.rfind("/alert/2") != std::string::npos) {
arsenalist	4:76ab12e2f8a3	1305	str.erase(str.begin(),str.begin()+str.rfind("/alert/2"));
arsenalist	4:76ab12e2f8a3	1306	if(str.find("\"status\":\"success\"") != std::string::npos) {
arsenalist	4:76ab12e2f8a3	1307	DBG.printf("send alert ch2 success\r\n");
arsenalist	4:76ab12e2f8a3	1308	} else {
arsenalist	4:76ab12e2f8a3	1309	DBG.printf("send alert ch2 failed\r\n");
arsenalist	4:76ab12e2f8a3	1310	}
arsenalist	4:76ab12e2f8a3	1311	}
arsenalist	4:76ab12e2f8a3	1312	}
arsenalist	4:76ab12e2f8a3	1313
arsenalist	4:76ab12e2f8a3	1314	if(CVrms > VRMSTHRESHOLD \|\| CWatt > WATTTHRESHOLD) {
arsenalist	7:7e8c6ad3fd64	1315	DBG.printf("alert on ch3\r\n");
arsenalist	4:76ab12e2f8a3	1316	DBG.printf("alert on ch3\r\n");
arsenalist	4:76ab12e2f8a3	1317	sprintf(s,"{\"uid\":\"%s\",\"hmac\":\"%s\",\"time\":\"2015-06-09 12:32:12\",\"voltage\":%.2f,\"power\":%.2f}",
arsenalist	4:76ab12e2f8a3	1318	emmaUID.c_str(),hmac.c_str(),CVrms,CWatt);
arsenalist	4:76ab12e2f8a3	1319	rest.post("/emma/api/controller/alert/3",s);
arsenalist	4:76ab12e2f8a3	1320	wait(2);
arsenalist	4:76ab12e2f8a3	1321	str = rxBuf;
arsenalist	4:76ab12e2f8a3	1322	if(str.rfind("/alert/3") != std::string::npos) {
arsenalist	4:76ab12e2f8a3	1323	str.erase(str.begin(),str.begin()+str.rfind("/alert/3"));
arsenalist	4:76ab12e2f8a3	1324	if(str.find("\"status\":\"success\"") != std::string::npos) {
arsenalist	4:76ab12e2f8a3	1325	DBG.printf("send alert ch3 success\r\n");
arsenalist	4:76ab12e2f8a3	1326	} else {
arsenalist	4:76ab12e2f8a3	1327	DBG.printf("send alert ch3 failed\r\n");
arsenalist	4:76ab12e2f8a3	1328	}
arsenalist	4:76ab12e2f8a3	1329	}
arsenalist	4:76ab12e2f8a3	1330	}
arsenalist	4:76ab12e2f8a3	1331	//DBG.printf("checkVoltagePower-finish\r\n");
arsenalist	4:76ab12e2f8a3	1332	}
arsenalist	4:76ab12e2f8a3	1333	/end energy related/
arsenalist	0:f4e449fa34d7	1334
arsenalist	0:f4e449fa34d7	1335	/start wifi mqtt/
arsenalist	0:f4e449fa34d7	1336	void mqttConnected(void* response) {
arsenalist	1:d314a43ae6f7	1337	DBG.printf("MQTT Connected\r\n");
arsenalist	0:f4e449fa34d7	1338	char mqttTopic[64];
arsenalist	0:f4e449fa34d7	1339	sprintf(mqttTopic,"%s/%s/command",platformDOMAIN.c_str(),emmaUID.c_str());
arsenalist	0:f4e449fa34d7	1340	mqtt.subscribe(mqttTopic);
arsenalist	0:f4e449fa34d7	1341	}
arsenalist	0:f4e449fa34d7	1342	void mqttDisconnected(void* response) {
arsenalist	1:d314a43ae6f7	1343	DBG.printf("MQTT Disconnected\r\n");
arsenalist	0:f4e449fa34d7	1344	}
arsenalist	0:f4e449fa34d7	1345	/end wifi mqtt/
arsenalist	0:f4e449fa34d7	1346
arsenalist	0:f4e449fa34d7	1347	/start wifi rest/
arsenalist	4:76ab12e2f8a3	1348	void rxInterrupt(void) {
arsenalist	4:76ab12e2f8a3	1349	char c;
arsenalist	4:76ab12e2f8a3	1350
arsenalist	4:76ab12e2f8a3	1351	while(_ESP.readable()) {
arsenalist	4:76ab12e2f8a3	1352	c = _ESP.getc();
arsenalist	4:76ab12e2f8a3	1353	if(c != 0) { //char is not null
arsenalist	4:76ab12e2f8a3	1354	rxBuf += c;
arsenalist	4:76ab12e2f8a3	1355	}
arsenalist	4:76ab12e2f8a3	1356	}
arsenalist	4:76ab12e2f8a3	1357	}
arsenalist	4:76ab12e2f8a3	1358	void checkRxBuffer(void) {
arsenalist	4:76ab12e2f8a3	1359	//check new command
arsenalist	4:76ab12e2f8a3	1360	if(rxBuf.rfind("/command") != std::string::npos) {
arsenalist	4:76ab12e2f8a3	1361	rxBuf.erase(rxBuf.begin(),rxBuf.begin()+rxBuf.rfind("/command"));
arsenalist	4:76ab12e2f8a3	1362	if(rxBuf.find("[{") != std::string::npos && rxBuf.find("}]") != std::string::npos) {
arsenalist	4:76ab12e2f8a3	1363	rxBuf.erase(rxBuf.begin(),rxBuf.begin()+rxBuf.find("[{")+1);
arsenalist	4:76ab12e2f8a3	1364	rxBuf.erase(rxBuf.begin()+rxBuf.find("]"),rxBuf.end());
arsenalist	4:76ab12e2f8a3	1365	globalCommand = rxBuf;
arsenalist	4:76ab12e2f8a3	1366	//DBG.printf("gC:%s\r\n",globalCommand.c_str());
arsenalist	4:76ab12e2f8a3	1367	newCommand = true;
arsenalist	4:76ab12e2f8a3	1368	}
arsenalist	4:76ab12e2f8a3	1369	}
arsenalist	4:76ab12e2f8a3	1370
arsenalist	4:76ab12e2f8a3	1371	//clear rxBuf
arsenalist	4:76ab12e2f8a3	1372	rxBuf.clear();
arsenalist	4:76ab12e2f8a3	1373	}
arsenalist	0:f4e449fa34d7	1374	/end wifi rest/
arsenalist	0:f4e449fa34d7	1375
arsenalist	0:f4e449fa34d7	1376	/start eth mqtt/
arsenalist	0:f4e449fa34d7	1377	void ethMQTTMessageArrived(MQTT::MessageData& md) {
arsenalist	0:f4e449fa34d7	1378	MQTT::Message &message = md.message;
arsenalist	0:f4e449fa34d7	1379	DBG.printf("Message arrived: qos %d, retained %d, dup %d, packetid %d\r\n",
arsenalist	0:f4e449fa34d7	1380	message.qos, message.retained, message.dup, message.id);
arsenalist	0:f4e449fa34d7	1381	DBG.printf("Payload: %.s\r\n", message.payloadlen, (char)message.payload);
arsenalist	0:f4e449fa34d7	1382	//DBG.printf("Payload %s\r\n",message.payload);
arsenalist	0:f4e449fa34d7	1383
arsenalist	0:f4e449fa34d7	1384
arsenalist	0:f4e449fa34d7	1385	//check whether cmd is json
arsenalist	0:f4e449fa34d7	1386	//char r[255];
arsenalist	0:f4e449fa34d7	1387	char s = (char)message.payload;
arsenalist	0:f4e449fa34d7	1388	string sp(s);
arsenalist	0:f4e449fa34d7	1389	//sprintf(s,"%.s",message.payloadlen, (char)message.payload);
arsenalist	0:f4e449fa34d7	1390	//sprintf(globCmd,"%s",s);
arsenalist	0:f4e449fa34d7	1391	//DBG.printf("Payload: %s\r\n", r);
arsenalist	0:f4e449fa34d7	1392	//string cmd = r;
arsenalist	0:f4e449fa34d7	1393	//globalCommand = cmd;
arsenalist	10:1dc69e0ce7fd	1394
arsenalist	10:1dc69e0ce7fd	1395	//globalCommand = sp;
arsenalist	10:1dc69e0ce7fd	1396
arsenalist	0:f4e449fa34d7	1397	//globCmd = (char*)message.payload;
arsenalist	0:f4e449fa34d7	1398	//string globCmd((char*)message.payload);
arsenalist	0:f4e449fa34d7	1399	//std::string sp = static_cast<std::char>(message.payload);
arsenalist	0:f4e449fa34d7	1400	//string sp((char*)message.payload);
arsenalist	10:1dc69e0ce7fd	1401
arsenalist	10:1dc69e0ce7fd	1402	//DBG.printf("String: %s\r\n",sp.c_str());
arsenalist	10:1dc69e0ce7fd	1403
arsenalist	0:f4e449fa34d7	1404	//globCmd = sp;
arsenalist	0:f4e449fa34d7	1405
arsenalist	10:1dc69e0ce7fd	1406	//newCommand = true;
arsenalist	10:1dc69e0ce7fd	1407	if(sp.find("[") != std::string::npos && sp.find("]") != std::string::npos) {
arsenalist	10:1dc69e0ce7fd	1408	sp.erase(sp.begin(),sp.begin()+sp.find("[")+1);
arsenalist	10:1dc69e0ce7fd	1409	sp.erase(sp.begin()+sp.find("]"),sp.end());
arsenalist	10:1dc69e0ce7fd	1410	globalCommand = sp;
arsenalist	0:f4e449fa34d7	1411	newCommand = true;
arsenalist	0:f4e449fa34d7	1412	}
arsenalist	10:1dc69e0ce7fd	1413	sp.clear();
arsenalist	0:f4e449fa34d7	1414	}
arsenalist	0:f4e449fa34d7	1415
arsenalist	0:f4e449fa34d7	1416	int ethMQTTConnect(MQTT::Client<MQTTEthernet, Countdown, MQTT_MAX_PACKET_SIZE>* client, MQTTEthernet* ipstack) {
arsenalist	0:f4e449fa34d7	1417	//char hostname[] = "q.thingfabric.com";
arsenalist	0:f4e449fa34d7	1418	//char hostname[] = "192.168.131.200";
arsenalist	0:f4e449fa34d7	1419	//int rc = ipstack->connect(hostname, MQTT_PORT);
arsenalist	0:f4e449fa34d7	1420	int rc = ipstack->connect(MQTT_HOST, MQTT_PORT);
arsenalist	0:f4e449fa34d7	1421
arsenalist	0:f4e449fa34d7	1422	if(rc!=0)
arsenalist	0:f4e449fa34d7	1423	return rc;
arsenalist	0:f4e449fa34d7	1424
arsenalist	0:f4e449fa34d7	1425	//MQTT Connect
arsenalist	0:f4e449fa34d7	1426	//char clientId[] = "emma/0674ff575349896767072538";
arsenalist	0:f4e449fa34d7	1427	char clientId [32];
arsenalist	0:f4e449fa34d7	1428	sprintf(clientId,"emma/%s",emmaUID.c_str());
arsenalist	0:f4e449fa34d7	1429	//DBG.printf("clientId:%s\r\n",clientId);
arsenalist	0:f4e449fa34d7	1430	MQTTPacket_connectData data = MQTTPacket_connectData_initializer;
arsenalist	0:f4e449fa34d7	1431	data.MQTTVersion = 3;
arsenalist	0:f4e449fa34d7	1432	data.clientID.cstring = clientId;
arsenalist	0:f4e449fa34d7	1433	data.username.cstring = "761b233e-a49a-4830-a8ae-87cec3dc1086";
arsenalist	0:f4e449fa34d7	1434	data.password.cstring = "ef25cf4567fbc07113252f8d72b7faf2";
arsenalist	0:f4e449fa34d7	1435
arsenalist	0:f4e449fa34d7	1436	if((rc = client->connect(&data)) == 0) {
arsenalist	0:f4e449fa34d7	1437	DBG.printf("connected\r\n");
arsenalist	0:f4e449fa34d7	1438	}
arsenalist	0:f4e449fa34d7	1439
arsenalist	0:f4e449fa34d7	1440	//MQTT Subscribe
arsenalist	0:f4e449fa34d7	1441	//char* topic = "gaisbwqreqrfxjc/0674ff575349896767072538/command";
arsenalist	0:f4e449fa34d7	1442	char s[64];
arsenalist	0:f4e449fa34d7	1443	sprintf(s,"%s/%s/command",platformDOMAIN.c_str(),emmaUID.c_str());
arsenalist	0:f4e449fa34d7	1444	string topic = s;
arsenalist	0:f4e449fa34d7	1445	//DBG.printf("topic:%s\r\n",topic.c_str());
arsenalist	0:f4e449fa34d7	1446	if((rc=client->subscribe(topic.c_str(),MQTT::QOS0,ethMQTTMessageArrived)) == 0) {
arsenalist	0:f4e449fa34d7	1447	DBG.printf("subscribe success!\r\n");
arsenalist	0:f4e449fa34d7	1448	}
arsenalist	0:f4e449fa34d7	1449	return rc;
arsenalist	0:f4e449fa34d7	1450	}
arsenalist	0:f4e449fa34d7	1451	void ethMQTTAttemptConnect(MQTT::Client<MQTTEthernet, Countdown, MQTT_MAX_PACKET_SIZE>* client, MQTTEthernet* ipstack) {
arsenalist	0:f4e449fa34d7	1452	int retryAttempt = 0;
arsenalist	0:f4e449fa34d7	1453
arsenalist	0:f4e449fa34d7	1454	while(!ipstack->getEth().linkstatus()) {
arsenalist	0:f4e449fa34d7	1455	DBG.printf("Ethernet link not present. Check cable connection\r\n");
arsenalist	0:f4e449fa34d7	1456	wait(1);
arsenalist	0:f4e449fa34d7	1457	}
arsenalist	0:f4e449fa34d7	1458
arsenalist	0:f4e449fa34d7	1459	while(ethMQTTConnect(client,ipstack) != 0) {
arsenalist	0:f4e449fa34d7	1460	int timeout = 3;
arsenalist	0:f4e449fa34d7	1461	DBG.printf("Retry attempt number %d waiting %d\r\n", retryAttempt, timeout);
arsenalist	0:f4e449fa34d7	1462	wait(timeout);
arsenalist	0:f4e449fa34d7	1463	retryAttempt++;
arsenalist	0:f4e449fa34d7	1464	}
arsenalist	0:f4e449fa34d7	1465	}
arsenalist	0:f4e449fa34d7	1466	/end eth mqtt/
arsenalist	0:f4e449fa34d7	1467
arsenalist	0:f4e449fa34d7	1468	/start emma settings/
arsenalist	0:f4e449fa34d7	1469	string getUID(void) {
arsenalist	0:f4e449fa34d7	1470	char s[32];
arsenalist	0:f4e449fa34d7	1471	unsigned long unique = (unsigned long )BASE_ADDR;
arsenalist	0:f4e449fa34d7	1472	sprintf(s,"%08x%08x%08x",unique[0], unique[1], unique[2]);
arsenalist	0:f4e449fa34d7	1473	return s;
arsenalist	0:f4e449fa34d7	1474	}
arsenalist	0:f4e449fa34d7	1475
arsenalist	0:f4e449fa34d7	1476	string readSetting(string parameter) {
arsenalist	0:f4e449fa34d7	1477	FILE *fp;
arsenalist	0:f4e449fa34d7	1478	signed char c;
arsenalist	0:f4e449fa34d7	1479	int i=0;
arsenalist	0:f4e449fa34d7	1480	char s[64];
arsenalist	0:f4e449fa34d7	1481	string strS;
arsenalist	0:f4e449fa34d7	1482
arsenalist	0:f4e449fa34d7	1483	sprintf(s,"/sd/settings/%s.txt",parameter.c_str());
arsenalist	0:f4e449fa34d7	1484
arsenalist	0:f4e449fa34d7	1485	fp = fopen(s,"r");
arsenalist	0:f4e449fa34d7	1486	memset(s,0,sizeof(s));
arsenalist	0:f4e449fa34d7	1487	if(fp != NULL) {
arsenalist	0:f4e449fa34d7	1488	while(1) {
arsenalist	0:f4e449fa34d7	1489	c = fgetc(fp);
arsenalist	0:f4e449fa34d7	1490	if(c == EOF){
arsenalist	0:f4e449fa34d7	1491	break;
arsenalist	0:f4e449fa34d7	1492	}
arsenalist	0:f4e449fa34d7	1493	s[i] = c;
arsenalist	0:f4e449fa34d7	1494	i++;
arsenalist	0:f4e449fa34d7	1495	}
arsenalist	0:f4e449fa34d7	1496	strS = s;
arsenalist	0:f4e449fa34d7	1497	if(strS.find("(") != std::string::npos && strS.find(")") != std::string::npos) {
arsenalist	0:f4e449fa34d7	1498	strS.erase(strS.begin(),strS.begin()+strS.find("(")+1);
arsenalist	0:f4e449fa34d7	1499	strS.erase(strS.begin()+strS.find(")"),strS.end());
arsenalist	0:f4e449fa34d7	1500	} else {
arsenalist	0:f4e449fa34d7	1501	strS = "";
arsenalist	0:f4e449fa34d7	1502	}
arsenalist	0:f4e449fa34d7	1503	}
arsenalist	0:f4e449fa34d7	1504	fclose(fp);
arsenalist	0:f4e449fa34d7	1505	return strS;
arsenalist	0:f4e449fa34d7	1506	}
arsenalist	0:f4e449fa34d7	1507
arsenalist	0:f4e449fa34d7	1508	bool writeSetting(string parameter, string value) {
arsenalist	0:f4e449fa34d7	1509	FILE *fp;
arsenalist	0:f4e449fa34d7	1510	char s[255];
arsenalist	0:f4e449fa34d7	1511
arsenalist	0:f4e449fa34d7	1512	sprintf(s,"/sd/settings/%s.txt",parameter.c_str());
arsenalist	0:f4e449fa34d7	1513	fp = fopen(s,"w");
arsenalist	0:f4e449fa34d7	1514	if(fp != NULL) {
arsenalist	0:f4e449fa34d7	1515	fprintf(fp,value.c_str());
arsenalist	0:f4e449fa34d7	1516	fclose(fp);
arsenalist	0:f4e449fa34d7	1517	return true;
arsenalist	0:f4e449fa34d7	1518	}
arsenalist	0:f4e449fa34d7	1519	return false;
arsenalist	0:f4e449fa34d7	1520	}
arsenalist	0:f4e449fa34d7	1521	/end emma settings/
arsenalist	0:f4e449fa34d7	1522
arsenalist	0:f4e449fa34d7	1523	/start emma node/
arsenalist	0:f4e449fa34d7	1524	string readNodeIP(string macAddr) {
arsenalist	0:f4e449fa34d7	1525	FILE *fp;
arsenalist	0:f4e449fa34d7	1526	signed char c;
arsenalist	0:f4e449fa34d7	1527	int i=0;
arsenalist	0:f4e449fa34d7	1528	char s[64];
arsenalist	0:f4e449fa34d7	1529	string strS;
arsenalist	0:f4e449fa34d7	1530
arsenalist	0:f4e449fa34d7	1531	sprintf(s,"/sd/nodeList/%s/nodeIP.txt",macAddr.c_str());
arsenalist	0:f4e449fa34d7	1532
arsenalist	0:f4e449fa34d7	1533	fp = fopen(s,"r");
arsenalist	0:f4e449fa34d7	1534	memset(s,0,sizeof(s));
arsenalist	0:f4e449fa34d7	1535	if(fp != NULL) {
arsenalist	0:f4e449fa34d7	1536	while(1) {
arsenalist	0:f4e449fa34d7	1537	c = fgetc(fp);
arsenalist	0:f4e449fa34d7	1538	if(c == EOF){
arsenalist	0:f4e449fa34d7	1539	break;
arsenalist	0:f4e449fa34d7	1540	}
arsenalist	0:f4e449fa34d7	1541	s[i] = c;
arsenalist	0:f4e449fa34d7	1542	i++;
arsenalist	0:f4e449fa34d7	1543	}
arsenalist	0:f4e449fa34d7	1544	strS = s;
arsenalist	0:f4e449fa34d7	1545	if(strS.find("(") != std::string::npos && strS.find(")") != std::string::npos) {
arsenalist	0:f4e449fa34d7	1546	strS.erase(strS.begin(),strS.begin()+strS.find("(")+1);
arsenalist	0:f4e449fa34d7	1547	strS.erase(strS.begin()+strS.find(")"),strS.end());
arsenalist	0:f4e449fa34d7	1548	} else {
arsenalist	0:f4e449fa34d7	1549	strS = "";
arsenalist	0:f4e449fa34d7	1550	}
arsenalist	0:f4e449fa34d7	1551	}
arsenalist	0:f4e449fa34d7	1552	fclose(fp);
arsenalist	0:f4e449fa34d7	1553	return strS;
arsenalist	0:f4e449fa34d7	1554	}
arsenalist	0:f4e449fa34d7	1555
arsenalist	0:f4e449fa34d7	1556	string readNodeCmd(string dType, string cmd) {
arsenalist	0:f4e449fa34d7	1557	FILE *fp;
arsenalist	0:f4e449fa34d7	1558	signed char c;
arsenalist	0:f4e449fa34d7	1559	int i=0;
arsenalist	0:f4e449fa34d7	1560	char s[128];
arsenalist	0:f4e449fa34d7	1561	string strS;
arsenalist	0:f4e449fa34d7	1562
arsenalist	0:f4e449fa34d7	1563	sprintf(s,"/sd/nodeCode/%s/%s.txt",dType.c_str(),cmd.c_str());
arsenalist	0:f4e449fa34d7	1564
arsenalist	0:f4e449fa34d7	1565	fp = fopen(s,"r");
arsenalist	0:f4e449fa34d7	1566	memset(s,0,sizeof(s));
arsenalist	0:f4e449fa34d7	1567	if(fp != NULL) {
arsenalist	0:f4e449fa34d7	1568	while(1) {
arsenalist	0:f4e449fa34d7	1569	c = fgetc(fp);
arsenalist	0:f4e449fa34d7	1570	if(c == EOF){
arsenalist	0:f4e449fa34d7	1571	break;
arsenalist	0:f4e449fa34d7	1572	}
arsenalist	0:f4e449fa34d7	1573	s[i] = c;
arsenalist	0:f4e449fa34d7	1574	i++;
arsenalist	0:f4e449fa34d7	1575	}
arsenalist	0:f4e449fa34d7	1576	strS = s;
arsenalist	0:f4e449fa34d7	1577	if(strS.find("(") != std::string::npos && strS.find(")") != std::string::npos) {
arsenalist	0:f4e449fa34d7	1578	strS.erase(strS.begin(),strS.begin()+strS.find("(")+1);
arsenalist	0:f4e449fa34d7	1579	strS.erase(strS.begin()+strS.find(")"),strS.end());
arsenalist	0:f4e449fa34d7	1580	} else {
arsenalist	0:f4e449fa34d7	1581	strS = "";
arsenalist	0:f4e449fa34d7	1582	}
arsenalist	0:f4e449fa34d7	1583	}
arsenalist	0:f4e449fa34d7	1584	fclose(fp);
arsenalist	0:f4e449fa34d7	1585	return strS;
arsenalist	0:f4e449fa34d7	1586	}
arsenalist	0:f4e449fa34d7	1587
arsenalist	0:f4e449fa34d7	1588	string *readNodeList(void) {
arsenalist	0:f4e449fa34d7	1589	static string nd[10]; //max node
arsenalist	0:f4e449fa34d7	1590	DIR *d;
arsenalist	0:f4e449fa34d7	1591	struct dirent *p;
arsenalist	0:f4e449fa34d7	1592	string q;
arsenalist	0:f4e449fa34d7	1593	int i=0;
arsenalist	0:f4e449fa34d7	1594
arsenalist	0:f4e449fa34d7	1595	d = opendir("/sd/nodeList");
arsenalist	0:f4e449fa34d7	1596	if(d != NULL) {
arsenalist	0:f4e449fa34d7	1597	while((p = readdir(d)) != NULL) {
arsenalist	0:f4e449fa34d7	1598	q = p->d_name;
arsenalist	0:f4e449fa34d7	1599	nd[i] = q;
arsenalist	0:f4e449fa34d7	1600	i++;
arsenalist	0:f4e449fa34d7	1601	}
arsenalist	0:f4e449fa34d7	1602	}
arsenalist	0:f4e449fa34d7	1603	closedir(d);
arsenalist	0:f4e449fa34d7	1604	return nd;
arsenalist	0:f4e449fa34d7	1605	}
arsenalist	0:f4e449fa34d7	1606
arsenalist	0:f4e449fa34d7	1607	string wifiGetNodeTemp(string macAddr) {
arsenalist	0:f4e449fa34d7	1608	int trial=0;
arsenalist	0:f4e449fa34d7	1609	string nodeIP = readNodeIP(macAddr);
arsenalist	0:f4e449fa34d7	1610	string str;
arsenalist	0:f4e449fa34d7	1611	string temp = "0";
arsenalist	0:f4e449fa34d7	1612
arsenalist	0:f4e449fa34d7	1613	if(rest.begin(nodeIP.c_str(),REMOTE_TCP_PORT,false)) {
arsenalist	0:f4e449fa34d7	1614	while(1) {
arsenalist	0:f4e449fa34d7	1615	char rcv[256] = {};
arsenalist	0:f4e449fa34d7	1616	rest.get("/","<?xml version=\"1.0\" encoding=\"utf-8\"?><app_cmd cmd=\"2\"/>\r\n");
arsenalist	0:f4e449fa34d7	1617	rest.getResponse(rcv,sizeof(rcv));
arsenalist	0:f4e449fa34d7	1618	str = rcv;
arsenalist	0:f4e449fa34d7	1619	if(str.find("temp=") != std::string::npos) {
arsenalist	0:f4e449fa34d7	1620	str.erase(str.begin(),str.begin()+str.find("temp=")+6);
arsenalist	0:f4e449fa34d7	1621	str.erase(str.begin()+str.find("\""),str.end());
arsenalist	0:f4e449fa34d7	1622	temp = str;
arsenalist	0:f4e449fa34d7	1623	break;
arsenalist	0:f4e449fa34d7	1624	}
arsenalist	0:f4e449fa34d7	1625	if(trial>1) { //three times trial
arsenalist	0:f4e449fa34d7	1626	break;
arsenalist	0:f4e449fa34d7	1627	}
arsenalist	0:f4e449fa34d7	1628	trial++;
arsenalist	0:f4e449fa34d7	1629	wait(2);
arsenalist	0:f4e449fa34d7	1630	}
arsenalist	0:f4e449fa34d7	1631	}
arsenalist	0:f4e449fa34d7	1632	return temp;
arsenalist	0:f4e449fa34d7	1633	}
arsenalist	0:f4e449fa34d7	1634	/end emma node/
arsenalist	0:f4e449fa34d7	1635
arsenalist	0:f4e449fa34d7	1636	/start emma connection function/
arsenalist	0:f4e449fa34d7	1637	string ethGET(string host, int port, string url) {
arsenalist	0:f4e449fa34d7	1638	char buf[1024];
arsenalist	0:f4e449fa34d7	1639	char s[256];
arsenalist	0:f4e449fa34d7	1640	int ret;
arsenalist	0:f4e449fa34d7	1641	TCPSocketConnection sock;
arsenalist	0:f4e449fa34d7	1642	Timer t;
arsenalist	0:f4e449fa34d7	1643
arsenalist	0:f4e449fa34d7	1644	sprintf(s,"%s",url.c_str());
arsenalist	0:f4e449fa34d7	1645	sock.connect(host.c_str(),port);
arsenalist	0:f4e449fa34d7	1646	sock.send_all(s,sizeof(s)-1);
arsenalist	0:f4e449fa34d7	1647	wait(2);
arsenalist	0:f4e449fa34d7	1648
arsenalist	0:f4e449fa34d7	1649	//receive return
arsenalist	0:f4e449fa34d7	1650	t.start();
arsenalist	0:f4e449fa34d7	1651	while(1) {
arsenalist	0:f4e449fa34d7	1652	ret = sock.receive(buf, sizeof(buf));
arsenalist	0:f4e449fa34d7	1653	if(ret<=0 \|\| t.read_ms() > 10000) {
arsenalist	0:f4e449fa34d7	1654	t.stop();
arsenalist	0:f4e449fa34d7	1655	break;
arsenalist	0:f4e449fa34d7	1656	}
arsenalist	0:f4e449fa34d7	1657	}
arsenalist	0:f4e449fa34d7	1658	sock.close();
arsenalist	0:f4e449fa34d7	1659	return buf;
arsenalist	0:f4e449fa34d7	1660	}
arsenalist	0:f4e449fa34d7	1661	/end emma connection function/
arsenalist	0:f4e449fa34d7	1662
arsenalist	0:f4e449fa34d7	1663	/start emma private function/
arsenalist	8:51a0ca9079ca	1664	/*
arsenalist	8:51a0ca9079ca	1665	void connectedIface(void) { //WARNING: should be run in emmaModeRegister and emmaModeOperation only - problem with esp, after MODE=B, cannot go back to MODE=S
arsenalist	0:f4e449fa34d7	1666	char s[512];
arsenalist	0:f4e449fa34d7	1667	int connPort;
arsenalist	0:f4e449fa34d7	1668	string connHost;
arsenalist	0:f4e449fa34d7	1669	string str;
arsenalist	0:f4e449fa34d7	1670	Timer t;
arsenalist	0:f4e449fa34d7	1671
arsenalist	0:f4e449fa34d7	1672	//wifi interface
arsenalist	0:f4e449fa34d7	1673	if(wifiAvailable) {
arsenalist	0:f4e449fa34d7	1674	_ESP.printf("MODE=B");
arsenalist	0:f4e449fa34d7	1675	if(useProxy) {
arsenalist	0:f4e449fa34d7	1676	connHost = proxySERVER;
arsenalist	0:f4e449fa34d7	1677	sscanf(proxyPORT.c_str(),"%d",&connPort);
arsenalist	0:f4e449fa34d7	1678	for(int i=0; i<sizeof(s); i++) {
arsenalist	0:f4e449fa34d7	1679	s[i]=0; }
arsenalist	4:76ab12e2f8a3	1680	sprintf(s,"http://%s:%d/emma/api/controller/test HTTP/1.0\nHost: %s\r\n\r\n",EMMA_SERVER_HOST,EMMA_SERVER_PORT,EMMA_SERVER_HOST);
arsenalist	0:f4e449fa34d7	1681	} else {
arsenalist	0:f4e449fa34d7	1682	connHost = EMMA_SERVER_HOST;
arsenalist	0:f4e449fa34d7	1683	connPort = EMMA_SERVER_PORT;
arsenalist	0:f4e449fa34d7	1684	for(int i=0; i<sizeof(s); i++) {
arsenalist	0:f4e449fa34d7	1685	s[i]=0; }
arsenalist	4:76ab12e2f8a3	1686	sprintf(s,"/emma/api/controller/test");
arsenalist	0:f4e449fa34d7	1687	}
arsenalist	0:f4e449fa34d7	1688	wait(1);
arsenalist	0:f4e449fa34d7	1689	t.start();
arsenalist	0:f4e449fa34d7	1690	while(!esp.ready() && t.read_ms() < 5000);
arsenalist	0:f4e449fa34d7	1691	t.stop();
arsenalist	0:f4e449fa34d7	1692	if(rest.begin(connHost.c_str(),connPort,false)) {
arsenalist	0:f4e449fa34d7	1693	//DBG.printf("rest begin\r\n");
arsenalist	0:f4e449fa34d7	1694	esp.process();
arsenalist	0:f4e449fa34d7	1695	rest.get(s);
arsenalist	0:f4e449fa34d7	1696	for(int i=0; i<sizeof(s); i++) {
arsenalist	0:f4e449fa34d7	1697	s[i]=0; }
arsenalist	0:f4e449fa34d7	1698	rest.getResponse(s,sizeof(s));
arsenalist	0:f4e449fa34d7	1699	str = s;
arsenalist	0:f4e449fa34d7	1700	//DBG.printf("response:%s\r\n",s);
arsenalist	0:f4e449fa34d7	1701	if(str.find("OK") != std::string::npos) {
arsenalist	0:f4e449fa34d7	1702	wifiConnected = true;
arsenalist	0:f4e449fa34d7	1703	}
arsenalist	0:f4e449fa34d7	1704	} else {
arsenalist	0:f4e449fa34d7	1705	wifiConnected = false;
arsenalist	0:f4e449fa34d7	1706	}
arsenalist	0:f4e449fa34d7	1707	} else {
arsenalist	0:f4e449fa34d7	1708	wifiConnected = false;
arsenalist	0:f4e449fa34d7	1709	}
arsenalist	0:f4e449fa34d7	1710
arsenalist	0:f4e449fa34d7	1711	//eth interface
arsenalist	0:f4e449fa34d7	1712	if(ethAvailable) {
arsenalist	0:f4e449fa34d7	1713	if(useProxy) {
arsenalist	0:f4e449fa34d7	1714	connHost = proxySERVER;
arsenalist	0:f4e449fa34d7	1715	sscanf(proxyPORT.c_str(),"%d",&connPort);
arsenalist	0:f4e449fa34d7	1716	for(int i=0; i<sizeof(s); i++) {
arsenalist	0:f4e449fa34d7	1717	s[i]=0; }
arsenalist	0:f4e449fa34d7	1718	sprintf(s,"GET http://%s:%d/emma/api/web/test HTTP/1.0\nHost: %s\r\n\r\n",EMMA_SERVER_HOST,EMMA_SERVER_PORT,EMMA_SERVER_HOST);
arsenalist	0:f4e449fa34d7	1719	} else {
arsenalist	0:f4e449fa34d7	1720	connHost = EMMA_SERVER_HOST;
arsenalist	0:f4e449fa34d7	1721	connPort = EMMA_SERVER_PORT;
arsenalist	0:f4e449fa34d7	1722	for(int i=0; i<sizeof(s); i++) {
arsenalist	0:f4e449fa34d7	1723	s[i]=0; }
arsenalist	0:f4e449fa34d7	1724	strcpy(s,"GET /emma/api/web/test HTTP/1.0\nHost: %s\r\n\r\n");
arsenalist	0:f4e449fa34d7	1725	}
arsenalist	0:f4e449fa34d7	1726
arsenalist	0:f4e449fa34d7	1727	t.start();
arsenalist	0:f4e449fa34d7	1728	while(1) {
arsenalist	0:f4e449fa34d7	1729	str = ethGET(connHost,connPort,s);
arsenalist	0:f4e449fa34d7	1730	if(str.find("OK") != std::string::npos) {
arsenalist	0:f4e449fa34d7	1731	t.stop();
arsenalist	0:f4e449fa34d7	1732	ethConnected = true;
arsenalist	0:f4e449fa34d7	1733	break;
arsenalist	0:f4e449fa34d7	1734	}
arsenalist	0:f4e449fa34d7	1735	if(t.read_ms() > 5000) {
arsenalist	0:f4e449fa34d7	1736	t.stop();
arsenalist	0:f4e449fa34d7	1737	ethConnected = false;
arsenalist	0:f4e449fa34d7	1738	break;
arsenalist	0:f4e449fa34d7	1739	}
arsenalist	0:f4e449fa34d7	1740	}
arsenalist	0:f4e449fa34d7	1741	} else {
arsenalist	0:f4e449fa34d7	1742	ethConnected = false;
arsenalist	0:f4e449fa34d7	1743	}
arsenalist	0:f4e449fa34d7	1744
arsenalist	0:f4e449fa34d7	1745	//gprs interface
arsenalist	0:f4e449fa34d7	1746	}
arsenalist	8:51a0ca9079ca	1747	*/
arsenalist	8:51a0ca9079ca	1748	void isEthAvailable(void) {
arsenalist	8:51a0ca9079ca	1749	if(ipstack.getEth().linkstatus()) {
arsenalist	8:51a0ca9079ca	1750	ethAvailable = true;
arsenalist	8:51a0ca9079ca	1751	} else {
arsenalist	8:51a0ca9079ca	1752	ethAvailable = false;
arsenalist	8:51a0ca9079ca	1753	}
arsenalist	8:51a0ca9079ca	1754	}
arsenalist	8:51a0ca9079ca	1755
arsenalist	8:51a0ca9079ca	1756	void isEthConnected(void) {
arsenalist	8:51a0ca9079ca	1757	char s[512];
arsenalist	8:51a0ca9079ca	1758	int connPort;
arsenalist	8:51a0ca9079ca	1759	string connHost;
arsenalist	8:51a0ca9079ca	1760	string str;
arsenalist	8:51a0ca9079ca	1761	Timer t;
arsenalist	8:51a0ca9079ca	1762
arsenalist	8:51a0ca9079ca	1763	if(ethAvailable) {
arsenalist	8:51a0ca9079ca	1764	if(useProxy) {
arsenalist	8:51a0ca9079ca	1765	connHost = proxySERVER;
arsenalist	8:51a0ca9079ca	1766	sscanf(proxyPORT.c_str(),"%d",&connPort);
arsenalist	8:51a0ca9079ca	1767	for(int i=0; i<sizeof(s); i++) {
arsenalist	8:51a0ca9079ca	1768	s[i]=0; }
arsenalist	8:51a0ca9079ca	1769	sprintf(s,"GET http://%s:%d/emma/api/controller/test HTTP/1.0\nHost: %s\r\n\r\n",EMMA_SERVER_HOST,EMMA_SERVER_PORT,EMMA_SERVER_HOST);
arsenalist	8:51a0ca9079ca	1770	} else {
arsenalist	8:51a0ca9079ca	1771	connHost = EMMA_SERVER_HOST;
arsenalist	8:51a0ca9079ca	1772	connPort = EMMA_SERVER_PORT;
arsenalist	8:51a0ca9079ca	1773	for(int i=0; i<sizeof(s); i++) {
arsenalist	8:51a0ca9079ca	1774	s[i]=0; }
arsenalist	8:51a0ca9079ca	1775	strcpy(s,"GET /emma/api/controller/test HTTP/1.0\nHost: %s\r\n\r\n");
arsenalist	8:51a0ca9079ca	1776	}
arsenalist	8:51a0ca9079ca	1777
arsenalist	8:51a0ca9079ca	1778	t.start();
arsenalist	8:51a0ca9079ca	1779	while(1) {
arsenalist	8:51a0ca9079ca	1780	str = ethGET(connHost,connPort,s);
arsenalist	8:51a0ca9079ca	1781	if(str.find("OK") != std::string::npos) {
arsenalist	8:51a0ca9079ca	1782	t.stop();
arsenalist	8:51a0ca9079ca	1783	ethConnected = true;
arsenalist	8:51a0ca9079ca	1784	break;
arsenalist	8:51a0ca9079ca	1785	}
arsenalist	8:51a0ca9079ca	1786	if(t.read_ms() > 5000) {
arsenalist	8:51a0ca9079ca	1787	t.stop();
arsenalist	8:51a0ca9079ca	1788	ethConnected = false;
arsenalist	8:51a0ca9079ca	1789	break;
arsenalist	8:51a0ca9079ca	1790	}
arsenalist	8:51a0ca9079ca	1791	}
arsenalist	8:51a0ca9079ca	1792	} else {
arsenalist	8:51a0ca9079ca	1793	ethConnected = false;
arsenalist	8:51a0ca9079ca	1794	}
arsenalist	8:51a0ca9079ca	1795	}
arsenalist	8:51a0ca9079ca	1796
arsenalist	8:51a0ca9079ca	1797	void isWiFiConnected(void) { //WARNING: should be run in emmaModeRegister and emmaModeOperation only - limitation with esp, after MODE=B, cannot go to MODE=S
arsenalist	8:51a0ca9079ca	1798	char s[512];
arsenalist	8:51a0ca9079ca	1799	int connPort;
arsenalist	8:51a0ca9079ca	1800	string connHost;
arsenalist	8:51a0ca9079ca	1801	string str;
arsenalist	8:51a0ca9079ca	1802	Timer t;
arsenalist	8:51a0ca9079ca	1803
arsenalist	8:51a0ca9079ca	1804	if(wifiAvailable) {
arsenalist	8:51a0ca9079ca	1805	_ESP.printf("MODE=B");
arsenalist	8:51a0ca9079ca	1806	if(useProxy) {
arsenalist	8:51a0ca9079ca	1807	connHost = proxySERVER;
arsenalist	8:51a0ca9079ca	1808	sscanf(proxyPORT.c_str(),"%d",&connPort);
arsenalist	8:51a0ca9079ca	1809	for(int i=0; i<sizeof(s); i++) {
arsenalist	8:51a0ca9079ca	1810	s[i]=0; }
arsenalist	8:51a0ca9079ca	1811	sprintf(s,"http://%s:%d/emma/api/controller/test HTTP/1.0\nHost: %s\r\n\r\n",EMMA_SERVER_HOST,EMMA_SERVER_PORT,EMMA_SERVER_HOST);
arsenalist	8:51a0ca9079ca	1812	} else {
arsenalist	8:51a0ca9079ca	1813	connHost = EMMA_SERVER_HOST;
arsenalist	8:51a0ca9079ca	1814	connPort = EMMA_SERVER_PORT;
arsenalist	8:51a0ca9079ca	1815	for(int i=0; i<sizeof(s); i++) {
arsenalist	8:51a0ca9079ca	1816	s[i]=0; }
arsenalist	8:51a0ca9079ca	1817	sprintf(s,"/emma/api/controller/test");
arsenalist	8:51a0ca9079ca	1818	}
arsenalist	8:51a0ca9079ca	1819	wait(1);
arsenalist	8:51a0ca9079ca	1820	t.start();
arsenalist	8:51a0ca9079ca	1821	while(!esp.ready() && t.read_ms() < 5000);
arsenalist	8:51a0ca9079ca	1822	t.stop();
arsenalist	8:51a0ca9079ca	1823	if(rest.begin(connHost.c_str(),connPort,false)) {
arsenalist	8:51a0ca9079ca	1824	//DBG.printf("rest begin\r\n");
arsenalist	8:51a0ca9079ca	1825	esp.process();
arsenalist	8:51a0ca9079ca	1826	rest.get(s);
arsenalist	8:51a0ca9079ca	1827	for(int i=0; i<sizeof(s); i++) {
arsenalist	8:51a0ca9079ca	1828	s[i]=0; }
arsenalist	8:51a0ca9079ca	1829	rest.getResponse(s,sizeof(s));
arsenalist	8:51a0ca9079ca	1830	str = s;
arsenalist	8:51a0ca9079ca	1831	//DBG.printf("response:%s\r\n",s);
arsenalist	8:51a0ca9079ca	1832	if(str.find("OK") != std::string::npos) {
arsenalist	8:51a0ca9079ca	1833	wifiConnected = true;
arsenalist	8:51a0ca9079ca	1834	}
arsenalist	8:51a0ca9079ca	1835	} else {
arsenalist	8:51a0ca9079ca	1836	wifiConnected = false;
arsenalist	8:51a0ca9079ca	1837	}
arsenalist	8:51a0ca9079ca	1838	} else {
arsenalist	8:51a0ca9079ca	1839	wifiConnected = false;
arsenalist	8:51a0ca9079ca	1840	}
arsenalist	8:51a0ca9079ca	1841	}
arsenalist	8:51a0ca9079ca	1842
arsenalist	8:51a0ca9079ca	1843	void isGprsConnected(void) {
arsenalist	8:51a0ca9079ca	1844
arsenalist	8:51a0ca9079ca	1845	}
arsenalist	0:f4e449fa34d7	1846
arsenalist	0:f4e449fa34d7	1847	void addChar(char *s, char c) {
arsenalist	0:f4e449fa34d7	1848	uint16_t k; //customized for EMS
arsenalist	0:f4e449fa34d7	1849	k = strlen(s);
arsenalist	0:f4e449fa34d7	1850	s[k] = c;
arsenalist	0:f4e449fa34d7	1851	s[k + 1] = 0;
arsenalist	0:f4e449fa34d7	1852	}
arsenalist	0:f4e449fa34d7	1853
arsenalist	0:f4e449fa34d7	1854	void rcvReply(char *r, int to) {
arsenalist	0:f4e449fa34d7	1855	Timer t;
arsenalist	0:f4e449fa34d7	1856	bool ended = false;
arsenalist	0:f4e449fa34d7	1857	char c;
arsenalist	0:f4e449fa34d7	1858
arsenalist	0:f4e449fa34d7	1859	strcpy(r,"");
arsenalist	0:f4e449fa34d7	1860	t.start();
arsenalist	0:f4e449fa34d7	1861	while(!ended) {
arsenalist	0:f4e449fa34d7	1862	if(_ESP.readable()) {
arsenalist	0:f4e449fa34d7	1863	c = _ESP.getc();
arsenalist	0:f4e449fa34d7	1864	addChar(r,c);
arsenalist	0:f4e449fa34d7	1865	t.start();
arsenalist	0:f4e449fa34d7	1866	}
arsenalist	0:f4e449fa34d7	1867	if(t.read_ms() > to) {
arsenalist	0:f4e449fa34d7	1868	ended = true;
arsenalist	0:f4e449fa34d7	1869	}
arsenalist	0:f4e449fa34d7	1870	}
arsenalist	0:f4e449fa34d7	1871	addChar(r, 0x00);
arsenalist	0:f4e449fa34d7	1872	}
arsenalist	0:f4e449fa34d7	1873
arsenalist	0:f4e449fa34d7	1874	string calculateMD5(string text) {
arsenalist	0:f4e449fa34d7	1875	char s[64];
arsenalist	0:f4e449fa34d7	1876	memset(s,0,sizeof(s)); //for unknown reason, after reading UID, the 's' will contaion UID data
arsenalist	0:f4e449fa34d7	1877	uint8_t hash[16];
arsenalist	0:f4e449fa34d7	1878	MD5::computeHash(hash, (uint8_t*)text.c_str(), strlen(text.c_str()));
arsenalist	0:f4e449fa34d7	1879	for(int i=0; i<16; ++i) {
arsenalist	0:f4e449fa34d7	1880	sprintf(s,"%s%02x",s,hash[i]);
arsenalist	0:f4e449fa34d7	1881	}
arsenalist	0:f4e449fa34d7	1882	return s;
arsenalist	0:f4e449fa34d7	1883	}
arsenalist	0:f4e449fa34d7	1884
arsenalist	0:f4e449fa34d7	1885	bool writeFirmwareHexToChar(string value) {
arsenalist	0:f4e449fa34d7	1886	FILE *fp;
arsenalist	0:f4e449fa34d7	1887	char s[32];
arsenalist	0:f4e449fa34d7	1888	int number;
arsenalist	0:f4e449fa34d7	1889	string chunk;
arsenalist	0:f4e449fa34d7	1890
arsenalist	0:f4e449fa34d7	1891	sprintf(s,"/sd/newFirmware/firmware.bin");
arsenalist	0:f4e449fa34d7	1892	fp = fopen(s,"a");
arsenalist	0:f4e449fa34d7	1893	if(fp != NULL) {
arsenalist	0:f4e449fa34d7	1894	for(int ch=0; ch<value.size(); ch+=2) {
arsenalist	0:f4e449fa34d7	1895	chunk = value.substr(ch,2);
arsenalist	0:f4e449fa34d7	1896	sscanf(chunk.c_str(),"%x",&number);
arsenalist	0:f4e449fa34d7	1897	fprintf(fp,"%c",number);
arsenalist	0:f4e449fa34d7	1898	}
arsenalist	0:f4e449fa34d7	1899	fclose(fp);
arsenalist	0:f4e449fa34d7	1900	return true;
arsenalist	0:f4e449fa34d7	1901	}
arsenalist	0:f4e449fa34d7	1902	return false;
arsenalist	0:f4e449fa34d7	1903	}
arsenalist	0:f4e449fa34d7	1904
arsenalist	0:f4e449fa34d7	1905	bool clearFirmware(void) {
arsenalist	0:f4e449fa34d7	1906	FILE *fp;
arsenalist	0:f4e449fa34d7	1907	char s[32];
arsenalist	0:f4e449fa34d7	1908
arsenalist	0:f4e449fa34d7	1909	sprintf(s,"/sd/newFirmware/firmware.bin");
arsenalist	0:f4e449fa34d7	1910	fp = fopen(s,"w");
arsenalist	0:f4e449fa34d7	1911	if(fp != NULL) {
arsenalist	0:f4e449fa34d7	1912	fprintf(fp,"");
arsenalist	0:f4e449fa34d7	1913	fclose(fp);
arsenalist	0:f4e449fa34d7	1914	return true;
arsenalist	0:f4e449fa34d7	1915	}
arsenalist	0:f4e449fa34d7	1916	return false;
arsenalist	0:f4e449fa34d7	1917	}
arsenalist	0:f4e449fa34d7	1918	/end emma private function/

Repository toolbox

Export to desktop IDE

Build repository

Repository details

Type:	Program
Created:	07 Aug 2015
Imports:	2
Forks:	0
Commits:	30
Dependents:	0
Dependencies:	15
Followers:	1

emmaCode.cpp@10:1dc69e0ce7fd, 2015-07-13 (annotated)

Who changed what in which revision?

Repository toolbox

Repository details

Important Information for this Arm website

Access Warning