diff options
| author | Emiliano Ciavatta | 2020-09-16 13:41:04 +0000 |
|---|---|---|
| committer | Emiliano Ciavatta | 2020-09-16 13:41:04 +0000 |
| commit | ec949ffea86a14526a7142d048022a4a07f684ff (patch) | |
| tree | f91966e42d93e94e29d7c11c1eeb67704da297eb /connection_streams_controller.go | |
| parent | 2954045cb28ea8cbf4dbd019355a2df8fed28ccc (diff) | |
Improve frontend connection visualization
Diffstat (limited to 'connection_streams_controller.go')
| -rw-r--r-- | connection_streams_controller.go | 18 |
1 files changed, 11 insertions, 7 deletions
diff --git a/connection_streams_controller.go b/connection_streams_controller.go index 3ba30f8..c4876b1 100644 --- a/connection_streams_controller.go +++ b/connection_streams_controller.go @@ -27,13 +27,14 @@ type ConnectionStream struct { type PatternSlice [2]uint64 type Payload struct { - FromClient bool `json:"from_client"` - Content string `json:"content"` - Metadata parsers.Metadata `json:"metadata"` - Index int `json:"index"` - Timestamp time.Time `json:"timestamp"` - IsRetransmitted bool `json:"is_retransmitted"` - RegexMatches []RegexSlice `json:"regex_matches"` + FromClient bool `json:"from_client"` + Content string `json:"content"` + Metadata parsers.Metadata `json:"metadata"` + IsMetadataContinuation bool `json:"is_metadata_continuation"` + Index int `json:"index"` + Timestamp time.Time `json:"timestamp"` + IsRetransmitted bool `json:"is_retransmitted"` + RegexMatches []RegexSlice `json:"regex_matches"` } type RegexSlice struct { @@ -138,8 +139,11 @@ func (csc ConnectionStreamsController) GetConnectionPayload(c context.Context, c if sideChanged { metadata := parsers.Parse(contentChunkBuffer.Bytes()) + var isMetadataContinuation bool for _, elem := range payloadsBuffer { elem.Metadata = metadata + elem.IsMetadataContinuation = isMetadataContinuation + isMetadataContinuation = true } payloadsBuffer = payloadsBuffer[:0] |