Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>

@@ -286,0 +314,4 @@
+    val usage = "matrix send --room RAUM TEXT|-"
+    fun given(value: String?) = value?.takeIf { it.isNotBlank() } ?: throw UsageError(usage)
+    val room = given(invocation.option("--room", usage))
+    val text = given(invocation.arguments.removeFirstOrNull())

@@ -0,0 +45,4 @@
+            reached = MatrixReading.reached(event.event.id.full, Instant.ofEpochMilli(event.event.originTimestamp), request)
+            if (!reached && candidate(event)) found += flow
+        }
+        check(reached || request.afterEvent == null || found.size == request.limit) {

@@ -0,0 +20,4 @@
+
+    /** The reading of [room]; [since] is an event ID or a time, and with it the limit is as far as a reading goes back. */
+    fun request(room: String, since: String?, limit: Int?, zone: ZoneId): ReadRequest {
+        val afterEvent = since?.takeIf { it.startsWith("$") }

@@ -0,0 +43,4 @@
+    internal suspend fun candidates(events: Flow<Flow<TimelineEvent>>, request: ReadRequest): List<Flow<TimelineEvent>> {
+        val found = mutableListOf<Flow<TimelineEvent>>()
+        var reached = false
+        events.takeWhile { !reached && (request.afterEvent != null || found.size < request.limit) }.collect { flow ->

@@ -0,0 +58,4 @@
+        withTimeoutOrNull(30.seconds) { event.first { it.content != null } } ?: event.first()
+
+    /** Whether [event] may be a message: a text, a notice, a file and the like, or an encrypted event other than a reaction. */
+    internal fun candidate(event: TimelineEvent): Boolean {

@@ -0,0 +34,4 @@
+
+- **Given** the device of `matrix login` is verified and member of the room "HSAdmin NG"
+- **When** an agent runs `werkregie-dashboard matrix send --room "HSAdmin NG" "Build ist grün"`
+- **Then** the message is in the room, encrypted like the room, and the command prints `SENT` and its event ID

@@ -0,0 +26,4 @@
+object MatrixReader {
+    /** Reads with [client], which has synced once since it started; the text the command prints. */
+    internal suspend fun read(client: MatrixClient, roomId: RoomId, request: ReadRequest): String = withTimeout(5.minutes) {
+        val events = coroutineScope { candidates(client, roomId, request).map { async { decrypted(it) } }.awaitAll() }

@@ -0,0 +27,4 @@
+    /** Reads with [client], which has synced once since it started; the text the command prints. */
+    internal suspend fun read(client: MatrixClient, roomId: RoomId, request: ReadRequest): String = withTimeout(5.minutes) {
+        val events = coroutineScope { candidates(client, roomId, request).map { async { decrypted(it) } }.awaitAll() }
+        MatrixReading.text(events.mapNotNull(::entry).reversed(), ZoneId.systemDefault())

@@ -0,0 +43,4 @@
+    internal suspend fun candidates(events: Flow<Flow<TimelineEvent>>, request: ReadRequest): List<Flow<TimelineEvent>> {
+        val found = mutableListOf<Flow<TimelineEvent>>()
+        var reached = false
+        events.takeWhile { !reached && (request.afterEvent != null || found.size < request.limit) }.collect { flow ->