imap

package

v0.2.23 Latest Latest Go to latest Published: May 12, 2025 License: Apache-2.0 Imports: 21 Imported by: 0

Details

View Source

const (
	SYNC_EMAILS_BATCH_SIZE_PER_ITERATION = 20
	SYNC_EMAILS_ITERATIONS_PER_ACQUIRE   = 500
)

This section is empty.

func NewIMAPService(nats *nats_internal.NATSConnections, repos *repository.Repositories, googleSvc interfaces.GoogleService) interfaces.IMAPService

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

func (s *IMAPService) AcceptMailboxForSync(ctx context.Context, mailbox *models.Mailbox) bool

func (s *IMAPService) GetMessageByUID(ctx context.Context, mailboxID, folderName string, uid uint32) (*imap.Message, error)

func (s *IMAPService) ListFolders(ctx context.Context, mailboxID string) ([]string, error)

ListFolders returns a list of all available folders in the mailbox

func (s *IMAPService) Start(ctx context.Context) error

Start initializes the service and connects to mailboxes

func (s *IMAPService) Status() map[string]interfaces.MailboxStatus

Status returns the current status of all mailboxes

func (s *IMAPService) Stop() error

Stop gracefully shuts down the service

type XOAuth2Auth struct {
	Username string
	Token    string
}

XOAuth2Auth implements XOAUTH2 authentication for Gmail

func (a *XOAuth2Auth) Next(challenge []byte) ([]byte, error)

func (a *XOAuth2Auth) Start() (string, []byte, error)