clmimicry

type ActiveShardsConfig []interface{}

type Config struct {
	LoggingLevel string  `yaml:"logging" default:"info"`
	MetricsAddr  string  `yaml:"metricsAddr" default:":9090"`
	PProfAddr    *string `yaml:"pprofAddr"`
	ProbeAddr    *string `yaml:"probeAddr"`

	// The name of the mimicry
	Name string `yaml:"name"`

	// Ethereum configuration
	Ethereum ethereum.Config `yaml:"ethereum"`

	// Outputs configuration
	Outputs []output.Config `yaml:"outputs"`

	// Labels configures the mimicry with labels
	Labels map[string]string `yaml:"labels"`

	// NTP Server to use for clock drift correction
	NTPServer string `yaml:"ntpServer" default:"time.google.com"`

	// Node is the configuration for the node
	Node NodeConfig `yaml:"node"`

	// Events is the configuration for the events
	Events EventConfig `yaml:"events"`

	// Traces is the configuration for the traces.
	Traces TracesConfig `yaml:"traces"`
}

type EventConfig struct {
	RecvRPCEnabled                 bool `yaml:"recvRpcEnabled" default:"false"`
	SendRPCEnabled                 bool `yaml:"sendRpcEnabled" default:"false"`
	DropRPCEnabled                 bool `yaml:"dropRpcEnabled" default:"false"`
	RpcMetaControlIHaveEnabled     bool `yaml:"rpcMetaControlIHaveEnabled" default:"false"`
	RpcMetaControlIWantEnabled     bool `yaml:"rpcMetaControlIWantEnabled" default:"false"`
	RpcMetaControlIDontWantEnabled bool `yaml:"rpcMetaControlIDontWantEnabled" default:"false"`
	RpcMetaControlGraftEnabled     bool `yaml:"rpcMetaControlGraftEnabled" default:"false"`
	RpcMetaControlPruneEnabled     bool `yaml:"rpcMetaControlPruneEnabled" default:"false"`
	RpcMetaSubscriptionEnabled     bool `yaml:"rpcMetaSubscriptionEnabled" default:"false"`
	RpcMetaMessageEnabled          bool `yaml:"rpcMetaMessageEnabled" default:"false"`
	AddPeerEnabled                 bool `yaml:"addPeerEnabled" default:"true"`
	RemovePeerEnabled              bool `yaml:"removePeerEnabled" default:"true"`
	ConnectedEnabled               bool `yaml:"connectedEnabled" default:"true"`
	DisconnectedEnabled            bool `yaml:"disconnectedEnabled" default:"true"`
	JoinEnabled                    bool `yaml:"joinEnabled" default:"true"`
	LeaveEnabled                   bool `yaml:"leaveEnabled" default:"false"`
	GraftEnabled                   bool `yaml:"graftEnabled" default:"false"`
	PruneEnabled                   bool `yaml:"pruneEnabled" default:"false"`
	PublishMessageEnabled          bool `yaml:"publishMessageEnabled" default:"false"`
	RejectMessageEnabled           bool `yaml:"rejectMessageEnabled" default:"false"`
	DuplicateMessageEnabled        bool `yaml:"duplicateMessageEnabled" default:"false"`
	DeliverMessageEnabled          bool `yaml:"deliverMessageEnabled" default:"false"`
	HandleMetadataEnabled          bool `yaml:"handleMetadataEnabled" default:"true"`
	HandleStatusEnabled            bool `yaml:"handleStatusEnabled" default:"true"`
	GossipSubBeaconBlockEnabled    bool `yaml:"gossipSubBeaconBlockEnabled" default:"true"`
	GossipSubAttestationEnabled    bool `yaml:"gossipSubAttestationEnabled" default:"true"`
	GossipSubBlobSidecarEnabled    bool `yaml:"gossipSubBlobSidecarEnabled" default:"true"`
}

type FilteredMessageWithIndex struct {
	MessageID     *wrapperspb.StringValue
	OriginalIndex uint32
}

type Metrics struct {
	// contains filtered or unexported fields
}

type Mimicry struct {
	Config *Config
	// contains filtered or unexported fields
}

type NodeConfig struct {
	// The private key for the libp2p host and local enode in hex format
	PrivateKeyStr string `yaml:"privateKeyStr" default:""`

	// General timeout when communicating with other network participants
	DialTimeout time.Duration `yaml:"dialTimeout" default:"5s"`

	// The address information of the local ethereuem [enode.Node].
	Devp2pHost string `yaml:"devp2pHost" default:"0.0.0.0"`
	Devp2pPort int    `yaml:"devp2pPort" default:"0"`

	// The address information of the local libp2p host
	Libp2pHost string `yaml:"libp2pHost" default:"0.0.0.0"`
	Libp2pPort int    `yaml:"libp2pPort" default:"0"`

	// The address information where the Beacon API or Prysm's custom API is accessible at
	PrysmHost     string `yaml:"prysmHost" default:"127.0.0.1"`
	PrysmPortHTTP int    `yaml:"prysmPortHttp" default:"3500"`
	PrysmPortGRPC int    `yaml:"prysmPortGrpc" default:"4000"`
	PrysmUseTLS   bool   `yaml:"prysmUseTls" default:"false"`

	// The maximum number of peers our libp2p host can be connected to.
	MaxPeers int `yaml:"maxPeers" default:"30"`

	// Limits the number of concurrent connection establishment routines. When
	// we discover peers over discv5 and are not at our MaxPeers limit we try
	// to establish a connection to a peer. However, we limit the concurrency to
	// this DialConcurrency value.
	DialConcurrency int `yaml:"dialConcurrency" default:"16"`

	// DataStreamType is the type of data stream to use for the node (e.g. kinesis, callback, etc).
	DataStreamType string `yaml:"dataStreamType" default:"callback"`

	// Subnets is the configuration for gossipsub subnets.
	Subnets map[string]*hermes.SubnetConfig `yaml:"subnets"`
}

type Override struct {
	MetricsAddr struct {
		Enabled bool
		Value   string
	}
}

type ShardingKeyType string

type TopicConfig struct {
	// Total number of shards for this topic.
	TotalShards uint64 `yaml:"totalShards" default:"64"`
	// List of active shards to process. Supports individual numbers and ranges (e.g., "0-255").
	ActiveShardsRaw ActiveShardsConfig `yaml:"activeShards"`
	// Processed active shards (populated during validation).
	ActiveShards []uint64 `yaml:"-"`
	// Key to use for sharding (MsgID, PeerID, etc).
	ShardingKey string `yaml:"shardingKey" default:"MsgID"`
}

type TracesConfig struct {
	// Whether or not trace config is globally enabled.
	Enabled bool `yaml:"enabled" default:"false"`
	// AlwaysRecordRootRpcEvents is a flag that controls whether or not to record
	// the root rpc events even if there are no rpc meta/control level messages.
	AlwaysRecordRootRpcEvents bool `yaml:"alwaysRecordRootRpcEvents" default:"false"`
	// Topics allows for per-topic configuration.
	Topics map[string]TopicConfig `yaml:"topics"`
	// contains filtered or unexported fields
}