/**

 * GMyth Library

 *

 * @file gmyth/gmyth_vlc.c

 *

 * @brief <p> GMythVLC library provides functions that

 * interact with a VLC server running telnet interface.

 *

 * Copyright (C) 2007 INdT - Instituto Nokia de Tecnologia.

 * @author Artur Duque de Souza <artur.souza@indt.org.br>

 *

 * 

 * This program is free software; you can redistribute it and/or modify

 * it under the terms of the GNU Lesser General Public License as published by

 * the Free Software Foundation; either version 2 of the License, or

 * (at your option) any later version.

 *

 * This program is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

 * You should have received a copy of the GNU Lesser General Public License

 * along with this program; if not, write to the Free Software

 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA

 */

#ifdef HAVE_CONFIG_H

#include "config.h"

#endif

#include <assert.h>

#include "gmyth_vlc.h"

#include "gmyth_debug.h"

#include "gmyth_socket.h"

/*

 * static functions 

 */

static int      _socket_send(int socket, gchar * msg);

static int      _socket_recv(int socket, gchar * buf);

/** Primitive function to send a message through the socket

 *

 * @param socket 

 * @param msg the message itself

 * @return 0 if success

 */

static int

_socket_send(int socket, gchar * msg)

{

    size_t          size = strlen(msg) + 2; // (\n + \0)

    gchar          *final = (gchar *) g_malloc0(sizeof(gchar) * size);

    g_snprintf(final, size, "%s\n", msg);

    if (send(socket, final, strlen(final), 0) == -1)

        perror("GMyth_VLC: send error");

    g_free(final);

    return 0;

}

/** Primitive function to receive a message through the socket

 *

 * @param socket 

 * @param buf Buffer to put the message

 * @return 0 if success

 */

static int

_socket_recv(int socket, gchar * buf)

{

    int             numbytes = 0;

    if ((numbytes = recv(socket, buf, BUFFER - 1, 0)) == -1) {

        perror("GMyth_VLC: recv error");

        return -1;

    }

    buf[numbytes - 1] = '\0';

    return numbytes;

}

/** Function that adds options to the output media

 *

 * @param vlc structure with options for vlc

 * @param output the number of the output media

 * @param kind the type of option we'll change

 * @param the params for the option

 * @return 0 if success

 */

int

gmyth_vlc_setup_output(GMythVlc * vlc, int output, gchar * kind,

                       gchar * opts)

{

    int             ret;

    size_t          size = strlen(opts) + 25;

    gchar          *msg = g_malloc0(sizeof(gchar) * size);

    g_snprintf(msg, size, "setup output%d %s %s", output, kind, opts);

    ret = _socket_send(vlc->sockfd, msg);

    g_free(msg);

    return ret;

}

/** Function to clean the playlist

 *

 * @param vlc structure with options for vlc

 * @param output the number of the output media

 * @param file the file we want to insert in the playlist

 * @return 0 if success

 */

int

gmyth_vlc_clean_playlist(GMythVlc * vlc)

{

    return _socket_send(vlc->sockfd, "del all");

}

/** Function to control the playlist

 *

 * @param vlc structure with options for vlc

 * @param output the number of the output media

 * @param command play, stop or pause(just for vod)

 * @return 0 if success

 */

int

gmyth_vlc_control_input(GMythVlc * vlc, int output, gchar * command)

{

    size_t          size = 25;

    gchar          *msg = g_malloc0(sizeof(gchar) * size);

    g_snprintf(msg, size, "control output%d %s", output, command);

    int             ret = _socket_send(vlc->sockfd, msg);

    g_free(msg);

    return ret;

}

/** Function to insert an item in the playlist

 *

 * @param vlc structure with options for vlc

 * @param output the number of the output media

 * @param file the file we want to insert in the playlist

 * @return 0 if success

 */

int

gmyth_vlc_create_input(GMythVlc * vlc, int output, gchar * file)

{

    return gmyth_vlc_setup_output(vlc, output, "input", file);

}

