Tahinli/Socket-Programming-Windows-CLI
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions
Socket-Programming-Windows-CLI/Socket_Multi/main.c
Tahinli f105fac6d7
Update main.c
2022-11-06 03:02:42 +03:00

465 lines
10 KiB
C
Raw Blame History

#ifndef WIN32_LEAN_AND_MEAN
#define WIN32_LEAN_AND_MEAN
#endif
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <winsock2.h>
#include <windows.h>
#include <ws2tcpip.h>
#include <iphlpapi.h>
#pragma comment(lib, "Ws_32.lib")
#define BUFLEN 512
#define PORT YOUR PORT(INT)
#define ADDRESS "YOUR-SERVER-IP"(STRING)
#define MAX_CLIENTS 5
//FUNCS
int dc(int i);
int mte(char*);
//variables
fd_set socketSet;
SOCKET clients[MAX_CLIENTS];
SOCKET sd, max_sd;
int curNoClients = 0;
struct sockaddr_in clientAddr;
int clientAddrlen;
char running = !0;
char recvbuf[BUFLEN];
char sysM[BUFLEN];
char message[BUFLEN+50];
char lastIP[32];
char lastPort[16];
char arIP[MAX_CLIENTS][32];
char arPort[MAX_CLIENTS][16];
char dIP[MAX_CLIENTS*5][32];
char dPort[MAX_CLIENTS*5][16];
int dcl=0;
int first[MAX_CLIENTS][1];
char lastName[20];
char arName[MAX_CLIENTS][20];
char dName[MAX_CLIENTS*5][20];
char pass[]="superstrongpass";
char gpass[20];
int arPas[MAX_CLIENTS];
int main(void) {
printf("Hi!\n");
int res, sendRes;
//Init
WSADATA wsaData;
res = WSAStartup(MAKEWORD(2,2), &wsaData);
if(res)
{
printf("Startup failed : %d\n",res);
return 1;
}
//Setup Server
//Construct
SOCKET listener;
listener = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
if (listener == INVALID_SOCKET)
{
printf("Error with construction: %d\n",WSAGetLastError());
WSACleanup();
return 1;
}
//Setup for multi
char multiple = !0;
res = setsockopt(listener, SOL_SOCKET, SO_REUSEADDR, &multiple, sizeof(multiple));
if (res < 0)
{
printf("Multiple Client Setup Failed : %d\n", WSAGetLastError());
closesocket(listener);
WSACleanup();
return 1;
}
//Bind Address
struct sockaddr_in address;
address.sin_family = AF_INET;
address.sin_addr.s_addr = inet_addr(ADDRESS);
address.sin_port = htons(PORT);
bind(listener, (struct sockaddr*)&address,sizeof(address));
if ( res == SOCKET_ERROR)
{
printf("Bind failed &d\n", WSAGetLastError());
closesocket(listener);
WSACleanup();
return 1;
}
//set listener
res = listen(listener, SOMAXCONN);
if ( res == SOCKET_ERROR)
{
printf("Listen failed &d\n", WSAGetLastError());
closesocket(listener);
WSACleanup();
return 1;
}
printf("Accepting on %s:%d\n", ADDRESS, PORT);
//Main Loop
//clear client array
memset(clients, 0, MAX_CLIENTS * sizeof(SOCKET));
for(int i=0;i<MAX_CLIENTS;i++)
{
strcpy(&arIP[i][0],"");
strcpy(&arPort[i][0],"");
strcpy(&arName[i][0],"");
first[i][0]=-1;
arPas[i]=-1;
}
for(int i=0;i<MAX_CLIENTS*5;i++)
{
strcpy(&dIP[i][0],"");
strcpy(&dPort[i][0],"");
strcpy(&dName[i][0],"");
}
strcpy(sysM,"");
strcpy(lastIP,"");
strcpy(lastPort,"");
strcpy(message,"");
strcpy(lastName,"");
//Loop
while(running)
{
strcpy(sysM,"");
//clear the set
FD_ZERO(&socketSet);
//add listener
FD_SET(listener, &socketSet);
for(int i = 0;i<MAX_CLIENTS;i++)
{
sd = clients[i];
if(sd>0)
{
//add an active client to the set
FD_SET(sd, &socketSet);
}
if(sd>max_sd)
{
max_sd = sd;
}
}
int activity = select(max_sd+1, &socketSet, NULL, NULL, NULL);
if (activity < 0)
{
continue;
}
//determine if listener socket has activity
if(FD_ISSET(listener, &socketSet))
{
//accept connection
sd = accept(listener, NULL, NULL);
if(sd == INVALID_SOCKET)
{
printf("Error Accepting : %d \n", WSAGetLastError());
}
//get client info
clientAddrlen = sizeof(address);
getpeername(sd, (struct sockaddr*)&clientAddr, &clientAddrlen);
strcat(lastIP,inet_ntoa(clientAddr.sin_addr));
itoa(ntohs(clientAddr.sin_port),lastPort,10);
printf("Client connected at %s:%s\n", lastIP,lastPort);
//add to array
if(curNoClients >= MAX_CLIENTS )
{
printf("FULL\n");
send(sd,"\n ---SERVER--- = Server is FULL, Going to be Disconnected\n",strlen("\n ---SYSTEM--- = Server is FULL, Going to be Disconnected\n"),0);
closesocket(sd);
shutdown(sd, SD_BOTH);
}
else
{
//scan through list
for(int i = 0; i< MAX_CLIENTS; i++)
{
if(!clients[i])
{
clients[i]= sd;
printf("Added to the List at index: %d\n", i);
strcpy(&arIP[i][0],lastIP);
strcpy(&arPort[i][0],lastPort);
first[i][0]=1;
arPas[i]=0;
curNoClients++;
strcat(sysM,"\n---SERVER--- = ");
strncat(sysM,lastIP,strlen(sysM));
strncat(sysM,":",strlen(sysM));
strncat(sysM,lastPort,strlen(sysM));
strncat(sysM," Has Connected\n",strlen(sysM));
for(int j = 0; j<MAX_CLIENTS; j++)
{
if(sd==clients[j] || arPas[j]==0 || first[j][0]==1)
{
continue;
}
else
{
send(clients[j],sysM, strlen(sysM), 0);
}
}
break;
}
}
}
strcpy(sysM,"");
strcpy(lastIP,"");
strcpy(lastPort,"");
strcpy(lastName,"");
}
// iterate through clients
for(int i=0;i<MAX_CLIENTS;i++)
{
strcpy(message,"");
if(!clients[i])
{
continue;
}
sd = clients[i];
//determine if clients have activity
if(FD_ISSET(sd, &socketSet))
{
//get message
res = recv(sd, recvbuf, BUFLEN, 0);
if(res > 0)
{
//print message
recvbuf[res] = '\0';
printf("%d.Client -Received (%d): %s \n",i,res,recvbuf);
//test if leave
if(!memcmp(recvbuf, "/leave", 6))
{
dc(i);
}
//test if quit
else if(!memcmp(recvbuf, "/quit", 5*sizeof(char)))
{
running = 0;
break;
}
else
{
//Name
if(first[i][0]==1)
{
strcpy(lastName,recvbuf);
if(lastName[0]==13)
{
strcpy(lastName,"Unknown");
}
else
{
strcpy(&arName[i][0],lastName);
strcpy(lastName,"");
first[i][0]=0;
}
}
//Password
else if(arPas[i]==0)
{
strcpy(gpass,recvbuf);
if(strcmp(pass,gpass)==0)
{
arPas[i]=1;
send(sd,"---SERVER--- = Connection Successful\n",strlen("---SERVER--- = Connection Successful\n"),0);
strcat(sysM,"---SERVER--- = ");
strcat(sysM,&arIP[i][0]);
strcat(sysM,":");
strcat(sysM,&arPort[i][0]);
strcat(sysM," is Authorized as ");
strcat(sysM,&arName[i][0]);
mte(sysM);
}
else
{
send(sd,"Password is wrong\n",strlen("Password is wrong\n"),0);
dc(i);
}
}
//send message to everyone
else
{
for(int j = 0; j<MAX_CLIENTS; j++)
{
if(sd==clients[j] || arPas[j]==0 || first[j][0]==1)
{
continue;
}
else
{
//NAME is ADDRESS
/*strcat(message,&arIP[i][0]);
strcat(message,":");
strcat(message,&arPort[i][0]);
strcat(message," ");
strcat(message,"=");
strcat(message," ");
strcat(message,recvbuf);
send(clients[j],message,strlen(message),0);*/
//NAME is NAME
strcat(message,&arName[i][0]);
strcat(message," ");
strcat(message,"=");
strcat(message," ");
strcat(message,recvbuf);
send(clients[j],message,strlen(message),0);
}
}
res = 0;
}
}
}
else
{
dc(i);
}
}
}
}
//disconnect everyone
for(int i = 0; i<MAX_CLIENTS;i++)
{
if(clients[i]>0)
{
dc(i);
}
}
//shutdown client
//res = shutdown(sd, SD_BOTH);
if(res == SOCKET_ERROR)
{
printf("Client shutdown failed : %d \n",WSAGetLastError());
}
closesocket(sd);
//ShutDown
closesocket(listener);
//Cleanup
res = WSACleanup();
if(res)
{
printf("Cleanup failed %d\n",res);
return 1;
}
printf("DONE\n");
return 0;
}
int dc(int i)
{
//close message
getpeername(sd, (struct sockaddr*)&clientAddr, &clientAddrlen);
strcat(lastIP,inet_ntoa(clientAddr.sin_addr));
itoa(ntohs(clientAddr.sin_port),lastPort,10);
printf("Client disconnected at %s:%s\n", lastIP,lastPort);
closesocket(sd);
shutdown(sd, SD_BOTH);
clients[i]=0;
strcpy(&arIP[i][0],"");
strcpy(&arPort[i][0],"");
first[i][0]=-1;
arPas[i]=-1;
curNoClients--;
if(dcl<MAX_CLIENTS*5)
{
strcpy(&dIP[dcl][0],lastIP);
strcpy(&dPort[dcl][0],lastPort);
strcpy(&dName[dcl][0],&arName[i][0]);
dcl++;
}
else
{
printf("\nDCList is Full !\n");
}
strcat(sysM,"\n---SERVER--- = ");
strcat(sysM,lastIP);
strcat(sysM,":");
strcat(sysM,lastPort);
strcat(sysM,"-->");
strcat(sysM,&arName[i][0]);
strncat(sysM," Has Disconnected\n",strlen(sysM));
strcpy(&arName[i][0],"");
for(int j = 0; j<MAX_CLIENTS; j++)
{
if(sd==clients[j] || arPas[j]==0 || first[j][0]==1)
{
continue;
}
else
{
send(clients[j],sysM, strlen(sysM), 0);
}
}
strcpy(sysM,"");
strcpy(lastIP,"");
strcpy(lastPort,"");
return 0;
}
int mte(char* message)
{
for(int j = 0; j<MAX_CLIENTS; j++)
{
if(arPas[j]==0 || first[j][0]==1)
{
continue;
}
else
{
send(clients[j],message,strlen(message),0);
}
}
return 0;
}
Reference in a new issue View git blame Copy permalink