vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-04-20 05:31:30 +00:00
Code Issues Packages Projects Releases Wiki Activity

tests: fix matrix test typing

Browse Source
This commit is contained in:
Gustavo Madeira Santana
2026-03-30 22:39:25 -04:00
parent 47136536c8
commit d859746862
2 changed files with 17 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
extensions/matrix/src/matrix/direct-management.test.ts
View File

@@ -305,9 +305,11 @@ describe("promoteMatrixDirectRoomCandidate", () => {
it("serializes concurrent m.direct writes so distinct mappings are not lost", async () => {
let directContent: Record<string, string[]> = {};
let releaseFirstWrite: (() => void) | null = null;
let releaseFirstWrite!: () => void;
const firstWriteStarted = new Promise<void>((resolve) => {
releaseFirstWrite = resolve;
releaseFirstWrite = () => {
resolve();
};
});
let writeCount = 0;
const setAccountData = vi.fn(async (_eventType: string, content: Record<string, string[]>) => {
@@ -337,7 +339,7 @@ describe("promoteMatrixDirectRoomCandidate", () => {
roomId: "!bob:example.org",
});
releaseFirstWrite?.();
releaseFirstWrite();
await expect(Promise.all([firstWrite, secondWrite])).resolves.toEqual([true, true]);
expect(directContent).toEqual({

23
extensions/matrix/src/matrix/monitor/index.test.ts
View File

@@ -2,6 +2,11 @@ import path from "node:path";
import { z } from "openclaw/plugin-sdk/zod";
import { beforeAll, beforeEach, describe, expect, it, vi } from "vitest";
import { loadRuntimeApiExportTypesViaJiti } from "../../../../../test/helpers/plugins/jiti-runtime-api.ts";
import type { MatrixRoomInfo } from "./room-info.js";
type DirectRoomTrackerOptions = {
canPromoteRecentInvite?: (roomId: string) => boolean | Promise<boolean>;
};
const hoisted = vi.hoisted(() => {
const callOrder: string[] = [];
@@ -25,10 +30,12 @@ const hoisted = vi.hoisted(() => {
drainPendingDecryptions: vi.fn(async () => undefined),
};
const createMatrixRoomMessageHandler = vi.fn(() => vi.fn());
const createDirectRoomTracker = vi.fn(() => ({
const createDirectRoomTracker = vi.fn((_client: unknown, _opts?: DirectRoomTrackerOptions) => ({
isDirectMessage: vi.fn(async () => false),
}));
const getRoomInfo = vi.fn(async () => ({
const getRoomInfo = vi.fn<
(roomId: string, opts?: { includeAliases?: boolean }) => Promise<MatrixRoomInfo>
>(async () => ({
altAliases: [],
nameResolved: true,
aliasesResolved: true,
@@ -496,9 +503,7 @@ describe("monitorMatrixProvider", () => {
it("wires recent-invite promotion to fail closed when room metadata is unresolved", async () => {
await startMonitorAndAbortAfterStartup();
const trackerOpts = hoisted.createDirectRoomTracker.mock.calls[0]?.[1] as
| { canPromoteRecentInvite?: (roomId: string) => Promise<boolean> }
| undefined;
const trackerOpts = hoisted.createDirectRoomTracker.mock.calls[0]?.[1];
if (!trackerOpts?.canPromoteRecentInvite) {
throw new Error("recent invite promotion callback was not wired");
}
@@ -515,9 +520,7 @@ describe("monitorMatrixProvider", () => {
it("wires recent-invite promotion to reject named rooms", async () => {
await startMonitorAndAbortAfterStartup();
const trackerOpts = hoisted.createDirectRoomTracker.mock.calls[0]?.[1] as
| { canPromoteRecentInvite?: (roomId: string) => Promise<boolean> }
| undefined;
const trackerOpts = hoisted.createDirectRoomTracker.mock.calls[0]?.[1];
if (!trackerOpts?.canPromoteRecentInvite) {
throw new Error("recent invite promotion callback was not wired");
}
@@ -539,9 +542,7 @@ describe("monitorMatrixProvider", () => {
await startMonitorAndAbortAfterStartup();
const trackerOpts = hoisted.createDirectRoomTracker.mock.calls[0]?.[1] as
| { canPromoteRecentInvite?: (roomId: string) => Promise<boolean> }
| undefined;
const trackerOpts = hoisted.createDirectRoomTracker.mock.calls[0]?.[1];
if (!trackerOpts?.canPromoteRecentInvite) {
throw new Error("recent invite promotion callback was not wired");
}