import os
import sys
import subprocess
import pickle
from .utils import format_return, insert_list, docker_error, get_mdi_standard, get_compose_path, get_package_path, get_mdimechanic_yaml

# Paths to enter each identified node
node_paths = { "@DEFAULT": "" }

# Paths associated with the edges for the node graph
node_edge_paths = [ ("@DEFAULT", "") ]

# Use MPI for the tests
use_mpi = False

def docker_up( base_path, docker_path ):
    mdimechanic_yaml = get_mdimechanic_yaml( base_path )

    # Create the docker environment
    docker_env = os.environ
    docker_env['MDIMECH_WORKDIR'] = base_path
    docker_env['MDIMECH_PACKAGEDIR'] = get_package_path()
    docker_env['MDIMECH_ENGINE_NAME'] = mdimechanic_yaml['docker']['image_name']

    # Run "docker-compose up -d"
    up_proc = subprocess.Popen( ["docker-compose", "up", "-d"],
                                stdout=subprocess.PIPE, stderr=subprocess.PIPE,
                                cwd=docker_path, env=docker_env )
    up_tup = up_proc.communicate()
    up_out = format_return(up_tup[0])
    up_err = format_return(up_tup[1])
    return up_proc.returncode

def docker_down( base_path, docker_path ):
    # Create the docker environment
    docker_env = os.environ
    docker_env['MDIMECH_WORKDIR'] = base_path
    docker_env['MDIMECH_PACKAGEDIR'] = get_package_path()

    # Run "docker-compose down"
    down_proc = subprocess.Popen( ["docker-compose", "down"],
                                  stdout=subprocess.PIPE, stderr=subprocess.PIPE,
                                  cwd=docker_path, env=docker_env )
    down_tup = down_proc.communicate()
    down_out = format_return(down_tup[0])
    down_err = format_return(down_tup[1])
    return down_proc.returncode


