1 Commits

Author SHA1 Message Date
edmand46 989bd7646c v0.7.0: public domain types in rudder, hide OpenAPI names from callers
CI / build (push) Successful in 51s
2026-08-27 16:10:27 +03:00
14 changed files with 150 additions and 122 deletions
+23 -19
View File
@@ -41,6 +41,9 @@ if err != nil {
players, err := client.Players.List(ctx, rudder.ListPlayersParameters{Limit: 100}) players, err := client.Players.List(ctx, rudder.ListPlayersParameters{Limit: 100})
``` ```
Публичные типы живут в пакете `rudder`. Пакет `models` — сгенерированный
wire-формат, в прикладном коде его импортировать не нужно.
## Handles ## Handles
`client.Player(id)` и `client.Leaderboard(slug)` создают handle без `client.Player(id)` и `client.Leaderboard(slug)` создают handle без
@@ -87,13 +90,13 @@ err = player.Delete(ctx, "")
board := client.Leaderboard("weekly") board := client.Leaderboard("weekly")
entries, err := board.List(ctx, rudder.ListLeaderboardEntriesParameters{Limit: 100}) entries, err := board.List(ctx, rudder.ListLeaderboardEntriesParameters{Limit: 100})
// entries.Entries []models.RankEntry, entries.NextCursor // entries.Entries []rudder.Rank, entries.NextCursor
entry, err := board.Get(ctx, "p1") // *models.RankEntry с rank entry, err := board.Get(ctx, "p1") // *rudder.Rank с rank
around, err := board.GetAround(ctx, "p1", 10) // []models.RankEntry вокруг игрока around, err := board.GetAround(ctx, "p1", 10) // []rudder.Rank вокруг игрока
err = board.Submit(ctx, []models.BatchLeaderboardEntry{{PlayerID: "p1", Score: 1500}}) err = board.Submit(ctx, []rudder.LeaderboardScore{{PlayerID: "p1", Score: 1500}})
err = board.Update(ctx, []models.BatchLeaderboardEntry{{PlayerID: "p1", Score: 1600}}) err = board.Update(ctx, []rudder.LeaderboardScore{{PlayerID: "p1", Score: 1600}})
err = board.Delete(ctx, []string{"p1", "p2"}) err = board.Delete(ctx, []string{"p1", "p2"})
``` ```
@@ -106,52 +109,52 @@ err = board.Delete(ctx, []string{"p1", "p2"})
```go ```go
wallets, err := client.Wallet.Adjust(ctx, rudder.AdjustWalletParameters{ wallets, err := client.Wallet.Adjust(ctx, rudder.AdjustWalletParameters{
IdempotencyKey: "grant-001", IdempotencyKey: "grant-001",
Items: []models.BatchAdjustPlayerWalletsItem{ Items: []rudder.WalletAdjustment{
{PlayerID: "p1", CurrencyCode: "coins", Amount: 100, Reason: "compensation"}, {PlayerID: "p1", CurrencyCode: "coins", Amount: 100, Reason: "compensation"},
{PlayerID: "p2", CurrencyCode: "coins", Amount: 100, Reason: "compensation"}, {PlayerID: "p2", CurrencyCode: "coins", Amount: 100, Reason: "compensation"},
}, },
}) })
items, err := client.Inventory.Adjust(ctx, rudder.AdjustInventoryParameters{ items, err := client.Inventory.Adjust(ctx, rudder.AdjustInventoryParameters{
Items: []models.BatchAdjustPlayerInventoryItemsItem{ Items: []rudder.InventoryAdjustment{
{PlayerID: "p1", Slug: "sword", Amount: 1, Reason: "quest reward"}, {PlayerID: "p1", Slug: "sword", Amount: 1, Reason: "quest reward"},
}, },
}) })
updated, err := client.Players.Update(ctx, rudder.UpdatePlayersParameters{ updated, err := client.Players.Update(ctx, rudder.UpdatePlayersParameters{
Items: []models.BatchUpdatePlayersItem{ Items: []rudder.PlayerUpdate{
{PlayerID: "p1", Nickname: "Neo"}, {PlayerID: "p1", Nickname: "Neo"},
}, },
}) })
banned, err := client.Players.Ban(ctx, rudder.BanPlayersParameters{ banned, err := client.Players.Ban(ctx, rudder.BanPlayersParameters{
Items: []models.BatchBanPlayersItem{ Items: []rudder.PlayerBan{
{PlayerID: "p2", Reason: "cheating", BannedUntil: "2030-01-01T00:00:00Z"}, {PlayerID: "p2", Reason: "cheating", BannedUntil: "2030-01-01T00:00:00Z"},
}, },
}) })
unbanned, err := client.Players.Unban(ctx, rudder.UnbanPlayersParameters{ unbanned, err := client.Players.Unban(ctx, rudder.UnbanPlayersParameters{
Items: []models.BatchPlayerItem{{PlayerID: "p2"}}, PlayerIDs: []string{"p2"},
}) })
err = client.Players.Delete(ctx, rudder.DeletePlayersParameters{ err = client.Players.Delete(ctx, rudder.DeletePlayersParameters{
Items: []models.BatchPlayerItem{{PlayerID: "p3"}}, PlayerIDs: []string{"p3"},
}) })
err = client.Quests.Reset(ctx, rudder.ResetPlayerQuestsParameters{ err = client.Quests.Reset(ctx, rudder.PlayerQuestsParameters{
Items: []models.BatchPlayerQuestsItem{ Items: []rudder.PlayerQuestRef{
{PlayerID: "p1", QuestID: "daily-1"}, {PlayerID: "p1", QuestID: "daily-1"},
}, },
}) })
// ForceComplete и ForceClaim — аналогично // ForceComplete и ForceClaim — аналогично
err = client.Leaderboards.Submit(ctx, "weekly", []models.BatchLeaderboardEntry{ err = client.Leaderboards.Submit(ctx, "weekly", []rudder.LeaderboardScore{
{PlayerID: "p1", Score: 1500}, {PlayerID: "p1", Score: 1500},
}) })
// Update и Delete — аналогично // Update и Delete — аналогично
err = client.Storage.Upsert(ctx, rudder.UpsertStorageParameters{ err = client.Storage.Upsert(ctx, rudder.UpsertStorageParameters{
Items: []models.AdminProjectStorageItem{ Items: []rudder.ProjectStorageInput{
{Type: "config", Data: `{"event":"x2"}`}, {Type: "config", Data: `{"event":"x2"}`},
}, },
}) })
@@ -168,24 +171,24 @@ err = client.Storage.Delete(ctx, rudder.DeleteStorageParameters{
```go ```go
boards, err := client.Leaderboards.List(ctx, rudder.ListLeaderboardsParameters{Limit: 100}) boards, err := client.Leaderboards.List(ctx, rudder.ListLeaderboardsParameters{Limit: 100})
// boards.Items []models.LeaderboardDefinition, boards.NextCursor // boards.Items []rudder.Leaderboard, boards.NextCursor
quests, err := client.Quests.List(ctx, rudder.ListQuestsParameters{ quests, err := client.Quests.List(ctx, rudder.ListQuestsParameters{
Status: &status, // "active" или "archived", optional Status: &status, // "active" или "archived", optional
Limit: 100, Limit: 100,
}) })
// quests.Items []models.QuestDefinition, quests.NextCursor // quests.Items []rudder.Quest, quests.NextCursor
history, err := client.Wallet.History(ctx, playerID, rudder.WalletHistoryParameters{ history, err := client.Wallet.History(ctx, playerID, rudder.WalletHistoryParameters{
Currency: &currency, // optional Currency: &currency, // optional
Limit: 50, Limit: 50,
}) })
// history.Entries []models.WalletAudit, history.NextCursor // history.Entries []rudder.WalletTransaction, history.NextCursor
inventory, err := client.Inventory.List(ctx, playerID, rudder.ListInventoryParameters{ inventory, err := client.Inventory.List(ctx, playerID, rudder.ListInventoryParameters{
Limit: 50, Limit: 50,
}) })
// inventory.Items []models.InventoryItem, inventory.NextCursor // inventory.Items []rudder.InventoryItem, inventory.NextCursor
storage, err := client.Storage.List(ctx, rudder.ListStorageParameters{ storage, err := client.Storage.List(ctx, rudder.ListStorageParameters{
Limit: 100, Limit: 100,
@@ -209,3 +212,4 @@ if errors.As(err, &apiErr) {
`models/` генерируется apigen'ом из `liveops-gateway/openapi.yaml` `models/` генерируется apigen'ом из `liveops-gateway/openapi.yaml`
(`make generate-openapi` в liveops-gateway). Руками не править. (`make generate-openapi` в liveops-gateway). Руками не править.
Публичные имена — aliases в корне пакета `rudder` (`types.go`).
+4 -4
View File
@@ -15,10 +15,10 @@ type InventoryService struct {
type AdjustInventoryParameters struct { type AdjustInventoryParameters struct {
IdempotencyKey string IdempotencyKey string
Items []models.BatchAdjustPlayerInventoryItemsItem Items []InventoryAdjustment
} }
func (s *InventoryService) Adjust(ctx context.Context, parameters AdjustInventoryParameters) ([]models.InventoryItem, error) { func (s *InventoryService) Adjust(ctx context.Context, parameters AdjustInventoryParameters) ([]InventoryItem, error) {
body := models.BatchAdjustPlayerInventoryItemsRequest{ body := models.BatchAdjustPlayerInventoryItemsRequest{
IdempotencyKey: parameters.IdempotencyKey, IdempotencyKey: parameters.IdempotencyKey,
Items: parameters.Items, Items: parameters.Items,
@@ -36,7 +36,7 @@ type ListInventoryParameters struct {
Cursor *string Cursor *string
} }
func (s *InventoryService) List(ctx context.Context, playerID string, parameters ListInventoryParameters) (*models.GetPlayerInventoryResponse, error) { func (s *InventoryService) List(ctx context.Context, playerID string, parameters ListInventoryParameters) (*InventoryList, error) {
query := url.Values{} query := url.Values{}
if parameters.Limit > 0 { if parameters.Limit > 0 {
query.Set("limit", strconv.Itoa(parameters.Limit)) query.Set("limit", strconv.Itoa(parameters.Limit))
@@ -45,7 +45,7 @@ func (s *InventoryService) List(ctx context.Context, playerID string, parameters
query.Set("cursor", *parameters.Cursor) query.Set("cursor", *parameters.Cursor)
} }
var response models.GetPlayerInventoryResponse var response InventoryList
if err := s.transport.do(ctx, http.MethodGet, "/players/"+url.PathEscape(playerID)+"/inventory", query, nil, &response); err != nil { if err := s.transport.do(ctx, http.MethodGet, "/players/"+url.PathEscape(playerID)+"/inventory", query, nil, &response); err != nil {
return nil, err return nil, err
} }
+7 -7
View File
@@ -20,7 +20,7 @@ type ListLeaderboardEntriesParameters struct {
Cursor *string Cursor *string
} }
func (h *LeaderboardHandle) List(ctx context.Context, parameters ListLeaderboardEntriesParameters) (*models.ListLeaderboardEntriesResponse, error) { func (h *LeaderboardHandle) List(ctx context.Context, parameters ListLeaderboardEntriesParameters) (*RankList, error) {
query := url.Values{} query := url.Values{}
if parameters.Limit > 0 { if parameters.Limit > 0 {
query.Set("limit", strconv.Itoa(parameters.Limit)) query.Set("limit", strconv.Itoa(parameters.Limit))
@@ -29,22 +29,22 @@ func (h *LeaderboardHandle) List(ctx context.Context, parameters ListLeaderboard
query.Set("cursor", *parameters.Cursor) query.Set("cursor", *parameters.Cursor)
} }
var response models.ListLeaderboardEntriesResponse var response RankList
if err := h.transport.do(ctx, http.MethodGet, "/leaderboards/"+url.PathEscape(h.slug)+"/entries", query, nil, &response); err != nil { if err := h.transport.do(ctx, http.MethodGet, "/leaderboards/"+url.PathEscape(h.slug)+"/entries", query, nil, &response); err != nil {
return nil, err return nil, err
} }
return &response, nil return &response, nil
} }
func (h *LeaderboardHandle) Get(ctx context.Context, playerID string) (*models.RankEntry, error) { func (h *LeaderboardHandle) Get(ctx context.Context, playerID string) (*Rank, error) {
var response models.RankEntry 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 { 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 nil, err
} }
return &response, nil return &response, nil
} }
func (h *LeaderboardHandle) GetAround(ctx context.Context, playerID string, limit int) ([]models.RankEntry, error) { func (h *LeaderboardHandle) GetAround(ctx context.Context, playerID string, limit int) ([]Rank, error) {
query := url.Values{} query := url.Values{}
if limit > 0 { if limit > 0 {
query.Set("limit", strconv.Itoa(limit)) query.Set("limit", strconv.Itoa(limit))
@@ -57,11 +57,11 @@ func (h *LeaderboardHandle) GetAround(ctx context.Context, playerID string, limi
return response.Entries, nil return response.Entries, nil
} }
func (h *LeaderboardHandle) Submit(ctx context.Context, items []models.BatchLeaderboardEntry) error { func (h *LeaderboardHandle) Submit(ctx context.Context, items []LeaderboardScore) error {
return h.leaderboards.Submit(ctx, h.slug, items) return h.leaderboards.Submit(ctx, h.slug, items)
} }
func (h *LeaderboardHandle) Update(ctx context.Context, items []models.BatchLeaderboardEntry) error { func (h *LeaderboardHandle) Update(ctx context.Context, items []LeaderboardScore) error {
return h.leaderboards.Update(ctx, h.slug, items) return h.leaderboards.Update(ctx, h.slug, items)
} }
+4 -4
View File
@@ -18,7 +18,7 @@ type ListLeaderboardsParameters struct {
Cursor *string Cursor *string
} }
func (s *LeaderboardsService) List(ctx context.Context, parameters ListLeaderboardsParameters) (*models.ListLeaderboardsResponse, error) { func (s *LeaderboardsService) List(ctx context.Context, parameters ListLeaderboardsParameters) (*LeaderboardList, error) {
query := url.Values{} query := url.Values{}
if parameters.Limit > 0 { if parameters.Limit > 0 {
query.Set("limit", strconv.Itoa(parameters.Limit)) query.Set("limit", strconv.Itoa(parameters.Limit))
@@ -27,21 +27,21 @@ func (s *LeaderboardsService) List(ctx context.Context, parameters ListLeaderboa
query.Set("cursor", *parameters.Cursor) query.Set("cursor", *parameters.Cursor)
} }
var response models.ListLeaderboardsResponse var response LeaderboardList
if err := s.transport.do(ctx, http.MethodGet, "/leaderboards", query, nil, &response); err != nil { if err := s.transport.do(ctx, http.MethodGet, "/leaderboards", query, nil, &response); err != nil {
return nil, err return nil, err
} }
return &response, nil return &response, nil
} }
func (s *LeaderboardsService) Submit(ctx context.Context, slug string, items []models.BatchLeaderboardEntry) error { func (s *LeaderboardsService) Submit(ctx context.Context, slug string, items []LeaderboardScore) error {
body := models.BatchSubmitLeaderboardEntriesRequest{ body := models.BatchSubmitLeaderboardEntriesRequest{
Items: items, Items: items,
} }
return s.transport.do(ctx, http.MethodPost, "/leaderboards/"+url.PathEscape(slug)+"/entries", nil, body, nil) 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 []models.BatchLeaderboardEntry) error { func (s *LeaderboardsService) Update(ctx context.Context, slug string, items []LeaderboardScore) error {
body := models.BatchUpdateLeaderboardEntriesRequest{ body := models.BatchUpdateLeaderboardEntriesRequest{
Items: items, Items: items,
} }
+7 -9
View File
@@ -3,8 +3,6 @@ package rudder
import ( import (
"context" "context"
"encoding/json" "encoding/json"
"hub.rudder.build/rudder/rudder-go-sdk/models"
) )
type PlayerHandle struct { type PlayerHandle struct {
@@ -38,10 +36,10 @@ type UpdatePlayerParameters struct {
Data json.RawMessage Data json.RawMessage
} }
func (h *PlayerHandle) Update(ctx context.Context, parameters UpdatePlayerParameters) (*models.AdminPlayer, error) { func (h *PlayerHandle) Update(ctx context.Context, parameters UpdatePlayerParameters) (*Player, error) {
players, err := h.players.Update(ctx, UpdatePlayersParameters{ players, err := h.players.Update(ctx, UpdatePlayersParameters{
IdempotencyKey: parameters.IdempotencyKey, IdempotencyKey: parameters.IdempotencyKey,
Items: []models.BatchUpdatePlayersItem{{ Items: []PlayerUpdate{{
PlayerID: h.playerID, PlayerID: h.playerID,
Nickname: parameters.Nickname, Nickname: parameters.Nickname,
Data: parameters.Data, Data: parameters.Data,
@@ -59,10 +57,10 @@ type BanPlayerParameters struct {
BannedUntil string BannedUntil string
} }
func (h *PlayerHandle) Ban(ctx context.Context, parameters BanPlayerParameters) (*models.AdminPlayer, error) { func (h *PlayerHandle) Ban(ctx context.Context, parameters BanPlayerParameters) (*Player, error) {
players, err := h.players.Ban(ctx, BanPlayersParameters{ players, err := h.players.Ban(ctx, BanPlayersParameters{
IdempotencyKey: parameters.IdempotencyKey, IdempotencyKey: parameters.IdempotencyKey,
Items: []models.BatchBanPlayersItem{{ Items: []PlayerBan{{
PlayerID: h.playerID, PlayerID: h.playerID,
Reason: parameters.Reason, Reason: parameters.Reason,
BannedUntil: parameters.BannedUntil, BannedUntil: parameters.BannedUntil,
@@ -74,10 +72,10 @@ func (h *PlayerHandle) Ban(ctx context.Context, parameters BanPlayerParameters)
return &players[0], nil return &players[0], nil
} }
func (h *PlayerHandle) Unban(ctx context.Context, idempotencyKey string) (*models.AdminPlayer, error) { func (h *PlayerHandle) Unban(ctx context.Context, idempotencyKey string) (*Player, error) {
players, err := h.players.Unban(ctx, UnbanPlayersParameters{ players, err := h.players.Unban(ctx, UnbanPlayersParameters{
IdempotencyKey: idempotencyKey, IdempotencyKey: idempotencyKey,
Items: []models.BatchPlayerItem{{PlayerID: h.playerID}}, PlayerIDs: []string{h.playerID},
}) })
if err != nil { if err != nil {
return nil, err return nil, err
@@ -88,6 +86,6 @@ func (h *PlayerHandle) Unban(ctx context.Context, idempotencyKey string) (*model
func (h *PlayerHandle) Delete(ctx context.Context, idempotencyKey string) error { func (h *PlayerHandle) Delete(ctx context.Context, idempotencyKey string) error {
return h.players.Delete(ctx, DeletePlayersParameters{ return h.players.Delete(ctx, DeletePlayersParameters{
IdempotencyKey: idempotencyKey, IdempotencyKey: idempotencyKey,
Items: []models.BatchPlayerItem{{PlayerID: h.playerID}}, PlayerIDs: []string{h.playerID},
}) })
} }
+4 -8
View File
@@ -1,10 +1,6 @@
package rudder package rudder
import ( import "context"
"context"
"hub.rudder.build/rudder/rudder-go-sdk/models"
)
type PlayerInventoryHandle struct { type PlayerInventoryHandle struct {
playerID string playerID string
@@ -18,10 +14,10 @@ type AdjustPlayerInventoryParameters struct {
Reason string Reason string
} }
func (h *PlayerInventoryHandle) Adjust(ctx context.Context, parameters AdjustPlayerInventoryParameters) (*models.InventoryItem, error) { func (h *PlayerInventoryHandle) Adjust(ctx context.Context, parameters AdjustPlayerInventoryParameters) (*InventoryItem, error) {
items, err := h.inventory.Adjust(ctx, AdjustInventoryParameters{ items, err := h.inventory.Adjust(ctx, AdjustInventoryParameters{
IdempotencyKey: parameters.IdempotencyKey, IdempotencyKey: parameters.IdempotencyKey,
Items: []models.BatchAdjustPlayerInventoryItemsItem{{ Items: []InventoryAdjustment{{
PlayerID: h.playerID, PlayerID: h.playerID,
Slug: parameters.Slug, Slug: parameters.Slug,
Amount: parameters.Amount, Amount: parameters.Amount,
@@ -34,6 +30,6 @@ func (h *PlayerInventoryHandle) Adjust(ctx context.Context, parameters AdjustPla
return &items[0], nil return &items[0], nil
} }
func (h *PlayerInventoryHandle) List(ctx context.Context, parameters ListInventoryParameters) (*models.GetPlayerInventoryResponse, error) { func (h *PlayerInventoryHandle) List(ctx context.Context, parameters ListInventoryParameters) (*InventoryList, error) {
return h.inventory.List(ctx, h.playerID, parameters) return h.inventory.List(ctx, h.playerID, parameters)
} }
+7 -7
View File
@@ -14,7 +14,7 @@ type PlayerQuestsHandle struct {
quests *QuestsService quests *QuestsService
} }
func (h *PlayerQuestsHandle) List(ctx context.Context) ([]models.AdminPlayerQuest, error) { func (h *PlayerQuestsHandle) List(ctx context.Context) ([]PlayerQuest, error) {
var response models.ListPlayerQuestsResponse var response models.ListPlayerQuestsResponse
if err := h.transport.do(ctx, http.MethodGet, "/players/"+url.PathEscape(h.playerID)+"/quests", nil, nil, &response); err != nil { if err := h.transport.do(ctx, http.MethodGet, "/players/"+url.PathEscape(h.playerID)+"/quests", nil, nil, &response); err != nil {
return nil, err return nil, err
@@ -28,22 +28,22 @@ type PlayerQuestParameters struct {
} }
func (h *PlayerQuestsHandle) Reset(ctx context.Context, parameters PlayerQuestParameters) error { func (h *PlayerQuestsHandle) Reset(ctx context.Context, parameters PlayerQuestParameters) error {
return h.quests.Reset(ctx, ResetPlayerQuestsParameters{ return h.quests.Reset(ctx, PlayerQuestsParameters{
IdempotencyKey: parameters.IdempotencyKey, IdempotencyKey: parameters.IdempotencyKey,
Items: []models.BatchPlayerQuestsItem{{PlayerID: h.playerID, QuestID: parameters.QuestID}}, Items: []PlayerQuestRef{{PlayerID: h.playerID, QuestID: parameters.QuestID}},
}) })
} }
func (h *PlayerQuestsHandle) ForceComplete(ctx context.Context, parameters PlayerQuestParameters) error { func (h *PlayerQuestsHandle) ForceComplete(ctx context.Context, parameters PlayerQuestParameters) error {
return h.quests.ForceComplete(ctx, ForceCompletePlayerQuestsParameters{ return h.quests.ForceComplete(ctx, PlayerQuestsParameters{
IdempotencyKey: parameters.IdempotencyKey, IdempotencyKey: parameters.IdempotencyKey,
Items: []models.BatchPlayerQuestsItem{{PlayerID: h.playerID, QuestID: parameters.QuestID}}, Items: []PlayerQuestRef{{PlayerID: h.playerID, QuestID: parameters.QuestID}},
}) })
} }
func (h *PlayerQuestsHandle) ForceClaim(ctx context.Context, parameters PlayerQuestParameters) error { func (h *PlayerQuestsHandle) ForceClaim(ctx context.Context, parameters PlayerQuestParameters) error {
return h.quests.ForceClaim(ctx, ForceClaimPlayerQuestsParameters{ return h.quests.ForceClaim(ctx, PlayerQuestsParameters{
IdempotencyKey: parameters.IdempotencyKey, IdempotencyKey: parameters.IdempotencyKey,
Items: []models.BatchPlayerQuestsItem{{PlayerID: h.playerID, QuestID: parameters.QuestID}}, Items: []PlayerQuestRef{{PlayerID: h.playerID, QuestID: parameters.QuestID}},
}) })
} }
+3 -3
View File
@@ -13,8 +13,8 @@ type PlayerStorageHandle struct {
transport *transport transport *transport
} }
func (h *PlayerStorageHandle) Get(ctx context.Context, storageType string) (*models.PlayerStorage, error) { func (h *PlayerStorageHandle) Get(ctx context.Context, storageType string) (*PlayerStorage, error) {
var response models.PlayerStorage 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 { 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 nil, err
} }
@@ -28,7 +28,7 @@ type UpsertPlayerStorageParameters struct {
ExpiresAt string ExpiresAt string
} }
func (h *PlayerStorageHandle) Upsert(ctx context.Context, parameters UpsertPlayerStorageParameters) (*models.PlayerStorage, error) { func (h *PlayerStorageHandle) Upsert(ctx context.Context, parameters UpsertPlayerStorageParameters) (*PlayerStorage, error) {
body := models.BatchUpsertPlayerStoragesRequest{ body := models.BatchUpsertPlayerStoragesRequest{
IdempotencyKey: parameters.IdempotencyKey, IdempotencyKey: parameters.IdempotencyKey,
Items: []models.BatchUpsertPlayerStoragesItem{{ Items: []models.BatchUpsertPlayerStoragesItem{{
+4 -8
View File
@@ -1,10 +1,6 @@
package rudder package rudder
import ( import "context"
"context"
"hub.rudder.build/rudder/rudder-go-sdk/models"
)
type PlayerWalletHandle struct { type PlayerWalletHandle struct {
playerID string playerID string
@@ -18,10 +14,10 @@ type AdjustPlayerWalletParameters struct {
Reason string Reason string
} }
func (h *PlayerWalletHandle) Adjust(ctx context.Context, parameters AdjustPlayerWalletParameters) (*models.WalletDetails, error) { func (h *PlayerWalletHandle) Adjust(ctx context.Context, parameters AdjustPlayerWalletParameters) (*WalletBalance, error) {
wallets, err := h.wallet.Adjust(ctx, AdjustWalletParameters{ wallets, err := h.wallet.Adjust(ctx, AdjustWalletParameters{
IdempotencyKey: parameters.IdempotencyKey, IdempotencyKey: parameters.IdempotencyKey,
Items: []models.BatchAdjustPlayerWalletsItem{{ Items: []WalletAdjustment{{
PlayerID: h.playerID, PlayerID: h.playerID,
CurrencyCode: parameters.CurrencyCode, CurrencyCode: parameters.CurrencyCode,
Amount: parameters.Amount, Amount: parameters.Amount,
@@ -34,6 +30,6 @@ func (h *PlayerWalletHandle) Adjust(ctx context.Context, parameters AdjustPlayer
return &wallets[0], nil return &wallets[0], nil
} }
func (h *PlayerWalletHandle) History(ctx context.Context, parameters WalletHistoryParameters) (*models.GetWalletHistoryResponse, error) { func (h *PlayerWalletHandle) History(ctx context.Context, parameters WalletHistoryParameters) (*WalletHistory, error) {
return h.wallet.History(ctx, h.playerID, parameters) return h.wallet.History(ctx, h.playerID, parameters)
} }
+21 -13
View File
@@ -19,7 +19,7 @@ type ListPlayersParameters struct {
Search string 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{} query := url.Values{}
if parameters.Limit > 0 { if parameters.Limit > 0 {
query.Set("limit", strconv.Itoa(parameters.Limit)) query.Set("limit", strconv.Itoa(parameters.Limit))
@@ -31,15 +31,15 @@ func (s *PlayersService) List(ctx context.Context, parameters ListPlayersParamet
query.Set("search", parameters.Search) 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 { if err := s.transport.do(ctx, http.MethodGet, "/players/list", query, nil, &response); err != nil {
return nil, err return nil, err
} }
return &response, nil 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 { if err := s.transport.do(ctx, http.MethodGet, "/players/"+url.PathEscape(playerID), nil, nil, &response); err != nil {
return nil, err return nil, err
} }
@@ -48,10 +48,10 @@ func (s *PlayersService) Get(ctx context.Context, playerID string) (*models.Admi
type UpdatePlayersParameters struct { type UpdatePlayersParameters struct {
IdempotencyKey string IdempotencyKey string
Items []models.BatchUpdatePlayersItem Items []PlayerUpdate
} }
func (s *PlayersService) Update(ctx context.Context, parameters UpdatePlayersParameters) ([]models.AdminPlayer, error) { func (s *PlayersService) Update(ctx context.Context, parameters UpdatePlayersParameters) ([]Player, error) {
body := models.BatchUpdatePlayersRequest{ body := models.BatchUpdatePlayersRequest{
IdempotencyKey: parameters.IdempotencyKey, IdempotencyKey: parameters.IdempotencyKey,
Items: parameters.Items, Items: parameters.Items,
@@ -66,10 +66,10 @@ func (s *PlayersService) Update(ctx context.Context, parameters UpdatePlayersPar
type BanPlayersParameters struct { type BanPlayersParameters struct {
IdempotencyKey string IdempotencyKey string
Items []models.BatchBanPlayersItem Items []PlayerBan
} }
func (s *PlayersService) Ban(ctx context.Context, parameters BanPlayersParameters) ([]models.AdminPlayer, error) { func (s *PlayersService) Ban(ctx context.Context, parameters BanPlayersParameters) ([]Player, error) {
body := models.BatchBanPlayersRequest{ body := models.BatchBanPlayersRequest{
IdempotencyKey: parameters.IdempotencyKey, IdempotencyKey: parameters.IdempotencyKey,
Items: parameters.Items, Items: parameters.Items,
@@ -84,13 +84,13 @@ func (s *PlayersService) Ban(ctx context.Context, parameters BanPlayersParameter
type UnbanPlayersParameters struct { type UnbanPlayersParameters struct {
IdempotencyKey string IdempotencyKey string
Items []models.BatchPlayerItem PlayerIDs []string
} }
func (s *PlayersService) Unban(ctx context.Context, parameters UnbanPlayersParameters) ([]models.AdminPlayer, error) { func (s *PlayersService) Unban(ctx context.Context, parameters UnbanPlayersParameters) ([]Player, error) {
body := models.BatchUnbanPlayersRequest{ body := models.BatchUnbanPlayersRequest{
IdempotencyKey: parameters.IdempotencyKey, IdempotencyKey: parameters.IdempotencyKey,
Items: parameters.Items, Items: batchPlayerItems(parameters.PlayerIDs),
} }
var response models.BatchPlayersResponse var response models.BatchPlayersResponse
@@ -102,13 +102,21 @@ func (s *PlayersService) Unban(ctx context.Context, parameters UnbanPlayersParam
type DeletePlayersParameters struct { type DeletePlayersParameters struct {
IdempotencyKey string IdempotencyKey string
Items []models.BatchPlayerItem PlayerIDs []string
} }
func (s *PlayersService) Delete(ctx context.Context, parameters DeletePlayersParameters) error { func (s *PlayersService) Delete(ctx context.Context, parameters DeletePlayersParameters) error {
body := models.BatchDeletePlayersRequest{ body := models.BatchDeletePlayersRequest{
IdempotencyKey: parameters.IdempotencyKey, IdempotencyKey: parameters.IdempotencyKey,
Items: parameters.Items, Items: batchPlayerItems(parameters.PlayerIDs),
} }
return s.transport.do(ctx, http.MethodDelete, "/players", nil, body, nil) 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
}
+18 -32
View File
@@ -19,7 +19,7 @@ type ListQuestsParameters struct {
Cursor *string Cursor *string
} }
func (s *QuestsService) List(ctx context.Context, parameters ListQuestsParameters) (*models.AdminListQuestsResponse, error) { func (s *QuestsService) List(ctx context.Context, parameters ListQuestsParameters) (*QuestList, error) {
query := url.Values{} query := url.Values{}
if parameters.Status != nil { if parameters.Status != nil {
query.Set("status", *parameters.Status) query.Set("status", *parameters.Status)
@@ -31,48 +31,34 @@ func (s *QuestsService) List(ctx context.Context, parameters ListQuestsParameter
query.Set("cursor", *parameters.Cursor) query.Set("cursor", *parameters.Cursor)
} }
var response models.AdminListQuestsResponse var response QuestList
if err := s.transport.do(ctx, http.MethodGet, "/quests", query, nil, &response); err != nil { if err := s.transport.do(ctx, http.MethodGet, "/quests", query, nil, &response); err != nil {
return nil, err return nil, err
} }
return &response, nil return &response, nil
} }
type ResetPlayerQuestsParameters struct { type PlayerQuestsParameters struct {
IdempotencyKey string IdempotencyKey string
Items []models.BatchPlayerQuestsItem Items []PlayerQuestRef
} }
func (s *QuestsService) Reset(ctx context.Context, parameters ResetPlayerQuestsParameters) error { 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{ body := models.BatchPlayerQuestsRequest{
IdempotencyKey: parameters.IdempotencyKey, IdempotencyKey: parameters.IdempotencyKey,
Items: parameters.Items, Items: parameters.Items,
} }
return s.transport.do(ctx, http.MethodPost, "/players/quests/reset", nil, body, nil) return s.transport.do(ctx, http.MethodPost, path, nil, body, nil)
}
type ForceCompletePlayerQuestsParameters struct {
IdempotencyKey string
Items []models.BatchPlayerQuestsItem
}
func (s *QuestsService) ForceComplete(ctx context.Context, parameters ForceCompletePlayerQuestsParameters) error {
body := models.BatchPlayerQuestsRequest{
IdempotencyKey: parameters.IdempotencyKey,
Items: parameters.Items,
}
return s.transport.do(ctx, http.MethodPost, "/players/quests/force-complete", nil, body, nil)
}
type ForceClaimPlayerQuestsParameters struct {
IdempotencyKey string
Items []models.BatchPlayerQuestsItem
}
func (s *QuestsService) ForceClaim(ctx context.Context, parameters ForceClaimPlayerQuestsParameters) error {
body := models.BatchPlayerQuestsRequest{
IdempotencyKey: parameters.IdempotencyKey,
Items: parameters.Items,
}
return s.transport.do(ctx, http.MethodPost, "/players/quests/force-claim", nil, body, nil)
} }
+4 -4
View File
@@ -19,7 +19,7 @@ type ListStorageParameters struct {
Search string Search string
} }
func (s *StorageService) List(ctx context.Context, parameters ListStorageParameters) (*models.GetProjectStorageResponse, error) { func (s *StorageService) List(ctx context.Context, parameters ListStorageParameters) (*ProjectStorageList, error) {
query := url.Values{} query := url.Values{}
if parameters.Limit > 0 { if parameters.Limit > 0 {
query.Set("limit", strconv.Itoa(parameters.Limit)) query.Set("limit", strconv.Itoa(parameters.Limit))
@@ -31,14 +31,14 @@ func (s *StorageService) List(ctx context.Context, parameters ListStorageParamet
query.Set("search", parameters.Search) query.Set("search", parameters.Search)
} }
var response models.GetProjectStorageResponse var response ProjectStorageList
if err := s.transport.do(ctx, http.MethodGet, "/project-storage", query, nil, &response); err != nil { if err := s.transport.do(ctx, http.MethodGet, "/project-storage", query, nil, &response); err != nil {
return nil, err return nil, err
} }
return &response, nil return &response, nil
} }
func (s *StorageService) Get(ctx context.Context, itemType string) (*models.ProjectStorageItem, error) { func (s *StorageService) Get(ctx context.Context, itemType string) (*ProjectStorage, error) {
var response models.AdminGetProjectStorageResponse var response models.AdminGetProjectStorageResponse
if err := s.transport.do(ctx, http.MethodGet, "/project-storage/"+url.PathEscape(itemType), nil, nil, &response); err != nil { if err := s.transport.do(ctx, http.MethodGet, "/project-storage/"+url.PathEscape(itemType), nil, nil, &response); err != nil {
return nil, err return nil, err
@@ -48,7 +48,7 @@ func (s *StorageService) Get(ctx context.Context, itemType string) (*models.Proj
type UpsertStorageParameters struct { type UpsertStorageParameters struct {
IdempotencyKey string IdempotencyKey string
Items []models.AdminProjectStorageItem Items []ProjectStorageInput
} }
func (s *StorageService) Upsert(ctx context.Context, parameters UpsertStorageParameters) error { func (s *StorageService) Upsert(ctx context.Context, parameters UpsertStorageParameters) error {
+40
View File
@@ -0,0 +1,40 @@
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 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
+4 -4
View File
@@ -15,10 +15,10 @@ type WalletService struct {
type AdjustWalletParameters struct { type AdjustWalletParameters struct {
IdempotencyKey string IdempotencyKey string
Items []models.BatchAdjustPlayerWalletsItem Items []WalletAdjustment
} }
func (s *WalletService) Adjust(ctx context.Context, parameters AdjustWalletParameters) ([]models.WalletDetails, error) { func (s *WalletService) Adjust(ctx context.Context, parameters AdjustWalletParameters) ([]WalletBalance, error) {
body := models.BatchAdjustPlayerWalletsRequest{ body := models.BatchAdjustPlayerWalletsRequest{
IdempotencyKey: parameters.IdempotencyKey, IdempotencyKey: parameters.IdempotencyKey,
Items: parameters.Items, Items: parameters.Items,
@@ -37,7 +37,7 @@ type WalletHistoryParameters struct {
Cursor *string Cursor *string
} }
func (s *WalletService) History(ctx context.Context, playerID string, parameters WalletHistoryParameters) (*models.GetWalletHistoryResponse, error) { func (s *WalletService) History(ctx context.Context, playerID string, parameters WalletHistoryParameters) (*WalletHistory, error) {
query := url.Values{} query := url.Values{}
if parameters.Currency != nil { if parameters.Currency != nil {
query.Set("currency", *parameters.Currency) query.Set("currency", *parameters.Currency)
@@ -49,7 +49,7 @@ func (s *WalletService) History(ctx context.Context, playerID string, parameters
query.Set("cursor", *parameters.Cursor) query.Set("cursor", *parameters.Cursor)
} }
var response models.GetWalletHistoryResponse var response WalletHistory
if err := s.transport.do(ctx, http.MethodGet, "/players/"+url.PathEscape(playerID)+"/wallet/history", query, nil, &response); err != nil { if err := s.transport.do(ctx, http.MethodGet, "/players/"+url.PathEscape(playerID)+"/wallet/history", query, nil, &response); err != nil {
return nil, err return nil, err
} }