all contracts

Author: tehranifar

Dockerfile

@@ -2,5 +2,5 @@ FROM golang:1.17
 RUN mkdir /app
 ADD . /app
 WORKDIR /app
-RUN go build -o main .
-CMD ["/app/main"]
+RUN go build -o ff .
+CMD ["/app/ff"]

docker-compose.yml

@@ -4,8 +4,7 @@ services:
   ff:
     build:
       context: ./
-      dockerfile: Dockerfile
-    container_name: ff    
+      dockerfile: Dockerfile    
     ports:
       - '2112:2112'
 
@@ -23,8 +22,7 @@ services:
       - 9090:9090
 
   grafana:  
-    image: grafana/grafana:latest
-    container_name: grafana
+    image: grafana/grafana:latest  
     ports:
       - "3000:3000"
     volumes:

follower/cadence.go

@@ -0,0 +1,32 @@
+package follower
+
+import (
+	"regexp"
+)
+
+var knownImports = map[string]string{
+	"c1e4f4f4c4257510": "TopShotMarket",
+	"329feb3ab062d289": "RaceDay",
+	"64f83c60989ce555": "ChainmonstersMarket",
+	"3c5959b568896393": "FUSD",
+}
+
+type CadenceImport struct {
+	Contract string
+	Address  string
+}
+
+func GetImports(code string) []CadenceImport {
+	r, _ := regexp.Compile("import (?P<Contract>\\w*) from 0x(?P<Address>[0-9a-f]*)")
+	matches := r.FindAllStringSubmatch(code, -1)
+
+	var returnList []CadenceImport
+	for i := range matches {
+		returnList = append(returnList, CadenceImport{
+			Contract: matches[i][1],
+			Address:  matches[i][2],
+		})
+	}
+
+	return returnList
+}

follower/follower.go

@@ -5,7 +5,6 @@ import (
 	"fmt"
 	"strings"
 	"tehranifar/fflow/storage"
-	"tehranifar/fflow/tags"
 	"time"
 
 	"github.com/onflow/flow-go-sdk"
@@ -75,25 +74,33 @@ func (f *Follower) processBlock(ctx context.Context, block *flow.Block) error {
 			}
 
 			txError := ""
+			failed := false
 			if txRes.Error != nil {
 				txError = txRes.Error.Error()
+				failed = true
 			}
 
-			importTags := tags.ProcessImportTags(string(tx.Script))
-			for _, tag := range importTags {
-				failed := false
-				if txRes.Error != nil {
-					failed = true
-				}
-				RegisterTagMetrics(tag, failed)
+			var tagList []string
+			CadenceImports := GetImports(string(tx.Script))
+			for _, imp := range CadenceImports {
+				RegisterImportMetrics(imp, failed)
+				tagList = append(tagList, imp.Contract)
+				tagList = append(tagList, imp.Address)
 			}
-			dbTags := strings.Join(importTags, ",")
+			dbImportTags := strings.Join(tagList, ",")
+
+			var authAddressList []string
+			for _, auth := range tx.Authorizers {
+				authAddressList = append(authAddressList, auth.String())
+			}
+			dbAuthorizer := strings.Join(authAddressList, ",")
 
 			f.storage.Save(&storage.Transaction{
-				Tx:    txID.String(),
-				Code:  string(tx.Script),
-				Error: txError,
-				Tags:  dbTags,
+				Authorizers: dbAuthorizer,
+				Tx:          txID.String(),
+				Code:        string(tx.Script),
+				Error:       txError,
+				ImportTags:  dbImportTags,
 			})
 
 		}

follower/metrics.go

@@ -12,10 +12,10 @@ var (
 		Name: "import_tag_total",
 		Help: "The total number of observed known imports",
 	}, []string{
-		"contract", "failed",
+		"contract", "address", "failed",
 	})
 )
 
-func RegisterTagMetrics(contract string, failed bool) {
-	tagsObserved.WithLabelValues(contract, strconv.FormatBool(failed)).Inc()
+func RegisterImportMetrics(imp CadenceImport, failed bool) {
+	tagsObserved.WithLabelValues(imp.Contract, imp.Address, strconv.FormatBool(failed)).Inc()
 }

main.go

@@ -17,7 +17,6 @@ import (
 //
 //
 // - deploy to ec2
-// - more contracts
 // - create panels
 // - event listener (from tx list)
 // - event metrics

prometheus/prometheus.yml

@@ -1,6 +1,6 @@
 global:
-  scrape_interval:     1s
-  evaluation_interval: 1s
+  scrape_interval:     15s
+  evaluation_interval: 15s
 
 scrape_configs:
   - job_name: prometheus

storage/store.go

@@ -16,10 +16,11 @@ type Storage struct {
 type Transaction struct {
 	gorm.Model
 
-	Tx    string
-	Code  string
-	Error string
-	Tags  string
+	Authorizers string
+	Tx          string
+	Code        string
+	Error       string
+	ImportTags  string
 }
 
 func NewSqliteStorage() (Provider, error) {