fix: tracking job offer update events (#194)

* chore: no need to fetch the evn var everytime

* chore: remove job offer update subscription

* fix: track job offer update before calling all subscriptions

pkg/jobcreator/controller.go

@@ -128,6 +128,7 @@ func (controller *JobCreatorController) subscribeToSolver() error {
 				controller.log.Error("solver event", fmt.Errorf("RP received nil job offer"))
 				return
 			}
+			metricsDashboard.TrackJobOfferUpdate(*ev.JobOffer)
 			for _, sub := range controller.jobOfferSubscriptions {
 				go sub(*ev.JobOffer)
 			}

pkg/jobcreator/onchain_jobcreator.go

@@ -8,7 +8,6 @@ import (
 
 	"github.com/davecgh/go-spew/spew"
 	"github.com/lilypad-tech/lilypad/pkg/data"
-	"github.com/lilypad-tech/lilypad/pkg/metricsDashboard"
 	"github.com/lilypad-tech/lilypad/pkg/system"
 	"github.com/lilypad-tech/lilypad/pkg/web3"
 	jobcreatorweb3 "github.com/lilypad-tech/lilypad/pkg/web3/bindings/jobcreator"
@@ -64,8 +63,6 @@ func (jobCreator *OnChainJobCreator) Start(ctx context.Context, cm *system.Clean
 		return errorChan
 	}
 
-	jobCreator.SubscribeToJobOfferUpdates(metricsDashboard.TrackJobOfferUpdate)
-
 	jobCreator.controller.SubscribeToJobOfferUpdates(func(evOffer data.JobOfferContainer) {
 		if evOffer.State != data.GetAgreementStateIndex("ResultsAccepted") {
 			return

pkg/metricsDashboard/logger.go

@@ -16,8 +16,9 @@ const nodeInfoEndpoint = "nodes"
 const nodeConnectionEndpoint = "uptimes"
 const dealsEndpoint = "deals"
 
+var host = os.Getenv("API_HOST")
+
 func trackEvent(path string, json string) {
-	var host = os.Getenv("API_HOST")
 	if host == "" {
 		return
 	}