This repository has been archived on 2023-04-13. You can view files and clone it, but cannot push or open issues or pull requests.
go-discogs/discogs.go

95 lines
1.9 KiB
Go
Raw Normal View History

2016-03-04 16:08:02 +00:00
package discogs
import (
2018-03-12 16:30:58 +00:00
"encoding/json"
"io/ioutil"
2016-03-04 16:08:02 +00:00
"net/http"
2018-03-12 16:30:58 +00:00
"net/url"
2016-03-04 16:08:02 +00:00
)
const (
2018-03-21 18:17:40 +00:00
discogsAPI = "https://api.discogs.com"
2016-03-04 16:08:02 +00:00
)
2018-03-17 20:12:25 +00:00
// Options is a set of options to use discogs API client
2018-02-20 15:13:04 +00:00
type Options struct {
2018-02-20 17:00:24 +00:00
URL string
2018-02-20 15:13:04 +00:00
Currency string
UserAgent string
2018-02-20 15:16:34 +00:00
Token string
2018-02-20 15:13:04 +00:00
}
2016-03-04 16:08:02 +00:00
// Client is a Discogs client for making Discogs API requests.
type Client struct {
2018-03-21 18:17:40 +00:00
Database *DatabaseService
Search *SearchService
2016-03-04 16:08:02 +00:00
}
2018-03-12 16:30:58 +00:00
var header *http.Header
2016-03-04 16:08:02 +00:00
// NewClient returns a new Client.
2018-02-20 15:13:04 +00:00
func NewClient(o *Options) (*Client, error) {
2018-03-12 16:30:58 +00:00
header = &http.Header{}
if o == nil || o.UserAgent == "" {
2018-03-24 13:14:54 +00:00
return nil, ErrUserAgentInvalid
2018-02-20 15:13:04 +00:00
}
2017-04-25 16:39:32 +00:00
2018-03-12 16:30:58 +00:00
header.Add("User-Agent", o.UserAgent)
2018-02-20 15:13:04 +00:00
cur, err := currency(o.Currency)
if err != nil {
return nil, err
2016-03-04 16:08:02 +00:00
}
2018-02-20 15:13:04 +00:00
2018-02-20 15:16:34 +00:00
// set token, it's required for some queries like search
if o.Token != "" {
2018-02-20 16:26:00 +00:00
header.Add("Authorization", "Discogs token="+o.Token)
2018-02-20 15:16:34 +00:00
}
2018-02-20 15:13:04 +00:00
2018-03-12 16:30:58 +00:00
if o.URL == "" {
o.URL = discogsAPI
}
2018-02-20 15:16:34 +00:00
return &Client{
2018-03-21 18:17:40 +00:00
Database: newDatabaseService(o.URL, cur),
Search: newSearchService(o.URL + "/database/search"),
2018-02-20 15:13:04 +00:00
}, nil
2016-03-04 16:08:02 +00:00
}
2017-04-25 16:39:32 +00:00
2018-02-20 15:13:04 +00:00
// currency validates currency for marketplace data.
2017-04-25 16:39:32 +00:00
// Defaults to the authenticated users currency. Must be one of the following:
// USD GBP EUR CAD AUD JPY CHF MXN BRL NZD SEK ZAR
2018-02-20 15:13:04 +00:00
func currency(c string) (string, error) {
switch c {
2017-04-26 12:57:03 +00:00
case "USD", "GBP", "EUR", "CAD", "AUD", "JPY", "CHF", "MXN", "BRL", "NZD", "SEK", "ZAR":
2018-02-20 15:13:04 +00:00
return c, nil
2018-02-20 17:00:24 +00:00
case "":
return "USD", nil
2017-04-26 12:57:03 +00:00
default:
2018-03-24 13:14:54 +00:00
return "", ErrCurrencyNotSupported
2017-04-26 12:57:03 +00:00
}
2017-04-25 16:39:32 +00:00
}
2018-03-12 16:30:58 +00:00
func request(path string, params url.Values, resp interface{}) error {
r, err := http.NewRequest("GET", path+"?"+params.Encode(), nil)
if err != nil {
return err
}
r.Header = *header
client := &http.Client{}
response, err := client.Do(r)
if err != nil {
return err
}
defer response.Body.Close()
2018-03-12 16:30:58 +00:00
body, err := ioutil.ReadAll(response.Body)
if err != nil {
return err
}
return json.Unmarshal(body, &resp)
}