2020-03-10 / Kathy Yeh

1. modify upload log to http server
2. add Handshake Information: an opening HTTP request
3. add wss function

EVSE/Modularization/ocppfiles/MessageHandler.c

@@ -41,7 +41,6 @@
 
 
 
-
 #define PASS				1
 #define FAIL				-1
 
@@ -6266,14 +6265,7 @@ int handleGetDiagnosticsRequest(char *uuid, char *payload)
 {
 	mtrace();
 	int result = FAIL;
-	//void *ret; //
-	//char fnamePlusPath[100]="";
-	//char fname[40]="";
 	pthread_t t; // pthread 變數
-	//time_t rawtime;
-	//struct tm * timeinfo;
-
-	//system("exec /root/Module_WebService 'log' 6"); // for OCTT TEST
 	system("exec /root/logPackTools 'log' 6");
 #if 0
 	//char buffer [128];
@@ -6298,7 +6290,6 @@ int handleGetDiagnosticsRequest(char *uuid, char *payload)
 	strcpy(GetDiagnosticspayloadData, payload);
 	sendGetDiagnosticsConfirmation(uuid,fnamePWithNoPath/*(char*) ret*/);
 	pthread_create(&t, NULL, GetDiagnosticsProcess, payload);
-   // pthread_join(t, NULL/*&ret*/);
 
 	return result;
 }
@@ -6313,8 +6304,6 @@ void* GetDiagnosticsProcess(void* data)
 	int retriesIsNULL,retryIntervalIsNULL, startTimeIsNULL, stopTimeIsNULL;
 	char protocol[10]={0}, user[50]={0},password[50]={0},host[50]={0}, path[50]={0}, ftppath[60]={0},host1[50]={0},path1[50]={0};
 	int port=0;
-	//char fnamePlusPath[100]="";//="00000_2019-06-09_160902_CSULog.zip";
-	//char fname[40]="";
 	char sstr[260]={ 0 };//sstr[200]={ 0 };
 	int c = 0;
 	char *loc;
@@ -6324,7 +6313,6 @@ void* GetDiagnosticsProcess(void* data)
 	char * pch;
 
 //	[2,"137d88c7-a403-4ead-bb2d-fc6ec90531c1","GetDiagnostics",{"location":"ftp://ipc_ui:pht2016@ftp.phihong.com.tw/DC/log/","retries":0,"retryInterval":0,"startTime":"0001-01-01T00:00:00.000Z","stopTime":"0001-01-01T00:00:00.000Z"}]
-	//char *str = (char*) data; // ?  ?輸入資 ?
 	char str[300]={ 0 };
 	strcpy(str,(const char*)GetDiagnosticspayloadData);
 
@@ -6464,6 +6452,7 @@ void* GetDiagnosticsProcess(void* data)
 	else
 	{
 		DEBUG_INFO("fnamePlusPath not exist!\n");
+		sendDiagnosticsStatusNotificationRequest(DiagnosticsStatusStr[DiagnosticsStatus_UploadFailed]);
 		goto end;
 
 	}
