database

Jul 29, 2020

Changes in this version

type SessionRepository

+ func (r *SessionRepository) DoInTx(ctx context.Context, f func(ctx context.Context) (interface{}, error)) (interface{}, error)

+ func (r *SessionRepository) FindByIDForUpdate(ctx context.Context, id string) (*entity.Session, error)

+ type TransactionDAO interface

+ Exec func(query string, args ...interface{}) (sql.Result, error)

+ Insert func(list ...interface{}) error

+ SelectOne func(holder interface{}, query string, args ...interface{}) error

+ Update func(list ...interface{}) (int64, error)

Jul 18, 2020

Changes in this version

+ func NewDB() (*gorp.DbMap, error)

+ type AuthRepository struct

+ func NewAuthRepository(dbMap *gorp.DbMap) *AuthRepository

+ func (r AuthRepository) DeleteState(state string) error

+ func (r AuthRepository) FindStateByState(state string) (*entity.AuthState, error)

+ func (r AuthRepository) GetTokenByUserID(userID string) (*oauth2.Token, error)

+ func (r AuthRepository) GetUserIDFromSession(sessionID string) (string, error)

+ func (r AuthRepository) StoreORUpdateToken(userID string, token *oauth2.Token) error

+ func (r AuthRepository) StoreSession(sessionID, userID string) error

+ func (r AuthRepository) StoreState(authState *entity.AuthState) error

+ type SessionRepository struct

+ func NewSessionRepository(dbMap *gorp.DbMap) *SessionRepository

+ func (r *SessionRepository) ArchiveSessionsForBatch() error

+ func (r *SessionRepository) FindByID(id string) (*entity.Session, error)

+ func (r *SessionRepository) FindCreatorTokenBySessionID(sessionID string) (*oauth2.Token, string, error)

+ func (r *SessionRepository) StoreQueueTrack(queueTrack *entity.QueueTrackToStore) error

+ func (r *SessionRepository) StoreSession(session *entity.Session) error

+ func (r *SessionRepository) Update(session *entity.Session) error

+ func (r *SessionRepository) UpdateWithExpiredAt(session *entity.Session, newExpiredAt time.Time) error

+ type UserRepository struct

+ func NewUserRepository(dbMap *gorp.DbMap) *UserRepository

+ func (r *UserRepository) FindByID(id string) (*entity.User, error)

+ func (r *UserRepository) FindBySpotifyUserID(spotifyUserID string) (*entity.User, error)

+ func (r *UserRepository) Store(user *entity.User) error

+ func (r *UserRepository) Update(user *entity.User) error