dandri/Draupnir
1
0
Fork 0
mirror of https://github.com/the-draupnir-project/Draupnir.git synced 2026-04-26 10:57:55 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Update ReportPoller to use Draupnir (mps).

Browse Source
This commit is contained in:
gnuxie
2023-11-24 16:35:33 +00:00
parent e5e771aaea
commit 7a5aafde7d
1 changed files with 22 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

38
src/report/ReportPoller.ts
View File

@@ -30,7 +30,7 @@ import { ReportManager } from './ReportManager';
import { LogLevel, LogService } from "matrix-bot-sdk";
import ManagementRoomOutput from "../ManagementRoomOutput";
import { Draupnir } from "../Draupnir";
import { isStringRoomID } from "matrix-protection-suite";
import { ActionException, ActionExceptionKind, Ok, SynapseReport, Value, isError } from "matrix-protection-suite";
/**
* Synapse will tell us where we last got to on polling reports, so we need
@@ -83,7 +83,7 @@ export class ReportPoller {
private async getAbuseReports() {
let response_: {
event_reports: { room_id: string, event_id: string, sender: string, reason: string }[],
event_reports: unknown[],
next_token: number | undefined
} | undefined;
try {
@@ -102,31 +102,37 @@ export class ReportPoller {
}
const response = response_!;
for (let report of response.event_reports) {
if (!isStringRoomID(report.room_id)) {
LogService.error(`ReportPoller`, `Malformed room ID, skipping report ${report.room_id}`);
for (const rawReport of response.event_reports) {
const reportResult = Value.Decode(SynapseReport, rawReport);
if (isError(reportResult)) {
LogService.error('ReportPoller', `Failed to decode a synapse report ${reportResult.error.uuid}`, rawReport);
continue;
}
const report = reportResult.ok;
if (!this.draupnir.protectedRoomsSet.isProtectedRoom(report.room_id)) {
continue;
}
let event: any; // `any` because `handleServerAbuseReport` uses `any`
try {
event = (await this.draupnir.client.doRequest(
"GET",
`/_synapse/admin/v1/rooms/${report.room_id}/context/${report.event_id}?limit=1`
)).event;
} catch (ex) {
this.draupnir.managementRoomOutput.logMessage(LogLevel.ERROR, "getAbuseReports", `failed to get context: ${ex}`);
// FIXME: shouldn't we have a SafeMatrixSendClient in the BotSDKMPS that gives us ActionResult's with
// Decoded events.
// Problem is that our current event model isn't going to match up with extensible events.
const eventContext = await this.draupnir.client.doRequest(
"GET",
`/_synapse/admin/v1/rooms/${report.room_id}/context/${report.event_id}?limit=1`
).then(
(value) => Ok(value),
(exception) => ActionException.Result(`Failed to retrieve the context for an event ${report.event_id}`, { exception, exceptionKind: ActionExceptionKind.Unknown })
)
if (isError(eventContext)) {
this.draupnir.managementRoomOutput.logMessage(LogLevel.ERROR, "getAbuseReports", `failed to get context: ${eventContext.error.uuid}`);
continue;
}
const event = eventContext.ok.event;
await this.manager.handleServerAbuseReport({
roomId: report.room_id,
roomID: report.room_id,
reporterId: report.sender,
event: event,
reason: report.reason,
reason: report.reason ?? undefined,
});
}