def test_command( base_path, command, nrecv, recv_type, nsend, send_type ):
    global use_mpi

    # Remove any leftover files from previous runs of min_driver.py
    #base_path = get_base_path()
    dat_file = os.path.join( base_path, ".mdimechanic", ".temp", "min_driver.dat" )
    err_file = os.path.join( base_path, ".mdimechanic", ".temp", "min_driver.err" )
    if os.path.exists( dat_file ):
        os.remove( dat_file )
    if os.path.exists( err_file ):
        os.remove( err_file )

    if use_mpi:
        mdi_driver_options = "-role DRIVER -name driver -method MPI"
        mdi_engine_options = "-role ENGINE -name TESTCODE -method MPI"
        docker_path = get_compose_path( "mpi" )
    else:
        mdi_driver_options = "-role DRIVER -name driver -method TCP -port 8021"
        mdi_engine_options = "-role ENGINE -name TESTCODE -method TCP -hostname mdi_mechanic -port 8021"
        docker_path = get_compose_path( "tcp" )

    # Create the script for MDI Mechanic
    docker_file = os.path.join( base_path, ".mdimechanic", ".temp", "docker_mdi_mechanic.sh" )
    docker_lines = [ "#!/bin/bash\n",
                     "\n",
                     "# Exit if any command fails\n",
                     "\n",
                     "cd /MDI_Mechanic/mdimechanic/drivers\n",
                     "python min_driver.py \\\n"
    ]
    if command is not None:
        docker_lines.append( "   -command \'" + str(command) + "\' \\\n" )
    if nrecv is not None:
        docker_lines.append( "   -nreceive \'" + str(nrecv) + "\' \\\n" )
    if recv_type is not None:
        docker_lines.append( "   -rtype \'" + str(recv_type) + "\' \\\n" )
    if nsend is not None:
        docker_lines.append( "   -nsend \'" + str(nsend) + "\' \\\n" )
    if send_type is not None:
        docker_lines.append( "   -stype \'" + str(send_type) + "\' \\\n" )
    docker_lines.append( "   -mdi \"" + str(mdi_driver_options) + "\"\n" )
    os.makedirs(os.path.dirname(docker_file), exist_ok=True)
    with open(docker_file, 'w') as file:
        file.writelines( docker_lines )

    mdimechanic_yaml = get_mdimechanic_yaml( base_path )
    script_lines = mdimechanic_yaml['engine_tests'][0]['script']
    script = "#!/bin/bash\nset -e\ncd /repo\n"
    script += "export MDI_OPTIONS=\'" + str(mdi_engine_options) + "\'\n"
    for line in script_lines:
        script += line + '\n'

    # Write the script to run the test
    script_path = os.path.join( base_path, ".mdimechanic", ".temp", "docker_mdi_engine.sh" )
    os.makedirs(os.path.dirname(script_path), exist_ok=True)
    with open(script_path, "w") as script_file:
        script_file.write( script )



    if use_mpi:

        # Start the docker container
        if docker_up( base_path, docker_path ) != 0:
            raise Exception("Unable to start docker-compose")

        # Create the docker environment
        docker_env = os.environ
        docker_env['MDIMECH_WORKDIR'] = base_path
        docker_env['MDIMECH_PACKAGEDIR'] = get_package_path()
        docker_env['MDIMECH_ENGINE_NAME'] = mdimechanic_yaml['docker']['image_name']

        # Run "docker-compose exec"
        exec_proc = subprocess.Popen( ["docker-compose", "exec", "-T", "--user", "mpiuser", "mdi_mechanic", "mpiexec", "-app", "/MDI_Mechanic/mdimechanic/docker/mpi/mdi_appfile"],
                                      stdout=subprocess.PIPE, stderr=subprocess.PIPE,
                                      cwd=docker_path, env=docker_env )
        exec_tup = exec_proc.communicate()
        exec_out = format_return(exec_tup[0])
        exec_err = format_return(exec_tup[1])
        if exec_proc.returncode != 0:
            print("FAILED", flush=True)
            docker_down( base_path, docker_path )
            return False

    else:

        # Create the docker environment
        docker_env = os.environ
        docker_env['MDIMECH_WORKDIR'] = base_path
        docker_env['MDIMECH_PACKAGEDIR'] = get_package_path()
        docker_env['MDIMECH_ENGINE_NAME'] = mdimechanic_yaml['docker']['image_name']

        # Run the docker container
        up_proc = subprocess.Popen( ["docker-compose", "up", "--exit-code-from", "mdi_mechanic", "--abort-on-container-exit"],
                                    stdout=subprocess.PIPE, stderr=subprocess.PIPE,
                                    cwd=docker_path, env=docker_env )
        up_tup = up_proc.communicate()
        up_out = format_return(up_tup[0])
        up_err = format_return(up_tup[1])
        if up_proc.returncode != 0:
            print("FAILED", flush=True)
            docker_down( base_path, docker_path )
            return False



    if docker_down( base_path, docker_path ) != 0:
        print("FAILED", flush=True)
        return False


    print("WORKED", flush=True)
    return True



def find_nodes( base_path ):
    global node_paths
    global node_edge_paths
    
    # List of all node commands in the MDI Standard
    command_list = []
    commands = None
    
    #base_path = get_base_path()
    standard = get_mdi_standard( base_path )
    commands = standard['commands']
    
    for command in commands:
        if command[0] == '@' and command != '@':
            command_list.append( command )
    ordered_commands = sorted( command_list )
    ####################
    #return
    ####################

    # Check which of the MDI Standard commands work from the @DEFAULT node
    for command in ordered_commands:
        command_works = test_command( base_path, command, None, None, None, None )
        if command_works:
            node_paths[command] = command
            node_edge_paths.append( (command, command) )
    
    # From the nodes that have currently been identified, attempt to use the "@" command to identify more nodes
    print("Searching for supported nodes", flush=True)
    original_nodes = []
    for node in node_paths.keys():
        original_nodes.append(node)
    ordered_nodes = sorted( original_nodes )
    for node in ordered_nodes:
        for ii in range(20):
            new_path = node_paths[node]
            for jj in range(ii+1):
                new_path += " @"
            command = new_path + " <@"
            print("Checking for node at: " + str(new_path), end=" ")
            command_works = test_command( base_path, command, "MDI_COMMAND_LENGTH", "MDI_CHAR", None, None )
        
            # Read the name of the node
            node_name = None
            dat_file = os.path.join( base_path, ".mdimechanic", ".temp", "min_driver.dat" )
            err_file = os.path.join( base_path, ".mdimechanic", ".temp", "min_driver.err" )
            if os.path.isfile( dat_file ):
                with open( dat_file, "r") as f:
                    node_name = f.read()
            err_value = None
            if os.path.isfile( err_file ):
                with open( err_file, "r") as f:
                    err_value = f.read()
                
            if node_name is not None and not node_name in node_paths.keys():
                node_paths[node_name] = new_path

            # Check whether this should be added to the node graph
            if node_name is not None:
                split_path = new_path.split()
                include = True
                for node_edge in node_edge_paths:
                    if node_edge[0] == node_name:
                        path = node_edge[1].split()
                        if path[0] == split_path[0]:
                            include = False

                if include:
                    node_edge_paths.append( (node_name, new_path) )

    print("Completed search for nodes.", flush=True)
    print("Found the following nodes: " + str(node_paths.keys()) )

