From 4cbf4d816c9a07c303131fbc2a5650854d62dec7 Mon Sep 17 00:00:00 2001
From: Andrey Tvorozhkov <andrey@head-labs.com>
Date: Mon, 16 Sep 2024 11:24:18 +0300
Subject: [PATCH] Publish calls

---
 lite-server-daemon/adnl-lite-proxy.cpp | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/lite-server-daemon/adnl-lite-proxy.cpp b/lite-server-daemon/adnl-lite-proxy.cpp
index 4c4e6ed8a..b6b4c3a71 100644
--- a/lite-server-daemon/adnl-lite-proxy.cpp
+++ b/lite-server-daemon/adnl-lite-proxy.cpp
@@ -917,6 +917,8 @@ namespace ton::liteserver {
                                                                                       error->message_ +
                                                                                       " : tried over all nodes");
                     process_cache(std::move(data), res.clone(), compiled_query, elapsed);
+                    td::actor::send_closure(actor_id(this), &LiteProxy::publish_call, dst, std::move(data), started_at,
+                                            elapsed);
                     promise.set_value(std::move(res));
                     return;
                   } else {
@@ -939,6 +941,8 @@ namespace ton::liteserver {
                                                                                   error->message_ +
                                                                                   " : tried over all nodes");
                 process_cache(std::move(data), res.clone(), compiled_query, elapsed);
+                td::actor::send_closure(actor_id(this), &LiteProxy::publish_call, dst, std::move(data), started_at,
+                                        elapsed);
                 promise.set_value(std::move(res));
                 return;
               } else {
@@ -955,6 +959,8 @@ namespace ton::liteserver {
               LOG(INFO)
               << "Query to: " << server_adnl << " success, Query: " << compiled_query << " Elapsed: " << elapsed;
               process_cache(std::move(data), res.clone(), compiled_query, elapsed);
+              td::actor::send_closure(actor_id(this), &LiteProxy::publish_call, dst, std::move(data), started_at,
+                                      elapsed);
               promise.set_value(std::move(res));
               return;
             }
@@ -969,6 +975,8 @@ namespace ton::liteserver {
               LOG(ERROR) << "Too deep refire";
               auto res = create_serialize_tl_object<lite_api::liteServer_error>(228, error.message().str());
               process_cache(std::move(data), res.clone(), compiled_query, elapsed);
+              td::actor::send_closure(actor_id(this), &LiteProxy::publish_call, dst, std::move(data), started_at,
+                                      elapsed);
               promise.set_value(std::move(res));
               return;
             } else {