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

void send_chat_request(char * username) {

	int i;
	char ip[16];

	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);

	// set the timeout of the socket
	struct timeval tv;
	tv.tv_sec  = REQUEST_TIMEOUT;
	tv.tv_usec = 0;
	setsockopt(client_s, SOL_SOCKET, SO_RCVTIMEO, (char *)&tv, sizeof(struct timeval));

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

	if (retcode == -1) {

		// socket timed out or didn't receive anything
		printf("No response from peer within timeout window \n");

	} else {

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

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

			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;
}