package rudder

import (
	"context"
	"encoding/json"
	"net/http"
	"net/url"
	"strconv"
	"time"

	"hub.rudder.build/rudder/rudder-go-sdk/models"
)

type PlayersService struct {
	transport *transport
}

type ListPlayersParameters struct {
	Limit  int
	Offset int
	Search string
}

func (s *PlayersService) List(ctx context.Context, parameters ListPlayersParameters) (*models.ListPlayersResponse, error) {
	query := url.Values{}
	if parameters.Limit > 0 {
		query.Set("limit", strconv.Itoa(parameters.Limit))
	}
	if parameters.Offset > 0 {
		query.Set("offset", strconv.Itoa(parameters.Offset))
	}
	if parameters.Search != "" {
		query.Set("search", parameters.Search)
	}

	var response models.ListPlayersResponse
	if err := s.transport.do(ctx, http.MethodGet, "/players/list", query, nil, &response); err != nil {
		return nil, err
	}
	return &response, nil
}

func (s *PlayersService) Get(ctx context.Context, playerID string) (*models.AdminPlayerDetails, error) {
	var response models.AdminPlayerDetails
	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 {
	Nickname *string
	Data     json.RawMessage
}

func (s *PlayersService) Update(ctx context.Context, playerID string, parameters UpdatePlayerParameters) (*models.AdminPlayer, error) {
	body := models.UpdatePlayerRequest{
		Data: parameters.Data,
	}
	if parameters.Nickname != nil {
		body.Nickname = *parameters.Nickname
	}

	var response models.AdminPlayer
	if err := s.transport.do(ctx, http.MethodPatch, "/players/"+url.PathEscape(playerID), nil, body, &response); err != nil {
		return nil, err
	}
	return &response, nil
}

type BanPlayerParameters struct {
	Reason         string
	Until          *time.Time
	IdempotencyKey string
}

func (s *PlayersService) Ban(ctx context.Context, playerID string, parameters BanPlayerParameters) (*models.AdminPlayer, error) {
	body := models.BanPlayerRequest{
		Reason:         parameters.Reason,
		IdempotencyKey: parameters.IdempotencyKey,
	}
	if parameters.Until != nil {
		body.BannedUntil = parameters.Until.Format(time.RFC3339)
	}

	var response models.AdminPlayer
	if err := s.transport.do(ctx, http.MethodPost, "/players/"+url.PathEscape(playerID)+"/ban", nil, body, &response); err != nil {
		return nil, err
	}
	return &response, nil
}

func (s *PlayersService) Unban(ctx context.Context, playerID string) (*models.AdminPlayer, error) {
	var response models.AdminPlayer
	if err := s.transport.do(ctx, http.MethodPost, "/players/"+url.PathEscape(playerID)+"/unban", nil, nil, &response); err != nil {
		return nil, err
	}
	return &response, nil
}

func (s *PlayersService) Delete(ctx context.Context, playerID string, idempotencyKey string) error {
	body := models.DeletePlayerRequest{
		IdempotencyKey: idempotencyKey,
	}
	return s.transport.do(ctx, http.MethodDelete, "/players/"+url.PathEscape(playerID), nil, body, nil)
}