intermediate changes

ref:cde9a383711a11544ce7e107a78147fb96cc4029

5 files changed, 127 insertions, 0 deletions

diff --git a/library/cpp/monlib/messagebus/mon_messagebus.cpp b/library/cpp/monlib/messagebus/mon_messagebus.cpp
new file mode 100644
index 0000000000..355b4386cd
--- /dev/null
+++ b/library/cpp/monlib/messagebus/mon_messagebus.cpp
@@ -0,0 +1,11 @@
+#include <library/cpp/messagebus/www/www.h>
+
+#include "mon_messagebus.h"
+
+using namespace NMonitoring;
+
+void TBusNgMonPage::Output(NMonitoring::IMonHttpRequest& request) {
+    NBus::TBusWww::TOptionalParams params;
+    params.ParentLinks.push_back(NBus::TBusWww::TLink{"/", request.GetServiceTitle()});
+    BusWww->ServeHttp(request.Output(), request.GetParams(), params);
+}
diff --git a/library/cpp/monlib/messagebus/mon_messagebus.h b/library/cpp/monlib/messagebus/mon_messagebus.h
new file mode 100644
index 0000000000..e1fa73c69f
--- /dev/null
+++ b/library/cpp/monlib/messagebus/mon_messagebus.h
@@ -0,0 +1,46 @@
+#pragma once
+
+#include <library/cpp/messagebus/ybus.h>
+#include <library/cpp/messagebus/www/www.h>
+
+#include <library/cpp/monlib/service/pages/mon_page.h>
+
+namespace NMonitoring {
+    template <class TBusSmth>
+    class TBusSmthMonPage: public NMonitoring::IMonPage {
+    private:
+        TBusSmth* Smth;
+
+    public:
+        explicit TBusSmthMonPage(const TString& name, const TString& title, TBusSmth* smth)
+            : IMonPage("msgbus/" + name, title)
+            , Smth(smth)
+        {
+        }
+        void Output(NMonitoring::IMonHttpRequest& request) override {
+            Y_UNUSED(request);
+            request.Output() << NMonitoring::HTTPOKHTML;
+            request.Output() << "<h2>" << Title << "</h2>";
+            request.Output() << "<pre>";
+            request.Output() << Smth->GetStatus();
+            request.Output() << "</pre>";
+        }
+    };
+
+    using TBusQueueMonPage = TBusSmthMonPage<NBus::TBusMessageQueue>;
+    using TBusModuleMonPage = TBusSmthMonPage<NBus::TBusModule>;
+
+    class TBusNgMonPage: public NMonitoring::IMonPage {
+    public:
+        TIntrusivePtr<NBus::TBusWww> BusWww;
+
+    public:
+        TBusNgMonPage()
+            : IMonPage("messagebus", "MessageBus")
+            , BusWww(new NBus::TBusWww)
+        {
+        }
+        void Output(NMonitoring::IMonHttpRequest& request) override;
+    };
+
+}
diff --git a/library/cpp/monlib/messagebus/mon_service_messagebus.cpp b/library/cpp/monlib/messagebus/mon_service_messagebus.cpp
new file mode 100644
index 0000000000..4dd144ebe8
--- /dev/null
+++ b/library/cpp/monlib/messagebus/mon_service_messagebus.cpp
@@ -0,0 +1,8 @@
+#include "mon_service_messagebus.h"
+
+using namespace NMonitoring;
+
+TMonServiceMessageBus::TMonServiceMessageBus(ui16 port, const TString& title)
+    : TMonService2(port, title)
+{
+}
diff --git a/library/cpp/monlib/messagebus/mon_service_messagebus.h b/library/cpp/monlib/messagebus/mon_service_messagebus.h
new file mode 100644
index 0000000000..fe791e8a9b
--- /dev/null
+++ b/library/cpp/monlib/messagebus/mon_service_messagebus.h
@@ -0,0 +1,46 @@
+#pragma once
+
+#include "mon_messagebus.h"
+
+#include <library/cpp/monlib/service/monservice.h>
+
+#include <util/system/mutex.h>
+
+namespace NMonitoring {
+    class TMonServiceMessageBus: public TMonService2 {
+    private:
+        TMutex Mtx;
+        TIntrusivePtr<NMonitoring::TBusNgMonPage> BusNgMonPage;
+
+    public:
+        TMonServiceMessageBus(ui16 port, const TString& title);
+
+    private:
+        NBus::TBusWww* RegisterBusNgMonPage() {
+            TGuard<TMutex> g(Mtx);
+            if (!BusNgMonPage) {
+                BusNgMonPage = new NMonitoring::TBusNgMonPage();
+                Register(BusNgMonPage.Get());
+            }
+            return BusNgMonPage->BusWww.Get();
+        }
+
+    public:
+        void RegisterClientSession(NBus::TBusClientSessionPtr clientSession) {
+            RegisterBusNgMonPage()->RegisterClientSession(clientSession);
+        }
+
+        void RegisterServerSession(NBus::TBusServerSessionPtr serverSession) {
+            RegisterBusNgMonPage()->RegisterServerSession(serverSession);
+        }
+
+        void RegisterQueue(NBus::TBusMessageQueuePtr queue) {
+            RegisterBusNgMonPage()->RegisterQueue(queue);
+        }
+
+        void RegisterModule(NBus::TBusModule* module) {
+            RegisterBusNgMonPage()->RegisterModule(module);
+        }
+    };
+
+}
diff --git a/library/cpp/monlib/messagebus/ya.make b/library/cpp/monlib/messagebus/ya.make
new file mode 100644
index 0000000000..a0b5362296
--- /dev/null
+++ b/library/cpp/monlib/messagebus/ya.make
@@ -0,0 +1,16 @@
+LIBRARY()
+
+OWNER(g:solomon)
+
+SRCS(
+    mon_messagebus.cpp
+    mon_service_messagebus.cpp
+)
+
+PEERDIR(
+    library/cpp/messagebus
+    library/cpp/messagebus/www
+    library/cpp/monlib/dynamic_counters
+)
+
+END()