#!/usr/bin/env python3
import xmlrpc.client
import traceback
import socket
import time
import sys
import os

import renderlib
import c3t_rpc_client as rpc

try:
    from termcolor import colored
except ImportError:
    def colored(str, col):
        return str

print("C3TT preroll generator")
renderlib.debug = True

if os.environ.get('CRS_TOKEN') is None or os.environ.get('CRS_SECRET') is None:
    print('CRS_TOKEN or CRS_SECRET is empty. did you source the tracker-scripts-profile?')
    sys.exit(1)

ticket_type = 'recording'
ticket_state = 'generating'

host = socket.getfqdn()
url = os.environ['CRS_TRACKER']
token = os.environ['CRS_TOKEN']
secret = os.environ['CRS_SECRET']

filter = {}
if not os.environ.get('CRS_ROOM') is None:
    filter['Fahrplan.Room'] = os.environ['CRS_ROOM']

projects = {}


def generatePreroll(ticket):
    print(ticket)
    projectname = ticket.get('Processing.Prerolls.Slug', ticket['Meta.Acronym'])
    if not projectname in projects:
        projects[projectname] = renderlib.loadProject(projectname)

    project = projects[projectname]
    task = project.ticket(ticket)
    task.outfile = os.path.join(ticket['Processing.Path.Intros'], ticket['Fahrplan.ID'] + '.dv')
    task.workdir = os.path.join(os.getcwd(), projectname, 'artwork')

    print(colored("rendering", 'green'))
    renderlib.rendertask(task)

    if hasattr(project, 'deploy'):
        print(colored("deploying", 'green'))
        project.deploy(ticket, task)


while True:
    print(colored(
        'Asking RPC for {0}-tickets which are ready for state {1}'.format(ticket_type, ticket_state), 'yellow'))

    ticket_id = rpc.assignNextUnassignedForState(
        ticket_type, ticket_state, url, token, host, secret, filter)
    if ticket_id != False:
        ticket = rpc.getTicketProperties(str(ticket_id), url, token, host, secret)
        try:
            generatePreroll(ticket)
            rpc.setTicketDone(str(ticket_id), url, token, host, secret)
        except:
            error = str(traceback.format_exc())
            print(colored(error, 'red'))
            rpc.setTicketFailed(str(ticket_id), error, url, token, host, secret)

    else:
        print('No ticket found')

    print('Sleeping for 30 seconds')
    time.sleep(30)