it("preserves separate finalized block events when Matrix block streaming is enabled", async () => {

const primeRoom = vi.fn().mockResolvedValue("driver-sync-start");

const sendTextMessage = vi.fn().mockResolvedValue("$block-stream-trigger");

const readBlockText = (label: "First" | "Second") =>

new RegExp(`${label} exact marker: \`([^\\\`]+)\``).exec(

String(sendTextMessage.mock.calls[0]?.[0]?.body),

)?.[1] ?? `MATRIX_QA_BLOCK_${label.toUpperCase()}_FIXED`;

const readBlockText = (label: "ONE" | "TWO") =>

String(sendTextMessage.mock.calls[0]?.[0]?.body)

.split("\n")

.find((line) => line.startsWith(`MATRIX_QA_BLOCK_${label}_`)) ??

`MATRIX_QA_BLOCK_${label}_FIXED`;

const waitForRoomEvent = vi

.fn()

.mockImplementationOnce(async () => ({

eventId: "$block-one",

sender: "@sut:matrix-qa.test",

type: "m.room.message",

body: readBlockText("First"),

body: readBlockText("ONE"),

},

since: "driver-sync-block-one",

}))

eventId: "$block-two",

sender: "@sut:matrix-qa.test",

type: "m.room.message",

body: readBlockText("Second"),

body: readBlockText("TWO"),

},

since: "driver-sync-next",

}));

mentionUserIds: ["@sut:matrix-qa.test"],

roomId: "!block:matrix-qa.test",

});

const body = String(sendTextMessage.mock.calls[0]?.[0]?.body);

expect(body).toMatch(

/reply with exactly this two-line body and no extra text:\nMATRIX_QA_BLOCK_ONE_[A-F0-9]{8}\nMATRIX_QA_BLOCK_TWO_[A-F0-9]{8}$/,

);

expect(waitForRoomEvent).toHaveBeenNthCalledWith(

2,

expect.objectContaining({