#include "registar.h"

#include <util/datetime/base.h>
#include <util/generic/maybe.h>
#include <util/system/tempfile.h>

#include <optional>

namespace NUnitTest {

extern const TString Y_UNITTEST_OUTPUT_CMDLINE_OPTION;
extern const TString Y_UNITTEST_TEST_FILTER_FILE_OPTION;

class TJUnitProcessor : public ITestSuiteProcessor {
    struct TFailure {
        TString Message;
        TString BackTrace;
    };

    struct TTestCase {
        TString Name;
        bool Success;
        TVector<TFailure> Failures;
        TString StdOut;
        TString StdErr;
        double DurationSecods = 0.0;

        size_t GetFailuresCount() const {
            return Failures.size();
        }
    };

    struct TTestSuite {
        TMap<TString, TTestCase> Cases;

        size_t GetTestsCount() const {
            return Cases.size();
        }

        size_t GetFailuresCount() const {
            size_t sum = 0;
            for (const auto& [name, testCase] : Cases) {
                sum += testCase.GetFailuresCount();
            }
            return sum;
        }

        double GetDurationSeconds() const {
            double sum = 0.0;
            for (const auto& [name, testCase] : Cases) {
                sum += testCase.DurationSecods;
            }
            return sum;
        }
    };

    // Holds a copy of TTest structure for current test
    class TCurrentTest {
    public:
        TCurrentTest(const TTest* test)
            : TestName(test->name)
            , Unit(*test->unit)
            , Test{&Unit, TestName.c_str()}
        {
        }

        operator const TTest*() const {
            return &Test;
        }

    private:
        TString TestName;
        TUnit Unit;
        TTest Test;
    };

    struct TOutputCapturer;

public:
    enum class EOutputFormat {
        Xml,
        Json,
    };

    TJUnitProcessor(TString file, TString exec, EOutputFormat outputFormat);
    ~TJUnitProcessor();

    void SetForkTestsParams(bool forkTests, bool isForked) override;

    void OnBeforeTest(const TTest* test) override;
    void OnError(const TError* descr) override;
    void OnFinish(const TFinish* descr) override;

private:
    TTestCase* GetTestCase(const TTest* test) {
        auto& suite = Suites[test->unit->name];
        return &suite.Cases[test->name];
    }

    void Save();

    size_t GetTestsCount() const {
        size_t sum = 0;
        for (const auto& [name, suite] : Suites) {
            sum += suite.GetTestsCount();
        }
        return sum;
    }

    size_t GetFailuresCount() const {
        size_t sum = 0;
        for (const auto& [name, suite] : Suites) {
            sum += suite.GetFailuresCount();
        }
        return sum;
    }

    void SerializeToFile();
    void SerializeToXml();
    void SerializeToJson();
    void MergeSubprocessReport();

    TString BuildFileName(size_t index, const TStringBuf extension) const;
    TStringBuf GetFileExtension() const;
    void MakeReportFileName();
    void MakeTmpFileNameForForkedTests();
    static void TransferFromCapturer(THolder<TJUnitProcessor::TOutputCapturer>& capturer, TString& out, IOutputStream& outStream);

    static void CaptureSignal(TJUnitProcessor* processor);
    static void UncaptureSignal();
    static void SignalHandler(int signal);

private:
    const TString FileName; // cmd line param
    const TString ExecName; // cmd line param
    const EOutputFormat OutputFormat;
    TString ResultReportFileName;
    TMaybe<TTempFile> TmpReportFile;
    TMap<TString, TTestSuite> Suites;
    THolder<TOutputCapturer> StdErrCapturer;
    THolder<TOutputCapturer> StdOutCapturer;
    TInstant StartCurrentTestTime;
    void (*PrevAbortHandler)(int) = nullptr;
    void (*PrevSegvHandler)(int) = nullptr;
    std::optional<TCurrentTest> CurrentTest;
};

} // namespace NUnitTest