#! /usr/bin/env python

from openturns import coupling_tools
import os
import time
import sys

wanted_lines = '# ooo\nE=@E\nE1=@E\nFE1=@F#oo\nZ=@Z@Z\n# ooo\n'
semi_parsed = '# ooo\nE=2\nE1=2\nFE1=@F#oo\nZ=@Z@Z\n# ooo\n'
parsed = '# ooo\nE=1.6\nE1=1.6\nFE1=5#oo\nZ=66\n# ooo\n'

# how many Mo for perf file
#howbig = 3024
howbig = 256
max_time = howbig // 5
# enable it manually, see #600
max_time = sys.maxsize


def create_template():
    template_name = 'template.in'

    template_handle = open(template_name, 'wb')
    template_handle.write(wanted_lines.encode())
    template_handle.close()

    return template_name


def create_big_template():
    template_name = 'template_big.in'

    template_handle = open(template_name, 'wb')

    print(('create template file of ' + str(howbig) + 'Mo'))

    template_handle.write(wanted_lines.encode())
    for i in range(howbig):
        for i in range(1024):
            # line of 1024 octets
            template_handle.write(b'u' * 1024)
            template_handle.write(b'\n')
    template_handle.write(b'# ooo\n')
    template_handle.close()

    return template_name


def remove_file(filename, quiet=False):
    if quiet:
        try:
            os.remove(filename)
        except:
            pass
    else:
        os.remove(filename)


def check_outfile(filename, wanted_result):
    """ wanted_result: a string """
    is_ok = True
    handle = open(filename)
    for wanted_line, result_line in zip(wanted_result.splitlines(True), handle):
        if wanted_line != result_line:
            print(('Aaaaarg, result is not what we wanted (result:' +
                   result_line + ', should be:' + wanted_line.decode() + ')'))
            is_ok = False
    handle.close()

    if is_ok:
        print(('check ' + filename + ': ok'))
    else:
        exit(1)
    # return is_ok


def check_replace():
    print(("=== " + sys._getframe().f_code.co_name))
    print("= check replace std")
    template = create_template()
    template_out = template + ".replaced"
    coupling_tools.replace(infile=template, outfile=template_out,
                           tokens=["@E"], values=[2])
    check_outfile(template_out, semi_parsed)
    remove_file(template_out)
    remove_file(template)

    print("= check replace more vars")
    template = create_template()
    coupling_tools.replace(infile=template, outfile=template_out,
                           tokens=["@E", "@F", "@Z"],
                           values=[1.6, 5, 6])
    check_outfile(template_out, parsed)
    remove_file(template_out)
    remove_file(template)

    print("= check replace inplace")
    template = create_template()
    coupling_tools.replace(infile=template, outfile=template,
                           tokens=["@E", "@F", "@Z"], values=[1.6, 5, 6])
    check_outfile(template, parsed)
    remove_file(template)

    print("= check replace inplace with None")
    template = create_template()
    coupling_tools.replace(infile=template, outfile=None,
                           tokens=["@E", "@F", "@Z"], values=[1.6, 5, 6])
    check_outfile(template, parsed)
    remove_file(template)

    print("= check replace big template")
    start_time = time.time()
    template = create_big_template()
    sys.stderr.write(
        "big template created in : " + str(time.time() - start_time) + "s\n")

    template_out = template + ".replaced"
    start_time = time.time()
    coupling_tools.replace(infile=template, outfile=template_out,
                           tokens=["@E"], values=[2])
    time_to_parse = str(int(time.time() - start_time))
    check_outfile(template_out, semi_parsed)
    remove_file(template_out)
    remove_file(template)
    sys.stderr.write("parsed template in: " + time_to_parse + "s\n")
    # parsed template=3G -> 25s on bx (ssd, core i7@2.5GHz)
    if int(time_to_parse) > max_time:
        print(('time to get token took too long (should be ' +
               str(max_time) + 's max)'))
        exit(1)
    else:
        print('check replace big template: ok')


def create_results(tokens, values=None, big=False):
    filename = "results.out"

    handle = open(filename, "wb")

    if big:
        print(("create file of " + str(howbig) + "Mo"))

        for i in range(howbig):
            for i in range(1024):
                # line of 1024 octets
                handle.write(b'u' * 1024)
                handle.write(b'\n')
        handle.write(b'# ooo\n')

    if values == None:
        handle.write(tokens.encode())
    else:
        n = 0
        for t, v in zip(tokens, values):
            handle.write((t + str(v)).encode())
            # go to next line sometimes
            if n % 3 == 0:
                handle.write(b'\n')
            n += 1
    handle.close()

    return filename


