database

type Database interface {
	BeginTx() (Transaction, error)
	Close() error

	AddSession(session Session) error
	DeleteSession(uid string) error
	GetSessionByUserId(userId string) (Session, error)

	AddRemyx(rmx Remyx) error
	UpdateRemyx(rmx Remyx) error
	DeleteRemyx(uid string) error
	GetRemyx(uid string) (Remyx, error)
	ListRemyxes(userId string) ([]RemyxWithCount, error)

	AddSourcePlaylist(pl RemyxPlaylist) error
	DeleteSourcePlaylist(remyxUid, userUid, playlistUid string) error
	GetSourcePlaylists(remyxUid string) ([]RemyxPlaylist, error)

	AddTargetPlaylist(pl RemyxPlaylist) error
	DeleteTargetPlaylist(remyxUid, userUid string) error
	GetTargetPlaylists(remyxUid string) ([]RemyxPlaylist, error)
}

type Entity struct {
	Uid       string    `json:"uid"`
	CreatedAt time.Time `json:"created_at"`
}

type PostgresDriver struct {
	*SQLDriver
	// contains filtered or unexported fields
}

type Remyx struct {
	Entity

	CreatorUid string  `json:"creator_uid"`
	Head       int     `json:"head"`
	Name       *string `json:"name"`
}

type RemyxPlaylist struct {
	RemyxUid    string     `json:"remyx_uid"`
	PlaylistUid spotify.ID `json:"playlist_uid"`
	UserUid     string     `json:"user_uid"`
}

type RemyxWithCount struct {
	Remyx

	PlaylistCount int `json:"playlist_count"`
}

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

type Session struct {
	Entity

	UserId       string `json:"user_uid"`
	RefreshToken string `json:"refresh_token"`
}

type TX struct {
	sync.Mutex

	*SQLDriver
	// contains filtered or unexported fields
}

type Transaction interface {
	Database
	Commit() error
	Rollback() error
}