utils.c

#include "utils.h"

void* serializar_paquete(t_paquete* paquete, int *bytes)
{
	*bytes = sizeof(paquete->codigo_operacion) + sizeof(paquete->buffer->size) + paquete->buffer->size;
	void* a_enviar = malloc(*bytes);
	int offset = 0;

	memcpy(a_enviar + offset, &(paquete->codigo_operacion), sizeof(paquete->codigo_operacion));
	offset += sizeof(paquete->codigo_operacion);
	memcpy(a_enviar + offset, &(paquete->buffer->size), sizeof(paquete->buffer->size));
	offset += sizeof(paquete->buffer->size);
	memcpy(a_enviar + offset, paquete->buffer->stream, paquete->buffer->size);
	offset += paquete->buffer->size;

	return a_enviar;
}

int crear_conexion(char *ip, char* puerto)
{
	struct addrinfo hints;
	struct addrinfo *server_info;

	memset(&hints, 0, sizeof(hints));
	hints.ai_family = AF_UNSPEC;
	hints.ai_socktype = SOCK_STREAM;
	hints.ai_flags = AI_PASSIVE;

	getaddrinfo(ip, puerto, &hints, &server_info);

	int socket_cliente = socket(server_info->ai_family, server_info->ai_socktype, server_info->ai_protocol);

	if(connect(socket_cliente, server_info->ai_addr, server_info->ai_addrlen) == -1){
		socket_cliente = 0;
	}

	freeaddrinfo(server_info);

	return socket_cliente;
}

void enviar_mensaje(char* mensaje, int socket_cliente)
{
	int tamanioMensaje = strlen(mensaje) + 1;
	int bytes = 0;
	void* mensaje_serializado;
	t_paquete* paquete = malloc(sizeof(t_paquete));

	paquete->codigo_operacion = MENSAJE;
	paquete->buffer = malloc(sizeof(t_buffer));
	paquete->buffer->stream = mensaje;
	paquete->buffer->size = tamanioMensaje;
	paquete->buffer->stream = malloc(paquete->buffer->size);
	memcpy(paquete->buffer->stream, mensaje, tamanioMensaje);
	mensaje_serializado = serializar_paquete(paquete, &bytes);

	free(paquete->buffer->stream);
	free(paquete->buffer);
	free(paquete);

	if(send(socket_cliente, mensaje_serializado, bytes, 0) == -1){
		printf("Error enviando mensaje.");
		free(mensaje_serializado); //TODO Ver cómo evitar redundancia de código y avisarle al usuario que hubo un error.
		exit(5);
	}
	
	free(mensaje_serializado);
}

char* recibir_mensaje(int socket_cliente)
{
	op_code codigo_operacion;
	char* buffer;
	int size;

	if(recv(socket_cliente, &codigo_operacion, sizeof(int), 0) <= 0){
		printf("Error recibiendo mensaje.\n");
		return NULL;
	}

	switch(codigo_operacion) {
	    case MENSAJE:
	    	recv(socket_cliente, &size, sizeof(int), 0);
			buffer = malloc(size);
			recv(socket_cliente, buffer, size, 0);
	        break;
	    default:
	    	printf("Error: código no válido.\n");
			return NULL;
	}

	return buffer;
}

void liberar_conexion(int socket_cliente)
{
	close(socket_cliente);
}