get_followees.go

package audiusclient

import (
	"encoding/json"
	"errors"
	"io/ioutil"
	"net/http"
	"net/url"
	"strconv"
)

type GetFolloweesResponse struct {
	Data []APIUser
}

func (c *Client) GetFollowees(userID string, limit uint64, offset uint64) (GetFolloweesResponse, error) {
	var getFolloweesResponse GetFolloweesResponse

	// Build the query:
	query := url.Values{}
	query.Add("limit", strconv.FormatUint(limit, 10))
	query.Add("offset", strconv.FormatUint(offset, 10))
	query.Add("user_id", userID)

	// Select an audius host:
	selectedHostURL, err := c.GetHost()
	if err != nil {
		return getFolloweesResponse, err
	}
	requestURL := *selectedHostURL
	requestURL.Path = "/v1/full/users/" + userID + "/following"
	requestURL.RawQuery = query.Encode()

	// Create the request:
	urlString := requestURL.String()
	req, err := http.NewRequest("GET", urlString, nil)
	if err != nil {
		return getFolloweesResponse, err
	}

	// Make the request:
	res, err := httpClient.Do(req)
	if err != nil {
		return getFolloweesResponse, err
	}
	defer res.Body.Close()
	if res.StatusCode != 200 {
		// Parse the error:
		body, err := ioutil.ReadAll(res.Body)
		if err != nil {
			return getFolloweesResponse, err
		}
		err = errors.New(string(body))

		return getFolloweesResponse, err
	}

	// Decode the body:
	err = json.NewDecoder(res.Body).Decode(&getFolloweesResponse)
	if err != nil {
		return getFolloweesResponse, err
	}

	return getFolloweesResponse, nil
}