/*

    Terminal Mixer - multi-point multi-user access to terminal applications

    Copyright (C) 2007  Lluís Batlle i Rossell

    Please find the license in the provided COPYING file.

*/

#include <unistd.h>

#include <stdlib.h>

#include <assert.h>

#include <string.h>

#include <sys/socket.h>

#include "main.h"

char *stream_buffer = 0;

char *ostream_buffer = 0;

char *ostream_buffer2 = 0;

int stream_buffer_size;

int ostream_buffer_size;

int ostream_buffer2_size;

void init_stream_buffers()

{

    if (stream_buffer == 0)

    {

        int eth_buf;

        assert(command_line.buffer_size > 0);

        stream_buffer_size = command_line.buffer_size;

#ifdef linux

        if ((command_line.is_server && command_line.s_param.serve_eth)

                || (!command_line.is_server && command_line.c_param.transport == ETHERNET))

        {

            eth_buf = eth_proto_max_send();

            stream_buffer_size = min(command_line.buffer_size, eth_buf);

        }

#endif

        stream_buffer = (char *) malloc(stream_buffer_size);

        ostream_buffer_size = stream_buffer_size;

        ostream_buffer = (char *) malloc(ostream_buffer_size);

        ostream_buffer2_size = stream_buffer_size;

        ostream_buffer2 = (char *) malloc(ostream_buffer_size);

    }

}

static void send_xterm_resize_string_to_socket(int s)

{

    char *term;

    term = getenv("TERM");

    /* I prefer it to send the xterm string always. */

    if (1 || term == 0 || strcmp(term, "xterm") == 0)

    {

        char *xterm_str;

        xterm_str = get_xterm_resize_string();

          hex_dump("xterm_resize", xterm_str, strlen(xterm_str));

        send(s, xterm_str, strlen(xterm_str), 0);

        hex_dump("xterm string sent", xterm_str, strlen(xterm_str));

    }

}

static void telnet_send_noecho(int s)

{

  char seq[] = { 255 /*IAC*/, 251 /*WILL*/, 1 /*ECHO*/ };

  hex_dump("telnet_send_noecho", seq, sizeof seq);

  send(s, seq, sizeof seq, 0);

}

static void telnet_send_suppress_go_ahead(int s)

{

  char seq[] = { 255 /*IAC*/, 251 /*WILL*/, 3 /*ECHO*/ };

  hex_dump("telnet_send_suppress_go_ahead", seq, sizeof seq);

  send(s, seq, sizeof seq, 0);

}

void welcome_new_client_socket(int s)

{

    if (command_line.s_param.run_in_subterminal)

    {

        telnet_send_noecho(s);

        telnet_send_suppress_go_ahead(s);

    }

    if (command_line.s_param.send_xterm_resize)

        send_xterm_resize_string_to_socket(s);

}