ExchangeTrade gRPC Method

参数

来自

字符串

必填

正在加载...

exchangeID

整数

必填

正在加载...

tokenID

字符串

必填

正在加载...

amountToken

整数

必填

正在加载...

amountExpected

整数

必填

正在加载...

退货

交易

对象

正在加载...

原始数据

对象

正在加载...

ref_block_bytes

字符串

正在加载...

ref_block_num

整数

正在加载...

ref_block_hash

字符串

正在加载...

到期

整数

正在加载...

auths

数组

正在加载...

数据

字符串

正在加载...

合同

数组

正在加载...

类型

字符串

正在加载...

参数

对象

正在加载...

值

字符串

正在加载...

type_url

字符串

正在加载...

提供商

字符串

正在加载...

合同名称

字符串

正在加载...

Permission_id

整数

正在加载...

脚本

字符串

正在加载...

时间戳

整数

正在加载...

fee_limit

整数

正在加载...

签名

数组

正在加载...

ret

数组

正在加载...

费用

整数

正在加载...

ret

字符串

正在加载...

contractRet

字符串

正在加载...

资产问题ID

字符串

正在加载...

取款金额

整数

正在加载...

解冻金额

整数

正在加载...

exchange_received_amount

整数

正在加载...

exchange_inject_another_amount

整数

正在加载...

exchange_withdraw_another_amount

整数

正在加载...

exchange_id

整数

正在加载...

受保护的交易费

整数

正在加载...

订单编号

字符串

正在加载...

订单详情

数组

正在加载...

makerOrderId

字符串

正在加载...

takerOrderId

字符串

正在加载...

fillSellQuantity

整数

正在加载...

fillBuyQuantity

整数

正在加载...

取款_到期金额

整数

正在加载...

cancelUnfreezeV2Amount

对象

正在加载...

txid

字符串

正在加载...

常量结果

数组

正在加载...

结果

对象

正在加载...

结果

布尔型

正在加载...

代码

字符串

正在加载...

消息

字符串

正在加载...

energy_used

整数

正在加载...

日志

数组

正在加载...

地址

字符串

正在加载...

主题

数组

正在加载...

数据

字符串

正在加载...

内部交易

数组

正在加载...

哈希

字符串

正在加载...

caller_address

字符串

正在加载...

transferTo_address

字符串

正在加载...

callValueInfo

数组

正在加载...

callValue

整数

正在加载...

tokenId

字符串

正在加载...

注

字符串

正在加载...

被拒绝

布尔型

正在加载...

额外

字符串

正在加载...

能量消耗

整数

正在加载...

请求

1
包 main
2

3
导入 (
4
   "上下文"
5
   "crypto/tls"
6
   "encoding/json"
7
   "fmt"
8
   "github.com/fbsobreira/gotron-sdk/pkg/client"
9
   "google.golang.org/grpc"
10
   "google.golang.org/grpc/credentials"
11
)
12

13
// Quicknode endpoints consist of two crucial components: the endpoint name and the corresponding token
14
// For eg: QN Endpoint: https://docs-demo.tron-mainnet.quiknode.pro/abcde123456789
15
// endpoint will be: docs-demo.tron-mainnet.quiknode.pro:50051  {50051 is the port number for Tron gRPC}
16
// token will be : abcde123456789
17

18
var token = "YOUR_TOKEN"
19
var 端点 = "YOUR_ENDPOINT:50051"
20

21
类型 auth 结构体 {
22
   token string
23
}
24

25
func (a *auth) GetRequestMetadata(ctx 上下文.上下文, uri ...字符串) (map[字符串]字符串, error) {
26
   return map[string]string{
27
      "x-token": a.token,
28
   }, nil
29
}
30

31
func (a *auth) RequireTransportSecurity() bool {
32
   return false
33
}
34

