(event: Event)
| 133 | class Service extends Context.Service<Service, TransportService>()("@opencode/RunStreamTransport") {} |
| 134 | |
| 135 | function sid(event: Event): string | undefined { |
| 136 | if (event.type === "message.updated") { |
| 137 | return event.properties.sessionID |
| 138 | } |
| 139 | |
| 140 | if (event.type === "message.part.delta") { |
| 141 | return event.properties.sessionID |
| 142 | } |
| 143 | |
| 144 | if (event.type === "message.part.updated") { |
| 145 | return event.properties.part.sessionID |
| 146 | } |
| 147 | |
| 148 | if ( |
| 149 | event.type === "session.next.shell.started" || |
| 150 | event.type === "session.next.shell.ended" || |
| 151 | event.type === "permission.asked" || |
| 152 | event.type === "permission.replied" || |
| 153 | event.type === "question.asked" || |
| 154 | event.type === "question.replied" || |
| 155 | event.type === "question.rejected" || |
| 156 | event.type === "session.error" || |
| 157 | event.type === "session.status" |
| 158 | ) { |
| 159 | return event.properties.sessionID |
| 160 | } |
| 161 | |
| 162 | return undefined |
| 163 | } |
| 164 | |
| 165 | function isEvent(value: unknown): value is Event { |
| 166 | if (!value || typeof value !== "object" || Array.isArray(value)) { |
no outgoing calls
no test coverage detected