Merge pull request #46 from sidan-lab/main

Fix: Error handling / TransactionDetail schema type
maestro-org · Apr 19, 2024 · fa0911f · fa0911f
2 parents b7b8a7e + dd57081
commit fa0911f
Show file tree

Hide file tree

Showing 14 changed files with 185 additions and 2 deletions.
diff --git a/client/accounts.go b/client/accounts.go
@@ -3,6 +3,7 @@ package client
 import (
 	"encoding/json"
 	"fmt"
+	"net/http"
 
 	"github.com/maestro-org/go-sdk/models"
 	"github.com/maestro-org/go-sdk/utils"
@@ -21,6 +22,9 @@ func (c *Client) AccountAddresses(
 	if err != nil {
 		return nil, err
 	}
+	if resp.StatusCode != http.StatusOK {
+		return nil, fmt.Errorf("unexpected error: %d", resp.Body)
+	}
 	defer resp.Body.Close()
 	var accountAddresses models.AccountAddresses
 	err = json.NewDecoder(resp.Body).Decode(&accountAddresses)
@@ -43,6 +47,9 @@ func (c *Client) AccountAssets(
 	if err != nil {
 		return nil, err
 	}
+	if resp.StatusCode != http.StatusOK {
+		return nil, fmt.Errorf("unexpected error: %d", resp.Body)
+	}
 	defer resp.Body.Close()
 	var accountAssets models.AccountAssets
 	err = json.NewDecoder(resp.Body).Decode(&accountAssets)
@@ -65,6 +72,9 @@ func (c *Client) StakeAccountHistory(
 	if err != nil {
 		return nil, err
 	}
+	if resp.StatusCode != http.StatusOK {
+		return nil, fmt.Errorf("unexpected error: %d", resp.Body)
+	}
 	defer resp.Body.Close()
 	var stakeAccountHistory models.StakeAccountHistory
 	err = json.NewDecoder(resp.Body).Decode(&stakeAccountHistory)
@@ -82,6 +92,10 @@ func (c *Client) StakeAccountInformation(
 	if err != nil {
 		return nil, err
 	}
+	if resp.StatusCode != http.StatusOK {
+		return nil, fmt.Errorf("unexpected error: %d", resp.Body)
+	}
+
 	defer resp.Body.Close()
 	var stakeAccountInformation models.StakeAccountInformation
 	err = json.NewDecoder(resp.Body).Decode(&stakeAccountInformation)
@@ -104,6 +118,9 @@ func (c *Client) StakeAccountRewards(
 	if err != nil {
 		return nil, err
 	}
+	if resp.StatusCode != http.StatusOK {
+		return nil, fmt.Errorf("unexpected error: %d", resp.Body)
+	}
 	defer resp.Body.Close()
 	var stakeAccountRewards models.StakeAccountRewards
 	err = json.NewDecoder(resp.Body).Decode(&stakeAccountRewards)
@@ -126,6 +143,9 @@ func (c *Client) StakeAccountUpdates(
 	if err != nil {
 		return nil, err
 	}
+	if resp.StatusCode != http.StatusOK {
+		return nil, fmt.Errorf("unexpected error: %d", resp.Body)
+	}
 	defer resp.Body.Close()
 	var stakeAccountUpdates models.StakeAccountUpdates
 	err = json.NewDecoder(resp.Body).Decode(&stakeAccountUpdates)

diff --git a/client/addresses.go b/client/addresses.go
@@ -3,6 +3,7 @@ package client
 import (
 	"encoding/json"
 	"fmt"
+	"net/http"
 
 	"github.com/maestro-org/go-sdk/models"
 	"github.com/maestro-org/go-sdk/utils"
@@ -14,6 +15,9 @@ func (c *Client) DecodeAddress(address string) (*models.DecodedAddress, error) {
 	if err != nil {
 		return nil, err
 	}
+	if resp.StatusCode != http.StatusOK {
+		return nil, fmt.Errorf("unexpected error: %d", resp.Body)
+	}
 	defer resp.Body.Close()
 	var decodedAddress models.DecodedAddress
 	err = json.NewDecoder(resp.Body).Decode(&decodedAddress)
@@ -29,6 +33,9 @@ func (c *Client) AddressTransactionCount(address string) (*models.AddressTransac
 	if err != nil {
 		return nil, err
 	}
+	if resp.StatusCode != http.StatusOK {
+		return nil, fmt.Errorf("unexpected error: %d", resp.Body)
+	}
 	defer resp.Body.Close()
 	var addressTransactionCount models.AddressTransactionCount
 	err = json.NewDecoder(resp.Body).Decode(&addressTransactionCount)
@@ -51,6 +58,9 @@ func (c *Client) AddressTransactions(
 	if err != nil {
 		return nil, err
 	}
+	if resp.StatusCode != http.StatusOK {
+		return nil, fmt.Errorf("unexpected error: %d", resp.Body)
+	}
 	defer resp.Body.Close()
 	var addressTransactions models.AddressTransactions
 	err = json.NewDecoder(resp.Body).Decode(&addressTransactions)
@@ -73,6 +83,9 @@ func (c *Client) PaymentCredentialTransactions(
 	if err != nil {
 		return nil, err
 	}
+	if resp.StatusCode != http.StatusOK {
+		return nil, fmt.Errorf("unexpected error: %d", resp.Body)
+	}
 	defer resp.Body.Close()
 	var addressTransactions models.AddressTransactions
 	err = json.NewDecoder(resp.Body).Decode(&addressTransactions)
@@ -95,6 +108,9 @@ func (c *Client) UtxoReferencesAtAddress(
 	if err != nil {
 		return nil, err
 	}
+	if resp.StatusCode != http.StatusOK {
+		return nil, fmt.Errorf("unexpected error: %d", resp.Body)
+	}
 	defer resp.Body.Close()
 	var utxoReferencesAtAddress models.UtxoReferencesAtAddress
 	err = json.NewDecoder(resp.Body).Decode(&utxoReferencesAtAddress)
@@ -117,6 +133,9 @@ func (c *Client) UtxosAtAddress(
 	if err != nil {
 		return nil, err
 	}
+	if resp.StatusCode != http.StatusOK {
+		return nil, fmt.Errorf("unexpected error: %d", resp.Body)
+	}
 	defer resp.Body.Close()
 	var utxosAtAddress models.UtxosAtAddress
 	err = json.NewDecoder(resp.Body).Decode(&utxosAtAddress)
@@ -140,6 +159,9 @@ func (c *Client) UtxosAtAddresses(
 	if err != nil {
 		return nil, err
 	}
+	if resp.StatusCode != http.StatusOK {
+		return nil, fmt.Errorf("unexpected error: %d", resp.Body)
+	}
 	defer resp.Body.Close()
 	var utxosAtAddress models.UtxosAtAddress
 	err = json.NewDecoder(resp.Body).Decode(&utxosAtAddress)
@@ -162,6 +184,9 @@ func (c *Client) UtxosByPaymentCredential(
 	if err != nil {
 		return nil, err
 	}
+	if resp.StatusCode != http.StatusOK {
+		return nil, fmt.Errorf("unexpected error: %d", resp.Body)
+	}
 	defer resp.Body.Close()
 	var utxosAtAddress models.UtxosAtAddress
 	err = json.NewDecoder(resp.Body).Decode(&utxosAtAddress)

diff --git a/client/asset.go b/client/asset.go
@@ -3,6 +3,7 @@ package client
 import (
 	"encoding/json"
 	"fmt"
+	"net/http"
 
 	"github.com/maestro-org/go-sdk/models"
 	"github.com/maestro-org/go-sdk/utils"
@@ -21,6 +22,9 @@ func (c *Client) AccountsHoldingAsset(
 	if err != nil {
 		return nil, err
 	}
+	if resp.StatusCode != http.StatusOK {
+		return nil, fmt.Errorf("unexpected error: %d", resp.Body)
+	}
 	defer resp.Body.Close()
 	var accountsHoldingAsset models.AccountsHoldingAsset
 	err = json.NewDecoder(resp.Body).Decode(&accountsHoldingAsset)
@@ -43,6 +47,9 @@ func (c *Client) AddressHoldingAsset(
 	if err != nil {
 		return nil, err
 	}
+	if resp.StatusCode != http.StatusOK {
+		return nil, fmt.Errorf("unexpected error: %d", resp.Body)
+	}
 	defer resp.Body.Close()
 	var addressesHoldingAsset models.AddressesHoldingAsset
 	err = json.NewDecoder(resp.Body).Decode(&addressesHoldingAsset)
@@ -58,6 +65,9 @@ func (c *Client) Asset(assetId string) (*models.AssetInformations, error) {
 	if err != nil {
 		return nil, err
 	}
+	if resp.StatusCode != http.StatusOK {
+		return nil, fmt.Errorf("unexpected error: %d", resp.Body)
+	}
 	defer resp.Body.Close()
 	var assetInformation models.AssetInformations
 	err = json.NewDecoder(resp.Body).Decode(&assetInformation)
@@ -80,6 +90,9 @@ func (c *Client) AssetTransactions(
 	if err != nil {
 		return nil, err
 	}
+	if resp.StatusCode != http.StatusOK {
+		return nil, fmt.Errorf("unexpected error: %d", resp.Body)
+	}
 	defer resp.Body.Close()
 	var assetTransactions models.AssetTransactions
 	err = json.NewDecoder(resp.Body).Decode(&assetTransactions)
@@ -102,6 +115,9 @@ func (c *Client) AssetUpdates(
 	if err != nil {
 		return nil, err
 	}
+	if resp.StatusCode != http.StatusOK {
+		return nil, fmt.Errorf("unexpected error: %d", resp.Body)
+	}
 	defer resp.Body.Close()
 	var assetUpdates models.AssetUpdates
 	err = json.NewDecoder(resp.Body).Decode(&assetUpdates)
@@ -122,6 +138,9 @@ func (c *Client) AssetUtxos(assetId string, params *utils.Parameters) (*models.A
 	if err != nil {
 		return nil, err
 	}
+	if resp.StatusCode != http.StatusOK {
+		return nil, fmt.Errorf("unexpected error: %d", resp.Body)
+	}
 	defer resp.Body.Close()
 	var assetUtxos models.AssetUtxos
 	err = json.NewDecoder(resp.Body).Decode(&assetUtxos)

diff --git a/client/asset_policy.go b/client/asset_policy.go
@@ -3,6 +3,7 @@ package client
 import (
 	"encoding/json"
 	"fmt"
+	"net/http"
 
 	"github.com/maestro-org/go-sdk/models"
 	"github.com/maestro-org/go-sdk/utils"
@@ -21,6 +22,9 @@ func (c *Client) AccountsHoldingPolicy(
 	if err != nil {
 		return nil, err
 	}
+	if resp.StatusCode != http.StatusOK {
+		return nil, fmt.Errorf("unexpected error: %d", resp.Body)
+	}
 	defer resp.Body.Close()
 	var response models.AccountsHoldingPolicy
 	err = json.NewDecoder(resp.Body).Decode(&response)
@@ -43,6 +47,9 @@ func (c *Client) AddressesHoldingPolicy(
 	if err != nil {
 		return nil, err
 	}
+	if resp.StatusCode != http.StatusOK {
+		return nil, fmt.Errorf("unexpected error: %d", resp.Body)
+	}
 	defer resp.Body.Close()
 	var response models.AddressesHoldingPolicy
 	err = json.NewDecoder(resp.Body).Decode(&response)
@@ -65,6 +72,9 @@ func (c *Client) SpecificPolicyInformations(
 	if err != nil {
 		return nil, err
 	}
+	if resp.StatusCode != http.StatusOK {
+		return nil, fmt.Errorf("unexpected error: %d", resp.Body)
+	}
 	defer resp.Body.Close()
 	var response models.PolicyInformation
 	err = json.NewDecoder(resp.Body).Decode(&response)
@@ -87,6 +97,9 @@ func (c *Client) TransactionsMovingPolicy(
 	if err != nil {
 		return nil, err
 	}
+	if resp.StatusCode != http.StatusOK {
+		return nil, fmt.Errorf("unexpected error: %d", resp.Body)
+	}
 	defer resp.Body.Close()
 	var response models.PolicyTransactions
 	err = json.NewDecoder(resp.Body).Decode(&response)
@@ -109,6 +122,9 @@ func (c *Client) UtxosContainingPolicy(
 	if err != nil {
 		return nil, err
 	}
+	if resp.StatusCode != http.StatusOK {
+		return nil, fmt.Errorf("unexpected error: %d", resp.Body)
+	}
 	defer resp.Body.Close()
 	var response models.UtxosContainingPolicy
 	err = json.NewDecoder(resp.Body).Decode(&response)

diff --git a/client/datum.go b/client/datum.go
@@ -3,6 +3,7 @@ package client
 import (
 	"encoding/json"
 	"fmt"
+	"net/http"
 
 	"github.com/maestro-org/go-sdk/models"
 )
@@ -13,6 +14,9 @@ func (c *Client) DatumFromHash(hash string) (*models.DatumFromHash, error) {
 	if err != nil {
 		return nil, err
 	}
+	if resp.StatusCode != http.StatusOK {
+		return nil, fmt.Errorf("unexpected error: %d", resp.Body)
+	}
 	defer resp.Body.Close()
 	var datum models.DatumFromHash
 	err = json.NewDecoder(resp.Body).Decode(&datum)

diff --git a/client/ecosystem.go b/client/ecosystem.go
@@ -3,6 +3,7 @@ package client
 import (
 	"encoding/json"
 	"fmt"
+	"net/http"
 
 	"github.com/maestro-org/go-sdk/models"
 )
@@ -13,6 +14,9 @@ func (c *Client) ResolveAdaHandle(handle string) (*models.BasicResponse, error)
 	if err != nil {
 		return nil, err
 	}
+	if resp.StatusCode != http.StatusOK {
+		return nil, fmt.Errorf("unexpected error: %d", resp.Body)
+	}
 	defer resp.Body.Close()
 	var adaHandle models.BasicResponse
 	err = json.NewDecoder(resp.Body).Decode(&adaHandle)

diff --git a/client/epochs.go b/client/epochs.go
@@ -3,6 +3,7 @@ package client
 import (
 	"encoding/json"
 	"fmt"
+	"net/http"
 
 	"github.com/maestro-org/go-sdk/models"
 )
@@ -13,6 +14,9 @@ func (c *Client) CurrentEpoch() (*models.EpochResp, error) {
 	if err != nil {
 		return nil, err
 	}
+	if resp.StatusCode != http.StatusOK {
+		return nil, fmt.Errorf("unexpected error: %d", resp.Body)
+	}
 	defer resp.Body.Close()
 	var currentEpoch models.EpochResp
 	err = json.NewDecoder(resp.Body).Decode(&currentEpoch)
@@ -28,6 +32,9 @@ func (c *Client) SpecificEpoch(epochNo int) (*models.EpochResp, error) {
 	if err != nil {
 		return nil, err
 	}
+	if resp.StatusCode != http.StatusOK {
+		return nil, fmt.Errorf("unexpected error: %d", resp.Body)
+	}
 	defer resp.Body.Close()
 	var specificEpoch models.EpochResp
 	err = json.NewDecoder(resp.Body).Decode(&specificEpoch)

diff --git a/client/general.go b/client/general.go
@@ -2,6 +2,8 @@ package client
 
 import (
 	"encoding/json"
+	"fmt"
+	"net/http"
 
 	"github.com/maestro-org/go-sdk/models"
 )
@@ -12,6 +14,9 @@ func (c *Client) ChainTip() (*models.ChainTip, error) {
 	if err != nil {
 		return nil, err
 	}
+	if resp.StatusCode != http.StatusOK {
+		return nil, fmt.Errorf("unexpected error: %d", resp.Body)
+	}
 	defer resp.Body.Close()
 	var chainTip models.ChainTip
 	err = json.NewDecoder(resp.Body).Decode(&chainTip)
@@ -27,6 +32,9 @@ func (c *Client) EraHistory() (*models.EraHistory, error) {
 	if err != nil {
 		return nil, err
 	}
+	if resp.StatusCode != http.StatusOK {
+		return nil, fmt.Errorf("unexpected error: %d", resp.Body)
+	}
 	defer resp.Body.Close()
 	var eraHistory models.EraHistory
 	err = json.NewDecoder(resp.Body).Decode(&eraHistory)
@@ -42,6 +50,9 @@ func (c *Client) ProtocolParameters() (*models.ProtocolParameters, error) {
 	if err != nil {
 		return nil, err
 	}
+	if resp.StatusCode != http.StatusOK {
+		return nil, fmt.Errorf("unexpected error: %d", resp.Body)
+	}
 	defer resp.Body.Close()
 	var protocolParameters models.ProtocolParameters
 	err = json.NewDecoder(resp.Body).Decode(&protocolParameters)
@@ -57,6 +68,9 @@ func (c *Client) BlockChainStartTime() (models.BasicResponse, error) {
 	if err != nil {
 		return models.BasicResponse{}, err
 	}
+	if resp.StatusCode != http.StatusOK {
+		return models.BasicResponse{}, fmt.Errorf("unexpected error: %d", resp.Body)
+	}
 	defer resp.Body.Close()
 	var blockchainStartTime models.BasicResponse
 	err = json.NewDecoder(resp.Body).Decode(&blockchainStartTime)