paypal/billing.go

package paypalsdk

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

// ActivatePlan activates a billing plan.
// By default, a new plan is not activated.
// Endpoint: PATCH /v1/payments/billing-plans/
func (c *Client) ActivatePlan(planID string) error {
	buf := bytes.NewBuffer([]byte("[{\"op\":\"replace\",\"path\":\"/\",\"value\":{\"state\":\"ACTIVE\"}}]"))
	req, err := http.NewRequest("PATCH", fmt.Sprintf("%s%s", c.APIBase, "/v1/payments/billing-plans/"+planID), buf)
	if err != nil {
		return err
	}
	return c.SendWithAuth(req, nil)
}

// CancelAgreement cancels a billing agreement.
// Endpoint: POST /v1/payments/billing-agreements/{agreement_id}/cancel
func (c *Client) CancelAgreement(agreementID string) error {
	buf := bytes.NewBuffer([]byte(`{"note": "Canceling the profile."}`))
	req, err := http.NewRequest("POST", fmt.Sprintf("%s%s", c.APIBase, "/v1/payments/billing-agreements/"+agreementID+"/cancel"), buf)
	if err != nil {
		return err
	}

	err = c.SendWithAuth(req, nil)

	// A successful request returns the HTTP 204 No Content status code with no JSON response body.
	// This raises error "EOF"
	if err != nil && err.Error() == "EOF" {
		return nil
	}

	return err
}

// CreateBillingPlan creates a billing plan in Paypal.
// Endpoint: POST /v1/payments/billing-plans
func (c *Client) CreateBillingPlan(plan BillingPlan) (*BillingPlan, error) {
	req, err := c.NewRequest("POST", fmt.Sprintf("%s%s", c.APIBase, "/v1/payments/billing-plans"), plan)
	response := &BillingPlan{}
	if err != nil {
		return response, err
	}
	err = c.SendWithAuth(req, response)
	return response, err
}

// CreateBillingAgreement creates an agreement for specified plan.
// Endpoint: POST /v1/payments/billing-agreements
func (c *Client) CreateBillingAgreement(a BillingAgreement) (*BillingAgreement, error) {
	// PayPal needs only ID, so we will remove all fields except Plan ID
	a.Plan = BillingPlan{
		ID: a.Plan.ID,
	}

	req, err := c.NewRequest("POST", fmt.Sprintf("%s%s", c.APIBase, "/v1/payments/billing-agreements"), a)
	response := &BillingAgreement{}
	if err != nil {
		return response, err
	}
	err = c.SendWithAuth(req, response)
	return response, err
}

// DeletePlan deletes a billing plan.
// Endpoint: PATCH /v1/payments/billing-plans/
func (c *Client) DeletePlan(planID string) error {
	buf := bytes.NewBuffer([]byte("[{\"op\":\"replace\",\"path\":\"/\",\"value\":{\"state\":\"DELETED\"}}]"))
	req, err := http.NewRequest("PATCH", fmt.Sprintf("%s%s", c.APIBase, "/v1/payments/billing-plans/"+planID), buf)
	if err != nil {
		return err
	}
	return c.SendWithAuth(req, nil)
}

// ExecuteApprovedAgreement - Use this call to execute (complete) a PayPal agreement that has been approved by the payer.
// Endpoint: POST /v1/payments/billing-agreements/token/agreement-execute
func (c *Client) ExecuteApprovedAgreement(token string) (*BillingAgreement, error) {
	req, err := http.NewRequest("POST", fmt.Sprintf("%s%s", c.APIBase, "/v1/payments/billing-agreements/"+token+"/agreement-execute"), nil)
	if err != nil {
		return &BillingAgreement{}, err
	}

	e := BillingAgreement{}

	if err = c.SendWithAuth(req, &e); err != nil {
		return &e, err
	}

	if e.ID == "" {
		return &e, errors.New("Unable to execute agreement with token=" + token)
	}

	return &e, err
}

// ListBillingPlans - Lists billing plans.
// Valid values for status: "CREATED", "ACTIVE", "INACTIVE".
// Endpoint: GET /v1/payments/billing-plans/
func (c *Client) ListBillingPlans(status interface{}, page interface{}) (*ListBillingPlansResp, error) {
	if status == nil {
		status = "CREATED"
	}
	if page == nil {
		page = "0"
	}
	req, err := http.NewRequest("GET", fmt.Sprintf("%s%s", c.APIBase, "/v1/payments/billing-plans?total_required=yes&status="+status.(string)+"&page="+page.(string)), nil)
	if err != nil {
		return &ListBillingPlansResp{}, err
	}

	l := ListBillingPlansResp{}

	err = c.SendWithAuth(req, &l)

	// A successful request for empty list returns the HTTP 204 No Content status code with no JSON response body.
	// This raises error "EOF"
	if err != nil && err.Error() == "EOF" {
		return &l, nil
	}

	return &l, err
}

// ReactivateAgreement reactivates a suspended billing agreement.
// Endpoint: POST /v1/payments/billing-agreements/{agreement_id}/re-activate
func (c *Client) ReactivateAgreement(agreementID string) error {
	buf := bytes.NewBuffer([]byte(`{"note": "Reactivating the profile."}`))
	req, err := http.NewRequest("POST", fmt.Sprintf("%s%s", c.APIBase, "/v1/payments/billing-agreements/"+agreementID+"/re-activate"), buf)
	if err != nil {
		return err
	}

	err = c.SendWithAuth(req, nil)

	// A successful request returns the HTTP 204 No Content status code with no JSON response body.
	// This raises error "EOF"
	if err != nil && err.Error() == "EOF" {
		return nil
	}

	return err
}

// SuspendAgreement suspends a billing agreement.
// Endpoint: POST /v1/payments/billing-agreements/{agreement_id}/suspend
func (c *Client) SuspendAgreement(agreementID string) error {
	buf := bytes.NewBuffer([]byte(`{"note": "Suspending the profile."}`))
	req, err := http.NewRequest("POST", fmt.Sprintf("%s%s", c.APIBase, "/v1/payments/billing-agreements/"+agreementID+"/suspend"), buf)
	if err != nil {
		return err
	}

	err = c.SendWithAuth(req, nil)

	// A successful request returns the HTTP 204 No Content status code with no JSON response body.
	// This raises error "EOF"
	if err != nil && err.Error() == "EOF" {
		return nil
	}

	return err
}