Skip to content

Commit

Permalink
refactor using request function
Browse files Browse the repository at this point in the history
  • Loading branch information
minhkstn committed Apr 11, 2023
1 parent e2f5dba commit 3c76d27
Show file tree
Hide file tree
Showing 3 changed files with 48 additions and 41 deletions.
39 changes: 8 additions & 31 deletions bigmap.go
Original file line number Diff line number Diff line change
Expand Up @@ -20,21 +20,14 @@ func (c *TZKT) GetBigMapValueByPointer(pointer int, key string) ([]byte, error)
}.Encode(),
}

var results []json.RawMessage

req, err := http.NewRequest("GET", u.String(), nil)
if err != nil {
return nil, err
}

resp, err := c.client.Do(req)
if err != nil {
return nil, err
}

defer resp.Body.Close()

var results []json.RawMessage

if err := json.NewDecoder(resp.Body).Decode(&results); err != nil {
if err := c.request(req, &results); err != nil {
return nil, err
}

Expand Down Expand Up @@ -64,21 +57,14 @@ func (c *TZKT) GetBigMapPointersByContract(contract string, tags ...string) ([]i
RawQuery: query.Encode(),
}

req, err := http.NewRequest("GET", u.String(), nil)
if err != nil {
return nil, err
}
var pointer []int

resp, err := c.client.Do(req)
req, err := http.NewRequest("GET", u.String(), nil)
if err != nil {
return nil, err
}

defer resp.Body.Close()
var pointer []int

err = json.NewDecoder(resp.Body).Decode(&pointer)
if err != nil {
if err := c.request(req, &pointer); err != nil {
return nil, err
}

Expand All @@ -98,23 +84,14 @@ func (c *TZKT) GetBigMapsByContractAndPath(contract string, path string) (int, e
}.Encode(),
}

fmt.Println(u)
var pointer []int

req, err := http.NewRequest("GET", u.String(), nil)
if err != nil {
return 0, err
}

resp, err := c.client.Do(req)
if err != nil {
return 0, err
}

defer resp.Body.Close()
var pointer []int

err = json.NewDecoder(resp.Body).Decode(&pointer)
if err != nil {
if err := c.request(req, &pointer); err != nil {
return 0, err
}

Expand Down
5 changes: 4 additions & 1 deletion operation.go
Original file line number Diff line number Diff line change
Expand Up @@ -44,7 +44,10 @@ func (c *TZKT) GetTransaction(id uint64) (TransactionDetails, error) {

var txs []TransactionDetails

req, _ := http.NewRequest("GET", u.String(), nil)
req, err := http.NewRequest("GET", u.String(), nil)
if err != nil {
return TransactionDetails{}, err
}
if err := c.request(req, &txs); err != nil {
return TransactionDetails{}, err
}
Expand Down
45 changes: 36 additions & 9 deletions token.go
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,10 @@ func (c *TZKT) GetTokenBalanceOfOwner(contract, tokenID, owner string) (int, err

var balance int

req, _ := http.NewRequest("GET", u.String(), nil)
req, err := http.NewRequest("GET", u.String(), nil)
if err != nil {
return balance, err
}
if err := c.request(req, &balance); err != nil {
return balance, err
}
Expand Down Expand Up @@ -56,7 +59,10 @@ func (c *TZKT) GetTokenOwners(contract, tokenID string, limit int, lastTime time

var owners []TokenOwner

req, _ := http.NewRequest("GET", u.String(), nil)
req, err := http.NewRequest("GET", u.String(), nil)
if err != nil {
return nil, err
}
if err := c.request(req, &owners); err != nil {
return nil, err
}
Expand Down Expand Up @@ -84,7 +90,11 @@ func (c *TZKT) GetTokenBalanceAndLastTimeForOwner(contract, tokenID, owner strin

var owners []TokenOwner

req, _ := http.NewRequest("GET", u.String(), nil)
req, err := http.NewRequest("GET", u.String(), nil)
if err != nil {
return 0, time.Time{}, err
}

if err := c.request(req, &owners); err != nil {
return 0, time.Time{}, err
}
Expand Down Expand Up @@ -120,7 +130,11 @@ func (c *TZKT) GetTokenLastActivityTime(contract, tokenID string) (time.Time, er

var activityTime []time.Time

req, _ := http.NewRequest("GET", u.String(), nil)
req, err := http.NewRequest("GET", u.String(), nil)
if err != nil {
return time.Time{}, err
}

if err := c.request(req, &activityTime); err != nil {
return time.Time{}, err
}
Expand Down Expand Up @@ -154,7 +168,11 @@ func (c *TZKT) GetTokenTransfers(contract, tokenID string, limit int) ([]TokenTr

var transfers []TokenTransfer

req, _ := http.NewRequest("GET", u.String(), nil)
req, err := http.NewRequest("GET", u.String(), nil)
if err != nil {
return nil, err
}

if err := c.request(req, &transfers); err != nil {
return nil, err
}
Expand Down Expand Up @@ -182,6 +200,7 @@ func (c *TZKT) GetTokenTransfersCount(contract, tokenID string) (int, error) {
if err != nil {
return 0, err
}

if err := c.request(req, &count); err != nil {
return 0, err
}
Expand Down Expand Up @@ -212,7 +231,11 @@ func (c *TZKT) RetrieveTokens(owner string, lastTime time.Time, offset int) ([]O
}
var ownedTokens []OwnedToken

req, _ := http.NewRequest("GET", u.String(), nil)
req, err := http.NewRequest("GET", u.String(), nil)
if err != nil {
return ownedTokens, err
}

if err := c.request(req, &ownedTokens); err != nil {
return ownedTokens, err
}
Expand All @@ -221,8 +244,6 @@ func (c *TZKT) RetrieveTokens(owner string, lastTime time.Time, offset int) ([]O
}

func (c *TZKT) GetContractToken(contract, tokenID string) (Token, error) {
var tokenResponse []Token

u := url.URL{
Scheme: "https",
Host: c.endpoint,
Expand All @@ -233,7 +254,13 @@ func (c *TZKT) GetContractToken(contract, tokenID string) (Token, error) {
}.Encode(),
}

req, _ := http.NewRequest("GET", u.String(), nil)
var tokenResponse []Token

req, err := http.NewRequest("GET", u.String(), nil)
if err != nil {
return Token{}, err
}

if err := c.request(req, &tokenResponse); err != nil {
return Token{}, err
}
Expand Down

0 comments on commit 3c76d27

Please sign in to comment.