def check_results(ok_values, values):
    if ok_values == values:
        print("ok")
    else:
        print(
            ("Error: found: " + str(values) + " should be: " + str(ok_values)))
        exit(1)


def check_get_line_col():
    print(("=== " + sys._getframe().f_code.co_name))
    content = """01 02 03 04 05 06 07 08 09
11 12 13 14 15 16 17 18 19
21 22 23 24 25 26 27 28 29
31 32 33 34 35 36 37 38 39
"""
    result_file = create_results(content)

    value = 1
    result = coupling_tools.get_line_col(result_file)
    if value != result:
        raise Exception("! got " + str(result) + ' instead of ' +
                        str(value))
    value = 3
    result = coupling_tools.get_line_col(result_file, skip_col=2)
    if value != result:
        raise Exception("! got " + str(result) + ' instead of ' +
                        str(value))
    value = 11
    result = coupling_tools.get_line_col(result_file, 1)
    if value != result:
        raise Exception("! got " + str(result) + ' instead of ' +
                        str(value))
    value = 16
    result = coupling_tools.get_line_col(result_file, 1, 5)
    if value != result:
        raise Exception("! got " + str(result) + ' instead of ' +
                        str(value))
    value = 9
    result = coupling_tools.get_line_col(result_file, skip_col=-1)
    if value != result:
        raise Exception("! got " + str(result) + ' instead of ' +
                        str(value))
    value = 17
    result = coupling_tools.get_line_col(result_file, 1, -3)
    if value != result:
        raise Exception("! got " + str(result) + ' instead of ' +
                        str(value))
    value = 31
    result = coupling_tools.get_line_col(result_file, -1)
    if value != result:
        raise Exception("! got " + str(result) + ' instead of ' +
                        str(value))
    value = 14
    result = coupling_tools.get_line_col(result_file, -3, -6)
    if value != result:
        raise Exception("! got " + str(result) + ' instead of ' +
                        str(value))
    value = 3
    result = coupling_tools.get_line_col(result_file, seek=6)
    if value != result:
        raise Exception("! got " + str(result) + ' instead of ' +
                        str(value))
    value = 23
    result = coupling_tools.get_line_col(
        result_file, skip_line=1, skip_col=2, seek=30)
    if value != result:
        raise Exception("! got " + str(result) + ' instead of ' +
                        str(value))
    value = 31
    result = coupling_tools.get_line_col(result_file, skip_line=-1, seek=-100)
    if value != result:
        raise Exception("! got " + str(result) + ' instead of ' +
                        str(value))

    #coupling_tools.debug = True
    value = 21
    just_before_line_ret = 80
    sys.stderr.write('char at pos ' + str(just_before_line_ret) + ':->' +
                     content[just_before_line_ret] + '<-\n')
    result = coupling_tools.get_line_col(result_file, skip_line=-1,
                                         seek=-just_before_line_ret)
    if value != result:
        raise Exception("! got " + str(result) + ' instead of ' +
                        str(value))

    value = 21
    just_after_line_ret = just_before_line_ret + 1
    sys.stderr.write('char at pos ' + str(just_after_line_ret) + ':->' +
                     content[just_after_line_ret] + '<-\n')
    result = coupling_tools.get_line_col(result_file, skip_line=-2,
                                         seek=-just_after_line_ret)
    if value != result:
        raise Exception("! got " + str(result) + ' instead of ' +
                        str(value))

    try:
        result = coupling_tools.get_line_col(result_file, skip_line=4)
    except:
        pass
    else:
        raise Exception("! should have fail !")

    try:
        result = coupling_tools.get_line_col(result_file, skip_line=-5)
    except:
        pass
    else:
        raise Exception("! should have fail !")

    os.remove(result_file)

    # test with a last empty line
    content = """01 02 03 04 05 06 07 08 09
11 12 13 14 15 16 17 18 19

"""
    result_file = create_results(content)

    value = 19
    result = coupling_tools.get_line_col(
        result_file, skip_line=-2, skip_col=-1)
    if value != result:
        raise Exception("! got " + str(result) + ' instead of ' +
                        str(value))

    value = 1
    result = coupling_tools.get_line_col(result_file, skip_line=-3)
    if value != result:
        raise Exception("! got " + str(result) + ' instead of ' +
                        str(value))

    try:
        result = coupling_tools.get_line_col(result_file, skip_line=-1)
    except:
        pass
    else:
        raise Exception("! should have fail !")

    os.remove(result_file)

    print("ok")


