#
# Author: George Paraskevopoulos (geopar@intracom-telecom.com)
#         Manuel Buil (manuel.buil@ericsson.com)
# Prepares the controller and the compute nodes for the odl-sfc testcase
#
#
# All rights reserved. This program and the accompanying materials
# are made available under the terms of the Apache License, Version 2.0
# which accompanies this distribution, and is available at
# http://www.apache.org/licenses/LICENSE-2.0
#

import os
import sys
import subprocess
import paramiko
import functest.utils.functest_logger as ft_logger

logger = ft_logger.Logger("ODL_SFC").getLogger()

try:
    FUNCTEST_REPO_DIR = os.environ['FUNCTEST_REPO_DIR']
except:
    logger.debug("FUNCTEST_REPO_DIR does not exist!!!!!")

FUNCTEST_REPO_DIR = "/home/opnfv/repos/functest"

try:
    INSTALLER_IP = os.environ['INSTALLER_IP']

except:
    logger.debug("INSTALLER_IP does not exist. We create 10.20.0.2")
    INSTALLER_IP = "10.20.0.2"

os.environ['ODL_SFC_LOG'] = "/home/opnfv/functest/results/odl-sfc.log"
os.environ['ODL_SFC_DIR'] = os.path.join(FUNCTEST_REPO_DIR,
                                         "functest/opnfv_tests/features/sfc")

command = os.environ['ODL_SFC_DIR'] + ("/server_presetup_CI.bash | "
                                       "tee -a ${ODL_SFC_LOG} "
                                       "1>/dev/null 2>&1")

output = subprocess.Popen(command, shell=True, stdout=subprocess.PIPE)

# This code is for debugging purposes
# for line in iter(output.stdout.readline, ''):
#    i = line.rstrip()
#    print(i)

# Make sure the process is finished before checking the returncode
if not output.poll():
    output.wait()

# Get return value
if output.returncode:
    print("The presetup of the server did not work")
    sys.exit(output.returncode)

logger.info("The presetup of the server worked ")

ssh_options = "-o UserKnownHostsFile=/dev/null -o StrictHostKeyChecking=no"
ssh = paramiko.SSHClient()
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())

try:
    ssh.connect(INSTALLER_IP, username="root",
                password="r00tme", timeout=2)
    command = "fuel node | grep compute | awk '{print $10}'"
    logger.info("Executing ssh to collect the compute IPs")
    (stdin, stdout, stderr) = ssh.exec_command(command)
except:
    logger.debug("Something went wrong in the ssh to collect the computes IP")

output = stdout.readlines()
for ip in output:
    command = os.environ['ODL_SFC_DIR'] + ("/compute_presetup_CI.bash "
                                           "" + ip.rstrip() + "| tee -a "
                                           "${ODL_SFC_LOG} 1>/dev/null 2>&1")

    output = subprocess.Popen(command, shell=True, stdout=subprocess.PIPE)

# This code is for debugging purposes
#    for line in iter(output.stdout.readline, ''):
#        print(line)
#        sys.stdout.flush()

    output.stdout.close()

    if not (output.poll()):
        output.wait()

    # Get return value
    if output.returncode:
        print("The compute config did not work on compute %s" % ip)
        sys.exit(output.returncode)

sys.exit(0)