user

Documentation

Index

• Constants
• Variables
• func TryBuildDebugMessage(path string) error
• type AccountMailboxMap
• type DebugMetadata
• type DiagMailboxMessage
• type DiagnosticMetadata
  • func (apm DiagnosticMetadata) BuildMailboxToMessageMap(ctx context.Context, user *User) (map[string]AccountMailboxMap, error)
• type User
  • func New(ctx context.Context, encVault *vault.User, client *proton.Client, ...) (*User, error)
  • func (user *User) BadEventFeedbackResync(ctx context.Context) error
  • func (user *User) BridgePass() []byte
  • func (user *User) CheckAuth(email string, password []byte) (string, error)
  • func (user *User) Close()
  • func (user *User) DebugDownloadMessages(ctx context.Context, path string, msgs map[string]DiagMailboxMessage, ...) error
  • func (user *User) DisplayNames() map[string]string
  • func (user *User) Emails() []string
  • func (user *User) GetAddressMode() vault.AddressMode
  • func (user *User) GetDiagnosticMetadata(ctx context.Context) (DiagnosticMetadata, error)
  • func (user *User) GetEventCh() <-chan events.Event
  • func (user *User) GetGluonID(addrID string) (string, bool)
  • func (user *User) GetGluonIDs() map[string]string
  • func (user *User) GetSMTPService() *smtp.Service
  • func (user *User) GetUserPlanName() string
  • func (user *User) GluonKey() []byte
  • func (user *User) ID() string
  • func (user *User) IsTelemetryEnabled(ctx context.Context) bool
  • func (user *User) Logout(ctx context.Context, withAPI, withData, withDataDisabledKillSwitch bool) error
  • func (user *User) Match(query string) bool
  • func (user *User) MaxSpace() uint64
  • func (user *User) Name() string
  • func (user *User) OnBadEvent(ctx context.Context)
  • func (user *User) PauseEventLoop()
  • func (user *User) PauseEventLoopWithWaiter() *userevents.EventPollWaiter
  • func (user *User) PublishEvent(_ context.Context, event events.Event)
  • func (user *User) RemoveGluonID(addrID, gluonID string) error
  • func (user *User) ResumeEventLoop()
  • func (user *User) SendRepairDeferredTrigger(ctx context.Context)
  • func (user *User) SendRepairTrigger(ctx context.Context)
  • func (user *User) SendTelemetry(ctx context.Context, data []byte) error
  • func (user *User) SetAddressMode(ctx context.Context, mode vault.AddressMode) error
  • func (user *User) SetGluonID(addrID, gluonID string) error
  • func (user *User) SetShowAllMail(show bool)
  • func (user *User) TriggerRepair() error
  • func (user *User) UsedSpace() uint64
  • func (user *User) VerifyResyncAndExecute()

Constants

const (
	SyncRetryCooldown = 20 * time.Second
)

Variables

var (
	ErrNoSuchAddress  = errors.New("no such address")
	ErrMissingAddrKey = errors.New("missing address key")
)

var (
	EventPeriod = 20 * time.Second // nolint:gochecknoglobals,revive
	EventJitter = 20 * time.Second // nolint:gochecknoglobals,revive
)

Functions

func TryBuildDebugMessage

func TryBuildDebugMessage(path string) error

Types

type AccountMailboxMap

type AccountMailboxMap map[string][]DiagMailboxMessage

type DebugMetadata

type DebugMetadata struct {
	proton.MessageMetadata
	Header        string
	ParsedHeaders proton.Headers
	MIMEType      rfc822.MIMEType
	Attachments   []proton.Attachment
}

type DiagMailboxMessage

type DiagMailboxMessage struct {
	AddressID string
	UserID    string
	ID        string
	Flags     imap.FlagSet
}

type DiagnosticMetadata

type DiagnosticMetadata struct {
	MessageIDs       []string
	Metadata         []proton.MessageMetadata
	FailedMessageIDs xmaps.Set[string]
}

func (DiagnosticMetadata) BuildMailboxToMessageMap

func (apm DiagnosticMetadata) BuildMailboxToMessageMap(ctx context.Context, user *User) (map[string]AccountMailboxMap, error)

type User

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

func New

func New(
	ctx context.Context,
	encVault *vault.User,
	client *proton.Client,
	reporter reporter.Reporter,
	apiUser proton.User,
	crashHandler async.PanicHandler,
	showAllMail bool,
	maxSyncMemory uint64,
	telemetryManager telemetry.Availability,
	imapServerManager imapservice.IMAPServerManager,
	smtpServerManager smtp.ServerManager,
	eventSubscription events.Subscription,
	syncService syncservice.Regulator,
	observabilityService *observability.Service,
	syncConfigDir string,
	isNew bool,
	notificationStore *notifications.Store,
	getFlagValFn unleash.GetFlagValueFn,
) (*User, error)