def write_supported_commands( base_path ):
    global node_paths
    
    # List of all commands in the MDI Standard
    command_list = []
    commands = None
    
    #base_path = get_base_path()
    standard = get_mdi_standard( base_path )
    commands = standard['commands']
    
    for command in commands.keys():
        values = commands[command]
        command_list.append( command )
    ordered_commands = sorted( command_list )

    # Identify all supported nodes, and find a path to them
    find_nodes( base_path )
    ordered_nodes = sorted( node_paths.keys() )
    
    # Write the README.md section that lists all supported commands
    command_sec = []

    # Write the section header
    command_sec.append( "## Supported Commands\n" )
    command_sec.append( "\n" )
    header_line = "| "
    for node in ordered_nodes:
        header_line += "| " + str(node) + " "
    header_line += "|\n"
    command_sec.append( header_line )
    header_line = "| ------------- "
    for node in ordered_nodes:
        header_line += "| ------------- "
    header_line += "|\n"
    command_sec.append( header_line )

    # Write the list of supported commands
    for command in ordered_commands:
        nrecv = None
        recv_type = None
        nsend = None
        send_type = None
        print("---------------------------------------")
        print("Testing command: " + str(command))
        if commands[command] is not None and 'recv' in commands[command].keys():
            nrecv = commands[command]['recv']['count']
            recv_type = commands[command]['recv']['datatype']
        if commands[command] is not None and 'send' in commands[command].keys():
            nsend = commands[command]['send']['count']
            send_type = commands[command]['send']['datatype']
        
        line = "| " + str(command) + " "
        for node in ordered_nodes:
            command_with_path = node_paths[node] + " " + command
            padded_string = str(node).ljust(20, '.')
            print(padded_string, end=" ")
            command_works = test_command( base_path, command_with_path, nrecv, recv_type, nsend, send_type )
        
            if command_works:
                # Display a bright green box
                command_status = "![command](report/badges/box-brightgreen.svg)"
            else:
                # Display a light gray box
                command_status = "![command](report/badges/box-lightgray.svg)"

            line += "| " + str(command_status) + " "
        line += "|\n"
        command_sec.append( line )

    # Replace all ">" or "<" symbols with Markdown escape sequences
    for iline in range(len(command_sec)):
        line = command_sec[iline]
        line = line.replace(">", "&gt;")
        line = line.replace("<", "&lt;")
        command_sec[iline] = line
        
    return command_sec

