stash_tabs.go

package poeapi

import (
	"encoding/json"
	"fmt"
	"net/url"
)

// GetStashOptions contains the request parameters for the stash endpoint.
type GetStashOptions struct {
	// ID is the unique change ID containing a set of stashes. If ID is omitted,
	// the API will return the oldest stash tab possible.
	ID string
}

func (opts GetStashOptions) toQueryParams() string {
	u := url.Values{}
	if opts.ID != "" {
		u.Add("id", opts.ID)
	}
	return u.Encode()
}

func (c *client) GetStashes(opts GetStashOptions) (StashResponse, error) {
	url := fmt.Sprintf("%s?%s", c.formatURL(stashTabsEndpoint),
		opts.toQueryParams())
	resp, err := c.get(url)
	if err != nil {
		return StashResponse{}, err
	}
	return parseStashResponse(resp)
}

func parseStashResponse(resp string) (StashResponse, error) {
	var s StashResponse
	if err := json.Unmarshal([]byte(resp), &s); err != nil {
		return StashResponse{}, err
	}
	return s, nil
}

type latestChange struct {
	ID string `json:"next_change_id"`
}

func (c *client) GetLatestStashID() (string, error) {
	var url string
	if c.useSSL {
		url = fmt.Sprintf("https://%s/api/Data/GetStats", c.ninjaHost)
	} else {
		url = fmt.Sprintf("http://%s/api/Data/GetStats", c.ninjaHost)
	}

	resp, err := c.get(url)
	if err != nil {
		return "", err
	}
	return parseLatestChangeResponse(resp)
}

func parseLatestChangeResponse(resp string) (string, error) {
	var latest latestChange
	if err := json.Unmarshal([]byte(resp), &latest); err != nil {
		return "", err
	}
	return latest.ID, nil
}