common

type Application interface {
	GetConfigFilename() string
	// устанавливает путь к файлу с настройками
	SetConfigFilename(string)

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

	// устанавливает канал событий приложения
	SetEvents(chan *ApplicationEvent)

	// возвращает канал событий приложения
	Events() chan *ApplicationEvent

	// устанавливает канал завершения приложения
	SetDone(chan bool)

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

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

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

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

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

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

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

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

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

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

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

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

type ApplicationEventKind int

type DelayedBindingType int

type EventService interface {
	Events() chan *SendEvent
}

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 string `json:"body"`

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

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

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

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

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

type PublishService interface {
	Service
	OnPublish(*ApplicationEvent)
}

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

type ReportService interface {
	Service
	EventService
	OnShowReport()
}

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

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

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

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

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

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

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

type SendEventResult int

type SendingService interface {
	Service
	EventService
	OnRun()
	OnFinish()
}

type Service interface {
	OnInit(*ApplicationEvent)
}

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

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

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

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

	// статус
	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"`
}