/**

  * 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);

 }