aboutsummaryrefslogtreecommitdiff
path: root/zenserver/diag
diff options
context:
space:
mode:
authorStefan Boberg <[email protected]>2023-05-02 10:01:47 +0200
committerGitHub <[email protected]>2023-05-02 10:01:47 +0200
commit075d17f8ada47e990fe94606c3d21df409223465 (patch)
treee50549b766a2f3c354798a54ff73404217b4c9af /zenserver/diag
parentfix: bundle shouldn't append content zip to zen (diff)
downloadzen-075d17f8ada47e990fe94606c3d21df409223465.tar.xz
zen-075d17f8ada47e990fe94606c3d21df409223465.zip
moved source directories into `/src` (#264)
* moved source directories into `/src` * updated bundle.lua for new `src` path * moved some docs, icon * removed old test trees
Diffstat (limited to 'zenserver/diag')
-rw-r--r--zenserver/diag/diagsvcs.cpp127
-rw-r--r--zenserver/diag/diagsvcs.h111
-rw-r--r--zenserver/diag/formatters.h71
-rw-r--r--zenserver/diag/logging.cpp467
-rw-r--r--zenserver/diag/logging.h10
5 files changed, 0 insertions, 786 deletions
diff --git a/zenserver/diag/diagsvcs.cpp b/zenserver/diag/diagsvcs.cpp
deleted file mode 100644
index 29ad5c3dd..000000000
--- a/zenserver/diag/diagsvcs.cpp
+++ /dev/null
@@ -1,127 +0,0 @@
-// Copyright Epic Games, Inc. All Rights Reserved.
-
-#include "diagsvcs.h"
-
-#include <zencore/compactbinary.h>
-#include <zencore/compactbinarybuilder.h>
-#include <zencore/config.h>
-#include <zencore/filesystem.h>
-#include <zencore/logging.h>
-#include <zencore/string.h>
-#include <fstream>
-#include <sstream>
-
-#include <json11.hpp>
-
-namespace zen {
-
-using namespace std::literals;
-
-bool
-ReadFile(const std::string& Path, StringBuilderBase& Out)
-{
- try
- {
- constexpr auto ReadSize = std::size_t{4096};
- auto FileStream = std::ifstream{Path};
-
- std::string Buf(ReadSize, '\0');
- while (FileStream.read(&Buf[0], ReadSize))
- {
- Out.Append(std::string_view(&Buf[0], FileStream.gcount()));
- }
- Out.Append(std::string_view(&Buf[0], FileStream.gcount()));
-
- return true;
- }
- catch (std::exception&)
- {
- Out.Reset();
- return false;
- }
-}
-
-HttpHealthService::HttpHealthService()
-{
- m_Router.RegisterRoute(
- "",
- [](HttpRouterRequest& RoutedReq) {
- HttpServerRequest& HttpReq = RoutedReq.ServerRequest();
- HttpReq.WriteResponse(HttpResponseCode::OK, HttpContentType::kText, u8"OK!"sv);
- },
- HttpVerb::kGet);
-
- m_Router.RegisterRoute(
- "info",
- [this](HttpRouterRequest& RoutedReq) {
- HttpServerRequest& HttpReq = RoutedReq.ServerRequest();
-
- CbObjectWriter Writer;
- Writer << "DataRoot"sv << m_HealthInfo.DataRoot.string();
- Writer << "AbsLogPath"sv << m_HealthInfo.AbsLogPath.string();
- Writer << "BuildVersion"sv << m_HealthInfo.BuildVersion;
- Writer << "HttpServerClass"sv << m_HealthInfo.HttpServerClass;
-
- HttpReq.WriteResponse(HttpResponseCode::OK, Writer.Save());
- },
- HttpVerb::kGet);
-
- m_Router.RegisterRoute(
- "log",
- [this](HttpRouterRequest& RoutedReq) {
- HttpServerRequest& HttpReq = RoutedReq.ServerRequest();
-
- zen::Log().flush();
-
- std::filesystem::path Path =
- m_HealthInfo.AbsLogPath.empty() ? m_HealthInfo.DataRoot / "logs/zenserver.log" : m_HealthInfo.AbsLogPath;
-
- ExtendableStringBuilder<4096> Sb;
- if (ReadFile(Path.string(), Sb) && Sb.Size() > 0)
- {
- HttpReq.WriteResponse(HttpResponseCode::OK, HttpContentType::kText, Sb.ToView());
- }
- else
- {
- HttpReq.WriteResponse(HttpResponseCode::NotFound);
- }
- },
- HttpVerb::kGet);
- m_Router.RegisterRoute(
- "version",
- [this](HttpRouterRequest& RoutedReq) {
- HttpServerRequest& HttpReq = RoutedReq.ServerRequest();
- if (HttpReq.GetQueryParams().GetValue("detailed") == "true")
- {
- HttpReq.WriteResponse(HttpResponseCode::OK, HttpContentType::kText, ZEN_CFG_VERSION_BUILD_STRING_FULL);
- }
- else
- {
- HttpReq.WriteResponse(HttpResponseCode::OK, HttpContentType::kText, ZEN_CFG_VERSION);
- }
- },
- HttpVerb::kGet);
-}
-
-void
-HttpHealthService::SetHealthInfo(HealthServiceInfo&& Info)
-{
- m_HealthInfo = std::move(Info);
-}
-
-const char*
-HttpHealthService::BaseUri() const
-{
- return "/health/";
-}
-
-void
-HttpHealthService::HandleRequest(HttpServerRequest& Request)
-{
- if (!m_Router.HandleRequest(Request))
- {
- Request.WriteResponse(HttpResponseCode::OK, HttpContentType::kText, u8"OK!"sv);
- }
-}
-
-} // namespace zen
diff --git a/zenserver/diag/diagsvcs.h b/zenserver/diag/diagsvcs.h
deleted file mode 100644
index bd03f8023..000000000
--- a/zenserver/diag/diagsvcs.h
+++ /dev/null
@@ -1,111 +0,0 @@
-// Copyright Epic Games, Inc. All Rights Reserved.
-
-#pragma once
-
-#include <zencore/iobuffer.h>
-#include <zenhttp/httpserver.h>
-
-#include <filesystem>
-
-//////////////////////////////////////////////////////////////////////////
-
-namespace zen {
-
-class HttpTestService : public HttpService
-{
- uint32_t LogPoint = 0;
-
-public:
- HttpTestService() {}
- ~HttpTestService() = default;
-
- virtual const char* BaseUri() const override { return "/test/"; }
-
- virtual void HandleRequest(HttpServerRequest& Request) override
- {
- using namespace std::literals;
-
- auto Uri = Request.RelativeUri();
-
- if (Uri == "hello"sv)
- {
- Request.WriteResponse(HttpResponseCode::OK, HttpContentType::kText, u8"hello world!"sv);
-
- // OutputLogMessageInternal(&LogPoint, 0, 0);
- }
- else if (Uri == "1K"sv)
- {
- Request.WriteResponse(HttpResponseCode::OK, HttpContentType::kBinary, m_1k);
- }
- else if (Uri == "1M"sv)
- {
- Request.WriteResponse(HttpResponseCode::OK, HttpContentType::kBinary, m_1m);
- }
- else if (Uri == "1M_1k"sv)
- {
- std::vector<IoBuffer> Buffers;
- Buffers.reserve(1024);
-
- for (int i = 0; i < 1024; ++i)
- {
- Buffers.push_back(m_1k);
- }
-
- Request.WriteResponse(HttpResponseCode::OK, HttpContentType::kBinary, Buffers);
- }
- else if (Uri == "1G"sv)
- {
- std::vector<IoBuffer> Buffers;
- Buffers.reserve(1024);
-
- for (int i = 0; i < 1024; ++i)
- {
- Buffers.push_back(m_1m);
- }
-
- Request.WriteResponse(HttpResponseCode::OK, HttpContentType::kBinary, Buffers);
- }
- else if (Uri == "1G_1k"sv)
- {
- std::vector<IoBuffer> Buffers;
- Buffers.reserve(1024 * 1024);
-
- for (int i = 0; i < 1024 * 1024; ++i)
- {
- Buffers.push_back(m_1k);
- }
-
- Request.WriteResponse(HttpResponseCode::OK, HttpContentType::kBinary, Buffers);
- }
- }
-
-private:
- IoBuffer m_1m{1024 * 1024};
- IoBuffer m_1k{m_1m, 0u, 1024};
-};
-
-struct HealthServiceInfo
-{
- std::filesystem::path DataRoot;
- std::filesystem::path AbsLogPath;
- std::string HttpServerClass;
- std::string BuildVersion;
-};
-
-class HttpHealthService : public HttpService
-{
-public:
- HttpHealthService();
- ~HttpHealthService() = default;
-
- void SetHealthInfo(HealthServiceInfo&& Info);
-
- virtual const char* BaseUri() const override;
- virtual void HandleRequest(HttpServerRequest& Request) override final;
-
-private:
- HttpRequestRouter m_Router;
- HealthServiceInfo m_HealthInfo;
-};
-
-} // namespace zen
diff --git a/zenserver/diag/formatters.h b/zenserver/diag/formatters.h
deleted file mode 100644
index 759df58d3..000000000
--- a/zenserver/diag/formatters.h
+++ /dev/null
@@ -1,71 +0,0 @@
-// Copyright Epic Games, Inc. All Rights Reserved.
-
-#pragma once
-
-#include <zencore/compactbinary.h>
-#include <zencore/compactbinaryvalidation.h>
-#include <zencore/iobuffer.h>
-#include <zencore/string.h>
-
-ZEN_THIRD_PARTY_INCLUDES_START
-#include <cpr/cpr.h>
-#include <fmt/format.h>
-ZEN_THIRD_PARTY_INCLUDES_END
-
-template<>
-struct fmt::formatter<cpr::Response>
-{
- constexpr auto parse(format_parse_context& Ctx) -> decltype(Ctx.begin()) { return Ctx.end(); }
-
- template<typename FormatContext>
- auto format(const cpr::Response& Response, FormatContext& Ctx) -> decltype(Ctx.out())
- {
- using namespace std::literals;
-
- if (Response.status_code == 200 || Response.status_code == 201)
- {
- return fmt::format_to(Ctx.out(),
- "Url: {}, Status: {}, Bytes: {}/{} (Up/Down), Elapsed: {}s",
- Response.url.str(),
- Response.status_code,
- Response.uploaded_bytes,
- Response.downloaded_bytes,
- Response.elapsed);
- }
- else
- {
- const auto It = Response.header.find("Content-Type");
- const std::string_view ContentType = It != Response.header.end() ? It->second : "<None>"sv;
-
- if (ContentType == "application/x-ue-cb"sv)
- {
- zen::IoBuffer Body(zen::IoBuffer::Wrap, Response.text.data(), Response.text.size());
- zen::CbObjectView Obj(Body.Data());
- zen::ExtendableStringBuilder<256> Sb;
- std::string_view Json = Obj.ToJson(Sb).ToView();
-
- return fmt::format_to(Ctx.out(),
- "Url: {}, Status: {}, Bytes: {}/{} (Up/Down), Elapsed: {}s, Response: '{}', Reason: '{}'",
- Response.url.str(),
- Response.status_code,
- Response.uploaded_bytes,
- Response.downloaded_bytes,
- Response.elapsed,
- Json,
- Response.reason);
- }
- else
- {
- return fmt::format_to(Ctx.out(),
- "Url: {}, Status: {}, Bytes: {}/{} (Up/Down), Elapsed: {}s, Reponse: '{}', Reason: '{}'",
- Response.url.str(),
- Response.status_code,
- Response.uploaded_bytes,
- Response.downloaded_bytes,
- Response.elapsed,
- Response.text,
- Response.reason);
- }
- }
- }
-};
diff --git a/zenserver/diag/logging.cpp b/zenserver/diag/logging.cpp
deleted file mode 100644
index 24c7572f4..000000000
--- a/zenserver/diag/logging.cpp
+++ /dev/null
@@ -1,467 +0,0 @@
-// Copyright Epic Games, Inc. All Rights Reserved.
-
-#include "logging.h"
-
-#include "config.h"
-
-ZEN_THIRD_PARTY_INCLUDES_START
-#include <spdlog/async.h>
-#include <spdlog/async_logger.h>
-#include <spdlog/pattern_formatter.h>
-#include <spdlog/sinks/ansicolor_sink.h>
-#include <spdlog/sinks/basic_file_sink.h>
-#include <spdlog/sinks/daily_file_sink.h>
-#include <spdlog/sinks/msvc_sink.h>
-#include <spdlog/sinks/rotating_file_sink.h>
-#include <spdlog/sinks/stdout_color_sinks.h>
-ZEN_THIRD_PARTY_INCLUDES_END
-
-#include <zencore/compactbinary.h>
-#include <zencore/filesystem.h>
-#include <zencore/string.h>
-
-#include <chrono>
-#include <memory>
-
-// Custom logging -- test code, this should be tweaked
-
-namespace logging {
-
-using namespace spdlog;
-using namespace spdlog::details;
-using namespace std::literals;
-
-class full_formatter final : public spdlog::formatter
-{
-public:
- full_formatter(std::string_view LogId, std::chrono::time_point<std::chrono::system_clock> Epoch) : m_Epoch(Epoch), m_LogId(LogId) {}
-
- virtual std::unique_ptr<formatter> clone() const override { return std::make_unique<full_formatter>(m_LogId, m_Epoch); }
-
- static constexpr bool UseDate = false;
-
- virtual void format(const details::log_msg& msg, memory_buf_t& dest) override
- {
- using std::chrono::duration_cast;
- using std::chrono::milliseconds;
- using std::chrono::seconds;
-
- if constexpr (UseDate)
- {
- auto secs = std::chrono::duration_cast<seconds>(msg.time.time_since_epoch());
- if (secs != m_LastLogSecs)
- {
- m_CachedTm = os::localtime(log_clock::to_time_t(msg.time));
- m_LastLogSecs = secs;
- }
- }
-
- const auto& tm_time = m_CachedTm;
-
- // cache the date/time part for the next second.
- auto duration = msg.time - m_Epoch;
- auto secs = duration_cast<seconds>(duration);
-
- if (m_CacheTimestamp != secs || m_CachedDatetime.size() == 0)
- {
- m_CachedDatetime.clear();
- m_CachedDatetime.push_back('[');
-
- if constexpr (UseDate)
- {
- fmt_helper::append_int(tm_time.tm_year + 1900, m_CachedDatetime);
- m_CachedDatetime.push_back('-');
-
- fmt_helper::pad2(tm_time.tm_mon + 1, m_CachedDatetime);
- m_CachedDatetime.push_back('-');
-
- fmt_helper::pad2(tm_time.tm_mday, m_CachedDatetime);
- m_CachedDatetime.push_back(' ');
-
- fmt_helper::pad2(tm_time.tm_hour, m_CachedDatetime);
- m_CachedDatetime.push_back(':');
-
- fmt_helper::pad2(tm_time.tm_min, m_CachedDatetime);
- m_CachedDatetime.push_back(':');
-
- fmt_helper::pad2(tm_time.tm_sec, m_CachedDatetime);
- }
- else
- {
- int Count = int(secs.count());
-
- const int LogSecs = Count % 60;
- Count /= 60;
-
- const int LogMins = Count % 60;
- Count /= 60;
-
- const int LogHours = Count;
-
- fmt_helper::pad2(LogHours, m_CachedDatetime);
- m_CachedDatetime.push_back(':');
- fmt_helper::pad2(LogMins, m_CachedDatetime);
- m_CachedDatetime.push_back(':');
- fmt_helper::pad2(LogSecs, m_CachedDatetime);
- }
-
- m_CachedDatetime.push_back('.');
-
- m_CacheTimestamp = secs;
- }
-
- dest.append(m_CachedDatetime.begin(), m_CachedDatetime.end());
-
- auto millis = fmt_helper::time_fraction<milliseconds>(msg.time);
- fmt_helper::pad3(static_cast<uint32_t>(millis.count()), dest);
- dest.push_back(']');
- dest.push_back(' ');
-
- if (!m_LogId.empty())
- {
- dest.push_back('[');
- fmt_helper::append_string_view(m_LogId, dest);
- dest.push_back(']');
- dest.push_back(' ');
- }
-
- // append logger name if exists
- if (msg.logger_name.size() > 0)
- {
- dest.push_back('[');
- fmt_helper::append_string_view(msg.logger_name, dest);
- dest.push_back(']');
- dest.push_back(' ');
- }
-
- dest.push_back('[');
- // wrap the level name with color
- msg.color_range_start = dest.size();
- fmt_helper::append_string_view(level::to_string_view(msg.level), dest);
- msg.color_range_end = dest.size();
- dest.push_back(']');
- dest.push_back(' ');
-
- // add source location if present
- if (!msg.source.empty())
- {
- dest.push_back('[');
- const char* filename = details::short_filename_formatter<details::null_scoped_padder>::basename(msg.source.filename);
- fmt_helper::append_string_view(filename, dest);
- dest.push_back(':');
- fmt_helper::append_int(msg.source.line, dest);
- dest.push_back(']');
- dest.push_back(' ');
- }
-
- fmt_helper::append_string_view(msg.payload, dest);
- fmt_helper::append_string_view("\n"sv, dest);
- }
-
-private:
- std::chrono::time_point<std::chrono::system_clock> m_Epoch;
- std::tm m_CachedTm;
- std::chrono::seconds m_LastLogSecs;
- std::chrono::seconds m_CacheTimestamp{0};
- memory_buf_t m_CachedDatetime;
- std::string m_LogId;
-};
-
-class json_formatter final : public spdlog::formatter
-{
-public:
- json_formatter(std::string_view LogId) : m_LogId(LogId) {}
-
- virtual std::unique_ptr<formatter> clone() const override { return std::make_unique<json_formatter>(m_LogId); }
-
- virtual void format(const details::log_msg& msg, memory_buf_t& dest) override
- {
- using std::chrono::duration_cast;
- using std::chrono::milliseconds;
- using std::chrono::seconds;
-
- auto secs = std::chrono::duration_cast<seconds>(msg.time.time_since_epoch());
- if (secs != m_LastLogSecs)
- {
- m_CachedTm = os::localtime(log_clock::to_time_t(msg.time));
- m_LastLogSecs = secs;
- }
-
- const auto& tm_time = m_CachedTm;
-
- // cache the date/time part for the next second.
-
- if (m_CacheTimestamp != secs || m_CachedDatetime.size() == 0)
- {
- m_CachedDatetime.clear();
-
- fmt_helper::append_int(tm_time.tm_year + 1900, m_CachedDatetime);
- m_CachedDatetime.push_back('-');
-
- fmt_helper::pad2(tm_time.tm_mon + 1, m_CachedDatetime);
- m_CachedDatetime.push_back('-');
-
- fmt_helper::pad2(tm_time.tm_mday, m_CachedDatetime);
- m_CachedDatetime.push_back(' ');
-
- fmt_helper::pad2(tm_time.tm_hour, m_CachedDatetime);
- m_CachedDatetime.push_back(':');
-
- fmt_helper::pad2(tm_time.tm_min, m_CachedDatetime);
- m_CachedDatetime.push_back(':');
-
- fmt_helper::pad2(tm_time.tm_sec, m_CachedDatetime);
-
- m_CachedDatetime.push_back('.');
-
- m_CacheTimestamp = secs;
- }
- dest.append("{"sv);
- dest.append("\"time\": \""sv);
- dest.append(m_CachedDatetime.begin(), m_CachedDatetime.end());
- auto millis = fmt_helper::time_fraction<milliseconds>(msg.time);
- fmt_helper::pad3(static_cast<uint32_t>(millis.count()), dest);
- dest.append("\", "sv);
-
- dest.append("\"status\": \""sv);
- dest.append(level::to_string_view(msg.level));
- dest.append("\", "sv);
-
- dest.append("\"source\": \""sv);
- dest.append("zenserver"sv);
- dest.append("\", "sv);
-
- dest.append("\"service\": \""sv);
- dest.append("zencache"sv);
- dest.append("\", "sv);
-
- if (!m_LogId.empty())
- {
- dest.append("\"id\": \""sv);
- dest.append(m_LogId);
- dest.append("\", "sv);
- }
-
- if (msg.logger_name.size() > 0)
- {
- dest.append("\"logger.name\": \""sv);
- dest.append(msg.logger_name);
- dest.append("\", "sv);
- }
-
- if (msg.thread_id != 0)
- {
- dest.append("\"logger.thread_name\": \""sv);
- fmt_helper::pad_uint(msg.thread_id, 0, dest);
- dest.append("\", "sv);
- }
-
- if (!msg.source.empty())
- {
- dest.append("\"file\": \""sv);
- WriteEscapedString(dest, details::short_filename_formatter<details::null_scoped_padder>::basename(msg.source.filename));
- dest.append("\","sv);
-
- dest.append("\"line\": \""sv);
- dest.append(fmt::format("{}", msg.source.line));
- dest.append("\","sv);
-
- dest.append("\"logger.method_name\": \""sv);
- WriteEscapedString(dest, msg.source.funcname);
- dest.append("\", "sv);
- }
-
- dest.append("\"message\": \""sv);
- WriteEscapedString(dest, msg.payload);
- dest.append("\""sv);
-
- dest.append("}\n"sv);
- }
-
-private:
- static inline const std::unordered_map<char, std::string_view> SpecialCharacterMap{{'\b', "\\b"sv},
- {'\f', "\\f"sv},
- {'\n', "\\n"sv},
- {'\r', "\\r"sv},
- {'\t', "\\t"sv},
- {'"', "\\\""sv},
- {'\\', "\\\\"sv}};
-
- static void WriteEscapedString(memory_buf_t& dest, const spdlog::string_view_t& payload)
- {
- const char* RangeStart = payload.begin();
- for (const char* It = RangeStart; It != payload.end(); ++It)
- {
- if (auto SpecialIt = SpecialCharacterMap.find(*It); SpecialIt != SpecialCharacterMap.end())
- {
- if (RangeStart != It)
- {
- dest.append(RangeStart, It);
- }
- dest.append(SpecialIt->second);
- RangeStart = It + 1;
- }
- }
- if (RangeStart != payload.end())
- {
- dest.append(RangeStart, payload.end());
- }
- };
-
- std::tm m_CachedTm{0, 0, 0, 0, 0, 0, 0, 0, 0};
- std::chrono::seconds m_LastLogSecs{0};
- std::chrono::seconds m_CacheTimestamp{0};
- memory_buf_t m_CachedDatetime;
- std::string m_LogId;
-};
-
-bool
-EnableVTMode()
-{
-#if ZEN_PLATFORM_WINDOWS
- // Set output mode to handle virtual terminal sequences
- HANDLE hOut = GetStdHandle(STD_OUTPUT_HANDLE);
- if (hOut == INVALID_HANDLE_VALUE)
- {
- return false;
- }
-
- DWORD dwMode = 0;
- if (!GetConsoleMode(hOut, &dwMode))
- {
- return false;
- }
-
- dwMode |= ENABLE_VIRTUAL_TERMINAL_PROCESSING;
- if (!SetConsoleMode(hOut, dwMode))
- {
- return false;
- }
-#endif
-
- return true;
-}
-
-} // namespace logging
-
-void
-InitializeLogging(const ZenServerOptions& GlobalOptions)
-{
- zen::logging::InitializeLogging();
- logging::EnableVTMode();
-
- bool IsAsync = true;
- spdlog::level::level_enum LogLevel = spdlog::level::info;
-
- if (GlobalOptions.IsDebug)
- {
- LogLevel = spdlog::level::debug;
- IsAsync = false;
- }
-
- if (GlobalOptions.IsTest)
- {
- LogLevel = spdlog::level::trace;
- IsAsync = false;
- }
-
- if (IsAsync)
- {
- const int QueueSize = 8192;
- const int ThreadCount = 1;
- spdlog::init_thread_pool(QueueSize, ThreadCount);
-
- auto AsyncLogger = spdlog::create_async<spdlog::sinks::ansicolor_stdout_sink_mt>("main");
- zen::logging::SetDefault(AsyncLogger);
- }
-
- // Sinks
-
- auto ConsoleSink = std::make_shared<spdlog::sinks::ansicolor_stdout_sink_mt>();
-
- // spdlog can't create directories that starts with `\\?\` so we make sure the folder exists before creating the logger instance
- zen::CreateDirectories(GlobalOptions.AbsLogFile.parent_path());
-
-#if 0
- auto FileSink = std::make_shared<spdlog::sinks::daily_file_sink_mt>(zen::PathToUtf8(GlobalOptions.AbsLogFile),
- 0,
- 0,
- /* truncate */ false,
- uint16_t(/* max files */ 14));
-#else
- auto FileSink = std::make_shared<spdlog::sinks::rotating_file_sink_mt>(zen::PathToUtf8(GlobalOptions.AbsLogFile),
- /* max size */ 128 * 1024 * 1024,
- /* max files */ 16,
- /* rotate on open */ true);
-#endif
-
- std::set_terminate([]() { ZEN_CRITICAL("Program exited abnormally via std::terminate()"); });
-
- // Default
-
- auto& DefaultLogger = zen::logging::Default();
- auto& Sinks = DefaultLogger.sinks();
-
- Sinks.clear();
- Sinks.push_back(ConsoleSink);
- Sinks.push_back(FileSink);
-
-#if ZEN_PLATFORM_WINDOWS
- if (zen::IsDebuggerPresent() && GlobalOptions.IsDebug)
- {
- auto DebugSink = std::make_shared<spdlog::sinks::msvc_sink_mt>();
- DebugSink->set_level(spdlog::level::debug);
- Sinks.push_back(DebugSink);
- }
-#endif
-
- // HTTP server request logging
-
- std::filesystem::path HttpLogPath = GlobalOptions.DataDir / "logs" / "http.log";
-
- // spdlog can't create directories that starts with `\\?\` so we make sure the folder exists before creating the logger instance
- zen::CreateDirectories(HttpLogPath.parent_path());
-
- auto HttpSink = std::make_shared<spdlog::sinks::rotating_file_sink_mt>(zen::PathToUtf8(HttpLogPath),
- /* max size */ 128 * 1024 * 1024,
- /* max files */ 16,
- /* rotate on open */ true);
-
- auto HttpLogger = std::make_shared<spdlog::logger>("http_requests", HttpSink);
- spdlog::register_logger(HttpLogger);
-
- // Jupiter - only log upstream HTTP traffic to file
-
- auto JupiterLogger = std::make_shared<spdlog::logger>("jupiter", FileSink);
- spdlog::register_logger(JupiterLogger);
-
- // Zen - only log upstream HTTP traffic to file
-
- auto ZenClientLogger = std::make_shared<spdlog::logger>("zenclient", FileSink);
- spdlog::register_logger(ZenClientLogger);
-
- // Configure all registered loggers according to settings
-
- spdlog::set_level(LogLevel);
- spdlog::flush_on(spdlog::level::err);
- spdlog::flush_every(std::chrono::seconds{2});
- spdlog::set_formatter(std::make_unique<logging::full_formatter>(GlobalOptions.LogId, std::chrono::system_clock::now()));
-
- if (GlobalOptions.AbsLogFile.extension() == ".json")
- {
- FileSink->set_formatter(std::make_unique<logging::json_formatter>(GlobalOptions.LogId));
- }
- else
- {
- FileSink->set_pattern("[%C-%m-%d.%e %T] [%n] [%l] %v");
- }
- DefaultLogger.info("log starting at {}", zen::DateTime::Now().ToIso8601());
-}
-
-void
-ShutdownLogging()
-{
- auto& DefaultLogger = zen::logging::Default();
- DefaultLogger.info("log ending at {}", zen::DateTime::Now().ToIso8601());
- zen::logging::ShutdownLogging();
-}
diff --git a/zenserver/diag/logging.h b/zenserver/diag/logging.h
deleted file mode 100644
index 8df49f842..000000000
--- a/zenserver/diag/logging.h
+++ /dev/null
@@ -1,10 +0,0 @@
-// Copyright Epic Games, Inc. All Rights Reserved.
-
-#pragma once
-
-#include <zencore/logging.h>
-struct ZenServerOptions;
-
-void InitializeLogging(const ZenServerOptions& GlobalOptions);
-
-void ShutdownLogging();