import ConfigParser
import json
import os
import requests
import sys
import uuid
import time


config = ConfigParser.RawConfigParser()
__file__ = os.path.join(sys.path[0], sys.argv[1])
config.read(__file__)

plugin = config.get('manager', 'plugin')
ip = config.get('manager', 'ip')
port = config.get('manager', 'port')
cluster_size = config.getint('manager', 'cluster_size')
flavor_id = config.get('manager', 'flavor_id')
image_id = config.get('manager', 'image_id')
bigsea_username = config.get('manager', 'bigsea_username')
bigsea_password = config.get('manager', 'bigsea_password')

opportunistic = config.get('plugin', 'opportunistic')
dependencies = config.get('plugin', 'dependencies')
args = config.get('plugin', 'args').split()
main_class = config.get('plugin', 'main_class')
job_template_name = config.get('plugin', 'job_template_name')
job_binary_name = config.get('plugin', 'job_binary_name')
job_binary_url = config.get('plugin', 'job_binary_url')
input_ds_id = ''
output_ds_id = ''
plugin_app = config.get('plugin', 'plugin_app')
expected_time = config.getint('plugin', 'expected_time')
collect_period = config.getint('plugin', 'collect_period')
openstack_plugin = config.get('plugin', 'openstack_plugin')
job_type = config.get('plugin', 'job_type')
version = '2.1.0'
cluster_id = config.get('plugin', 'cluster_id')
slave_ng = config.get('plugin', 'slave_ng')
opportunistic_slave_ng = config.get('plugin', 'opportunistic_slave_ng')
master_ng = config.get('plugin', 'master_ng')
net_id = config.get('plugin', 'net_id')
actuator = config.get('scaler', 'actuator')
starting_cap = config.get('scaler', 'starting_cap')

scaler_plugin = config.get('scaler', 'scaler_plugin')
scaling_parameters = {}
scaling_parameters['actuator'] = config.get('scaler', 'actuator')
scaling_parameters['metric_source'] = config.get('scaler', 'metric_source')
scaling_parameters['application_type'] = config.get('scaler', 'application_type')
scaling_parameters['check_interval'] = config.getint('scaler', 'check_interval')
scaling_parameters['trigger_down'] = config.getint('scaler', 'trigger_down')
scaling_parameters['trigger_up'] = config.getint('scaler', 'trigger_up')
scaling_parameters['min_cap'] = config.getint('scaler', 'min_cap')
scaling_parameters['max_cap'] = config.getint('scaler', 'max_cap')
scaling_parameters['actuation_size'] = config.getint('scaler', 'actuation_size')
scaling_parameters['metric_rounding'] = config.getint('scaler', 'metric_rounding')

headers = {'Content-Type': 'application/json'}
body = dict(plugin=plugin, scaler_plugin=scaler_plugin,
    scaling_parameters=scaling_parameters, cluster_size=cluster_size,
    starting_cap=starting_cap, actuator=actuator,
    flavor_id=flavor_id, image_id=image_id, opportunistic=opportunistic,
    args=args, main_class=main_class, job_template_name=job_template_name,
    job_binary_name=job_binary_name, job_binary_url=job_binary_url,
    input_ds_id=input_ds_id, output_ds_id=output_ds_id,
    plugin_app=plugin_app, expected_time=expected_time,
    collect_period=collect_period, bigsea_username=bigsea_username,
    bigsea_password=bigsea_password, openstack_plugin=openstack_plugin,
    job_type=job_type, version=version, opportunistic_slave_ng=opportunistic_slave_ng,
    slave_ng=slave_ng, master_ng=master_ng, net_id=net_id, dependencies=dependencies
    )
url = "http://%s:%s/manager/execute" % (ip, port)
print "Making request to", url
body_log = body.copy()
r = requests.post(url, headers=headers, data=json.dumps(body))
print "Application id: %s" % r.content

url_status = "http://%s:%s/manager/status" % (ip, port)
url_execution_log = "http://%s:%s/manager/execution_log" % (ip, port)
print "Running application"

old_status = []
f = open("app.log", "w")
while(True):
    r_status = requests.get(url_status)

    for line in r_status.json():
        if line not in old_status:
            print str(line)
            f.write(str(line)+"\n")
            old_status.append(line)
        if "Finished" in line:
            std = requests.get(url_execution_log).json()

            err = open("stderr", "w")
            err.write(str(std[1]))
            err.close()

            out = open("stdout", "w")
            out.write(str(std[0]))
            out.close()

            f.close()

            print "See stderr and stdout files to more details of application execution"

            exit()

    time.sleep(20)