core

type Attachment struct {
	UUID        string
	Name        string
	Type        AttachmentType
	MessageUUID string
	Data        []byte
}

type AttachmentRepositoryPort interface {
	// Create saves a new attachment.
	Create(att *Attachment) error
	// Get returns an attachment by it's UUID without data.
	Get(uuid string) (*Attachment, error)
	// GetData returns the data for an attachment.
	GetData(att *Attachment) ([]byte, error)
	// GetFS returns the attachment file system.
	GetFS() fs.FS
	// ListByMessage returns a list of attachments for a message without data.
	ListByMessage(msg *Message) ([]Attachment, error)
	// DeleteData deletes the data for an attachment.
	DeleteData(att *Attachment) error
}

type AttachmentType string

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

type Bridge struct {
	Name            string
	Endpoints       []string
	OnlyText        bool
	OnlyAttachments bool
	Filters         []Filter
}

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

type Database interface {
	Close() error
	AttachmentRepository() AttachmentRepositoryPort
	MessageRepository() MessageRepositoryPort
}

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 initializes a new endpoint.
	Create(name, endpointType string, config map[string]string) error
	// Get returns an endpoint by it's name.
	Get(name string) (EndpointPort, error)
}

type EndpointServicePort interface {
	SendByEndpointNames(emsg *EndpointMessage, endpointNames []string) error
}

type Filter struct {
	To   string
	From string
	// contains filtered or unexported fields
}

type Message struct {
	UUID        string              // UUID of the message.
	From        string              // From is the email address of the sender.
	To          map[string]struct{} // To is the email addresses of the recipients.
	Subject     string              // Subject of the message.
	Text        string              // Text is the message body.
	Attachments []Attachment        // Attachment is the attachments of the message.
	Status      Status              // Status is the status of the message.
	CreatedAt   time.Time           // Time message was received.
}

type MessageRepositoryPort interface {
	// Create saves a message.
	Create(msg *Message) error
	// Count returns the number of messages.
	Count() (int, error)
	// Get returns a message by it's UUID.
	Get(uuid string) (*Message, error)
	// List messages.
	List(limit, offset int) ([]Message, error)
	// Update a message.
	Update(msg *Message, updateFN func(msg *Message) (*Message, error)) error
	// Delete a message.
	Delete(msg *Message) error
}

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

type Status uint8