PB_emma_controller_mbed_src - emma controller code in production board v1

Emma » Code » PB_emma_controller_mbed_src

emma controller code in production board v1

Dependencies: ADE7758_v1 Crypto DHT11 MQTT MbedJSONValueEmma SDFileSystem TFT_ILI9341 SWSPI SetRTC TFT_fonts Touch W5500Interface mbed-rtos mbed-src SoftSerial

Fork of emma_controller_energy by Emma

emmaCode.cpp@11:2311b2d5157d, 2015-07-13 (annotated)

Committer:: arsenalist
Date:: Mon Jul 13 13:29:25 2015 +0000
Revision:: 11:2311b2d5157d
Parent:: 10:1dc69e0ce7fd
Child:: 12:96f637ed37f9

Calibrate Vrms.

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	11:2311b2d5157d	160	int st = writeSetting(parameter[i],val.c_str());
arsenalist	11:2311b2d5157d	161	if(st) {
arsenalist	11:2311b2d5157d	162	DBG.printf("%s is saved\r\n",parameter[i]);
arsenalist	11:2311b2d5157d	163	} else {
arsenalist	11:2311b2d5157d	164	DBG.printf("%s is not saved\r\n",parameter[i]);
arsenalist	11:2311b2d5157d	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	0:f4e449fa34d7	738	mqtt.connectedCb.attach(&mqttConnected);
arsenalist	0:f4e449fa34d7	739	mqtt.disconnectedCb.attach(&mqttDisconnected);
arsenalist	0:f4e449fa34d7	740	mqtt.connect(MQTT_HOST,MQTT_PORT,false);
arsenalist	0:f4e449fa34d7	741	DBG.printf("emma: success to setup mqtt\r\n");
arsenalist	0:f4e449fa34d7	742	}
arsenalist	0:f4e449fa34d7	743	DBG.printf("emma: system started\r\n");
arsenalist	0:f4e449fa34d7	744
arsenalist	4:76ab12e2f8a3	745	t.start();
arsenalist	4:76ab12e2f8a3	746	while(t.read_ms() < 5000) {
arsenalist	4:76ab12e2f8a3	747	esp.process();
arsenalist	4:76ab12e2f8a3	748	}
arsenalist	4:76ab12e2f8a3	749	t.stop();
arsenalist	4:76ab12e2f8a3	750	t.reset();
arsenalist	0:f4e449fa34d7	751
arsenalist	0:f4e449fa34d7	752	//set ade7758 parameter
arsenalist	0:f4e449fa34d7	753	ADE.begin();
arsenalist	0:f4e449fa34d7	754	ADE.AVRMSCalib = 1526873.00;
arsenalist	0:f4e449fa34d7	755	ADE.BVRMSCalib = 534202.00;
arsenalist	0:f4e449fa34d7	756	ADE.CVRMSCalib = 456990.00;
arsenalist	0:f4e449fa34d7	757	ADE.AIRMSCalib = 39248.00;
arsenalist	0:f4e449fa34d7	758	ADE.BIRMSCalib = 654.00;
arsenalist	0:f4e449fa34d7	759	ADE.CIRMSCalib = 111.00;
arsenalist	0:f4e449fa34d7	760
arsenalist	0:f4e449fa34d7	761	ADE.writeRMSOffset(AIRMSOFFSET, BIRMSOFFSET, CIRMSOFFSET, AVRMSOFFSET, BVRMSOFFSET, CVRMSOFFSET);
arsenalist	0:f4e449fa34d7	762
arsenalist	0:f4e449fa34d7	763	ADE.write16bits(AWG, 0);
arsenalist	0:f4e449fa34d7	764	ADE.write16bits(BWG, 0);
arsenalist	0:f4e449fa34d7	765	ADE.write16bits(CWG, 0);
arsenalist	0:f4e449fa34d7	766	ADE.write16bits(AVAG, 0);
arsenalist	0:f4e449fa34d7	767	ADE.write16bits(BVAG, 0);
arsenalist	0:f4e449fa34d7	768	ADE.write16bits(CVAG, 0);
arsenalist	0:f4e449fa34d7	769
arsenalist	4:76ab12e2f8a3	770	ADE.AWhLSB = 0.00006025556;
arsenalist	0:f4e449fa34d7	771	ADE.BWhLSB = 0.25075167;
arsenalist	0:f4e449fa34d7	772	ADE.CWhLSB = 0.25075167;
arsenalist	0:f4e449fa34d7	773
arsenalist	0:f4e449fa34d7	774	ADE.AVAhLSB = 0.00008370;
arsenalist	0:f4e449fa34d7	775	ADE.BVAhLSB = 0;
arsenalist	0:f4e449fa34d7	776	ADE.CVAhLSB = 0;
arsenalist	0:f4e449fa34d7	777
arsenalist	4:76ab12e2f8a3	778	//init rest to server
arsenalist	7:7e8c6ad3fd64	779	if(rest.begin(EMMA_SERVER_HOST,EMMA_SERVER_PORT,false)) {
arsenalist	4:76ab12e2f8a3	780	DBG.printf("rest to server is created\r\n");
arsenalist	4:76ab12e2f8a3	781	} else {
arsenalist	4:76ab12e2f8a3	782	DBG.printf("rest to server is NOT created\r\n");
arsenalist	4:76ab12e2f8a3	783	}
arsenalist	4:76ab12e2f8a3	784
arsenalist	7:7e8c6ad3fd64	785	//check firmware update
arsenalist	7:7e8c6ad3fd64	786
arsenalist	7:7e8c6ad3fd64	787	//execute last state of switches on board
arsenalist	7:7e8c6ad3fd64	788
arsenalist	7:7e8c6ad3fd64	789	//get list of nodes from server
arsenalist	7:7e8c6ad3fd64	790	sprintf(s,"/emma/api/controller/remotes?uid=%s&hmac=%s",emmaUID.c_str(),hmac.c_str());
arsenalist	7:7e8c6ad3fd64	791	rest.get(s);
arsenalist	7:7e8c6ad3fd64	792	for(int i=0; i<sizeof(s); i++) {
arsenalist	7:7e8c6ad3fd64	793	s[i]=0; }
arsenalist	7:7e8c6ad3fd64	794	rest.getResponse(s,sizeof(s));
arsenalist	7:7e8c6ad3fd64	795	str = s;
arsenalist	7:7e8c6ad3fd64	796	if(str.rfind("[{\"mac\"") != std::string::npos) {
arsenalist	7:7e8c6ad3fd64	797	DBG.printf("get nodes from server\r\n");
arsenalist	7:7e8c6ad3fd64	798	str.erase(str.begin(),str.begin()+str.rfind("[{\"mac\""));
arsenalist	7:7e8c6ad3fd64	799	str.erase(str.begin()+str.rfind("}]")+2,str.end());
arsenalist	7:7e8c6ad3fd64	800
arsenalist	7:7e8c6ad3fd64	801	MbedJSONValue jsonValue;
arsenalist	7:7e8c6ad3fd64	802	parse(jsonValue,str.c_str());
arsenalist	7:7e8c6ad3fd64	803	char *parameter[2] = {"mac","ip"};
arsenalist	7:7e8c6ad3fd64	804
arsenalist	7:7e8c6ad3fd64	805	//check whether nodes valid
arsenalist	7:7e8c6ad3fd64	806	bool validNodes = true;
arsenalist	7:7e8c6ad3fd64	807	for(int i=0; i<jsonValue.size(); i++) {
arsenalist	7:7e8c6ad3fd64	808	for(int j=0; j<2; j++) {
arsenalist	7:7e8c6ad3fd64	809	validNodes = validNodes && jsonValue[i].hasMember(parameter[j]);
arsenalist	7:7e8c6ad3fd64	810	}
arsenalist	7:7e8c6ad3fd64	811	}
arsenalist	7:7e8c6ad3fd64	812	DBG.printf("nodes validity:%d\r\n",validNodes);
arsenalist	7:7e8c6ad3fd64	813
arsenalist	7:7e8c6ad3fd64	814	if(validNodes) {
arsenalist	7:7e8c6ad3fd64	815	for(int i=0; i<jsonValue.size(); i++) {
arsenalist	7:7e8c6ad3fd64	816	string macValue = jsonValue[i][parameter[0]].get<std::string>();
arsenalist	7:7e8c6ad3fd64	817	string ipValue = jsonValue[i][parameter[1]].get<std::string>();
arsenalist	7:7e8c6ad3fd64	818	nodes[i].macAddr = macValue;
arsenalist	7:7e8c6ad3fd64	819	nodes[i].ipAddr = ipValue;
arsenalist	7:7e8c6ad3fd64	820	DBG.printf("nodes[%d]-mac:%s\r\n",i,nodes[i].macAddr.c_str());
arsenalist	7:7e8c6ad3fd64	821	DBG.printf("nodes[%d]-ip:%s\r\n",i,nodes[i].ipAddr.c_str());
arsenalist	7:7e8c6ad3fd64	822	}
arsenalist	7:7e8c6ad3fd64	823	}
arsenalist	7:7e8c6ad3fd64	824
arsenalist	7:7e8c6ad3fd64	825	} else {
arsenalist	7:7e8c6ad3fd64	826	DBG.printf("no nodes from server\r\n");
arsenalist	7:7e8c6ad3fd64	827	}
arsenalist	7:7e8c6ad3fd64	828
arsenalist	7:7e8c6ad3fd64	829
arsenalist	4:76ab12e2f8a3	830	//preset nodes' macAddr and ipAddr
arsenalist	7:7e8c6ad3fd64	831	//nodes[0].macAddr = "002629034222";
arsenalist	7:7e8c6ad3fd64	832	//nodes[0].ipAddr = "192.168.2.15";
arsenalist	7:7e8c6ad3fd64	833	//nodes[1].macAddr = "00262903424e";
arsenalist	7:7e8c6ad3fd64	834	//nodes[1].ipAddr = "192.168.2.32";
arsenalist	4:76ab12e2f8a3	835
arsenalist	4:76ab12e2f8a3	836	//init rest to remotes
arsenalist	4:76ab12e2f8a3	837	for(int i=0; i<NODES_MAX; i++) {
arsenalist	4:76ab12e2f8a3	838	if(!nodes[i].ipAddr.empty()) {
arsenalist	4:76ab12e2f8a3	839	DBG.printf("restConn nodes[%d] is created\r\n",i);
arsenalist	4:76ab12e2f8a3	840	nodes[i].restConn->begin(nodes[i].ipAddr.c_str(),16038,false);
arsenalist	4:76ab12e2f8a3	841	wait(1);
arsenalist	4:76ab12e2f8a3	842	} else {
arsenalist	4:76ab12e2f8a3	843	DBG.printf("restConn nodes[%d] is NOT created\r\n",i);
arsenalist	4:76ab12e2f8a3	844	wait(1);
arsenalist	4:76ab12e2f8a3	845	}
arsenalist	4:76ab12e2f8a3	846	}
arsenalist	4:76ab12e2f8a3	847
arsenalist	4:76ab12e2f8a3	848	_ESP.attach(&rxInterrupt,Serial::RxIrq);
arsenalist	4:76ab12e2f8a3	849
arsenalist	4:76ab12e2f8a3	850	//define thread
arsenalist	4:76ab12e2f8a3	851	osThreadDef(energyThread, osPriorityBelowNormal, (4*DEFAULT_STACK_SIZE));
arsenalist	0:f4e449fa34d7	852	//create thread
arsenalist	2:fdfdeb5fd6fd	853	osThreadCreate(osThread(energyThread),NULL);
arsenalist	0:f4e449fa34d7	854
arsenalist	0:f4e449fa34d7	855	t.start();
arsenalist	4:76ab12e2f8a3	856	tNodes.start();
arsenalist	4:76ab12e2f8a3	857	wait(1);
arsenalist	0:f4e449fa34d7	858	while(1) {
arsenalist	4:76ab12e2f8a3	859	checkRxBuffer();
arsenalist	4:76ab12e2f8a3	860	checkVoltagePower();
arsenalist	4:76ab12e2f8a3	861	//panelEnergy, panelVoltage, and panelPower
arsenalist	4:76ab12e2f8a3	862	if(t.read_ms() > 10000) {
arsenalist	4:76ab12e2f8a3	863	DBG.printf("[%d]WattHR for each phase: %.2f, %.2f, %.2f\r\n", loop, AWattHr, BWattHr, CWattHr);
arsenalist	4:76ab12e2f8a3	864	DBG.printf("VRMS for each phase: %.2f, %.2f, %.2f\r\n", AVrms, BVrms, CVrms);
arsenalist	4:76ab12e2f8a3	865	DBG.printf("Watt for each phase: %.2f, %.2f, %.2f\r\n", AWatt, BWatt, CWatt);
arsenalist	4:76ab12e2f8a3	866
arsenalist	4:76ab12e2f8a3	867	//for(int i=1; i<4; i++) {
arsenalist	4:76ab12e2f8a3	868	for(int i=1; i<2; i++) {
arsenalist	4:76ab12e2f8a3	869	DBG.printf("sending channel: %d\r\n",i);
arsenalist	4:76ab12e2f8a3	870	if(i==1){
arsenalist	4:76ab12e2f8a3	871	XWattHr = AWattHr;
arsenalist	4:76ab12e2f8a3	872	XVrms = AVrms;
arsenalist	4:76ab12e2f8a3	873	XWatt = AWatt;
arsenalist	4:76ab12e2f8a3	874	} else if(i==2) {
arsenalist	4:76ab12e2f8a3	875	XWattHr = BWattHr;
arsenalist	4:76ab12e2f8a3	876	XVrms = BVrms;
arsenalist	4:76ab12e2f8a3	877	XWatt = BWatt;
arsenalist	4:76ab12e2f8a3	878	} else {
arsenalist	4:76ab12e2f8a3	879	XWattHr = CWattHr;
arsenalist	4:76ab12e2f8a3	880	XVrms = CVrms;
arsenalist	4:76ab12e2f8a3	881	XWatt = CWatt;
arsenalist	4:76ab12e2f8a3	882	}
arsenalist	4:76ab12e2f8a3	883	sprintf(r,"/emma/api/controller/energy/%d",i);
arsenalist	4:76ab12e2f8a3	884	sprintf(s,"{\"uid\":\"%s\",\"hmac\":\"%s\",\"time\":\"2015-06-09 12:32:12\",\"energy\":%.2f,\"voltage\":%.2f,\"power\":%.2f}",
arsenalist	4:76ab12e2f8a3	885	emmaUID.c_str(),hmac.c_str(),XWattHr,XVrms,XWatt);
arsenalist	4:76ab12e2f8a3	886	rest.post(r,s);
arsenalist	4:76ab12e2f8a3	887	wait(2);
arsenalist	4:76ab12e2f8a3	888	if(rxBuf.find("\"status\":\"success\"") != std::string::npos) {
arsenalist	4:76ab12e2f8a3	889	DBG.printf("send channel: %d success\r\n",i);
arsenalist	4:76ab12e2f8a3	890	} else {
arsenalist	4:76ab12e2f8a3	891	DBG.printf("send channel: %d failed\r\n",i);
arsenalist	4:76ab12e2f8a3	892	}
arsenalist	0:f4e449fa34d7	893	}
arsenalist	4:76ab12e2f8a3	894	t.reset();
arsenalist	4:76ab12e2f8a3	895	loop++;
arsenalist	0:f4e449fa34d7	896	}
arsenalist	0:f4e449fa34d7	897
arsenalist	5:d00233dd36f5	898	checkRxBuffer();
arsenalist	5:d00233dd36f5	899	checkVoltagePower();
arsenalist	0:f4e449fa34d7	900	//nodeTemp
arsenalist	5:d00233dd36f5	901	if(tNodes.read_ms() > 30000) {
arsenalist	5:d00233dd36f5	902	DBG.printf("getNodesTemperature\r\n");
arsenalist	5:d00233dd36f5	903
arsenalist	5:d00233dd36f5	904	for(int i=0; i<NODES_MAX; i++) {
arsenalist	5:d00233dd36f5	905	if(!nodes[i].ipAddr.empty()) {
arsenalist	5:d00233dd36f5	906	//get node's temp
arsenalist	5:d00233dd36f5	907	string temp;
arsenalist	5:d00233dd36f5	908	nodes[i].restConn->get("/","<?xml version=\"1.0\" encoding=\"utf-8\"?><app_cmd cmd=\"2\"/>\r\n");
arsenalist	5:d00233dd36f5	909	wait(2);
arsenalist	5:d00233dd36f5	910	temp = rxBuf;
arsenalist	5:d00233dd36f5	911	if(temp.rfind(nodes[i].ipAddr) != std::string::npos) {
arsenalist	5:d00233dd36f5	912	temp.erase(temp.begin(),temp.begin()+temp.rfind(nodes[i].ipAddr));
arsenalist	5:d00233dd36f5	913	if(temp.rfind("temp=") != std::string::npos) {
arsenalist	5:d00233dd36f5	914	temp.erase(temp.begin(),temp.begin()+temp.rfind("temp=")+6);
arsenalist	5:d00233dd36f5	915	temp.erase(temp.begin()+temp.find("\""),temp.end());
arsenalist	5:d00233dd36f5	916	} else {
arsenalist	5:d00233dd36f5	917	temp = "0"; //connect to node, but receive none
arsenalist	5:d00233dd36f5	918	}
arsenalist	5:d00233dd36f5	919	} else {
arsenalist	5:d00233dd36f5	920	temp = "0"; //not connected to node
arsenalist	5:d00233dd36f5	921	}
arsenalist	0:f4e449fa34d7	922
arsenalist	5:d00233dd36f5	923	DBG.printf("nodeTemp[%d]:%s\r\n",i,temp.c_str());
arsenalist	5:d00233dd36f5	924
arsenalist	5:d00233dd36f5	925	//send node's temp
arsenalist	0:f4e449fa34d7	926	sprintf(s,"{\"uid\":\"%s\",\"hmac\":\"%s\",\"time\":\"2015-06-09 12:32:12\",\"mac\":\"%s\",\"value\":%s}",
arsenalist	5:d00233dd36f5	927	emmaUID.c_str(),hmac.c_str(),nodes[i].macAddr.c_str(),temp.c_str());
arsenalist	0:f4e449fa34d7	928	rest.post("/emma/api/controller/nodetemp",s);
arsenalist	5:d00233dd36f5	929	wait(2);
arsenalist	5:d00233dd36f5	930	temp = rxBuf;
arsenalist	5:d00233dd36f5	931	if(temp.rfind("/nodetemp") != std::string::npos) {
arsenalist	5:d00233dd36f5	932	temp.erase(temp.begin(),temp.begin()+temp.rfind("/nodetemp"));
arsenalist	5:d00233dd36f5	933	if(temp.find("\"status\":\"success\"") != std::string::npos) {
arsenalist	5:d00233dd36f5	934	DBG.printf("send nodeTemp success\r\n");
arsenalist	5:d00233dd36f5	935	} else {
arsenalist	5:d00233dd36f5	936	DBG.printf("send nodeTemp failed\r\n");
arsenalist	5:d00233dd36f5	937	}
arsenalist	5:d00233dd36f5	938	}
arsenalist	6:45f50f1177db	939	checkRxBuffer();
arsenalist	6:45f50f1177db	940	checkVoltagePower();
arsenalist	5:d00233dd36f5	941	}
arsenalist	0:f4e449fa34d7	942	}
arsenalist	5:d00233dd36f5	943	}
arsenalist	5:d00233dd36f5	944	checkRxBuffer();
arsenalist	5:d00233dd36f5	945	checkVoltagePower();
arsenalist	5:d00233dd36f5	946	//command
arsenalist	0:f4e449fa34d7	947	if(newCommand) {
arsenalist	5:d00233dd36f5	948	DBG.printf("newCommand:\r\n%s\r\n",globalCommand.c_str());
arsenalist	0:f4e449fa34d7	949	MbedJSONValue jsonValue;
arsenalist	0:f4e449fa34d7	950	parse(jsonValue,globalCommand.c_str());
arsenalist	0:f4e449fa34d7	951	char *parameter[5] = {"id","nType","nAddr","dType","cmd"};
arsenalist	0:f4e449fa34d7	952
arsenalist	7:7e8c6ad3fd64	953	//check whether command is valid
arsenalist	0:f4e449fa34d7	954	bool validCommand = true;
arsenalist	0:f4e449fa34d7	955	for(int i=0; i<5; i++) {
arsenalist	0:f4e449fa34d7	956	validCommand = validCommand && jsonValue.hasMember(parameter[i]);
arsenalist	0:f4e449fa34d7	957	}
arsenalist	0:f4e449fa34d7	958	DBG.printf("command validity:%d\r\n",validCommand);
arsenalist	0:f4e449fa34d7	959
arsenalist	0:f4e449fa34d7	960	if(validCommand) {
arsenalist	0:f4e449fa34d7	961	string commandId = jsonValue[parameter[0]].get<std::string>();
arsenalist	0:f4e449fa34d7	962	string commandNType = jsonValue[parameter[1]].get<std::string>();
arsenalist	0:f4e449fa34d7	963	string commandNAddr = jsonValue[parameter[2]].get<std::string>();
arsenalist	0:f4e449fa34d7	964	string commandDType = jsonValue[parameter[3]].get<std::string>();
arsenalist	0:f4e449fa34d7	965	string commandCmd = jsonValue[parameter[4]].get<std::string>();
arsenalist	0:f4e449fa34d7	966
arsenalist	0:f4e449fa34d7	967	if(commandNType == "0") { //switch on panel controller
arsenalist	0:f4e449fa34d7	968	DBG.printf("command for switch\r\n");
arsenalist	0:f4e449fa34d7	969	}
arsenalist	0:f4e449fa34d7	970	else if(commandNType == "1") { //node with mac address
arsenalist	0:f4e449fa34d7	971	DBG.printf("command for node\r\n");
arsenalist	0:f4e449fa34d7	972	//get node ip address based on node mac address
arsenalist	5:d00233dd36f5	973	//string nodeIP;
arsenalist	1:d314a43ae6f7	974	//nodeIp = readNodeIP(commandNAddr);
arsenalist	5:d00233dd36f5	975	//nodeIP = "192.168.2.15";
arsenalist	0:f4e449fa34d7	976	//DBG.printf("nodeIP: %s\r\n",nodeIP.c_str());
arsenalist	5:d00233dd36f5	977
arsenalist	5:d00233dd36f5	978	//get index of node list based on mac address
arsenalist	5:d00233dd36f5	979	int idx = NODES_INVALID;
arsenalist	5:d00233dd36f5	980	for(int i=0; i<NODES_MAX; i++) {
arsenalist	5:d00233dd36f5	981	if(!nodes[i].macAddr.compare(commandNAddr)) {
arsenalist	5:d00233dd36f5	982	idx = i;
arsenalist	5:d00233dd36f5	983	}
arsenalist	5:d00233dd36f5	984	}
arsenalist	5:d00233dd36f5	985
arsenalist	5:d00233dd36f5	986	//execution process
arsenalist	5:d00233dd36f5	987	int trial;
arsenalist	5:d00233dd36f5	988	string execResult = "notExecuted";
arsenalist	5:d00233dd36f5	989	if(idx != NODES_INVALID) {
arsenalist	5:d00233dd36f5	990	DBG.printf("index found at %d\r\n",idx);
arsenalist	0:f4e449fa34d7	991
arsenalist	5:d00233dd36f5	992	//get cmd string based on device type and command number
arsenalist	5:d00233dd36f5	993	string nodeCmd;
arsenalist	5:d00233dd36f5	994	//nodeCmd = readNodeCmd(commandDType,commandCmd);
arsenalist	5:d00233dd36f5	995	nodeCmd = "020129A0163B161315131613153C151316131514143C153C16141414141415151315141414141514141415141414143D1514143D141415141414143D14000D"; //turn off
arsenalist	5:d00233dd36f5	996	//DBG.printf("nodeCmd: %s\r\n",nodeCmd.c_str());
arsenalist	0:f4e449fa34d7	997
arsenalist	5:d00233dd36f5	998	//execute command
arsenalist	5:d00233dd36f5	999	DBG.printf("executing command\r\n");
arsenalist	0:f4e449fa34d7	1000	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	1001
arsenalist	5:d00233dd36f5	1002	trial=0;
arsenalist	0:f4e449fa34d7	1003	while(1) {
arsenalist	5:d00233dd36f5	1004	//cmdExecuted = false;
arsenalist	5:d00233dd36f5	1005	if(trial>=2) { //two times trial
arsenalist	0:f4e449fa34d7	1006	DBG.printf("cmd is not executed\r\n");
arsenalist	0:f4e449fa34d7	1007	break;
arsenalist	0:f4e449fa34d7	1008	}
arsenalist	5:d00233dd36f5	1009	nodes[idx].restConn->get("/",s);
arsenalist	5:d00233dd36f5	1010	wait(2);
arsenalist	5:d00233dd36f5	1011	if(rxBuf.find("REST: Sent") != std::string::npos) {
arsenalist	5:d00233dd36f5	1012	DBG.printf("cmd executed\r\n");
arsenalist	5:d00233dd36f5	1013	execResult = "executed";
arsenalist	5:d00233dd36f5	1014	break;
arsenalist	5:d00233dd36f5	1015	}
arsenalist	0:f4e449fa34d7	1016	trial++;
arsenalist	5:d00233dd36f5	1017	}
arsenalist	5:d00233dd36f5	1018	}
arsenalist	5:d00233dd36f5	1019
arsenalist	5:d00233dd36f5	1020	wait(2);
arsenalist	5:d00233dd36f5	1021	//send execution result
arsenalist	5:d00233dd36f5	1022	DBG.printf("send execution result\r\n");
arsenalist	5:d00233dd36f5	1023	sprintf(s,"{\"id\":\"%s\",\"nType\":\"%s\",\"nAddr\":\"%s\",\"dType\":\"%s\",\"cmd\":\"%s\",\"result\":\"%s\"}",
arsenalist	5:d00233dd36f5	1024	commandId.c_str(),commandNType.c_str(),commandNAddr.c_str(),commandDType.c_str(),commandCmd.c_str(),execResult.c_str());
arsenalist	5:d00233dd36f5	1025
arsenalist	5:d00233dd36f5	1026	trial=0;
arsenalist	5:d00233dd36f5	1027	while(1) {
arsenalist	5:d00233dd36f5	1028	if(trial>=2) { //two times trial
arsenalist	5:d00233dd36f5	1029	DBG.printf("send execution result failed\r\n");
arsenalist	5:d00233dd36f5	1030	break;
arsenalist	0:f4e449fa34d7	1031	}
arsenalist	5:d00233dd36f5	1032	rest.post("/emma/api/controller/test",s);
arsenalist	5:d00233dd36f5	1033	wait(2);
arsenalist	5:d00233dd36f5	1034	if(rxBuf.find("\"status\":\"OK\"") != std::string::npos) {
arsenalist	5:d00233dd36f5	1035	DBG.printf("send execution result success\r\n");
arsenalist	5:d00233dd36f5	1036	break;
arsenalist	0:f4e449fa34d7	1037	}
arsenalist	5:d00233dd36f5	1038	trial++;
arsenalist	0:f4e449fa34d7	1039	}
arsenalist	0:f4e449fa34d7	1040	}
arsenalist	0:f4e449fa34d7	1041	}
arsenalist	0:f4e449fa34d7	1042	newCommand = false;
arsenalist	2:fdfdeb5fd6fd	1043	}
arsenalist	4:76ab12e2f8a3	1044	osDelay(5000);
arsenalist	0:f4e449fa34d7	1045	}
arsenalist	0:f4e449fa34d7	1046	}
arsenalist	0:f4e449fa34d7	1047	}
arsenalist	0:f4e449fa34d7	1048	void emmaModeFirmwareDownload(void) {
arsenalist	0:f4e449fa34d7	1049	bool emmaGetFirmwareParam = false;
arsenalist	0:f4e449fa34d7	1050
arsenalist	0:f4e449fa34d7	1051	DBG.printf("emmaModeFirmwareDownload\r\n");
arsenalist	0:f4e449fa34d7	1052
arsenalist	0:f4e449fa34d7	1053	char s[384];
arsenalist	0:f4e449fa34d7	1054	string str;
arsenalist	0:f4e449fa34d7	1055	string connData;
arsenalist	0:f4e449fa34d7	1056	string chunk;
arsenalist	0:f4e449fa34d7	1057
arsenalist	0:f4e449fa34d7	1058	//firmware parameter
arsenalist	0:f4e449fa34d7	1059	string firmwareVer;
arsenalist	0:f4e449fa34d7	1060	string firmwareName;
arsenalist	0:f4e449fa34d7	1061	int numPart;
arsenalist	0:f4e449fa34d7	1062
arsenalist	0:f4e449fa34d7	1063	//downloading
arsenalist	0:f4e449fa34d7	1064	string firmwarePart;
arsenalist	0:f4e449fa34d7	1065	string calcMD5;
arsenalist	0:f4e449fa34d7	1066	string srvrMD5;
arsenalist	0:f4e449fa34d7	1067	bool nextPart;
arsenalist	0:f4e449fa34d7	1068
arsenalist	0:f4e449fa34d7	1069	//set wifi to mode bridge
arsenalist	0:f4e449fa34d7	1070	_ESP.printf("MODE=B");
arsenalist	0:f4e449fa34d7	1071	DBG.printf("set mode bridge\r\n");
arsenalist	0:f4e449fa34d7	1072	while(1) {
arsenalist	0:f4e449fa34d7	1073	char rcv[128] = {};
arsenalist	0:f4e449fa34d7	1074	rcvReply(rcv,3000);
arsenalist	0:f4e449fa34d7	1075	str = rcv;
arsenalist	0:f4e449fa34d7	1076	if(str.find("MODE=B_OK") != std::string::npos)
arsenalist	0:f4e449fa34d7	1077	break;
arsenalist	0:f4e449fa34d7	1078	}
arsenalist	0:f4e449fa34d7	1079	DBG.printf("MODE=B\r\n");
arsenalist	0:f4e449fa34d7	1080
arsenalist	0:f4e449fa34d7	1081	esp.enable();
arsenalist	0:f4e449fa34d7	1082	wait(1);
arsenalist	0:f4e449fa34d7	1083	while(!esp.ready());
arsenalist	0:f4e449fa34d7	1084
arsenalist	0:f4e449fa34d7	1085	if(!rest.begin("candra.tritronik.com",3128,false)) {
arsenalist	0:f4e449fa34d7	1086	DBG.printf("EMMA: fail to setup rest");
arsenalist	0:f4e449fa34d7	1087	while(1);
arsenalist	0:f4e449fa34d7	1088	}
arsenalist	0:f4e449fa34d7	1089
arsenalist	0:f4e449fa34d7	1090	//wifiConnected = true; //with custom firmware, panel should connect wifi automatically
arsenalist	0:f4e449fa34d7	1091	useProxy = true;
arsenalist	0:f4e449fa34d7	1092
arsenalist	0:f4e449fa34d7	1093	esp.process();
arsenalist	0:f4e449fa34d7	1094	//set connData
arsenalist	0:f4e449fa34d7	1095	if(useProxy) {
arsenalist	0:f4e449fa34d7	1096	for(int i=0; i<sizeof(s); i++) {
arsenalist	0:f4e449fa34d7	1097	s[i]=0; }
arsenalist	0:f4e449fa34d7	1098	//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	1099	sprintf(s,"http://192.168.128.69/emmaController/firmware/firmwareParameter");
arsenalist	0:f4e449fa34d7	1100	connData = s;
arsenalist	0:f4e449fa34d7	1101	} else {
arsenalist	0:f4e449fa34d7	1102	for(int i=0; i<sizeof(s); i++) {
arsenalist	0:f4e449fa34d7	1103	s[i]=0; }
arsenalist	0:f4e449fa34d7	1104	//sprintf(s,"/emma/api/controller/register?uid=%s&hmac=%s",emmaUID.c_str(),hmac.c_str());
arsenalist	0:f4e449fa34d7	1105	sprintf(s,"/emmaController/firmware/firmwareParameter");
arsenalist	0:f4e449fa34d7	1106	connData = s;
arsenalist	0:f4e449fa34d7	1107	}
arsenalist	0:f4e449fa34d7	1108
arsenalist	0:f4e449fa34d7	1109	//get parameter of firmware to be downloaded
arsenalist	0:f4e449fa34d7	1110	while(!emmaGetFirmwareParam) {
arsenalist	0:f4e449fa34d7	1111	rest.get(connData.c_str());
arsenalist	0:f4e449fa34d7	1112	for(int i=0; i<sizeof(s); i++) {
arsenalist	0:f4e449fa34d7	1113	s[i]=0; }
arsenalist	0:f4e449fa34d7	1114	rest.getResponse(s,sizeof(s));
arsenalist	0:f4e449fa34d7	1115	//DBG.printf("rsp param:%s\r\n",s);
arsenalist	0:f4e449fa34d7	1116
arsenalist	0:f4e449fa34d7	1117	str = s;
arsenalist	0:f4e449fa34d7	1118	if(str.find("[") != std::string::npos && str.find("]") != std::string::npos) {
arsenalist	0:f4e449fa34d7	1119	str.erase(str.begin(),str.begin()+str.find("[")+1);
arsenalist	0:f4e449fa34d7	1120	str.erase(str.begin()+str.find("]"),str.end());
arsenalist	0:f4e449fa34d7	1121
arsenalist	0:f4e449fa34d7	1122	MbedJSONValue jsonValue;
arsenalist	0:f4e449fa34d7	1123	parse(jsonValue,str.c_str());
arsenalist	0:f4e449fa34d7	1124
arsenalist	0:f4e449fa34d7	1125	char *parameter[2] = {"firmwareVer","numPart"};
arsenalist	0:f4e449fa34d7	1126
arsenalist	0:f4e449fa34d7	1127	for(int i=0; i<2; i++) {
arsenalist	0:f4e449fa34d7	1128	if(jsonValue.hasMember(parameter[i])) {
arsenalist	0:f4e449fa34d7	1129	string val = jsonValue[parameter[i]].get<std::string>();
arsenalist	0:f4e449fa34d7	1130	if(i==0) {
arsenalist	0:f4e449fa34d7	1131	firmwareVer = val;
arsenalist	0:f4e449fa34d7	1132	} else if(i==1) {
arsenalist	0:f4e449fa34d7	1133	sscanf(val.c_str(),"%d",&numPart);
arsenalist	0:f4e449fa34d7	1134	}
arsenalist	0:f4e449fa34d7	1135	}
arsenalist	0:f4e449fa34d7	1136	}
arsenalist	0:f4e449fa34d7	1137
arsenalist	0:f4e449fa34d7	1138	if(!firmwareVer.empty() && numPart!=0) {
arsenalist	0:f4e449fa34d7	1139	emmaGetFirmwareParam = true;
arsenalist	0:f4e449fa34d7	1140	}
arsenalist	0:f4e449fa34d7	1141	}
arsenalist	0:f4e449fa34d7	1142	}
arsenalist	0:f4e449fa34d7	1143	DBG.printf("firmwareVer:%s\r\n",firmwareVer.c_str());
arsenalist	0:f4e449fa34d7	1144	DBG.printf("numPart:%d\r\n",numPart);
arsenalist	0:f4e449fa34d7	1145
arsenalist	0:f4e449fa34d7	1146	//clear firmware file
arsenalist	0:f4e449fa34d7	1147	while(1) {
arsenalist	0:f4e449fa34d7	1148	if(clearFirmware()){
arsenalist	0:f4e449fa34d7	1149	DBG.printf("clear firmware on sd card\r\n\r\n");
arsenalist	0:f4e449fa34d7	1150	break;
arsenalist	0:f4e449fa34d7	1151	}
arsenalist	0:f4e449fa34d7	1152	wait(1);
arsenalist	0:f4e449fa34d7	1153	}
arsenalist	0:f4e449fa34d7	1154
arsenalist	0:f4e449fa34d7	1155	//set connData
arsenalist	0:f4e449fa34d7	1156	if(useProxy) {
arsenalist	0:f4e449fa34d7	1157	for(int i=0; i<sizeof(s); i++) {
arsenalist	0:f4e449fa34d7	1158	s[i]=0; }
arsenalist	0:f4e449fa34d7	1159	sprintf(s,"http://192.168.128.69/emmaController/firmware/%s",firmwareVer.c_str());
arsenalist	0:f4e449fa34d7	1160	connData = s;
arsenalist	0:f4e449fa34d7	1161	} else {
arsenalist	0:f4e449fa34d7	1162	for(int i=0; i<sizeof(s); i++) {
arsenalist	0:f4e449fa34d7	1163	s[i]=0; }
arsenalist	0:f4e449fa34d7	1164	sprintf(s,"/emmaController/firmware/%s",firmwareVer.c_str());
arsenalist	0:f4e449fa34d7	1165	connData = s;
arsenalist	0:f4e449fa34d7	1166	}
arsenalist	0:f4e449fa34d7	1167
arsenalist	0:f4e449fa34d7	1168	//download firmware
arsenalist	0:f4e449fa34d7	1169	for(int n=0; n<numPart; n++) {
arsenalist	0:f4e449fa34d7	1170	nextPart = false;
arsenalist	0:f4e449fa34d7	1171	while(!nextPart) {
arsenalist	0:f4e449fa34d7	1172	for(int i=0; i<sizeof(s); i++) {
arsenalist	0:f4e449fa34d7	1173	s[i]=0; }
arsenalist	0:f4e449fa34d7	1174	sprintf(s,"%s/firmware_Hex_%s_%d",connData.c_str(),firmwareVer.c_str(),n);
arsenalist	0:f4e449fa34d7	1175	rest.get(s);
arsenalist	0:f4e449fa34d7	1176	for(int i=0; i<sizeof(s); i++) {
arsenalist	0:f4e449fa34d7	1177	s[i]=0; }
arsenalist	0:f4e449fa34d7	1178	rest.getResponse(s,sizeof(s));
arsenalist	0:f4e449fa34d7	1179	//DBG.printf("rsp[%d]:%s\r\n",n,s);
arsenalist	0:f4e449fa34d7	1180
arsenalist	0:f4e449fa34d7	1181	str = s;
arsenalist	0:f4e449fa34d7	1182	if(str.find("{") != std::string::npos && str.find("}") != std::string::npos) {
arsenalist	0:f4e449fa34d7	1183	str.erase(str.begin(),str.begin()+str.find("{")+1);
arsenalist	0:f4e449fa34d7	1184	str.erase(str.begin()+str.find("}"),str.end());
arsenalist	0:f4e449fa34d7	1185	//DBG.printf("firmwarePart[%d]:%s\r\n",n,str.c_str());
arsenalist	0:f4e449fa34d7	1186	firmwarePart = str;
arsenalist	0:f4e449fa34d7	1187
arsenalist	0:f4e449fa34d7	1188	//calculated MD5
arsenalist	0:f4e449fa34d7	1189	calcMD5 = calculateMD5(firmwarePart);
arsenalist	0:f4e449fa34d7	1190	//DBG.printf("calcMD5[%d]:%s\r\n",n,calcMD5.c_str());
arsenalist	0:f4e449fa34d7	1191
arsenalist	0:f4e449fa34d7	1192	//MD5 from server
arsenalist	0:f4e449fa34d7	1193	for(int i=0; i<sizeof(s); i++) {
arsenalist	0:f4e449fa34d7	1194	s[i]=0; }
arsenalist	0:f4e449fa34d7	1195	sprintf(s,"%s/MD5/firmware_MD5_%s_%d",connData.c_str(),firmwareVer.c_str(),n);
arsenalist	0:f4e449fa34d7	1196	rest.get(s);
arsenalist	0:f4e449fa34d7	1197	for(int i=0; i<sizeof(s); i++) {
arsenalist	0:f4e449fa34d7	1198	s[i]=0; }
arsenalist	0:f4e449fa34d7	1199	rest.getResponse(s,sizeof(s));
arsenalist	0:f4e449fa34d7	1200
arsenalist	0:f4e449fa34d7	1201	str = s;
arsenalist	0:f4e449fa34d7	1202	if(str.find("{") != std::string::npos && str.find("}") != std::string::npos) {
arsenalist	0:f4e449fa34d7	1203	str.erase(str.begin(),str.begin()+str.find("{")+1);
arsenalist	0:f4e449fa34d7	1204	str.erase(str.begin()+str.find("}"),str.end());
arsenalist	0:f4e449fa34d7	1205	srvrMD5 = str;
arsenalist	0:f4e449fa34d7	1206	//DBG.printf("srvrMD5[%d]:%s\r\n",n,srvrMD5.c_str());
arsenalist	0:f4e449fa34d7	1207
arsenalist	0:f4e449fa34d7	1208	//compare original MD5 vs MD5 from server
arsenalist	0:f4e449fa34d7	1209	if(strcmp(calcMD5.c_str(),srvrMD5.c_str()) == 0) {
arsenalist	0:f4e449fa34d7	1210	//DBG.printf("MD5 correct\r\n");
arsenalist	0:f4e449fa34d7	1211
arsenalist	0:f4e449fa34d7	1212	//save to sd card
arsenalist	0:f4e449fa34d7	1213	int st = writeFirmwareHexToChar(firmwarePart);
arsenalist	0:f4e449fa34d7	1214	if(st) {
arsenalist	0:f4e449fa34d7	1215	DBG.printf("firmwarePart[%d/%d] written\r\n",n,numPart-1);
arsenalist	0:f4e449fa34d7	1216	nextPart = true;
arsenalist	0:f4e449fa34d7	1217	}
arsenalist	0:f4e449fa34d7	1218
arsenalist	0:f4e449fa34d7	1219	} else {
arsenalist	0:f4e449fa34d7	1220	DBG.printf("MD5 incorrect\r\n");
arsenalist	0:f4e449fa34d7	1221	}
arsenalist	0:f4e449fa34d7	1222	}
arsenalist	0:f4e449fa34d7	1223	} else {
arsenalist	0:f4e449fa34d7	1224	DBG.printf("retry to fetch firmwarePart[%d]\r\n",n);
arsenalist	0:f4e449fa34d7	1225	}
arsenalist	0:f4e449fa34d7	1226	wait(0.5);
arsenalist	0:f4e449fa34d7	1227	}
arsenalist	0:f4e449fa34d7	1228	}
arsenalist	0:f4e449fa34d7	1229	DBG.printf("download finished\r\n");
arsenalist	0:f4e449fa34d7	1230	}
arsenalist	0:f4e449fa34d7	1231
arsenalist	4:76ab12e2f8a3	1232	/start energy related/
arsenalist	0:f4e449fa34d7	1233	void energyThread(void const*) {
arsenalist	0:f4e449fa34d7	1234	while(1) {
arsenalist	0:f4e449fa34d7	1235	//DBG.printf("insideEnergyThread\r\n");
arsenalist	0:f4e449fa34d7	1236	//osDelay(5000);
arsenalist	0:f4e449fa34d7	1237
arsenalist	0:f4e449fa34d7	1238	//calculate energy
arsenalist	4:76ab12e2f8a3	1239	DBG.printf("energyThread-start\r\n");
arsenalist	0:f4e449fa34d7	1240	float period = 0;
arsenalist	0:f4e449fa34d7	1241	AWattHrSum = 0;
arsenalist	0:f4e449fa34d7	1242	BWattHrSum = 0;
arsenalist	0:f4e449fa34d7	1243	CWattHrSum = 0;
arsenalist	0:f4e449fa34d7	1244	while(period < 1*60.0) {
arsenalist	0:f4e449fa34d7	1245	period += ADE.getAccumulationTime(PHASE_A);
arsenalist	0:f4e449fa34d7	1246	ADE.getAccumulatedEnergy(PHASE_A, &AWattHrValue, &BWattHrValue, &CWattHrValue, &AVAHrValue, &BVAHrValue, &CVAHrValue);
arsenalist	0:f4e449fa34d7	1247	AWattHrSum += AWattHrValue;
arsenalist	0:f4e449fa34d7	1248	BWattHrSum += BWattHrValue;
arsenalist	0:f4e449fa34d7	1249	CWattHrSum += CWattHrValue;
arsenalist	0:f4e449fa34d7	1250	}
arsenalist	0:f4e449fa34d7	1251	AWattHr = AWattHrSum * ADE.AWhLSB;
arsenalist	0:f4e449fa34d7	1252	BWattHr = BWattHrSum * ADE.BWhLSB;
arsenalist	0:f4e449fa34d7	1253	CWattHr = CWattHrSum * ADE.CWhLSB;
arsenalist	0:f4e449fa34d7	1254
arsenalist	4:76ab12e2f8a3	1255	DBG.printf("energyThread-finish\r\n");
arsenalist	0:f4e449fa34d7	1256	}
arsenalist	0:f4e449fa34d7	1257	}
arsenalist	4:76ab12e2f8a3	1258	void checkVoltagePower() {
arsenalist	4:76ab12e2f8a3	1259	//check if voltage or power violates threshold
arsenalist	4:76ab12e2f8a3	1260	char s[256];
arsenalist	4:76ab12e2f8a3	1261	string str;
arsenalist	4:76ab12e2f8a3	1262
arsenalist	4:76ab12e2f8a3	1263	//DBG.printf("checkVoltagePower-start\r\n");
arsenalist	4:76ab12e2f8a3	1264
arsenalist	11:2311b2d5157d	1265	AVrms = ADE.VRMS(PHASE_A) * 0.000128; //0.000158; //constants are from calculateVRMS function
arsenalist	11:2311b2d5157d	1266	BVrms = ADE.VRMS(PHASE_B) * 0.000127; //0.000157;
arsenalist	11:2311b2d5157d	1267	CVrms = ADE.VRMS(PHASE_C) * 0.000126; //0.000156;
arsenalist	4:76ab12e2f8a3	1268
arsenalist	4:76ab12e2f8a3	1269	AIrms = ADE.IRMS(PHASE_A) * 0.0000125; //constants are from calculateIRMS function
arsenalist	4:76ab12e2f8a3	1270	BIrms = ADE.IRMS(PHASE_B) * 0.0000123;
arsenalist	4:76ab12e2f8a3	1271	CIrms = ADE.IRMS(PHASE_C) * 0.0000124;
arsenalist	4:76ab12e2f8a3	1272
arsenalist	4:76ab12e2f8a3	1273	AWatt = AVrms * AIrms;
arsenalist	4:76ab12e2f8a3	1274	BWatt = BVrms * BIrms;
arsenalist	4:76ab12e2f8a3	1275	CWatt = CVrms * CIrms;
arsenalist	4:76ab12e2f8a3	1276
arsenalist	4:76ab12e2f8a3	1277	if(AVrms > VRMSTHRESHOLD \|\| AWatt > WATTTHRESHOLD) {
arsenalist	4:76ab12e2f8a3	1278	DBG.printf("alert on ch1\r\n");
arsenalist	4:76ab12e2f8a3	1279	sprintf(s,"{\"uid\":\"%s\",\"hmac\":\"%s\",\"time\":\"2015-06-09 12:32:12\",\"voltage\":%.2f,\"power\":%.2f}",
arsenalist	4:76ab12e2f8a3	1280	emmaUID.c_str(),hmac.c_str(),AVrms,AWatt);
arsenalist	4:76ab12e2f8a3	1281	rest.post("/emma/api/controller/alert/1",s);
arsenalist	4:76ab12e2f8a3	1282	wait(2);
arsenalist	4:76ab12e2f8a3	1283	str = rxBuf;
arsenalist	4:76ab12e2f8a3	1284	if(str.rfind("/alert/1") != std::string::npos) {
arsenalist	4:76ab12e2f8a3	1285	str.erase(str.begin(),str.begin()+str.rfind("/alert/1"));
arsenalist	4:76ab12e2f8a3	1286	if(str.find("\"status\":\"success\"") != std::string::npos) {
arsenalist	4:76ab12e2f8a3	1287	DBG.printf("send alert ch1 success\r\n");
arsenalist	4:76ab12e2f8a3	1288	} else {
arsenalist	4:76ab12e2f8a3	1289	DBG.printf("send alert ch1 failed\r\n");
arsenalist	4:76ab12e2f8a3	1290	}
arsenalist	4:76ab12e2f8a3	1291	}
arsenalist	4:76ab12e2f8a3	1292	}
arsenalist	4:76ab12e2f8a3	1293
arsenalist	4:76ab12e2f8a3	1294	if(BVrms > VRMSTHRESHOLD \|\| BWatt > WATTTHRESHOLD) {
arsenalist	4:76ab12e2f8a3	1295	DBG.printf("alert on ch2\r\n");
arsenalist	4:76ab12e2f8a3	1296	sprintf(s,"{\"uid\":\"%s\",\"hmac\":\"%s\",\"time\":\"2015-06-09 12:32:12\",\"voltage\":%.2f,\"power\":%.2f}",
arsenalist	4:76ab12e2f8a3	1297	emmaUID.c_str(),hmac.c_str(),BVrms,BWatt);
arsenalist	4:76ab12e2f8a3	1298	rest.post("/emma/api/controller/alert/2",s);
arsenalist	4:76ab12e2f8a3	1299	wait(2);
arsenalist	4:76ab12e2f8a3	1300	str = rxBuf;
arsenalist	4:76ab12e2f8a3	1301	if(str.rfind("/alert/2") != std::string::npos) {
arsenalist	4:76ab12e2f8a3	1302	str.erase(str.begin(),str.begin()+str.rfind("/alert/2"));
arsenalist	4:76ab12e2f8a3	1303	if(str.find("\"status\":\"success\"") != std::string::npos) {
arsenalist	4:76ab12e2f8a3	1304	DBG.printf("send alert ch2 success\r\n");
arsenalist	4:76ab12e2f8a3	1305	} else {
arsenalist	4:76ab12e2f8a3	1306	DBG.printf("send alert ch2 failed\r\n");
arsenalist	4:76ab12e2f8a3	1307	}
arsenalist	4:76ab12e2f8a3	1308	}
arsenalist	4:76ab12e2f8a3	1309	}
arsenalist	4:76ab12e2f8a3	1310
arsenalist	4:76ab12e2f8a3	1311	if(CVrms > VRMSTHRESHOLD \|\| CWatt > WATTTHRESHOLD) {
arsenalist	7:7e8c6ad3fd64	1312	DBG.printf("alert on ch3\r\n");
arsenalist	4:76ab12e2f8a3	1313	DBG.printf("alert on ch3\r\n");
arsenalist	4:76ab12e2f8a3	1314	sprintf(s,"{\"uid\":\"%s\",\"hmac\":\"%s\",\"time\":\"2015-06-09 12:32:12\",\"voltage\":%.2f,\"power\":%.2f}",
arsenalist	4:76ab12e2f8a3	1315	emmaUID.c_str(),hmac.c_str(),CVrms,CWatt);
arsenalist	4:76ab12e2f8a3	1316	rest.post("/emma/api/controller/alert/3",s);
arsenalist	4:76ab12e2f8a3	1317	wait(2);
arsenalist	4:76ab12e2f8a3	1318	str = rxBuf;
arsenalist	4:76ab12e2f8a3	1319	if(str.rfind("/alert/3") != std::string::npos) {
arsenalist	4:76ab12e2f8a3	1320	str.erase(str.begin(),str.begin()+str.rfind("/alert/3"));
arsenalist	4:76ab12e2f8a3	1321	if(str.find("\"status\":\"success\"") != std::string::npos) {
arsenalist	4:76ab12e2f8a3	1322	DBG.printf("send alert ch3 success\r\n");
arsenalist	4:76ab12e2f8a3	1323	} else {
arsenalist	4:76ab12e2f8a3	1324	DBG.printf("send alert ch3 failed\r\n");
arsenalist	4:76ab12e2f8a3	1325	}
arsenalist	4:76ab12e2f8a3	1326	}
arsenalist	4:76ab12e2f8a3	1327	}
arsenalist	4:76ab12e2f8a3	1328	//DBG.printf("checkVoltagePower-finish\r\n");
arsenalist	4:76ab12e2f8a3	1329	}
arsenalist	4:76ab12e2f8a3	1330	/end energy related/
arsenalist	0:f4e449fa34d7	1331
arsenalist	0:f4e449fa34d7	1332	/start wifi mqtt/
arsenalist	0:f4e449fa34d7	1333	void mqttConnected(void* response) {
arsenalist	1:d314a43ae6f7	1334	DBG.printf("MQTT Connected\r\n");
arsenalist	0:f4e449fa34d7	1335	char mqttTopic[64];
arsenalist	0:f4e449fa34d7	1336	sprintf(mqttTopic,"%s/%s/command",platformDOMAIN.c_str(),emmaUID.c_str());
arsenalist	0:f4e449fa34d7	1337	mqtt.subscribe(mqttTopic);
arsenalist	0:f4e449fa34d7	1338	}
arsenalist	0:f4e449fa34d7	1339	void mqttDisconnected(void* response) {
arsenalist	1:d314a43ae6f7	1340	DBG.printf("MQTT Disconnected\r\n");
arsenalist	0:f4e449fa34d7	1341	}
arsenalist	0:f4e449fa34d7	1342	/end wifi mqtt/
arsenalist	0:f4e449fa34d7	1343
arsenalist	0:f4e449fa34d7	1344	/start wifi rest/
arsenalist	4:76ab12e2f8a3	1345	void rxInterrupt(void) {
arsenalist	4:76ab12e2f8a3	1346	char c;
arsenalist	4:76ab12e2f8a3	1347
arsenalist	4:76ab12e2f8a3	1348	while(_ESP.readable()) {
arsenalist	4:76ab12e2f8a3	1349	c = _ESP.getc();
arsenalist	4:76ab12e2f8a3	1350	if(c != 0) { //char is not null
arsenalist	4:76ab12e2f8a3	1351	rxBuf += c;
arsenalist	4:76ab12e2f8a3	1352	}
arsenalist	4:76ab12e2f8a3	1353	}
arsenalist	4:76ab12e2f8a3	1354	}
arsenalist	4:76ab12e2f8a3	1355	void checkRxBuffer(void) {
arsenalist	4:76ab12e2f8a3	1356	//check new command
arsenalist	4:76ab12e2f8a3	1357	if(rxBuf.rfind("/command") != std::string::npos) {
arsenalist	4:76ab12e2f8a3	1358	rxBuf.erase(rxBuf.begin(),rxBuf.begin()+rxBuf.rfind("/command"));
arsenalist	4:76ab12e2f8a3	1359	if(rxBuf.find("[{") != std::string::npos && rxBuf.find("}]") != std::string::npos) {
arsenalist	4:76ab12e2f8a3	1360	rxBuf.erase(rxBuf.begin(),rxBuf.begin()+rxBuf.find("[{")+1);
arsenalist	4:76ab12e2f8a3	1361	rxBuf.erase(rxBuf.begin()+rxBuf.find("]"),rxBuf.end());
arsenalist	4:76ab12e2f8a3	1362	globalCommand = rxBuf;
arsenalist	4:76ab12e2f8a3	1363	//DBG.printf("gC:%s\r\n",globalCommand.c_str());
arsenalist	4:76ab12e2f8a3	1364	newCommand = true;
arsenalist	4:76ab12e2f8a3	1365	}
arsenalist	4:76ab12e2f8a3	1366	}
arsenalist	4:76ab12e2f8a3	1367
arsenalist	4:76ab12e2f8a3	1368	//clear rxBuf
arsenalist	4:76ab12e2f8a3	1369	rxBuf.clear();
arsenalist	4:76ab12e2f8a3	1370	}
arsenalist	0:f4e449fa34d7	1371	/end wifi rest/
arsenalist	0:f4e449fa34d7	1372
arsenalist	0:f4e449fa34d7	1373	/start eth mqtt/
arsenalist	0:f4e449fa34d7	1374	void ethMQTTMessageArrived(MQTT::MessageData& md) {
arsenalist	0:f4e449fa34d7	1375	MQTT::Message &message = md.message;
arsenalist	0:f4e449fa34d7	1376	DBG.printf("Message arrived: qos %d, retained %d, dup %d, packetid %d\r\n",
arsenalist	0:f4e449fa34d7	1377	message.qos, message.retained, message.dup, message.id);
arsenalist	0:f4e449fa34d7	1378	DBG.printf("Payload: %.s\r\n", message.payloadlen, (char)message.payload);
arsenalist	0:f4e449fa34d7	1379	//DBG.printf("Payload %s\r\n",message.payload);
arsenalist	0:f4e449fa34d7	1380
arsenalist	0:f4e449fa34d7	1381
arsenalist	0:f4e449fa34d7	1382	//check whether cmd is json
arsenalist	0:f4e449fa34d7	1383	//char r[255];
arsenalist	0:f4e449fa34d7	1384	char s = (char)message.payload;
arsenalist	0:f4e449fa34d7	1385	string sp(s);
arsenalist	0:f4e449fa34d7	1386	//sprintf(s,"%.s",message.payloadlen, (char)message.payload);
arsenalist	0:f4e449fa34d7	1387	//sprintf(globCmd,"%s",s);
arsenalist	0:f4e449fa34d7	1388	//DBG.printf("Payload: %s\r\n", r);
arsenalist	0:f4e449fa34d7	1389	//string cmd = r;
arsenalist	0:f4e449fa34d7	1390	//globalCommand = cmd;
arsenalist	10:1dc69e0ce7fd	1391
arsenalist	10:1dc69e0ce7fd	1392	//globalCommand = sp;
arsenalist	10:1dc69e0ce7fd	1393
arsenalist	0:f4e449fa34d7	1394	//globCmd = (char*)message.payload;
arsenalist	0:f4e449fa34d7	1395	//string globCmd((char*)message.payload);
arsenalist	0:f4e449fa34d7	1396	//std::string sp = static_cast<std::char>(message.payload);
arsenalist	0:f4e449fa34d7	1397	//string sp((char*)message.payload);
arsenalist	10:1dc69e0ce7fd	1398
arsenalist	10:1dc69e0ce7fd	1399	//DBG.printf("String: %s\r\n",sp.c_str());
arsenalist	10:1dc69e0ce7fd	1400
arsenalist	0:f4e449fa34d7	1401	//globCmd = sp;
arsenalist	0:f4e449fa34d7	1402
arsenalist	10:1dc69e0ce7fd	1403	//newCommand = true;
arsenalist	10:1dc69e0ce7fd	1404	if(sp.find("[") != std::string::npos && sp.find("]") != std::string::npos) {
arsenalist	10:1dc69e0ce7fd	1405	sp.erase(sp.begin(),sp.begin()+sp.find("[")+1);
arsenalist	10:1dc69e0ce7fd	1406	sp.erase(sp.begin()+sp.find("]"),sp.end());
arsenalist	10:1dc69e0ce7fd	1407	globalCommand = sp;
arsenalist	0:f4e449fa34d7	1408	newCommand = true;
arsenalist	0:f4e449fa34d7	1409	}
arsenalist	10:1dc69e0ce7fd	1410	sp.clear();
arsenalist	0:f4e449fa34d7	1411	}
arsenalist	0:f4e449fa34d7	1412
arsenalist	0:f4e449fa34d7	1413	int ethMQTTConnect(MQTT::Client<MQTTEthernet, Countdown, MQTT_MAX_PACKET_SIZE>* client, MQTTEthernet* ipstack) {
arsenalist	0:f4e449fa34d7	1414	//char hostname[] = "q.thingfabric.com";
arsenalist	0:f4e449fa34d7	1415	//char hostname[] = "192.168.131.200";
arsenalist	0:f4e449fa34d7	1416	//int rc = ipstack->connect(hostname, MQTT_PORT);
arsenalist	0:f4e449fa34d7	1417	int rc = ipstack->connect(MQTT_HOST, MQTT_PORT);
arsenalist	0:f4e449fa34d7	1418
arsenalist	0:f4e449fa34d7	1419	if(rc!=0)
arsenalist	0:f4e449fa34d7	1420	return rc;
arsenalist	0:f4e449fa34d7	1421
arsenalist	0:f4e449fa34d7	1422	//MQTT Connect
arsenalist	0:f4e449fa34d7	1423	//char clientId[] = "emma/0674ff575349896767072538";
arsenalist	0:f4e449fa34d7	1424	char clientId [32];
arsenalist	0:f4e449fa34d7	1425	sprintf(clientId,"emma/%s",emmaUID.c_str());
arsenalist	0:f4e449fa34d7	1426	//DBG.printf("clientId:%s\r\n",clientId);
arsenalist	0:f4e449fa34d7	1427	MQTTPacket_connectData data = MQTTPacket_connectData_initializer;
arsenalist	0:f4e449fa34d7	1428	data.MQTTVersion = 3;
arsenalist	0:f4e449fa34d7	1429	data.clientID.cstring = clientId;
arsenalist	0:f4e449fa34d7	1430	data.username.cstring = "761b233e-a49a-4830-a8ae-87cec3dc1086";
arsenalist	0:f4e449fa34d7	1431	data.password.cstring = "ef25cf4567fbc07113252f8d72b7faf2";
arsenalist	0:f4e449fa34d7	1432
arsenalist	0:f4e449fa34d7	1433	if((rc = client->connect(&data)) == 0) {
arsenalist	0:f4e449fa34d7	1434	DBG.printf("connected\r\n");
arsenalist	0:f4e449fa34d7	1435	}
arsenalist	0:f4e449fa34d7	1436
arsenalist	0:f4e449fa34d7	1437	//MQTT Subscribe
arsenalist	0:f4e449fa34d7	1438	//char* topic = "gaisbwqreqrfxjc/0674ff575349896767072538/command";
arsenalist	0:f4e449fa34d7	1439	char s[64];
arsenalist	0:f4e449fa34d7	1440	sprintf(s,"%s/%s/command",platformDOMAIN.c_str(),emmaUID.c_str());
arsenalist	0:f4e449fa34d7	1441	string topic = s;
arsenalist	0:f4e449fa34d7	1442	//DBG.printf("topic:%s\r\n",topic.c_str());
arsenalist	0:f4e449fa34d7	1443	if((rc=client->subscribe(topic.c_str(),MQTT::QOS0,ethMQTTMessageArrived)) == 0) {
arsenalist	0:f4e449fa34d7	1444	DBG.printf("subscribe success!\r\n");
arsenalist	0:f4e449fa34d7	1445	}
arsenalist	0:f4e449fa34d7	1446	return rc;
arsenalist	0:f4e449fa34d7	1447	}
arsenalist	0:f4e449fa34d7	1448	void ethMQTTAttemptConnect(MQTT::Client<MQTTEthernet, Countdown, MQTT_MAX_PACKET_SIZE>* client, MQTTEthernet* ipstack) {
arsenalist	0:f4e449fa34d7	1449	int retryAttempt = 0;
arsenalist	0:f4e449fa34d7	1450
arsenalist	0:f4e449fa34d7	1451	while(!ipstack->getEth().linkstatus()) {
arsenalist	0:f4e449fa34d7	1452	DBG.printf("Ethernet link not present. Check cable connection\r\n");
arsenalist	0:f4e449fa34d7	1453	wait(1);
arsenalist	0:f4e449fa34d7	1454	}
arsenalist	0:f4e449fa34d7	1455
arsenalist	0:f4e449fa34d7	1456	while(ethMQTTConnect(client,ipstack) != 0) {
arsenalist	0:f4e449fa34d7	1457	int timeout = 3;
arsenalist	0:f4e449fa34d7	1458	DBG.printf("Retry attempt number %d waiting %d\r\n", retryAttempt, timeout);
arsenalist	0:f4e449fa34d7	1459	wait(timeout);
arsenalist	0:f4e449fa34d7	1460	retryAttempt++;
arsenalist	0:f4e449fa34d7	1461	}
arsenalist	0:f4e449fa34d7	1462	}
arsenalist	0:f4e449fa34d7	1463	/end eth mqtt/
arsenalist	0:f4e449fa34d7	1464
arsenalist	0:f4e449fa34d7	1465	/start emma settings/
arsenalist	0:f4e449fa34d7	1466	string getUID(void) {
arsenalist	0:f4e449fa34d7	1467	char s[32];
arsenalist	0:f4e449fa34d7	1468	unsigned long unique = (unsigned long )BASE_ADDR;
arsenalist	0:f4e449fa34d7	1469	sprintf(s,"%08x%08x%08x",unique[0], unique[1], unique[2]);
arsenalist	0:f4e449fa34d7	1470	return s;
arsenalist	0:f4e449fa34d7	1471	}
arsenalist	0:f4e449fa34d7	1472
arsenalist	0:f4e449fa34d7	1473	string readSetting(string parameter) {
arsenalist	0:f4e449fa34d7	1474	FILE *fp;
arsenalist	0:f4e449fa34d7	1475	signed char c;
arsenalist	0:f4e449fa34d7	1476	int i=0;
arsenalist	0:f4e449fa34d7	1477	char s[64];
arsenalist	0:f4e449fa34d7	1478	string strS;
arsenalist	0:f4e449fa34d7	1479
arsenalist	0:f4e449fa34d7	1480	sprintf(s,"/sd/settings/%s.txt",parameter.c_str());
arsenalist	0:f4e449fa34d7	1481
arsenalist	0:f4e449fa34d7	1482	fp = fopen(s,"r");
arsenalist	0:f4e449fa34d7	1483	memset(s,0,sizeof(s));
arsenalist	0:f4e449fa34d7	1484	if(fp != NULL) {
arsenalist	0:f4e449fa34d7	1485	while(1) {
arsenalist	0:f4e449fa34d7	1486	c = fgetc(fp);
arsenalist	0:f4e449fa34d7	1487	if(c == EOF){
arsenalist	0:f4e449fa34d7	1488	break;
arsenalist	0:f4e449fa34d7	1489	}
arsenalist	0:f4e449fa34d7	1490	s[i] = c;
arsenalist	0:f4e449fa34d7	1491	i++;
arsenalist	0:f4e449fa34d7	1492	}
arsenalist	0:f4e449fa34d7	1493	strS = s;
arsenalist	0:f4e449fa34d7	1494	if(strS.find("(") != std::string::npos && strS.find(")") != std::string::npos) {
arsenalist	0:f4e449fa34d7	1495	strS.erase(strS.begin(),strS.begin()+strS.find("(")+1);
arsenalist	0:f4e449fa34d7	1496	strS.erase(strS.begin()+strS.find(")"),strS.end());
arsenalist	0:f4e449fa34d7	1497	} else {
arsenalist	0:f4e449fa34d7	1498	strS = "";
arsenalist	0:f4e449fa34d7	1499	}
arsenalist	0:f4e449fa34d7	1500	}
arsenalist	0:f4e449fa34d7	1501	fclose(fp);
arsenalist	0:f4e449fa34d7	1502	return strS;
arsenalist	0:f4e449fa34d7	1503	}
arsenalist	0:f4e449fa34d7	1504
arsenalist	0:f4e449fa34d7	1505	bool writeSetting(string parameter, string value) {
arsenalist	0:f4e449fa34d7	1506	FILE *fp;
arsenalist	0:f4e449fa34d7	1507	char s[255];
arsenalist	0:f4e449fa34d7	1508
arsenalist	0:f4e449fa34d7	1509	sprintf(s,"/sd/settings/%s.txt",parameter.c_str());
arsenalist	0:f4e449fa34d7	1510	fp = fopen(s,"w");
arsenalist	0:f4e449fa34d7	1511	if(fp != NULL) {
arsenalist	0:f4e449fa34d7	1512	fprintf(fp,value.c_str());
arsenalist	0:f4e449fa34d7	1513	fclose(fp);
arsenalist	0:f4e449fa34d7	1514	return true;
arsenalist	0:f4e449fa34d7	1515	}
arsenalist	0:f4e449fa34d7	1516	return false;
arsenalist	0:f4e449fa34d7	1517	}
arsenalist	0:f4e449fa34d7	1518	/end emma settings/
arsenalist	0:f4e449fa34d7	1519
arsenalist	0:f4e449fa34d7	1520	/start emma node/
arsenalist	0:f4e449fa34d7	1521	string readNodeIP(string macAddr) {
arsenalist	0:f4e449fa34d7	1522	FILE *fp;
arsenalist	0:f4e449fa34d7	1523	signed char c;
arsenalist	0:f4e449fa34d7	1524	int i=0;
arsenalist	0:f4e449fa34d7	1525	char s[64];
arsenalist	0:f4e449fa34d7	1526	string strS;
arsenalist	0:f4e449fa34d7	1527
arsenalist	0:f4e449fa34d7	1528	sprintf(s,"/sd/nodeList/%s/nodeIP.txt",macAddr.c_str());
arsenalist	0:f4e449fa34d7	1529
arsenalist	0:f4e449fa34d7	1530	fp = fopen(s,"r");
arsenalist	0:f4e449fa34d7	1531	memset(s,0,sizeof(s));
arsenalist	0:f4e449fa34d7	1532	if(fp != NULL) {
arsenalist	0:f4e449fa34d7	1533	while(1) {
arsenalist	0:f4e449fa34d7	1534	c = fgetc(fp);
arsenalist	0:f4e449fa34d7	1535	if(c == EOF){
arsenalist	0:f4e449fa34d7	1536	break;
arsenalist	0:f4e449fa34d7	1537	}
arsenalist	0:f4e449fa34d7	1538	s[i] = c;
arsenalist	0:f4e449fa34d7	1539	i++;
arsenalist	0:f4e449fa34d7	1540	}
arsenalist	0:f4e449fa34d7	1541	strS = s;
arsenalist	0:f4e449fa34d7	1542	if(strS.find("(") != std::string::npos && strS.find(")") != std::string::npos) {
arsenalist	0:f4e449fa34d7	1543	strS.erase(strS.begin(),strS.begin()+strS.find("(")+1);
arsenalist	0:f4e449fa34d7	1544	strS.erase(strS.begin()+strS.find(")"),strS.end());
arsenalist	0:f4e449fa34d7	1545	} else {
arsenalist	0:f4e449fa34d7	1546	strS = "";
arsenalist	0:f4e449fa34d7	1547	}
arsenalist	0:f4e449fa34d7	1548	}
arsenalist	0:f4e449fa34d7	1549	fclose(fp);
arsenalist	0:f4e449fa34d7	1550	return strS;
arsenalist	0:f4e449fa34d7	1551	}
arsenalist	0:f4e449fa34d7	1552
arsenalist	0:f4e449fa34d7	1553	string readNodeCmd(string dType, string cmd) {
arsenalist	0:f4e449fa34d7	1554	FILE *fp;
arsenalist	0:f4e449fa34d7	1555	signed char c;
arsenalist	0:f4e449fa34d7	1556	int i=0;
arsenalist	0:f4e449fa34d7	1557	char s[128];
arsenalist	0:f4e449fa34d7	1558	string strS;
arsenalist	0:f4e449fa34d7	1559
arsenalist	0:f4e449fa34d7	1560	sprintf(s,"/sd/nodeCode/%s/%s.txt",dType.c_str(),cmd.c_str());
arsenalist	0:f4e449fa34d7	1561
arsenalist	0:f4e449fa34d7	1562	fp = fopen(s,"r");
arsenalist	0:f4e449fa34d7	1563	memset(s,0,sizeof(s));
arsenalist	0:f4e449fa34d7	1564	if(fp != NULL) {
arsenalist	0:f4e449fa34d7	1565	while(1) {
arsenalist	0:f4e449fa34d7	1566	c = fgetc(fp);
arsenalist	0:f4e449fa34d7	1567	if(c == EOF){
arsenalist	0:f4e449fa34d7	1568	break;
arsenalist	0:f4e449fa34d7	1569	}
arsenalist	0:f4e449fa34d7	1570	s[i] = c;
arsenalist	0:f4e449fa34d7	1571	i++;
arsenalist	0:f4e449fa34d7	1572	}
arsenalist	0:f4e449fa34d7	1573	strS = s;
arsenalist	0:f4e449fa34d7	1574	if(strS.find("(") != std::string::npos && strS.find(")") != std::string::npos) {
arsenalist	0:f4e449fa34d7	1575	strS.erase(strS.begin(),strS.begin()+strS.find("(")+1);
arsenalist	0:f4e449fa34d7	1576	strS.erase(strS.begin()+strS.find(")"),strS.end());
arsenalist	0:f4e449fa34d7	1577	} else {
arsenalist	0:f4e449fa34d7	1578	strS = "";
arsenalist	0:f4e449fa34d7	1579	}
arsenalist	0:f4e449fa34d7	1580	}
arsenalist	0:f4e449fa34d7	1581	fclose(fp);
arsenalist	0:f4e449fa34d7	1582	return strS;
arsenalist	0:f4e449fa34d7	1583	}
arsenalist	0:f4e449fa34d7	1584
arsenalist	0:f4e449fa34d7	1585	string *readNodeList(void) {
arsenalist	0:f4e449fa34d7	1586	static string nd[10]; //max node
arsenalist	0:f4e449fa34d7	1587	DIR *d;
arsenalist	0:f4e449fa34d7	1588	struct dirent *p;
arsenalist	0:f4e449fa34d7	1589	string q;
arsenalist	0:f4e449fa34d7	1590	int i=0;
arsenalist	0:f4e449fa34d7	1591
arsenalist	0:f4e449fa34d7	1592	d = opendir("/sd/nodeList");
arsenalist	0:f4e449fa34d7	1593	if(d != NULL) {
arsenalist	0:f4e449fa34d7	1594	while((p = readdir(d)) != NULL) {
arsenalist	0:f4e449fa34d7	1595	q = p->d_name;
arsenalist	0:f4e449fa34d7	1596	nd[i] = q;
arsenalist	0:f4e449fa34d7	1597	i++;
arsenalist	0:f4e449fa34d7	1598	}
arsenalist	0:f4e449fa34d7	1599	}
arsenalist	0:f4e449fa34d7	1600	closedir(d);
arsenalist	0:f4e449fa34d7	1601	return nd;
arsenalist	0:f4e449fa34d7	1602	}
arsenalist	0:f4e449fa34d7	1603
arsenalist	0:f4e449fa34d7	1604	string wifiGetNodeTemp(string macAddr) {
arsenalist	0:f4e449fa34d7	1605	int trial=0;
arsenalist	0:f4e449fa34d7	1606	string nodeIP = readNodeIP(macAddr);
arsenalist	0:f4e449fa34d7	1607	string str;
arsenalist	0:f4e449fa34d7	1608	string temp = "0";
arsenalist	0:f4e449fa34d7	1609
arsenalist	0:f4e449fa34d7	1610	if(rest.begin(nodeIP.c_str(),REMOTE_TCP_PORT,false)) {
arsenalist	0:f4e449fa34d7	1611	while(1) {
arsenalist	0:f4e449fa34d7	1612	char rcv[256] = {};
arsenalist	0:f4e449fa34d7	1613	rest.get("/","<?xml version=\"1.0\" encoding=\"utf-8\"?><app_cmd cmd=\"2\"/>\r\n");
arsenalist	0:f4e449fa34d7	1614	rest.getResponse(rcv,sizeof(rcv));
arsenalist	0:f4e449fa34d7	1615	str = rcv;
arsenalist	0:f4e449fa34d7	1616	if(str.find("temp=") != std::string::npos) {
arsenalist	0:f4e449fa34d7	1617	str.erase(str.begin(),str.begin()+str.find("temp=")+6);
arsenalist	0:f4e449fa34d7	1618	str.erase(str.begin()+str.find("\""),str.end());
arsenalist	0:f4e449fa34d7	1619	temp = str;
arsenalist	0:f4e449fa34d7	1620	break;
arsenalist	0:f4e449fa34d7	1621	}
arsenalist	0:f4e449fa34d7	1622	if(trial>1) { //three times trial
arsenalist	0:f4e449fa34d7	1623	break;
arsenalist	0:f4e449fa34d7	1624	}
arsenalist	0:f4e449fa34d7	1625	trial++;
arsenalist	0:f4e449fa34d7	1626	wait(2);
arsenalist	0:f4e449fa34d7	1627	}
arsenalist	0:f4e449fa34d7	1628	}
arsenalist	0:f4e449fa34d7	1629	return temp;
arsenalist	0:f4e449fa34d7	1630	}
arsenalist	0:f4e449fa34d7	1631	/end emma node/
arsenalist	0:f4e449fa34d7	1632
arsenalist	0:f4e449fa34d7	1633	/start emma connection function/
arsenalist	0:f4e449fa34d7	1634	string ethGET(string host, int port, string url) {
arsenalist	0:f4e449fa34d7	1635	char buf[1024];
arsenalist	0:f4e449fa34d7	1636	char s[256];
arsenalist	0:f4e449fa34d7	1637	int ret;
arsenalist	0:f4e449fa34d7	1638	TCPSocketConnection sock;
arsenalist	0:f4e449fa34d7	1639	Timer t;
arsenalist	0:f4e449fa34d7	1640
arsenalist	0:f4e449fa34d7	1641	sprintf(s,"%s",url.c_str());
arsenalist	0:f4e449fa34d7	1642	sock.connect(host.c_str(),port);
arsenalist	0:f4e449fa34d7	1643	sock.send_all(s,sizeof(s)-1);
arsenalist	0:f4e449fa34d7	1644	wait(2);
arsenalist	0:f4e449fa34d7	1645
arsenalist	0:f4e449fa34d7	1646	//receive return
arsenalist	0:f4e449fa34d7	1647	t.start();
arsenalist	0:f4e449fa34d7	1648	while(1) {
arsenalist	0:f4e449fa34d7	1649	ret = sock.receive(buf, sizeof(buf));
arsenalist	0:f4e449fa34d7	1650	if(ret<=0 \|\| t.read_ms() > 10000) {
arsenalist	0:f4e449fa34d7	1651	t.stop();
arsenalist	0:f4e449fa34d7	1652	break;
arsenalist	0:f4e449fa34d7	1653	}
arsenalist	0:f4e449fa34d7	1654	}
arsenalist	0:f4e449fa34d7	1655	sock.close();
arsenalist	0:f4e449fa34d7	1656	return buf;
arsenalist	0:f4e449fa34d7	1657	}
arsenalist	0:f4e449fa34d7	1658	/end emma connection function/
arsenalist	0:f4e449fa34d7	1659
arsenalist	0:f4e449fa34d7	1660	/start emma private function/
arsenalist	8:51a0ca9079ca	1661	/*
arsenalist	8:51a0ca9079ca	1662	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	1663	char s[512];
arsenalist	0:f4e449fa34d7	1664	int connPort;
arsenalist	0:f4e449fa34d7	1665	string connHost;
arsenalist	0:f4e449fa34d7	1666	string str;
arsenalist	0:f4e449fa34d7	1667	Timer t;
arsenalist	0:f4e449fa34d7	1668
arsenalist	0:f4e449fa34d7	1669	//wifi interface
arsenalist	0:f4e449fa34d7	1670	if(wifiAvailable) {
arsenalist	0:f4e449fa34d7	1671	_ESP.printf("MODE=B");
arsenalist	0:f4e449fa34d7	1672	if(useProxy) {
arsenalist	0:f4e449fa34d7	1673	connHost = proxySERVER;
arsenalist	0:f4e449fa34d7	1674	sscanf(proxyPORT.c_str(),"%d",&connPort);
arsenalist	0:f4e449fa34d7	1675	for(int i=0; i<sizeof(s); i++) {
arsenalist	0:f4e449fa34d7	1676	s[i]=0; }
arsenalist	4:76ab12e2f8a3	1677	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	1678	} else {
arsenalist	0:f4e449fa34d7	1679	connHost = EMMA_SERVER_HOST;
arsenalist	0:f4e449fa34d7	1680	connPort = EMMA_SERVER_PORT;
arsenalist	0:f4e449fa34d7	1681	for(int i=0; i<sizeof(s); i++) {
arsenalist	0:f4e449fa34d7	1682	s[i]=0; }
arsenalist	4:76ab12e2f8a3	1683	sprintf(s,"/emma/api/controller/test");
arsenalist	0:f4e449fa34d7	1684	}
arsenalist	0:f4e449fa34d7	1685	wait(1);
arsenalist	0:f4e449fa34d7	1686	t.start();
arsenalist	0:f4e449fa34d7	1687	while(!esp.ready() && t.read_ms() < 5000);
arsenalist	0:f4e449fa34d7	1688	t.stop();
arsenalist	0:f4e449fa34d7	1689	if(rest.begin(connHost.c_str(),connPort,false)) {
arsenalist	0:f4e449fa34d7	1690	//DBG.printf("rest begin\r\n");
arsenalist	0:f4e449fa34d7	1691	esp.process();
arsenalist	0:f4e449fa34d7	1692	rest.get(s);
arsenalist	0:f4e449fa34d7	1693	for(int i=0; i<sizeof(s); i++) {
arsenalist	0:f4e449fa34d7	1694	s[i]=0; }
arsenalist	0:f4e449fa34d7	1695	rest.getResponse(s,sizeof(s));
arsenalist	0:f4e449fa34d7	1696	str = s;
arsenalist	0:f4e449fa34d7	1697	//DBG.printf("response:%s\r\n",s);
arsenalist	0:f4e449fa34d7	1698	if(str.find("OK") != std::string::npos) {
arsenalist	0:f4e449fa34d7	1699	wifiConnected = true;
arsenalist	0:f4e449fa34d7	1700	}
arsenalist	0:f4e449fa34d7	1701	} else {
arsenalist	0:f4e449fa34d7	1702	wifiConnected = false;
arsenalist	0:f4e449fa34d7	1703	}
arsenalist	0:f4e449fa34d7	1704	} else {
arsenalist	0:f4e449fa34d7	1705	wifiConnected = false;
arsenalist	0:f4e449fa34d7	1706	}
arsenalist	0:f4e449fa34d7	1707
arsenalist	0:f4e449fa34d7	1708	//eth interface
arsenalist	0:f4e449fa34d7	1709	if(ethAvailable) {
arsenalist	0:f4e449fa34d7	1710	if(useProxy) {
arsenalist	0:f4e449fa34d7	1711	connHost = proxySERVER;
arsenalist	0:f4e449fa34d7	1712	sscanf(proxyPORT.c_str(),"%d",&connPort);
arsenalist	0:f4e449fa34d7	1713	for(int i=0; i<sizeof(s); i++) {
arsenalist	0:f4e449fa34d7	1714	s[i]=0; }
arsenalist	0:f4e449fa34d7	1715	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	1716	} else {
arsenalist	0:f4e449fa34d7	1717	connHost = EMMA_SERVER_HOST;
arsenalist	0:f4e449fa34d7	1718	connPort = EMMA_SERVER_PORT;
arsenalist	0:f4e449fa34d7	1719	for(int i=0; i<sizeof(s); i++) {
arsenalist	0:f4e449fa34d7	1720	s[i]=0; }
arsenalist	0:f4e449fa34d7	1721	strcpy(s,"GET /emma/api/web/test HTTP/1.0\nHost: %s\r\n\r\n");
arsenalist	0:f4e449fa34d7	1722	}
arsenalist	0:f4e449fa34d7	1723
arsenalist	0:f4e449fa34d7	1724	t.start();
arsenalist	0:f4e449fa34d7	1725	while(1) {
arsenalist	0:f4e449fa34d7	1726	str = ethGET(connHost,connPort,s);
arsenalist	0:f4e449fa34d7	1727	if(str.find("OK") != std::string::npos) {
arsenalist	0:f4e449fa34d7	1728	t.stop();
arsenalist	0:f4e449fa34d7	1729	ethConnected = true;
arsenalist	0:f4e449fa34d7	1730	break;
arsenalist	0:f4e449fa34d7	1731	}
arsenalist	0:f4e449fa34d7	1732	if(t.read_ms() > 5000) {
arsenalist	0:f4e449fa34d7	1733	t.stop();
arsenalist	0:f4e449fa34d7	1734	ethConnected = false;
arsenalist	0:f4e449fa34d7	1735	break;
arsenalist	0:f4e449fa34d7	1736	}
arsenalist	0:f4e449fa34d7	1737	}
arsenalist	0:f4e449fa34d7	1738	} else {
arsenalist	0:f4e449fa34d7	1739	ethConnected = false;
arsenalist	0:f4e449fa34d7	1740	}
arsenalist	0:f4e449fa34d7	1741
arsenalist	0:f4e449fa34d7	1742	//gprs interface
arsenalist	0:f4e449fa34d7	1743	}
arsenalist	8:51a0ca9079ca	1744	*/
arsenalist	8:51a0ca9079ca	1745	void isEthAvailable(void) {
arsenalist	8:51a0ca9079ca	1746	if(ipstack.getEth().linkstatus()) {
arsenalist	8:51a0ca9079ca	1747	ethAvailable = true;
arsenalist	8:51a0ca9079ca	1748	} else {
arsenalist	8:51a0ca9079ca	1749	ethAvailable = false;
arsenalist	8:51a0ca9079ca	1750	}
arsenalist	8:51a0ca9079ca	1751	}
arsenalist	8:51a0ca9079ca	1752
arsenalist	8:51a0ca9079ca	1753	void isEthConnected(void) {
arsenalist	8:51a0ca9079ca	1754	char s[512];
arsenalist	8:51a0ca9079ca	1755	int connPort;
arsenalist	8:51a0ca9079ca	1756	string connHost;
arsenalist	8:51a0ca9079ca	1757	string str;
arsenalist	8:51a0ca9079ca	1758	Timer t;
arsenalist	8:51a0ca9079ca	1759
arsenalist	8:51a0ca9079ca	1760	if(ethAvailable) {
arsenalist	8:51a0ca9079ca	1761	if(useProxy) {
arsenalist	8:51a0ca9079ca	1762	connHost = proxySERVER;
arsenalist	8:51a0ca9079ca	1763	sscanf(proxyPORT.c_str(),"%d",&connPort);
arsenalist	8:51a0ca9079ca	1764	for(int i=0; i<sizeof(s); i++) {
arsenalist	8:51a0ca9079ca	1765	s[i]=0; }
arsenalist	8:51a0ca9079ca	1766	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	1767	} else {
arsenalist	8:51a0ca9079ca	1768	connHost = EMMA_SERVER_HOST;
arsenalist	8:51a0ca9079ca	1769	connPort = EMMA_SERVER_PORT;
arsenalist	8:51a0ca9079ca	1770	for(int i=0; i<sizeof(s); i++) {
arsenalist	8:51a0ca9079ca	1771	s[i]=0; }
arsenalist	8:51a0ca9079ca	1772	strcpy(s,"GET /emma/api/controller/test HTTP/1.0\nHost: %s\r\n\r\n");
arsenalist	8:51a0ca9079ca	1773	}
arsenalist	8:51a0ca9079ca	1774
arsenalist	8:51a0ca9079ca	1775	t.start();
arsenalist	8:51a0ca9079ca	1776	while(1) {
arsenalist	8:51a0ca9079ca	1777	str = ethGET(connHost,connPort,s);
arsenalist	8:51a0ca9079ca	1778	if(str.find("OK") != std::string::npos) {
arsenalist	8:51a0ca9079ca	1779	t.stop();
arsenalist	8:51a0ca9079ca	1780	ethConnected = true;
arsenalist	8:51a0ca9079ca	1781	break;
arsenalist	8:51a0ca9079ca	1782	}
arsenalist	8:51a0ca9079ca	1783	if(t.read_ms() > 5000) {
arsenalist	8:51a0ca9079ca	1784	t.stop();
arsenalist	8:51a0ca9079ca	1785	ethConnected = false;
arsenalist	8:51a0ca9079ca	1786	break;
arsenalist	8:51a0ca9079ca	1787	}
arsenalist	8:51a0ca9079ca	1788	}
arsenalist	8:51a0ca9079ca	1789	} else {
arsenalist	8:51a0ca9079ca	1790	ethConnected = false;
arsenalist	8:51a0ca9079ca	1791	}
arsenalist	8:51a0ca9079ca	1792	}
arsenalist	8:51a0ca9079ca	1793
arsenalist	8:51a0ca9079ca	1794	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	1795	char s[512];
arsenalist	8:51a0ca9079ca	1796	int connPort;
arsenalist	8:51a0ca9079ca	1797	string connHost;
arsenalist	8:51a0ca9079ca	1798	string str;
arsenalist	8:51a0ca9079ca	1799	Timer t;
arsenalist	8:51a0ca9079ca	1800
arsenalist	8:51a0ca9079ca	1801	if(wifiAvailable) {
arsenalist	8:51a0ca9079ca	1802	_ESP.printf("MODE=B");
arsenalist	8:51a0ca9079ca	1803	if(useProxy) {
arsenalist	8:51a0ca9079ca	1804	connHost = proxySERVER;
arsenalist	8:51a0ca9079ca	1805	sscanf(proxyPORT.c_str(),"%d",&connPort);
arsenalist	8:51a0ca9079ca	1806	for(int i=0; i<sizeof(s); i++) {
arsenalist	8:51a0ca9079ca	1807	s[i]=0; }
arsenalist	8:51a0ca9079ca	1808	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	1809	} else {
arsenalist	8:51a0ca9079ca	1810	connHost = EMMA_SERVER_HOST;
arsenalist	8:51a0ca9079ca	1811	connPort = EMMA_SERVER_PORT;
arsenalist	8:51a0ca9079ca	1812	for(int i=0; i<sizeof(s); i++) {
arsenalist	8:51a0ca9079ca	1813	s[i]=0; }
arsenalist	8:51a0ca9079ca	1814	sprintf(s,"/emma/api/controller/test");
arsenalist	8:51a0ca9079ca	1815	}
arsenalist	8:51a0ca9079ca	1816	wait(1);
arsenalist	8:51a0ca9079ca	1817	t.start();
arsenalist	8:51a0ca9079ca	1818	while(!esp.ready() && t.read_ms() < 5000);
arsenalist	8:51a0ca9079ca	1819	t.stop();
arsenalist	8:51a0ca9079ca	1820	if(rest.begin(connHost.c_str(),connPort,false)) {
arsenalist	8:51a0ca9079ca	1821	//DBG.printf("rest begin\r\n");
arsenalist	8:51a0ca9079ca	1822	esp.process();
arsenalist	8:51a0ca9079ca	1823	rest.get(s);
arsenalist	8:51a0ca9079ca	1824	for(int i=0; i<sizeof(s); i++) {
arsenalist	8:51a0ca9079ca	1825	s[i]=0; }
arsenalist	8:51a0ca9079ca	1826	rest.getResponse(s,sizeof(s));
arsenalist	8:51a0ca9079ca	1827	str = s;
arsenalist	8:51a0ca9079ca	1828	//DBG.printf("response:%s\r\n",s);
arsenalist	8:51a0ca9079ca	1829	if(str.find("OK") != std::string::npos) {
arsenalist	8:51a0ca9079ca	1830	wifiConnected = true;
arsenalist	8:51a0ca9079ca	1831	}
arsenalist	8:51a0ca9079ca	1832	} else {
arsenalist	8:51a0ca9079ca	1833	wifiConnected = false;
arsenalist	8:51a0ca9079ca	1834	}
arsenalist	8:51a0ca9079ca	1835	} else {
arsenalist	8:51a0ca9079ca	1836	wifiConnected = false;
arsenalist	8:51a0ca9079ca	1837	}
arsenalist	8:51a0ca9079ca	1838	}
arsenalist	8:51a0ca9079ca	1839
arsenalist	8:51a0ca9079ca	1840	void isGprsConnected(void) {
arsenalist	8:51a0ca9079ca	1841
arsenalist	8:51a0ca9079ca	1842	}
arsenalist	0:f4e449fa34d7	1843
arsenalist	0:f4e449fa34d7	1844	void addChar(char *s, char c) {
arsenalist	0:f4e449fa34d7	1845	uint16_t k; //customized for EMS
arsenalist	0:f4e449fa34d7	1846	k = strlen(s);
arsenalist	0:f4e449fa34d7	1847	s[k] = c;
arsenalist	0:f4e449fa34d7	1848	s[k + 1] = 0;
arsenalist	0:f4e449fa34d7	1849	}
arsenalist	0:f4e449fa34d7	1850
arsenalist	0:f4e449fa34d7	1851	void rcvReply(char *r, int to) {
arsenalist	0:f4e449fa34d7	1852	Timer t;
arsenalist	0:f4e449fa34d7	1853	bool ended = false;
arsenalist	0:f4e449fa34d7	1854	char c;
arsenalist	0:f4e449fa34d7	1855
arsenalist	0:f4e449fa34d7	1856	strcpy(r,"");
arsenalist	0:f4e449fa34d7	1857	t.start();
arsenalist	0:f4e449fa34d7	1858	while(!ended) {
arsenalist	0:f4e449fa34d7	1859	if(_ESP.readable()) {
arsenalist	0:f4e449fa34d7	1860	c = _ESP.getc();
arsenalist	0:f4e449fa34d7	1861	addChar(r,c);
arsenalist	0:f4e449fa34d7	1862	t.start();
arsenalist	0:f4e449fa34d7	1863	}
arsenalist	0:f4e449fa34d7	1864	if(t.read_ms() > to) {
arsenalist	0:f4e449fa34d7	1865	ended = true;
arsenalist	0:f4e449fa34d7	1866	}
arsenalist	0:f4e449fa34d7	1867	}
arsenalist	0:f4e449fa34d7	1868	addChar(r, 0x00);
arsenalist	0:f4e449fa34d7	1869	}
arsenalist	0:f4e449fa34d7	1870
arsenalist	0:f4e449fa34d7	1871	string calculateMD5(string text) {
arsenalist	0:f4e449fa34d7	1872	char s[64];
arsenalist	0:f4e449fa34d7	1873	memset(s,0,sizeof(s)); //for unknown reason, after reading UID, the 's' will contaion UID data
arsenalist	0:f4e449fa34d7	1874	uint8_t hash[16];
arsenalist	0:f4e449fa34d7	1875	MD5::computeHash(hash, (uint8_t*)text.c_str(), strlen(text.c_str()));
arsenalist	0:f4e449fa34d7	1876	for(int i=0; i<16; ++i) {
arsenalist	0:f4e449fa34d7	1877	sprintf(s,"%s%02x",s,hash[i]);
arsenalist	0:f4e449fa34d7	1878	}
arsenalist	0:f4e449fa34d7	1879	return s;
arsenalist	0:f4e449fa34d7	1880	}
arsenalist	0:f4e449fa34d7	1881
arsenalist	0:f4e449fa34d7	1882	bool writeFirmwareHexToChar(string value) {
arsenalist	0:f4e449fa34d7	1883	FILE *fp;
arsenalist	0:f4e449fa34d7	1884	char s[32];
arsenalist	0:f4e449fa34d7	1885	int number;
arsenalist	0:f4e449fa34d7	1886	string chunk;
arsenalist	0:f4e449fa34d7	1887
arsenalist	0:f4e449fa34d7	1888	sprintf(s,"/sd/newFirmware/firmware.bin");
arsenalist	0:f4e449fa34d7	1889	fp = fopen(s,"a");
arsenalist	0:f4e449fa34d7	1890	if(fp != NULL) {
arsenalist	0:f4e449fa34d7	1891	for(int ch=0; ch<value.size(); ch+=2) {
arsenalist	0:f4e449fa34d7	1892	chunk = value.substr(ch,2);
arsenalist	0:f4e449fa34d7	1893	sscanf(chunk.c_str(),"%x",&number);
arsenalist	0:f4e449fa34d7	1894	fprintf(fp,"%c",number);
arsenalist	0:f4e449fa34d7	1895	}
arsenalist	0:f4e449fa34d7	1896	fclose(fp);
arsenalist	0:f4e449fa34d7	1897	return true;
arsenalist	0:f4e449fa34d7	1898	}
arsenalist	0:f4e449fa34d7	1899	return false;
arsenalist	0:f4e449fa34d7	1900	}
arsenalist	0:f4e449fa34d7	1901
arsenalist	0:f4e449fa34d7	1902	bool clearFirmware(void) {
arsenalist	0:f4e449fa34d7	1903	FILE *fp;
arsenalist	0:f4e449fa34d7	1904	char s[32];
arsenalist	0:f4e449fa34d7	1905
arsenalist	0:f4e449fa34d7	1906	sprintf(s,"/sd/newFirmware/firmware.bin");
arsenalist	0:f4e449fa34d7	1907	fp = fopen(s,"w");
arsenalist	0:f4e449fa34d7	1908	if(fp != NULL) {
arsenalist	0:f4e449fa34d7	1909	fprintf(fp,"");
arsenalist	0:f4e449fa34d7	1910	fclose(fp);
arsenalist	0:f4e449fa34d7	1911	return true;
arsenalist	0:f4e449fa34d7	1912	}
arsenalist	0:f4e449fa34d7	1913	return false;
arsenalist	0:f4e449fa34d7	1914	}
arsenalist	0:f4e449fa34d7	1915	/end emma private function/

Repository toolbox

Export to desktop IDE

Build repository

Repository details

Type:	Program
Created:	25 Jul 2015
Imports:	4
Forks:	1
Commits:	65
Dependents:	0
Dependencies:	15
Followers:	6

This repository is Public (Unlisted).

The code in this repository is Apache licensed.

emmaCode.cpp@11:2311b2d5157d, 2015-07-13 (annotated)

Who changed what in which revision?

Repository toolbox

Repository details

Important Information for this Arm website

Access Warning