// ================================================================ //
//                                                                  //
//   File      : UnitTester.cxx                                     //
//   Purpose   :                                                    //
//                                                                  //
//   Coded by Ralf Westram (coder@reallysoft.de) in February 2010   //
//   Institute of Microbiology (Technical University Munich)        //
//   http://www.arb-home.de/                                        //
//                                                                  //
// ================================================================ //

#include "UnitTester.hxx"

#include <cstdarg>
#include <cstdlib>
#include <cstdio>
#include <cstring>
#include <cerrno>
#include <climits>

#include <sys/time.h>
#include <sys/stat.h>

#include <arb_simple_assert.h>
#include <arb_backtrace.h>
#include <arb_pathlen.h>
#include <arb_sleep.h>

#include <test_unit.h>
#include <ut_valgrinded.h>
#include <valgrind.h>

#include <SuppressOutput.h>

#include <SigHandler.h>
#include <setjmp.h>
#include <unistd.h>
#include <string>
#include <exception>
#include <signal.h>

#include <mod_rlimit.h>
#include "../SOURCE_TOOLS/arb_main.h"

#define ut_assert(cond) arb_assert(cond)

#if defined(DEBUG)
# if defined(DEVEL_RALF)

// whether EXPECT_VALID_TEST_LOCATION works or not seems to depend on how well compiler version and system match.
// now works with gcc 7.3 on my current development machine.
#  define EXPECT_VALID_TEST_LOCATION

# endif
#endif

using namespace std;

// --------------------------------------------------------------------------------

struct Globals : virtual Noncopyable {
    bool        inside_test;
    bool        running_on_valgrind;
    char       *runDir;
    pid_t       pid;
    const char *libname;

    Globals()
        : inside_test(false),
          runDir(NULp),
          pid(getpid()),
          libname(NULp)
    {
        running_on_valgrind = (RUNNING_ON_VALGRIND>0);
    }
    ~Globals() {
        free(runDir);
    }

    inline void setup_test_precondition() {
        TEST_EXPECT_ZERO_OR_SHOW_ERRNO(chdir(runDir));
    }
    inline void setup_test_postcondition() {
        TEST_ANNOTATE(NULp);
    }
};

static Globals GLOBAL;

// --------------------------------------------------------------------------------
// #define TRACE_PREFIX "UnitTester:0: "
#define TRACE_PREFIX "UnitTester: "

__ATTR__FORMAT(1) static void trace(const char *format, ...) {
    va_list parg;

    fflush(stdout);
    fflush(stderr);

    fputs(TRACE_PREFIX, stderr);
    va_start(parg, format);
    vfprintf(stderr, format, parg);
    va_end(parg);
    fputc('\n', stderr);
    fflush(stderr);
}

// --------------------------------------------------------------------------------

static const char *readable_result[] = { // index is UnitTestResult
    "OK"           ,
    "TRAPPED"      ,
    "VIOLATED"     ,
    "INTERRUPTED"  ,
    "THREW"        ,
    "INVALID"      , // use TEST_PUBLISH to make it valid
    "{unknown}"    ,
};

// --------------------------------------------------------------------------------

static jmp_buf UNITTEST_return_after_segv;
static bool    terminate_was_called = false;

enum TrapCode {
    TRAP_UNEXPECTED = 668,
    TRAP_SEGV,
    TRAP_INT,
    TRAP_TERM,
};

__ATTR__NORETURN static void UNITTEST_sigsegv_handler(int sig) {
    if (GLOBAL.inside_test) {
        int  trap_code;
        const char *backtrace_cause = NULp;
        switch (sig) {
            case SIGSEGV: {
                trap_code = TRAP_SEGV;

                arb_test::GlobalTestData& test_data = arb_test::test_data();
                if (!test_data.assertion_failed) { // not caused by assertion
                    backtrace_cause = "Caught SIGSEGV not caused by assertion";
                }
                break;
            }
            case SIGINT:
                trap_code = TRAP_INT;
                backtrace_cause = "Caught SIGINT (deadlock in test function?)";
                break;

            case SIGTERM:
                trap_code = TRAP_TERM;
                if (terminate_was_called) {
                    backtrace_cause = "Caught SIGTERM, cause std::terminate() has been called in test-code (might be an invalid throw)";
                }
                else {
                    backtrace_cause = "Caught SIGTERM (deadlock in uninterruptable test function?)";
                }
                break;

            default:
                trap_code = TRAP_UNEXPECTED;
                test_assert(0, true);
                break;
        }
        if (backtrace_cause) demangle_backtrace(BackTraceInfo(0), stderr, backtrace_cause);
        siglongjmp(UNITTEST_return_after_segv, trap_code); // suppress signal
    }

    const char *signame = NULp;
    switch (sig) {
        case SIGSEGV: signame = "SEGV"; break;
        case SIGINT: signame  = "INT"; break;
        case SIGTERM: signame = "TERM"; break;
    }

    fputs("[UnitTester catched unexpected signal ", stderr);
    if (signame) fputs(signame, stderr); else fprintf(stderr, "%i", sig);
    fputs("]\n", stderr);
    BackTraceInfo(0).dump(stderr, "Unexpected signal (NOT raised in test-code)");
    exit(EXIT_FAILURE);
}

