sdk: Players.VerifyAuth and VerifyWebhookSignature helper

README.md

@@ -23,7 +23,7 @@ go get hub.rudder.build/rudder/rudder-go-sdk@latest
 
 ## Доступ
 
-`APIKey` — это per-project Admin Key: поле «Admin Key» в настройках проекта
+`AdminKey` — это per-project Admin Key: поле «Admin Key» в настройках проекта
 в дашборде (app.rudder.build → проект → Settings). Ключ сам определяет
 проект, отдельный project ID не нужен. Храните его только на сервере —
 никогда не вшивайте в игровые клиенты.
@@ -32,20 +32,190 @@ go get hub.rudder.build/rudder/rudder-go-sdk@latest
 
 ```go
 client, err := rudder.New(rudder.Config{
-    APIKey: os.Getenv("RUDDER_ADMIN_KEY"),
+    AdminKey: os.Getenv("RUDDER_ADMIN_KEY"),
 })
 if err != nil {
     // *rudder.APIError с кодом sdk/invalid-options
 }
 
 players, err := client.Players.List(ctx, rudder.ListPlayersParameters{Limit: 100})
-entries, err := client.Leaderboards.Results(ctx, "weekly")
+```
-wallet, err := client.Wallet.Adjust(ctx, playerID, rudder.AdjustWalletParameters{
+
-    CurrencyCode: "coins",
+Публичные типы живут в пакете `rudder`. Пакет `models` — сгенерированный
-    Amount:       100,
+wire-формат, в прикладном коде его импортировать не нужно.
-    Reason:       "compensation",
+
+## Handles
+
+`client.Player(id)` и `client.Leaderboard(slug)` создают handle без
+HTTP-запроса. Handles — сахар над batch-методами сервисов: каждая операция
+отправляет batch из одного элемента с подставленным playerID/slug.
+
+```go
+player := client.Player("p1")
+
+wallet, err := player.Wallet().Adjust(ctx, rudder.AdjustPlayerWalletParameters{
+    IdempotencyKey: "grant-001",
+    CurrencyCode:   "coins",
+    Amount:         100,
+    Reason:         "compensation",
 })
-metrics, err := client.Metrics.Get(ctx)
+history, err := player.Wallet().History(ctx, rudder.WalletHistoryParameters{Limit: 50})
+
+item, err := player.Inventory().Adjust(ctx, rudder.AdjustPlayerInventoryParameters{
+    Slug:   "sword",
+    Amount: 1,
+    Reason: "quest reward",
+})
+inventory, err := player.Inventory().List(ctx, rudder.ListInventoryParameters{Limit: 50})
+
+storage, err := player.Storage().Get(ctx, "settings")
+updated, err := player.Storage().Upsert(ctx, rudder.UpsertPlayerStorageParameters{
+    Type: "settings",
+    Data: `{"lang":"ru"}`,
+})
+err = player.Storage().Delete(ctx, rudder.DeletePlayerStorageParameters{Type: "settings"})
+
+quests, err := player.Quests().List(ctx)
+err = player.Quests().Reset(ctx, rudder.PlayerQuestParameters{QuestID: "daily-1"})
+// ForceComplete и ForceClaim — аналогично
+
+updatedPlayer, err := player.Update(ctx, rudder.UpdatePlayerParameters{Nickname: "Neo"})
+banned, err := player.Ban(ctx, rudder.BanPlayerParameters{
+    Reason:      "cheating",
+    BannedUntil: "2030-01-01T00:00:00Z",
+})
+unbanned, err := player.Unban(ctx, "")
+err = player.Delete(ctx, "")
+
+board := client.Leaderboard("weekly")
+
+entries, err := board.List(ctx, rudder.ListLeaderboardEntriesParameters{Limit: 100})
+// entries.Entries []rudder.Rank, entries.NextCursor
+
+entry, err := board.Get(ctx, "p1")            // *rudder.Rank с rank
+around, err := board.GetAround(ctx, "p1", 10) // []rudder.Rank вокруг игрока
+
+err = board.Submit(ctx, []rudder.LeaderboardScore{{PlayerID: "p1", Score: 1500}})
+err = board.Update(ctx, []rudder.LeaderboardScore{{PlayerID: "p1", Score: 1600}})
+err = board.Delete(ctx, []string{"p1", "p2"})
+```
+
+## Batch-first API
+
+Все мутирующие операции верхнего уровня — batch-only: тело
+`{idempotencyKey?, items:[...]}` (`playerId` внутри элементов), до 100
+элементов, all-or-nothing в одной транзакции, один idempotency key на батч.
+
+```go
+wallets, err := client.Wallet.Adjust(ctx, rudder.AdjustWalletParameters{
+    IdempotencyKey: "grant-001",
+    Items: []rudder.WalletAdjustment{
+        {PlayerID: "p1", CurrencyCode: "coins", Amount: 100, Reason: "compensation"},
+        {PlayerID: "p2", CurrencyCode: "coins", Amount: 100, Reason: "compensation"},
+    },
+})
+
+items, err := client.Inventory.Adjust(ctx, rudder.AdjustInventoryParameters{
+    Items: []rudder.InventoryAdjustment{
+        {PlayerID: "p1", Slug: "sword", Amount: 1, Reason: "quest reward"},
+    },
+})
+
+updated, err := client.Players.Update(ctx, rudder.UpdatePlayersParameters{
+    Items: []rudder.PlayerUpdate{
+        {PlayerID: "p1", Nickname: "Neo"},
+    },
+})
+
+banned, err := client.Players.Ban(ctx, rudder.BanPlayersParameters{
+    Items: []rudder.PlayerBan{
+        {PlayerID: "p2", Reason: "cheating", BannedUntil: "2030-01-01T00:00:00Z"},
+    },
+})
+
+unbanned, err := client.Players.Unban(ctx, rudder.UnbanPlayersParameters{
+    PlayerIDs: []string{"p2"},
+})
+
+err = client.Players.Delete(ctx, rudder.DeletePlayersParameters{
+    PlayerIDs: []string{"p3"},
+})
+```
+
+## Верификация авторизации
+
+`Players.VerifyAuth` — одиночный (не batch) вызов `POST /players/auth/verify`:
+проверяет access token игрока и возвращает `playerId`, `projectId` и `status`
+(`active`/`banned`/`deleted`).
+
+```go
+verification, err := client.Players.VerifyAuth(ctx, accessToken)
+// verification.PlayerID, verification.ProjectID, verification.Status
+```
+
+`VerifyWebhookSignature` — пакетный хелпер для приёма webhook'ов с подписью
+`X-Signature` (hex HMAC-SHA256 от сырого тела, ключ — webhook secret проекта):
+
+```go
+if !rudder.VerifyWebhookSignature(secret, body, r.Header.Get("X-Signature")) {
+    // подпись не сошлась — отклонить запрос
+}
+```
+
+err = client.Quests.Reset(ctx, rudder.PlayerQuestsParameters{
+    Items: []rudder.PlayerQuestRef{
+        {PlayerID: "p1", QuestID: "daily-1"},
+    },
+})
+// ForceComplete и ForceClaim — аналогично
+
+err = client.Leaderboards.Submit(ctx, "weekly", []rudder.LeaderboardScore{
+    {PlayerID: "p1", Score: 1500},
+})
+// Update и Delete — аналогично
+
+err = client.Storage.Upsert(ctx, rudder.UpsertStorageParameters{
+    Items: []rudder.ProjectStorageInput{
+        {Type: "config", Data: `{"event":"x2"}`},
+    },
+})
+
+err = client.Storage.Delete(ctx, rudder.DeleteStorageParameters{
+    Types: []string{"config"},
+})
+```
+
+## Каталоги и read-операции
+
+Курсорная пагинация: передавайте `Limit`/`Cursor`, следующую страницу
+запрашивайте по `NextCursor` из ответа.
+
+```go
+boards, err := client.Leaderboards.List(ctx, rudder.ListLeaderboardsParameters{Limit: 100})
+// boards.Items []rudder.Leaderboard, boards.NextCursor
+
+quests, err := client.Quests.List(ctx, rudder.ListQuestsParameters{
+    Status: &status, // "active" или "archived", optional
+    Limit:  100,
+})
+// quests.Items []rudder.Quest, quests.NextCursor
+
+history, err := client.Wallet.History(ctx, playerID, rudder.WalletHistoryParameters{
+    Currency: &currency, // optional
+    Limit:    50,
+})
+// history.Entries []rudder.WalletTransaction, history.NextCursor
+
+inventory, err := client.Inventory.List(ctx, playerID, rudder.ListInventoryParameters{
+    Limit: 50,
+})
+// inventory.Items []rudder.InventoryItem, inventory.NextCursor
+
+storage, err := client.Storage.List(ctx, rudder.ListStorageParameters{
+    Limit:  100,
+    Search: "config", // optional
+})
+item, err := client.Storage.Get(ctx, "config")
 ```
 
 ## Ошибки
@@ -63,3 +233,4 @@ if errors.As(err, &apiErr) {
 
 `models/` генерируется apigen'ом из `liveops-gateway/openapi.yaml`
 (`make generate-openapi` в liveops-gateway). Руками не править.
+Публичные имена — aliases в корне пакета `rudder` (`types.go`).

client.go

@@ -8,7 +8,7 @@ import (
 const DefaultBaseURL = "https://api.rudder.build"
 
 type Config struct {
-	APIKey     string
+	AdminKey   string
 	BaseURL    string
 	Timeout    time.Duration
 	HTTPClient *http.Client
@@ -16,18 +16,18 @@ type Config struct {
 
 type Client struct {
 	Players      *PlayersService
-	Metrics      *MetricsService
 	Leaderboards *LeaderboardsService
 	Wallet       *WalletService
 	Inventory    *InventoryService
+	Quests       *QuestsService
 	Storage      *StorageService
 
-	ProjectStorage *ProjectStorageService
+	transport *transport
 }
 
 func New(config Config) (*Client, error) {
-	if config.APIKey == "" {
+	if config.AdminKey == "" {
-		return nil, &APIError{Code: ErrorCodeInvalidOptions, Message: "APIKey is required"}
+		return nil, &APIError{Code: ErrorCodeInvalidOptions, Message: "AdminKey is required"}
 	}
 
 	if config.BaseURL == "" {
@@ -42,18 +42,37 @@ func New(config Config) (*Client, error) {
 
 	transport := &transport{
 		baseURL:    config.BaseURL,
-		apiKey:     config.APIKey,
+		apiKey:     config.AdminKey,
 		httpClient: config.HTTPClient,
 	}
 
 	return &Client{
 		Players:      &PlayersService{transport: transport},
-		Metrics:      &MetricsService{transport: transport},
 		Leaderboards: &LeaderboardsService{transport: transport},
 		Wallet:       &WalletService{transport: transport},
 		Inventory:    &InventoryService{transport: transport},
+		Quests:       &QuestsService{transport: transport},
 		Storage:      &StorageService{transport: transport},
 
-		ProjectStorage: &ProjectStorageService{transport: transport},
+		transport: transport,
 	}, nil
 }
+
+func (c *Client) Player(playerID string) *PlayerHandle {
+	return &PlayerHandle{
+		playerID:  playerID,
+		transport: c.transport,
+		players:   c.Players,
+		wallet:    c.Wallet,
+		inventory: c.Inventory,
+		quests:    c.Quests,
+	}
+}
+
+func (c *Client) Leaderboard(slug string) *LeaderboardHandle {
+	return &LeaderboardHandle{
+		slug:         slug,
+		transport:    c.transport,
+		leaderboards: c.Leaderboards,
+	}
+}

inventory.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"net/http"
 	"net/url"
+	"strconv"
 
 	"hub.rudder.build/rudder/rudder-go-sdk/models"
 )
@@ -13,22 +14,39 @@ type InventoryService struct {
 }
 
 type AdjustInventoryParameters struct {
-	Slug           string
-	Amount         int64
-	Reason         string
 	IdempotencyKey string
+	Items          []InventoryAdjustment
 }
 
-func (s *InventoryService) Adjust(ctx context.Context, playerID string, parameters AdjustInventoryParameters) (*models.InventoryItem, error) {
+func (s *InventoryService) Adjust(ctx context.Context, parameters AdjustInventoryParameters) ([]InventoryItem, error) {
-	body := models.AdjustPlayerInventoryItemRequest{
+	body := models.BatchAdjustPlayerInventoryItemsRequest{
-		Slug:           parameters.Slug,
-		Amount:         parameters.Amount,
-		Reason:         parameters.Reason,
 		IdempotencyKey: parameters.IdempotencyKey,
+		Items:          parameters.Items,
 	}
 
-	var response models.InventoryItem
+	var response models.BatchAdjustPlayerInventoryItemsResponse
-	if err := s.transport.do(ctx, http.MethodPost, "/players/"+url.PathEscape(playerID)+"/inventory/adjust", nil, body, &response); err != nil {
+	if err := s.transport.do(ctx, http.MethodPost, "/players/inventory/adjust", nil, body, &response); err != nil {
+		return nil, err
+	}
+	return response.Items, nil
+}
+
+type ListInventoryParameters struct {
+	Limit  int
+	Cursor *string
+}
+
+func (s *InventoryService) List(ctx context.Context, playerID string, parameters ListInventoryParameters) (*InventoryList, error) {
+	query := url.Values{}
+	if parameters.Limit > 0 {
+		query.Set("limit", strconv.Itoa(parameters.Limit))
+	}
+	if parameters.Cursor != nil {
+		query.Set("cursor", *parameters.Cursor)
+	}
+
+	var response InventoryList
+	if err := s.transport.do(ctx, http.MethodGet, "/players/"+url.PathEscape(playerID)+"/inventory", query, nil, &response); err != nil {
 		return nil, err
 	}
 	return &response, nil

leaderboard.go

@@ -0,0 +1,70 @@
+package rudder
+
+import (
+	"context"
+	"net/http"
+	"net/url"
+	"strconv"
+
+	"hub.rudder.build/rudder/rudder-go-sdk/models"
+)
+
+type LeaderboardHandle struct {
+	slug         string
+	transport    *transport
+	leaderboards *LeaderboardsService
+}
+
+type ListLeaderboardEntriesParameters struct {
+	Limit  int
+	Cursor *string
+}
+
+func (h *LeaderboardHandle) List(ctx context.Context, parameters ListLeaderboardEntriesParameters) (*RankList, error) {
+	query := url.Values{}
+	if parameters.Limit > 0 {
+		query.Set("limit", strconv.Itoa(parameters.Limit))
+	}
+	if parameters.Cursor != nil {
+		query.Set("cursor", *parameters.Cursor)
+	}
+
+	var response RankList
+	if err := h.transport.do(ctx, http.MethodGet, "/leaderboards/"+url.PathEscape(h.slug)+"/entries", query, nil, &response); err != nil {
+		return nil, err
+	}
+	return &response, nil
+}
+
+func (h *LeaderboardHandle) Get(ctx context.Context, playerID string) (*Rank, error) {
+	var response Rank
+	if err := h.transport.do(ctx, http.MethodGet, "/leaderboards/"+url.PathEscape(h.slug)+"/entries/"+url.PathEscape(playerID), nil, nil, &response); err != nil {
+		return nil, err
+	}
+	return &response, nil
+}
+
+func (h *LeaderboardHandle) GetAround(ctx context.Context, playerID string, limit int) ([]Rank, error) {
+	query := url.Values{}
+	if limit > 0 {
+		query.Set("limit", strconv.Itoa(limit))
+	}
+
+	var response models.GetLeaderboardEntryAroundResponse
+	if err := h.transport.do(ctx, http.MethodGet, "/leaderboards/"+url.PathEscape(h.slug)+"/entries/"+url.PathEscape(playerID)+"/around", query, nil, &response); err != nil {
+		return nil, err
+	}
+	return response.Entries, nil
+}
+
+func (h *LeaderboardHandle) Submit(ctx context.Context, items []LeaderboardScore) error {
+	return h.leaderboards.Submit(ctx, h.slug, items)
+}
+
+func (h *LeaderboardHandle) Update(ctx context.Context, items []LeaderboardScore) error {
+	return h.leaderboards.Update(ctx, h.slug, items)
+}
+
+func (h *LeaderboardHandle) Delete(ctx context.Context, playerIDs []string) error {
+	return h.leaderboards.Delete(ctx, h.slug, playerIDs)
+}

leaderboards.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"net/http"
 	"net/url"
+	"strconv"
 
 	"hub.rudder.build/rudder/rudder-go-sdk/models"
 )
@@ -12,10 +13,44 @@ type LeaderboardsService struct {
 	transport *transport
 }
 
-func (s *LeaderboardsService) Results(ctx context.Context, slug string) ([]models.RankEntry, error) {
+type ListLeaderboardsParameters struct {
-	var response models.GetLeaderboardResultsResponse
+	Limit  int
-	if err := s.transport.do(ctx, http.MethodGet, "/leaderboards/"+url.PathEscape(slug)+"/results", nil, nil, &response); err != nil {
+	Cursor *string
+}
+
+func (s *LeaderboardsService) List(ctx context.Context, parameters ListLeaderboardsParameters) (*LeaderboardList, error) {
+	query := url.Values{}
+	if parameters.Limit > 0 {
+		query.Set("limit", strconv.Itoa(parameters.Limit))
+	}
+	if parameters.Cursor != nil {
+		query.Set("cursor", *parameters.Cursor)
+	}
+
+	var response LeaderboardList
+	if err := s.transport.do(ctx, http.MethodGet, "/leaderboards", query, nil, &response); err != nil {
 		return nil, err
 	}
-	return response.Entries, nil
+	return &response, nil
+}
+
+func (s *LeaderboardsService) Submit(ctx context.Context, slug string, items []LeaderboardScore) error {
+	body := models.BatchSubmitLeaderboardEntriesRequest{
+		Items: items,
+	}
+	return s.transport.do(ctx, http.MethodPost, "/leaderboards/"+url.PathEscape(slug)+"/entries", nil, body, nil)
+}
+
+func (s *LeaderboardsService) Update(ctx context.Context, slug string, items []LeaderboardScore) error {
+	body := models.BatchUpdateLeaderboardEntriesRequest{
+		Items: items,
+	}
+	return s.transport.do(ctx, http.MethodPatch, "/leaderboards/"+url.PathEscape(slug)+"/entries", nil, body, nil)
+}
+
+func (s *LeaderboardsService) Delete(ctx context.Context, slug string, playerIDs []string) error {
+	body := models.BatchDeleteLeaderboardEntriesRequest{
+		PlayerIds: playerIDs,
+	}
+	return s.transport.do(ctx, http.MethodDelete, "/leaderboards/"+url.PathEscape(slug)+"/entries", nil, body, nil)
 }

metrics.go

@@ -1,20 +0,0 @@
-package rudder
-
-import (
-	"context"
-	"net/http"
-
-	"hub.rudder.build/rudder/rudder-go-sdk/models"
-)
-
-type MetricsService struct {
-	transport *transport
-}
-
-func (s *MetricsService) Get(ctx context.Context) (*models.GetProjectMetricsResponse, error) {
-	var response models.GetProjectMetricsResponse
-	if err := s.transport.do(ctx, http.MethodGet, "/metrics", nil, nil, &response); err != nil {
-		return nil, err
-	}
-	return &response, nil
-}

models/adjustplayerinventoryitemrequest.go

@@ -1,10 +0,0 @@
-// Code generated by apigen. DO NOT EDIT.
-
-package models
-
-type AdjustPlayerInventoryItemRequest struct {
-	Amount         int64  `json:"amount,omitempty"`
-	IdempotencyKey string `json:"idempotencyKey,omitempty"`
-	Reason         string `json:"reason,omitempty"`
-	Slug           string `json:"slug,omitempty"`
-}

models/adjustplayerwalletrequest.go

@@ -1,11 +0,0 @@
-// Code generated by apigen. DO NOT EDIT.
-
-package models
-
-type AdjustPlayerWalletRequest struct {
-	Amount         int64  `json:"amount,omitempty"`
-	CurrencyCode   string `json:"currencyCode,omitempty"`
-	IdempotencyKey string `json:"idempotencyKey,omitempty"`
-	PlayerID       string `json:"playerId,omitempty"`
-	Reason         string `json:"reason,omitempty"`
-}

models/adminlistquestsresponse.go

@@ -0,0 +1,8 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type AdminListQuestsResponse struct {
+	Items      []QuestDefinition `json:"items,omitempty"`
+	NextCursor string            `json:"nextCursor,omitempty"`
+}

models/adminplayerquest.go

@@ -0,0 +1,10 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type AdminPlayerQuest struct {
+	Name       string                      `json:"name,omitempty"`
+	Objectives []AdminPlayerQuestObjective `json:"objectives,omitempty"`
+	QuestID    string                      `json:"questId,omitempty"`
+	Status     string                      `json:"status,omitempty"`
+}

models/adminplayerquestobjective.go

@@ -0,0 +1,9 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type AdminPlayerQuestObjective struct {
+	Current     int64  `json:"current,omitempty"`
+	ObjectiveID string `json:"objectiveId,omitempty"`
+	Target      int64  `json:"target,omitempty"`
+}

models/banplayerrequest.go

@@ -1,9 +0,0 @@
-// Code generated by apigen. DO NOT EDIT.
-
-package models
-
-type BanPlayerRequest struct {
-	BannedUntil    string `json:"bannedUntil,omitempty"`
-	IdempotencyKey string `json:"idempotencyKey,omitempty"`
-	Reason         string `json:"reason,omitempty"`
-}

models/batchadjustplayerinventoryitemsitem.go

@@ -0,0 +1,10 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type BatchAdjustPlayerInventoryItemsItem struct {
+	Amount   int64  `json:"amount,omitempty"`
+	PlayerID string `json:"playerId,omitempty"`
+	Reason   string `json:"reason,omitempty"`
+	Slug     string `json:"slug,omitempty"`
+}

models/batchadjustplayerinventoryitemsrequest.go

@@ -0,0 +1,8 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type BatchAdjustPlayerInventoryItemsRequest struct {
+	IdempotencyKey string                                `json:"idempotencyKey,omitempty"`
+	Items          []BatchAdjustPlayerInventoryItemsItem `json:"items,omitempty"`
+}

models/batchadjustplayerinventoryitemsresponse.go

@@ -0,0 +1,7 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type BatchAdjustPlayerInventoryItemsResponse struct {
+	Items []InventoryItem `json:"items,omitempty"`
+}

models/batchadjustplayerwalletsitem.go

@@ -0,0 +1,10 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type BatchAdjustPlayerWalletsItem struct {
+	Amount       int64  `json:"amount,omitempty"`
+	CurrencyCode string `json:"currencyCode,omitempty"`
+	PlayerID     string `json:"playerId,omitempty"`
+	Reason       string `json:"reason,omitempty"`
+}

models/batchadjustplayerwalletsrequest.go

@@ -0,0 +1,8 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type BatchAdjustPlayerWalletsRequest struct {
+	IdempotencyKey string                         `json:"idempotencyKey,omitempty"`
+	Items          []BatchAdjustPlayerWalletsItem `json:"items,omitempty"`
+}

models/batchadjustplayerwalletsresponse.go

@@ -0,0 +1,7 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type BatchAdjustPlayerWalletsResponse struct {
+	Wallets []WalletDetails `json:"wallets,omitempty"`
+}

models/batchbanplayersitem.go

@@ -0,0 +1,9 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type BatchBanPlayersItem struct {
+	BannedUntil string `json:"bannedUntil,omitempty"`
+	PlayerID    string `json:"playerId,omitempty"`
+	Reason      string `json:"reason,omitempty"`
+}

models/batchbanplayersrequest.go

@@ -0,0 +1,8 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type BatchBanPlayersRequest struct {
+	IdempotencyKey string                `json:"idempotencyKey,omitempty"`
+	Items          []BatchBanPlayersItem `json:"items,omitempty"`
+}

models/batchdeleteleaderboardentriesrequest.go

@@ -0,0 +1,7 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type BatchDeleteLeaderboardEntriesRequest struct {
+	PlayerIds []string `json:"playerIds,omitempty"`
+}

models/batchdeleteplayersrequest.go

@@ -0,0 +1,8 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type BatchDeletePlayersRequest struct {
+	IdempotencyKey string            `json:"idempotencyKey,omitempty"`
+	Items          []BatchPlayerItem `json:"items,omitempty"`
+}

models/batchdeleteplayerstoragesitem.go

@@ -0,0 +1,8 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type BatchDeletePlayerStoragesItem struct {
+	PlayerID string `json:"playerId,omitempty"`
+	Type     string `json:"type,omitempty"`
+}

models/batchdeleteplayerstoragesrequest.go

@@ -0,0 +1,8 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type BatchDeletePlayerStoragesRequest struct {
+	IdempotencyKey string                          `json:"idempotencyKey,omitempty"`
+	Items          []BatchDeletePlayerStoragesItem `json:"items,omitempty"`
+}

models/batchdeleteprojectstoragerequest.go

@@ -0,0 +1,8 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type BatchDeleteProjectStorageRequest struct {
+	IdempotencyKey string   `json:"idempotencyKey,omitempty"`
+	Types          []string `json:"types,omitempty"`
+}

models/batchleaderboardentry.go

@@ -0,0 +1,8 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type BatchLeaderboardEntry struct {
+	PlayerID string  `json:"playerId,omitempty"`
+	Score    float64 `json:"score,omitempty"`
+}

models/batchplayeritem.go

@@ -0,0 +1,7 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type BatchPlayerItem struct {
+	PlayerID string `json:"playerId,omitempty"`
+}

models/batchplayerquestsitem.go

@@ -0,0 +1,8 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type BatchPlayerQuestsItem struct {
+	PlayerID string `json:"playerId,omitempty"`
+	QuestID  string `json:"questId,omitempty"`
+}

models/batchplayerquestsrequest.go

@@ -0,0 +1,8 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type BatchPlayerQuestsRequest struct {
+	IdempotencyKey string                  `json:"idempotencyKey,omitempty"`
+	Items          []BatchPlayerQuestsItem `json:"items,omitempty"`
+}

models/batchplayersresponse.go

@@ -0,0 +1,7 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type BatchPlayersResponse struct {
+	Players []AdminPlayer `json:"players,omitempty"`
+}

models/batchsubmitleaderboardentriesrequest.go

@@ -0,0 +1,7 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type BatchSubmitLeaderboardEntriesRequest struct {
+	Items []BatchLeaderboardEntry `json:"items,omitempty"`
+}

models/batchunbanplayersrequest.go

@@ -0,0 +1,8 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type BatchUnbanPlayersRequest struct {
+	IdempotencyKey string            `json:"idempotencyKey,omitempty"`
+	Items          []BatchPlayerItem `json:"items,omitempty"`
+}

models/batchupdateleaderboardentriesrequest.go

@@ -0,0 +1,7 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type BatchUpdateLeaderboardEntriesRequest struct {
+	Items []BatchLeaderboardEntry `json:"items,omitempty"`
+}

models/batchupdateplayersitem.go

@@ -4,7 +4,8 @@ package models
 
 import "encoding/json"
 
-type UpdatePlayerRequest struct {
+type BatchUpdatePlayersItem struct {
 	Data     json.RawMessage `json:"data,omitempty"`
 	Nickname string          `json:"nickname,omitempty"`
+	PlayerID string          `json:"playerId,omitempty"`
 }

models/batchupdateplayersrequest.go

@@ -0,0 +1,8 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type BatchUpdatePlayersRequest struct {
+	IdempotencyKey string                   `json:"idempotencyKey,omitempty"`
+	Items          []BatchUpdatePlayersItem `json:"items,omitempty"`
+}

models/batchupsertplayerstoragesitem.go

@@ -2,7 +2,9 @@
 
 package models
 
-type UpsertPlayerStorageRequest struct {
+type BatchUpsertPlayerStoragesItem struct {
 	Data      string `json:"data,omitempty"`
 	ExpiresAt string `json:"expiresAt,omitempty"`
+	PlayerID  string `json:"playerId,omitempty"`
+	Type      string `json:"type,omitempty"`
 }

models/batchupsertplayerstoragesrequest.go

@@ -0,0 +1,8 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type BatchUpsertPlayerStoragesRequest struct {
+	IdempotencyKey string                          `json:"idempotencyKey,omitempty"`
+	Items          []BatchUpsertPlayerStoragesItem `json:"items,omitempty"`
+}

models/batchupsertplayerstoragesresponse.go

@@ -0,0 +1,7 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type BatchUpsertPlayerStoragesResponse struct {
+	Storages []PlayerStorage `json:"storages,omitempty"`
+}

models/batchupsertprojectstoragerequest.go

@@ -0,0 +1,8 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type BatchUpsertProjectStorageRequest struct {
+	IdempotencyKey string                    `json:"idempotencyKey,omitempty"`
+	Items          []AdminProjectStorageItem `json:"items,omitempty"`
+}

models/deleteplayerrequest.go

@@ -1,7 +0,0 @@
-// Code generated by apigen. DO NOT EDIT.
-
-package models
-
-type DeletePlayerRequest struct {
-	IdempotencyKey string `json:"idempotencyKey,omitempty"`
-}

models/errorresponse.go

@@ -0,0 +1,11 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type ErrorResponse struct {
+	Code      string `json:"code,omitempty"`
+	Error     string `json:"error,omitempty"`
+	Index     int    `json:"index,omitempty"`
+	PlayerID  string `json:"playerId,omitempty"`
+	RequestID string `json:"requestId,omitempty"`
+}

models/getleaderboardentryaroundresponse.go

@@ -2,6 +2,6 @@
 
 package models
 
-type GetLeaderboardResultsResponse struct {
+type GetLeaderboardEntryAroundResponse struct {
 	Entries []RankEntry `json:"entries,omitempty"`
 }

models/getplayerinventoryresponse.go

@@ -0,0 +1,8 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type GetPlayerInventoryResponse struct {
+	Items      []InventoryItem `json:"items,omitempty"`
+	NextCursor string          `json:"nextCursor,omitempty"`
+}

models/getwallethistoryresponse.go

@@ -0,0 +1,8 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type GetWalletHistoryResponse struct {
+	Entries    []WalletAudit `json:"entries,omitempty"`
+	NextCursor string        `json:"nextCursor,omitempty"`
+}

models/leaderboarddefinition.go

@@ -0,0 +1,12 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type LeaderboardDefinition struct {
+	MaxEntries   int64  `json:"maxEntries,omitempty"`
+	Metric       string `json:"metric,omitempty"`
+	Name         string `json:"name,omitempty"`
+	ResetPeriod  string `json:"resetPeriod,omitempty"`
+	Slug         string `json:"slug,omitempty"`
+	SortingOrder string `json:"sortingOrder,omitempty"`
+}

models/listleaderboardentriesresponse.go

@@ -0,0 +1,8 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type ListLeaderboardEntriesResponse struct {
+	Entries    []RankEntry `json:"entries,omitempty"`
+	NextCursor string      `json:"nextCursor,omitempty"`
+}

models/listleaderboardsresponse.go

@@ -0,0 +1,8 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type ListLeaderboardsResponse struct {
+	Items      []LeaderboardDefinition `json:"items,omitempty"`
+	NextCursor string                  `json:"nextCursor,omitempty"`
+}

models/listplayerquestsresponse.go

@@ -0,0 +1,7 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type ListPlayerQuestsResponse struct {
+	Quests []AdminPlayerQuest `json:"quests,omitempty"`
+}

models/questdefinition.go

@@ -0,0 +1,12 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type QuestDefinition struct {
+	ID          string                  `json:"id,omitempty"`
+	Name        string                  `json:"name,omitempty"`
+	NextQuestID string                  `json:"nextQuestId,omitempty"`
+	Objectives  []QuestObjective        `json:"objectives,omitempty"`
+	Rewards     []QuestRewardDefinition `json:"rewards,omitempty"`
+	Status      string                  `json:"status,omitempty"`
+}

models/questobjective.go

@@ -0,0 +1,9 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type QuestObjective struct {
+	ID     string `json:"id,omitempty"`
+	Metric string `json:"metric,omitempty"`
+	Target int64  `json:"target,omitempty"`
+}

models/questrewarddefinition.go

@@ -0,0 +1,9 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type QuestRewardDefinition struct {
+	Amount   int64  `json:"amount,omitempty"`
+	Currency string `json:"currency,omitempty"`
+	ItemID   string `json:"itemId,omitempty"`
+}

models/upsertprojectstoragerequest.go

@@ -1,7 +0,0 @@
-// Code generated by apigen. DO NOT EDIT.
-
-package models
-
-type UpsertProjectStorageRequest struct {
-	Items []AdminProjectStorageItem `json:"items,omitempty"`
-}

models/verifyplayerauthrequest.go

@@ -0,0 +1,7 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type VerifyPlayerAuthRequest struct {
+	AccessToken string `json:"accessToken,omitempty"`
+}

models/verifyplayerauthresponse.go

@@ -0,0 +1,9 @@
+// Code generated by apigen. DO NOT EDIT.
+
+package models
+
+type VerifyPlayerAuthResponse struct {
+	PlayerID  string `json:"playerId,omitempty"`
+	ProjectID string `json:"projectId,omitempty"`
+	Status    string `json:"status,omitempty"`
+}

player.go

@@ -0,0 +1,91 @@
+package rudder
+
+import (
+	"context"
+	"encoding/json"
+)
+
+type PlayerHandle struct {
+	playerID  string
+	transport *transport
+	players   *PlayersService
+	wallet    *WalletService
+	inventory *InventoryService
+	quests    *QuestsService
+}
+
+func (h *PlayerHandle) Wallet() *PlayerWalletHandle {
+	return &PlayerWalletHandle{playerID: h.playerID, wallet: h.wallet}
+}
+
+func (h *PlayerHandle) Inventory() *PlayerInventoryHandle {
+	return &PlayerInventoryHandle{playerID: h.playerID, inventory: h.inventory}
+}
+
+func (h *PlayerHandle) Storage() *PlayerStorageHandle {
+	return &PlayerStorageHandle{playerID: h.playerID, transport: h.transport}
+}
+
+func (h *PlayerHandle) Quests() *PlayerQuestsHandle {
+	return &PlayerQuestsHandle{playerID: h.playerID, transport: h.transport, quests: h.quests}
+}
+
+type UpdatePlayerParameters struct {
+	IdempotencyKey string
+	Nickname       string
+	Data           json.RawMessage
+}
+
+func (h *PlayerHandle) Update(ctx context.Context, parameters UpdatePlayerParameters) (*Player, error) {
+	players, err := h.players.Update(ctx, UpdatePlayersParameters{
+		IdempotencyKey: parameters.IdempotencyKey,
+		Items: []PlayerUpdate{{
+			PlayerID: h.playerID,
+			Nickname: parameters.Nickname,
+			Data:     parameters.Data,
+		}},
+	})
+	if err != nil {
+		return nil, err
+	}
+	return &players[0], nil
+}
+
+type BanPlayerParameters struct {
+	IdempotencyKey string
+	Reason         string
+	BannedUntil    string
+}
+
+func (h *PlayerHandle) Ban(ctx context.Context, parameters BanPlayerParameters) (*Player, error) {
+	players, err := h.players.Ban(ctx, BanPlayersParameters{
+		IdempotencyKey: parameters.IdempotencyKey,
+		Items: []PlayerBan{{
+			PlayerID:    h.playerID,
+			Reason:      parameters.Reason,
+			BannedUntil: parameters.BannedUntil,
+		}},
+	})
+	if err != nil {
+		return nil, err
+	}
+	return &players[0], nil
+}
+
+func (h *PlayerHandle) Unban(ctx context.Context, idempotencyKey string) (*Player, error) {
+	players, err := h.players.Unban(ctx, UnbanPlayersParameters{
+		IdempotencyKey: idempotencyKey,
+		PlayerIDs:      []string{h.playerID},
+	})
+	if err != nil {
+		return nil, err
+	}
+	return &players[0], nil
+}
+
+func (h *PlayerHandle) Delete(ctx context.Context, idempotencyKey string) error {
+	return h.players.Delete(ctx, DeletePlayersParameters{
+		IdempotencyKey: idempotencyKey,
+		PlayerIDs:      []string{h.playerID},
+	})
+}

player_inventory.go

@@ -0,0 +1,35 @@
+package rudder
+
+import "context"
+
+type PlayerInventoryHandle struct {
+	playerID  string
+	inventory *InventoryService
+}
+
+type AdjustPlayerInventoryParameters struct {
+	IdempotencyKey string
+	Slug           string
+	Amount         int64
+	Reason         string
+}
+
+func (h *PlayerInventoryHandle) Adjust(ctx context.Context, parameters AdjustPlayerInventoryParameters) (*InventoryItem, error) {
+	items, err := h.inventory.Adjust(ctx, AdjustInventoryParameters{
+		IdempotencyKey: parameters.IdempotencyKey,
+		Items: []InventoryAdjustment{{
+			PlayerID: h.playerID,
+			Slug:     parameters.Slug,
+			Amount:   parameters.Amount,
+			Reason:   parameters.Reason,
+		}},
+	})
+	if err != nil {
+		return nil, err
+	}
+	return &items[0], nil
+}
+
+func (h *PlayerInventoryHandle) List(ctx context.Context, parameters ListInventoryParameters) (*InventoryList, error) {
+	return h.inventory.List(ctx, h.playerID, parameters)
+}

player_quests.go

@@ -0,0 +1,49 @@
+package rudder
+
+import (
+	"context"
+	"net/http"
+	"net/url"
+
+	"hub.rudder.build/rudder/rudder-go-sdk/models"
+)
+
+type PlayerQuestsHandle struct {
+	playerID  string
+	transport *transport
+	quests    *QuestsService
+}
+
+func (h *PlayerQuestsHandle) List(ctx context.Context) ([]PlayerQuest, error) {
+	var response models.ListPlayerQuestsResponse
+	if err := h.transport.do(ctx, http.MethodGet, "/players/"+url.PathEscape(h.playerID)+"/quests", nil, nil, &response); err != nil {
+		return nil, err
+	}
+	return response.Quests, nil
+}
+
+type PlayerQuestParameters struct {
+	IdempotencyKey string
+	QuestID        string
+}
+
+func (h *PlayerQuestsHandle) Reset(ctx context.Context, parameters PlayerQuestParameters) error {
+	return h.quests.Reset(ctx, PlayerQuestsParameters{
+		IdempotencyKey: parameters.IdempotencyKey,
+		Items:          []PlayerQuestRef{{PlayerID: h.playerID, QuestID: parameters.QuestID}},
+	})
+}
+
+func (h *PlayerQuestsHandle) ForceComplete(ctx context.Context, parameters PlayerQuestParameters) error {
+	return h.quests.ForceComplete(ctx, PlayerQuestsParameters{
+		IdempotencyKey: parameters.IdempotencyKey,
+		Items:          []PlayerQuestRef{{PlayerID: h.playerID, QuestID: parameters.QuestID}},
+	})
+}
+
+func (h *PlayerQuestsHandle) ForceClaim(ctx context.Context, parameters PlayerQuestParameters) error {
+	return h.quests.ForceClaim(ctx, PlayerQuestsParameters{
+		IdempotencyKey: parameters.IdempotencyKey,
+		Items:          []PlayerQuestRef{{PlayerID: h.playerID, QuestID: parameters.QuestID}},
+	})
+}

player_storage.go

@@ -0,0 +1,63 @@
+package rudder
+
+import (
+	"context"
+	"net/http"
+	"net/url"
+
+	"hub.rudder.build/rudder/rudder-go-sdk/models"
+)
+
+type PlayerStorageHandle struct {
+	playerID  string
+	transport *transport
+}
+
+func (h *PlayerStorageHandle) Get(ctx context.Context, storageType string) (*PlayerStorage, error) {
+	var response PlayerStorage
+	if err := h.transport.do(ctx, http.MethodGet, "/players/"+url.PathEscape(h.playerID)+"/storage/"+url.PathEscape(storageType), nil, nil, &response); err != nil {
+		return nil, err
+	}
+	return &response, nil
+}
+
+type UpsertPlayerStorageParameters struct {
+	IdempotencyKey string
+	Type           string
+	Data           string
+	ExpiresAt      string
+}
+
+func (h *PlayerStorageHandle) Upsert(ctx context.Context, parameters UpsertPlayerStorageParameters) (*PlayerStorage, error) {
+	body := models.BatchUpsertPlayerStoragesRequest{
+		IdempotencyKey: parameters.IdempotencyKey,
+		Items: []models.BatchUpsertPlayerStoragesItem{{
+			PlayerID:  h.playerID,
+			Type:      parameters.Type,
+			Data:      parameters.Data,
+			ExpiresAt: parameters.ExpiresAt,
+		}},
+	}
+
+	var response models.BatchUpsertPlayerStoragesResponse
+	if err := h.transport.do(ctx, http.MethodPut, "/players/storage", nil, body, &response); err != nil {
+		return nil, err
+	}
+	return &response.Storages[0], nil
+}
+
+type DeletePlayerStorageParameters struct {
+	IdempotencyKey string
+	Type           string
+}
+
+func (h *PlayerStorageHandle) Delete(ctx context.Context, parameters DeletePlayerStorageParameters) error {
+	body := models.BatchDeletePlayerStoragesRequest{
+		IdempotencyKey: parameters.IdempotencyKey,
+		Items: []models.BatchDeletePlayerStoragesItem{{
+			PlayerID: h.playerID,
+			Type:     parameters.Type,
+		}},
+	}
+	return h.transport.do(ctx, http.MethodDelete, "/players/storage", nil, body, nil)
+}

player_wallet.go

@@ -0,0 +1,35 @@
+package rudder
+
+import "context"
+
+type PlayerWalletHandle struct {
+	playerID string
+	wallet   *WalletService
+}
+
+type AdjustPlayerWalletParameters struct {
+	IdempotencyKey string
+	CurrencyCode   string
+	Amount         int64
+	Reason         string
+}
+
+func (h *PlayerWalletHandle) Adjust(ctx context.Context, parameters AdjustPlayerWalletParameters) (*WalletBalance, error) {
+	wallets, err := h.wallet.Adjust(ctx, AdjustWalletParameters{
+		IdempotencyKey: parameters.IdempotencyKey,
+		Items: []WalletAdjustment{{
+			PlayerID:     h.playerID,
+			CurrencyCode: parameters.CurrencyCode,
+			Amount:       parameters.Amount,
+			Reason:       parameters.Reason,
+		}},
+	})
+	if err != nil {
+		return nil, err
+	}
+	return &wallets[0], nil
+}
+
+func (h *PlayerWalletHandle) History(ctx context.Context, parameters WalletHistoryParameters) (*WalletHistory, error) {
+	return h.wallet.History(ctx, h.playerID, parameters)
+}

players.go

@@ -2,11 +2,9 @@ package rudder
 
 import (
 	"context"
-	"encoding/json"
 	"net/http"
 	"net/url"
 	"strconv"
-	"time"
 
 	"hub.rudder.build/rudder/rudder-go-sdk/models"
 )
@@ -21,7 +19,7 @@ type ListPlayersParameters struct {
 	Search string
 }
 
-func (s *PlayersService) List(ctx context.Context, parameters ListPlayersParameters) (*models.ListPlayersResponse, error) {
+func (s *PlayersService) List(ctx context.Context, parameters ListPlayersParameters) (*PlayerList, error) {
 	query := url.Values{}
 	if parameters.Limit > 0 {
 		query.Set("limit", strconv.Itoa(parameters.Limit))
@@ -33,74 +31,102 @@ func (s *PlayersService) List(ctx context.Context, parameters ListPlayersParamet
 		query.Set("search", parameters.Search)
 	}
 
-	var response models.ListPlayersResponse
+	var response PlayerList
 	if err := s.transport.do(ctx, http.MethodGet, "/players/list", query, nil, &response); err != nil {
 		return nil, err
 	}
 	return &response, nil
 }
 
-func (s *PlayersService) Get(ctx context.Context, playerID string) (*models.AdminPlayerDetails, error) {
+func (s *PlayersService) Get(ctx context.Context, playerID string) (*PlayerDetails, error) {
-	var response models.AdminPlayerDetails
+	var response PlayerDetails
 	if err := s.transport.do(ctx, http.MethodGet, "/players/"+url.PathEscape(playerID), nil, nil, &response); err != nil {
 		return nil, err
 	}
 	return &response, nil
 }
 
-type UpdatePlayerParameters struct {
+func (s *PlayersService) VerifyAuth(ctx context.Context, accessToken string) (*PlayerAuthVerification, error) {
-	Nickname *string
+	body := models.VerifyPlayerAuthRequest{AccessToken: accessToken}
-	Data     json.RawMessage
-}
 
-func (s *PlayersService) Update(ctx context.Context, playerID string, parameters UpdatePlayerParameters) (*models.AdminPlayer, error) {
+	var response PlayerAuthVerification
-	body := models.UpdatePlayerRequest{
+	if err := s.transport.do(ctx, http.MethodPost, "/players/auth/verify", nil, body, &response); err != nil {
-		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 {
+type UpdatePlayersParameters struct {
-	Reason         string
-	Until          *time.Time
 	IdempotencyKey string
+	Items          []PlayerUpdate
 }
 
-func (s *PlayersService) Ban(ctx context.Context, playerID string, parameters BanPlayerParameters) (*models.AdminPlayer, error) {
+func (s *PlayersService) Update(ctx context.Context, parameters UpdatePlayersParameters) ([]Player, error) {
-	body := models.BanPlayerRequest{
+	body := models.BatchUpdatePlayersRequest{
-		Reason:         parameters.Reason,
 		IdempotencyKey: parameters.IdempotencyKey,
-	}
+		Items:          parameters.Items,
-	if parameters.Until != nil {
-		body.BannedUntil = parameters.Until.Format(time.RFC3339)
 	}
 
-	var response models.AdminPlayer
+	var response models.BatchPlayersResponse
-	if err := s.transport.do(ctx, http.MethodPost, "/players/"+url.PathEscape(playerID)+"/ban", nil, body, &response); err != nil {
+	if err := s.transport.do(ctx, http.MethodPatch, "/players", nil, body, &response); err != nil {
 		return nil, err
 	}
-	return &response, nil
+	return response.Players, nil
 }
 
-func (s *PlayersService) Unban(ctx context.Context, playerID string) (*models.AdminPlayer, error) {
+type BanPlayersParameters struct {
-	var response models.AdminPlayer
+	IdempotencyKey string
-	if err := s.transport.do(ctx, http.MethodPost, "/players/"+url.PathEscape(playerID)+"/unban", nil, nil, &response); err != nil {
+	Items          []PlayerBan
+}
+
+func (s *PlayersService) Ban(ctx context.Context, parameters BanPlayersParameters) ([]Player, error) {
+	body := models.BatchBanPlayersRequest{
+		IdempotencyKey: parameters.IdempotencyKey,
+		Items:          parameters.Items,
+	}
+
+	var response models.BatchPlayersResponse
+	if err := s.transport.do(ctx, http.MethodPost, "/players/ban", nil, body, &response); err != nil {
 		return nil, err
 	}
-	return &response, nil
+	return response.Players, nil
 }
 
-func (s *PlayersService) Delete(ctx context.Context, playerID string, idempotencyKey string) error {
+type UnbanPlayersParameters struct {
-	body := models.DeletePlayerRequest{
+	IdempotencyKey string
-		IdempotencyKey: idempotencyKey,
+	PlayerIDs      []string
-	}
+}
-	return s.transport.do(ctx, http.MethodDelete, "/players/"+url.PathEscape(playerID), nil, body, nil)
+
+func (s *PlayersService) Unban(ctx context.Context, parameters UnbanPlayersParameters) ([]Player, error) {
+	body := models.BatchUnbanPlayersRequest{
+		IdempotencyKey: parameters.IdempotencyKey,
+		Items:          batchPlayerItems(parameters.PlayerIDs),
+	}
+
+	var response models.BatchPlayersResponse
+	if err := s.transport.do(ctx, http.MethodPost, "/players/unban", nil, body, &response); err != nil {
+		return nil, err
+	}
+	return response.Players, nil
+}
+
+type DeletePlayersParameters struct {
+	IdempotencyKey string
+	PlayerIDs      []string
+}
+
+func (s *PlayersService) Delete(ctx context.Context, parameters DeletePlayersParameters) error {
+	body := models.BatchDeletePlayersRequest{
+		IdempotencyKey: parameters.IdempotencyKey,
+		Items:          batchPlayerItems(parameters.PlayerIDs),
+	}
+	return s.transport.do(ctx, http.MethodDelete, "/players", nil, body, nil)
+}
+
+func batchPlayerItems(playerIDs []string) []models.BatchPlayerItem {
+	items := make([]models.BatchPlayerItem, len(playerIDs))
+	for i, id := range playerIDs {
+		items[i] = models.BatchPlayerItem{PlayerID: id}
+	}
+	return items
 }

projectstorage.go

@@ -1,58 +0,0 @@
-package rudder
-
-import (
-	"context"
-	"net/http"
-	"net/url"
-	"strconv"
-
-	"hub.rudder.build/rudder/rudder-go-sdk/models"
-)
-
-type ProjectStorageService struct {
-	transport *transport
-}
-
-type ListProjectStorageParameters struct {
-	Limit  int
-	Cursor string
-}
-
-func (s *ProjectStorageService) List(ctx context.Context, parameters ListProjectStorageParameters) (*models.GetProjectStorageResponse, error) {
-	query := url.Values{}
-	if parameters.Limit > 0 {
-		query.Set("limit", strconv.Itoa(parameters.Limit))
-	}
-	if parameters.Cursor != "" {
-		query.Set("cursor", parameters.Cursor)
-	}
-
-	var response models.GetProjectStorageResponse
-	if err := s.transport.do(ctx, http.MethodGet, "/project-storage", query, nil, &response); err != nil {
-		return nil, err
-	}
-	return &response, nil
-}
-
-func (s *ProjectStorageService) Get(ctx context.Context, itemType string) (*models.ProjectStorageItem, error) {
-	var response models.AdminGetProjectStorageResponse
-	if err := s.transport.do(ctx, http.MethodGet, "/project-storage/"+url.PathEscape(itemType), nil, nil, &response); err != nil {
-		return nil, err
-	}
-	return &response.Item, nil
-}
-
-type UpsertProjectStorageParameters struct {
-	Items []models.AdminProjectStorageItem
-}
-
-func (s *ProjectStorageService) Upsert(ctx context.Context, parameters UpsertProjectStorageParameters) error {
-	body := models.UpsertProjectStorageRequest{
-		Items: parameters.Items,
-	}
-	return s.transport.do(ctx, http.MethodPut, "/project-storage", nil, body, nil)
-}
-
-func (s *ProjectStorageService) Delete(ctx context.Context, itemType string) error {
-	return s.transport.do(ctx, http.MethodDelete, "/project-storage/"+url.PathEscape(itemType), nil, nil, nil)
-}

quests.go

@@ -0,0 +1,64 @@
+package rudder
+
+import (
+	"context"
+	"net/http"
+	"net/url"
+	"strconv"
+
+	"hub.rudder.build/rudder/rudder-go-sdk/models"
+)
+
+type QuestsService struct {
+	transport *transport
+}
+
+type ListQuestsParameters struct {
+	Status *string
+	Limit  int
+	Cursor *string
+}
+
+func (s *QuestsService) List(ctx context.Context, parameters ListQuestsParameters) (*QuestList, error) {
+	query := url.Values{}
+	if parameters.Status != nil {
+		query.Set("status", *parameters.Status)
+	}
+	if parameters.Limit > 0 {
+		query.Set("limit", strconv.Itoa(parameters.Limit))
+	}
+	if parameters.Cursor != nil {
+		query.Set("cursor", *parameters.Cursor)
+	}
+
+	var response QuestList
+	if err := s.transport.do(ctx, http.MethodGet, "/quests", query, nil, &response); err != nil {
+		return nil, err
+	}
+	return &response, nil
+}
+
+type PlayerQuestsParameters struct {
+	IdempotencyKey string
+	Items          []PlayerQuestRef
+}
+
+func (s *QuestsService) Reset(ctx context.Context, parameters PlayerQuestsParameters) error {
+	return s.postPlayerQuests(ctx, "/players/quests/reset", parameters)
+}
+
+func (s *QuestsService) ForceComplete(ctx context.Context, parameters PlayerQuestsParameters) error {
+	return s.postPlayerQuests(ctx, "/players/quests/force-complete", parameters)
+}
+
+func (s *QuestsService) ForceClaim(ctx context.Context, parameters PlayerQuestsParameters) error {
+	return s.postPlayerQuests(ctx, "/players/quests/force-claim", parameters)
+}
+
+func (s *QuestsService) postPlayerQuests(ctx context.Context, path string, parameters PlayerQuestsParameters) error {
+	body := models.BatchPlayerQuestsRequest{
+		IdempotencyKey: parameters.IdempotencyKey,
+		Items:          parameters.Items,
+	}
+	return s.transport.do(ctx, http.MethodPost, path, nil, body, nil)
+}

storage.go

@@ -4,7 +4,7 @@ import (
 	"context"
 	"net/http"
 	"net/url"
-	"time"
+	"strconv"
 
 	"hub.rudder.build/rudder/rudder-go-sdk/models"
 )
@@ -13,34 +13,61 @@ type StorageService struct {
 	transport *transport
 }
 
-func (s *StorageService) Get(ctx context.Context, playerID string, storageType string) (*models.PlayerStorage, error) {
+type ListStorageParameters struct {
-	var response models.PlayerStorage
+	Limit  int
-	if err := s.transport.do(ctx, http.MethodGet, "/players/"+url.PathEscape(playerID)+"/storage/"+url.PathEscape(storageType), nil, nil, &response); err != nil {
+	Cursor string
+	Search string
+}
+
+func (s *StorageService) List(ctx context.Context, parameters ListStorageParameters) (*ProjectStorageList, error) {
+	query := url.Values{}
+	if parameters.Limit > 0 {
+		query.Set("limit", strconv.Itoa(parameters.Limit))
+	}
+	if parameters.Cursor != "" {
+		query.Set("cursor", parameters.Cursor)
+	}
+	if parameters.Search != "" {
+		query.Set("search", parameters.Search)
+	}
+
+	var response ProjectStorageList
+	if err := s.transport.do(ctx, http.MethodGet, "/project-storage", query, nil, &response); err != nil {
 		return nil, err
 	}
 	return &response, nil
 }
 
+func (s *StorageService) Get(ctx context.Context, itemType string) (*ProjectStorage, error) {
+	var response models.AdminGetProjectStorageResponse
+	if err := s.transport.do(ctx, http.MethodGet, "/project-storage/"+url.PathEscape(itemType), nil, nil, &response); err != nil {
+		return nil, err
+	}
+	return &response.Item, nil
+}
+
 type UpsertStorageParameters struct {
-	Data      string
+	IdempotencyKey string
-	ExpiresAt *time.Time
+	Items          []ProjectStorageInput
 }
 
-func (s *StorageService) Upsert(ctx context.Context, playerID string, storageType string, parameters UpsertStorageParameters) (*models.PlayerStorage, error) {
+func (s *StorageService) Upsert(ctx context.Context, parameters UpsertStorageParameters) error {
-	body := models.UpsertPlayerStorageRequest{
+	body := models.BatchUpsertProjectStorageRequest{
-		Data: parameters.Data,
+		IdempotencyKey: parameters.IdempotencyKey,
+		Items:          parameters.Items,
 	}
-	if parameters.ExpiresAt != nil {
+	return s.transport.do(ctx, http.MethodPut, "/project-storage", nil, body, nil)
-		body.ExpiresAt = parameters.ExpiresAt.Format(time.RFC3339)
-	}
-
-	var response models.PlayerStorage
-	if err := s.transport.do(ctx, http.MethodPut, "/players/"+url.PathEscape(playerID)+"/storage/"+url.PathEscape(storageType), nil, body, &response); err != nil {
-		return nil, err
-	}
-	return &response, nil
 }
 
-func (s *StorageService) Delete(ctx context.Context, playerID string, storageType string) error {
+type DeleteStorageParameters struct {
-	return s.transport.do(ctx, http.MethodDelete, "/players/"+url.PathEscape(playerID)+"/storage/"+url.PathEscape(storageType), nil, nil, nil)
+	IdempotencyKey string
+	Types          []string
+}
+
+func (s *StorageService) Delete(ctx context.Context, parameters DeleteStorageParameters) error {
+	body := models.BatchDeleteProjectStorageRequest{
+		IdempotencyKey: parameters.IdempotencyKey,
+		Types:          parameters.Types,
+	}
+	return s.transport.do(ctx, http.MethodDelete, "/project-storage", nil, body, nil)
 }

types.go

@@ -0,0 +1,41 @@
+package rudder
+
+import "hub.rudder.build/rudder/rudder-go-sdk/models"
+
+// Domain types are aliases of generated OpenAPI models so callers import
+// only this package. models/ is wire format and is not part of the public API.
+
+type Player = models.AdminPlayer
+type PlayerDetails = models.AdminPlayerDetails
+type PlayerList = models.ListPlayersResponse
+type PlayerUpdate = models.BatchUpdatePlayersItem
+type PlayerBan = models.BatchBanPlayersItem
+type PlayerAuthVerification = models.VerifyPlayerAuthResponse
+
+type WalletBalance = models.WalletDetails
+type WalletTransaction = models.WalletAudit
+type WalletHistory = models.GetWalletHistoryResponse
+type WalletAdjustment = models.BatchAdjustPlayerWalletsItem
+
+type InventoryItem = models.InventoryItem
+type InventoryList = models.GetPlayerInventoryResponse
+type InventoryAdjustment = models.BatchAdjustPlayerInventoryItemsItem
+
+type PlayerStorage = models.PlayerStorage
+type ProjectStorage = models.ProjectStorageItem
+type ProjectStorageList = models.GetProjectStorageResponse
+type ProjectStorageInput = models.AdminProjectStorageItem
+
+type PlayerQuest = models.AdminPlayerQuest
+type PlayerQuestObjective = models.AdminPlayerQuestObjective
+type PlayerQuestRef = models.BatchPlayerQuestsItem
+type Quest = models.QuestDefinition
+type QuestObjective = models.QuestObjective
+type QuestReward = models.QuestRewardDefinition
+type QuestList = models.AdminListQuestsResponse
+
+type Leaderboard = models.LeaderboardDefinition
+type LeaderboardList = models.ListLeaderboardsResponse
+type LeaderboardScore = models.BatchLeaderboardEntry
+type Rank = models.RankEntry
+type RankList = models.ListLeaderboardEntriesResponse

wallet.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"net/http"
 	"net/url"
+	"strconv"
 
 	"hub.rudder.build/rudder/rudder-go-sdk/models"
 )
@@ -13,23 +14,43 @@ type WalletService struct {
 }
 
 type AdjustWalletParameters struct {
-	CurrencyCode   string
-	Amount         int64
-	Reason         string
 	IdempotencyKey string
+	Items          []WalletAdjustment
 }
 
-func (s *WalletService) Adjust(ctx context.Context, playerID string, parameters AdjustWalletParameters) (*models.WalletDetails, error) {
+func (s *WalletService) Adjust(ctx context.Context, parameters AdjustWalletParameters) ([]WalletBalance, error) {
-	body := models.AdjustPlayerWalletRequest{
+	body := models.BatchAdjustPlayerWalletsRequest{
-		PlayerID:       playerID,
-		CurrencyCode:   parameters.CurrencyCode,
-		Amount:         parameters.Amount,
-		Reason:         parameters.Reason,
 		IdempotencyKey: parameters.IdempotencyKey,
+		Items:          parameters.Items,
 	}
 
-	var response models.WalletDetails
+	var response models.BatchAdjustPlayerWalletsResponse
-	if err := s.transport.do(ctx, http.MethodPost, "/players/"+url.PathEscape(playerID)+"/wallet/adjust", nil, body, &response); err != nil {
+	if err := s.transport.do(ctx, http.MethodPost, "/players/wallet/adjust", nil, body, &response); err != nil {
+		return nil, err
+	}
+	return response.Wallets, nil
+}
+
+type WalletHistoryParameters struct {
+	Currency *string
+	Limit    int
+	Cursor   *string
+}
+
+func (s *WalletService) History(ctx context.Context, playerID string, parameters WalletHistoryParameters) (*WalletHistory, error) {
+	query := url.Values{}
+	if parameters.Currency != nil {
+		query.Set("currency", *parameters.Currency)
+	}
+	if parameters.Limit > 0 {
+		query.Set("limit", strconv.Itoa(parameters.Limit))
+	}
+	if parameters.Cursor != nil {
+		query.Set("cursor", *parameters.Cursor)
+	}
+
+	var response WalletHistory
+	if err := s.transport.do(ctx, http.MethodGet, "/players/"+url.PathEscape(playerID)+"/wallet/history", query, nil, &response); err != nil {
 		return nil, err
 	}
 	return &response, nil

webhook.go

@@ -0,0 +1,18 @@
+package rudder
+
+import (
+	"crypto/hmac"
+	"crypto/sha256"
+	"encoding/hex"
+)
+
+func VerifyWebhookSignature(secret string, body []byte, signature string) bool {
+	mac := hmac.New(sha256.New, []byte(secret))
+	mac.Write(body)
+
+	expected, err := hex.DecodeString(signature)
+	if err != nil {
+		return false
+	}
+	return hmac.Equal(mac.Sum(nil), expected)
+}