-
Notifications
You must be signed in to change notification settings - Fork 16
/
faucet.go
57 lines (50 loc) · 1.73 KB
/
faucet.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
package aptos
import (
"errors"
"fmt"
"log/slog"
"net/url"
"strconv"
)
// FaucetClient uses the underlying NodeClient to request for APT for gas on a network.
// This can only be used in a test network (e.g. Localnet, Devnet, Testnet)
type FaucetClient struct {
nodeClient *NodeClient // NodeClient to use for requesting funds
url *url.URL // URL of the faucet e.g. https://testnet.faucet.aptoslabs.com
}
// NewFaucetClient creates a new client specifically for requesting faucet funds
func NewFaucetClient(nodeClient *NodeClient, faucetUrl string) (*FaucetClient, error) {
parsedUrl, err := url.Parse(faucetUrl)
if err != nil {
return nil, fmt.Errorf("failed to parse faucet url '%s': %w", faucetUrl, err)
}
return &FaucetClient{
nodeClient,
parsedUrl,
}, nil
}
// Fund account with the given amount of AptosCoin
func (faucetClient *FaucetClient) Fund(address AccountAddress, amount uint64) error {
if faucetClient.nodeClient == nil {
return errors.New("faucet's node-client not initialized")
}
// Build URL
mintUrl := faucetClient.url.JoinPath("mint")
params := url.Values{}
params.Set("amount", strconv.FormatUint(amount, 10))
params.Set("address", address.String())
mintUrl.RawQuery = params.Encode()
// Make request for funds
txnHashes, err := Post[[]string](faucetClient.nodeClient, mintUrl.String(), "text/plain", nil)
if err != nil {
return fmt.Errorf("response api decode error, %w", err)
}
// Wait for fund transactions to go through
slog.Debug("FundAccount wait for transactions", "number of transactions", len(txnHashes))
if len(txnHashes) == 1 {
_, err = faucetClient.nodeClient.WaitForTransaction(txnHashes[0])
return err
} else {
return faucetClient.nodeClient.PollForTransactions(txnHashes)
}
}