Skip to content

Commit

Permalink
removing substreams flags from firehose, adding dauth to start comman…
Browse files Browse the repository at this point in the history
…d and nitpick for substreams-tier1 import
  • Loading branch information
Eduard-Voiculescu committed Jul 4, 2023
1 parent e099753 commit 7d94e53
Show file tree
Hide file tree
Showing 3 changed files with 9 additions and 11 deletions.
10 changes: 0 additions & 10 deletions cmd/firesol/cli/firehose.go
Original file line number Diff line number Diff line change
Expand Up @@ -33,16 +33,6 @@ func init() {
RegisterFlags: func(cmd *cobra.Command) error {
cmd.Flags().String("firehose-grpc-listen-addr", FirehoseGRPCServingAddr, "Address on which the Firehose will listen")
cmd.Flags().String("firehose-discovery-service-url", "", "url to configure the grpc discovery service") //traffic-director://xds?vpc_network=vpc-global&use_xds_reds=true
cmd.Flags().Bool("substreams-enabled", false, "Whether to enable substreams")
cmd.Flags().Bool("substreams-partial-mode-enabled", false, "Whether to enable partial stores generation support on this instance (usually for internal deployments only)")
cmd.Flags().String("substreams-state-store-url", "{data-dir}/localdata", "where substreams state data are stored")
cmd.Flags().Uint64("substreams-cache-save-interval", uint64(1_000), "Interval in blocks at which to save module output & store snapshots")
cmd.Flags().String("substreams-client-endpoint", "", "Firehose endpoint for substreams client. if left empty, will default to this current local Firehose.")
cmd.Flags().String("substreams-client-jwt", "", "jwt for substreams client authentication")
cmd.Flags().Bool("substreams-client-insecure", false, "substreams client in insecure mode")
cmd.Flags().Bool("substreams-client-plaintext", true, "substreams client in plaintext mode")
cmd.Flags().Uint64("substreams-sub-request-parallel-jobs", 5, "substreams subrequest parallel jobs for the scheduler")
cmd.Flags().Uint64("substreams-sub-request-block-range-size", 1000, "substreams subrequest block range size value for the scheduler")

return nil
},
Expand Down
8 changes: 8 additions & 0 deletions cmd/firesol/cli/start.go
Original file line number Diff line number Diff line change
Expand Up @@ -16,12 +16,16 @@ package cli

import (
"fmt"
"github.com/streamingfast/dmetering"
"path/filepath"
"time"

"github.com/spf13/cobra"
"github.com/spf13/viper"
"github.com/streamingfast/bstream"
dauthgrpc "github.com/streamingfast/dauth/grpc"
dauthnull "github.com/streamingfast/dauth/null"
dauthtrust "github.com/streamingfast/dauth/trust"
"github.com/streamingfast/derr"
"github.com/streamingfast/dlauncher/launcher"
"go.uber.org/zap"
Expand All @@ -31,6 +35,10 @@ var StartCmd = &cobra.Command{Use: "start", Short: "Starts services all at once"

func init() {
RootCmd.AddCommand(StartCmd)
dauthgrpc.Register()
dauthtrust.Register()
dauthnull.Register()
dmetering.RegisterDefault()
}

func sfStartE(cmd *cobra.Command, args []string) (err error) {
Expand Down
2 changes: 1 addition & 1 deletion cmd/firesol/cli/substreams-tier1.go
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@ import (
discoveryservice "github.com/streamingfast/dgrpc/server/discovery-service"
"github.com/streamingfast/dlauncher/launcher"
"github.com/streamingfast/logging"
app "github.com/streamingfast/substreams/app"
"github.com/streamingfast/substreams/app"
)

var ss1HeadBlockNumMetric = metricset.NewHeadBlockNumber("substreams-tier1")
Expand Down

0 comments on commit 7d94e53

Please sign in to comment.