#include <stdio.h> /* for printf() and fprintf() */
#include <sys/socket.h> /* for socket(), connect(), send(), and recv() */
#include <arpa/inet.h> /* for sockaddr_in and inet_addr() */
#include <stdlib.h> /* for atoi() and exit() */
#include <string.h> /* for memset() */
#include <unistd.h> /* for close() */
#include <time.h> /* for time fuctions */
#define RCVBUFSIZE 500 /* Size of receive buffer */
typedef struct
{
char OperationType,Service,Amount[8+1],ExtraData[22+1];
char RFU[100+1];
char ConfigPath[127+1];
} Request;
//void DieWithError(char *errorMessage); /* Error handling function */
void DieWithError(char *errorMessage)
{
perror(errorMessage);
exit(1);
}
//127.0.0.1
//10000
static int ServerLog (char * str, int size)
{
FILE *stream;
time_t dt_tm;
char aux[100];
char filename[40];
struct tm * now;
memset(filename,0,40);
//if (logos.state)
{
dt_tm=time(NULL);
now=localtime(&dt_tm);
sprintf(filename,"logClient%04d%02d%02d",now->tm_year+1900,now->tm_mon+1,now->tm_mday);
if ( (stream = fopen( filename, "a+" )) != NULL )
{
sprintf(aux,"[%04d/%02d/%02d %02d:%02d:%02d]-",now->tm_year+1900,now->tm_mon+1,now->tm_mday, now->tm_hour,now->tm_min,now->tm_sec);
fwrite( (char *)aux,1, strlen(aux), stream );
fwrite( (char *)str,1, size, stream );
fclose( stream );
}
}
return 0;
}
/* log message as hexa and ascii * */
void ServerLogThis(char *str, int len) {
int i, j, x;
char c;
char logbuf[200];
//if(!logos.dump) return;
logbuf[0] = 0;
sprintf(logbuf, "*************** DUMP CONTENTS length(%d) ***************\n", len);
ServerLog(logbuf, strlen(logbuf));
for(i= 0; i < len; ) {
memset(logbuf, 0, sizeof(logbuf));
// hexa dump
for(x= i, j= 0; x < len && j < 16; x++, j++) {
sprintf(logbuf, "%s%02.02x ", logbuf, (unsigned char)str[x]);
}
if(j < 16) {
while(j < 16) {
sprintf(logbuf, "%s ", logbuf); j++;
}
}
// separator
sprintf(logbuf, "%s ; ", logbuf);
// ascii dump
for(x= i, j= 0; x < len && j < 16; x++, j++) {
c= str[x];
if(c < 32 || c > 126) c= '.';
sprintf(logbuf, "%s%c", logbuf, c);
}
// Mete NewLine
sprintf(logbuf, "%s\n", logbuf);
// print dump
ServerLog(logbuf, strlen(logbuf));
i+= j;
}
sprintf(logbuf, "---------------------------------------------\n");
ServerLog(logbuf, strlen(logbuf));
}
int main(int argc, char *argv[])
{
int sock; /* Socket descriptor */
struct sockaddr_in echoServAddr; /* Echo server address */
unsigned short echoServPort; /* Echo server port */
char servIP[15 + 1]; /* Server IP address (dotted quad) */
char *echoString; /* String to send to echo server */
char echoBuffer[6000];/* Buffer for echo string */
unsigned int echoStringLen; /* Length of string to echo */
int bytesRcvd, totalBytesRcvd; /* Bytes read in single recv()
and total bytes read */
char logbuf[200];
/* Ingelink Request aux fields */
int tam = 0;
int *iRet;
echoString=(char*) malloc(sizeof(Request));
memset(servIP,0,sizeof(servIP));
memset(echoString,0,sizeof(Request));
memset(echoBuffer,0,sizeof(echoBuffer));
if ((argc < 3) || (argc > 4)) /* Test for correct number of arguments */
{
fprintf(stderr, "Usage: %s <Server IP> <Echo Word> [<Echo Port>]\n", argv[0]);
// sprintf(servIP,"127.0.0.1");
// sprintf(echoString,"4000000000");
exit(1);
}
else{
sprintf(servIP,"%s",argv[1]); /* First arg: server IP address (dotted quad) */
sprintf(echoString, "%s",argv[2]); /* Second arg: string to echo */
}
if (argc == 4)
echoServPort = atoi(argv[3]); /* Use given port, if any */
else //echoServPort = 7; /* 7 is the well-known port for the echo service */
echoServPort = 10001;
printf("POS2GO - Network TRX\n");
printf("Client running in port %d...\n", echoServPort);
sprintf(logbuf, "CLIENT START ----------------------->\n");
ServerLog(logbuf, strlen(logbuf));
/* Create a reliable, stream socket using TCP */
if ((sock = socket(PF_INET, SOCK_STREAM, IPPROTO_TCP)) < 0)
DieWithError("socket() failed");
/* Construct the server address structure */
memset(&echoServAddr, 0, sizeof(echoServAddr)); /* Zero out structure */
echoServAddr.sin_family = AF_INET; /* Internet address family */
echoServAddr.sin_addr.s_addr = inet_addr(servIP); /* Server IP address */
echoServAddr.sin_port = htons(echoServPort); /* Server port */
/* Establish the connection to the echo server */
if (connect(sock, (struct sockaddr *) &echoServAddr, sizeof(echoServAddr)) < 0)
DieWithError("connect() failed");
echoStringLen = 2*sizeof(int) + (5 * 1024); /* Determine input length */
tam = sizeof(Request);
/* Send the string to the server */
if (send(sock, echoString, tam , 0) != tam)
DieWithError("send() sent a different number of bytes than expected");
/*
if(echoString[0] == '4')
{
// Sending Cancelation after x seconds //
printf("Sending Cancelation after 20 seconds...\n");
sleep(20);
memset(echoString,0,sizeof(Request));
sprintf(echoString,"6000000000");
tam = sizeof(Request);
if (send(sock, echoString, tam , 0) != tam)
printf("send() cancelation error\n");
else
printf("send() cancelation ok\n");
printf("1st Read\n");
// Receive the same string back from the server //
totalBytesRcvd = 0;
printf("Received: \n"); // Setup to print the echoed string //
while (totalBytesRcvd < echoStringLen)
{
// Receive up to the buffer size (minus 1 to leave space for a null terminator) bytes from the sender //
if ((bytesRcvd = recv(sock, echoBuffer + totalBytesRcvd, RCVBUFSIZE - 1, 0)) <= 0)
DieWithError("recv() failed or connection closed prematurely");
printf("Receiving %d bytes...\n",bytesRcvd);
totalBytesRcvd += bytesRcvd; // Keep tally of total bytes //
echoBuffer[bytesRcvd] = '\0'; // Terminate the string! //
}
sprintf(logbuf, "Cancelation Response Buffer:\n");
ServerLog(logbuf, strlen(logbuf));
ServerLogThis(echoBuffer, totalBytesRcvd); // Print the echo buffer //
printf("\n"); // Print a final linefeed //
}*/
printf("2nd Read\n");
memset(echoBuffer,0,sizeof(echoBuffer));
/* Receive the same string back from the server */
totalBytesRcvd = 0;
printf("Received: \n"); /* Setup to print the echoed string */
while (totalBytesRcvd < echoStringLen)
{
/* Receive up to the buffer size (minus 1 to leave space for
* a null terminator) bytes from the sender */
if ((bytesRcvd = recv(sock, echoBuffer + totalBytesRcvd, RCVBUFSIZE - 1, 0)) <= 0)
DieWithError("recv() failed or connection closed prematurely");
printf("Receiving %d bytes...\n",bytesRcvd);
totalBytesRcvd += bytesRcvd; /* Keep tally of total bytes */
echoBuffer[bytesRcvd] = '\0'; /* Terminate the string! */
}
//memcpy(iRet, echoBuffer, sizeof(int));
//memcpy(tam, echoBuffer + sizeof(int), sizeof(int));
//printf("\nRet:%d\n", *iRet); /* Print the Ingelink return */
//printf("\nSize:%d\n", *tam); /* Print the ticket size */
sprintf(logbuf, "Request Response Buffer:\n");
ServerLog(logbuf, strlen(logbuf));
ServerLogThis(echoBuffer, totalBytesRcvd); /* Print the echo buffer */
printf("\n"); /* Print a final linefeed */
sprintf(logbuf, "<----------------------- CLIENT END\n");
ServerLog(logbuf, strlen(logbuf));
close(sock);
free(echoString);
exit(0);
}
