/*
    stdin mix - a mixer/multiplexer for stdin to processes
    Copyright (C) 2007  Lluís Batlle i Rossell

    Please find the license in the provided COPYING file.
*/
#include <stdlib.h>
#include <sys/un.h>
#include <sys/socket.h>

#include "main.h"

static char socket_path[256];
static char default_path_prefix[] = "/tmp/socket-sm.";

static void get_path()
{
    char *new;
    
    new = getenv("SM_SOCKET");
    if (new == 0)
    {
        char num[20];
        snprintf(socket_path, sizeof(socket_path), "%s%i",
                default_path_prefix, (int) getuid());
    } else
        strncpy(socket_path, new, sizeof(socket_path));
}

int serve_socket()
{
    int ls;
    struct sockaddr_un addr;
    int res;

    get_path();

    ls = socket(AF_UNIX, SOCK_STREAM, 0);
    if (ls == -1)
        error("Cannot create the unix listen socket in the server");

    addr.sun_family = AF_UNIX;
    strncpy(addr.sun_path, socket_path, sizeof(addr.sun_path));

    res = bind(ls, (struct sockaddr *) & addr, sizeof(addr));
    if (res == -1)
        error("Error binding to %s", socket_path);

    res = listen(ls, 10);
    if (res == -1)
        error("Error listening on the binded unix socket");

    return ls;
}

int accept_connection(int ls)
{
    int cs;
    cs = accept(ls, 0, 0);
    return cs;
}

int connect_socket()
{
    struct sockaddr_un addr;
    int res;
    int cs;

    get_path();

    cs = socket(AF_UNIX, SOCK_STREAM, 0);
    if (cs == -1)
        error("Cannot create the unix connect socket in the client");

    addr.sun_family = AF_UNIX;
    strncpy(addr.sun_path, socket_path, sizeof(addr.sun_path));

    res = connect(cs, (struct sockaddr *) &addr, sizeof(addr));
    if (res == -1)
        error("Cannot connect to %s", socket_path);
    return cs;
}

void remove_socket(int ls)
{
    close(ls);
    unlink(socket_path);
}