mentionUserIds: [context.sutUserId],

roomId: context.roomId,

});

const matchesExpectedProgress = (body: string | undefined) =>

params.progressPattern.test(body ?? "") ||

(params.allowGenericProgressLine === true && hasMatrixQaToolProgressPreviewLine(body));

const getPreviewRootEventId = (event: MatrixQaObservedEvent) =>

event.relatesTo?.relType === "m.replace" && event.relatesTo.eventId

? event.relatesTo.eventId

: event.eventId;

const preview = await client

.waitForRoomEvent({

observedEvents: context.observedEvents,

predicate: (event) =>

event.roomId === context.roomId &&

event.sender === context.sutUserId &&

event.kind === params.expectedPreviewKind &&

event.relatesTo === undefined,

(event.relatesTo === undefined ||

(event.relatesTo.relType === "m.replace" && matchesExpectedProgress(event.body))),

roomId: context.roomId,

since: startSince,

timeoutMs: context.timeoutMs,

}),

);

});

const matchesExpectedProgress = (body: string | undefined) =>

params.progressPattern.test(body ?? "") ||

(params.allowGenericProgressLine === true && hasMatrixQaToolProgressPreviewLine(body));

const previewRootEventId = getPreviewRootEventId(preview.event);

const progress = matchesExpectedProgress(preview.event.body)

? preview

: await client

event.sender === context.sutUserId &&

event.kind === params.expectedPreviewKind &&

event.relatesTo?.relType === "m.replace" &&

event.relatesTo.eventId === preview.event.eventId &&

event.relatesTo.eventId === previewRootEventId &&

matchesExpectedProgress(event.body),

roomId: context.roomId,

since: preview.since,

cause: err,

events: context.observedEvents,

expectedPreviewKind: params.expectedPreviewKind,

previewEventId: preview.event.eventId,

previewEventId: previewRootEventId,

roomId: context.roomId,

startIndex: startObservedIndex,

sutUserId: context.sutUserId,

event.sender === context.sutUserId &&

isMatrixQaMessageLikeKind(event.kind) &&

event.relatesTo?.relType === "m.replace" &&

event.relatesTo.eventId === preview.event.eventId &&

event.relatesTo.eventId === previewRootEventId &&

doesMatrixQaReplyBodyMatchToken(event, params.finalText),

roomId: context.roomId,

since: progress.since,

buildMatrixQaToolProgressFinalTimeoutMessage({

cause: err,

events: context.observedEvents,

previewEventId: preview.event.eventId,

previewEventId: previewRootEventId,

roomId: context.roomId,

startIndex: startObservedIndex,

sutUserId: context.sutUserId,

const unexpectedWorkingEvents = findMatrixQaUnexpectedWorkingEvents({

events: context.observedEvents,

finalEventId: finalized.event.eventId,

previewEventId: preview.event.eventId,

previewEventId: previewRootEventId,

startIndex: startObservedIndex,

sutUserId: context.sutUserId,

});

artifacts: {

driverEventId,

previewBodyPreview: progress.event.body?.slice(0, 200),

previewEventId: preview.event.eventId,

previewEventId: previewRootEventId,

previewFormattedBodyPreview: progress.event.formattedBody?.slice(0, 200),

previewMentions: progress.event.mentions,

reply: finalReply,