'''

  # 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()