about summary refs log tree commit diff
diff options
context:
space:
mode:
authorRory& <root@rory.gay>2024-09-07 00:40:12 +0200
committerRory& <root@rory.gay>2024-09-07 00:40:12 +0200
commitdd2084ec0c7a14eb4619e13f583faddcfff42d6d (patch)
tree655391b23126c2d45e0f54e439a8ef154ca31345
parentSync optimisation changes (diff)
downloadLibMatrix-dev/moderationclient-changes.tar.xz
Clean up dev stuff a little bit dev/moderationclient-changes
-rw-r--r--LibMatrix/Helpers/SyncStateResolver.cs42
1 files changed, 0 insertions, 42 deletions
diff --git a/LibMatrix/Helpers/SyncStateResolver.cs b/LibMatrix/Helpers/SyncStateResolver.cs
index 5e34628..3be4492 100644
--- a/LibMatrix/Helpers/SyncStateResolver.cs
+++ b/LibMatrix/Helpers/SyncStateResolver.cs
@@ -129,46 +129,6 @@ public class SyncStateResolver(AuthenticatedHomeserverGeneric homeserver, ILogge
     }
 
     public async Task dev() {
-        // var keys = (await storageProvider?.GetAllKeysAsync()).ToFrozenSet();
-        // var times = new Dictionary<long, List<string>>();
-        // var values = keys.Select(async x => Task.Run(async () => (x, await storageProvider?.LoadObjectAsync<SyncResponse>(x)))).ToAsyncEnumerable();
-        // await foreach (var task in values) {
-        //     var (key, data) = await task;
-        //     if (data is null) continue;
-        //     var derivTime = data.GetDerivedSyncTime();
-        //     if (!times.ContainsKey(derivTime)) times[derivTime] = new();
-        //     times[derivTime].Add(key);
-        // }
-        //
-        // foreach (var (time, ckeys) in times.OrderBy(x => x.Key)) {
-        //     Console.WriteLine($"{time}: {ckeys.Count} keys");
-        // }
-
-        // var map = await GetCheckpointMap();
-        // if (map is null) return;
-        //
-        // var times = new Dictionary<long, List<string>>();
-        // foreach (var (time, keys) in map) {
-        //     Console.WriteLine($"{time}: {keys.Count} keys - calculating times");
-        //     Dictionary<string, Task<SyncResponse?>?> tasks = keys.ToDictionary(x => x, x => storageProvider?.LoadObjectAsync<SyncResponse>(x));
-        //     var nextKey = "init";
-        //     long lastTime = 0;
-        //     while (tasks.ContainsKey(nextKey)) {
-        //         var data = await tasks[nextKey];
-        //         if (data is null) break;
-        //         var derivTime = data.GetDerivedSyncTime();
-        //         if (derivTime == 0) derivTime = lastTime + 1;
-        //         if (!times.ContainsKey(derivTime)) times[derivTime] = new();
-        //         times[derivTime].Add(nextKey);
-        //         lastTime = derivTime;
-        //         nextKey = data.NextBatch;
-        //     }
-        // }
-        //
-        // foreach (var (time, ckeys) in times.OrderBy(x => x.Key)) {
-        //     Console.WriteLine($"{time}: {ckeys.Count} keys");
-        // }
-
         int i = 0;
         var sw = Stopwatch.StartNew();
         var hist = GetSerialisedHistory();
@@ -240,8 +200,6 @@ public class SyncStateResolver(AuthenticatedHomeserverGeneric homeserver, ILogge
             if (!key.StartsWith("old/")) continue;
             var parts = key.Split('/');
             if (parts.Length < 3) continue;
-            // if (!map.ContainsKey(parts[1])) map[parts[1]] = new();
-            // map[parts[1]].Add(parts[2]);
             if (!ulong.TryParse(parts[1], out var checkpoint)) continue;
             if (!map.ContainsKey(checkpoint)) map[checkpoint] = new();
             map[checkpoint].Add(parts[2]);