storage

Documentation

Index

• Variables
• type Color
• type Game
• type GameResults
  • func (r *GameResults) Scan(value interface{}) error
  • func (r *GameResults) Value() (driver.Value, error)
• type Player
• type SentNotification
  • func (sn *SentNotification) Scan(value interface{}) error
  • func (sn *SentNotification) Value() (driver.Value, error)
• type SentNotificationUpdater
• type Storage
  • func New(db *sql.DB) (*Storage, error)
  • func (s *Storage) CreateGame(ctx context.Context, game *Game) error
  • func (s *Storage) GetActiveGames(ctx context.Context) ([]*Game, error)
  • func (s *Storage) GetActiveUsers(ctx context.Context, activityBuffer time.Duration) ([]string, error)
  • func (s *Storage) GetGameByPlayerId(ctx context.Context, playerId string) (*Game, error)
  • func (s *Storage) GetGamesByUserId(ctx context.Context, userId string) ([]*Game, error)
  • func (s *Storage) GetUserById(ctx context.Context, userId string) (*User, error)
  • func (s *Storage) GetUserByNickname(ctx context.Context, nickname string) (*User, error)
  • func (s *Storage) SearchUsers(ctx context.Context, search string, limit int, excludeUser string) ([]*User, error)
  • func (s *Storage) UpdateDeviceToken(ctx context.Context, userId string, deviceToken []byte) error
  • func (s *Storage) UpdateGameResults(ctx context.Context, gameId string, results GameResults) error
  • func (s *Storage) UpdateSentNotification(ctx context.Context, userId string, updater SentNotificationUpdater) error
  • func (s *Storage) UpdateUser(ctx context.Context, user *User) (*User, error)
  • func (s *Storage) UpsertUser(ctx context.Context, user *User) error
• type User

Variables

var (
	ErrAlreadyExists = errors.New("already exists")
	ErrNotFound      = errors.New("not found")
)

Types

type Color

type Color string

const (
	ColorBlue   Color = "blue"
	ColorRed    Color = "red"
	ColorYellow Color = "yellow"
	ColorGreen  Color = "green"
	ColorBlack  Color = "black"
	ColorPurple Color = "purple"
	ColorOrange Color = "orange"
	ColorPink   Color = "pink"
	ColorBronze Color = "bronze"
)

type Game

type Game struct {
	GameId      string
	SpectatorId string
	CreatedAt   time.Time
	ExpiresAt   time.Time
	Players     []*Player
}

type GameResults

type GameResults struct {
	Raw map[string]any
}

func (*GameResults) Scan

func (r *GameResults) Scan(value interface{}) error

func (*GameResults) Value

func (r *GameResults) Value() (driver.Value, error)

type Player

type Player struct {
	UserId   string
	PlayerId string
	Color    Color
}

type SentNotification

type SentNotification struct {
	ActiveGames int `json:"ag"`
}

func (*SentNotification) Scan

func (sn *SentNotification) Scan(value interface{}) error

func (*SentNotification) Value

func (sn *SentNotification) Value() (driver.Value, error)

type SentNotificationUpdater

type SentNotificationUpdater func(ctx context.Context, sn SentNotification) (SentNotification, error)

type Storage

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

func New

func New(db *sql.DB) (*Storage, error)

func (*Storage) CreateGame

func (s *Storage) CreateGame(ctx context.Context, game *Game) error

func (*Storage) GetActiveGames

func (s *Storage) GetActiveGames(ctx context.Context) ([]*Game, error)

func (*Storage) GetActiveUsers

func (s *Storage) GetActiveUsers(ctx context.Context, activityBuffer time.Duration) ([]string, error)

func (*Storage) GetGameByPlayerId

func (s *Storage) GetGameByPlayerId(ctx context.Context, playerId string) (*Game, error)

func (*Storage) GetGamesByUserId

func (s *Storage) GetGamesByUserId(ctx context.Context, userId string) ([]*Game, error)

func (*Storage) GetUserById

func (s *Storage) GetUserById(ctx context.Context, userId string) (*User, error)

func (*Storage) GetUserByNickname

func (s *Storage) GetUserByNickname(ctx context.Context, nickname string) (*User, error)

func (*Storage) SearchUsers

func (s *Storage) SearchUsers(ctx context.Context, search string, limit int, excludeUser string) ([]*User, error)

func (*Storage) UpdateDeviceToken

func (s *Storage) UpdateDeviceToken(ctx context.Context, userId string, deviceToken []byte) error

func (*Storage) UpdateGameResults

func (s *Storage) UpdateGameResults(ctx context.Context, gameId string, results GameResults) error

func (*Storage) UpdateSentNotification

func (s *Storage) UpdateSentNotification(ctx context.Context, userId string, updater SentNotificationUpdater) error

func (*Storage) UpdateUser

func (s *Storage) UpdateUser(ctx context.Context, user *User) (*User, error)

func (*Storage) UpsertUser

func (s *Storage) UpsertUser(ctx context.Context, user *User) error

type User

type User struct {
	UserId      string
	Nickname    string
	Color       Color
	CreatedAt   time.Time
	DeviceToken []byte
}