Clean up dev stuff a little bit
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]);
|