TzKT API: some methods

Author: aopoltorzhicky

tzkt/api/api.go

@@ -4,9 +4,11 @@ import (
 	"bytes"
 	"context"
 	"fmt"
+	"io"
 	"io/ioutil"
 	"net/http"
 	"net/url"
+	"os"
 	"path"
 	"strconv"
 	"time"
@@ -117,11 +119,10 @@ func (tzkt *API) json(ctx context.Context, endpoint string, args map[string]stri
 	case http.StatusNoContent:
 		return nil
 	default:
-		body, err := ioutil.ReadAll(resp.Body)
-		if err != nil {
+		if _, err := io.Copy(os.Stdout, resp.Body); err != nil {
 			return err
 		}
-		return errors.New(fmt.Sprintf("%s: %s %s %v", resp.Status, string(body), endpoint, args))
+		return errors.New(fmt.Sprintf("%s: %s %v", resp.Status, endpoint, args))
 	}
 }
 

tzkt/api/data.go

@@ -22,6 +22,11 @@ const (
 	KindRegisterGlobalConstant = "register_constant"
 )
 
+// urls
+const (
+	BaseURL = "https://api.tzkt.io"
+)
+
 // Operation -
 type Operation struct {
 	ID         uint64      `json:"id" mapstructure:"id"`

tzkt/api/operations.go

@@ -2,6 +2,10 @@ package api
 
 import (
 	"context"
+	"fmt"
+
+	"github.com/dipdup-net/go-lib/tools"
+	"github.com/pkg/errors"
 )
 
 // GetEndorsements -
@@ -81,3 +85,18 @@ func (tzkt *API) GetMigrations(ctx context.Context, filters map[string]string) (
 	err = tzkt.json(ctx, "/v1/operations/migrations", filters, false, &operations)
 	return
 }
+
+// GetOperationsByHash -
+func (tzkt *API) GetOperationsByHash(ctx context.Context, hash string, filters map[string]string) (operations []Operation, err error) {
+	err = tzkt.json(ctx, fmt.Sprintf("/v1/operations/%s", hash), filters, false, &operations)
+	return
+}
+
+// GetTransactionsByHash -
+func (tzkt *API) GetTransactionsByHash(ctx context.Context, hash string, filters map[string]string) (operations []Transaction, err error) {
+	if !tools.IsOperationHash(hash) {
+		return nil, errors.Errorf("invalid operation hash: %s", hash)
+	}
+	err = tzkt.json(ctx, fmt.Sprintf("/v1/operations/transactions/%s", hash), filters, false, &operations)
+	return
+}