#!/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...")