#define SECOND 1000000

static void terminate_called() {
    // example-test triggering call of terminate_called(): ../CORE/arb_signal.cxx@TEST_throw_during_throw
    terminate_was_called = true;
    raise(SIGTERM);
    // GBK_dump_backtrace(stdout, "just raised SIGTERM - wtf am i doing here"); fflush(stdout);
}

static UnitTestResult execute_guarded_ClientCode(UnitTest_function fun, long *duration_usec) {
    terminate_handler old_terminate = std::set_terminate(terminate_called);

    SigHandler old_int_handler  = INSTALL_SIGHANDLER(SIGINT,  UNITTEST_sigsegv_handler, "execute_guarded");
    SigHandler old_term_handler = INSTALL_SIGHANDLER(SIGTERM, UNITTEST_sigsegv_handler, "execute_guarded");
    SigHandler old_segv_handler = INSTALL_SIGHANDLER(SIGSEGV, UNITTEST_sigsegv_handler, "execute_guarded");

    // ----------------------------------------
    // start of critical section
    // (need volatile for modified local auto variables, see man longjump)
    volatile timeval        t1;
    volatile UnitTestResult result  = TEST_OK;
    volatile int            trapped = sigsetjmp(UNITTEST_return_after_segv, 1);

    if (trapped) {
        switch (trapped) {
            case TRAP_UNEXPECTED: ut_assert(0); // fall-through
            case TRAP_SEGV: result = TEST_TRAPPED; break;

            case TRAP_INT:
            case TRAP_TERM: result = TEST_INTERRUPTED; break;
        }
    }
    else { // normal execution
        GLOBAL.inside_test = true;

        gettimeofday((timeval*)&t1, NULp);

        arb_test::test_data().assertion_failed = false;
        arb_test::test_data().running_test = true;

        // Note: fun() may do several ugly things, e.g.
        // - segfault                           (handled)
        // - never return                       (handled by caller)
        // - exit() or abort()                  (std::terminate is handled, direct call to abort is not)
        // - throw an exception                 (catched by caller of execute_guarded_ClientCode)
        // - change working dir                 (should always be reset before i get called)

        fun();

        // sleepms(10000); // simulate a deadlock
    }
    // end of critical section
    // ----------------------------------------

    timeval t2;
    gettimeofday(&t2, NULp);
    *duration_usec = (t2.tv_sec - t1.tv_sec) * SECOND + (t2.tv_usec - t1.tv_usec);

    GLOBAL.inside_test = false;

    UNINSTALL_SIGHANDLER(SIGSEGV, UNITTEST_sigsegv_handler, old_segv_handler, "execute_guarded");
    UNINSTALL_SIGHANDLER(SIGTERM, UNITTEST_sigsegv_handler, old_term_handler, "execute_guarded");
    UNINSTALL_SIGHANDLER(SIGINT,  UNITTEST_sigsegv_handler, old_int_handler,  "execute_guarded");

    terminate_handler handler = std::set_terminate(old_terminate);
    if (handler != terminate_called) {
        fputs("Error: test-code has modified std::terminate (this is invalid)\n", stderr);
        fflush(stderr);
        result = TEST_INVALID;
    }

    return result;
}

inline bool kill_verbose(pid_t pid, int sig, const char *signame) {
    int result = kill(pid, sig);
    if (result != 0) {
        fprintf(stderr, "Failed to send %s to test (%s)\n", signame, strerror(errno));
        fflush(stderr);
    }
    return result == 0;
}

class Flag {
    string flagname;

public:
    Flag(const string& flagname_) : flagname(flagname_) {}

