storage

Documentation

Index

• Variables
• type Color
• type DeviceTokenType
• type Game
• type GameResults
  • func (r *GameResults) Scan(value interface{}) error
  • func (r *GameResults) Value() (driver.Value, error)
• type Player
• type SearchUsers
• 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, req SearchUsers) ([]*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, req UpdateUser) (*User, error)
  • func (s *Storage) UpsertUser(ctx context.Context, req UpsertUser) error
• type UpdateUser
• type UpsertUser
• type User
• type UserNotificationState
• type UserType

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 DeviceTokenType

type DeviceTokenType string

const (
	DeviceTokenTypeSandbox    DeviceTokenType = "sdbx"
	DeviceTokenTypeProduction DeviceTokenType = "prod"
)

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 SearchUsers

type SearchUsers struct {
	Search         string
	ExcludedUserId string
	Limit          int
	Type           UserType
}

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, state UserNotificationState) (UserNotificationState, 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, req SearchUsers) ([]*User, error)

func (*Storage) UpdateDeviceToken

func (s *Storage) UpdateDeviceToken(ctx context.Context, userId string, deviceToken []byte, tokenType DeviceTokenType) 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, req UpdateUser) (*User, error)

func (*Storage) UpsertUser

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

type UpdateUser

type UpdateUser struct {
	UserId   string
	Nickname string
	Color    Color
	Type     UserType
}

type UpsertUser

type UpsertUser struct {
	UserId   string
	Nickname string
	LastIp   string
	Color    Color
}

type User

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

type UserNotificationState

type UserNotificationState struct {
	DeviceToken      []byte
	DeviceTokenType  DeviceTokenType
	SentNotification SentNotification
}

type UserType

type UserType string

const (
	UserTypeBlank  UserType = "blank"  // Just created users receive this type
	UserTypeActive UserType = "active" // Users that has changed their username and are ready to play
)