d0zingcat/gocryptotrader
1
0
Fork 0
mirror of https://github.com/d0zingcat/gocryptotrader.git synced 2026-05-22 23:16:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

Improved itBit implementation.

Browse Source
This commit is contained in:
Adrian Gallagher
2015-04-29 23:44:36 +10:00
parent 7806f09d99
commit 0d23b68b15
3 changed files with 42 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
config_example.json
View File

@@ -117,6 +117,7 @@
"Pairs": "XBTUSD,XBTSGD,XBTEUR",
"APIKey": "Key",
"APISecret": "Secret",
"ClientID": "ClientID",
"BaseCurrencies": "USD,SGD,EUR",
"Enabled": true,
"Verbose": false,

65
itbithttp.go
View File

@@ -4,6 +4,7 @@ import (
"strconv"
"bytes"
"errors"
"net/url"
"time"
"log"
)
@@ -65,9 +66,10 @@ func (i *ItBit) IsEnabled() (bool) {
return i.Enabled
}
func (i *ItBit) SetAPIKeys(apiKey, apiSecret string) {
func (i *ItBit) SetAPIKeys(apiKey, apiSecret, userID string) {
i.ClientKey = apiKey
i.APISecret = apiSecret
i.UserID = userID
}
func (i *ItBit) GetFee(maker bool) (float64) {
@@ -83,7 +85,6 @@ func (i *ItBit) Run() {
log.Printf("%s polling delay: %ds.\n", i.GetName(), i.RESTPollingDelay)
}
i.GetWallet("?")
for i.Enabled {
go func() {
ItbitBTC := i.GetTicker("XBTUSD")
@@ -125,14 +126,26 @@ func (i *ItBit) GetTradeHistory(currency, timestamp string) (bool) {
return true
}
func (i *ItBit) GetWallets(page int64, perPage int64, userID string) {
path := "/wallets/"
params := make(map[string]interface{})
params["page"] = strconv.FormatInt(page, 10)
params["perPage"] = strconv.FormatInt(perPage, 10)
params["userID"] = userID
func (i *ItBit) GetWallets(params url.Values) {
params.Set("userId", i.UserID)
path := "/wallets?" + params.Encode()
err := i.SendAuthenticatedHTTPRequest("GET", path, params)
log.Println(path)
return
err := i.SendAuthenticatedHTTPRequest("GET", path, nil)
if err != nil {
log.Println(err)
}
}
func (i *ItBit) CreateWallet(walletName string) {
path := "/wallets"
params := make(map[string]interface{})
params["userId"] = i.UserID
params["name"] = walletName
err := i.SendAuthenticatedHTTPRequest("POST", path, params)
if err != nil {
log.Println(err)
@@ -157,37 +170,35 @@ func (i *ItBit) GetWalletBalance(walletID, currency string) {
}
}
func (i *ItBit) GetWalletTrades(walletID string, page int64, perPage int64, rangeEnd int64, rangeStart int64) {
func (i *ItBit) GetWalletTrades(walletID string, params url.Values) {
path := "/wallets/" + walletID + "/trades"
params := make(map[string]interface{})
params["page"] = strconv.FormatInt(page, 10)
params["perPage"] = strconv.FormatInt(perPage, 10)
params["rangeEnd"] = strconv.FormatInt(page, 10)
params["rangeStart"] = strconv.FormatInt(perPage, 10)
err := i.SendAuthenticatedHTTPRequest("GET", path, params)
if len(params) > 0 {
path += "?" + params.Encode()
}
err := i.SendAuthenticatedHTTPRequest("GET", path, nil)
if err != nil {
log.Println(err)
}
}
func (i *ItBit) GetWalletOrders(walletID string, instrument string, page int64, perPage int64, status string) {
func (i *ItBit) GetWalletOrders(walletID string, params url.Values) {
path := "/wallets/" + walletID + "/orders"
params := make(map[string]interface{})
params["instrument"] = instrument
params["page"] = strconv.FormatInt(page, 10)
params["perPage"] = strconv.FormatInt(perPage, 10)
params["status"] = status
err := i.SendAuthenticatedHTTPRequest("GET", path, params)
if len(params) > 0 {
path += "?" + params.Encode()
}
err := i.SendAuthenticatedHTTPRequest("GET", path, nil)
if err != nil {
log.Println(err)
}
}
func (i *ItBit) PlaceWalletOrder(walletID, side, orderType, currency string, amount, price float64, instrument string) {
func (i *ItBit) PlaceWalletOrder(walletID, side, orderType, currency string, amount, price float64, instrument string, clientRef string) {
path := "/wallets/" + walletID + "/orders"
params := make(map[string]interface{})
params["side"] = side
@@ -197,6 +208,10 @@ func (i *ItBit) PlaceWalletOrder(walletID, side, orderType, currency string, amo
params["price"] = strconv.FormatFloat(price, 'f', 2, 64)
params["instrument"] = instrument
if clientRef != "" {
params["clientOrderIdentifier"] = clientRef
}
err := i.SendAuthenticatedHTTPRequest("POST", path, params)
if err != nil {
@@ -226,7 +241,7 @@ func (i *ItBit) PlaceWithdrawalRequest(walletID, currency, address string, amoun
path := "/wallets/" + walletID + "/cryptocurrency_withdrawals"
params := make(map[string]interface{})
params["currency"] = currency
params["amount"] = strconv.FormatFloat(amount, 'f', 8, 64)
params["amount"] = amount
params["address"] = address
err := i.SendAuthenticatedHTTPRequest("POST", path, params)

2
main.go
View File

@@ -222,7 +222,7 @@ func main() {
if !exch.Enabled {
bot.exchange.itbit.SetEnabled(false)
} else {
bot.exchange.itbit.SetAPIKeys(exch.APIKey, exch.APISecret)
bot.exchange.itbit.SetAPIKeys(exch.APIKey, exch.APISecret, exch.ClientID)
bot.exchange.itbit.RESTPollingDelay = exch.RESTPollingDelay
bot.exchange.itbit.Verbose = exch.Verbose
bot.exchange.itbit.Websocket = exch.Websocket