CaptureLogs.h

#pragma once
 
#include <xrpl/basics/Log.h>
#include <xrpl/beast/utility/Journal.h>
 
#include <memory>
#include <mutex>
#include <sstream>
#include <string>
 
namespace xrpl::test {

class CaptureLogs : public Logs
{
    std::mutex strmMutex_;
    std::stringstream strm_;
    std::string* pResult_;

    class CaptureSink : public beast::Journal::Sink
    {
        std::mutex& strmMutex_;
        std::stringstream& strm_;
 
    public:
        CaptureSink(beast::Severity threshold, std::mutex& mutex, std::stringstream& strm)
            : beast::Journal::Sink(threshold, false), strmMutex_(mutex), strm_(strm)
        {
        }
 
        void
        write(beast::Severity level, std::string const& text) override
        {
            std::scoped_lock const lock(strmMutex_);
            strm_ << text;
        }
 
        void
        writeAlways(beast::Severity level, std::string const& text) override
        {
            std::scoped_lock const lock(strmMutex_);
            strm_ << text;
        }
    };
 
public:
    explicit CaptureLogs(std::string* pResult) : Logs(beast::Severity::Info), pResult_(pResult)
    {
    }
 
    ~CaptureLogs() override
    {
        *pResult_ = strm_.str();
    }
 
    std::unique_ptr<beast::Journal::Sink>
    makeSink(std::string const& partition, beast::Severity threshold) override
    {
        return std::make_unique<CaptureSink>(threshold, strmMutex_, strm_);
    }
};
 
}  // namespace xrpl::test