auth.go

package pocketcasts

import (
	"bytes"
	"encoding/json"
	"errors"
	"fmt"
	"net/http"
)

const endpointSignin = "https://play.pocketcasts.com/users/sign_in"

type Connection struct{}

// NewConnection creates a new connection to the PocketCasts API.
func NewConnection() *Connection {
	return &Connection{}
}

type AuthedConnection struct {
	Client *http.Client
	*Connection
}

var ErrorInvalidUsernameOrPassword = errors.New("invalid username or password")

// Authenticate authenticates a user with the PocketCasts API
// and returns an AuthedConnection.
func (con *Connection) Authenticate(email, password string) (*AuthedConnection, error) {
	type authRequest struct {
		Email    string `json:"email"`
		Password string `json:"password"`
		Scope    string `json:"scope"`
	}

	type authSuccess struct {
		Token string `json:"token"`
		UUID  string `json:"uuid"`
	}

	aReq := authRequest{
		Email:    email,
		Password: password,
		Scope:    "webplayer",
	}

	reqJSON, err := json.Marshal(aReq)
	if err != nil {
		return nil, err
	}

	body := bytes.NewBuffer(reqJSON)

	client := &http.Client{}

	req, err := http.NewRequest("POST", "https://api.pocketcasts.com/user/login", body)
	if err != nil {
		return nil, err
	}

	req.Header.Add("Content-Type", "application/json")

	resp, err := client.Do(req)
	if err != nil {
		return nil, err
	}
	defer resp.Body.Close()

	if resp.StatusCode == http.StatusUnauthorized {
		return nil, ErrorInvalidUsernameOrPassword
	}

	if resp.StatusCode != http.StatusOK {
		return nil, fmt.Errorf("request error: %s", resp.Status)
	}

	dec := json.NewDecoder(resp.Body)

	respSuccess := authSuccess{}
	err = dec.Decode(&respSuccess)
	if err != nil {
		return nil, err
	}

	client.Transport = tokenTransport{
		Token: respSuccess.Token,
	}

	return &AuthedConnection{
		Client:     client,
		Connection: con,
	}, nil
}

type tokenTransport struct {
	Token string
}

func (t tokenTransport) RoundTrip(r *http.Request) (*http.Response, error) {
	r.Header.Add("Authorization", "Bearer "+t.Token)

	if r.Header.Get("Content-Type") == "" {
		r.Header.Add("Content-Type", "application/json")
	}

	resp, err := http.DefaultTransport.RoundTrip(r)

	return resp, err
}