35
func main() {
36

37
   opts := []grpc.DialOption{
38
      grpc.WithTransportCredentials(credentials.NewTLS(&tls.Config{})),
39
      grpc.WithPerRPCCredentials(&auth{token}),
40
   }
41
   conn := client.NewGrpcClient(endpoint)
42
   if err := conn.Start(opts...); err != nil {
43
      panic(err)
44
   }
45
   defer conn.Conn.Close()
46

47
   from := "TZ4UXDV5ZhNW7fb2AMSbgfAEZ7hWsnYS2g" // Address performing the trade
48
   exchangeID := int64(123)                     // ID of the exchange pair
49
   
50
   fmt.Printf("Verifying exchange ID %d...\n", exchangeID)
51
   exchange, err := conn.ExchangeByID(exchangeID)
52
   if err != nil {
53
      fmt.Printf("Error: The specified exchange does not exist: %v\n", err)
54
      返回
55
   }
56
   
57
   firstTokenID := string(exchange.FirstTokenId)
58
   secondTokenID := string(exchange.SecondTokenId)
59
   fmt.Printf("Exchange %d contains tokens: %s and %s\n", 
60
      exchangeID, firstTokenID, secondTokenID)
61
   
62
   tokenID := firstTokenID                             
63
   amountToken := int64(1000000)                        
64
   amountExpected := int64(1800000)                    
65
   
66
   if tokenID != firstTokenID && tokenID != secondTokenID {
67
      fmt.Printf("Error: Token %s is not in exchange %d\n", tokenID, exchangeID)
68
      返回
69
   }
70
   
71
   fmt.Printf("Checking token balance for %s...\n", tokenID)
72
   var tokenBalance int64
73
   // The method to get balance depends on whether we're trading TRX or a TRC10 token
74
   if tokenID == "" {
75
      // For TRX
76
      account, err := conn.GetAccount(from)
77
      if err != nil {
78
         fmt.Printf("Error getting account: %v\n", err)
79
         返回
80
      }
81
      tokenBalance = account.Balance
82
   } else {
83
      // For TRC10 tokens
84
      account, err := conn.GetAccount(from)
85
      if err != nil {
86
         fmt.Printf("Error getting account: %v\n", err)
87
         返回
88
      }
89
   
90
      found := false
91
      for tokenName, balance := range account.AssetV2 {
92
         if string(tokenName) == tokenID {
93
            tokenBalance = balance
94
            found = true
95
            break
96
         }
97
      }
98
      if !found {
99
         tokenBalance = 0
100
      }
101
   }
102
   
103
   fmt.Printf("Token balance: %d\n", tokenBalance)
104

105
   if tokenBalance < amountToken {
106
      fmt.Printf("Error: Insufficient token balance. Have: %d, Need: %d\n", tokenBalance, amountToken)
107
      fmt.Println("Please make sure you have enough tokens before trading.")
108
      返回
109
   }
110
   
111
   // Create the trade transaction
112
   fmt.Println("Creating exchange trade transaction...")
113
   
114
   tx, err := conn.ExchangeTrade(
115
      from,            // The trader's address
116
      exchangeID,      // Exchange ID
117
      tokenID,         // Token ID to trade
118
      amountToken,     // Amount to trade
119
      amountExpected,  // Minimum expected return
120
   )
121
   
122
   if err != nil {
123
      fmt.Printf("Error creating trade transaction: %v\n", err)
124
      返回
125
   }
126
   
127
   fmt.Println("Trade transaction created successfully. Transaction details:")
128
   jsonData, _ := json.MarshalIndent(tx, "", "  ")
129
   fmt.Println(string(jsonData))
130
   
131
   // NOTE: In a production environment, the transaction should be signed here
132
   fmt.Println("\nBroadcasting transaction to the TRON network...")
133
   result, err := conn.Broadcast(tx.Transaction)
134
   if err != nil {
135
      fmt.Printf("Error broadcasting transaction: %v\n", err)
136
      返回
137
   }
138
   
139
   if !result.GetResult() {
140
      fmt.Printf("Broadcast failed: %s\n", result.GetMessage())
141
      返回
142
   }
143
   
144
   fmt.Println("Trade executed successfully! Result:")
145
   resultJSON, _ := json.MarshalIndent(result, "", "  ")
146
   fmt.Println(string(resultJSON))
147
}

1
包 main
2

3
导入 (
4
   "上下文"
5
   "crypto/tls"
6
   "encoding/json"
7
   "fmt"
8
   "github.com/fbsobreira/gotron-sdk/pkg/client"
9
   "google.golang.org/grpc"
10
   "google.golang.org/grpc/credentials"
11
)
12

13
// Quicknode endpoints consist of two crucial components: the endpoint name and the corresponding token
14
// For eg: QN Endpoint: https://docs-demo.tron-mainnet.quiknode.pro/abcde123456789
15
// endpoint will be: docs-demo.tron-mainnet.quiknode.pro:50051  {50051 is the port number for Tron gRPC}
16
// token will be : abcde123456789
17

18
var token = "YOUR_TOKEN"
19
var 端点 = "YOUR_ENDPOINT:50051"
20

21
类型 auth 结构体 {
22
   token string
23
}
24

25
func (a *auth) GetRequestMetadata(ctx 上下文.上下文, uri ...字符串) (map[字符串]字符串, error) {
26
   return map[string]string{
27
      "x-token": a.token,
28
   }, nil
29
}
30