def check_get():
    print(("=== " + sys._getframe().f_code.co_name))
    tokens = ["@Y1=", "@Y2="]
    values = [5.4, 6.5]
    result_file = create_results(tokens, values)
    results = coupling_tools.get(filename=result_file, tokens=tokens)
    check_results(values, results)
    remove(result_file)

    # Y = coupling_tools.get(outfile="output.py", tokens=["@Y1=", "@Y2="],
    #                       occurence=[0, 0], col=[0, 3], line=[0, 2])


def check_get_token_escaped():
    print(("=== " + sys._getframe().f_code.co_name))
    result_file = "results.out"
    handle = open(result_file, "wb")
    handle.write(b'FOO (BAR\n')
    handle.write(b'1.0 1.1 1.2 1.3\n')
    handle.write(b'2.0 2.1 2.2 2.3\n')
    handle.close()
    results = coupling_tools.get(
        filename=result_file, tokens=['FOO \(BAR'], skip_lines=[1], skip_cols=[1])
    check_results([1.1], results)
    os.remove(result_file)


def check_get_regex():
    print(("=== " + sys._getframe().f_code.co_name))
    tokens = ["@E=", "02=", " 01 = "]
    values = [-9.55555E5, 8, 5.4]
    result_file = create_results(tokens, values)
    results = coupling_tools.get_regex(filename=result_file,
                                       patterns=['@E=(\R)',
                                                 '02\s*=\s*(\I)\s*',
                                                 '01 =\s*(\R)']
                                       )
    check_results(values, results)
    remove_file(result_file)


def check_get_regex_perf():
    print(("=== " + sys._getframe().f_code.co_name))
    tokens = ["@E=", "02=", " 01 = "]
    values = [-9.55555E5, 8, 5.4]
    start_time = time.time()
    result_file = create_results(tokens, values, big=True)
    sys.stderr.write(
        "big file created in : " + str(time.time() - start_time) + "s\n")
    start_time = time.time()
    results = coupling_tools.get_regex(filename=result_file,
                                       patterns=['@E=(\R)',
                                                 '02\s*=\s*(\I)\s*',
                                                 '01 =\s*(\R)']
                                       )
    time_to_parse = str(int(time.time() - start_time))
    check_results(values, results)
    remove_file(result_file)
    # get file=3G -> 16s on bx (ssd, core i7@2.5GHz)
    sys.stderr.write("get regex in file in: " + time_to_parse + "s\n")
    if int(time_to_parse) > max_time:
        print(('time to get token took too long (should be ' +
               str(max_time) + 's max)'))
        exit(1)
    else:
        print("get regex in file: ok")


def check_get_tokens():
    print(("=== " + sys._getframe().f_code.co_name))
    tokens = ["@E=", " pp", ",virg", " normal="]
    values = [-9.55555E6, 56.666, -12345678912.2, 0]
    result_file = create_results(tokens, values)
    results = coupling_tools.get(filename=result_file,
                                 tokens=tokens)
    check_results(values, results)
    remove_file(result_file)


def check_get_tokens_skip():
    print(("=== " + sys._getframe().f_code.co_name))
    content = "@E=99 @E=-9.55555E6 pp88 pp 56.666,virg-12345678912.2 normal=0"
    values = [-9.55555E6, 56.666, -12345678912.2, 0]
    result_file = create_results(content)
    results = coupling_tools.get(filename=result_file,
                                 tokens=["@E=", "pp", ",virg",
                                         "normal="],
                                 skip_tokens=[1, -1, 0, 0]
                                 )
    check_results(values, results)
    remove_file(result_file)

    print(("=== " + sys._getframe().f_code.co_name + "2"))
    tokens = '@E=99 @E=7899 pp88 pp pp\n'\
             'pp999 pp56.666E-9pp,virg-12345678912.2 uu88 uuuu\n'\
             'uu999uu\n'
    values = [99, 56.666E-9, -12345678912.2, 999]
    result_file = create_results(tokens)
    results = coupling_tools.get(filename=result_file,
                                 tokens=["@E=", "pp", ",virg",
                                         "uu"],
                                 skip_tokens=[0, 4, -1, 3]
                                 )
    check_results(values, results)
    remove_file(result_file)


