#include <stdio.h>  // Per l'I/O de stdin/stdout

#include <sys/socket.h>  // Per les macros bool,true,false

#include <sys/un.h>  // Per les estructures dels unix sockets

#include <errno.h>  // Pels errors de les crides a fitxer

#include <string.h> // Per strerror()

#include <stdlib.h> // Per abort()

#include <assert.h> // Per assert()

#include <unistd.h> // Per les crides a fitxer

#include "rfc3164.h" // Per MESSAGE_LENGTH

void show_help(const char * restrict program)

{

	printf("Usage: %s <unix_socket>\n", program);

}

int connect_unix(const char * restrict socketname)

{

	int socket_unix;

	struct sockaddr_un source_unix;

	int result;

	socket_unix = socket(PF_UNIX, SOCK_DGRAM, 0 );

	if (socket_unix == -1)

	{

		printf("Unix socket creation error: %s\n", strerror(errno));

		abort();

		/* Unreachable */

		return -1;

	}

	/* Unix socket listen address */

	memset(&source_unix, 0, sizeof(source_unix));

	source_unix.sun_family = AF_UNIX;

	strcpy(source_unix.sun_path, socketname);

	result = connect(socket_unix, (struct sockaddr *) &source_unix,

		sizeof(source_unix));

	if (result == -1)

	{

		printf("Unix socket connect error: %s\n", strerror(errno));

		abort();

		/* Unreachable */

		return -1;

	}

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

	return socket_unix;

}

void writer_loop(const char * restrict socketname)

{

	int socket_unix;

	int result;

	char message[MESSAGE_LENGTH+1];

	socket_unix = connect_unix(socketname);

	while (fgets(message, MESSAGE_LENGTH, stdin) != NULL )

	{

		send(socket_unix, message, strlen(message), 0);

		/* Strip the last \n */

		if (strlen(message) > 1)

			message[strlen(message)-1] = '\0';

		/* Allow exiting the program */

		if(!strcmp(message,"close"))

			break;

	}

	result = close(socket_unix);

	if (result == -1)

	{

		printf("Unix socket close 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;

	}

	writer_loop(argv[1]);

	return 0;

}