From 3407f97096fd66aeb25f1cd26ba002d3f8a23127 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Roman=20Smr=C5=BE?= <roman.smrz@seznam.cz>
Date: Sun, 27 Aug 2023 11:41:41 +0200
Subject: Network: announce protocol version

---
 src/network/protocol.cpp | 8 ++++++++
 1 file changed, 8 insertions(+)

(limited to 'src/network/protocol.cpp')

diff --git a/src/network/protocol.cpp b/src/network/protocol.cpp
index 89fa327..f001d6c 100644
--- a/src/network/protocol.cpp
+++ b/src/network/protocol.cpp
@@ -108,6 +108,7 @@ NetworkProtocol::Connection NetworkProtocol::connect(sockaddr_in6 addr)
 
 		vector<Header::Item> header {
 			Header::AnnounceSelf { self->ref()->digest() },
+			Header::Version { defaultVersion },
 		};
 		conn->send(self->ref()->storage(), header, {}, false);
 	}
@@ -143,6 +144,7 @@ void NetworkProtocol::announceTo(variant<sockaddr_in, sockaddr_in6> addr)
 
 		bytes = Header({
 			Header::AnnounceSelf { self->ref()->digest() },
+			Header::Version { defaultVersion },
 		}).toObject(self->ref()->storage()).encode();
 	}
 
@@ -409,6 +411,9 @@ optional<NetworkProtocol::Header> NetworkProtocol::Header::load(const PartialObj
 		if (item.name == "ACK") {
 			if (auto ref = item.asRef())
 				items.emplace_back(Acknowledged { ref->digest() });
+		} else if (item.name == "VER") {
+			if (auto ver = item.asText())
+				items.emplace_back(Version { *ver });
 		} else if (item.name == "REQ") {
 			if (auto ref = item.asRef())
 				items.emplace_back(DataRequest { ref->digest() });
@@ -447,6 +452,9 @@ PartialObject NetworkProtocol::Header::toObject(const PartialStorage & st) const
 		if (const auto * ptr = get_if<Acknowledged>(&item))
 			ritems.emplace_back("ACK", st.ref(ptr->value));
 
+		else if (const auto * ptr = get_if<Version>(&item))
+			ritems.emplace_back("VER", ptr->value);
+
 		else if (const auto * ptr = get_if<DataRequest>(&item))
 			ritems.emplace_back("REQ", st.ref(ptr->value));
 
-- 
cgit v1.2.3