    bool is_up() const { struct stat stt; return stat(flagname.c_str(), &stt) == 0 && S_ISREG(stt.st_mode); }
    void raise() {
        fprintf(stderr, "Raising flag '%s'\n", flagname.c_str()); fflush(stderr);
        ut_assert(!is_up());
        FILE *fp = fopen(flagname.c_str(), "w");
        fclose(fp);
    }
    void lower() {
        fprintf(stderr, "Lowering flag '%s'\n", flagname.c_str()); fflush(stderr);
        ut_assert(is_up());
        TEST_EXPECT_ZERO_OR_SHOW_ERRNO(unlink(flagname.c_str()));
    }

    void lower_if_up() { if (is_up()) lower(); }
};

inline Flag getLocalFlag(const char *flagname) {
    string localname  = string(GLOBAL.runDir)+"/../flags/"+flagname+'.'+GLOBAL.libname;
    return Flag(localname);
}

static bool flag_callback(arb_test::FlagAction action, const char *name) {
    using namespace arb_test;

    Flag flag   = getLocalFlag(name);
    bool result = true;

    switch (action) {
        case FLAG_RAISE:
            if (!flag.is_up()) flag.raise();
            break;
        case FLAG_IS_RAISED:
            result = flag.is_up();
            break;
    }

    return result;
}

inline bool been_inside_environment() {
    return getLocalFlag(ANY_SETUP).is_up() || arb_test::test_data().entered_mutex_loop;
}
inline bool did_valgrinded_syscall() {
    return seen_valgrinded_call();
}
inline void reset_test_local_flags() {
    getLocalFlag(ANY_SETUP).lower_if_up();
}

void sleepms(long ms) {
    long seconds = ms/1000;
    long rest_ms = ms - seconds*1000;

    if (seconds) ARB_sleep(seconds, SEC);
    ARB_sleep(rest_ms, MS);
}

#if (DEADLOCKGUARD == 1)
__ATTR__NORETURN static void deadlockguard(long max_allowed_duration_ms, bool detect_environment_calls) {
    // this function is completely incompatible with debuggers
    sleepms(max_allowed_duration_ms);

    if (detect_environment_calls && been_inside_environment()) {
        fprintf(stderr, "[test_environment has been called. Added %li ms tolerance]\n", MAX_EXEC_MS_ENV);
        fflush(stderr);
        sleepms(MAX_EXEC_MS_ENV);
        max_allowed_duration_ms += MAX_EXEC_MS_ENV;
    }

    if (did_valgrinded_syscall()) {
        const long additional    = max_allowed_duration_ms*3 + MAX_EXEC_MS_VGSYS;
        fprintf(stderr, "[external calls are running valgrinded. Added %li ms tolerance]\n", additional);
        fflush(stderr);
        sleepms(additional);
        max_allowed_duration_ms += additional;
    }

    const int aBIT = 50; // 50 milliseconds

    fprintf(stderr,
            "[deadlockguard woke up after %li ms]\n"
            "[interrupting possibly deadlocked test]\n",
            max_allowed_duration_ms); fflush(stderr);
    kill_verbose(GLOBAL.pid, SIGINT, "SIGINT");
    sleepms(aBIT); // give parent a chance to kill me

    fprintf(stderr, "[test still running -> terminate]\n"); fflush(stderr);
    kill_verbose(GLOBAL.pid, SIGTERM, "SIGTERM");
    sleepms(aBIT); // give parent a chance to kill me

    fprintf(stderr, "[still running -> kill]\n"); fflush(stderr);
    kill_verbose(GLOBAL.pid, SIGKILL, "SIGKILL"); // commit suicide
    // parent had his chance
    fprintf(stderr, "[still alive after suicide -> perplexed]\n"); fflush(stderr);
    exit(EXIT_FAILURE);
}
#endif

UnitTestResult execute_guarded(UnitTest_function fun, long *duration_usec, long max_allowed_duration_ms, bool detect_environment_calls) {
    if (GLOBAL.running_on_valgrind) max_allowed_duration_ms *= 4;
    UnitTestResult result;

    pid_t child_pid = fork();
    if (child_pid) { // parent
        try { result = execute_guarded_ClientCode(fun, duration_usec); }
        catch (...) { result = TEST_THREW; }
        if (kill(child_pid, SIGKILL) != 0) {
            fprintf(stderr, "Failed to kill deadlock-guard (%s)\n", strerror(errno)); fflush(stderr);
        }
    }
    else { // child
#if (DEADLOCKGUARD == 1)
        deadlockguard(max_allowed_duration_ms, detect_environment_calls);
#else
#warning DEADLOCKGUARD has been disabled (not default!)
        detect_environment_calls = !!detect_environment_calls; // dont warn
#endif
        exit(EXIT_FAILURE);
    }

    return result;
}

