common

type Application interface {
	// GetConfigData get config data
	GetConfigData() ([]byte, error, error)

	// SetConfigMeta set config meta data
	SetConfigMeta(configFilename, configRemoteAddr, configUpdateDuration string)

	// InitConfig initialize config data
	InitConfig()

	// IsValidConfigFilename проверяет валидность пути к файлу с настройками
	IsValidConfigFilename(string) bool

	// InitChannels init channels
	InitChannels(cBufSize int)

	// OnEvent runs event callback
	OnEvent(f func(ev *ApplicationEvent))

	// CloseEvents close events channel
	CloseEvents()

	// SendEvents send event to the channel
	SendEvents(ev *ApplicationEvent) bool

	// Done возвращает канал завершения приложения
	Done() <-chan bool

	// Close main app
	Close()

	// Services возвращает сервисы, используемые приложением
	Services() []interface{}

	// FireInit инициализирует сервисы
	FireInit(*ApplicationEvent, interface{})

	// FireRun запускает сервисы приложения
	FireRun(*ApplicationEvent, interface{})

	// FireFinish останавливает сервисы приложения
	FireFinish(*ApplicationEvent, interface{})

	// Init инициализирует приложение
	Init(*ApplicationEvent, bool)

	// Run запускает приложение
	Run()

	// RunWithArgs запускает приложение с аргументами
	RunWithArgs(...interface{})

	// Timeout возвращает таймауты приложения
	Timeout() Timeout
}

type ApplicationEvent struct {
	// Kind тип события
	Kind ApplicationEventKind

	// Data данные из файла настроек
	Data []byte

	// Args аргументы командной строки
	Args map[string]interface{}
}

type ApplicationEventKind int

type DelayedBindingType int

type EventService interface {
	Event(ev *SendEvent) bool
}

type GrepService interface {
	Service
	OnGrep(*ApplicationEvent)
}

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

type LimitedQueue struct {
	*Queue
	// contains filtered or unexported fields
}

type MailError struct {
	// сообщение
	Message string `json:"message"`

	// код ошибки
	Code int `json:"code"`
}

type MailMessage struct {
	// идентификатор для логов
	Id int64 `json:"-"`

	// отправитель
	Envelope string `json:"envelope"`

	// получатель
	Recipient string `json:"recipient"`

	// тело письма
	Body []byte `json:"body"`

	// домен отправителя, удобно сразу получить и использовать далее
	HostnameFrom string `json:"-"`

	// Домен получателя, удобно сразу получить и использовать далее
	HostnameTo string `json:"-"`

	// дата создания, используется в основном сервисом ограничений
	CreatedDate time.Time `json:"-"`

	// тип очереди, в которою письмо уже было отправлено после неудачной отправки, ипользуется для цепочки очередей
	BindingType DelayedBindingType `json:"bindingType"`

	// ошибка отправки
	Error *MailError `json:"error"`
}

type PublishService interface {
	Service
	EventService
	OnPublish(*ApplicationEvent)
}

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

type ReportService interface {
	Service
	EventService
	OnShowReport()
}

type SendEvent struct {
	// Client клиент для отправки писем
	Client *SmtpClient

	// Message письмо, полученное из очереди
	Message *MailMessage

	// CreateDate дата создания необходима при получении подключения к почтовому сервису
	CreateDate time.Time

	// Result результат
	Result chan SendEventResult

	// TryCount количество попыток отправок письма
	TryCount int

	// Iterator итератор сервисов, участвующих в отправке письма
	Iterator *Iterator

	// Queue очередь, в которую необходимо будет положить клиента после отправки письма
	Queue *LimitedQueue
}

type SendEventResult int

type SendingService interface {
	Service
	EventService
	OnRun()
}

type Service interface {
	OnInit(*ApplicationEvent)
	OnFinish()
}

type SmtpClient struct {
	// идертификатор клиента для удобства в логах
	Id int

	// Conn соединение к почтовому серверу
	Conn net.Conn

	// Worker реальный smtp клиент
	Worker *smtp.Client

	// ModifyDate дата создания или изменения статуса клиента
	ModifyDate time.Time

	// Status статус
	Status SmtpClientStatus
	// contains filtered or unexported fields
}

type SmtpClientStatus int

type Timeout struct {
	Sleep      time.Duration `yaml:"sleep"`
	Waiting    time.Duration `yaml:"waiting"`
	Connection time.Duration `yaml:"connection"`
	Hello      time.Duration `yaml:"hello"`
	Mail       time.Duration `yaml:"mail"`
	Rcpt       time.Duration `yaml:"rcpt"`
	Data       time.Duration `yaml:"data"`
}