func (*User) BadEventFeedbackResync

func (user *User) BadEventFeedbackResync(ctx context.Context) error

BadEventFeedbackResync sends user feedback whether should do message re-sync.

func (*User) BridgePass

func (user *User) BridgePass() []byte

BridgePass returns the user's bridge password, used for authentication over SMTP and IMAP.

func (*User) CheckAuth

func (user *User) CheckAuth(email string, password []byte) (string, error)

CheckAuth returns whether the given email and password can be used to authenticate over IMAP or SMTP with this user. It returns the address ID of the authenticated address.

func (*User) Close

func (user *User) Close()

Close closes ongoing connections and cleans up resources.

func (*User) DebugDownloadMessages

func (user *User) DebugDownloadMessages(
	ctx context.Context,
	path string,
	msgs map[string]DiagMailboxMessage,
	progressCB func(string, int, int),
) error

func (*User) DisplayNames

func (user *User) DisplayNames() map[string]string

DisplayNames returns a map of the email addresses and their associated display names.

func (*User) Emails

func (user *User) Emails() []string

Emails returns all the user's active email addresses. It returns them in sorted order; the user's primary address is first.

func (*User) GetAddressMode

func (user *User) GetAddressMode() vault.AddressMode

GetAddressMode returns the user's current address mode.

func (*User) GetDiagnosticMetadata

func (user *User) GetDiagnosticMetadata(ctx context.Context) (DiagnosticMetadata, error)

func (*User) GetEventCh

func (user *User) GetEventCh() <-chan events.Event

GetEventCh returns a channel which notifies of events happening to the user (such as deauth, address change).

func (*User) GetGluonID

func (user *User) GetGluonID(addrID string) (string, bool)

GetGluonID returns the gluon ID for the given address, if present.

func (*User) GetGluonIDs

func (user *User) GetGluonIDs() map[string]string

GetGluonIDs returns the users gluon IDs.

func (*User) GetSMTPService

func (user *User) GetSMTPService() *smtp.Service

func (*User) GetUserPlanName

func (user *User) GetUserPlanName() string

GetUserPlanName returns the user's subscription plan name.

func (*User) GluonKey

func (user *User) GluonKey() []byte

GluonKey returns the user's gluon key from the vault.

func (*User) ID

func (user *User) ID() string

ID returns the user's ID.

func (*User) IsTelemetryEnabled

func (user *User) IsTelemetryEnabled(ctx context.Context) bool

IsTelemetryEnabled check if the telemetry is enabled or disabled for this user.

func (*User) Logout

func (user *User) Logout(ctx context.Context, withAPI, withData, withDataDisabledKillSwitch bool) error

Logout logs the user out from the API.

func (*User) Match

func (user *User) Match(query string) bool

Match matches the given query against the user's username and email addresses.

func (*User) MaxSpace

func (user *User) MaxSpace() uint64

MaxSpace returns the amount of space the user can use on the API.

func (*User) Name

func (user *User) Name() string

Name returns the user's username.

func (*User) OnBadEvent

func (user *User) OnBadEvent(ctx context.Context)

func (*User) PauseEventLoop

func (user *User) PauseEventLoop()

func (*User) PauseEventLoopWithWaiter

func (user *User) PauseEventLoopWithWaiter() *userevents.EventPollWaiter

func (*User) PublishEvent

func (user *User) PublishEvent(_ context.Context, event events.Event)

func (*User) RemoveGluonID

func (user *User) RemoveGluonID(addrID, gluonID string) error

RemoveGluonID removes the gluon ID for the given address.

func (*User) ResumeEventLoop

func (user *User) ResumeEventLoop()

func (*User) SendRepairDeferredTrigger

func (user *User) SendRepairDeferredTrigger(ctx context.Context)

func (*User) SendRepairTrigger

func (user *User) SendRepairTrigger(ctx context.Context)

func (*User) SendTelemetry

func (user *User) SendTelemetry(ctx context.Context, data []byte) error

SendTelemetry send telemetry request.

func (*User) SetAddressMode

func (user *User) SetAddressMode(ctx context.Context, mode vault.AddressMode) error

SetAddressMode sets the user's address mode.

func (*User) SetGluonID

func (user *User) SetGluonID(addrID, gluonID string) error

SetGluonID sets the gluon ID for the given address.

func (*User) SetShowAllMail

func (user *User) SetShowAllMail(show bool)

SetShowAllMail sets whether to show the All Mail mailbox.

func (*User) TriggerRepair

func (user *User) TriggerRepair() error

func (*User) UsedSpace

func (user *User) UsedSpace() uint64

UsedSpace returns the total space used by the user on the API.

func (*User) VerifyResyncAndExecute

func (user *User) VerifyResyncAndExecute()