fetchers

Documentation

Index

• func GOGIdToSteamApp(gogId string, rxa kvas.ReduxAssets) uint32
• func Items(ids []string, pt vangogh_local_data.ProductType, httpClient *http.Client) error
• func NewKvasIndexSetter(pt vangogh_local_data.ProductType, ids []string) (*kvasIndexSetter, error)
• func Pages(pt vangogh_local_data.ProductType, since int64, httpClient *http.Client, ...) error
• type SteamUrlProvider
  • func (sup *SteamUrlProvider) DefaultSourceUrl(gogId string) *url.URL

Functions

func GOGIdToSteamApp

func GOGIdToSteamApp(gogId string, rxa kvas.ReduxAssets) uint32

func Items

func Items(
	ids []string,
	pt vangogh_local_data.ProductType,
	httpClient *http.Client) error

Items fetches all individual data items (details, api-products-v1/v2) using provided ids

func NewKvasIndexSetter

func NewKvasIndexSetter(pt vangogh_local_data.ProductType, ids []string) (*kvasIndexSetter, error)

func Pages

func Pages(pt vangogh_local_data.ProductType, since int64, httpClient *http.Client, tpw nod.TotalProgressWriter) error

Pages fetches all paged product type pages concurrently (using dolo.GetSet). To do that it downloads the first page, decodes that to get TotalPages, then constructs a slice of URLs and page ids to download all the remaining pages from 2nd to TotalPages using kvas index setter.

Types

type SteamUrlProvider

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

func (*SteamUrlProvider) DefaultSourceUrl

func (sup *SteamUrlProvider) DefaultSourceUrl(gogId string) *url.URL