fix lints

Author: Tofel

lib/client/rpc.go

@@ -234,8 +234,8 @@ func (m *RPCClient) BlockNumber() (int64, error) {
 }
 
 // GethSetHead sets the Ethereum node's head to a specified block in the past.
-// This function is useful for testing and debugging by allowing developers to 
-// manipulate the blockchain state to a previous block. It returns an error 
+// This function is useful for testing and debugging by allowing developers to
+// manipulate the blockchain state to a previous block. It returns an error
 // if the operation fails.
 func (m *RPCClient) GethSetHead(blocksBack int) error {
 	decimalLastBlock, err := m.BlockNumber()

lib/docker/test_env/env_component.go

@@ -34,7 +34,7 @@ type EnvComponent struct {
 type EnvComponentOption = func(c *EnvComponent)
 
 // WithContainerName sets the container name for an EnvComponent.
-// It allows customization of the container's identity, enhancing clarity 
+// It allows customization of the container's identity, enhancing clarity
 // and organization in containerized environments.
 func WithContainerName(name string) EnvComponentOption {
 	return func(c *EnvComponent) {

lib/docker/test_env/ethereum_env.go

@@ -88,7 +88,7 @@ func (b *EthereumNetworkBuilder) WithConsensusLayer(consensusLayer config.Consen
 }
 
 // WithExecutionLayer sets the execution layer for the Ethereum network builder.
-// It allows users to specify which execution layer to use, ensuring compatibility 
+// It allows users to specify which execution layer to use, ensuring compatibility
 // with the selected Ethereum version and consensus layer.
 func (b *EthereumNetworkBuilder) WithExecutionLayer(executionLayer config_types.ExecutionLayer) *EthereumNetworkBuilder {
 	b.executionLayer = executionLayer
@@ -103,7 +103,7 @@ func (b *EthereumNetworkBuilder) WithEthereumChainConfig(config config.EthereumC
 }
 
 // WithDockerNetworks sets the Docker networks for the Ethereum network builder.
-// It allows users to specify custom networks for containerized deployments, 
+// It allows users to specify custom networks for containerized deployments,
 // enhancing flexibility in network configuration.
 func (b *EthereumNetworkBuilder) WithDockerNetworks(networks []string) *EthereumNetworkBuilder {
 	b.dockerNetworks = networks
@@ -119,15 +119,15 @@ func (b *EthereumNetworkBuilder) WithNodeLogLevel(nodeLogLevel string) *Ethereum
 }
 
 // WithExistingConfig sets an existing Ethereum network configuration for the builder.
-// It allows users to customize the network setup using predefined settings, 
+// It allows users to customize the network setup using predefined settings,
 // facilitating the creation of a network with specific parameters.
 func (b *EthereumNetworkBuilder) WithExistingConfig(config config.EthereumNetworkConfig) *EthereumNetworkBuilder {
 	b.existingConfig = &config
 	return b
 }
 
-// WithExistingConfigFromEnvVar enables the use of an existing Ethereum configuration 
-// sourced from an environment variable. This allows for flexible deployment 
+// WithExistingConfigFromEnvVar enables the use of an existing Ethereum configuration
+// sourced from an environment variable. This allows for flexible deployment
 // configurations without hardcoding values, enhancing security and adaptability.
 func (b *EthereumNetworkBuilder) WithExistingConfigFromEnvVar() *EthereumNetworkBuilder {
 	b.existingFromEnvVar = true
@@ -143,7 +143,7 @@ func (b *EthereumNetworkBuilder) WithTest(t *testing.T) *EthereumNetworkBuilder
 }
 
 // WithCustomDockerImages sets custom Docker images for the Ethereum network builder.
-// This allows users to specify their own container images for different components, 
+// This allows users to specify their own container images for different components,
 // enabling greater flexibility and customization in the network setup.
 func (b *EthereumNetworkBuilder) WithCustomDockerImages(newImages map[config.ContainerType]string) *EthereumNetworkBuilder {
 	b.customDockerImages = newImages
@@ -787,7 +787,7 @@ func (en *EthereumNetwork) getImageOverride(ct config.ContainerType) string {
 }
 
 // Save persists the configuration of the Ethereum network to a TOML file.
-// It generates a unique filename and logs the path for future reference in end-to-end tests. 
+// It generates a unique filename and logs the path for future reference in end-to-end tests.
 // This function is essential for maintaining consistent test environments.
 func (en *EthereumNetwork) Save() error {
 	name := fmt.Sprintf("ethereum_network_%s", uuid.NewString()[0:8])

lib/docker/test_env/job_distributor/jd.go

@@ -151,7 +151,7 @@ func New(networks []string, opts ...Option) *Component {
 }
 
 // WithTestInstance sets up a test logger and test context for a Component.
-// It is useful for initializing components in unit tests, ensuring that logs 
+// It is useful for initializing components in unit tests, ensuring that logs
 // are captured and associated with the provided testing.T instance.
 func WithTestInstance(t *testing.T) Option {
 	return func(j *Component) {
@@ -161,7 +161,7 @@ func WithTestInstance(t *testing.T) Option {
 }
 
 // WithContainerPort sets the container port for a Component.
-// This option allows customization of the network configuration for the container, 
+// This option allows customization of the network configuration for the container,
 // enabling proper communication with external services.
 func WithContainerPort(port string) Option {
 	return func(j *Component) {
@@ -170,7 +170,7 @@ func WithContainerPort(port string) Option {
 }
 
 // WithWSRPCContainerPort sets the WebSocket RPC port for the Component.
-// This option allows users to configure the port for WebSocket communication, 
+// This option allows users to configure the port for WebSocket communication,
 // enabling flexibility in service deployment and integration.
 func WithWSRPCContainerPort(port string) Option {
 	return func(j *Component) {

lib/docker/test_env/kafka.go

@@ -150,8 +150,8 @@ func (k *Kafka) StartContainer() error {
 }
 
 // CreateLocalTopics creates Kafka topics based on the provided configurations.
-// It ensures that topics are only created if they do not already exist, 
-// and logs the creation details for each topic. This function is useful 
+// It ensures that topics are only created if they do not already exist,
+// and logs the creation details for each topic. This function is useful
 // for initializing Kafka environments with predefined topic settings.
 func (k *Kafka) CreateLocalTopics() error {
 	for _, topicConfig := range k.TopicConfigs {

lib/docker/test_env/killgrave.go

@@ -329,8 +329,8 @@ type RequestData struct {
 }
 
 // GetReceivedRequests retrieves and parses request data from a log file.
-// It ensures all requests are written before reading and returns a slice of 
-// RequestData along with any encountered errors. This function is useful for 
+// It ensures all requests are written before reading and returns a slice of
+// RequestData along with any encountered errors. This function is useful for
 // accessing logged request information in a structured format.
 func (k *Killgrave) GetReceivedRequests() ([]RequestData, error) {
 	// killgrave uses a channel to write the request data to a file so we want to make sure

lib/docker/test_env/postgres.go

@@ -62,7 +62,7 @@ func WithPostgresImageName(imageName string) PostgresDbOption {
 }
 
 // WithPostgresImageVersion sets the PostgreSQL container image version for the database.
-// It allows customization of the database version used in the container, enhancing flexibility 
+// It allows customization of the database version used in the container, enhancing flexibility
 // for development and testing environments.
 func WithPostgresImageVersion(version string) PostgresDbOption {
 	return func(c *PostgresDb) {
@@ -91,7 +91,7 @@ func WithContainerEnv(key, value string) PostgresDbOption {
 }
 
 // NewPostgresDb initializes a new Postgres database instance with specified networks and options.
-// It sets up the container environment and default configurations, returning the PostgresDb object 
+// It sets up the container environment and default configurations, returning the PostgresDb object
 // for use in applications requiring a Postgres database connection.
 func NewPostgresDb(networks []string, opts ...PostgresDbOption) (*PostgresDb, error) {
 	imageParts := strings.Split(defaultPostgresImage, ":")
@@ -137,13 +137,13 @@ func (pg *PostgresDb) WithTestInstance(t *testing.T) *PostgresDb {
 }
 
 // StartContainer initializes and starts a PostgreSQL database container.
-// It ensures the container is ready for use, providing both internal and external connection URLs. 
+// It ensures the container is ready for use, providing both internal and external connection URLs.
 // This function is essential for setting up a database environment in testing or development scenarios.
 func (pg *PostgresDb) StartContainer() error {
 	return pg.startOrRestartContainer(false)
 }
 
-// RestartContainer restarts the PostgreSQL database container, ensuring it is running with the latest configuration. 
+// RestartContainer restarts the PostgreSQL database container, ensuring it is running with the latest configuration.
 // This function is useful for applying changes or recovering from issues without needing to manually stop and start the container.
 func (pg *PostgresDb) RestartContainer() error {
 	return pg.startOrRestartContainer(true)

lib/docker/test_env/prysm.go

@@ -49,7 +49,7 @@ type PrysmBeaconChain struct {
 	posContainerSettings
 }
 
-// NewPrysmBeaconChain initializes a new Prysm beacon chain instance with the specified network configurations and parameters. 
+// NewPrysmBeaconChain initializes a new Prysm beacon chain instance with the specified network configurations and parameters.
 // It is used to set up a beacon chain for Ethereum 2.0, enabling users to run and manage a consensus layer node.
 func NewPrysmBeaconChain(networks []string, chainConfig *config.EthereumChainConfig, generatedDataHostDir, generatedDataContainerDir, gethExecutionURL string, baseEthereumFork ethereum.Fork, opts ...EnvComponentOption) (*PrysmBeaconChain, error) {
 	prysmBeaconChainImage, ok := beaconForkToImageMap[baseEthereumFork]

lib/docker/test_env/schema_registry.go

@@ -54,7 +54,7 @@ func (r *SchemaRegistry) WithTestInstance(t *testing.T) *SchemaRegistry {
 }
 
 // WithContainerName sets the container name for the SchemaRegistry instance.
-// This allows users to customize the naming of the container for better organization 
+// This allows users to customize the naming of the container for better organization
 // and identification within their application. It returns the updated SchemaRegistry.
 func (r *SchemaRegistry) WithContainerName(name string) *SchemaRegistry {
 	r.ContainerName = name
@@ -80,9 +80,9 @@ func (r *SchemaRegistry) WithEnvVars(envVars map[string]string) *SchemaRegistry
 }
 
 // StartContainer initializes and starts a Schema Registry container.
-// It sets up the necessary environment variables and logs the internal 
-// and external URLs for accessing the container. This function is 
-// essential for users needing a running instance of Schema Registry 
+// It sets up the necessary environment variables and logs the internal
+// and external URLs for accessing the container. This function is
+// essential for users needing a running instance of Schema Registry
 // for testing or development purposes.
 func (r *SchemaRegistry) StartContainer() error {
 	r.InternalUrl = fmt.Sprintf("http://%s:%s", r.ContainerName, "8081")

lib/logging/log.go

@@ -34,7 +34,7 @@ type CustomT struct {
 }
 
 // Write writes the contents of p to the logger associated with CustomT.
-// It handles empty input gracefully and logs a warning if called after the test has ended. 
+// It handles empty input gracefully and logs a warning if called after the test has ended.
 // Returns the number of bytes written and any write error encountered.
 func (ct *CustomT) Write(p []byte) (n int, err error) {
 	str := string(p)