/** Function to create a channel in vlc

 *

 * @param vlc structure with options for vlc

 * @param type the type of channel (broadcast, vod...)

 * @param port

 * @return 0 if success

 */

int

gmyth_vlc_create_channel(GMythVlc * vlc, gchar * type, int port,

                         int vcodec)

{

    int             ret;

    size_t          size = 40;

    gchar          *msg = (gchar *) g_malloc0(sizeof(gchar) * size);

    g_snprintf(msg, size, "new output%d %s enabled loop", vlc->n_outputs,

               type);

    ret = _socket_send(vlc->sockfd, msg);

    if (ret > -1) {

        gmyth_vlc_setup_output(vlc, vlc->n_outputs, "option",

                               "sout-keep=1");

        g_free(msg);

        size = 256;

        msg = (gchar *) g_malloc0(sizeof(gchar) * size);

        if (vcodec == MPEG1)

            // Best transcode option for N800 (MP1V)

            g_snprintf(msg, size, "#transcode{vcodec=mp1v,vb=384,"

                       "fps=25.0,scale=1,acodec=mpga,"

                       "ab=64,channels=1}:duplicate{dst="

                       "std{access=http,mux=mpeg1,dst=" ":%d}}", port);

        else

            // Best transcode option for N800 (THEORA)

            g_snprintf(msg, size, "#transcode{vcodec=theo,vb=384,"

                       "fps=25.0,scale=1,acodec=vorb,"

                       "ab=64,channels=1}:duplicate{dst="

                       "std{access=http,mux=ogg,dst=" ":%d}}", port);

        ret = gmyth_vlc_setup_output(vlc, vlc->n_outputs, "output", msg);

        vlc->n_outputs++;

    }

    g_free(msg);

    return ret;

}

/** Function to connect to vlc on the backend

 *

 * @param vlc structure with options for vlc

 * @param backend_info infos about the backend

 * @param passwd the password for telnet interface

 * @return 0 if success

 */

int

gmyth_vlc_connect(GMythVlc * vlc, GMythBackendInfo * backend_info,

                  gchar * passwd, int port)

{

    int             numbytes;

    if ((vlc->he = gethostbyname(backend_info->hostname)) == NULL) {

        herror("GMyth_VLC: gethostbyname error");

        return -1;

    }

    if ((vlc->sockfd = socket(PF_INET, SOCK_STREAM, 0)) == -1) {

        perror("GMyth_VLC: socket error");

        return -1;

    }

    // Socket properties

    vlc->their_addr.sin_family = AF_INET;

    vlc->their_addr.sin_port = htons(port);

    vlc->their_addr.sin_addr = *((struct in_addr *) vlc->he->h_addr);

    memset(&(vlc->their_addr.sin_zero), '\0', 8);

    if (connect(vlc->sockfd, (struct sockaddr *) &(vlc->their_addr),

                sizeof(struct sockaddr)) == -1) {

        perror("GMyth_VLC: connect error. Check VLC's telnet interface");

        return -1;

    }

    // Receive the Password's Prompt

    numbytes = _socket_recv(vlc->sockfd, vlc->buf);

    // Send the Password. We don't have to

    // care about passwords being sent in plain text

    // because telnet protocol does it.

    _socket_send(vlc->sockfd, passwd);

    // Receive the Welcome msg

    numbytes = _socket_recv(vlc->sockfd, vlc->buf);

    if (numbytes > -1)

        if (strncmp(vlc->buf, "\r\nWrong password.", 17) == 0) {

            perror("Gmyth_VLC: passwd error. Check your passwd");

            return -2;

        }

    return 0;

}

/** Function to disconnect from vlc

 *

 * @param vlc structure with options for vlc

 * @param backend_info infos about the backend

 * @return 0 if success

 */

int

gmyth_vlc_disconnect(GMythVlc * vlc)

{

    int             ret;

    ret = gmyth_vlc_clean_playlist(vlc);

    if (ret > -1) {

        vlc->n_outputs = 0;

        vlc->n_inputs = 0;

    }

    return close(vlc->sockfd);

}