whimap

type Attachment struct {
	Name        string `json:"name"`
	ContentType string `json:"content_type"`
	Size        int64  `json:"size"`
	URI         string `json:"uri,omitempty"`
	ResourceID  string `json:"resource_id,omitempty"`
	Skipped     string `json:"skipped,omitempty"`
}

type Config struct {
	Sources    Sources
	Objects    Objects
	Bucket     string
	Recorder   Recorder
	RawWindows RawWindows
	Marks      MarkStore
	Files      Files
	Lock       Lock
	Replica    string
	Logger     *slog.Logger
	// Open opens a session; nil is imapmail.Open.
	Open func(ctx context.Context, a imapmail.Account) (*imapmail.Session, error)
	Now  func() time.Time
}

type External struct {
	From    string   `json:"from"`
	To      []string `json:"to"`
	Cc      []string `json:"cc,omitempty"`
	Subject string   `json:"subject"`
	Body    string   `json:"body"`
}

type File struct {
	Folder      string
	Name        string
	ContentType string
	Data        []byte
}

type Files interface {
	PutFile(ctx context.Context, src whsource.Source, f File) (uri, id string, err error)
}

type Lock func(ctx context.Context, source string) (release func(), ok bool, err error)

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

type Mark struct {
	Source      string `json:"-"`
	Folder      string `json:"folder"`
	UIDValidity uint32 `json:"uid_validity"`
	LastUID     uint32 `json:"last_uid"`
	Stored      int64  `json:"stored"`
	// HiddenNotAllowed and HiddenUnauthenticated count the messages the
	// sender rules withheld. Nothing else of them is kept.
	HiddenNotAllowed      int64      `json:"hidden_not_allowed"`
	HiddenUnauthenticated int64      `json:"hidden_unauthenticated"`
	LastPolledAt          *time.Time `json:"last_polled_at,omitempty"`
	LastError             string     `json:"last_error,omitempty"`
}

type MarkStore interface {
	Get(ctx context.Context, source, folder string) (Mark, error)
	Put(ctx context.Context, mk Mark) error
}

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

type Objects interface {
	PutObject(ctx context.Context, bucket, key string, data []byte, contentType string) error
}

type Payload struct {
	Folder      string `json:"folder"`
	UID         uint32 `json:"uid"`
	UIDValidity uint32 `json:"uid_validity"`
	MessageID   string `json:"message_id,omitempty"`
	InReplyTo   string `json:"in_reply_to,omitempty"`
	// References are the thread's earlier Message-IDs.
	References []string `json:"references,omitempty"`
	Date       string   `json:"date,omitempty"`
	Arrived    string   `json:"arrived"`
	// FromAddress is the sender's address as the From header names it, and
	// SenderAuth what the receiving server recorded of it.
	FromAddress string `json:"from_address"`
	SenderAuth  string `json:"sender_auth"`
	Size        int64  `json:"size"`
	BodyFormat  string `json:"body_format"`
	// BodySkipped says why the body was not read, empty when it was.
	BodySkipped string       `json:"body_skipped,omitempty"`
	Attachments []Attachment `json:"attachments"`
	External    External     `json:"external"`
	Notice      string       `json:"notice"`
}

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

type RawWindows interface {
	EnsureRawWindow(ctx context.Context, src whsource.Source, start time.Time) error
}

type Recorder interface {
	MarkSegment(ctx context.Context, source string, start time.Time, length time.Duration, bytes int64) error
}

type Sources interface {
	List(ctx context.Context) ([]whsource.Source, error)
}