#include #include #include #include #include #include #include #include "message.h" #include "user.h" #include "easysock.h" #include "file_helpers.h" #include "message_helpers.h" #define BUFFER_SIZE 10000 #define MAX_CONNECTIONS 100 User** create_user_list(char* filename); void sigint_handler(int dummy); User* fetch_user(char* username); User** users; int num_users; bool stop_running = false; int main() { signal(SIGINT,sigint_handler); struct sockaddr temp_addr; socklen_t temp_addrlen; fd_set read_fd_set; int conn_sockets[MAX_CONNECTIONS] = {-1}; User* dest_users[MAX_CONNECTIONS] = {NULL}; FD_ZERO(&read_fd_set); char buffer[BUFFER_SIZE]; users = create_user_list("user_file.txt"); num_users = num_of_lines("user_file.txt"); struct sockaddr addr_struct; int server_sock = create_local(4,'T',"127.0.0.1",30000,&addr_struct); conn_sockets[0] = server_sock; assert(listen(server_sock,MAX_CONNECTIONS) == 0); while (true) { FD_ZERO(&read_fd_set); for (int i=0; i < MAX_CONNECTIONS; i++) { if (conn_sockets[i] > 0) { FD_SET(conn_sockets[i],&read_fd_set); } } int num_conns = select(FD_SETSIZE, &read_fd_set, NULL, NULL, NULL); if (num_conns > 0) { if (FD_ISSET(conn_sockets[0],&read_fd_set)) { int client_sock = accept(conn_sockets[0],&temp_addr,&temp_addrlen); for (int i=0;i < MAX_CONNECTIONS; i++) { if (conn_sockets[i] <= 0) { conn_sockets[i] = client_sock; break; } } } for (int i=1; i < MAX_CONNECTIONS; i++) { if (FD_ISSET(conn_sockets[i],&read_fd_set)) { int num_bytes_read = recv(conn_sockets[i],buffer,sizeof(buffer),0); if (num_bytes_read <= 0) { close(conn_sockets[i]); conn_sockets[i] = 0; dest_users[i] = NULL; } else { if (dest_users[i] == NULL) { dest_users[i] = fetch_user(user_string(buffer)); if (dest_users[i] == NULL) { printf("Invalid message format or User\n"); exit(241); } else { printf("Message intended for %s\n",dest_users[i]->username); exit(0); } } // for (int i=0;i on every line */ int num_users = num_of_lines(filename); char* file_str = file_to_string(filename); char* token = malloc(sizeof(char) * 30); User** users = malloc (num_users * sizeof(User*)); token = strtok(file_str," \r\n"); for (int i=0;iusername = strdup(token); token = strtok(NULL," \r\n"); users[i]->password = strdup(token); token = strtok(NULL," \r\n"); } return users; } void sigint_handler(int dummy) { stop_running = true; } User* fetch_user(char* username) { if (username == NULL) { return NULL; } for (int i=0;iusername, username) == 0) { return users[i]; } } return NULL; }