proxy

Documentation

Index

• Constants
• type CachedResponse
• type CachingResponseWriter
  • func (rw *CachingResponseWriter) Header() http.Header
  • func (rw *CachingResponseWriter) Write(data []byte) (int, error)
  • func (rw *CachingResponseWriter) WriteHeader(statusCode int)
• type PredictionState
• type Rating
• type RatingUpdate
  • func NewRatingUpdate() *RatingUpdate
  • func (ru *RatingUpdate) FetchRatings(userID uint64) (Ratings, error)
  • func (ru *RatingUpdate) InjectRating(next http.Handler, w http.ResponseWriter, r *http.Request)
  • func (ru *RatingUpdate) RatingUpdateHandler(next http.Handler) http.Handler
• type Ratings
• type ResponseCache
  • func (c *ResponseCache) AddResponse(request string, response *http.Response, body []byte)
  • func (c *ResponseCache) GetResponse(request string) (http.Response, []byte)
  • func (c *ResponseCache) RemoveResponse(request string)
  • func (c *ResponseCache) ResponseExists(request string) bool
• type StatsGetPrediction
  • func CreateStatsGetPrediction(GGStriveAPIURL string, client *http.Client, responseCache *ResponseCache) StatsGetPrediction
  • func (s *StatsGetPrediction) AsyncGetStats(body []byte, reqType StatsGetType)
  • func (s *StatsGetPrediction) HandleGetStats(w http.ResponseWriter, r *http.Request) bool
  • func (s *StatsGetPrediction) ProcessStatsQueue(queue chan *StatsGetTask)
  • func (s *StatsGetPrediction) StatsGetStateHandler(next http.Handler) http.Handler
• type StatsGetTask
  • func ExpectedRCodeCalls() []StatsGetTask
  • func ExpectedTitleScreenCalls() []StatsGetTask
• type StatsGetType
• type StriveAPIProxy
  • func CreateStriveProxy(listen string, GGStriveAPIURL string, PatchedAPIURL string, ...) *StriveAPIProxy
  • func (s *StriveAPIProxy) CacheInvalidationHandler(next http.Handler) http.Handler
  • func (s *StriveAPIProxy) HandleCachedRequest(request string, w http.ResponseWriter, r *http.Request)
  • func (s *StriveAPIProxy) HandleCatchall(w http.ResponseWriter, r *http.Request)
  • func (s *StriveAPIProxy) HandleGetBlock(w http.ResponseWriter, r *http.Request)
  • func (s *StriveAPIProxy) HandleGetEnv(w http.ResponseWriter, r *http.Request)
  • func (s *StriveAPIProxy) HandleGetFollow(w http.ResponseWriter, r *http.Request)
  • func (s *StriveAPIProxy) HandleGetNews(w http.ResponseWriter, r *http.Request)
  • func (s *StriveAPIProxy) HandleStatsSet(w http.ResponseWriter, r *http.Request)
  • func (s *StriveAPIProxy) Shutdown()
• type StriveAPIProxyOptions

Constants

const StatsGetWorkers = 5

Types

type CachedResponse

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

type CachingResponseWriter

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

func (*CachingResponseWriter) Header

func (rw *CachingResponseWriter) Header() http.Header

func (*CachingResponseWriter) Write

func (rw *CachingResponseWriter) Write(data []byte) (int, error)

func (*CachingResponseWriter) WriteHeader

func (rw *CachingResponseWriter) WriteHeader(statusCode int)

type PredictionState

type PredictionState int

type Rating

type Rating struct {
	Value     float64
	Deviation float64
}

type RatingUpdate

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

func NewRatingUpdate

func NewRatingUpdate() *RatingUpdate

func (*RatingUpdate) FetchRatings

func (ru *RatingUpdate) FetchRatings(userID uint64) (Ratings, error)

func (*RatingUpdate) InjectRating

func (ru *RatingUpdate) InjectRating(next http.Handler, w http.ResponseWriter, r *http.Request)

func (*RatingUpdate) RatingUpdateHandler

func (ru *RatingUpdate) RatingUpdateHandler(next http.Handler) http.Handler

type Ratings

type Ratings []Rating

type ResponseCache

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

func (*ResponseCache) AddResponse

func (c *ResponseCache) AddResponse(request string, response *http.Response, body []byte)

