logs can stay

Author: julienrbrt

block/internal/submitting/da_submitter.go

@@ -399,10 +399,11 @@ func submitToDA[T any](
 
 		submitCtx, cancel := context.WithTimeout(ctx, submissionTimeout)
 		defer cancel()
+
 		// Perform submission
 		start := time.Now()
 		res := types.SubmitWithHelpers(submitCtx, s.da, s.logger, marshaled, rs.GasPrice, namespace, options)
-		s.logger.Info().Int("attempts", rs.Attempt).Dur("elapsed", time.Since(start)).Msg("got SubmitWithHelpers response from celestia")
+		s.logger.Debug().Int("attempts", rs.Attempt).Dur("elapsed", time.Since(start)).Uint64("code", uint64(res.Code)).Msg("got SubmitWithHelpers response from celestia")
 
 		// Record submission result for observability
 		if daVisualizationServer := server.GetDAVisualizationServer(); daVisualizationServer != nil {

block/internal/submitting/submitter.go

@@ -154,12 +154,12 @@ func (s *Submitter) daSubmissionLoop() {
 		case <-ticker.C:
 			// Submit headers
 			if headersNb := s.cache.NumPendingHeaders(); headersNb != 0 {
-				s.logger.Info().Time("t", time.Now()).Uint64("headers", headersNb).Msg("Submitting headers")
+				s.logger.Debug().Time("t", time.Now()).Uint64("headers", headersNb).Msg("Submitting headers")
 				if s.headerSubmissionMtx.TryLock() {
-					s.logger.Warn().Time("t", time.Now()).Uint64("headers", headersNb).Msg("Header submission in progress")
+					s.logger.Debug().Time("t", time.Now()).Uint64("headers", headersNb).Msg("Header submission in progress")
 					go func() {
 						defer func() {
-							s.logger.Info().Time("t", time.Now()).Uint64("headers", headersNb).Msg("Header submission completed")
+							s.logger.Debug().Time("t", time.Now()).Uint64("headers", headersNb).Msg("Header submission completed")
 							s.headerSubmissionMtx.Unlock()
 						}()
 						if err := s.daSubmitter.SubmitHeaders(s.ctx, s.cache); err != nil {
@@ -178,12 +178,12 @@ func (s *Submitter) daSubmissionLoop() {
 
 			// Submit data
 			if dataNb := s.cache.NumPendingData(); dataNb != 0 {
-				s.logger.Info().Time("t", time.Now()).Uint64("data", dataNb).Msg("Submitting data")
+				s.logger.Debug().Time("t", time.Now()).Uint64("data", dataNb).Msg("Submitting data")
 				if s.dataSubmissionMtx.TryLock() {
-					s.logger.Info().Time("t", time.Now()).Uint64("data", dataNb).Msg("Data submission in progress")
+					s.logger.Debug().Time("t", time.Now()).Uint64("data", dataNb).Msg("Data submission in progress")
 					go func() {
 						defer func() {
-							s.logger.Info().Time("t", time.Now()).Uint64("data", dataNb).Msg("Data submission completed")
+							s.logger.Debug().Time("t", time.Now()).Uint64("data", dataNb).Msg("Data submission completed")
 							s.dataSubmissionMtx.Unlock()
 						}()
 						if err := s.daSubmitter.SubmitData(s.ctx, s.cache, s.signer, s.genesis); err != nil {