syncservice

type APIClient interface {
	GetGroupedMessageCount(ctx context.Context) ([]proton.MessageGroupCount, error)
	GetLabels(ctx context.Context, labelTypes ...proton.LabelType) ([]proton.Label, error)
	GetMessage(ctx context.Context, messageID string) (proton.Message, error)
	GetMessageMetadataPage(ctx context.Context, page, pageSize int, filter proton.MessageFilter) ([]proton.MessageMetadata, error)
	GetFullMessage(ctx context.Context, messageID string, scheduler proton.Scheduler, storageProvider proton.AttachmentAllocator) (proton.FullMessage, error)
	GetAttachmentInto(ctx context.Context, attachmentID string, reader io.ReaderFrom) error
	GetAttachment(ctx context.Context, attachmentID string) ([]byte, error)
}

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

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

type ApplyStageInput = StageInputConsumer[ApplyRequest]

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

type BuildResult struct {
	AddressID string
	MessageID string
	Update    *imap.MessageCreated
}

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

type BuildStageInput = StageInputConsumer[BuildRequest]

type BuildStageOutput = StageOutputProducer[ApplyRequest]

type ChannelConsumerProducer[T any] struct {
	// contains filtered or unexported fields
}

type DefaultDownloadRateModifier struct{}

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

type DownloadRateModifier interface {
	Apply(wasSuccess bool, current int, max int) int
}

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

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

type DownloadStageInput = StageInputConsumer[DownloadRequest]

type DownloadStageOutput = StageOutputProducer[BuildRequest]

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

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

type JobWaiterMessage int

type LabelMap = map[string]proton.Label

type MessageBuilder interface {
	WithKeys(f func(*crypto.KeyRing, map[string]*crypto.KeyRing) error) error
	BuildMessage(apiLabels map[string]proton.Label, full proton.FullMessage, addrKR *crypto.KeyRing, buffer *bytes.Buffer) (BuildResult, error)
}

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

type MetadataStageInput = StageInputConsumer[*Job]

type MetadataStageOutput = StageOutputProducer[DownloadRequest]

type Regulator interface {
	Sync(ctx context.Context, stage *Job) error
}

type Reporter interface {
	OnStart(ctx context.Context)
	OnFinished(ctx context.Context)
	OnError(ctx context.Context, err error)
	OnProgress(ctx context.Context, delta int64)
	InitializeProgressCounter(ctx context.Context, current int64, total int64)
}

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

type StageInputConsumer[T any] interface {
	Consume(ctx context.Context) (T, error)
}

type StageOutputProducer[T any] interface {
	Produce(ctx context.Context, value T) error
	Close()
}

type StateProvider interface {
	AddFailedMessageID(context.Context, ...string) error
	RemFailedMessageID(context.Context, ...string) error
	GetSyncStatus(context.Context) (Status, error)
	ClearSyncStatus(context.Context) error
	SetHasLabels(context.Context, bool) error
	SetHasMessages(context.Context, bool) error
	SetLastMessageID(context.Context, string, int64) error
	SetMessageCount(context.Context, int64) error
}

type Status struct {
	HasLabels           bool
	HasMessages         bool
	HasMessageCount     bool
	FailedMessages      xmaps.Set[string]
	LastSyncedMessageID string
	NumSyncedMessages   int64
	TotalMessageCount   int64
}

type UpdateApplier interface {
	ApplySyncUpdates(ctx context.Context, updates []BuildResult) error
	SyncSystemLabelsOnly(ctx context.Context, labels map[string]proton.Label) error
	SyncLabels(ctx context.Context, labels map[string]proton.Label) error
}