// --------------------------------------------------------------------------------

class SimpleTester {
    const UnitTest_simple *tests;
    const UnitTest_simple *postcond;
    size_t                 count;
    size_t                 postcount;
    double                 duration_ms;

    bool perform(size_t which);
    UnitTestResult run_postcond(long *duration_usec, long max_allowed_duration_ms, bool print_errors);

public:
    SimpleTester(const UnitTest_simple *tests_, const UnitTest_simple *postcond_)
        : tests(tests_),
          postcond(postcond_),
          duration_ms(0.0)
    {
        for (count = 0; tests[count].fun; ++count) {}
        for (postcount = 0; postcond[postcount].fun; ++postcount) {}
    }

    size_t perform_all();
    size_t get_test_count() const { return count; }

    double overall_duration_ms() const { return duration_ms; }
};


size_t SimpleTester::perform_all() {
    // returns number of passed tests

    trace("performing %zu simple tests..", count);
    size_t passed = 0;
    for (size_t c = 0; c<count; ++c) {
        GLOBAL.setup_test_precondition();
        passed += perform(c);
        GLOBAL.setup_test_postcondition();
    }
    return passed;
}


UnitTestResult SimpleTester::run_postcond(long *duration_usec_sum, long abort_after_ms, bool print_errors) {
    UnitTestResult result = TEST_OK;
    *duration_usec_sum    = 0;
    for (size_t pc = 0; pc<postcount && result == TEST_OK; ++pc) {
        long duration_usec;
        result              = execute_guarded(postcond[pc].fun, &duration_usec, abort_after_ms, true); // <-- call postcond
        *duration_usec_sum += duration_usec;

        if (result != TEST_OK && print_errors) {
            postcond[pc].print_error(stderr, result);
        }
    }
    return result;
}

void UnitTest_simple::print_error(FILE *out, UnitTestResult result) const {
    switch (result) {
        case TEST_OK:
            break;

        case TEST_TRAPPED:
            fprintf(out, "%s: Error: %s failed (details above)\n", location, name);
            break;

        case TEST_FAILED_POSTCONDITION:
            fprintf(out, "%s: Error: %s succeeded, but violates general postconditions (see above)\n", location, name);
            break;

        case TEST_INTERRUPTED:
            fprintf(out, "%s: Error: %s has been interrupted (details above)\n", location, name);
            break;

        case TEST_THREW:
            fprintf(out, "%s: Error: %s has thrown an exception\n", location, name);
            break;

        case TEST_INVALID:
            fprintf(out, "%s: Error: %s is invalid (see above)\n", location, name);
            break;

        case TEST_UNKNOWN_RESULT:
            ut_assert(0);
            break;
    }
}

bool SimpleTester::perform(size_t which) {
    ut_assert(which<count);

    const UnitTest_simple& test = tests[which];
    UnitTest_function      fun  = test.fun;

    reset_test_local_flags();

    bool       marked_as_slow = strlen(test.name) >= 10 && memcmp(test.name, "TEST_SLOW_", 10) == 0;
    const long abort_after_ms = marked_as_slow ? MAX_EXEC_MS_SLOW : MAX_EXEC_MS_NORMAL;

#if defined(EXPECT_VALID_TEST_LOCATION)
    bool invalid = !test.location;
#else
    bool invalid = false; // in NDEBUG mode location is always missing (i.e. we dont expect to have one)
#endif

    UnitTestResult result = TEST_UNKNOWN_RESULT;
    unsigned       tryMax = 1; // normally only try once; see ./README.txt@TEST_ALLOW_RETRY
    for (unsigned tryCount = 1; tryCount<=tryMax && result != TEST_OK; ++tryCount) {
        long   duration_usec;
        result                  = invalid ? TEST_INVALID : execute_guarded(fun, &duration_usec, abort_after_ms, true); // <--- call unittest
        double duration_ms_this = invalid ? 0.0 : duration_usec/1000.0;

        duration_ms += duration_ms_this;

        long           duration_usec_post = 0;
        UnitTestResult postcond_result    = TEST_UNKNOWN_RESULT;

        if (result == TEST_OK) {
            // if test is ok -> check postconditions
            postcond_result = run_postcond(&duration_usec_post, MAX_EXEC_MS_NORMAL, true);
            if (postcond_result != TEST_OK) {
                result = TEST_FAILED_POSTCONDITION; // fail test, if any postcondition fails
            }
        }

        trace("* %s = %s (%.1f ms)", test.name, readable_result[result], duration_ms_this);

        if (result == TEST_OK) {
            if (duration_ms_this >= WARN_SLOW_ABOVE_MS) {                    // long test duration
                if (!marked_as_slow) {
                    bool accept_slow = GLOBAL.running_on_valgrind || did_valgrinded_syscall();
                    if (!accept_slow) {
                        fprintf(stderr, "%s: Warning: Name of slow tests shall start with TEST_SLOW_ (it'll be run after other tests)\n",
                                test.location);
                    }
                }
            }
        }

        test.print_error(stderr, result);

        if (result != TEST_OK) { // test did not succeed
            if (tryCount == 1) { // 1st attempt failed
                tryMax = arb_test::test_data().allowed_retries();
                if (tryMax>1) {
                    fprintf(stderr, "%s: Warning: test failed, but allows %u retries\n", test.location, tryMax-1);
                }
            }

            if (result != TEST_FAILED_POSTCONDITION) { // postconditions not checked yet
                // also check postconditions when test failed
                // (because they are used to clean up side effects of failing tests)
                SuppressOutput here;
                postcond_result = run_postcond(&duration_usec_post, MAX_EXEC_MS_NORMAL, false); // but do not print anything
            }
        }

        double duration_ms_postcond  = duration_usec_post/1000.0;
        duration_ms                 += duration_ms_postcond;
    }

    return result == TEST_OK;
}


