component.go

package telegram

import (
	"github.com/D3rus/go-library/app"
	"github.com/D3rus/go-library/configurator"
	reConfiguration "github.com/D3rus/go-library/configurator/re_configuration"
	"github.com/D3rus/go-library/container"
	"github.com/D3rus/go-library/logger"
	"github.com/D3rus/go-library/runner"
	"github.com/spf13/pflag"
)

var Component = &app.Component{
	Dependencies: app.Components{
		logger.Component,
		configurator.Component,
		reConfiguration.Component,
		runner.Component,
	},
	Constructor: app.Constructor(func(container container.Container) error {
		return container.Provides(
			NewConfig,
			NewReConfigurationWithConfigurator,
			func(telegram *ReConfiguration, informer logger.Informer) *Process {
				return NewProcess(telegram, informer)
			},
			func(telegram *Process) Telegram { return telegram },
		)
	}),
	BindFlags: app.BindFlags(func(flagSet *pflag.FlagSet, container container.Container) error {
		return container.Invoke(func(config *Config) {
			flagSet.StringVar(&config.Token, TokenFieldName, "", "telegram bot access token")
			flagSet.StringVar(&config.ProxyHost, ProxyHostFieldName, "", "proxy host to connect to telegram")
			flagSet.StringVar(&config.User, UserFieldName, "", "user for authorization in the proxy server")
			flagSet.StringVar(&config.Password, PasswordFieldName, "", "password for authorization in the proxy server")
			flagSet.DurationVar(&config.Timeout, TimeoutFieldName, TimeoutDefault, "host connection timeout")
			flagSet.DurationVar(&config.KeepAlive, KeepAliveFieldName, KeepAliveDefault, "period between keepalive messages")
			flagSet.DurationVar(&config.IdleConnTimeout, IdleConnTimeoutFieldName, IdleConnTimeoutDefault, "the maximum amount of time an idle")
			flagSet.DurationVar(&config.TLSHandshakeTimeout, TLSHandshakeTimeoutFieldName, TLSHandshakeTimeoutDefault, "maximum TLS handshake timeout")
			flagSet.DurationVar(&config.ExpectContinueTimeout, ExpectContinueTimeoutFieldName, ExpectContinueTimeoutDefault, "the amount of time to wait for the first server response headers after a complete write of the request headers")
			flagSet.Uint16Var(&config.MaxIdleConns, MaxIdleConnsFieldName, MaxIdleConnsDefault, "total maximum number of idle (keep-alive) connections")
		})
	}),
	Run: app.Run(func(container container.Container) error {
		return container.Invoke(func(
			configurator *ReConfiguration,
			process *Process,
			reConfiguration reConfiguration.ReConfiguration,
			informer logger.Informer,
			config *Config,
			runner runner.Runner,
		) error {
			reConfiguration.Registration(configurator)
			informer.Info("telegram: registration in the reConfigurator")

			return runner.AddProcesses(process)
		})
	}),
}