def node_graph( base_path ):
    global node_edge_paths

    print("*********************************************")
    print("* Creating node graph                       *")
    print("*********************************************")

    print("node_edge_paths: " + str(node_edge_paths))

    package_path = get_package_path()

    nodes = {}
    edges = []
    for edge_path in node_edge_paths:
        name = edge_path[0]
        path = edge_path[1].split()
        if '@' in path:
            parent_cluster = str(path[0]) + '_'
            if not parent_cluster in nodes.keys():
                nodes[ parent_cluster ] = str(name)
                edges.append( ( path[0], parent_cluster ) )
            else:
                nodes[ parent_cluster ] += '\n' + str(name)
        else:
            nodes[ name ] = name
            if name != '@DEFAULT':
                edges.append( ( '@DEFAULT', name ) )
    print("nodes: " + str(nodes))

    # Save the graph data to a file
    graph_data = { 'nodes': nodes,
                   'edges': edges }
    graph_file = os.path.join( base_path, ".mdimechanic", ".temp", "graph.pickle")
    os.makedirs(os.path.dirname(graph_file), exist_ok=True)
    with open(graph_file, 'wb') as handle:
        pickle.dump(graph_data, handle, protocol=min(pickle.HIGHEST_PROTOCOL, 4))

    # Graph script
    graph_script = '''
import os
import pickle
from graphviz import Digraph

# Read the data required to make the graph
#graph_file = os.path.join( \'/repo\', \'.mdimechanic\', \'.temp\', \'graph.pickle\')
graph_file = \'/repo/.mdimechanic/.temp/graph.pickle\'

with open(graph_file, 'rb') as handle:
    data = pickle.load(handle)
nodes = data['nodes']
edges = data['edges']

dot = Digraph(comment='Node Report', format='svg')

node_list = []
for node in nodes.keys():
    node_list.append( node )
ordered_nodes = sorted( node_list )
    
for node in ordered_nodes:
    dot.node( node, nodes[ node ], shape='box', margin='0.1' )

for edge in edges:
    dot.edge( edge[0], edge[1] )

#graph_path = os.path.join( base_path, "report", "graphs", "node-report.gv" )
graph_path = '/repo/report/graphs/node-report.gv'
dot.render( graph_path )
'''

    # Render the graph within a docker image, so that it is consistent across machines
    graph_proc = subprocess.Popen( ["docker", "run", "--rm",
                                    "-v", str(base_path) + ":/repo",
                                    "-v", str(package_path) + ":/MDI_Mechanic",
                                    "mdi_mechanic/mdi_mechanic",
                                    "bash", "-c",
                                    "cd /MDI_Mechanic/mdimechanic/utils && python -c \"" + graph_script + "\""],
                                   stdout=subprocess.PIPE, stderr=subprocess.PIPE)
    graph_tup = graph_proc.communicate()
    if graph_proc.returncode != 0:
        docker_error( graph_tup, "Graph process returned an error." )

def analyze_nodes( base_path ):
    #package_path = get_package_path()

    # Read the README.md file
    readme_path = os.path.join(base_path, "README.md")
    with open(readme_path, "r") as file:
        readme = file.readlines()

    # Check the README.md file for any comments for travis
    for iline in range(len(readme)):
        line = readme[iline]
        sline = line.split()
        if len(sline) > 0 and sline[0] == '[travis]:':
            instruction = sline[3]

            if instruction == "supported_commands":
                # Need to insert a list of supported commands here
                command_sec = write_supported_commands( base_path )
                insert_list( readme, command_sec, iline )

    # Write the updates to the README file
    temp_file = os.path.join( base_path, '.mdimechanic', '.temp', 'README.temp')
    os.makedirs(os.path.dirname(temp_file), exist_ok=True)
    with open(temp_file, 'w') as file:
        file.writelines( readme )

    # Create the node graph
    node_graph( base_path )

import os
import sys
import subprocess
import pickle
from .utils import format_return, insert_list, docker_error, get_mdi_standard, get_compose_path, get_package_path, get_mdimechanic_yaml

# Paths to enter each identified node
node_paths = { "@DEFAULT": "" }

# Paths associated with the edges for the node graph
node_edge_paths = [ ("@DEFAULT", "") ]

# Use MPI for the tests
use_mpi = False

def docker_up( base_path, docker_path ):
    mdimechanic_yaml = get_mdimechanic_yaml( base_path )

    # Create the docker environment
    docker_env = os.environ
    docker_env['MDIMECH_WORKDIR'] = base_path
    docker_env['MDIMECH_PACKAGEDIR'] = get_package_path()
    docker_env['MDIMECH_ENGINE_NAME'] = mdimechanic_yaml['docker']['image_name']

    # Run "docker-compose up -d"
    up_proc = subprocess.Popen( ["docker-compose", "up", "-d"],
                                stdout=subprocess.PIPE, stderr=subprocess.PIPE,
                                cwd=docker_path, env=docker_env )
    up_tup = up_proc.communicate()
    up_out = format_return(up_tup[0])
    up_err = format_return(up_tup[1])
    return up_proc.returncode

