Add helper function (#945)

cmd/api/handlers/helpers.go

@@ -0,0 +1,41 @@
+package handlers
+
+import (
+	"net/http"
+	"strings"
+
+	"github.com/baking-bad/bcdhub/internal/config"
+	"github.com/baking-bad/bcdhub/internal/models/types"
+	"github.com/gin-gonic/gin"
+)
+
+// ContractsHelpers -
+func ContractsHelpers() gin.HandlerFunc {
+	return func(c *gin.Context) {
+		ctx := c.MustGet("context").(*config.Context)
+
+		var req getByNetwork
+		if err := c.BindUri(&req); handleError(c, ctx.Storage, err, http.StatusNotFound) {
+			return
+		}
+
+		var args findContract
+		if err := c.BindQuery(&args); handleError(c, ctx.Storage, err, http.StatusBadRequest) {
+			return
+		}
+
+		splitted := strings.Split(args.Tags, ",")
+		tags := types.NewTags(splitted)
+		contract, err := ctx.Contracts.FindOne(tags)
+		if handleError(c, ctx.Storage, err, http.StatusNotFound) {
+			return
+		}
+
+		response, err := contractPostprocessing(ctx, contract)
+		if handleError(c, ctx.Storage, err, 0) {
+			return
+		}
+
+		c.SecureJSON(http.StatusOK, response)
+	}
+}

cmd/api/handlers/requests.go

@@ -249,3 +249,7 @@ type globalConstantsContractsRequest struct {
 type getViewsArgs struct {
 	Kind ViewSchemaKind `form:"kind" binding:"omitempty,oneof=off-chain on-chain"`
 }
+
+type findContract struct {
+	Tags string `form:"tags" binding:"omitempty"`
+}

cmd/api/main.go

@@ -119,6 +119,11 @@ func (api *app) makeRouter() {
 			}
 		}
 
+		helpers := v1.Group("helpers")
+		{
+			helpers.GET("contracts/:network", handlers.NetworkMiddleware(api.Contexts), cache.CachePage(store, time.Hour, handlers.ContractsHelpers()))
+		}
+
 		bigmap := v1.Group("bigmap/:network/:ptr")
 		bigmap.Use(handlers.NetworkMiddleware(api.Contexts))
 		{

internal/models/contract/repository.go

@@ -1,6 +1,10 @@
 package contract
 
-import "time"
+import (
+	"time"
+
+	"github.com/baking-bad/bcdhub/internal/models/types"
+)
 
 // Repository -
 type Repository interface {
@@ -15,6 +19,7 @@ type Repository interface {
 
 	// ScriptPart - returns part of script type. Part can be `storage`, `parameter` or `code`.
 	ScriptPart(address string, symLink, part string) ([]byte, error)
+	FindOne(tags types.Tags) (Contract, error)
 }
 
 // ScriptRepository -

internal/postgres/contract/storage.go

@@ -240,3 +240,14 @@ func (storage *Storage) RecentlyCalled(offset, size int64) (contracts []contract
 func (storage *Storage) Count() (int, error) {
 	return storage.DB.Model((*contract.Contract)(nil)).CountEstimate(1000000)
 }
+
+// FindOne -
+func (storage *Storage) FindOne(tags types.Tags) (result contract.Contract, err error) {
+	err = storage.DB.Model(&result).
+		Where("tags&? > 0", tags).
+		ColumnExpr("contract.id, contract.tx_count, contract.last_action, contract.account_id, contract.timestamp, contract.level").
+		ColumnExpr("account.address as account__address, account.alias as account__alias").
+		Join(`LEFT JOIN "accounts" AS "account" ON "account"."id" = "contract"."account_id"`).
+		First()
+	return
+}