'''

 # GMyth-Stream

 #

 # @file plugins/comm/xmlrpc.py

 #

 # @brief <p> Plugin for GMyth-Stream

 #

 # 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

 #

 '''

import SimpleXMLRPCServer

class Handler:

    def __init__(self, pool):

        self.pool = pool

    def _listMethods(self):

        return ['Setup', 'Play', 'Stop', 'Close']

    def _methodHelp(self, method):

        if method == 'Setup':

            return "Setup the Media: Setup(filename,codec,bitrate,widht,height,port)"

        elif method == 'Play':

            return "Play the Media: Play()"

        elif method == 'Stop':

            return "Stop the Media: Stop()"

        elif method == 'Close':

            return "Close the connection: Close()"

        else:

            # By convention, return empty

            # string if no help is available

            return ""

    def Setup(self, filename, codec, bitrate, width, height, port):

        self.pool.append("SETUP")

        self.pool.append("%s %s %s %s %s %s" % (filename, codec, bitrate,\

                                             width, height, port))

        return 0

    def Play(self):

        self.pool.append("PLAY")

        return 0

    def Stop(self):

        self.pool.append("STOP")

        return 0

    def Close(self):

        self.pool.append("CLOSE")

        return 0

class Server:

    def __init__(self, config):

        self.host = 'localhost'

        self.port = int(config.get("Comm", "port"))

        self.finish = 0

        self.pool = []

        self.handler = Handler(self.pool)

        self.xmlrpc = SimpleXMLRPCServer.SimpleXMLRPCServer((self.host, self.port))

        self.xmlrpc.register_instance(self.handler)

    def getMsg(self, size):

        try:

            return self.pool.pop(0)

        except IndexError:

            return ""

    def getRequest(self):

        self.xmlrpc.handle_request()

        return (0, "RPC Client")

    def disconnect_client(self, connection):

        connection = 0

    def stop(self):

        self.xmlrpc.server_close()