diff --git a/management/internals/controllers/network_map/controller/controller.go b/management/internals/controllers/network_map/controller/controller.go index 4e8fedb14..28917cdd2 100644 --- a/management/internals/controllers/network_map/controller/controller.go +++ b/management/internals/controllers/network_map/controller/controller.go @@ -236,6 +236,8 @@ func (c *Controller) sendUpdateAccountPeers(ctx context.Context, accountID strin c.perAccountOrGlobalSupportedSyncMessageVersions(accountID), grpc.SyncMessageVersionsFromProtoEnums(peer.Meta.Capabilities)) + log.WithField("sync_message_version", commonSyncMessageVersions[0]).Debug("common highest sync message version") + if commonSyncMessageVersions[0] == grpc.ComponentNetworkMap { components := account.GetPeerNetworkMapComponents( ctx, p.ID, peersCustomZone, accountZones, approvedPeersMap, resourcePolicies, routers, groupIDToUserIDs) @@ -401,6 +403,8 @@ func (c *Controller) sendUpdateForAffectedPeers(ctx context.Context, accountID s c.perAccountOrGlobalSupportedSyncMessageVersions(accountID), grpc.SyncMessageVersionsFromProtoEnums(peer.Meta.Capabilities)) + log.WithField("sync_message_version", commonSyncMessageVersions[0]).Debug("common highest sync message version") + if commonSyncMessageVersions[0] == grpc.ComponentNetworkMap { components := account.GetPeerNetworkMapComponents( ctx, p.ID, peersCustomZone, accountZones, approvedPeersMap, resourcePolicies, routers, groupIDToUserIDs) @@ -535,6 +539,8 @@ func (c *Controller) UpdateAccountPeer(ctx context.Context, accountId string, pe c.perAccountOrGlobalSupportedSyncMessageVersions(accountId), grpc.SyncMessageVersionsFromProtoEnums(peer.Meta.Capabilities)) + log.WithField("sync_message_version", commonSyncMessageVersions[0]).Debug("common highest sync message version") + if commonSyncMessageVersions[0] == grpc.ComponentNetworkMap { components := account.GetPeerNetworkMapComponents( ctx, peer.ID, peersCustomZone, accountZones, approvedPeersMap, resourcePolicies, routers, groupIDToUserIDs) diff --git a/management/internals/shared/grpc/server.go b/management/internals/shared/grpc/server.go index 7a6a13bec..ab8cf0e04 100644 --- a/management/internals/shared/grpc/server.go +++ b/management/internals/shared/grpc/server.go @@ -1025,6 +1025,8 @@ func (s *Server) sendInitialSync(ctx context.Context, peerKey wgtypes.Key, peer SyncMessageVersionsFromString(s.perAccountOrGlobalSyncMessageVersions(peer.AccountID)), SyncMessageVersionsFromProtoEnums(peer.Meta.Capabilities)) + log.WithField("sync_message_version", commonSyncMessageVersions[0]).Debug("common highest sync message version") + if commonSyncMessageVersions[0] == ComponentNetworkMap { // Capable peer: discard the legacy NetworkMap that SyncAndMarkPeer // computed and recompute the raw components instead. This wastes one