diff --git a/codec/consolereader.go b/codec/consolereader.go index d0640293..2ef2867a 100644 --- a/codec/consolereader.go +++ b/codec/consolereader.go @@ -218,6 +218,14 @@ func (l *ConsoleReader) Read() (out interface{}, err error) { case strings.HasPrefix(line, "DTRX_OP FAILED"): err = ctx.readFailedDTrxOp(line) + case strings.HasPrefix(line, "ACCEPTED_BLOCK_V2"): + block, err := ctx.readAcceptedBlockV2(line) + if err != nil { + return nil, l.formatError(line, err) + } + + return block, nil + case strings.HasPrefix(line, "ACCEPTED_BLOCK"): block, err := ctx.readAcceptedBlock(line) if err != nil {