middleware

var (
	ReadBytesLoggerComponent = &app.Component{
		Dependencies: app.Components{
			logger.Component,
			client.Component,
		},
		Run: app.Run(func(container container.Container) error {
			return container.Invoke(func(socketClient client.Client, logger logger.Logger) {
				socketClient.Use(ReadBytesLogger(logger))
			})
		}),
	}

	ReadBytesMetricComponent = &app.Component{
		Dependencies: app.Components{
			logger.Component,
			client.Component,
			metric.Component,
		},
		Run: app.Run(func(container container.Container) error {
			return container.Invoke(func(socketClient client.Client, logger logger.Logger, metric *metric.Metric) {
				socketClient.Use(ReadBytesMetric(logger, metric))
			})
		}),
	}

	ReadTimeoutComponent = &app.Component{
		Dependencies: app.Components{
			logger.Component,
			configurator.Component,
			client.Component,
		},
		Constructor: app.Constructor(func(container container.Container) error {
			return container.Provide(NewReadConfig)
		}),
		BindFlags: app.BindFlags(ReadTimeoutComponentBindFlags),
		Run: app.Run(func(container container.Container) error {
			return container.Invoke(func(socketClient client.Client, config *ReadConfig, logger logger.Logger, configurator configurator.Configurator) {
				socketClient.Use(ReadTimeout(ReadConfigConfiguration(config, configurator), logger))
			})
		}),
	}

	ReadComponent = &app.Component{
		Dependencies: app.Components{
			ReadBytesLoggerComponent,
			ReadBytesMetricComponent,
			ReadTimeoutComponent,
		},
	}

	WriteBytesLoggerComponent = &app.Component{
		Dependencies: app.Components{
			logger.Component,
			client.Component,
		},
		Run: app.Run(func(container container.Container) error {
			return container.Invoke(func(socketClient client.Client, logger logger.Logger) {
				socketClient.Use(WriteBytesLogger(logger))
			})
		}),
	}

	WriteBytesMetricComponent = &app.Component{
		Dependencies: app.Components{
			logger.Component,
			client.Component,
			metric.Component,
		},
		Run: app.Run(func(container container.Container) error {
			return container.Invoke(func(socketClient client.Client, logger logger.Logger, metric *metric.Metric) {
				socketClient.Use(WriteBytesMetric(logger, metric))
			})
		}),
	}

	WriteTimeoutComponent = &app.Component{
		Dependencies: app.Components{
			logger.Component,
			configurator.Component,
			client.Component,
		},
		Constructor: app.Constructor(func(container container.Container) error {
			return container.Provide(NewWriteConfig)
		}),
		BindFlags: app.BindFlags(WriteTimeoutComponentBindFlags),
		Run: app.Run(func(container container.Container) error {
			return container.Invoke(func(socketClient client.Client, config *WriteConfig, logger logger.Logger, configurator configurator.Configurator) {
				socketClient.Use(WriteTimeout(WriteConfigConfiguration(config, configurator), logger))
			})
		}),
	}

	WriteComponent = &app.Component{
		Dependencies: app.Components{
			WriteBytesLoggerComponent,
			WriteBytesMetricComponent,
			WriteTimeoutComponent,
		},
	}

	Component = &app.Component{Dependencies: app.Components{ReadComponent, WriteComponent}}
)