Ecosystem/xmr-remote-nodes
1
0
Fork 0
mirror of https://github.com/ditatompel/xmr-remote-nodes.git synced 2025-01-08 20:09:43 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Fetch estimate fee has it own function

Browse source
This commit is contained in:
ditatompel 2024-06-03 13:10:35 +07:00
parent c6d48764a2
commit 33efa8fd31
No known key found for this signature in database
GPG key ID: 31D3D06D77950979
1 changed files with 40 additions and 30 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

70
cmd/client/probe.go
View file

@ -227,41 +227,13 @@ func (p *proberClient) fetchNode(node monero.Node) (monero.Node, error) {
// time.Sleep(1 * time.Second)
// check fee
rpcCheckFeeParam := []byte(`{"jsonrpc": "2.0","id": "0","method": "get_fee_estimate"}`)
reqCheckFee, err := http.NewRequest(http.MethodPost, endpoint, bytes.NewBuffer(rpcCheckFeeParam))
fee, err := p.fetchFee(client, endpoint)
if err != nil {
return node, err
}
reqCheckFee.Header.Set("Content-Type", "application/json; charset=UTF-8")
reqCheckFee.Header.Set("User-Agent", RPCUserAgent)
checkFee, err := client.Do(reqCheckFee)
if err != nil {
return node, err
}
defer checkFee.Body.Close()
if checkFee.StatusCode != 200 {
return node, fmt.Errorf("status code: %d", checkFee.StatusCode)
}
bodyCheckFee, err := io.ReadAll(checkFee.Body)
if err != nil {
return node, err
}
feeEstimate := struct {
Result struct {
Fee uint `json:"fee"`
} `json:"result"`
}{}
if err := json.Unmarshal(bodyCheckFee, &feeEstimate); err != nil {
return node, err
}
node.EstimateFee = fee
tookTime := time.Since(startTime).Seconds()
node.EstimateFee = feeEstimate.Result.Fee
slog.Info(fmt.Sprintf("[PROBE] Took %f seconds", tookTime))
if err := p.reportResult(node, tookTime); err != nil {
@ -270,6 +242,44 @@ func (p *proberClient) fetchNode(node monero.Node) (monero.Node, error) {
return node, nil
}
// get estimate fee from remote node
func (p *proberClient) fetchFee(client http.Client, endpoint string) (uint, error) {
rpcParam := []byte(`{"jsonrpc": "2.0","id": "0","method": "get_fee_estimate"}`)
req, err := http.NewRequest(http.MethodPost, endpoint, bytes.NewBuffer(rpcParam))
if err != nil {
return 0, err
}
req.Header.Set("Content-Type", "application/json; charset=UTF-8")
req.Header.Set("User-Agent", RPCUserAgent)
res, err := client.Do(req)
if err != nil {
return 0, err
}
defer res.Body.Close()
if res.StatusCode != 200 {
return 0, fmt.Errorf("status code: %d", res.StatusCode)
}
body, err := io.ReadAll(res.Body)
if err != nil {
return 0, err
}
f := struct {
Result struct {
Fee uint `json:"fee"`
} `json:"result"`
}{}
if err := json.Unmarshal(body, &f); err != nil {
return 0, err
}
return f.Result.Fee, nil
}
func (p *proberClient) reportResult(node monero.Node, tookTime float64) error {
jsonData, err := json.Marshal(monero.ProbeReport{
TookTime: tookTime,