domain

type Attachment struct {
	UUID        string         `json:"uuid" storm:"id"`
	Name        string         `json:"name"`
	Type        AttachmentType `json:"type"`
	MessageUUID string         `json:"message_uuid" storm:"index"`
	Data        []byte         `json:"-"`
}

type AttachmentRepositoryPort interface {
	// CreateAttachment saves a new attachment.
	CreateAttachment(att *Attachment) error
	// GetAttachment returns an attachment by it's UUID.
	GetAttachment(uuid string) (*Attachment, error)
	// GetAttachmentData returns the data for an attachment.
	GetAttachmentData(att *Attachment) ([]byte, error)
	// GetAttachments returns a list of attachments for a message.
	GetAttachments(msg *Message) ([]Attachment, error)
	// GetFS returns the attachment file system
	GetAttachmentFS() fs.FS
}

type AttachmentType string

type AuthServicePort interface {
	AnonymousLogin() bool
	Login(username, password string) error
}

type Bridge struct {
	Name            string   `json:"name" mapstructure:"name"`
	Endpoints       []string `json:"endpoints" mapstructure:"endpoints"`
	OnlyText        bool     `json:"only_text" mapstructure:"only_text"`
	OnlyAttachments bool     `json:"only_attachments" mapstructure:"only_attachments"`
	Filters         []Filter `json:"filters" mapstructure:"filters"`
}

type BridgeServicePort interface {
	// GetBridges returns a list of bridges that the message belongs to.
	GetBridges(msg *Message) []Bridge
}

type Config struct {
	DB        ConfigDB         `json:"database" mapstructure:"database"`
	SMTP      ConfigSMTP       `json:"smtp" mapstructure:"smtp"`
	HTTP      ConfigHTTP       `json:"http" mapstructure:"http"`
	Bridges   []Bridge         `json:"bridges" mapstructure:"bridges"`
	Endpoints []ConfigEndpoint `json:"endpoints" mapstructure:"endpoints"`
}

type ConfigDB struct {
	Type        string `json:"type" mapstructure:"type"`
	DB          string `json:"db" mapstructure:"db"`
	Attachments string `json:"attachments" mapstructure:"attachments"`
}

type ConfigEndpoint struct {
	Name   string            `json:"name" mapstructure:"name"`
	Type   string            `json:"type" mapstructure:"type"`
	Config map[string]string `json:"config" mapstructure:"config"`
}

type ConfigHTTP struct {
	Enable bool   `json:"enable" mapstructure:"enable"`
	Addr   string `json:"-" mapstructure:"-"`
	Host   string `json:"host" mapstructure:"host"`
	Port   uint16 `json:"port" mapstructure:"port"`
}

type ConfigSMTP struct {
	Host     string `json:"host" mapstructure:"host"`
	Port     uint16 `json:"port" mapstructure:"port"`
	PortStr  string `json:"-" mapstructure:"-"`
	Size     int    `json:"size" mapstructure:"size"`
	Auth     bool   `json:"auth" mapstructure:"auth"`
	Username string `json:"username" mapstructure:"username"`
	Password string `json:"password" mapstructure:"password"`
}

type DAO struct {
	Attachment AttachmentRepositoryPort
	Message    MessageRepositoryPort
	Endpoint   EndpointRepositoryPort
}

type EndpointAttachment struct {
	Name string
	Type AttachmentType
	Data []byte
}

type EndpointMessage struct {
	Text        string               // Text is the message body.
	Attachments []EndpointAttachment // Attachments is a list of attachments.
}

type EndpointPort interface {
	// Send sends the message to the endpoint.
	Send(msg *EndpointMessage) error
}

type EndpointRepositoryPort interface {
	Create(name, endpointType string, config map[string]string) error
	Get(name string) (EndpointPort, error)
}

type EndpointServicePort interface {
	// SendBridges sends message through the given bridges, returns error if all sends failed.
	SendBridges(msg *Message, bridges []Bridge) error
}

type Filter struct {
	To   string `json:"to,omitempty" mapstructure:"to,omitempty"`
	From string `json:"from,omitempty" mapstructure:"from,omitempty"`
}

type Message struct {
	CreatedAt   time.Time       `json:"created_at"`      // Time message was received.
	UUID        string          `json:"uuid" storm:"id"` // UUID of the message.
	Subject     string          `json:"subject"`         // Subject of the message.
	From        string          `json:"from"`            // From is the email address of the sender.
	To          map[string]bool `json:"to"`              // To is the email addresses of the recipients.
	Text        string          `json:"text"`            // Text is the message body.
	Attachments []Attachment    `json:"-"`               // Attachment is the attachments of the message.
	Status      Status          `json:"status"`          // Status is the status of the message.
}

type MessageRepositoryPort interface {
	// CreateMessage saves a new message.
	CreateMessage(msg *Message) error
	// GetMessage returns a message by it's UUID.
	GetMessage(uuid string) (*Message, error)
	// DeleteMessage deletes a message.
	DeleteMessage(msg *Message) error
	// GetMessages returns a list of messages.
	GetMessages(limit, offset int) ([]Message, error)
	// CountMessages returns the number of messages.
	CountMessages() (int, error)
	// UpdateMessage updates a message.
	UpdateMessage(msg *Message, updateFN func(msg *Message) (*Message, error)) error
}

type MessageServicePort interface {
	// Create creates a new message and saves it.
	Create(subject, from string, to map[string]bool, text string) (*Message, error)
	// CreateAttachment adds an attachment to a message.
	CreateAttachment(msg *Message, name string, data []byte) (*Attachment, error)
	// UpdateStatus updates the status of a message.
	UpdateStatus(msg *Message, status Status) error
	// List messages with attachments.
	List(limit, offset int) ([]Message, error)
	// Get a message with attachments.
	Get(uuid string) (*Message, error)
}

type Status uint8