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

Users » bonchenko » Code » PB_Emma_Ethernet

able to subscribe for >10hrs and still running

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

Fork of PB_emma_controller_mbed_src by Emma

emmaCode.cpp@14:8287f0f5d987, 2015-07-14 (annotated)

Committer:: arsenalist
Date:: Tue Jul 14 16:48:24 2015 +0000
Revision:: 14:8287f0f5d987
Parent:: 13:e8adfe305dbc
Child:: 15:136526c28afb

Working RTC with backup.

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

Repository toolbox

Export to desktop IDE

Build repository

Repository details

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

emmaCode.cpp@14:8287f0f5d987, 2015-07-14 (annotated)

Who changed what in which revision?

Repository toolbox

Repository details

Important Information for this Arm website

Access Warning