Revert "Merge tag 'tags/24.3.9-hotfix-2' into stream-nb-24-3"

This reverts commit 989fbc6, reversing
changes made to eb870f2.

Author: mvgorbunov

.github/config/muted_ya.txt

@@ -9,7 +9,9 @@ ydb/core/quoter/ut QuoterWithKesusTest.PrefetchCoefficient
 ydb/core/keyvalue/ut_trace TKeyValueTracingTest.*
 ydb/core/kqp/provider/ut KikimrIcGateway.TestLoadBasicSecretValueFromExternalDataSourceMetadata
 ydb/core/kqp/ut/olap KqpOlapBlobsSharing.*
+ydb/core/kqp/ut/olap KqpOlap.ScanQueryOltpAndOlap
 ydb/core/kqp/ut/olap KqpOlapStatistics.StatsUsageWithTTL
+ydb/core/kqp/ut/olap KqpOlap.YqlScriptOltpAndOlap
 ydb/core/kqp/ut/olap KqpOlapAggregations.Aggregation_ResultCountAll_FilterL
 ydb/core/kqp/ut/olap KqpOlapWrite.WriteDeleteCleanGC
 ydb/core/kqp/ut/pg KqpPg.CreateIndex
@@ -30,7 +32,6 @@ ydb/core/kqp/ut/service KqpQueryService.ExecuteQueryPgTableSelect
 ydb/core/kqp/ut/service KqpQueryService.QueryOnClosedSession
 ydb/core/kqp/ut/service KqpService.CloseSessionsWithLoad
 ydb/core/kqp/ut/service [38/50]*
-ydb/core/kqp/ut/service KqpQueryService.TableSink_OltpUpdate
 ydb/core/persqueue/ut [37/40] chunk chunk
 ydb/core/persqueue/ut [38/40] chunk chunk
 ydb/core/persqueue/ut TPQTest.*DirectRead*

ydb/apps/ydbd/ya.make

@@ -1,8 +1,6 @@
 PROGRAM(ydbd)
 
-IF (NOT SANITIZER_TYPE)  # for some reasons some tests with asan are failed, see comment in CPPCOM-32
-    NO_EXPORT_DYNAMIC_SYMBOLS()
-ENDIF()
+NO_EXPORT_DYNAMIC_SYMBOLS()
 
 IF (OS_LINUX)
     ALLOCATOR(TCMALLOC_256K)

ydb/core/audit/audit_log.cpp

@@ -0,0 +1,24 @@
+#include "audit_log.h"
+#include "audit_log_impl.h"
+
+#include <library/cpp/logger/record.h>
+#include <ydb/library/actors/core/hfunc.h>
+#include <ydb/library/actors/core/log.h>
+
+namespace NKikimr::NAudit {
+
+std::atomic<bool> AUDIT_LOG_ENABLED = false;
+
+THolder<NActors::IActor> CreateAuditWriter(TMap<NKikimrConfig::TAuditConfig::EFormat, TVector<THolder<TLogBackend>>> logBackends)
+{
+    AUDIT_LOG_ENABLED.store(true);
+    return MakeHolder<TAuditLogActor>(std::move(logBackends));
+}
+
+void SendAuditLog(const NActors::TActorSystem* sys, TVector<std::pair<TString, TString>>&& parts)
+{
+    auto request = MakeHolder<TEvAuditLog::TEvWriteAuditLog>(Now(), std::move(parts));
+    sys->Send(MakeAuditServiceID(), request.Release());
+}
+
+}    // namespace NKikimr::NAudit

ydb/core/audit/audit_log.h

@@ -1,12 +1,19 @@
 #pragma once
 
-#include <utility>
-#include <atomic>
-
-#include <util/generic/string.h>
-#include <util/generic/vector.h>
+#include <ydb/core/base/events.h>
 
 #include <ydb/library/actors/core/actor.h>
+#include <ydb/library/actors/core/events.h>
+#include <library/cpp/logger/backend.h>
+#include <ydb/core/protos/config.pb.h>
+#include <ydb/library/services/services.pb.h>
+
+#include <library/cpp/logger/record.h>
+#include <ydb/library/actors/core/hfunc.h>
+#include <ydb/library/actors/core/log.h>
+
+#include <util/generic/strbuf.h>
+#include <util/datetime/base.h>
 
 #define AUDIT_LOG_S(sys, expr)                                                                                                  \
     do {                                                                                                                        \
@@ -17,7 +24,7 @@
         }                                                                                                                       \
     } while (0) /**/
 
