Introduce Self-Mirroring in development mode

Signed-off-by: Mikhail Agapov <mikhail.agapov@decentraland.org>

Author: mikhail-dcl

src/DCLPulse/DCLPulse.sln.DotSettings.user

@@ -8,6 +8,7 @@
 	<s:String x:Key="/Default/CodeInspection/ExcludedFiles/FilesAndFoldersToSkip2/=7020124F_002D9FFC_002D4AC3_002D8F3D_002DAAB8E0240759_002Ff_003AIMessage_00601_002Ecs_002Fl_003AC_0021_003FUsers_003Fagapo_003FAppData_003FRoaming_003FJetBrains_003FRider2025_002E3_003Fresharper_002Dhost_003FDecompilerCache_003Fdecompiler_003F8ac5df484cef4ddabb15fdcaf03dc5076a118_003F0e_003F0c2692d4_003FIMessage_00601_002Ecs/@EntryIndexedValue">ForceIncluded</s:String>
 	<s:String x:Key="/Default/CodeInspection/ExcludedFiles/FilesAndFoldersToSkip2/=7020124F_002D9FFC_002D4AC3_002D8F3D_002DAAB8E0240759_002Ff_003ALogger_00601_002Ecs_002Fl_003AC_0021_003FUsers_003Fagapo_003FAppData_003FRoaming_003FJetBrains_003FRider2025_002E3_003Fresharper_002Dhost_003FDecompilerCache_003Fdecompiler_003F436aa929069b4451a1f15ef16423b31810708_003F34_003Fc52369b4_003FLogger_00601_002Ecs/@EntryIndexedValue">ForceIncluded</s:String>
 	<s:String x:Key="/Default/CodeInspection/ExcludedFiles/FilesAndFoldersToSkip2/=7020124F_002D9FFC_002D4AC3_002D8F3D_002DAAB8E0240759_002Ff_003AServiceCollectionServiceExtensions_002Ecs_002Fl_003AC_0021_003FUsers_003Fagapo_003FAppData_003FRoaming_003FJetBrains_003FRider2025_002E3_003Fresharper_002Dhost_003FDecompilerCache_003Fdecompiler_003F6aa57ddeb02b4bef8365bcdc6f7c52dd10338_003F00_003F243b1034_003FServiceCollectionServiceExtensions_002Ecs/@EntryIndexedValue">ForceIncluded</s:String>
+	<s:String x:Key="/Default/CodeInspection/ExcludedFiles/FilesAndFoldersToSkip2/=7020124F_002D9FFC_002D4AC3_002D8F3D_002DAAB8E0240759_002Ff_003AVector3_002Ecs_002Fl_003AC_0021_003FUsers_003Fagapo_003FAppData_003FRoaming_003FJetBrains_003FRider2025_002E3_003Fresharper_002Dhost_003FDecompilerCache_003Fdecompiler_003Fd2fc4e5236f74a0d8789f902be54d3bbf48938_003Fb0_003F90f6c211_003FVector3_002Ecs/@EntryIndexedValue">ForceIncluded</s:String>
 	<s:String x:Key="/Default/CodeStyle/CodeCleanup/RecentlyUsedProfile/@EntryValue">Code Style Reformat DCL</s:String>
 	<s:String x:Key="/Default/Environment/UnitTesting/UnitTestSessionStore/Sessions/=70eda9a7_002D816d_002D4cde_002D89b3_002D0c64dd72a349/@EntryIndexedValue">&lt;SessionState ContinuousTestingMode="0" IsActive="True" Name="All tests from &amp;lt;DCLPulseTests&amp;gt;" xmlns="urn:schemas-jetbrains-com:jetbrains-ut-session"&gt;
   &lt;Project Location="/Users/nicolas.lorusso/Documents/workspace/Pulse/src/DCLPulseTests" Presentation="&amp;lt;DCLPulseTests&amp;gt;" /&gt;

src/DCLPulse/Peers/PeerOptions.cs

@@ -1,4 +1,6 @@
-namespace Pulse.Peers;
+using Pulse.Peers.Simulation;
+
+namespace Pulse.Peers;
 
 public sealed class PeerOptions
 {
@@ -10,4 +12,15 @@ public sealed class PeerOptions
     ///     Simulation steps in milliseconds for tiers
     /// </summary>
     public uint[] SimulationSteps { get; set; } = new[] { 50u, 100u, 200u };
+
+    /// <summary>
+    ///     When enabled, each peer receives its own state updates as if from another peer
+    ///     identified by <see cref="PeerSimulation.SELF_MIRROR_WALLET_ID" />.
+    /// </summary>
+    public bool SelfMirrorEnabled { get; set; }
+
+    /// <summary>
+    ///     Tier index (0, 1, 2) used for self-mirror updates, controlling update frequency and field detail.
+    /// </summary>
+    public int SelfMirrorTier { get; set; }
 }

src/DCLPulse/Peers/PeersManager.cs

