Skip to content
/ oanda Public

This project is an implementation of the new V20 REST API from Oanda in Go

License

Notifications You must be signed in to change notification settings

nii236/oanda

Repository files navigation

Go Report Card Build Status

Oanda Client API

Oanda released V20 of their REST API recently, and there has been no implementations of it yet for Go. This is an attempt at filling that gap.

Installation

Get the package:

brew install glide
go get -d github.com/nii236/oanda
cd $GOPATH/src/github.com/nii236/oanda/
glide install

Usage

Only the following endpoints have been implemented so far:

  • Accounts - List Accounts
  • Pricing - Current Prices

Write your main program. This example will poll every single for the latest ticker data.

package main

import (
	"time"

	"github.com/Sirupsen/logrus"
	"github.com/nii236/oanda"
	"github.com/spf13/pflag"
	"github.com/spf13/viper"
)

type pairslice []string

var pairs pairslice
var log *logrus.Logger

func init() {
	viper.SetDefault("token", "")
	viper.SetDefault("account", "")
	viper.SetDefault("pairs", []string{"EUR_USD"})

	pflag.StringP("token", "t", "", "Access token from Oanda")
	pflag.StringP("account", "a", "", "Account ID from Oanda")
	pflag.StringSliceP("pairs", "p", []string{"EUR_USD", "AUD_USD"}, "Slice of pairs to subscribe")
	pflag.BoolP("help", "h", false, "Prints the help text")
	viper.BindPFlag("token", pflag.Lookup("token"))
	viper.BindPFlag("account", pflag.Lookup("account"))
	viper.BindPFlag("pairs", pflag.Lookup("pairs"))
	viper.BindPFlag("help", pflag.Lookup("help"))

	pflag.Parse()

	viper.SetEnvPrefix("OANDA")
	viper.BindEnv("token")
	viper.BindEnv("account")
	viper.BindEnv("pairs")

	log = logrus.New()
}

func main() {
	if viper.GetBool("help") {
		pflag.PrintDefaults()
		return
	}
	token := viper.GetString("token")
	account := viper.GetString("account")
	pairs := viper.GetStringSlice("pairs")

	log.Infoln("token:", token)
	log.Infoln("account:", account)
	log.Infoln("pairs:", pairs)

	if token == "" || account == "" {
		log.Error("Need token and account.")
		return
	}

	c, err := oanda.NewFxPracticeClient(token)
	if err != nil {
		log.Errorln(err)
		return
	}

	t := time.NewTicker(1 * time.Second)

	for {
		select {
		case <-t.C:
			log.Infoln("Fetching latest prices...")
			p, err := c.GetPrices(account, pairs, "")
			if err != nil {
				log.Errorln(err)
				t.Stop()
				return
			}
			for _, price := range p.Prices {

				log.Infoln("Instrument:", price.InstrumentName)
				log.Infoln("Status:", price.Status)
				t, err := time.Parse(time.RFC3339Nano, price.Time)
				if err != nil {
					log.Infoln("Could not parse time")
				}
				log.Infoln("Time:", t.Local())
				log.Infoln("Asks:")
				for _, ask := range price.Asks {
					log.Infoln("	Price:", ask.Price, "Liquidity:", ask.Liquidity)
				}
				log.Infoln("Bids:")
				for _, bid := range price.Bids {
					log.Infoln("	Price:", bid.Price, "Liquidity:", bid.Liquidity)
				}
			}

		}

	}
}

Contributing

Help is needed implementing all of the REST API endpoints. They are listed in interfaces.go.

  1. Fork it!
  2. Create your feature branch: git checkout -b my-new-feature
  3. Commit your changes: git commit -am 'Add some feature'
  4. Push to the branch: git push origin my-new-feature
  5. Submit a pull request

About

This project is an implementation of the new V20 REST API from Oanda in Go

Resources

License

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages