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(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 {