v0.5.0: batch-first API, player/leaderboard handles, unified naming, Storage is global project storage, catalog list methods

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) {
-	var response models.PlayerStorage
-	if err := s.transport.do(ctx, http.MethodGet, "/players/"+url.PathEscape(playerID)+"/storage/"+url.PathEscape(storageType), nil, nil, &response); err != nil {
+type ListStorageParameters struct {
+	Limit  int
+	Cursor string
+	Search string
+}
+
+func (s *StorageService) List(ctx context.Context, parameters ListStorageParameters) (*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)
+	}
+	if parameters.Search != "" {
+		query.Set("search", parameters.Search)
+	}
+
+	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 *StorageService) 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 UpsertStorageParameters struct {
-	Data      string
-	ExpiresAt *time.Time
+	IdempotencyKey string
+	Items          []models.AdminProjectStorageItem
 }
 
-func (s *StorageService) Upsert(ctx context.Context, playerID string, storageType string, parameters UpsertStorageParameters) (*models.PlayerStorage, error) {
-	body := models.UpsertPlayerStorageRequest{
-		Data: parameters.Data,
+func (s *StorageService) Upsert(ctx context.Context, parameters UpsertStorageParameters) error {
+	body := models.BatchUpsertProjectStorageRequest{
+		IdempotencyKey: parameters.IdempotencyKey,
+		Items:          parameters.Items,
 	}
-	if parameters.ExpiresAt != 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
+	return s.transport.do(ctx, http.MethodPut, "/project-storage", nil, body, nil)
 }
 
-func (s *StorageService) Delete(ctx context.Context, playerID string, storageType string) error {
-	return s.transport.do(ctx, http.MethodDelete, "/players/"+url.PathEscape(playerID)+"/storage/"+url.PathEscape(storageType), nil, nil, nil)
+type DeleteStorageParameters struct {
+	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)
 }