logs cleanup (#63)

cmd/light-client/main.go

@@ -41,7 +41,6 @@ var rootCmd = &cobra.Command{
 	Version: fmt.Sprintf("%s, commit %s", common.Version, common.GitCommit),
 	PersistentPreRun: func(cmd *cobra.Command, args []string) {
 		logging.SetLogLevel("*", loglevel)
-		logging.SetLogLevel("rpc", "error")
 
 		// Load the configuration
 		config := das.LoadConfig()

internal/light-client/poller/challenge.go

@@ -138,7 +138,7 @@ func (c *Challenge) Solve(workload *pb.Workload, identity *utils.Identity) (bool
 	// Compare the target
 	switch c.ClauseType.Type {
 	case "Modulo":
-		log.Infof("Solving Modulo challenge M=%s, K=%s", c.ClauseType.M, c.ClauseType.K)
+		log.Debugf("Modulo challenge M=%s, K=%s ...", c.ClauseType.M, c.ClauseType.K)
 		eligible, err := c.solveModulo(target, c.ClauseType.M, c.ClauseType.K)
 		if err != nil {
 			return false, nil, fmt.Errorf("failed to solve Modulo challenge: %w", err)

internal/light-client/poller/poll.go

@@ -48,6 +48,7 @@ func (p *WorkloadPoller) periodicPoll() {
 		}
 
 		// Process the workloads
+
 		for _, workload := range response.Workloads {
 			log.Debugf("processing workload: %v", workload.GetWorkload().ReadableString())
 			challenge, err := Decode(workload.Workload.Challenge)
@@ -60,12 +61,15 @@ func (p *WorkloadPoller) periodicPoll() {
 				log.Errorf("failed to solve challenge: %s", err)
 			}
 
-			log.Infof("workload is eligible: %v", eligible)
+			log.Debugf("workload is eligible: %v", eligible)
 			if eligible {
+				log.Infof("workload for CID %s is eligible", workload.GetWorkload().GetCID().String())
 				p.sampler.ProcessEvent(workload, seed)
 			}
 		}
 
+		log.Infof("%d workloads available", len(response.Workloads))
+
 		// unix timestamp to time
 		nextUpdate := time.Unix(int64(response.NextUpdateTimestamp), 0)
 

internal/light-client/schemapb/utils.go

@@ -22,3 +22,8 @@ func (w *Workload) ReadableString() string {
 		w.Challenge,
 	)
 }
+
+func (w *Workload) GetCID() *cid.Cid {
+	c, _ := cid.Cast(w.IpfsCid)
+	return &c
+}