mirror of
https://github.com/openclaw/openclaw.git
synced 2026-06-06 05:51:15 +08:00
test: keep matrix async listeners lint-safe
(cherry picked from commitb7a38bdd2f) (cherry picked from commit5851bcfc58)
This commit is contained in:
@@ -17,7 +17,12 @@ function createClientStub() {
|
||||
const client = {
|
||||
on: vi.fn((eventName: string, listener: unknown) => {
|
||||
if (eventName === "room.invite") {
|
||||
inviteHandler = listener as InviteHandler;
|
||||
inviteHandler = async (roomId, inviteEvent) => {
|
||||
(listener as (roomId: string, inviteEvent: unknown) => void)(roomId, inviteEvent);
|
||||
await new Promise<void>((resolve) => {
|
||||
setImmediate(resolve);
|
||||
});
|
||||
};
|
||||
}
|
||||
return client;
|
||||
}),
|
||||
|
||||
@@ -217,6 +217,15 @@ function createHarness(params?: {
|
||||
throw new Error("room.event listener was not registered");
|
||||
}
|
||||
|
||||
const failedDecryptListener: FailedDecryptListener | undefined = listeners.has(
|
||||
"room.failed_decryption",
|
||||
)
|
||||
? async (roomId, event, error) => {
|
||||
listeners.get("room.failed_decryption")?.(roomId, event, error);
|
||||
await flushTasks();
|
||||
}
|
||||
: undefined;
|
||||
|
||||
return {
|
||||
onRoomMessage,
|
||||
sendMessage,
|
||||
@@ -234,9 +243,7 @@ function createHarness(params?: {
|
||||
roomDecryptedEventListener: listeners.get("room.decrypted_event") as
|
||||
| RoomEventListener
|
||||
| undefined,
|
||||
failedDecryptListener: listeners.get("room.failed_decryption") as
|
||||
| FailedDecryptListener
|
||||
| undefined,
|
||||
failedDecryptListener,
|
||||
verificationSummaryListener: listeners.get("verification.summary") as
|
||||
| VerificationSummaryListener
|
||||
| undefined,
|
||||
|
||||
@@ -273,7 +273,7 @@ export function registerMatrixMonitorEvents(params: {
|
||||
|
||||
client.on("room.failed_decryption", (roomId: string, event: MatrixRawEvent, error: Error) => {
|
||||
void runMonitorTask(
|
||||
`failed decryption handler room=${roomId} id=${event.event_id ?? "unknown"}`,
|
||||
`failed decrypt handler room=${roomId} id=${event.event_id ?? "unknown"}`,
|
||||
async () => {
|
||||
const failureState = postHealthySyncDecryptFailureTracker.recordFailure(
|
||||
roomId,
|
||||
|
||||
Reference in New Issue
Block a user