email_processor

Documentation

Index

• func NewEmailProcessor(repositories *repository.Repositories, eventsService *events.EventsService, ...) interfaces.EmailProcessor
• type EmailHeaders
• type ImapProcessor
  • func NewImapProcessor(repositories *repository.Repositories, processor interfaces.EmailProcessor, ...) *ImapProcessor
  • func (p *ImapProcessor) ProcessIMAPMessage(ctx context.Context, inboundEmail dto.EmailReceived) error
  • func (p *ImapProcessor) SaveMessageAsEML(ctx context.Context, msg *go_imap.Message, emailID string) (string, error)

Functions

func NewEmailProcessor

func NewEmailProcessor(
	repositories *repository.Repositories,
	eventsService *events.EventsService,
	aiService interfaces.AIService,
) interfaces.EmailProcessor

Types

type EmailHeaders

type EmailHeaders struct {
	AutoSubmitted      bool
	ContentDescription string
	DeliveryStatus     bool
	ListUnsubscribe    bool
	Precedence         string
	ReturnPath         string
	ReturnPathExists   bool
	XAutoreply         string
	XAutoresponse      string
	XLoop              bool
	XFailedRecipients  []string
	ReplyTo            string
	ReplyToExists      bool
	Sender             string
	ForwardedFor       string
	DKIM               []string
	SPF                string
	DMARC              string
}

type ImapProcessor

type ImapProcessor struct {
	interfaces.EmailProcessor
	// contains filtered or unexported fields
}

func NewImapProcessor

func NewImapProcessor(
	repositories *repository.Repositories,
	processor interfaces.EmailProcessor,
	imapService interfaces.IMAPService,
	storageService interfaces.StorageService,
) *ImapProcessor

func (*ImapProcessor) ProcessIMAPMessage

func (p *ImapProcessor) ProcessIMAPMessage(ctx context.Context, inboundEmail dto.EmailReceived) error

func (*ImapProcessor) SaveMessageAsEML

func (p *ImapProcessor) SaveMessageAsEML(ctx context.Context, msg *go_imap.Message, emailID string) (string, error)