core

type Account struct {
	ID           string
	Email        string
	CreatedAt    time.Time
	LastSignInAt *time.Time
}

type AccountStore interface {
	// Insert stores a, and does nothing when its email already has an account.
	Insert(ctx context.Context, a Account) error
	GetByEmail(ctx context.Context, email string) (Account, error)
	GetByID(ctx context.Context, id string) (Account, error)
	SetLastSignIn(ctx context.Context, id string, at time.Time) error
	List(ctx context.Context) ([]Account, error)
	// DeleteByEmail removes the account, and with it everything that
	// references it: tokens, sessions, share links, and pending sign-in codes.
	DeleteByEmail(ctx context.Context, email string) error
}

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

type CodeStore interface {
	Put(ctx context.Context, email, codeHash string, expiresAt time.Time) error
	// Consume checks codeHash against email's pending code. A match burns the
	// code and returns ok. A miss counts an attempt; the code burns on the
	// maxAttempts-th miss. left is the attempts remaining, and 0 when no live
	// code remains.
	Consume(ctx context.Context, email, codeHash string, now time.Time, maxAttempts int) (ok bool, left int, err error)
	DeleteExpired(ctx context.Context, now time.Time) (int, error)
}

type Document struct {
	ID        string
	Space     string
	Path      string
	Title     string
	Kind      drive.Kind
	SHA256    string
	Size      int64
	UpdatedAt time.Time
}

type DocumentStore interface {
	// Put checks the quota and upserts in one transaction. A nil quota means
	// unlimited.
	Put(ctx context.Context, d NewDocument, quota *int64) (Document, error)
	Get(ctx context.Context, space, path string) (Document, []byte, error)
	List(ctx context.Context, space string) ([]Document, error)
	Recent(ctx context.Context, limit int) ([]Document, error)
	// ListByIDs returns the documents that exist among ids, newest first.
	ListByIDs(ctx context.Context, ids []string) ([]Document, error)
	Spaces(ctx context.Context) ([]SpaceUsage, error)
	Delete(ctx context.Context, space, path string) (string, error)
	GetByID(ctx context.Context, id string) (Document, []byte, error)
	// Search matches q as plain terms, the last one as a prefix, in one space
	// or in all of them when space is empty. Title and path matches rank above
	// body matches.
	Search(ctx context.Context, q, space string, limit int) ([]SearchHit, error)
	// Usage is the sum of all stored body sizes.
	Usage(ctx context.Context) (int64, error)
}

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

type Error struct {
	Kind    Kind
	Message string
	Err     error
}

type Kind string

type Mail struct {
	ID        string
	To        string
	Subject   string
	Body      string
	Attempts  int
	NextAt    time.Time
	CreatedAt time.Time
}

type NewDocument struct {
	ID         string
	Space      string
	Path       string
	Title      string
	Kind       drive.Kind
	SHA256     string
	Body       []byte
	SearchText string
	UpdatedAt  time.Time
}

type Option func(*options)

type OutboxStore interface {
	Append(ctx context.Context, m Mail) error
	// Due returns up to limit mails whose NextAt is not after now, oldest first.
	Due(ctx context.Context, now time.Time, limit int) ([]Mail, error)
	// MarkSent removes m: the outbox holds only mail still to send.
	MarkSent(ctx context.Context, id string) error
	MarkFailed(ctx context.Context, id string, nextAt time.Time) error
}

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

type Principal struct {
	UserID     string
	Email      string
	Scope      Scope
	Policy     config.Policy
	ViaSession bool
}

type Scope string

type SearchHit struct {
	Document Document
	Snippet  string
}

type Session struct {
	ID        string
	UserID    string
	ExpiresAt time.Time
	CreatedAt time.Time
}

type SessionStore interface {
	Insert(ctx context.Context, s Session, valueHash string) error
	GetByValueHash(ctx context.Context, valueHash string) (Session, error)
	SetExpiry(ctx context.Context, id string, expiresAt time.Time) error
	// DeleteByValueHash does nothing when the session is already gone.
	DeleteByValueHash(ctx context.Context, valueHash string) error
	DeleteExpired(ctx context.Context, now time.Time) (int, error)
}

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

type ShareLink struct {
	ID         string
	Slug       string
	UserID     string
	DocumentID string
	ExpiresAt  *time.Time
	// ExpiresIn is the preset that set ExpiresAt, or empty for no expiry.
	ExpiresIn string
	CreatedAt time.Time
}

type ShareStore interface {
	// InsertIfAbsent stores l unless its document already has a link.
	InsertIfAbsent(ctx context.Context, l ShareLink) error
	GetBySlug(ctx context.Context, slug string) (ShareLink, error)
	GetByDocument(ctx context.Context, userID, documentID string) (ShareLink, error)
	ListByUser(ctx context.Context, userID string) ([]ShareLink, error)
	UpdateExpiry(ctx context.Context, id string, expiresAt *time.Time, expiresIn string) error
	Delete(ctx context.Context, id string) error
	DeleteByDocument(ctx context.Context, userID, documentID string) error
	DeleteExpired(ctx context.Context, now time.Time) (int, error)
}

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

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

type SpaceUsage struct {
	Space     string
	Documents int
	Bytes     int64
}

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

type Token struct {
	ID         string
	UserID     string
	Name       string
	Scope      Scope
	ExpiresAt  *time.Time
	LastUsedAt *time.Time
	CreatedAt  time.Time
}

type TokenStore interface {
	Insert(ctx context.Context, t Token, secretHash string) error
	GetBySecretHash(ctx context.Context, secretHash string) (Token, error)
	ListByUser(ctx context.Context, userID string) ([]Token, error)
	Delete(ctx context.Context, userID, id string) error
	Touch(ctx context.Context, id string, at time.Time) error
}

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

type UserStores interface {
	// Open returns userID's store, creating an empty one on first use. The
	// caller must call release when done; the store stays valid until then.
	Open(ctx context.Context, userID string) (store DocumentStore, release func(), err error)
	// Remove deletes everything stored for userID, once its leases are released.
	Remove(ctx context.Context, userID string) error
}