def docker_down( base_path, docker_path ):
    # Create the docker environment
    docker_env = os.environ
    docker_env['MDIMECH_WORKDIR'] = base_path
    docker_env['MDIMECH_PACKAGEDIR'] = get_package_path()

    # Run "docker-compose down"
    down_proc = subprocess.Popen( ["docker-compose", "down"],
                                  stdout=subprocess.PIPE, stderr=subprocess.PIPE,
                                  cwd=docker_path, env=docker_env )
    down_tup = down_proc.communicate()
    down_out = format_return(down_tup[0])
    down_err = format_return(down_tup[1])
    return down_proc.returncode


def test_command( base_path, command, nrecv, recv_type, nsend, send_type ):
    global use_mpi

    # Remove any leftover files from previous runs of min_driver.py
    #base_path = get_base_path()
    dat_file = os.path.join( base_path, ".mdimechanic", ".temp", "min_driver.dat" )
    err_file = os.path.join( base_path, ".mdimechanic", ".temp", "min_driver.err" )
    if os.path.exists( dat_file ):
        os.remove( dat_file )
    if os.path.exists( err_file ):
        os.remove( err_file )

    if use_mpi:
        mdi_driver_options = "-role DRIVER -name driver -method MPI"
        mdi_engine_options = "-role ENGINE -name TESTCODE -method MPI"
        docker_path = get_compose_path( "mpi" )
    else:
        mdi_driver_options = "-role DRIVER -name driver -method TCP -port 8021"
        mdi_engine_options = "-role ENGINE -name TESTCODE -method TCP -hostname mdi_mechanic -port 8021"
        docker_path = get_compose_path( "tcp" )

    # Create the script for MDI Mechanic
    docker_file = os.path.join( base_path, ".mdimechanic", ".temp", "docker_mdi_mechanic.sh" )
    docker_lines = [ "#!/bin/bash\n",
                     "\n",
                     "# Exit if any command fails\n",
                     "\n",
                     "cd /MDI_Mechanic/mdimechanic/drivers\n",
                     "python min_driver.py \\\n"
    ]
    if command is not None:
        docker_lines.append( "   -command \'" + str(command) + "\' \\\n" )
    if nrecv is not None:
        docker_lines.append( "   -nreceive \'" + str(nrecv) + "\' \\\n" )
    if recv_type is not None:
        docker_lines.append( "   -rtype \'" + str(recv_type) + "\' \\\n" )
    if nsend is not None:
        docker_lines.append( "   -nsend \'" + str(nsend) + "\' \\\n" )
    if send_type is not None:
        docker_lines.append( "   -stype \'" + str(send_type) + "\' \\\n" )
    docker_lines.append( "   -mdi \"" + str(mdi_driver_options) + "\"\n" )
    os.makedirs(os.path.dirname(docker_file), exist_ok=True)
    with open(docker_file, 'w') as file:
        file.writelines( docker_lines )

    mdimechanic_yaml = get_mdimechanic_yaml( base_path )
    script_lines = mdimechanic_yaml['engine_tests'][0]['script']
    script = "#!/bin/bash\nset -e\ncd /repo\n"
    script += "export MDI_OPTIONS=\'" + str(mdi_engine_options) + "\'\n"
    for line in script_lines:
        script += line + '\n'

    # Write the script to run the test
    script_path = os.path.join( base_path, ".mdimechanic", ".temp", "docker_mdi_engine.sh" )
    os.makedirs(os.path.dirname(script_path), exist_ok=True)
    with open(script_path, "w") as script_file:
        script_file.write( script )



    if use_mpi:

        # Start the docker container
        if docker_up( base_path, docker_path ) != 0:
            raise Exception("Unable to start docker-compose")

        # Create the docker environment
        docker_env = os.environ
        docker_env['MDIMECH_WORKDIR'] = base_path
        docker_env['MDIMECH_PACKAGEDIR'] = get_package_path()
        docker_env['MDIMECH_ENGINE_NAME'] = mdimechanic_yaml['docker']['image_name']

        # Run "docker-compose exec"
        exec_proc = subprocess.Popen( ["docker-compose", "exec", "-T", "--user", "mpiuser", "mdi_mechanic", "mpiexec", "-app", "/MDI_Mechanic/mdimechanic/docker/mpi/mdi_appfile"],
                                      stdout=subprocess.PIPE, stderr=subprocess.PIPE,
                                      cwd=docker_path, env=docker_env )
        exec_tup = exec_proc.communicate()
        exec_out = format_return(exec_tup[0])
        exec_err = format_return(exec_tup[1])
        if exec_proc.returncode != 0:
            print("FAILED", flush=True)
            docker_down( base_path, docker_path )
            return False

    else:

        # Create the docker environment
        docker_env = os.environ
        docker_env['MDIMECH_WORKDIR'] = base_path
        docker_env['MDIMECH_PACKAGEDIR'] = get_package_path()
        docker_env['MDIMECH_ENGINE_NAME'] = mdimechanic_yaml['docker']['image_name']

        # Run the docker container
        up_proc = subprocess.Popen( ["docker-compose", "up", "--exit-code-from", "mdi_mechanic", "--abort-on-container-exit"],
                                    stdout=subprocess.PIPE, stderr=subprocess.PIPE,
                                    cwd=docker_path, env=docker_env )
        up_tup = up_proc.communicate()
        up_out = format_return(up_tup[0])
        up_err = format_return(up_tup[1])
        if up_proc.returncode != 0:
            print("FAILED", flush=True)
            docker_down( base_path, docker_path )
            return False



    if docker_down( base_path, docker_path ) != 0:
        print("FAILED", flush=True)
        return False


    print("WORKED", flush=True)
    return True



