add init stdout for proto msg type

multiversx · Mar 12, 2024 · 8559c29 · 8559c29
1 parent 48862d3
commit 8559c29
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/process/firehoseDataProcessor.go b/process/firehoseDataProcessor.go
@@ -18,6 +18,10 @@ var log = logger.GetOrCreate("firehose")
 const (
 	firehosePrefix = "FIRE"
 	blockPrefix    = "BLOCK"
+	initPrefix     = "INIT"
+
+	protocolReaderVersion = "1.0"
+	protoMessageType      = "type.googleapis.com/bstream.pb.sf.bstream.v1.OutportBlock"
 )
 
 type dataProcessor struct {
@@ -53,6 +57,8 @@ func NewFirehoseDataProcessor(
 		outport.TopicSaveBlock: dp.saveBlock,
 	}
 
+	_, _ = fmt.Fprintf(dp.writer, "%s %s %s %s\n", firehosePrefix, initPrefix, protocolReaderVersion, protoMessageType)
+
 	return dp, nil
 }