FMZ Quant Trading Platform Protocolo personalizado Acesso a trocas personalizadas
Autora:FMZ~Lydia, Criado: 2023-07-12 15:29:54, Atualizado: 2024-01-03 21:01:07
FMZ Quant Trading Platform Protocolo personalizado Acesso a trocas personalizadas
Documentação de utilização de protocolo personalizado
Você pode usar este protocolo geral para acessar qualquer troca que forneça negociação de API, o protocolo específico de API não é limitado, seja descanso, websocket, correção... Tudo pode ser acessado para usar. Exemplo de protocolo personalizado Python:https://www.fmz.com/strategy/101399
Operação do plug-in de protocolo personalizado, configurações de porta
A configuração para o endereço de escuta e porta do http://127.0.0.1:6666/DigitalAssetouhttp://127.0.0.1:6666/exchange.
Por que precisamos de definir estesP.I.ecaminhos- O que é?
Isto é porque quandoadição de trocaPágina noPainel de instrumentos da plataforma quântica FMZ, selecionando a opção API-KEY. Este endereço de serviço informa ao docker onde acessar o IP e a porta (o docker e o programa de plug-in Custom Protocol podem não estar sendo executados no mesmo dispositivo).http://127.0.0.1:6666/DigitalAsset. DigitalAsseté apenas um exemplo e pode ser substituído por um nome de sua escolha.
No FMZ Quant Platformaccess keyesecret keyNo entanto, algumas interfaces de API requerem que a senha de negociação seja passada (por exemplo, a interface de colocação de ordens de certas trocas).secret key(ouaccess keyEntão, no programa Custom Protocol plugin, podemos executar uma cadeiasplitoperação para separar estes dados, como mostrado na imagem do exemplo.
E então no plugin, processá-lo para obterXXX_PassWord- Não.
Por exemplo, no exemplo completo no final deste post, na função newBitgo:
func newBitgo(accessKey, secretKey string) *iBitgo {
s := new(iBitgo)
s.accessKey = accessKey
s.secretKey = secretKey
// Additional configuration information in the secretKey can be separated here and can be written as in the following comment
/*
arr := strings.SplitN(secretKey, ",", 2)
if len(arr) != 2 {
panic("Configuration error!")
}
s.secretKey = arr[0] // secret key
s.passWord = arr[1] // XXX_PassWord
*/
s.apiBase = "https://www.bitgo.cn"
s.timeout = 20 * time.Second
s.timeLocation = time.FixedZone("Asia/Shanghai", 8*60*60)
return s
}
Analisando novamente os parâmetros nos dados de solicitação, o docker envia os dados de solicitação como:
"secret_key" : "XXX",
O plugin recebe os dados recebidos contendo esse tipo de informação e separa a XXX_PassWord dele com base no separador de vírgulas, de modo que ele recebe os dados adicionais passados.
Exemplo de um plugin de protocolo personalizado geralmainFunção:GoDescrição da língua:
func main(){
var addr = flag.String("b", "127.0.0.1:6666", "bing addr") // Set command line parameters, default value description, port setting 6666
flag.Parse() // Parsing the command line
if *addr == "" {
flag.Usage() // Display the command line description
return
}
basePath := "/DigitalAsset"
log.Println("Running ", fmt.Sprintf("http://%s%s", *addr, basePath), "...") // Print listening port information
http.HandleFunc(basePath, OnPost)
http.ListenAndServe(*addr, nil)
}
2. Função de resposta
O requestUma vez recebida uma solicitação, ela invoca a função de resposta para executar e depois analisa os parâmetros dos dados da solicitação.
/* JSON structure of request, FMZ Quant call GetTicker, docker sent to the custom protocol plugin case example (the value of params may be different for each API call, here the method is ticker):
{
"access_key" : "XXX", // `json:"access_key"`
"secret_key" : "XXX", // `json:"secret_key"`
"nonce" : "1502345965295519602", // `json:"nonce"`
"method" : "ticker", // `json:"method"`
"params" : { // `json:"params"`
"symbol" : "btc",
...
}, // The parameters are slightly different for each request. That is, different FMZ Quant APIs are called in the strategy with different parameters, which are described in the following sections for each API.
}
*/
Então, com base noMethodcampo norequestestrutura obtida por JSON deserializing a solicitação Corpo de dados recebidos no programa Universal Protocol Plugin, podemos usar umswitchdeclaração para categorizar e lidar com diferentes FMZ Quant APIs sendo chamadas no docker (ou seja, identificar quais FMZ QuantAPIA estratégia executada no docker está a invocar:
Exemplo emGoLíngua:
switch request.Method { // M of request.Method is capitalized here, the body of the request received by the custom protocol program for the JSON data, in the Go language, the anti-JSON serialization (Unmarshal) is a structure, the first letter of the field must be capitalized
case "accounts" : // When the exchange.GetAccount() function is called in the bot strategy on the docker, the docker sends in a request where the Body carries data with a method attribute value of accounts
data, err = e.GetAccount(symbol)
case "ticker" :
data, err = e.GetTicker(symbol)
case "depth" :
data, err = e.GetDepth(symbol)
case "trades" :
data, err = e.GetTrades(symbol)
case "trade" :
...
default:
...
Após a execução desses ramos, os dados retornados devem ser escritos na estrutura que o programa Custom Protocol Plugin usará para responder à solicitação do docker.
Exemplo na linguagem Go:
defer func(){ // Handling of closing work
if e := recover(); e != nil { // The recover() function is used to catch panic, e ! = nil, i.e. an error has occurred
if ee, ok := e.(error); ok { // Type derivation, successful derivation assigns ee.Error() to e
e = ee.Error() // Call the Error method to get the returned error string
}
ret = map[string]string{"error": fmt.Sprintf("%v", e)}
}
b, _ := json.Marshal(ret) // Encode the result obtained from this call, ret, assign it to b, and write it into the response pointer
w.Write(b)
//fmt.Println("after w.Write the b is", string(b)) // test
}()
3. Tipos de chamadas de API
Divididos grosso modo em duas categorias:
- Interfaces públicas que não requerem assinatura, por exemplo:
GetTicker()
GetDepth()
GetTrades()
GetRecords(period)
…
- Interfaces de utilizador que necessitam de assinatura, tais como:
Buy, Sell
GetOrder(id)
GetOrders()
GetAccount()
CancelOrder(id)- Não.
Os métodos de assinatura podem variar de troca para troca e precisam ser escritos especificamente de acordo com as necessidades.
4. O formato de dados para a interação entre o Custom Protocol Plugin e o docker ao chamar várias interfaces FMZ Quant API:
Algumas interfaces FMZ Quant API, tais como
GetName(),GetLabel(), etc., não enviem pedidos aoPlugin de protocolo personalizadoquando for chamado. Quando ligarexchange.GetName(), o exchange configurado no plugin universal retornaráExchange .
-
- GetTicker: Usado para obter os dados atuais do ticker.
Omethodemrequestenviado peloDockerpara a função de resposta de escuta éticker.
O docker envia o parâmetro:request.Params.symbol, que é enviado pelo docker com base na moeda definida na página do robô.
O formato de dados (JSON) transportado no corpo da solicitação quando o docker solicita o Custom Protocol Plugin
{
"access_key" : "access_key",
"secret_key" : "secret_key",
"nonce" : "1500793319499", // millisecond timestamp
"method" : "ticker",
"params" : {"symbol" : "ETH_BTC"}, // Take the ETH_BTC trading pair for example
}
Estrutura do valor de retorno final enviado ao docker: (ou seja, o formato em que os dados são devolvidos ao docker após a interface de troca ser solicitada pelo plug-in de protocolo comum)
Estrutura JSON
{
"data": {
"time": 1500793319499, // Millisecond timestamp, integer
"buy": 1000, // floating-point type as follows
"sell": 1001,
"last": 1005,
"high": 1100,
"low": 980,
"vol": 523,
}
}
-
- GetRecords: Usado para recuperar os dados de linha K fornecidos pela troca. (Com base nos parâmetros solicitados pelo docker)
Omethodemrequestenviado pelo docker para a função de resposta de escuta érecords.
O docker envia os parâmetros:request.Params.period, que está associado ao primeiro parâmetro doexchange.GetRecordsA função realrequest.Params.periodPor exemplo, o período diário é60*24, que é1440. request.Params.symbolé enviado pelo docker com base na moeda definida.
O formato de dados transportado no corpo da solicitação quando o docker solicita o Custom Protocol Plugin.
{
"access_key" : "access_key",
"secret_key" : "secret_key",
"nonce" : "1500793319499", // millisecond timestamp
"method" : "records",
"params" : {"symbol" : "ETH_BTC", "period" : "1440"}, // Example of an ETH_BTC pair with a daily K-period
}
Estrutura do valor de retorno final enviado ao docker:
Estrutura JSON
{
"data": [
[1500793319, 1.1, 2.2, 3.3, 4.4, 5.5], // "Time":1500793319000,"Open":1.1,"High":2.2,"Low":3.3,"Close":4.4,"Volume":5.5
[1500793259, 1.01, 2.02, 3.03, 4.04, 5.05],
...
]
}
Dados do teste de idiomas:
ret_records = []interface{}{
[6]interface{}{1500793319, 1.1, 2.2, 3.3, 4.4, 5.5},
[6]interface{}{1500793259, 1.01, 2.02, 3.03, 4.04, 5.05}
}
Plataforma quântica FMZLogDisplaysrecordsdados:
[
{"Time":1500793319000,"Open":1.1,"High":2.2,"Low":3.3,"Close":4.4,"Volume":5.5},
{"Time":1500793259000,"Open":1.01,"High":2.02,"Low":3.03,"Close":4.04,"Volume":5.05}
]
Nota: 1. O primeiro elemento da matriz bidimensional é de tipointO docker irá multiplicar automaticamente a marca de tempo por 1000, como mencionado acima.
-
- GetDepth: Retira as informações de profundidade (livro de pedidos, ask1, ask2... bid1, bid2...) da troca.
Omethodemrequestenviado pelo docker para a função de resposta de escuta édepth.
O docker envia o parâmetro:request.Params.symbol, que é enviado pelo docker com base na moeda definida na estratégia.
O formato de dados transportado no corpo da solicitação quando o docker solicita o Plugin de Protocolo Personalizado
{
"access_key" : "access_key",
"secret_key" : "secret_key",
"nonce" : "1500793319499", // millisecond timestamp
"method" : "depth",
"params" : {"symbol" : "ETH_BTC"}, // Take the ETH_BTC trading pair for example
}
Estrutura do valor de retorno final enviado ao docker:
Estrutura JSON
{
"data" : {
"time" : 1500793319499,
"asks" : [ [1000, 0.5], [1001, 0.23], [1004, 2.1], ... ],
"bids" : [ [999, 0.25], [998, 0.8], [995, 1.4], ... ],
}
}
-
- GetTrades: Obter os registos de negociação de toda a bolsa dentro de um determinado período de tempo (excluindo os próprios negócios)
Omethodemrequestenviado pelo docker para a função de resposta de escuta é:trades.
Parâmetros enviados pelo docker: O valor derequest.Params.symbolé a moeda de negociação, por exemplo:btc, que é enviado pelo docker com base nas configurações de estratégia.
O formato de dados carregado pelo docker ao solicitar o plugin de protocolo personalizado é o seguinte
{
"access_key" : "access_key",
"secret_key" : "secret_key",
"nonce" : "1500793319499", // millisecond timestamp
"method" : "trades",
"params" : {"symbol" : "ETH_BTC"}, // Take the ETH_BTC trading pair for example
}
Estrutura do valor de retorno final enviado ao docker:
Estrutura JSON
{
"data": [
{
"id": 12232153,
"time" : 1529919412968,
"price": 1000,
"amount": 0.5,
"type": "buy", // "buy"、"sell"
},{
"id": 12545664,
"time" : 1529919412900,
"price": 1001,
"amount": 1,
"type": "sell",
},{
...
}
]
}
-
- GetAccount: Obter informações sobre os ativos da conta.
Omethodemrequestenviado pelo docker para a função de resposta de escuta é:accounts.
Parâmetros enviados pelo docker: (Nota: Geralmente, é para obter todos os ativos da conta! Por favor, consulte a interface de troca para ver se é para obter ativos individuais ou a informação total de ativos)
O formato de dados carregado pelo docker ao solicitar o plugin de protocolo personalizado é o seguinte
{
"access_key" : "access_key",
"secret_key" : "secret_key",
"nonce" : "1500793319499", // millisecond timestamp
"method" : "accounts",
"params" : {},
}
Estrutura do valor de retorno final enviado ao docker:
Estrutura JSON
{
"data": [
{"currency": "btc", "free": 1.2, "frozen": 0.1},
{"currency": "ltc", "free": 25, "frozen": 2.1},
{"currency": "ltc", "free": 25, "frozen": 2.1},
...
],
"raw" : {...} // It is possible to write the raw message (response) returned by the exchange when the plugin accesses the exchange
}
-
- Comprar, vender: Colocar uma ordem para negociação (ordem de mercado ou ordem de limite).
Omethodemrequestenviado pelo docker para a função de resposta de escuta é:trade.
Parâmetros enviados pelo docker:request.Params.type: enviado pelo docker com base em se ele está chamandoexchange.Buyouexchange.Sell, request.Params.price: o primeiro parâmetro doAPIfunção chamada na estratégia,request.Params.amount: o segundo parâmetro doAPIfunção chamada na estratégia,request.Params.symbol: enviado pelo docker com base na moeda de negociação definida.
O formato de dados carregado pelo docker ao solicitar o plugin de protocolo personalizado é o seguinte
{
"access_key" : "access_key",
"secret_key" : "secret_key",
"nonce" : "1500793319499", // millisecond timestamp
"method" : "trade",
"params" : {
"symbol" : "ETH_BTC",
"type" : "buy",
"price" : "1000",
"amount" : "1"
}, // Example of an ETH_BTC trading pair, "type": "buy" buy request, price 1000, quantity 1
}
Estrutura do valor de retorno final enviado ao docker:
Estrutura JSON
{
"data": {
"id": 125456, // Order id returned after placing an order
// If the order id is in the form of a string like "asdf346sfasf532"
// Here the id can also be a string type
}
}
-
- GetOrder: Obter informações de uma ordem específica por ID de ordem
Omethodemrequestenviado pelo docker para a função de resposta de escuta é:order.
Parâmetros enviados pelo docker:request.Params.id, request.Params.symbol.
O formato de dados carregado pelo docker ao solicitar o plugin de protocolo personalizado é o seguinte
{
"access_key" : "access_key",
"secret_key" : "secret_key",
"nonce" : "1500793319499", // millisecond timestamp
"method" : "order",
"params" : {"symbol" : "ETH_BTC", "id" : "XXX"}, // Take the ETH_BTC trading pair and order ID XXX as an example. Please note that some exchanges use numerical order IDs, such as 123456, while others use string order IDs, such as poimd55sdfheqxv. The specific format of the order ID depends on the exchange.
}
Estrutura do valor de retorno final enviado ao docker:
Estrutura JSON
{
"data": {
"id": 2565244,
"amount": 0.15,
"price": 1002,
"status": "open", // "open": pending, "closed": closed, "canceled": canceled
"deal_amount": 0,
"type": "buy", // "buy"、"sell"
"avg_price": 0, // If not provided by the exchange, it can be assigned a value of 0 during processing
}
}
-
- GetOrders: Obter informações para todos os pedidos não preenchidos
Omethodemrequestenviado pelo docker para a função de resposta de escuta éorders.
Parâmetros enviados pelo docker:request.Params.symbol
O formato de dados carregado pelo docker ao solicitar o plugin de protocolo personalizado é o seguinte
{
"access_key" : "access_key",
"secret_key" : "secret_key",
"nonce" : "1500793319499", // millisecond timestamp
"method" : "orders",
"params" : {"symbol" : "ETH_BTC"}, // Take the ETH_BTC trading pair for example
}
Estrutura do valor de retorno final enviado ao docker:
Estrutura JSON
{
"data": [{
"id": 542156,
"amount": 0.25,
"price": 1005,
"deal_amount": 0,
"type": "buy", // "buy"、"sell"
"status": "open", // "open"
},{
...
}]
}
-
- CancelOrder: Cancelar uma encomenda com o ID de encomenda especificado
Omethodemrequestenviado pelo docker para a função de resposta de escuta écancel.
Parâmetros enviados pelo docker:request.Params.id(tipo de string, o primeiro parâmetro da função API chamada pela estratégia),request.Params.symbol(por exemplo, btc, enviado pelo docker com base na moeda definida pela estratégia)
O formato de dados carregado pelo docker ao solicitar o plugin de protocolo personalizado é o seguinte
{
"access_key" : "access_key",
"secret_key" : "secret_key",
"nonce" : "1500793319499", // millisecond timestamp
"method" : "cancel",
"params" : {"symbol" : "ETH_BTC", "id" : "XXX"}, // Take an ETH_BTC trading pair with an id of "XXX" (same as the GetOrder function's parameter id) for example
}
Estrutura do valor de retorno final enviado ao docker:
Estrutura JSON
{
"data": true, // true or false
}
-
- Liga para oexchange.IOFunção da plataforma quântica FMZ
Omethodemrequestenviado pelo docker para a função de resposta de escuta começa com_api_.
O formato de dados carregado pelo docker ao solicitar o plugin de protocolo personalizado é o seguinte
{
"access_key" : "access_key",
"secret_key" : "secret_key",
"nonce" : "1500793319499", // millisecond timestamp
"method" : "__api_XXX", // XXX is the API interface for the specific exchange (base address not included)
"params" : {"borrow_id" : "123", "symbol" : "cny"}, // Specifically, the parameters passed into the IO function
}
Estrutura do valor de retorno final enviado ao docker:
{
"data": {...} // The return value of a specific interface call
}
A título de exemplo, o convite à estratégia:
var io_str = exchange.IO("api", "POST", "cancel_borrow", "symbol=cny&borrow_id=123")
Código de teste no plug-in (idioma de acesso):
fmt.Println("request.Method:", request.Method, "request.Params:", request.Params)
Linha de comando do plugin: 2017/08/31 10:19:59 Correndohttp://127.0.0.1:6666/DigitalAsset …
Impressão da linha de comando do plugin: request.Method, request.ParamsNo corpo da solicitação enviada pelo docker, os dados analisados na solicitação são os seguintes:request.Methodé__api_cancel_borrow
request.Paramsé{"borrow_id" : "123", "symbol" : "cny"}
Você pode personalizar o manuseio destesexchange.IOchamadas que acessam diretamente a trocaAPI.
# Attention:
# When calling exchange.IO("api", "POST", "/api/v1/getAccount", "symbol=BTC_USDT"),
# If the second parameter is not POST but: exchange.IO("api", "GET", "/api/v1/getAccount", "symbol=BTC_USDT")
# is the GET method, which is then stored in the header Http-Method in the http request accepted by the custom protocol plugin.
# So you need to refer to the following sample code for the custom protocol handling IO function implementation:
// tapiCall function definition
func (p *iStocksExchange) tapiCall(method string, params map[string]string, httpType string) (js *Json, err error) {
...
}
// In the OnPost function
if strings.HasPrefix(request.Method, "__api_") {
var js *Json
js, err = e.tapiCall(request.Method[6:], request.Params, r.Header.Get("Http-Method"))
...
}
- Suporte para troca.GetRawJSON:
O sistema subjacente lida automaticamente com as chamadas paraexchange.GetRawJSON, então não há necessidade de implementá-lo no plugin.
- Suporte para troca.
O sistema subjacente lida automaticamente com as chamadas paraexchange.Go, então não há necessidade de lidar com ele no plugin.
var beginTime = new Date().getTime()
var ret = exchange.Go("GetDepth")
var endTime = new Date().getTime()
Log(endTime - beginTime, "#FF0000")
// Sleep(2000)
beginTime = new Date().getTime()
Log(exchange.GetTicker())
endTime = new Date().getTime()
Log(endTime - beginTime, "#FF0000")
var depth = ret.wait()
Log("depth:", depth)
# Note: If you specify a timeout when waiting using exchange.
# Always make sure to obtain the final data so that the concurrent threads of the application can be reclaimed.
- Apoio às funções de futuros:
Você precisa implementar um manuseio específico no programa do plugin para funções de futuros. Por exemplo, definir alavancagem, código de contrato e direção de ordem. Você pode definir uma variável local para registrar essas informações. Para recuperar posições, você precisará acessar a API de troca para obter dados brutos e processá-los na estrutura de posição definida na plataforma FMZ, e depois devolvê-lo.
Quando as seguintes funções são chamadas na estratégia, o formato doRpcA solicitação recebida pelo programa do plugin é ligeiramente diferente de outras interfaces.RpcRequestA principal diferença é que o valor de params é uma estrutura composta.
Tipo de contrato Definir o código do contrato.
{"access_key":"123","method":"io","nonce":1623307269528738000,"params":{"args":["quarter"],"code":2},"secret_key":"123"}
Configurar direção Definir a direcção para a colocação de ordens de futuros.
{"access_key":"123","method":"io","nonce":1623308734966484000,"params":{"args":["closesell"],"code":1},"secret_key":"123"}
SetMarginLevel Estabelece a alavancagem dos futuros.
{"access_key":"123","method":"io","nonce":1623308734966939000,"params":{"args":[12],"code":0},"secret_key":"123"}
GetPosition Obter a posição de futuros. Quando?
exchange.GetPosition()chama-se:
{"access_key":"123","method":"io","nonce":1623308734967442000,"params":{"args":[],"code":3},"secret_key":"123"}
Quando?exchange.GetPosition("swap")chama-se:
{"access_key":"123","method":"io","nonce":1623308734967442000,"params":{"args":["swap"],"code":3},"secret_key":"123"}
- Complete Go Language Exemplo de Plugin de Protocolo Personalizado (Acesso ao Bitgo Exchange)
/*
GOOS=linux GOARCH=amd64 go build -ldflags '-s -w -extldflags -static' rest_bitgo.go
*/
package main
import (
"bytes"
"crypto/md5"
"encoding/hex"
"encoding/json"
"errors"
"flag"
"fmt"
"io/ioutil"
"log"
"net/http"
"net/url"
"sort"
"strconv"
"strings"
"time"
)
func toFloat(s interface{}) float64 {
var ret float64
switch v := s.(type) {
case float64:
ret = v
case float32:
ret = float64(v)
case int64:
ret = float64(v)
case int:
ret = float64(v)
case int32:
ret = float64(v)
case string:
ret, _ = strconv.ParseFloat(strings.TrimSpace(v), 64)
}
return ret
}
func float2str(i float64) string {
return strconv.FormatFloat(i, 'f', -1, 64)
}
func toInt64(s interface{}) int64 {
var ret int64
switch v := s.(type) {
case int:
ret = int64(v)
case float64:
ret = int64(v)
case bool:
if v {
ret = 1
} else {
ret = 0
}
case int64:
ret = v
case string:
ret, _ = strconv.ParseInt(strings.TrimSpace(v), 10, 64)
}
return ret
}
func toString(s interface{}) string {
var ret string
switch v := s.(type) {
case string:
ret = v
case int64:
ret = strconv.FormatInt(v, 10)
case float64:
ret = strconv.FormatFloat(v, 'f', -1, 64)
case bool:
ret = strconv.FormatBool(v)
default:
ret = fmt.Sprintf("%v", s)
}
return ret
}
type Json struct {
data interface{}
}
func NewJson(body []byte) (*Json, error) {
j := new(Json)
err := j.UnmarshalJSON(body)
if err != nil {
return nil, err
}
return j, nil
}
func (j *Json) UnmarshalJSON(p []byte) error {
return json.Unmarshal(p, &j.data)
}
func (j *Json) Get(key string) *Json {
m, err := j.Map()
if err == nil {
if val, ok := m[key]; ok {
return &Json{val}
}
}
return &Json{nil}
}
func (j *Json) CheckGet(key string) (*Json, bool) {
m, err := j.Map()
if err == nil {
if val, ok := m[key]; ok {
return &Json{val}, true
}
}
return nil, false
}
func (j *Json) Map() (map[string]interface{}, error) {
if m, ok := (j.data).(map[string]interface{}); ok {
return m, nil
}
return nil, errors.New("type assertion to map[string]interface{} failed")
}
func (j *Json) Array() ([]interface{}, error) {
if a, ok := (j.data).([]interface{}); ok {
return a, nil
}
return nil, errors.New("type assertion to []interface{} failed")
}
func (j *Json) Bool() (bool, error) {
if s, ok := (j.data).(bool); ok {
return s, nil
}
return false, errors.New("type assertion to bool failed")
}
func (j *Json) String() (string, error) {
if s, ok := (j.data).(string); ok {
return s, nil
}
return "", errors.New("type assertion to string failed")
}
func (j *Json) Bytes() ([]byte, error) {
if s, ok := (j.data).(string); ok {
return []byte(s), nil
}
return nil, errors.New("type assertion to []byte failed")
}
func (j *Json) Int() (int, error) {
if f, ok := (j.data).(float64); ok {
return int(f), nil
}
return -1, errors.New("type assertion to float64 failed")
}
func (j *Json) MustArray(args ...[]interface{}) []interface{} {
var def []interface{}
switch len(args) {
case 0:
case 1:
def = args[0]
default:
log.Panicf("MustArray() received too many arguments %d", len(args))
}
a, err := j.Array()
if err == nil {
return a
}
return def
}
func (j *Json) MustMap(args ...map[string]interface{}) map[string]interface{} {
var def map[string]interface{}
switch len(args) {
case 0:
case 1:
def = args[0]
default:
log.Panicf("MustMap() received too many arguments %d", len(args))
}
a, err := j.Map()
if err == nil {
return a
}
return def
}
func (j *Json) MustString(args ...string) string {
var def string
switch len(args) {
case 0:
case 1:
def = args[0]
default:
log.Panicf("MustString() received too many arguments %d", len(args))
}
s, err := j.String()
if err == nil {
return s
}
return def
}
func (j *Json) MustInt64() int64 {
var ret int64
var err error
switch v := j.data.(type) {
case int:
ret = int64(v)
case int64:
ret = v
case float64:
ret = int64(v)
case string:
if ret, err = strconv.ParseInt(v, 10, 64); err != nil {
panic(err)
}
default:
ret = 0
//panic("type assertion to int64 failed")
}
return ret
}
func (j *Json) MustFloat64() float64 {
var ret float64
var err error
switch v := j.data.(type) {
case int:
ret = float64(v)
case int64:
ret = float64(v)
case float64:
ret = v
case string:
v = strings.Replace(v, ",", "", -1)
if ret, err = strconv.ParseFloat(v, 64); err != nil {
panic(err)
}
default:
ret = 0
//panic("type assertion to float64 failed")
}
return ret
}
type iBitgo struct {
accessKey string
secretKey string
currency string
opCurrency string
baseCurrency string
secret string
secretExpires int64
apiBase string
step int64
newRate float64
timeout time.Duration
timeLocation *time.Location
}
type MapSorter []Item
type Item struct {
Key string
Val string
}
func NewMapSorter(m map[string]string) MapSorter {
ms := make(MapSorter, 0, len(m))
for k, v := range m {
if strings.HasPrefix(k, "!") {
k = strings.Replace(k, "!", "", -1)
}
ms = append(ms, Item{k, v})
}
return ms
}
func (ms MapSorter) Len() int {
return len(ms)
}
func (ms MapSorter) Less(i, j int) bool {
//return ms[i].Val < ms[j].Val // Sort by value
return ms[i].Key < ms[j].Key // Sort by key
}
func (ms MapSorter) Swap(i, j int) {
ms[i], ms[j] = ms[j], ms[i]
}
func encodeParams(params map[string]string, escape bool) string {
ms := NewMapSorter(params)
sort.Sort(ms)
v := url.Values{}
for _, item := range ms {
v.Add(item.Key, item.Val)
}
if escape {
return v.Encode()
}
var buf bytes.Buffer
keys := make([]string, 0, len(v))
for k := range v {
keys = append(keys, k)
}
sort.Strings(keys)
for _, k := range keys {
vs := v[k]
prefix := k + "="
for _, v := range vs {
if buf.Len() > 0 {
buf.WriteByte('&')
}
buf.WriteString(prefix)
buf.WriteString(v)
}
}
return buf.String()
}
func newBitgo(accessKey, secretKey string) *iBitgo {
s := new(iBitgo)
s.accessKey = accessKey
s.secretKey = secretKey
s.apiBase = "https://www.bitgo.cn"
s.timeout = 20 * time.Second
s.timeLocation = time.FixedZone("Asia/Shanghai", 8*60*60)
return s
}
func (p *iBitgo) apiCall(method string) (*Json, error) {
req, err := http.NewRequest("POST", fmt.Sprintf("%s/appApi.html?%s", p.apiBase, method), nil)
if err != nil {
return nil, err
}
req.Header.Set("Content-Type", "application/x-www-form-urlencoded")
resp, err := http.DefaultClient.Do(req)
if err != nil {
return nil, err
}
defer resp.Body.Close()
b, err := ioutil.ReadAll(resp.Body)
if err != nil {
return nil, err
}
return NewJson(b)
}
func (p *iBitgo) GetTicker(symbol string) (ticker interface{}, err error) {
var js *Json
js, err = p.apiCall("action=market&symbol=" + symbol)
if err != nil {
return
}
dic := js.Get("data")
ticker = map[string]interface{}{
"time": js.Get("time").MustInt64(),
"buy": dic.Get("buy").MustFloat64(),
"sell": dic.Get("sell").MustFloat64(),
"last": dic.Get("last").MustFloat64(),
"high": dic.Get("high").MustFloat64(),
"low": dic.Get("low").MustFloat64(),
"vol": dic.Get("vol").MustFloat64(),
}
return
}
func (p *iBitgo) GetDepth(symbol string) (depth interface{}, err error) {
var js *Json
js, err = p.apiCall("action=depth&symbol=" + symbol)
if err != nil {
return
}
dic := js.Get("data")
asks := [][2]float64{}
bids := [][2]float64{}
for _, pair := range dic.Get("asks").MustArray() {
arr := pair.([]interface{})
asks = append(asks, [2]float64{toFloat(arr[0]), toFloat(arr[1])})
}
for _, pair := range dic.Get("bids").MustArray() {
arr := pair.([]interface{})
bids = append(bids, [2]float64{toFloat(arr[0]), toFloat(arr[1])})
}
depth = map[string]interface{}{
"time": js.Get("time").MustInt64(),
"asks": asks,
"bids": bids,
}
return
}
func (p *iBitgo) GetTrades(symbol string) (trades interface{}, err error) {
var js *Json
js, err = p.apiCall("action=trades&symbol=" + symbol)
if err != nil {
return
}
dic := js.Get("data")
items := []map[string]interface{}{}
for _, pair := range dic.MustArray() {
item := map[string]interface{}{}
arr := pair.(map[string]interface{})
item["id"] = toInt64(arr["id"])
item["price"] = toFloat(arr["price"])
item["amount"] = toFloat(arr["amount"])
// trade.Time = toInt64(arr["time"]) * 1000
if toString(arr["en_type"]) == "bid" {
item["type"] = "buy"
} else {
item["type"] = "sell"
}
items = append(items, item)
}
trades = items
return
}
func (p *iBitgo) GetRecords(step int64, symbol string) (records interface{}, err error) {
var js *Json
js, err = p.apiCall(fmt.Sprintf("action=kline&symbol=%s&step=%d", symbol, step*60))
if err != nil {
return
}
items := []interface{}{}
for _, pair := range js.Get("data").MustArray() {
arr := pair.([]interface{})
if len(arr) < 6 {
err = errors.New("response format error")
return
}
item := [6]interface{}{}
item[0] = toInt64(arr[0])
item[1] = toFloat(arr[1])
item[2] = toFloat(arr[2])
item[3] = toFloat(arr[3])
item[4] = toFloat(arr[4])
item[5] = toFloat(arr[5])
items = append(items, item)
}
records = items
return
}
func (p *iBitgo) tapiCall(method string, params map[string]string) (js *Json, err error) {
if params == nil {
params = map[string]string{}
}
params["api_key"] = p.accessKey
h := md5.New()
h.Write([]byte(encodeParams(params, false) + "&secret_key=" + p.secretKey))
params["sign"] = strings.ToUpper(hex.EncodeToString(h.Sum(nil)))
params["action"] = method
qs := encodeParams(params, false)
req, err := http.NewRequest("POST", fmt.Sprintf("%s/appApi.html?%s", p.apiBase, qs), nil)
if err != nil {
return nil, err
}
req.Header.Set("Content-Type", "application/x-www-form-urlencoded")
resp, err := http.DefaultClient.Do(req)
if err != nil {
return nil, err
}
defer resp.Body.Close()
b, err := ioutil.ReadAll(resp.Body)
if err != nil {
return nil, err
}
js, err = NewJson(b)
if js != nil {
if code := js.Get("code").MustInt64(); code != 200 {
s := js.Get("msg").MustString()
if s == "" {
s = fmt.Sprintf("%v", toString(js.data))
}
return nil, errors.New(s)
}
}
return js, err
}
func (p *iBitgo) GetAccount(symbol string) (account interface{}, err error) {
var js *Json
js, err = p.tapiCall("userinfo", nil)
if err != nil {
return
}
mp := js.Get("data")
assets := map[string]map[string]interface{}{}
for k := range mp.MustMap() {
dic := mp.Get(k)
if k == "free" {
for c := range dic.MustMap() {
if _, ok := assets[c]; !ok {
assets[c] = map[string]interface{}{}
}
assets[c]["currency"] = c
assets[c]["free"] = dic.Get(c).MustFloat64()
}
} else if k == "frozen" {
for c := range dic.MustMap() {
if _, ok := assets[c]; !ok {
assets[c] = map[string]interface{}{}
}
assets[c]["currency"] = c
assets[c]["frozen"] = dic.Get(c).MustFloat64()
}
}
}
accounts := []map[string]interface{}{}
for _, pair := range assets {
accounts = append(accounts, pair)
}
account = accounts
return
}
func (p *iBitgo) Trade(side string, price, amount float64, symbol string) (orderId interface{}, err error) {
var js *Json
js, err = p.tapiCall("trade", map[string]string{
"symbol": symbol,
"type": side,
"price": float2str(price),
"amount": float2str(amount),
})
if err != nil {
return
}
orderId = map[string]int64{"id": js.Get("orderId").MustInt64()}
return
}
func (p *iBitgo) GetOrders(symbol string) (orders interface{}, err error) {
var js *Json
js, err = p.tapiCall("entrust", map[string]string{"symbol": symbol})
if err != nil {
return
}
items := []map[string]interface{}{}
for _, ele := range js.Get("data").MustArray() {
mp := ele.(map[string]interface{})
item := map[string]interface{}{}
item["id"] = toInt64(mp["id"])
item["amount"] = toFloat(mp["count"])
if _, ok := mp["prize"]; ok {
item["price"] = toFloat(mp["prize"])
} else {
item["price"] = toFloat(mp["price"])
}
item["deal_amount"] = toFloat(mp["success_count"])
if toInt64(mp["type"]) == 0 {
item["type"] = "buy"
} else {
item["type"] = "sell"
}
item["status"] = "open"
items = append(items, item)
}
return items, nil
}
func (p *iBitgo) GetOrder(orderId int64, symbol string) (order interface{}, err error) {
var js *Json
js, err = p.tapiCall("order", map[string]string{"id": toString(orderId)})
if err != nil {
return
}
found := false
item := map[string]interface{}{}
for _, ele := range js.Get("data").MustArray() {
mp := ele.(map[string]interface{})
if toInt64(mp["id"]) != orderId {
continue
}
item["id"] = toInt64(mp["id"])
item["amount"] = toFloat(mp["count"])
if _, ok := mp["prize"]; ok {
item["price"] = toFloat(mp["prize"])
} else {
item["price"] = toFloat(mp["price"])
}
item["deal_amount"] = toFloat(mp["success_count"])
if toInt64(mp["type"]) == 0 {
item["type"] = "buy"
} else {
item["type"] = "sell"
}
switch toInt64(mp["status"]) {
case 1, 2:
item["status"] = "open"
case 3:
item["status"] = "closed"
case 4:
item["status"] = "cancelled"
}
found = true
break
}
if !found {
return nil, errors.New("order not found")
}
return item, nil
}
func (p *iBitgo) CancelOrder(orderId int64, symbol string) (ret bool, err error) {
_, err = p.tapiCall("cancel_entrust", map[string]string{"id": strconv.FormatInt(orderId, 10)})
if err != nil {
return
}
ret = true
return
}
type RpcRequest struct { // The fields in a struct must start with an uppercase letter, otherwise they cannot be parsed correctly. Structs can have exported and unexported fields, where fields starting with an uppercase letter are considered exported.
// During unmarshaling, the JSON tag of a struct is used to match and find the corresponding field. Therefore, modifiers are required in this case.
AccessKey string `json:"access_key"`
SecretKey string `json:"secret_key"`
Nonce int64 `json:"nonce"`
Method string `json:"method"`
Params map[string]string `json:"params"`
}
func OnPost(w http.ResponseWriter, r *http.Request) {
var ret interface{}
defer func() {
if e := recover(); e != nil {
if ee, ok := e.(error); ok {
e = ee.Error()
}
ret = map[string]string{"error": fmt.Sprintf("%v", e)}
}
b, _ := json.Marshal(ret)
w.Write(b)
}()
b, err := ioutil.ReadAll(r.Body)
if err != nil {
panic(err)
}
var request RpcRequest
err = json.Unmarshal(b, &request)
if err != nil {
panic(err)
}
e := newBitgo(request.AccessKey, request.SecretKey)
symbol := request.Params["symbol"]
if s := request.Params["access_key"]; len(s) > 0 {
e.accessKey = s
}
if s := request.Params["secret_key"]; len(s) > 0 {
e.secretKey = s
}
if symbolIdx, ok := map[string]int{
"btc": 1,
"ltc": 2,
"etp": 3,
"eth": 4,
"etc": 5,
"doge": 6,
"bec": 7,
}[strings.Replace(strings.ToLower(symbol), "_cny", "", -1)]; ok {
symbol = toString(symbolIdx)
}
var data interface{}
switch request.Method {
case "ticker":
data, err = e.GetTicker(symbol)
case "depth":
data, err = e.GetDepth(symbol)
case "trades":
data, err = e.GetTrades(symbol)
case "records":
data, err = e.GetRecords(toInt64(request.Params["period"]), symbol)
case "accounts":
data, err = e.GetAccount(symbol)
case "trade":
side := request.Params["type"]
if side == "buy" {
side = "0"
} else {
side = "1"
}
price := toFloat(request.Params["price"])
amount := toFloat(request.Params["amount"])
data, err = e.Trade(side, price, amount, symbol)
case "orders":
data, err = e.GetOrders(symbol)
case "order":
data, err = e.GetOrder(toInt64(request.Params["id"]), symbol)
case "cancel":
data, err = e.CancelOrder(toInt64(request.Params["id"]), symbol)
default:
if strings.HasPrefix(request.Method, "__api_") {
data, err = e.tapiCall(request.Method[6:], request.Params)
} else {
panic(errors.New(request.Method + " not support"))
}
}
if err != nil {
panic(err)
}
ret = map[string]interface{}{
"data": data,
}
return
}
func main() {
var addr = flag.String("b", "127.0.0.1:6666", "bind addr")
flag.Parse()
if *addr == "" {
flag.Usage()
return
}
basePath := "/exchange"
log.Println("Running ", fmt.Sprintf("http://%s%s", *addr, basePath), "...")
http.HandleFunc(basePath, OnPost)
http.ListenAndServe(*addr, nil)
}
- Documento de Descrição da Configuração dos Títulos Futu
- FMZ Quant Uniswap V3 Guia de operações relacionadas com a liquidez dos bancos de câmbio (parte 1)
- FMZ Quantificação Uniswap V3 Guia de operação relacionado à liquidez do reservatório de câmbio (1)
- Construção de funções de botão interativas na barra de status da estratégia
- Configurações do Parâmetro de Interface da Estratégia
- FMZ Plataforma Quantitativa de Criptomoedas Guia de Uso do WebSocket (Explicação detalhada da função de discagem atualizada)
- Curso em Python em X minutos
- Curso de JavaScript em X minutos
- Relativamente à forma de colocar ordens limitadas post-só BitMEX e ordens por lotes usando IO (um exemplo)
- Biblioteca FMZ Quant TA de código aberto, aprenda a usar (com versões Javascript/Python/C++)
- FMZ lançou o Python Local Backtest Engine
- Tutoriais avançados para a escrita de estratégias da plataforma FMZ Quant
- Aplicação da função "__Thread" no projeto de estratégia JavaScript
- Aplicação da função _Thread no design da política JavaScript
- Ensinar a projetar biblioteca de classe modelo para obter dados de linha K de comprimento especificado
- Aprenda a projetar uma biblioteca de modelos para obter dados de linha especificados de K-longitude.
- Comece com o desenvolvimento web3 facilmente baseado no Ethereum usando FMZ
- Explore as novas funções do editor de estratégia FMZ: Como o ChatGPT melhora significativamente a sua produtividade quantitativa
- Descubra as novas funcionalidades do editor de estratégia FMZ: como o ChatGPT pode aumentar significativamente a sua produtividade quantitativa
- Introdução fácil ao desenvolvimento web3 baseado no Ethereum com o FMZ