func (*ResponseCache) GetResponse

func (c *ResponseCache) GetResponse(request string) (http.Response, []byte)

func (*ResponseCache) RemoveResponse

func (c *ResponseCache) RemoveResponse(request string)

func (*ResponseCache) ResponseExists

func (c *ResponseCache) ResponseExists(request string) bool

type StatsGetPrediction

type StatsGetPrediction struct {
	GGStriveAPIURL string

	PredictReplay bool
	// contains filtered or unexported fields
}

func CreateStatsGetPrediction

func CreateStatsGetPrediction(GGStriveAPIURL string, client *http.Client, responseCache *ResponseCache) StatsGetPrediction

func (*StatsGetPrediction) AsyncGetStats

func (s *StatsGetPrediction) AsyncGetStats(body []byte, reqType StatsGetType)

func (*StatsGetPrediction) HandleGetStats

func (s *StatsGetPrediction) HandleGetStats(w http.ResponseWriter, r *http.Request) bool

Proxy getstats

func (*StatsGetPrediction) ProcessStatsQueue

func (s *StatsGetPrediction) ProcessStatsQueue(queue chan *StatsGetTask)

Process the filled queue, then exit when it's empty

func (*StatsGetPrediction) StatsGetStateHandler

func (s *StatsGetPrediction) StatsGetStateHandler(next http.Handler) http.Handler

type StatsGetTask

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

func ExpectedRCodeCalls

func ExpectedRCodeCalls() []StatsGetTask

func ExpectedTitleScreenCalls

func ExpectedTitleScreenCalls() []StatsGetTask

type StatsGetType

type StatsGetType int

type StriveAPIProxy

type StriveAPIProxy struct {
	Client         *http.Client
	Server         *http.Server
	GGStriveAPIURL string
	PatchedAPIURL  string

	CacheEnv bool
	// contains filtered or unexported fields
}

func CreateStriveProxy

func CreateStriveProxy(listen string, GGStriveAPIURL string, PatchedAPIURL string, options *StriveAPIProxyOptions) *StriveAPIProxy

func (*StriveAPIProxy) CacheInvalidationHandler

func (s *StriveAPIProxy) CacheInvalidationHandler(next http.Handler) http.Handler

Invalidate cache if certain requests are used

func (*StriveAPIProxy) HandleCachedRequest

func (s *StriveAPIProxy) HandleCachedRequest(request string, w http.ResponseWriter, r *http.Request)

Generic handler func for cached requests

func (*StriveAPIProxy) HandleCatchall

func (s *StriveAPIProxy) HandleCatchall(w http.ResponseWriter, r *http.Request)

Proxy everything else

func (*StriveAPIProxy) HandleGetBlock

func (s *StriveAPIProxy) HandleGetBlock(w http.ResponseWriter, r *http.Request)

UNSAFE: Cache get_block on first request. On every other request return the cached value.

func (*StriveAPIProxy) HandleGetEnv

func (s *StriveAPIProxy) HandleGetEnv(w http.ResponseWriter, r *http.Request)

GGST uses the URL from this API after initial launch so we need to intercept this.

func (*StriveAPIProxy) HandleGetFollow

func (s *StriveAPIProxy) HandleGetFollow(w http.ResponseWriter, r *http.Request)

UNSAFE: Cache get_follow on first request. On every other request return the cached value.

func (*StriveAPIProxy) HandleGetNews

func (s *StriveAPIProxy) HandleGetNews(w http.ResponseWriter, r *http.Request)

UNSAFE: Cache news on first request. On every other request return the cached value.

func (*StriveAPIProxy) HandleStatsSet

func (s *StriveAPIProxy) HandleStatsSet(w http.ResponseWriter, r *http.Request)

UNSAFE HandleStatsSet is the handler for buffered stats/set so the stats can be flushed asynchronously from the game.

func (*StriveAPIProxy) Shutdown

func (s *StriveAPIProxy) Shutdown()

type StriveAPIProxyOptions

type StriveAPIProxyOptions struct {
	AsyncStatsSet   bool
	PredictStatsGet bool
	CacheNews       bool
	NoNews          bool
	PredictReplay   bool
	CacheEnv        bool
	CacheFollow     bool
	RatingUpdate    bool
}