#include <unistd.h> // Per les crides a fitxer
#include <stdio.h>  // Per l'I/O de stdin/stdout
#include <errno.h>  // Pels errors de les crides a fitxer
#include <string.h> // Per strerror()
#include <stdlib.h> // Per abort()
#include <sys/types.h>  // Per crides de fitxer
#include <sys/socket.h>  // Per les macros bool,true,false
#include <sys/un.h>  // Per les estructures dels unix sockets
#include <assert.h> // Per assert()

#include "rfc3164.h"

void show_help(const char * restrict program)
{
	printf("Usage: %s <unix_socket>\n", program);
}


int listen_unix(const char * restrict socketname)
{
	int socket_unix;
	struct sockaddr_un source_unix;
	int result;
	int sockopt;


	socket_unix = socket(PF_UNIX, SOCK_DGRAM, 0 );
	if (socket_unix == -1)
	{
		printf("Unix socket creation error: %s\n", strerror(errno));
		abort();
	}

	/* Allow socket reuse */
	sockopt = 1;
	result = setsockopt(socket_unix, SOL_SOCKET, SO_REUSEADDR, &sockopt,
		sizeof(sockopt));
	assert(result == 0);

	/* Unix socket listen address */
	memset(&source_unix, 0, sizeof(source_unix));
	source_unix.sun_family = AF_UNIX;
	strcpy(source_unix.sun_path, socketname);
	result = bind(socket_unix, (struct sockaddr *) &source_unix,
		sizeof(source_unix));
	assert(result == 0);

	/* Here we should take care of the socket permissions */

	return socket_unix;
}

void server_loop(const char * restrict socketname)
{
	int socket_unix;
	int result;
	char message[MESSAGE_LENGTH+1];


	socket_unix = listen_unix(socketname);

	result = 0;
	while ((result = recv(socket_unix, message, MESSAGE_LENGTH, 0)) >=0 )
	{
		process_message(message);
		/* Debug */
		if(!strcmp(message,"close"))
			break;
	}
	result = close(socket_unix);
	if (result == -1)
	{
		printf("Unix socket close error: %s\n", strerror(errno));
		abort();
	}
	result = unlink(socketname);
	if (result == -1)
	{
		printf("Unix socket unlink error: %s\n", strerror(errno));
		abort();
	}

}


int main(int argn, char **argv)
{
	/* Processem els paràmetres d'entrada */
	if (argn != 2) {
		show_help(argv[0]);
		return 2;
	}

	server_loop(argv[1]);

	return 0;
}