def find_nodes( base_path ):
    global node_paths
    global node_edge_paths
    
    # List of all node commands in the MDI Standard
    command_list = []
    commands = None
    
    #base_path = get_base_path()
    standard = get_mdi_standard( base_path )
    commands = standard['commands']
    
    for command in commands:
        if command[0] == '@' and command != '@':
            command_list.append( command )
    ordered_commands = sorted( command_list )
    ####################
    #return
    ####################

    # Check which of the MDI Standard commands work from the @DEFAULT node
    for command in ordered_commands:
        command_works = test_command( base_path, command, None, None, None, None )
        if command_works:
            node_paths[command] = command
            node_edge_paths.append( (command, command) )
    
    # From the nodes that have currently been identified, attempt to use the "@" command to identify more nodes
    print("Searching for supported nodes", flush=True)
    original_nodes = []
    for node in node_paths.keys():
        original_nodes.append(node)
    ordered_nodes = sorted( original_nodes )
    for node in ordered_nodes:
        for ii in range(20):
            new_path = node_paths[node]
            for jj in range(ii+1):
                new_path += " @"
            command = new_path + " <@"
            print("Checking for node at: " + str(new_path), end=" ")
            command_works = test_command( base_path, command, "MDI_COMMAND_LENGTH", "MDI_CHAR", None, None )
        
            # Read the name of the node
            node_name = None
            dat_file = os.path.join( base_path, ".mdimechanic", ".temp", "min_driver.dat" )
            err_file = os.path.join( base_path, ".mdimechanic", ".temp", "min_driver.err" )
            if os.path.isfile( dat_file ):
                with open( dat_file, "r") as f:
                    node_name = f.read()
            err_value = None
            if os.path.isfile( err_file ):
                with open( err_file, "r") as f:
                    err_value = f.read()
                
            if node_name is not None and not node_name in node_paths.keys():
                node_paths[node_name] = new_path

            # Check whether this should be added to the node graph
            if node_name is not None:
                split_path = new_path.split()
                include = True
                for node_edge in node_edge_paths:
                    if node_edge[0] == node_name:
                        path = node_edge[1].split()
                        if path[0] == split_path[0]:
                            include = False

                if include:
                    node_edge_paths.append( (node_name, new_path) )

    print("Completed search for nodes.", flush=True)
    print("Found the following nodes: " + str(node_paths.keys()) )