def check_get_array():
    print(("=== " + sys._getframe().f_code.co_name))
    tokens = '11.0E-9 22.0crap 33.0 44.0 55.0\n'\
             '11.1 22.1 33.1 44.1\n'\
             '11.2 22.2 33.2 44.2'
    values = [11.0E-9, 22.0, 55.0, 11.1, 33.2, 22.2, 33.2]
    result_file = create_results(tokens)
    results = coupling_tools.get(filename=result_file,
                                 skip_lines=[0, 0,  0, 1, 2, 2, -1],
                                 skip_cols=[0, 1, -1, 0, 2, 1, -2]
                                 )
    check_results(values, results)
    remove_file(result_file)


def check_get_tokens_line_col():
    print(("=== " + sys._getframe().f_code.co_name))
    tokens = '11.0E-9 22.0crap 33.0 44.0 55.0\n'\
             '11.1 22.1 33.1 44.1 middle\n'\
             '11.2 22.2 33.2 44.2\n'\
             '@E=1111.1E11 666'
    values = [1111.1E11, 22.0, 33.1, 666, 33.2, 44.1, 55.0]
    result_file = create_results(tokens)
    results = coupling_tools.get(filename=result_file,
                                 tokens=['@E=', None, '@E=', '@E=',
                                         'middle', 'middle', 'middle'],
                                 skip_lines=[0, 0, -2, 0, 1, 0, -1],
                                 skip_cols=[0, 1, 2, 1, -2, -1, -1]
                                 )
    check_results(values, results)
    remove_file(result_file)


def check_get_tokens_skip_line_col():
    print(("=== " + sys._getframe().f_code.co_name))
    tokens = '11.0E-9 22.0crap 33.0 44.0 55.0\n'\
             '11.1 22.1 33.1 44.1 middle\n'\
             '11.2 22.2 middle 33.2 44.2\n'\
             '@E=1111.1E11 666\n'\
             '@E=999 8888 @E=95\n'
    values = [1111.1E11, 33.2, 666, 8888, 8888, 666]
    result_file = create_results(tokens)
    results = coupling_tools.get(filename=result_file,
                                 tokens=[
                                     '@E=', 'middle', 'middle', '@E=', '@E=', '@E='],
                                 skip_tokens=[0, 1, -1, -2, -1, -2],
                                 skip_lines=[0, 0, 1, 0, 0, -1],
                                 skip_cols=[0, 0, 1, 1, -1, -1]
                                 )
    check_results(values, results)
    remove_file(result_file)


def check_get_tokens_perf():
    print(("=== " + sys._getframe().f_code.co_name))
    tokens = ["@E=", " pp", ",virg", " normal="]
    values = [-9.55555E6, 56.666, -12345678912.2, 0]
    tokens = ["@E="]
    values = [-9.55555E6]
    start_time = time.time()
    result_file = create_results(tokens, values, big=True)
    sys.stderr.write(
        "big file created in : " + str(time.time() - start_time) + "s\n")
    start_time = time.time()
    results = coupling_tools.get(filename=result_file,
                                 tokens=tokens)
    time_to_parse = str(int(time.time() - start_time))
    check_results(values, results)
    remove_file(result_file)
    # get file=3G -> 18s on bx (ssd, core i7@2.5GHz)
    sys.stderr.write('get token in file in: ' + time_to_parse + 's\n')
    if int(time_to_parse) > max_time:
        print(('time to get token took too long (should be ' +
               str(max_time) + 's max)'))
        exit(1)
    else:
        print('get tokens: ok')


