blocklog

type Collector interface {
	// RegisterBlockHash registers a blockHash for a test name.
	// When a log line with this blockHash is seen, it will be associated with the test.
	// If the log already arrived (buffered in unmatched), it's immediately associated.
	RegisterBlockHash(testName, blockHash string)

	// GetBlockLogs returns all captured block logs mapped by test name.
	GetBlockLogs() map[string]json.RawMessage

	// Writer returns an io.Writer that intercepts log lines, parses them,
	// and passes them through to the downstream writer.
	Writer() io.Writer
}

type Parser interface {
	// ParseLine attempts to extract a JSON payload from a log line.
	// Returns the raw JSON message and true if successful, or nil and false if the line
	// doesn't contain a parseable JSON payload.
	ParseLine(line string) (json.RawMessage, bool)

	// ClientType returns the client type this parser is for.
	ClientType() client.ClientType
}