-#define AUDIT_LOG(expr) AUDIT_LOG_S((::NActors::TlsActivationContext->ExecutorThread.ActorSystem), expr)
+#define AUDIT_LOG(expr) AUDIT_LOG_S((TlsActivationContext->ExecutorThread.ActorSystem), expr)
 
 #define AUDIT_PART_NO_COND(key, value) AUDIT_PART_COND(key, value, true)
 #define AUDIT_PART_COND(key, value, condition)                                                                                    \
@@ -30,14 +37,90 @@
 #define GET_AUDIT_PART_MACRO(_1, _2, _3, NAME,...) NAME
 #define AUDIT_PART(...) GET_AUDIT_PART_MACRO(__VA_ARGS__, AUDIT_PART_COND, AUDIT_PART_NO_COND)(__VA_ARGS__)
 
-namespace NActors {
-    class TActorSystem;
-}
-
 namespace NKikimr::NAudit {
 
 extern std::atomic<bool> AUDIT_LOG_ENABLED;
 
+struct TEvAuditLog
+{
+    //
+    // Events declaration
+    //
+
+    enum EEvents
+    {
+        EvBegin = EventSpaceBegin(TKikimrEvents::ES_YDB_AUDIT_LOG),
+
+        // Request actors
+        EvWriteAuditLog = EvBegin + 0,
+
+        EvEnd
+    };
+
+    static_assert(EvEnd <= EventSpaceEnd(TKikimrEvents::ES_YDB_AUDIT_LOG),
+                  "expected EvEnd <= EventSpaceEnd(TKikimrEvents::ES_YDB_AUDIT_LOG)");
+
+    struct TEvWriteAuditLog
+        : public NActors::TEventLocal<TEvWriteAuditLog, EvWriteAuditLog>
+    {
+        TInstant Time;
+        TVector<std::pair<TString, TString>> Parts;
+
+        TEvWriteAuditLog(TInstant time, TVector<std::pair<TString, TString>>&& parts)
+            : Time(time)
+            , Parts(std::move(parts))
+        {}
+    };
+};
+
+class TAuditLogActor final
+    : public TActor<TAuditLogActor>
+{
+private:
+    const TMap<NKikimrConfig::TAuditConfig::EFormat, TVector<THolder<TLogBackend>>> LogBackends;
+public:
+    TAuditLogActor(TMap<NKikimrConfig::TAuditConfig::EFormat, TVector<THolder<TLogBackend>>> logBackends)
+        : TActor(&TThis::StateWork)
+        , LogBackends(std::move(logBackends))
+    {
+    }
+
+    static constexpr NKikimrServices::TActivity::EType ActorActivityType() {
+        return NKikimrServices::TActivity::AUDIT_WRITER_ACTOR;
+    }
+
+private:
+    STFUNC(StateWork);
+
+    void HandlePoisonPill(
+        const TEvents::TEvPoisonPill::TPtr& ev,
+        const TActorContext& ctx);
+
+    void HandleWriteAuditLog(
+        const TEvAuditLog::TEvWriteAuditLog::TPtr& ev,
+        const TActorContext& ctx);
+
+    static void WriteLog(
+        const TString& log,
+        const TVector<THolder<TLogBackend>>& logBackends);
+
+    static TString GetJsonLog(
+        const TEvAuditLog::TEvWriteAuditLog::TPtr& ev);
+
+    static TString GetTxtLog(
+        const TEvAuditLog::TEvWriteAuditLog::TPtr& ev);
+
+    void HandleUnexpectedEvent(STFUNC_SIG);
+};
+
+////////////////////////////////////////////////////////////////////////////////
+
 void SendAuditLog(const NActors::TActorSystem* sys, TVector<std::pair<TString, TString>>&& parts);
 
+inline NActors::TActorId MakeAuditServiceID() {
+    return NActors::TActorId(0, TStringBuf("YDB_AUDIT"));
+}
+
+THolder<NActors::IActor> CreateAuditWriter(TMap<NKikimrConfig::TAuditConfig::EFormat, TVector<THolder<TLogBackend>>> logBackends);
+
 }   // namespace NKikimr::NAudit