def check_get_tokens_skip_perf():
    print(("=== " + sys._getframe().f_code.co_name))
    content = "@E=99 @E=-9.55555E6 pp88 pp 56.666,virg-12345678912.2 normal=0"
    values = [-9.55555E6, 56.666, -12345678912.2, 0]
    content = "@E=99 @E=-9.55555E6 pp88 pp 56.666,virg-12345678912.2 normal=0"
    values = [-9.55555E6]
    start_time = time.time()
    result_file = create_results(content, big=True)
    sys.stderr.write(
        "big file created in : " + str(time.time() - start_time) + "s\n")
    start_time = time.time()
    results = coupling_tools.get(filename=result_file,
                                 tokens=["@E="],
                                 skip_tokens=[-1]
                                 )
    time_to_parse = str(int(time.time() - start_time))
    check_results(values, results)
    remove_file(result_file)
    # get file=3G -> 21s on bx (ssd, core i7@2.5GHz)
    sys.stderr.write("get token skip in file in: " + time_to_parse + "s\n")
    if int(time_to_parse) > max_time:
        print(('time to get token took too long (should be ' +
               str(max_time) + 's max)'))
        exit(1)
    else:
        print('get tokens skip: ok')


def check_get_line_col_perf():
    print(("=== " + sys._getframe().f_code.co_name))
    tokens = '11.0E-9 22.0 33.0 44.0 55.0\n'\
             '11.1 22.1 33.1 44.1\n'\
             '11.2 22.2 33.2 44.2'\
             '\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n'\
             '\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n'\
             '\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n'
    values = [22.0]
    start_time = time.time()
    result_file = create_results(tokens, big=True)
    sys.stderr.write(
        'big file created in : ' + str(time.time() - start_time) + 's\n')
    start_time = time.time()
    results = coupling_tools.get(filename=result_file,
                                 skip_lines=[-92],
                                 skip_cols=[1]
                                 )
    time_to_parse = str(int(time.time() - start_time))
    check_results(values, results)
    remove_file(result_file)
    # get file=3G -> 15s on bx (ssd, core i7@2.5GHz)
    sys.stderr.write(
        'get token skip line col in file in: ' + time_to_parse + 's\n')
    if int(time_to_parse) > max_time:
        print(('time to get token took too long (should be ' +
               str(max_time) + 's max)'))
        exit(1)
    else:
        print('get line col: ok')


def check_execute():
    print(("=== " + sys._getframe().f_code.co_name))
    # ensure previous print is print before following command output
    sys.stdout.flush()

    # Care with -darwin systems

    if ('darwin' in sys.platform) or ('win' not in sys.platform):
        coupling_tools.execute('/bin/ls /bin/kill')
        coupling_tools.execute('echo "hi"', is_shell=True)
        coupling_tools.execute('echo "hi"', is_shell=True,
                               shell_exe='/bin/bash')

        ret, stdout = coupling_tools.execute('/bin/ls /bin/kill',
                                             get_stdout=True)
        if stdout != b'/bin/kill\n':
            raise Exception("coupling_tools.execute error!")

        ret, stdout, stderr = coupling_tools.execute('/bin/ls /bin/kill',
                                                     get_stdout=True, get_stderr=True)
        if stdout != b'/bin/kill\n' and stderr != b'':
            raise Exception("coupling_tools.execute error!")

        ret, stderr = coupling_tools.execute('/bin/ls /bin/kill 1>&2',
                                             is_shell=True,
                                             get_stderr=True)
        if stderr != b'/bin/kill\n':
            raise Exception("coupling_tools.execute error!")
    else:
        coupling_tools.execute('cmd.exe /c echo /bin/kill')
        exec_in_wine = os.path.exists('/boot')
        if exec_in_wine:
            # command 'echo' do not work in python on wine for an unknown
            # reason
            print('hi')
            print('hi')
        else:
            # native windows
            coupling_tools.execute('echo hi', is_shell=True)
            coupling_tools.execute('echo hi', is_shell=True, hide_win=False)

            ret, stdout = coupling_tools.execute('echo hello', is_shell=True,
                                                 get_stdout=True)
            if ret != 0 or not str(stdout).startswith('hello'):
                raise Exception("coupling_tools.execute error!")
    print("execute ok")

check_execute()
check_replace()
check_get_token_escaped()
check_get_regex()
check_get_regex_perf()
check_get_line_col()
check_get_tokens()
check_get_tokens_skip()
check_get_array()
check_get_tokens_line_col()
check_get_tokens_skip_line_col()
check_get_tokens_perf()
check_get_tokens_skip_perf()
check_get_line_col_perf()


exit(0)