#!/usr/bin/python

import os
import lib
import sys
import ConfigParser

config = ConfigParser.ConfigParser()
config.read("stream.conf")

media_plugin = config.get("Media", "engine")
exec("from plugins.media.%s import *" % media_plugin)

media = Media(config)

comm_plugin = config.get("Comm", "engine")
exec("from plugins.comm.%s import *" % comm_plugin)

# Start Our Server:
server = Server(config)

lib.log("Starting GMyth-Stream server")


'''
PROTOCOL DESCRIPTION
=====================

COMMAND OPTIONS

-> SETUP DESCRIPTION
|-> used to setup transcoding and streaming parameters
|-> must be used before any "PLAY" command
|-> e.g:

file://file_name mux vcodec vbitrate fps acodec abitrate width height options
dvd://title_number mux vcodec vbitrate fps acodec abitrate width height options

-> PLAY DESCRIPTION
 |-> used to start transcoding and streaming of file
 |-> must be used just if SETUP was used before
 |-> after it, _must_ send STOP

-> STOP DESCRIPTION
 |-> used to stop transcoding and streaming process
 |-> must be used just if PLAY was used before
 |-> must be used after PLAY

-> QUIT DESCRIPTION
 |-> used to quit the main loop (quit program)

'''
nextport = 0

while (server.finish == 0):
    conn, client, port = server.getRequest()
    server.sendMsg("Welcome to GMyth-Streamer Master")
    if nextport == 0:
        nextport = port

    while True:
        msg = server.getMsg(1024).strip()

        if not msg: break

        lib.log("Received %s from: %s" % (msg, client) )

        if msg == "SETUP":
            setup = server.getMsg(1024).strip().split(" ")
            size = len(setup)
            options = []

            if size < 10:
                server.sendMsg(lib.log("Wrong SETUP command from: %s" % client[0]))

            else:

                if size > 10:
                    i = 10
                    while (i < size):
                        options.append(setup[i])
                        i += 1

                nextport += 1
                ret = media.setup(setup[0], setup[1], setup[2], \
                                  setup[3], setup[4], setup[5],
                                  setup[6], setup[7], setup[8],
                                  nextport, options)

                if ret == 0:
                    server.Ack("SETUP")
                else:
                    server.sendMsg(lib.log(ret))


        elif msg == "PLAY":
            media.play()
            server.Ack("PLAY")
            server.sendMsg("STREAM PORT=%d" % nextport)

        elif msg == "STOP":
            media.stop()
            server.Ack("STOP")

        elif msg == "QUIT":
            server.finish = 1
            media.stop()
            server.Ack("QUIT")
            break

    lib.log("Closing connection with %s" % client[0])
    server.disconnect_client(conn)

server.stop()
del(server)
lib.log("Server stopped. Closing...")