/**********************************************************************
*	Project     : Unix/Linux Socket2air Example Applications
*	Description : notify <Ip Addr> <Login> <Pw> <TelNum> <Message>
*  compiler for Unix  : gcc -o notify -lsocket s2a_gcc.c
*  compiler for Linux : gcc -o notify s2a_gcc.c
**********************************************************************/
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <time.h>
#include <sys/socket.h>
#include <netinet/in.h>

#define SERV_PORT 8000
#define MAX_SEND_QUEUE_LEN 255
#define MAX_RET_MSG_LEN 128
#define INTERFACE_TYPE 0

char IpAddr[20] = "";
char Login[20] = "";
char Pw[20] = "";
char TelNum[20] = "";
char MsgId[50]= "";
char Msg[300] = "";
char TmpStr[300];

struct Send_Msg{
   unsigned char interface_type;
   unsigned char msg_type;
   unsigned char msg_content_len;
   char msg_content[MAX_SEND_QUEUE_LEN];
};

struct Ret_Msg{
   unsigned char ret_code;
   char ret_description[MAX_RET_MSG_LEN];
};

int FillMsg(char *src, char *target, int n)
{
int i,len;
len = strlen(target);
for(i=0; i<len; i++)
	src[n++] = target[i];
src[n++] = '\0';
return(n);
}

void LogMessage(char *info)
{
char str_time[50];
time_t tnow;
struct tm *lctime;
FILE *fp;
if( (fp=fopen("notify.log","a+")) == NULL )
   return;
time(&tnow);
lctime = localtime(&tnow);
strftime(str_time, 80, "%Y%m%d.%H%M%S", lctime);
sprintf(TmpStr,"%s %8s %8s %10s %s %s\n", str_time, Login, MsgId, TelNum, info, Msg);
fputs(TmpStr, fp);
fclose(fp);
}

int main(int argc, char *argv[])
{
int i,iPos,ret;
int sockfd;
struct Send_Msg sendMsg;
struct Ret_Msg retMsg;
struct sockaddr_in servaddr;

if(argc<6)
{
   printf("\nUsage : notify <Ip Addr> <Login> <Pw> <TelNum> <Msg> ");
   printf("\n <ex>: notify 203.66.172.131 test test1 0932xxxxxx System Crit Alarm");
   printf("\nOutput: notify.log");
   printf("\n <ex>: <Date.Time> <Login> <MessageId> <TelNum> <Status> <Msg>\n");
   LogMessage("Fail:Argument_Error");
   exit(0);
}

strcpy(IpAddr, argv[1]);
strcpy(Login, argv[2]);
strcpy(Pw, argv[3]);
strcpy(TelNum, argv[4]);
strcpy(Msg, "");
for(i=5; i<argc; i++)
   {strcat(Msg,argv[i]);	strcat(Msg," ");	}
Msg[160] = '\0';
/******* Startup Socket *******/
if ( (sockfd = socket(AF_INET, SOCK_STREAM, 0)) < 0)
   printf("socket error");
bzero(&servaddr, sizeof(servaddr));
servaddr.sin_family = AF_INET;
servaddr.sin_port   = htons(SERV_PORT);
if (inet_pton(AF_INET, argv[1], &servaddr.sin_addr) <= 0){
   printf("socket inet_pton error for %s", argv[1]);
   exit(0);
}
if (connect(sockfd, (struct sockaddr *) &servaddr, sizeof(servaddr)) < 0){
   printf("socket connect error");
   exit(0);
}

/******* 檢查Username,Pw帳號/密碼 *******/
memset((char *)&sendMsg, 0, sizeof(sendMsg));
sendMsg.interface_type = INTERFACE_TYPE;
sendMsg.msg_type = 0;
iPos = 0;
iPos = FillMsg(&sendMsg.msg_content[0], Login, iPos);
iPos = FillMsg(&sendMsg.msg_content[0], Pw, iPos);
sendMsg.msg_content_len = iPos;

if((ret = write(sockfd , (char *)&sendMsg, sizeof(sendMsg)))<0){
   printf("socket sending User/Pwd error");
   close(sockfd);
   LogMessage("Fail:Socket Sending_User/Pwd_Error");
   exit(0);
}
   
memset((char *)&retMsg, 0, sizeof(retMsg));	
if((ret = read(sockfd , (char *)&retMsg, sizeof(retMsg)))<0){   
   printf("socket receiving User/Pwd error");
   close(sockfd);
   LogMessage("Fail:Socket Receiving_User/Pwd_Error");
   exit(0);
}
if(retMsg.ret_code != 0 ){
   printf("Login/Password_Error !\n");
   close(sockfd);
   LogMessage("Fail:Login/Password_Error");
   exit(0);
}
printf("\n%s", retMsg.ret_description);

/******* 傳送訊息(立即傳送) *******/
memset((char *)&sendMsg, 0, sizeof(sendMsg));
sendMsg.interface_type = INTERFACE_TYPE;
sendMsg.msg_type = 1;
iPos = 0;
iPos = FillMsg(&sendMsg.msg_content[0], TelNum, iPos);
iPos = FillMsg(&sendMsg.msg_content[0], Msg, iPos);
sendMsg.msg_content[iPos++] = 100;	//立即傳送 
sendMsg.msg_content[iPos++] = '\0';
sendMsg.msg_content_len = iPos;

if((ret = write(sockfd , (char *)&sendMsg, sizeof(sendMsg)))<0){
   printf("socket sending message error");
   close(sockfd);
   LogMessage("Fail:Socket Sending_Message_Error");
   exit(0);
}

memset((char *)&retMsg, 0, sizeof(retMsg));
if((ret = read(sockfd , (char *)&retMsg, sizeof(retMsg)))<0){   
   printf("socket receiving message error");
   close(sockfd);
   LogMessage("Fail:Socket Receiving_User/Pwd_Error");
   exit(0);
}

strcpy(MsgId, retMsg.ret_description);
printf("\nMessage Id:%s", MsgId);
LogMessage("Success");
close(sockfd);
}