-
Notifications
You must be signed in to change notification settings - Fork 42
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
[fireblocks] Add transfer method (#227)
* fireblocks transfer * fix error msg
- Loading branch information
Showing
9 changed files
with
491 additions
and
99 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,38 @@ | ||
| package fireblocks | ||
|
|
||
| import ( | ||
| "context" | ||
| "encoding/json" | ||
| "fmt" | ||
| "strings" | ||
|
|
||
| "github.com/ethereum/go-ethereum/common" | ||
| ) | ||
|
|
||
| type WhitelistedAccount struct { | ||
| ID string `json:"id"` | ||
| Name string `json:"name"` | ||
| Assets []struct { | ||
| ID AssetID `json:"id"` | ||
| Balance string `json:"balance"` | ||
| LockedAmount string `json:"lockedAmount"` | ||
| Status string `json:"status"` | ||
| Address common.Address `json:"address"` | ||
| Tag string `json:"tag"` | ||
| } `json:"assets"` | ||
| } | ||
|
|
||
| func (f *client) ListExternalWallets(ctx context.Context) ([]WhitelistedAccount, error) { | ||
| var accounts []WhitelistedAccount | ||
| res, err := f.makeRequest(ctx, "GET", "/v1/external_wallets", nil) | ||
| if err != nil { | ||
| return accounts, fmt.Errorf("error making request: %w", err) | ||
| } | ||
| body := string(res) | ||
| err = json.NewDecoder(strings.NewReader(body)).Decode(&accounts) | ||
| if err != nil { | ||
| return accounts, fmt.Errorf("error parsing response body: %s: %w", body, err) | ||
| } | ||
|
|
||
| return accounts, nil | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,61 @@ | ||
| package fireblocks | ||
|
|
||
| type TransactionOperation string | ||
| type FeeLevel string | ||
|
|
||
| const ( | ||
| ContractCall TransactionOperation = "CONTRACT_CALL" | ||
| Transfer TransactionOperation = "TRANSFER" | ||
| Mint TransactionOperation = "MINT" | ||
| Burn TransactionOperation = "BURN" | ||
| TypedMessage TransactionOperation = "TYPED_MESSAGE" | ||
| Raw TransactionOperation = "RAW" | ||
|
|
||
| FeeLevelHigh FeeLevel = "HIGH" | ||
| FeeLevelMedium FeeLevel = "MEDIUM" | ||
| FeeLevelLow FeeLevel = "LOW" | ||
| ) | ||
|
|
||
| type account struct { | ||
| Type string `json:"type"` | ||
| ID string `json:"id"` | ||
| } | ||
|
|
||
| type extraParams struct { | ||
| Calldata string `json:"contractCallData"` | ||
| } | ||
|
|
||
| type TransactionRequest struct { | ||
| Operation TransactionOperation `json:"operation"` | ||
| // ExternalTxID is an optional field that can be used as an idempotency key. | ||
| ExternalTxID string `json:"externalTxId,omitempty"` | ||
| AssetID AssetID `json:"assetId"` | ||
| Source account `json:"source"` | ||
| Destination account `json:"destination"` | ||
| Amount string `json:"amount,omitempty"` | ||
| ExtraParameters extraParams `json:"extraParameters"` | ||
| // In case a transaction is stuck, specify the hash of the stuck transaction to replace it | ||
| // by this transaction with a higher fee, or to replace it with this transaction with a zero fee and drop it from | ||
| // the blockchain. | ||
| ReplaceTxByHash string `json:"replaceTxByHash,omitempty"` | ||
| // GasPrice and GasLimit are the gas price and gas limit for the transaction. | ||
| // If GasPrice is specified (non-1559), MaxFee and PriorityFee are not required. | ||
| GasPrice string `json:"gasPrice,omitempty"` | ||
| GasLimit string `json:"gasLimit,omitempty"` | ||
| // MaxFee and PriorityFee are the maximum and priority fees for the transaction. | ||
| // If the transaction is stuck, the Fireblocks platform will replace the transaction with a new one with a higher | ||
| // fee. | ||
| // These fields are required if FeeLevel is not specified. | ||
| MaxFee string `json:"maxFee,omitempty"` | ||
| PriorityFee string `json:"priorityFee,omitempty"` | ||
| // FeeLevel is the fee level for the transaction which Fireblocks estimates based on the current network conditions. | ||
| // The fee level can be HIGH, MEDIUM, or LOW. | ||
| // If MaxFee and PriorityFee are not specified, the Fireblocks platform will use the default fee level MEDIUM. | ||
| // Ref: https://developers.fireblocks.com/docs/gas-estimation#estimated-network-fee | ||
| FeeLevel FeeLevel `json:"feeLevel,omitempty"` | ||
| } | ||
|
|
||
| type TransactionResponse struct { | ||
| ID string `json:"id"` | ||
| Status TxStatus `json:"status"` | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,69 @@ | ||
| package fireblocks | ||
|
|
||
| import ( | ||
| "context" | ||
| "encoding/json" | ||
| "fmt" | ||
| "strings" | ||
| ) | ||
|
|
||
| func NewTransferRequest( | ||
| externalTxID string, | ||
| assetID AssetID, | ||
| sourceAccountID string, | ||
| destinationAccountID string, | ||
| amount string, // amount in ETH | ||
| replaceTxByHash string, | ||
| gasPrice string, | ||
| gasLimit string, | ||
| maxFee string, | ||
| priorityFee string, | ||
| feeLevel FeeLevel, | ||
| ) *TransactionRequest { | ||
| req := &TransactionRequest{ | ||
| Operation: Transfer, | ||
| ExternalTxID: externalTxID, | ||
| AssetID: assetID, | ||
| Source: account{ | ||
| Type: "VAULT_ACCOUNT", | ||
| ID: sourceAccountID, | ||
| }, | ||
| // https://developers.fireblocks.com/reference/transaction-sources-destinations | ||
| Destination: account{ | ||
| Type: "EXTERNAL_WALLET", | ||
| ID: destinationAccountID, | ||
| }, | ||
| Amount: amount, | ||
| ReplaceTxByHash: replaceTxByHash, | ||
| GasLimit: gasLimit, | ||
| } | ||
|
|
||
| if maxFee != "" && priorityFee != "" { | ||
| req.MaxFee = maxFee | ||
| req.PriorityFee = priorityFee | ||
| } else if gasPrice != "" { | ||
| req.GasPrice = gasPrice | ||
| } else { | ||
| req.FeeLevel = feeLevel | ||
| } | ||
|
|
||
| return req | ||
| } | ||
|
|
||
| func (f *client) Transfer(ctx context.Context, req *TransactionRequest) (*TransactionResponse, error) { | ||
| f.logger.Debug("Fireblocks transfer", "req", req) | ||
| res, err := f.makeRequest(ctx, "POST", "/v1/transactions", req) | ||
| if err != nil { | ||
| return nil, fmt.Errorf("error making request: %w", err) | ||
| } | ||
| var response TransactionResponse | ||
| err = json.NewDecoder(strings.NewReader(string(res))).Decode(&response) | ||
| if err != nil { | ||
| return nil, fmt.Errorf("error parsing response body: %w", err) | ||
| } | ||
|
|
||
| return &TransactionResponse{ | ||
| ID: response.ID, | ||
| Status: response.Status, | ||
| }, nil | ||
| } |
Oops, something went wrong.