@@ -6496,51 +6485,17 @@ void* GetDiagnosticsProcess(void* data)
 
 	if(strncmp(locationstr,"http", 4) == 0)
 	{
-		sscanf(locationstr,"%[^:]:%*2[/]%[^/]/%199[^\n]",
-			    	    			         protocol, host, path);
+		sscanf(locationstr,"%[^:]:%*2[/]%[^/]/%199[^\n]", protocol, host, path);
 
-		//sscanf(locationstr,"%[^:]:%*2[/]%[^:]:%[^@]@%[^/]%199[^\n]",
-			    	    	//	         protocol, user, password, host, path);
 		sprintf(ftppath,"/%s", path);
 
-		//DEBUG_INFO("protocol =%s\n",protocol);
-
-		//DEBUG_INFO("host =%s\n",host);
-
-		//DEBUG_INFO("path =%s\n",path);
-		//DEBUG_INFO("ftppath=%s\n",ftppath);
-		//int ftppathlen=strlen(ftppath);
-		//int i=1;
-		//char filenametemp[50];
-		//while(i < ftppathlen)
-		//{
-		//	int len=ftppathlen-i;
-		//	if(ftppath[len]== 47) // '/' ascll code: 47
-		//	{
-		//		DEBUG_INFO("compare '/' all right\n");
-		//	    break;
-		//	}
-		//	i=i+1;
-		//}
-
-		//memset(filenametemp, 0, sizeof(filenametemp));
-		//strncpy(filenametemp, ftppath+(ftppathlen-i+1), i+1);
-		//filenametemp[i+1] = 0;
-			//sendFirmwareStatusNotificationRequest(FirmwareStatusStr[FirmwareStatus_Downloading]);
-		//memset(fnamePlusPath, 0, sizeof(fnamePlusPath));
-		//strftime (fnamePlusPath,sizeof(fnamePlusPath),"/mnt/%4Y-%2m.zip",timeinfo);
-
-
 		do{
-			isSuccess = httpUploadFile(host, ftppath, fnamePlusPath, locationstr);//httpUploadFile(host, ftppath, fnamePlusPath, locationstr);
+			isSuccess = httpUploadFile(host, ftppath, fnamePlusPath, locationstr);
 			sleep(retryIntervalInt);
 		}while((isSuccess == 0)&&(retriesInt > 0 && retriesInt --));
 
-		//	isSuccess = httpDownLoadFile(host, ftppath, filenametemp, locationstr);
-
 		if(!isSuccess)
 		{
-			//BulldogUtil.sleepMs(interval*1000);
 			DEBUG_INFO("Diagnostics fail.\n");
 			sendDiagnosticsStatusNotificationRequest(DiagnosticsStatusStr[DiagnosticsStatus_UploadFailed]);
 		}
@@ -6548,7 +6503,6 @@ void* GetDiagnosticsProcess(void* data)
 		{
 			DEBUG_INFO("sendDiagnosticsStatusNotificationRequest Uploaded\n");
 			sendDiagnosticsStatusNotificationRequest(DiagnosticsStatusStr[DiagnosticsStatus_Uploaded]);
-			//isUpdateRequest = TRUE;
 		}
 
 	}
@@ -6557,14 +6511,6 @@ void* GetDiagnosticsProcess(void* data)
 		sscanf(host,"%[^/]%s",host1, path1);
 		sprintf(ftppath,"%s", path1);
 
-		DEBUG_INFO("protocol =%s\n",protocol);
-		DEBUG_INFO("user =%s\n",user);
-		DEBUG_INFO("password =%s\n",password);
-		DEBUG_INFO("host1 =%s\n",host1);
-		DEBUG_INFO("port =%d\n",port);
-		DEBUG_INFO("path1 =%s\n",path1);
-		DEBUG_INFO("ftppath=%s\n",ftppath);
-
 		int ftppathlen=strlen(ftppath);
 		int i=1;
 		char filenametemp[50];
@@ -6594,7 +6540,6 @@ void* GetDiagnosticsProcess(void* data)
 
 		if(!isSuccess)
 		{
-			//BulldogUtil.sleepMs(interval*1000);
 			DEBUG_INFO("Diagnostics fail.\n");
 			sendDiagnosticsStatusNotificationRequest(DiagnosticsStatusStr[DiagnosticsStatus_UploadFailed]);
 		}
@@ -6602,12 +6547,10 @@ void* GetDiagnosticsProcess(void* data)
 		{
 			DEBUG_INFO("sendDiagnosticsStatusNotificationRequest Uploaded\n");
 			sendDiagnosticsStatusNotificationRequest(DiagnosticsStatusStr[DiagnosticsStatus_Uploaded]);
-				//isUpdateRequest = TRUE;
 		}
 	}
 
 end:
-//	json_object_put(obj);
 	DiagnosticsStatusNotificationStatus = 0; //Idle
 	pthread_exit(NULL/*(void *) fname*/); // ?  ?子執行 ?
 
@@ -13659,10 +13602,11 @@ int httpUploadFile(char *location, char *path, char *filename,char *url)
 	char rmFileCmd[100]={0};
     char FilePath[100]={0};
 	char ftpbuf[200];
+	char filenametemp[60]={0};
 	int systemresult;
 
-	DEBUG_INFO("filename=%s\n",filename);
-	DEBUG_INFO("url=%s\n",url);
+	//DEBUG_INFO("filename=%s\n",filename);
+	//DEBUG_INFO("url=%s\n",url);
 
 	sprintf(FilePath,"%s","../mnt/upload_file.txt");
 