def write_supported_commands( base_path ):
    global node_paths
    
    # List of all commands in the MDI Standard
    command_list = []
    commands = None
    
    #base_path = get_base_path()
    standard = get_mdi_standard( base_path )
    commands = standard['commands']
    
    for command in commands.keys():
        values = commands[command]
        command_list.append( command )
    ordered_commands = sorted( command_list )

    # Identify all supported nodes, and find a path to them
    find_nodes( base_path )
    ordered_nodes = sorted( node_paths.keys() )
    
    # Write the README.md section that lists all supported commands
    command_sec = []

    # Write the section header
    command_sec.append( "## Supported Commands\n" )
    command_sec.append( "\n" )
    header_line = "| "
    for node in ordered_nodes:
        header_line += "| " + str(node) + " "
    header_line += "|\n"
    command_sec.append( header_line )
    header_line = "| ------------- "
    for node in ordered_nodes:
        header_line += "| ------------- "
    header_line += "|\n"
    command_sec.append( header_line )

    # Write the list of supported commands
    for command in ordered_commands:
        nrecv = None
        recv_type = None
        nsend = None
        send_type = None
        print("---------------------------------------")
        print("Testing command: " + str(command))
        if commands[command] is not None and 'recv' in commands[command].keys():
            nrecv = commands[command]['recv']['count']
            recv_type = commands[command]['recv']['datatype']
        if commands[command] is not None and 'send' in commands[command].keys():
            nsend = commands[command]['send']['count']
            send_type = commands[command]['send']['datatype']
        
        line = "| " + str(command) + " "
        for node in ordered_nodes:
            command_with_path = node_paths[node] + " " + command
            padded_string = str(node).ljust(20, '.')
            print(padded_string, end=" ")
            command_works = test_command( base_path, command_with_path, nrecv, recv_type, nsend, send_type )
        
            if command_works:
                # Display a bright green box
                command_status = "![command](report/badges/box-brightgreen.svg)"
            else:
                # Display a light gray box
                command_status = "![command](report/badges/box-lightgray.svg)"

            line += "| " + str(command_status) + " "
        line += "|\n"
        command_sec.append( line )

    # Replace all ">" or "<" symbols with Markdown escape sequences
    for iline in range(len(command_sec)):
        line = command_sec[iline]
        line = line.replace(">", "&gt;")
        line = line.replace("<", "&lt;")
        command_sec[iline] = line
        
    return command_sec

def node_graph( base_path ):
    global node_edge_paths

    print("*********************************************")
    print("* Creating node graph                       *")
    print("*********************************************")

    print("node_edge_paths: " + str(node_edge_paths))

    package_path = get_package_path()

    nodes = {}
    edges = []
    for edge_path in node_edge_paths:
        name = edge_path[0]
        path = edge_path[1].split()
        if '@' in path:
            parent_cluster = str(path[0]) + '_'
            if not parent_cluster in nodes.keys():
                nodes[ parent_cluster ] = str(name)
                edges.append( ( path[0], parent_cluster ) )
            else:
                nodes[ parent_cluster ] += '\n' + str(name)
        else:
            nodes[ name ] = name
            if name != '@DEFAULT':
                edges.append( ( '@DEFAULT', name ) )
    print("nodes: " + str(nodes))

    # Save the graph data to a file
    graph_data = { 'nodes': nodes,
                   'edges': edges }
    graph_file = os.path.join( base_path, ".mdimechanic", ".temp", "graph.pickle")
    os.makedirs(os.path.dirname(graph_file), exist_ok=True)
    with open(graph_file, 'wb') as handle:
        pickle.dump(graph_data, handle, protocol=min(pickle.HIGHEST_PROTOCOL, 4))

    # Graph script
    graph_script = '''
import os
import pickle
from graphviz import Digraph

# Read the data required to make the graph
#graph_file = os.path.join( \'/repo\', \'.mdimechanic\', \'.temp\', \'graph.pickle\')
graph_file = \'/repo/.mdimechanic/.temp/graph.pickle\'

with open(graph_file, 'rb') as handle:
    data = pickle.load(handle)
nodes = data['nodes']
edges = data['edges']

dot = Digraph(comment='Node Report', format='svg')

node_list = []
for node in nodes.keys():
    node_list.append( node )
ordered_nodes = sorted( node_list )
    
for node in ordered_nodes:
    dot.node( node, nodes[ node ], shape='box', margin='0.1' )

for edge in edges:
    dot.edge( edge[0], edge[1] )

#graph_path = os.path.join( base_path, "report", "graphs", "node-report.gv" )
graph_path = '/repo/report/graphs/node-report.gv'
dot.render( graph_path )
'''

    # Render the graph within a docker image, so that it is consistent across machines
    graph_proc = subprocess.Popen( ["docker", "run", "--rm",
                                    "-v", str(base_path) + ":/repo",
                                    "-v", str(package_path) + ":/MDI_Mechanic",
                                    "mdi_mechanic/mdi_mechanic",
                                    "bash", "-c",
                                    "cd /MDI_Mechanic/mdimechanic/utils && python -c \"" + graph_script + "\""],
                                   stdout=subprocess.PIPE, stderr=subprocess.PIPE)
    graph_tup = graph_proc.communicate()
    if graph_proc.returncode != 0:
        docker_error( graph_tup, "Graph process returned an error." )

