Function
pipeMessageToSessionEntry
(
slaveName: string,
msg: PipeMessage,
)
Source from the content-addressed store, hash-verified
| 144 | } |
| 145 | |
| 146 | function pipeMessageToSessionEntry( |
| 147 | slaveName: string, |
| 148 | msg: PipeMessage, |
| 149 | ): SessionEntry { |
| 150 | return { |
| 151 | type: msg.type as SessionEntry['type'], |
| 152 | content: msg.data ?? '', |
| 153 | from: msg.from ?? slaveName, |
| 154 | timestamp: msg.ts ?? new Date().toISOString(), |
| 155 | meta: msg.meta, |
| 156 | } |
| 157 | } |
| 158 | |
| 159 | function emitPipeEntry(slaveName: string, entry: SessionEntry): void { |
| 160 | for (const listener of _pipeEntryListeners) { |
Tested by
no test coverage detected