about summary refs log tree commit diff
path: root/ModerationBot/PolicyEngine.cs
diff options
context:
space:
mode:
Diffstat (limited to 'ModerationBot/PolicyEngine.cs')
-rw-r--r--ModerationBot/PolicyEngine.cs15
1 files changed, 4 insertions, 11 deletions
diff --git a/ModerationBot/PolicyEngine.cs b/ModerationBot/PolicyEngine.cs

index 7556fc5..a19f1f7 100644 --- a/ModerationBot/PolicyEngine.cs +++ b/ModerationBot/PolicyEngine.cs
@@ -61,7 +61,7 @@ public class PolicyEngine(AuthenticatedHomeserverGeneric hs, ILogger<ModerationB loadTasks.Add(LoadPolicyListAsync(room, policyList)); } - await foreach (var policyList in loadTasks.ToAsyncEnumerable()) { + await foreach (var policyList in loadTasks.ToAsyncResultEnumerable()) { policyLists.Add(policyList); if (true || policyList.Policies.Count >= 256 || policyLists.Count == PolicyListAccountData.Count) { @@ -195,7 +195,7 @@ public class PolicyEngine(AuthenticatedHomeserverGeneric hs, ILogger<ModerationB } } - var resolvedUri = await hsResolver.ResolveMediaUri(mxcUri.Split('/')[2], mxcUri); + var resolvedUri = await hs.GetMediaUrlAsync(mxcUri); var uriHash = hashAlgo.ComputeHash(mxcUri.AsBytes().ToArray()); byte[]? fileHash = null; @@ -204,16 +204,9 @@ public class PolicyEngine(AuthenticatedHomeserverGeneric hs, ILogger<ModerationB } catch (Exception ex) { await _logRoom.SendMessageEventAsync( - MessageFormatter.FormatException($"Error calculating file hash for {mxcUri} via {mxcUri.Split('/')[2]} ({resolvedUri}), retrying via {hs.BaseUrl}...", + MessageFormatter.FormatException($"Error calculating file hash for {mxcUri} ({resolvedUri})!", ex)); - try { - resolvedUri = await hsResolver.ResolveMediaUri(hs.BaseUrl, mxcUri); - fileHash = await hashAlgo.ComputeHashAsync(await hs.ClientHttpClient.GetStreamAsync(resolvedUri)); - } - catch (Exception ex2) { - await _logRoom.SendMessageEventAsync( - MessageFormatter.FormatException($"Error calculating file hash via {hs.BaseUrl} ({resolvedUri})!", ex2)); - } + return []; } logger.LogInformation("Checking media {url} with hash {hash}", resolvedUri, fileHash);