orders.go

package goanda

// Supporting OANDA docs - http://developer.oanda.com/rest-live-v20/order-ep/

import (
	"encoding/json"
	"time"
)

type OrderExtensions struct {
	Comment string `json:"comment,omitempty"`
	ID      string `json:"id,omitempty"`
	Tag     string `json:"tag,omitempty"`
}

type OnFill struct {
	TimeInForce string `json:"timeInForce,omitempty"`
	Price       string `json:"price,omitempty"` // must be a string for float precision
}

type OnFill_Trailing_SL struct {
	TimeInForce string `json:"timeInForce,omitempty"`
	Distance    string `json:"distance,omitempty"` // must be a string for float precision
}

type OrderBody struct {
	Units                    string                     `json:"units,omitempty"`
	Instrument               string                     `json:"instrument,omitempty"`
	TimeInForce              string                     `json:"timeInForce,omitempty"`
	Type                     string                     `json:"type"`
	PositionFill             string                     `json:"positionFill,omitempty"`
	Price                    string                     `json:"price,omitempty"`
	TakeProfitOnFill         *OnFill                    `json:"takeProfitOnFill,omitempty"`
	StopLossOnFill           *OnFill                    `json:"stopLossOnFill,omitempty"`
	TrailingStopLossOnFill   *OnFill_Trailing_SL        `json:"trailingStopLossOnFill,omitempty"`
	Distance                 string                     `json:"distance,omitempty"`
	ClientExtensions         *OrderExtensions           `json:"clientExtensions,omitempty"`
	TradeID                  string                     `json:"tradeID,omitempty"`
}

type OrderPayload struct {
	Order OrderBody `json:"order"`
}
type OrderResponse struct {
	LastTransactionID      string `json:"lastTransactionID"`
	OrderCreateTransaction struct {
		AccountID    string    `json:"accountID"`
		BatchID      string    `json:"batchID"`
		ID           string    `json:"id"`
		Instrument   string    `json:"instrument"`
		PositionFill string    `json:"positionFill"`
		Reason       string    `json:"reason"`
		Time         time.Time `json:"time"`
		TimeInForce  string    `json:"timeInForce"`
		Type         string    `json:"type"`
		Units        string    `json:"units"`
		UserID       int       `json:"userID"`
	} `json:"orderCreateTransaction"`
	OrderFillTransaction struct {
		AccountBalance string    `json:"accountBalance"`
		AccountID      string    `json:"accountID"`
		BatchID        string    `json:"batchID"`
		Financing      string    `json:"financing"`
		ID             string    `json:"id"`
		Instrument     string    `json:"instrument"`
		OrderID        string    `json:"orderID"`
		Pl             string    `json:"pl"`
		Price          string    `json:"price"`
		Reason         string    `json:"reason"`
		Time           time.Time `json:"time"`
		TradeOpened    struct {
			TradeID string `json:"tradeID"`
			Units   string `json:"units"`
		} `json:"tradeOpened"`
		Type   string `json:"type"`
		Units  string `json:"units"`
		UserID int    `json:"userID"`
	} `json:"orderFillTransaction"`
	RelatedTransactionIDs []string `json:"relatedTransactionIDs"`
}

type OrderInfo struct {
	ClientExtensions struct {
		Comment string `json:"comment,omitempty"`
		ID      string `json:"id,omitempty"`
		Tag     string `json:"tag,omitempty"`
	} `json:"clientExtensions,omitempty"`
	CreateTime       time.Time `json:"createTime"`
	ID               string    `json:"id"`
	Instrument       string    `json:"instrument,omitempty"`
	PartialFill      string    `json:"partialFill"`
	PositionFill     string    `json:"positionFill"`
	Price            string    `json:"price"`
	ReplacesOrderID  string    `json:"replacesOrderID,omitempty"`
	State            string    `json:"state"`
	TimeInForce      string    `json:"timeInForce"`
	TriggerCondition string    `json:"triggerCondition"`
	Type             string    `json:"type"`
	Units            string    `json:"units,omitempty"`
}

type RetrievedOrders struct {
	LastTransactionID string      `json:"lastTransactionID"`
	Orders            []OrderInfo `json:"orders,omitempty"`
}

type RetrievedOrder struct {
	Order OrderInfo `json:"order"`
}

type CancelledOrder struct {
	OrderCancelTransaction struct {
		ID                string    `json:"id"`
		Time              time.Time `json:"time"`
		UserID            int       `json:"userID"`
		AccountID         string    `json:"accountID"`
		BatchID           string    `json:"batchID"`
		RequestID         string    `json:"requestID"`
		Type              string    `json:"type"`
		OrderID           string    `json:"orderID"`
		ClientOrderID     string    `json:"clientOrderID"`
		Reason            string    `json:"reason"`
		ReplacedByOrderID string    `json:"replacedByOrderID"`
	} `json:"orderCancelTransaction"`
	RelatedTransactionIDs []string `json:"relatedTransactionIDs"`
	LastTransactionID     string   `json:"lastTransactionID"`
}

func (c *OandaConnection) CreateOrder(body OrderPayload) (OrderResponse, error, error) {
	endpoint := "v3/accounts/" + c.AccountID + "/orders"
	jsonBody, _ := json.Marshal(body)
	response, err1, err2 := c.Send(endpoint, jsonBody)
	data := OrderResponse{}
	_ = unmarshalJson(response, &data)

	return data, err1, err2
}

func (c *OandaConnection) GetOrders(instrument string) (RetrievedOrders, error, error) {
	endpoint := "v3/accounts/" + c.AccountID + "/orders"

	if instrument != "" {
		endpoint = endpoint + "?instrument=" + instrument
	}

	response, err1, err2 := c.Request(endpoint)
	data := RetrievedOrders{}
	_ = unmarshalJson(response, &data)

	return data, err1, err2
}

func (c *OandaConnection) GetPendingOrders() (RetrievedOrders, error, error) {
	endpoint := "v3/accounts/" + c.AccountID + "/pendingOrders"

	response, err1, err2 := c.Request(endpoint)
	data := RetrievedOrders{}
	_ = unmarshalJson(response, &data)

	return data, err1, err2

}

func (c *OandaConnection) GetOrder(orderSpecifier string) (RetrievedOrder, error, error) {
	endpoint := "v3/accounts/" + c.AccountID + "/orders/" + orderSpecifier

	response, err1, err2 := c.Request(endpoint)
	data := RetrievedOrder{}
	_ = unmarshalJson(response, &data)

	return data, err1, err2

}

func (c *OandaConnection) UpdateOrder(orderSpecifier string, body OrderPayload) (RetrievedOrder, error, error) {
	endpoint := "v3/accounts/" + c.AccountID + "/orders/" + orderSpecifier
	jsonBody, _ := json.Marshal(body)
	//checkErr(err)
	response, err1, err2 := c.Update(endpoint, jsonBody)
	data := RetrievedOrder{}
	_ = unmarshalJson(response, &data)

	return data, err1, err2
}

func (c *OandaConnection) CancelOrder(orderSpecifier string) (CancelledOrder, error, error) {
	endpoint := "v3/accounts/" + c.AccountID + "/orders/" + orderSpecifier + "/cancel"
	response, err1, err2 := c.Update(endpoint, nil)
	data := CancelledOrder{}
	_ = unmarshalJson(response, &data)

	return data, err1, err2

}