Tag final batch: Factory, PoolNode, submitblock, Stratum traces

  [Net]      Factory connect/resolve failures (demoted handshake to TRACE)
  [CoinP2P]  Version handshake, connection events
  [P2Pool]   PoolNode errors, peer connect events
  [LTC]      submitblock traces (received/merkle/relay/stale)
  [Stratum]  mining.submit trace, message received trace

Now every runtime log line has a protocol/chain prefix.
Startup/config messages are the only untagged lines (intentional).

Author: frstrtr

src/core/factory.hpp

@@ -95,13 +95,13 @@ class Client
 				if (ec)
 				{
 					if (ec != boost::system::errc::operation_canceled)
-						LOG_WARNING << "Factory::Client::connect_socket failed: " << ec.message();
+						LOG_WARNING << "[Net] Connection failed: " << ec.message();
 					else
 						LOG_DEBUG_COIND << "Factory::Client::connect_socket canceled";
 					return;
 				}
 
-				LOG_INFO << "Factory::Client::connect_socket try handshake with " << ep.address() << ":" << ep.port();
+				LOG_TRACE << "[Net] Handshake with " << ep.address() << ":" << ep.port();
 				socket->init();
 
 				m_node->connected(socket);
@@ -118,7 +118,7 @@ class Client
 				{
 
 					if (ec != boost::system::errc::operation_canceled)
-						LOG_WARNING << "Factory::Client::resolve failed: " << ec.message();
+						LOG_WARNING << "[Net] DNS resolve failed: " << ec.message();
 					else
 						LOG_DEBUG_OTHER << "Factory::Client::resolve canceled";
 					return;

src/core/web_server.cpp

@@ -1715,11 +1715,11 @@ nlohmann::json MiningInterface::getblocktemplate(const nlohmann::json& params, c
 
 nlohmann::json MiningInterface::submitblock(const std::string& hex_data, const std::string& request_id)
 {
-    LOG_TRACE << "submitblock: received " << hex_data.length() / 2 << " bytes";
+    LOG_TRACE << "[LTC] submitblock: received " << hex_data.length() / 2 << " bytes";
 
     // Block header is 80 bytes = 160 hex chars minimum
     if (hex_data.size() < 160) {
-        LOG_ERROR << "submitblock: hex data too short for a valid block header";
+        LOG_ERROR << "[LTC] submitblock: hex data too short for a valid block header";
         return {{"error", "block data too short"}};
     }
 
@@ -1751,7 +1751,7 @@ nlohmann::json MiningInterface::submitblock(const std::string& hex_data, const s
                 uint256 expected_prev;
                 expected_prev.SetHex(m_cached_template["previousblockhash"].get<std::string>());
                 if (submitted_prev_hash != expected_prev) {
-                    LOG_WARNING << "submitblock: stale block — prev_hash mismatch"
+                    LOG_WARNING << "[LTC] submitblock: stale block — prev_hash mismatch"
                                 << " submitted=" << submitted_prev_hash.GetHex()
                                 << " expected=" << expected_prev.GetHex();
                     is_stale = true;
@@ -1760,7 +1760,7 @@ nlohmann::json MiningInterface::submitblock(const std::string& hex_data, const s
 
             // Reconstruct expected merkle_root from coinbase + merkle branches
             if (!is_stale && !m_cached_coinb1.empty() && !m_cached_coinb2.empty()) {
-                LOG_TRACE << "submitblock: merkle_root=" << submitted_merkle_root.GetHex();
+                LOG_TRACE << "[LTC] submitblock: merkle_root=" << submitted_merkle_root.GetHex();
             }
         }
         // Fire stale callback OUTSIDE the lock to avoid deadlock
@@ -1797,13 +1797,13 @@ nlohmann::json MiningInterface::submitblock(const std::string& hex_data, const s
     } else if (m_embedded_node) {
         // Phase 4 embedded mode: no daemon — relay the block directly via P2P.
         // on_block_relay is wired to CoinBroadcaster::submit_block_raw().
-        LOG_TRACE << "submitblock: embedded relay " << hex_data.size()/2 << " bytes";
+        LOG_TRACE << "[LTC] submitblock: embedded relay " << hex_data.size()/2 << " bytes";
         if (m_on_block_relay)
             m_on_block_relay(hex_data);
         if (m_on_block_submitted && hex_data.size() >= 160)
             m_on_block_submitted(hex_data.substr(0, 160), 0);
     } else {
-        LOG_WARNING << "submitblock: no coin RPC or embedded node connected, block discarded";
+        LOG_WARNING << "[LTC] submitblock: no coin RPC or embedded node connected, block discarded";
     }
 
     return nullptr; // null = accepted in getblocktemplate spec
@@ -3784,7 +3784,7 @@ nlohmann::json MiningInterface::mining_submit(const std::string& username, const
     const std::map<uint32_t, std::vector<unsigned char>>& merged_addresses,
     const JobSnapshot* job)
 {
-    LOG_TRACE << "mining.submit " << username << " job=" << job_id
+    LOG_TRACE << "[Stratum] mining.submit " << username << " job=" << job_id
               << " nonce=" << nonce << " en2=" << extranonce2;
 
     // Basic share validation
@@ -4765,7 +4765,7 @@ void StratumSession::process_message(std::size_t bytes_read)
             line.pop_back();  // Remove \r if present
         }
 
-        LOG_TRACE << "Stratum message received: " << line;
+        LOG_TRACE << "[Stratum] Received: " << line;
 
         auto request = nlohmann::json::parse(line);
         std::string method = request.value("method", "");

src/impl/ltc/coin/p2p_node.hpp

@@ -330,7 +330,7 @@ class NodeP2P : public core::ICommunicator, public core::INetwork, public core::
 
     ADD_P2P_HANDLER(version)
     {
-        LOG_INFO << "version is?: " << msg->m_command
+        LOG_INFO << "[CoinP2P] version: " << msg->m_command
                  << " start_height=" << msg->m_start_height;
         // Notify header chain of peer's tip height for fast-sync scrypt skip.
         if (m_on_peer_height && msg->m_start_height > 0)

src/pool/node.hpp

@@ -94,12 +94,12 @@ class BaseNode : public NodeInterfaces, public core::Factory<core::Server, core:
         peer->m_timeout = std::make_unique<core::Timer>(m_context, true);
         peer->m_timeout->start(NEW_PEER_TIMEOUT_TIME, [&, addr = peer->addr()](){ timeout(addr); });
 
-        LOG_INFO << socket->get_addr().to_string() << " try to connect!";
+        LOG_INFO << "[P2Pool] " << socket->get_addr().to_string() << " connected";
     }
 
     void error(const message_error_type& err, const NetService& service, const std::source_location where = std::source_location::current()) override
     {
-        LOG_ERROR << "PoolNode <NetName>[" << service.to_string() << "]:";
+        LOG_ERROR << "[P2Pool] <NetName>[" << service.to_string() << "]:";
         LOG_ERROR << "\terror: " << err;
         LOG_ERROR << "\twhere: " << where.function_name();
         if (m_connections.contains(service))