@@ -13678,20 +13622,19 @@ int httpUploadFile(char *location, char *path, char *filename,char *url)
 	if(fp == NULL)
 	{
 		DEBUG_INFO("log is NULL\n");
-		return 0;
+		return FALSE;
 	}
 	else
 	{
 		fprintf(fp, "%s\n", url);
-		fprintf(fp, "%s\n", filename);
+
+		sscanf(filename, "%*2[.]%s", filenametemp);
+		fprintf(fp, "%s\n", filenametemp);
 		fclose(fp);
 	}
 
 	memset(ftpbuf, 0, sizeof(ftpbuf));
-	//sprintf(ftpbuf, "%s","../bin/php-cgi /var/www/ocpp_upload.php");
-	//sprintf(ftpbuf, "ftpput -u %s -p %s %s -P %d %s%s %s",user,password,IPbuffer,21,filename,filename,path);
-	//curl -i -F filename=image.jpg -F image=@/path/to/image.jpg http://localhost/xmlcreate/curlupload.php
-	sprintf(ftpbuf, "curl -i -F filename=%s -F image=@%s%s %s",filename,path,filename,url);
+	sprintf(ftpbuf, "%s","../bin/php-cgi /var/www/ocpp_upload.php");
 	systemresult = system(ftpbuf);
 
 	DEBUG_INFO("systemresult=%d\n",systemresult);
@@ -14177,7 +14120,7 @@ int GetOcppServerURL()
 
 	if((ShmSysConfigAndInfo->SysConfig.OcppServerURL != NULL) && (strcmp((const char *)ShmSysConfigAndInfo->SysConfig.OcppServerURL,"") != 0) )
 	{
-		DEBUG_INFO("ShmSysConfigAndInfo->SysConfig.OcppServerURL =%s\n",ShmSysConfigAndInfo->SysConfig.OcppServerURL);
+		//DEBUG_INFO("ShmSysConfigAndInfo->SysConfig.OcppServerURL =%s\n",ShmSysConfigAndInfo->SysConfig.OcppServerURL);
 		sscanf((const char *)ShmSysConfigAndInfo->SysConfig.OcppServerURL,
 						"%[^:]:%*2[/]%[^:]:%i/%[a-zA-Z0-9._/-]",
 						OcppProtocol, OcppHost, &OcppPort, OcppTempPath);
@@ -14190,7 +14133,7 @@ int GetOcppServerURL()
 	}
 	else if((ShmOCPP16Data->OcppServerURL != NULL) && (strcmp((const char *)ShmOCPP16Data->OcppServerURL,"") != 0))
 	{
-		DEBUG_INFO("ShmOCPP16Data->OcppServerURL =%s\n",ShmOCPP16Data->OcppServerURL);
+		//DEBUG_INFO("ShmOCPP16Data->OcppServerURL =%s\n",ShmOCPP16Data->OcppServerURL);
 		sscanf((const char *)ShmOCPP16Data->OcppServerURL,
 								"%[^:]:%*2[/]%[^:]:%i/%[a-zA-Z0-9._/-]",
 								OcppProtocol, OcppHost, &OcppPort, OcppTempPath);
@@ -14246,7 +14189,7 @@ int GetOcppPath()
 	}
 
 End:
-	DEBUG_INFO("OcppPath=%s\n",OcppPath);
+	//DEBUG_INFO("OcppPath=%s\n",OcppPath);
 	return result;
 }
 

EVSE/Modularization/ocppfiles/Module_OcppBackend.c

@@ -34,14 +34,11 @@
 #include	"sqlite3.h"
 
 
-
-
-#if 0
-#define DEBUG_INFO(format, args...) StoreLogMsg("[%s:%d][%s][Info] "format, __FILE__, __LINE__, __FUNCTION__, ##args)
-#define DEBUG_WARN(format, args...) StoreLogMsg("[%s:%d][%s][Warn] "format, __FILE__, __LINE__, __FUNCTION__, ##args)
-#define DEBUG_ERROR(format, args...) StoreLogMsg("[%s:%d][%s][Error] "format, __FILE__, __LINE__, __FUNCTION__, ##args)
+#ifndef SPEC_LATEST_SUPPORTED
+#define SPEC_LATEST_SUPPORTED 13
 #endif
 
+
 #define Debug
 //#define ARRAY_SIZE(A)		(sizeof(A) / sizeof(A[0]))
 #define PASS				1
