add player data operations: update, ban/unban, delete, inventory adjust, storage

Players.Update/Ban/Unban/Delete + List search; new InventoryService.Adjust
and StorageService.Get/Upsert/Delete; IdempotencyKey on wallet adjust;
models regenerated via apigen
This commit is contained in:
edmand46
2026-08-13 08:47:14 +03:00
parent d602a95baf
commit ae74fb22d3
12 changed files with 221 additions and 22 deletions
+63
View File
@@ -2,9 +2,11 @@ package rudder
import (
"context"
"encoding/json"
"net/http"
"net/url"
"strconv"
"time"
"hub.rudder.build/rudder/rudder-go-sdk/models"
)
@@ -16,6 +18,7 @@ type PlayersService struct {
type ListPlayersParameters struct {
Limit int
Offset int
Search string
}
func (s *PlayersService) List(ctx context.Context, parameters ListPlayersParameters) (*models.ListPlayersResponse, error) {
@@ -26,6 +29,9 @@ func (s *PlayersService) List(ctx context.Context, parameters ListPlayersParamet
if parameters.Offset > 0 {
query.Set("offset", strconv.Itoa(parameters.Offset))
}
if parameters.Search != "" {
query.Set("search", parameters.Search)
}
var response models.ListPlayersResponse
if err := s.transport.do(ctx, http.MethodGet, "/players/list", query, nil, &response); err != nil {
@@ -41,3 +47,60 @@ func (s *PlayersService) Get(ctx context.Context, playerID string) (*models.Admi
}
return &response, nil
}
type UpdatePlayerParameters struct {
Nickname *string
Data json.RawMessage
}
func (s *PlayersService) Update(ctx context.Context, playerID string, parameters UpdatePlayerParameters) (*models.AdminPlayer, error) {
body := models.UpdatePlayerRequest{
Data: parameters.Data,
}
if parameters.Nickname != nil {
body.Nickname = *parameters.Nickname
}
var response models.AdminPlayer
if err := s.transport.do(ctx, http.MethodPatch, "/players/"+url.PathEscape(playerID), nil, body, &response); err != nil {
return nil, err
}
return &response, nil
}
type BanPlayerParameters struct {
Reason string
Until *time.Time
IdempotencyKey string
}
func (s *PlayersService) Ban(ctx context.Context, playerID string, parameters BanPlayerParameters) (*models.AdminPlayer, error) {
body := models.BanPlayerRequest{
Reason: parameters.Reason,
IdempotencyKey: parameters.IdempotencyKey,
}
if parameters.Until != nil {
body.BannedUntil = parameters.Until.Format(time.RFC3339)
}
var response models.AdminPlayer
if err := s.transport.do(ctx, http.MethodPost, "/players/"+url.PathEscape(playerID)+"/ban", nil, body, &response); err != nil {
return nil, err
}
return &response, nil
}
func (s *PlayersService) Unban(ctx context.Context, playerID string) (*models.AdminPlayer, error) {
var response models.AdminPlayer
if err := s.transport.do(ctx, http.MethodPost, "/players/"+url.PathEscape(playerID)+"/unban", nil, nil, &response); err != nil {
return nil, err
}
return &response, nil
}
func (s *PlayersService) Delete(ctx context.Context, playerID string, idempotencyKey string) error {
body := models.DeletePlayerRequest{
IdempotencyKey: idempotencyKey,
}
return s.transport.do(ctx, http.MethodDelete, "/players/"+url.PathEscape(playerID), nil, body, nil)
}