// --------------------------------------------------------------------------------

static char text_buffer[100];

inline const char *as_text(size_t z) { sprintf(text_buffer, "%zu", z); return text_buffer; }
inline const char *as_text(double d) { sprintf(text_buffer, "%.1f", d); return text_buffer; }

inline void appendValue(string& report, const char *tag, const char *value) { report = report+' '+tag+'='+value; }

inline void appendValue(string& report, const char *tag, size_t value) { appendValue(report, tag, as_text(value)); }
inline void appendValue(string& report, const char *tag, double value) { appendValue(report, tag, as_text(value)); }

static const char *generateReport(const char *libname, size_t tests, size_t skipped, size_t passed, double duration_ms, size_t warnings) {
    // generate a report consumed by reporter.pl@parse_log

    static string report;
    report.clear();

    size_t tested = tests-skipped;
    size_t failed = tested-passed;

    appendValue(report, "target", libname);
    appendValue(report, "time", duration_ms);
    appendValue(report, "tests", tests);
    if (skipped) appendValue(report, "skipped", skipped);
    if (tests) {
        if (!failed) appendValue(report, "passed", "ALL");
        else         appendValue(report, "passed", passed);
    }
    if (failed) appendValue(report, "failed", failed);
    if (warnings) appendValue(report, "warnings", warnings);

    return report.c_str()+1; // skip leading space
}

const size_t Mb = 1024*1024;
const size_t Gb = 1024*Mb;

UnitTester::UnitTester(const char *libname, const UnitTest_simple *simple_tests, int warn_level, size_t skippedTests, const UnitTest_simple *postcond) {
    // this is the "main()" of the unit test
    // it is invoked from code generated by sym2testcode.pl@InvokeUnitTester

#if !defined(LEAKS_SANITIZED) && !defined(UNDEF_SANITIZED)
    // restrict memory available for test-code (does not work together with sanitizer)
    ModRLimit restrict_virtual_memory(RLIMIT_AS, 1 * Gb);
#endif

    start_of_main();

    TEST_EXPECT_ZERO_OR_SHOW_ERRNO(chdir("run"));
    GLOBAL.runDir  = getcwd(NULp, ARB_PATH_MAX);
    GLOBAL.libname = libname;

    size_t tests  = 0;
    size_t passed = 0;

    {
        arb_test::GlobalTestData& global = arb_test::test_data();

        global.init(flag_callback);
        global.show_warnings = (warn_level != 0);

        double duration_ms = 0;
        {
            SimpleTester simple_tester(simple_tests, postcond);

            tests = simple_tester.get_test_count();
            if (tests) {
                passed      = simple_tester.perform_all();
                duration_ms = simple_tester.overall_duration_ms();
            }
        }

        trace("%s", generateReport(libname,
                                   tests+skippedTests, skippedTests, passed,
                                   duration_ms, global.warnings));
    }

    arb_test::GlobalTestData::erase_instance();
    exit(tests == passed ? EXIT_SUCCESS : EXIT_FAILURE);
}