diff --git a/CHANGELOG.md b/CHANGELOG.md index f827a67..d19b81c 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -8,6 +8,10 @@ Operators, you should copy/paste content of this content straight to your projec If you were at `firehose-core` version `1.0.0` and are bumping to `1.1.0`, you should copy the content between those 2 version to your own repository, replacing placeholder value `fire{chain}` with your chain's own binary. +## Unreleased + +* Add `reader-node-firehose` which creates one-blocks by consuming blocks from an already existing Firehose endpoint. This can be used to set up an indexer stack without having to run an instrumented blockchain node. + ## v1.6.1 * Bump substreams to v1.10.0: Version 1.10.0 adds a new `EndpointInfo/Info` endpoint, introduces a 3-minute default execution timeout per block, updates metering metrics with a deprecation warning, enhances `substreams init` commands, and improves wasm module caching and Prometheus tool flexibility. Full changelog: https://github.com/streamingfast/substreams/releases/tag/v1.10.0 diff --git a/cmd/apps/reader_node_firehose.go b/cmd/apps/reader_node_firehose.go index d8c6e2d..f2b2f73 100644 --- a/cmd/apps/reader_node_firehose.go +++ b/cmd/apps/reader_node_firehose.go @@ -33,7 +33,7 @@ func RegisterReaderNodeFirehoseApp[B firecore.Block](chain *firecore.Chain[B], r launcher.RegisterApp(rootLog, &launcher.AppDef{ ID: "reader-node-firehose", Title: "Reader Node (Firehose)", - Description: "Blocks reading node, unmanaged, reads Firehose logs from standard input and transform them into Firehose chain specific blocks", + Description: "Blocks reading node, consumes blocks from an already existing Firehose endpoint. This can be used to set up an indexer stack without having to run an instrumented blockchain node.", RegisterFlags: func(cmd *cobra.Command) error { cmd.Flags().String("reader-node-firehose-endpoint", "", "Firehose endpoint to connect to.") cmd.Flags().String("reader-node-firehose-state", "{data-dir}/reader/state", "State file to store the cursor from the Firehose connection in.") @@ -69,8 +69,8 @@ func RegisterReaderNodeFirehoseApp[B firecore.Block](chain *firecore.Chain[B], r InsecureConn: viper.GetBool("reader-node-firehose-insecure"), PlaintextConn: viper.GetBool("reader-node-firehose-plaintext"), Compression: viper.GetString("reader-node-firehose-compression"), - ApiKey: os.Getenv(viper.GetString("reader-node-firehose-api-token-env-var")), - Jwt: os.Getenv(viper.GetString("reader-node-firehose-api-key-env-var")), + ApiKey: os.Getenv(viper.GetString("reader-node-firehose-api-key-env-var")), + Jwt: os.Getenv(viper.GetString("reader-node-firehose-api-token-env-var")), }, }, &firehose_reader.Modules{ MetricsAndReadinessManager: metricsAndReadinessManager,