service

Documentation

Index

• func NewSteamClient(client HTTPClient) *steamClient
• type GameProcessor
  • func NewGameProcessor(storage persistence.StorageDB, steamClient SteamClient) *GameProcessor
  • func (sv *GameProcessor) GetGamesFromAPI(ctx context.Context, items []entity.Item) ([][]byte, error)
  • func (sv *GameProcessor) ProcessResponse(responseData [][]byte, games []entity.Item) ([]steamapi.AppDetails, error)
  • func (sv *GameProcessor) RunProcessData(ctx context.Context, limit int) error
  • func (sv *GameProcessor) UpdateData(games []entity.Item, id int64, isValid bool) error
• type HTTPClient
• type ReviewsClient
• type SteamClient
• type SteamReviewAPI
  • func NewSteamReviewAPI(client *http.Client) *SteamReviewAPI
  • func (s *SteamReviewAPI) FetchReviews(appID int, typeReview string, limit string) (*model.ReviewResponse, error)

Functions

func NewSteamClient

func NewSteamClient(client HTTPClient) *steamClient

Types

type GameProcessor

type GameProcessor struct {
	// contains filtered or unexported fields
}

func NewGameProcessor

func NewGameProcessor(storage persistence.StorageDB, steamClient SteamClient) *GameProcessor

func (*GameProcessor) GetGamesFromAPI

func (sv *GameProcessor) GetGamesFromAPI(ctx context.Context, items []entity.Item) ([][]byte, error)

func (*GameProcessor) ProcessResponse

func (sv *GameProcessor) ProcessResponse(responseData [][]byte, games []entity.Item) ([]steamapi.AppDetails, error)

func (*GameProcessor) RunProcessData

func (sv *GameProcessor) RunProcessData(ctx context.Context, limit int) error

func (*GameProcessor) UpdateData

func (sv *GameProcessor) UpdateData(games []entity.Item, id int64, isValid bool) error

type HTTPClient

type HTTPClient interface {
	Do(req *http.Request) (*http.Response, error)
}

type ReviewsClient

type ReviewsClient interface {
	FetchReviews(appID int, typeReview string, limit string) (*model.ReviewResponse, error)
}

type SteamClient

type SteamClient interface {
	GetAppDetails(id int) ([]byte, error)
}

type SteamReviewAPI

type SteamReviewAPI struct {
	// contains filtered or unexported fields
}

func NewSteamReviewAPI

func NewSteamReviewAPI(client *http.Client) *SteamReviewAPI

func (*SteamReviewAPI) FetchReviews

func (s *SteamReviewAPI) FetchReviews(appID int, typeReview string, limit string) (*model.ReviewResponse, error)

FetchReviews obtiene las reseñas de un juego específico utilizando su appID. Acepta el appID del juego como argumento y devuelve un puntero a la estructura ReviewResponse que contiene la información de las reseñas, así como un posible error si ocurre.