workers

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

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

type ClonableMessage interface {
	Message
	Clone() Message
}

type ConnectImap struct {
	BaseMessage
}

type Database struct {
	*BaseWorker
	// contains filtered or unexported fields
}

type Done struct {
	BaseMessage
}

type Error struct {
	BaseMessage
	Error error
}

type FetchFullMail struct {
	BaseMessage
	Mailbox string
	Uid     uint32
}

type FetchFullMailRes struct {
	BaseMessage
	Filepath string
	FromImap bool
}

type FetchMailbox struct {
	BaseMessage
	Mailbox string
}

type FetchMailboxImapRes struct {
	BaseMessage
	Mailbox string
	Mails   []*models.Mail
}

type FetchMailboxRes struct {
	BaseMessage
	List        []*models.Thread
	LastSeenUid uint32
}

type FetchMailboxes struct {
	BaseMessage
}

type FetchMailboxesImapRes struct {
	BaseMessage
	Mailboxes []*models.Mailbox
}

type FetchMailboxesRes struct {
	BaseMessage
	Mailboxes []*models.Mailbox
}

type FetchMessageUpdates struct {
	BaseMessage
	Mailbox     string
	LastSeenUid uint32
}

type FetchMessageUpdatesRes struct {
	BaseMessage
	Mailbox string
	Mails   []*models.Mail
}

type FetchNewMessages struct {
	BaseMessage
	Mailbox     string
	LastSeenUid uint32
}

type FetchNewMessagesRes struct {
	BaseMessage
	Mailbox string
	Mails   []*models.Mail
}

type FetchThread struct {
	BaseMessage
	RootId int
}

type FetchThreadRes struct {
	BaseMessage
	Mails []*models.Mail
}

type InsertNewMessages struct {
	BaseMessage
	Mailbox string
	Mails   []*models.Mail
}

type InsertNewMessagesRes struct {
	BaseMessage
	Threads []*models.Thread
}

type Message interface {
	GetId() int
	SetId(i int)
	GetAccName() string
	SetAccName(accname string)
}

type MsgToDb struct {
	BaseMessage
	Wrapped Message
}

type SaveMailFlags struct {
	BaseMessage
	MailId int
	Flags  []string
}

type SendMail struct {
	BaseMessage
	Body io.Reader
}

type UpdateMessages struct {
	BaseMessage
	Mailbox     string
	Mails       []*models.Mail
	LastSeenUid uint32
}

type UpdateMessagesRes struct {
	BaseMessage
	Threads []*models.Thread
}

type Worker interface {
	Responses() <-chan Message
	PostMessage(m Message)
	Run()
	Close()
}