fix lint error

dymensionxyz · May 15, 2024 · b1b785f · b1b785f
1 parent 50bec52
commit b1b785f
Showing 1 changed file with 46 additions and 41 deletions.
diff --git a/da/celestia/celestia.go b/da/celestia/celestia.go
@@ -139,53 +139,58 @@ func (c *DataAvailabilityLayerClient) Start() (err error) {
 		return err
 	}
 
-	go retry.Do(
-		func() error {
-			state, err := rpc.Header.SyncState(c.ctx)
-			if err != nil {
-				c.logger.Error("Failed to start Celestia DA.", "Error", err)
-				return err
-			}
-
-			if !state.Finished() {
-				c.logger.Info("waiting for celestia-node to finish syncing", "height", state.Height, "target", state.ToHeight)
-
-				done := make(chan error, 1)
-				go func() {
-					done <- rpc.Header.SyncWait(c.ctx)
-				}()
-
-				ticker := time.NewTicker(1 * time.Minute)
-				defer ticker.Stop()
+	go func() {
+		err := retry.Do(
+			func() error {
+				state, err := rpc.Header.SyncState(c.ctx)
+				if err != nil {
+					c.logger.Error("Failed to start Celestia DA.", "Error", err)
+					return err
+				}
 
-				for {
-					select {
-					case err := <-done:
-						if err != nil {
-							return err
+				if !state.Finished() {
+					c.logger.Info("waiting for celestia-node to finish syncing", "height", state.Height, "target", state.ToHeight)
+
+					done := make(chan error, 1)
+					go func() {
+						done <- rpc.Header.SyncWait(c.ctx)
+					}()
+
+					ticker := time.NewTicker(1 * time.Minute)
+					defer ticker.Stop()
+
+					for {
+						select {
+						case err := <-done:
+							if err != nil {
+								return err
+							}
+							return nil
+						case <-ticker.C:
+							state, err := rpc.Header.SyncState(c.ctx)
+							if err != nil {
+								return err
+							}
+							c.logger.Info("celestia-node still syncing", "height", state.Height, "target", state.ToHeight)
 						}
-						return nil
-					case <-ticker.C:
-						state, err := rpc.Header.SyncState(c.ctx)
-						if err != nil {
-							return err
-						}
-						c.logger.Info("celestia-node still syncing", "height", state.Height, "target", state.ToHeight)
 					}
 				}
-			}
 
-			c.rpc = NewOpenRPC(rpc)
-			c.started <- struct{}{}
-			c.logger.Info("celestia-node is synced", "height", state.ToHeight)
+				c.rpc = NewOpenRPC(rpc)
+				c.started <- struct{}{}
+				c.logger.Info("celestia-node is synced", "height", state.ToHeight)
 
-			return nil
-		},
-		retry.Attempts(0), // try forever
-		retry.Delay(10*time.Second),
-		retry.LastErrorOnly(true),
-		retry.DelayType(retry.FixedDelay),
-	)
+				return nil
+			},
+			retry.Attempts(0), // try forever
+			retry.Delay(10*time.Second),
+			retry.LastErrorOnly(true),
+			retry.DelayType(retry.FixedDelay),
+		)
+		if err != nil {
+			c.logger.Error("Error when waiting for Celestia data availability client to sync", "err", err)
+		}
+	}()
 	return nil
 
 }