/*

    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 <unistd.h>

#include <sys/types.h>

#include <sys/select.h>

#include "main.h"

#include "handlers.h"

#include "filter.h"

static int myfd = -1;

extern struct FilterRules *client_recv_fr;

void c_eth_init()

{

    eth_proto_init();

    myfd = eth_proto_open(ETH_CLIENT);

    if (myfd < 0)

        error("Cannot eth_proto_open");

}

void c_eth_shutdown()

{

    if (myfd >= 0)

        close(myfd);

}

void c_eth_prepare_read_fdset(fd_set *read_set, int *maxfd)

{

    FD_SET(myfd, read_set);

    *maxfd = max(*maxfd, myfd);

    if (!eth_proto_allow_sending())

        avoid_sending(read_set);

}

/* Send -1 on eof */

int c_eth_process_read_fdset(fd_set *read_set)

{

    if (FD_ISSET(myfd, read_set))

    {

        int res;

        int olen;

        res = eth_proto_recv(stream_buffer, stream_buffer_size);

        if (res < 0)

            return 1; /* ignore it */

        if (res == 0) /* EOF */

        {

            filter_flush(client_recv_fr, ostream_buffer, &olen);

            if (olen > 0)

                send_to_client_stdout(ostream_buffer, olen);

            return -1;

        }

        hex_dump("recv_unix_client",stream_buffer, res);

        filter_stream(client_recv_fr, ostream_buffer, &olen, stream_buffer,

                res);

        if (olen > 0)

            send_to_client_stdout(ostream_buffer, olen);

    }

    return 0;

}

void c_eth_send_to_connected(const char *buffer, size_t size)

{

    eth_proto_send(buffer, size);

}