31
func (a *auth) RequireTransportSecurity() bool {
32
   return false
33
}
34

35
func main() {
36

37
   opts := []grpc.DialOption{
38
      grpc.WithTransportCredentials(credentials.NewTLS(&tls.Config{})),
39
      grpc.WithPerRPCCredentials(&auth{token}),
40
   }
41
   conn := client.NewGrpcClient(endpoint)
42
   if err := conn.Start(opts...); err != nil {
43
      panic(err)
44
   }
45
   defer conn.Conn.Close()
46

47
   from := "TZ4UXDV5ZhNW7fb2AMSbgfAEZ7hWsnYS2g" // Address performing the trade
48
   exchangeID := int64(123)                     // ID of the exchange pair
49
   
50
   fmt.Printf("Verifying exchange ID %d...\n", exchangeID)
51
   exchange, err := conn.ExchangeByID(exchangeID)
52
   if err != nil {
53
      fmt.Printf("Error: The specified exchange does not exist: %v\n", err)
54
      返回
55
   }
56
   
57
   firstTokenID := string(exchange.FirstTokenId)
58
   secondTokenID := string(exchange.SecondTokenId)
59
   fmt.Printf("Exchange %d contains tokens: %s and %s\n", 
60
      exchangeID, firstTokenID, secondTokenID)
61
   
62
   tokenID := firstTokenID                             
63
   amountToken := int64(1000000)                        
64
   amountExpected := int64(1800000)                    
65
   
66
   if tokenID != firstTokenID && tokenID != secondTokenID {
67
      fmt.Printf("Error: Token %s is not in exchange %d\n", tokenID, exchangeID)
68
      返回
69
   }
70
   
71
   fmt.Printf("Checking token balance for %s...\n", tokenID)
72
   var tokenBalance int64
73
   // The method to get balance depends on whether we're trading TRX or a TRC10 token
74
   if tokenID == "" {
75
      // For TRX
76
      account, err := conn.GetAccount(from)
77
      if err != nil {
78
         fmt.Printf("Error getting account: %v\n", err)
79
         返回
80
      }
81
      tokenBalance = account.Balance
82
   } else {
83
      // For TRC10 tokens
84
      account, err := conn.GetAccount(from)
85
      if err != nil {
86
         fmt.Printf("Error getting account: %v\n", err)
87
         返回
88
      }
89
   
90
      found := false
91
      for tokenName, balance := range account.AssetV2 {
92
         if string(tokenName) == tokenID {
93
            tokenBalance = balance
94
            found = true
95
            break
96
         }
97
      }
98
      if !found {
99
         tokenBalance = 0
100
      }
101
   }
102
   
103
   fmt.Printf("Token balance: %d\n", tokenBalance)
104

105
   if tokenBalance < amountToken {
106
      fmt.Printf("Error: Insufficient token balance. Have: %d, Need: %d\n", tokenBalance, amountToken)
107
      fmt.Println("Please make sure you have enough tokens before trading.")
108
      返回
109
   }
110
   
111
   // Create the trade transaction
112
   fmt.Println("Creating exchange trade transaction...")
113
   
114
   tx, err := conn.ExchangeTrade(
115
      from,            // The trader's address
116
      exchangeID,      // Exchange ID
117
      tokenID,         // Token ID to trade
118
      amountToken,     // Amount to trade
119
      amountExpected,  // Minimum expected return
120
   )
121
   
122
   if err != nil {
123
      fmt.Printf("Error creating trade transaction: %v\n", err)
124
      返回
125
   }
126
   
127
   fmt.Println("Trade transaction created successfully. Transaction details:")
128
   jsonData, _ := json.MarshalIndent(tx, "", "  ")
129
   fmt.Println(string(jsonData))
130
   
131
   // NOTE: In a production environment, the transaction should be signed here
132
   fmt.Println("\nBroadcasting transaction to the TRON network...")
133
   result, err := conn.Broadcast(tx.Transaction)
134
   if err != nil {
135
      fmt.Printf("Error broadcasting transaction: %v\n", err)
136
      返回
137
   }
138
   
139
   if !result.GetResult() {
140
      fmt.Printf("Broadcast failed: %s\n", result.GetMessage())
141
      返回
142
   }
143
   
144
   fmt.Println("Trade executed successfully! Result:")
145
   resultJSON, _ := json.MarshalIndent(result, "", "  ")
146
   fmt.Println(string(resultJSON))
147
}

还没有账号吗？

只需几秒钟即可创建您的 Quicknode 端点，并开始构建

免费开始使用