db

type Connection interface {
	Close()
	Begin() (*sql.Tx, error)

	CreateUser(
		tx *sql.Tx,
		userid, givenName, familyName, email string,
		isPrivateEmail, isEmailVerified bool,
	) (*User, error)
	DeleteUser(tx *sql.Tx, userid string) error
	LookupUser(tx *sql.Tx, userid string) (*User, error)
	UpdateUserEmail(tx *sql.Tx, userid, email string, isPrivateEmail, forward bool) error

	CreateSession(
		tx *sql.Tx,
		user *User,
		refreshTime, expireTime time.Time,
		refreshToken, accessToken, identityToken string,
		nonce string,
		provider string,
	) (*Session, error)
	DeleteSession(tx *sql.Tx, sessionid string) error
	DeleteSessionsForUser(tx *sql.Tx, userid string) error
	LookupSession(tx *sql.Tx, sessionid string) (*Session, error)
	UpdateSessionTokens(
		tx *sql.Tx,
		session *Session,
		accessToken, refreshToken, identityToken string,
		expiresIn time.Duration,
	) error

	AddRole(tx *sql.Tx, user *User, role string) error
	RemoveRole(tx *sql.Tx, user *User, role string) error
	QueryRoles(tx *sql.Tx, user *User) ([]string, error)
}

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

type Session struct {
	ID            string
	UserID        string
	Nonce         string
	RefreshToken  string
	AccessToken   string
	IdentityToken string
	Provider      string
	CreateTime    time.Time
	RefreshTime   time.Time
	ExpireTime    time.Time
	// contains filtered or unexported fields
}

type User struct {
	ID              string
	GivenName       string
	FamilyName      string
	Email           string
	IsPrivateEmail  bool
	IsEmailVerified bool
	CreateTime      time.Time
	// contains filtered or unexported fields
}