@@ -384,6 +381,32 @@ static int OCPP16Callback(struct lws *wsi, enum lws_callback_reasons reason, voi
 			DEBUG_INFO("LWS_CALLBACK_CLIENT_FILTER_PRE_ESTABLISH\n");
 			#endif
 			char buf[64];
+			char hash[20], key_b64[40];
+
+			lws_b64_encode_string(hash, 16, key_b64, sizeof(key_b64));// Sec-WebSocket-Key
+
+			DEBUG_OCPPMESSAGE_INFO("------------------Handshake: Client  START----------------\n");
+			lws_hdr_copy(wsi, buf, sizeof(buf) - 1, _WSI_TOKEN_CLIENT_URI);
+			DEBUG_OCPPMESSAGE_INFO("GET %s  HTTP/1.1 \n", buf);
+
+			lws_hdr_copy(wsi, buf, sizeof(buf) - 1, _WSI_TOKEN_CLIENT_HOST);
+			DEBUG_OCPPMESSAGE_INFO("Host: %s\n", buf);
+
+			//lws_hdr_copy(wsi, buf, sizeof(buf) - 1, _WSI_TOKEN_CLIENT_PEER_ADDRESS);
+			//DEBUG_OCPPMESSAGE_INFO("_WSI_TOKEN_CLIENT_PEER_ADDRESS %s\n", buf);
+
+			DEBUG_OCPPMESSAGE_INFO("Upgrade: websocket\n");
+
+			DEBUG_OCPPMESSAGE_INFO("Connection: Upgrade\n");
+
+			DEBUG_OCPPMESSAGE_INFO("Sec-WebSocket-Key: %s\n", key_b64);
+
+			lws_hdr_copy(wsi, buf, sizeof(buf) - 1, _WSI_TOKEN_CLIENT_SENT_PROTOCOLS);
+			DEBUG_OCPPMESSAGE_INFO("Sec-WebSocket-Protocol: %s\n", buf);
+
+			DEBUG_OCPPMESSAGE_INFO("Sec-WebSocket-Version: %d\n", SPEC_LATEST_SUPPORTED);
+
+			DEBUG_OCPPMESSAGE_INFO("------------------Handshake: Client  END----------------\n");
 
 			DEBUG_OCPPMESSAGE_INFO("------------------Handshake: Server response START----------------\n");
 
@@ -478,27 +501,52 @@ static int OCPP16Callback(struct lws *wsi, enum lws_callback_reasons reason, voi
 			ConnectionEstablished=0;
 
 			char buf1[64];
+			char hash1[20]={0}, key_b641[40]={0};
 
-					DEBUG_OCPPMESSAGE_INFO("------------------Handshake: Server response START----------------\n");
+			lws_b64_encode_string(hash1, 16, key_b641, sizeof(key_b641));// Sec-WebSocket-Key
 
-					lws_hdr_copy(wsi, buf1, sizeof(buf1) - 1, WSI_TOKEN_HTTP);
-					DEBUG_OCPPMESSAGE_INFO("HTTP/1.1 %s\n", buf1);
+			DEBUG_OCPPMESSAGE_INFO("------------------Handshake: Client  START----------------\n");
+			lws_hdr_copy(wsi, buf, sizeof(buf) - 1, _WSI_TOKEN_CLIENT_URI);
+			DEBUG_OCPPMESSAGE_INFO("GET %s  HTTP/1.1 \n", buf);
 
-					lws_hdr_copy(wsi, buf1, sizeof(buf1) - 1, WSI_TOKEN_UPGRADE);
-					DEBUG_OCPPMESSAGE_INFO("Upgrade: %s\n", buf1);
+			lws_hdr_copy(wsi, buf, sizeof(buf) - 1, _WSI_TOKEN_CLIENT_HOST);
+			DEBUG_OCPPMESSAGE_INFO("Host: %s\n", buf);
 
+			//lws_hdr_copy(wsi, buf, sizeof(buf) - 1, _WSI_TOKEN_CLIENT_PEER_ADDRESS);
+			//DEBUG_OCPPMESSAGE_INFO("_WSI_TOKEN_CLIENT_PEER_ADDRESS %s\n", buf);
 
-					lws_hdr_copy(wsi, buf1, sizeof(buf1) - 1, WSI_TOKEN_CONNECTION);
-					DEBUG_OCPPMESSAGE_INFO("Connection: %s\n", buf1);
+			DEBUG_OCPPMESSAGE_INFO("Upgrade: websocket\n");
 
-					lws_hdr_copy(wsi, buf1, sizeof(buf1) - 1, WSI_TOKEN_ACCEPT);
-					DEBUG_OCPPMESSAGE_INFO("Sec-WebSocket-Accept: %s\n", buf1);
+			DEBUG_OCPPMESSAGE_INFO("Connection: Upgrade\n");
 
-					lws_hdr_copy(wsi, buf1, sizeof(buf1) - 1, WSI_TOKEN_PROTOCOL);
-					DEBUG_OCPPMESSAGE_INFO("Sec-WebSocket-Protocol: %s\n", buf1);
+			DEBUG_OCPPMESSAGE_INFO("Sec-WebSocket-Key: %s\n", key_b641);
 
-					DEBUG_OCPPMESSAGE_INFO("------------------Handshake: Server response END----------------\n");
+			lws_hdr_copy(wsi, buf, sizeof(buf) - 1, _WSI_TOKEN_CLIENT_SENT_PROTOCOLS);
+			DEBUG_OCPPMESSAGE_INFO("Sec-WebSocket-Protocol: %s\n", buf);
+
+			DEBUG_OCPPMESSAGE_INFO("Sec-WebSocket-Version: %d\n", SPEC_LATEST_SUPPORTED);
+
+			DEBUG_OCPPMESSAGE_INFO("------------------Handshake: Client  END----------------\n");
+
+
+			DEBUG_OCPPMESSAGE_INFO("------------------Handshake: Server response START----------------\n");
+
+			lws_hdr_copy(wsi, buf1, sizeof(buf1) - 1, WSI_TOKEN_HTTP);
+			DEBUG_OCPPMESSAGE_INFO("HTTP/1.1 %s\n", buf1);
 
+			lws_hdr_copy(wsi, buf1, sizeof(buf1) - 1, WSI_TOKEN_UPGRADE);
+			DEBUG_OCPPMESSAGE_INFO("Upgrade: %s\n", buf1);
+
+			lws_hdr_copy(wsi, buf1, sizeof(buf1) - 1, WSI_TOKEN_CONNECTION);
+			DEBUG_OCPPMESSAGE_INFO("Connection: %s\n", buf1);
+
+			lws_hdr_copy(wsi, buf1, sizeof(buf1) - 1, WSI_TOKEN_ACCEPT);
+			DEBUG_OCPPMESSAGE_INFO("Sec-WebSocket-Accept: %s\n", buf1);
+
+			lws_hdr_copy(wsi, buf1, sizeof(buf1) - 1, WSI_TOKEN_PROTOCOL);
+			DEBUG_OCPPMESSAGE_INFO("Sec-WebSocket-Protocol: %s\n", buf1);
+
+			DEBUG_OCPPMESSAGE_INFO("------------------Handshake: Server response END----------------\n");
 
 			break;
 		case LWS_CALLBACK_CLOSED://4
@@ -617,17 +665,40 @@ int ConnectWsServer()
 		lws_context_destroy(context);
 
 	memset(&ContextInfo, 0, sizeof(struct lws_context_creation_info));
+
+	if((GetOcppServerURL()==0) || (GetOcppPort() == 0) || (GetOcppPath()==0) )
+	{
+		result = FAIL;
+		DEBUG_ERROR("OCPP URL is NULL or OCPP Port is zero or  OCPP Path is NULL\n");
+		return result;
+	}
+
+	if((strcmp(OcppProtocol,"ws")==0)&&(strlen(OcppProtocol)== 2))
+	{
+		printf("ws!!! \n");
+		use_ssl=0;
+	}
+	else if((strcmp(OcppProtocol,"wss")==0)&&(strlen(OcppProtocol)== 3))
+	{
+		printf("wss!!! \n");
+		use_ssl=1;
+	}
+
 	ContextInfo.port = CONTEXT_PORT_NO_LISTEN;
 	ContextInfo.iface = NULL;
 	ContextInfo.ssl_private_key_password = NULL;
-	ContextInfo.ssl_cert_filepath = NULL;
-	ContextInfo.ssl_private_key_filepath = NULL;
-	ContextInfo.ssl_ca_filepath = "/root/cacert.pem";
+	ContextInfo.ssl_cert_filepath = NULL;//"./ssl_key/client_cert.pem";//NULL;
+	ContextInfo.ssl_private_key_filepath = NULL;//"./ssl_key/client_key.pem";//NULL;//"./ssl_key/client_key.pem";//NULL;
+	ContextInfo.ssl_ca_filepath = "./cacert.pem";//"./ssl_key/cacert.pem";//"cacert.pem";//"./ssl_key/cacert.pem";//"/root/cacert.pem";
 	ContextInfo.ssl_cipher_list = NULL; //use default one
 	ContextInfo.gid = -1;
 	ContextInfo.uid = -1;
 	if(use_ssl)
-		ContextInfo.options |= LWS_SERVER_OPTION_DO_SSL_GLOBAL_INIT;
+	{
+		ContextInfo.options |= LWS_SERVER_OPTION_DO_SSL_GLOBAL_INIT ;
+		//ContextInfo.options |= LWS_SERVER_OPTION_REDIRECT_HTTP_TO_HTTPS | LWS_SERVER_OPTION_ALLOW_NON_SSL_ON_SSL_PORT | LWS_SERVER_OPTION_DISABLE_IPV6 | LWS_SERVER_OPTION_PEER_CERT_NOT_REQUIRED | LWS_SERVER_OPTION_VALIDATE_UTF8 | LWS_SERVER_OPTION_SKIP_SERVER_CANONICAL_NAME;
+	}
+
 	ContextInfo.protocols = protocols;
 	ContextInfo.timeout_secs = 9999;//30;
 	//if(ping pong enabled)
@@ -645,22 +716,19 @@ int ConnectWsServer()
 	// fill up below information
 	ConnInfo.context = context;
 
-	if((GetOcppServerURL()==0) || (GetOcppPort() == 0) || (GetOcppPath()==0) )
-	{
-		result = FAIL;
-		DEBUG_ERROR("OCPP URL is NULL or OCPP Port is zero or  OCPP Path is NULL\n");
-		return result;
-	}
-
 	ConnInfo.address=(const char *)OcppHost;
+	 printf("\n ConnInfo.address=%s\n",ConnInfo.address);
 
 	ConnInfo.port = GetOcppPort();
-
+  printf("\n ConnInfo.port=%d\n",ConnInfo.port);
 	ConnInfo.path=(const char *)OcppPath;
-	ConnInfo.host=lws_canonical_hostname(context);
+
+	 printf("\n ConnInfo.path=%s\n",ConnInfo.path);
+	ConnInfo.host=ConnInfo.address;//lws_canonical_hostname(context);
 	ConnInfo.origin="origin";
 	ConnInfo.protocol = protocols[1].name;
 	ConnInfo.ietf_version_or_minus_one = -1;
+
 	if(use_ssl)
 		ConnInfo.ssl_connection = LCCSCF_USE_SSL | LCCSCF_ALLOW_SELFSIGNED | LCCSCF_SKIP_SERVER_CERT_HOSTNAME_CHECK;;
 
@@ -1220,17 +1288,12 @@ if( fgets (str, 1200, fp)!=NULL ) {
 	 }
 
 	result = TRUE;
-	//return 1;
 }
 else
 {
-	//DEBUG_INFO("queue is null\n");
-
 	result = FALSE;
-	//return 0;
 }
 fclose(fp);
-//DEBUG_INFO("sentqueue end\n");
 return result;
 }
 
@@ -1257,7 +1320,6 @@ void* processTransactionQueue(void* data) {
 					TransactionQueueInterval = 10;//2;
 					sleep(TransactionQueueInterval);
 					sendbuffer = 1;
-					//DEBUG_INFO("test 1\n");
 				}
 				else
 				{
@@ -1324,8 +1386,8 @@ void CheckTransactionPacket(char *uuid)
 		if (cmpResult == 0)
 		{
 			DEBUG_INFO("TransactionPacket Compare All right!\n");
-			DEBUG_INFO("frontUUID=%s\n",frontUUID);
-			DEBUG_INFO("uuid=%s\n",uuid);
+			//DEBUG_INFO("frontUUID=%s\n",frontUUID);
+			//DEBUG_INFO("uuid=%s\n",uuid);
 			queue_operation(2,"","");//delq(); ---> remove temporally
 			TransactionQueueInterval = 0;
 			TransactionMessageResend = 1;