def analyze_nodes( base_path ):
    #package_path = get_package_path()

    # Read the README.md file
    readme_path = os.path.join(base_path, "README.md")
    with open(readme_path, "r") as file:
        readme = file.readlines()

    # Check the README.md file for any comments for travis
    for iline in range(len(readme)):
        line = readme[iline]
        sline = line.split()
        if len(sline) > 0 and sline[0] == '[travis]:':
            instruction = sline[3]

            if instruction == "supported_commands":
                # Need to insert a list of supported commands here
                command_sec = write_supported_commands( base_path )
                insert_list( readme, command_sec, iline )

    # Write the updates to the README file
    temp_file = os.path.join( base_path, '.mdimechanic', '.temp', 'README.temp')
    os.makedirs(os.path.dirname(temp_file), exist_ok=True)
    with open(temp_file, 'w') as file:
        file.writelines( readme )

    # Create the node graph
    node_graph( base_path )

# Paths to enter each identified node # Paths associated with the edges for the node graph # Use MPI for the tests # Create the docker environment # Run "docker-compose up -d" # Create the docker environment # Run "docker-compose down" # Remove any leftover files from previous runs of min_driver.py #base_path = get_base_path() # Create the script for MDI Mechanic # Write the script to run the test # Start the docker container # Create the docker environment # Run "docker-compose exec" # Create the docker environment # Run the docker container # List of all node commands in the MDI Standard #base_path = get_base_path() #################### #return #################### # Check which of the MDI Standard commands work from the @DEFAULT node # From the nodes that have currently been identified, attempt to use the "@" command to identify more nodes # Read the name of the node # Check whether this should be added to the node graph # List of all commands in the MDI Standard #base_path = get_base_path() # Identify all supported nodes, and find a path to them # Write the README.md section that lists all supported commands # Write the section header # Supported Commands\n" ) # Write the list of supported commands # Display a bright green box # Display a light gray box # Replace all ">" or "<" symbols with Markdown escape sequences # Save the graph data to a file # Graph script import os import pickle from graphviz import Digraph  # Read the data required to make the graph #graph_file = os.path.join( \'/repo\', \'.mdimechanic\', \'.temp\', \'graph.pickle\') graph_file = \'/repo/.mdimechanic/.temp/graph.pickle\'  with open(graph_file, 'rb') as handle:     data = pickle.load(handle) nodes = data['nodes'] edges = data['edges']  dot = Digraph(comment='Node Report', format='svg')  node_list = [] for node in nodes.keys():     node_list.append( node ) ordered_nodes = sorted( node_list )      for node in ordered_nodes:     dot.node( node, nodes[ node ], shape='box', margin='0.1' )  for edge in edges:     dot.edge( edge[0], edge[1] )  #graph_path = os.path.join( base_path, "report", "graphs", "node-report.gv" ) graph_path = '/repo/report/graphs/node-report.gv' dot.render( graph_path ) # Render the graph within a docker image, so that it is consistent across machines #package_path = get_package_path() # Read the README.md file # Check the README.md file for any comments for travis # Need to insert a list of supported commands here # Write the updates to the README file # Create the node graph