/**
 * Localchat
 * Ben Burwell
 *
 * Send chat request
 */


void *send_chat_request(void * arg) {

	int i;
	char ip[16];
	char * username = (char *) arg;

	pthread_mutex_lock(&peer_table_lock);

	for (i = 0; i < num_peers_in_table; i++) {
		if (strcmp(peers[i].username, username) == 0) {
			strcpy(ip, peers[i].ip);
		}
	}

	pthread_mutex_unlock(&peer_table_lock);

	struct sockaddr_in server_addr;
	char out_buf[GLOBAL_MSG_LENGTH];
	char in_buf[GLOBAL_MSG_LENGTH];
	int retcode;

	// create the socket
	client_s = socket(AF_INET, SOCK_STREAM, 0);

	if (client_s < 0) {
		printf("Network error, quitting... \n");
		exit(-1);
	}

	// fill in server info
	server_addr.sin_family = AF_INET;
	server_addr.sin_port = htons(CHAT_PORT);
	server_addr.sin_addr.s_addr = inet_addr(ip);

	retcode = connect(client_s, (struct sockaddr *)&server_addr, sizeof(server_addr));

	if (retcode < 0) {
		printf("Network error, quitting... \n");
		exit(-1);
	}

	// send the session request
	strcpy(out_buf, "SESREQ");
	send(client_s, out_buf, strlen(out_buf), 0);



	retcode = recv(client_s, in_buf, sizeof(in_buf), 0);

	if (strcmp(in_buf, "SESANS:Y") == 0) {
		printf("Request accepted, type /q to leave. \n");

		// set my in_chat flag
		strcpy(in_chat, "Y");

		pthread_t recv_thread;
		pthread_create(&recv_thread, NULL, receive_chat_messages, NULL);

		// set the user prompt
		strcpy(prompt, "chat>");

	} else {
		printf("Session declined. \n");
	}

	return;
}

void start_chat_request_thread(char * user) {

	pthread_create(&requester_t, NULL, send_chat_request, (void *)user);

	sleep(10);

	printf("Request timed out. \n");

	pthread_cancel(requester_t);

	return;
}