@@ -106,7 +106,8 @@ protected override Task ExecuteAsync(CancellationToken stoppingToken)
         {
             var simulation = new PeerSimulation(
                 areaOfInterest, snapshotBoard, spatialGrid, identityBoard,
-                messagePipe, peerOptions.SimulationSteps, timeProvider, transport, profileBoard, emoteBoard, peerSimulationLogger);
+                messagePipe, peerOptions.SimulationSteps, timeProvider, transport, profileBoard, emoteBoard, peerSimulationLogger,
+                peerOptions.SelfMirrorEnabled, peerOptions.SelfMirrorTier);
 
             tasks[i + 1] = WorkerAsync(i, messageChannels[i].Reader,
                 peerLifeCycleChannels[i].Reader, simulation, stoppingToken);

src/DCLPulse/Peers/Simulation/PeerSimulation.cs

@@ -22,6 +22,8 @@ public sealed class PeerSimulation : IPeerSimulation
     private const uint PEER_DISCONNECTION_CLEAN_TIMEOUT = 5000;
     private const uint PEER_PENDING_AUTH_CLEAN_TIMEOUT = 30000;
 
+    public const string SELF_MIRROR_WALLET_ID = "self_mirror";
+
     private readonly IAreaOfInterest areaOfInterest;
     private readonly SnapshotBoard snapshotBoard;
     private readonly SpatialGrid spatialGrid;
@@ -33,6 +35,8 @@ public sealed class PeerSimulation : IPeerSimulation
     private readonly ProfileBoard profileBoard;
     private readonly EmoteBoard emoteBoard;
     private readonly ILogger<PeerSimulation> logger;
+    private readonly bool selfMirrorEnabled;
+    private readonly PeerViewSimulationTier selfMirrorTier;
 
     /// <summary>
     ///     Per-observer views: observer PeerIndex → (subject PeerIndex → view).
@@ -71,7 +75,9 @@ public PeerSimulation(
         ITransport transport,
         ProfileBoard profileBoard,
         EmoteBoard emoteBoard,
-        ILogger<PeerSimulation> logger)
+        ILogger<PeerSimulation> logger,
+        bool selfMirrorEnabled = false,
+        int selfMirrorTier = 0)
     {
         this.areaOfInterest = areaOfInterest;
         this.snapshotBoard = snapshotBoard;
@@ -84,6 +90,8 @@ public PeerSimulation(
         this.profileBoard = profileBoard;
         this.emoteBoard = emoteBoard;
         this.logger = logger;
+        this.selfMirrorEnabled = selfMirrorEnabled;
+        this.selfMirrorTier = new PeerViewSimulationTier((byte)selfMirrorTier);
 
         BaseTickMs = simulationSteps[0];
         tierDivisors = new uint[simulationSteps.Length];
@@ -145,6 +153,9 @@ public void SimulateTick(Dictionary<PeerIndex, PeerState> peers, uint tickCounte
             collector.Clear();
             areaOfInterest.GetVisibleSubjects(observerId, in observerSnapshot, collector);
 
+            if (selfMirrorEnabled)
+                collector.Add(observerId, selfMirrorTier);
+
             ProcessVisibleSubjects(observerId, views, observerState.ResyncRequests, tickCounter);
 
             observerState.ResyncRequests?.Clear();
@@ -177,7 +188,9 @@ private void ProcessVisibleSubjects(
         {
             InterestEntry entry = collector.Entries[i];
 
-            if (entry.Subject == observerId)
+            bool isSelfMirror = entry.Subject == observerId;
+
+            if (isSelfMirror && !selfMirrorEnabled)
                 continue;
 
             bool isNew = !views.TryGetValue(entry.Subject, out PeerToPeerView view);
@@ -213,11 +226,15 @@ private void ProcessVisibleSubjects(
 
                 int profileVersion = profileBoard.Get(entry.Subject);
 
+                string? userId = isSelfMirror
+                    ? SELF_MIRROR_WALLET_ID
+                    : identityBoard.GetWalletIdByPeerIndex(entry.Subject);
+
                 messagePipe.Send(new OutgoingMessage(observerId, new ServerMessage
                 {
                     PlayerJoined = new PlayerJoined
                     {
-                        UserId = identityBoard.GetWalletIdByPeerIndex(entry.Subject),
+                        UserId = userId,
                         ProfileVersion = profileVersion,
                         State = CreateFullState(entry.Subject, subjectSnapshot),
                     },
@@ -277,7 +294,7 @@ void TryAnnounceProfile()
 
             void SyncEmoteState()
             {
-                // If the emote completion has not been process by the peer's worker yet, try to complete it now
+                // If the emote completion has not been processed by the peer's worker yet, try to complete it now
                 emoteBoard.TryComplete(entry.Subject, timeProvider.MonotonicTime);
 
                 EmoteState? emoteState = emoteBoard.Get(entry.Subject);

src/DCLPulse/appsettings.Development.json

@@ -4,5 +4,9 @@
       "Default": "Information",
       "Microsoft.Hosting.Lifetime": "Information"
     }
+  },
+  "Peers": {
+    "SelfMirrorEnabled": true,
+    "SelfMirrorTier": 0
   }
 }