less panics

cmd/internal/initializer/initializer.go

@@ -53,7 +53,7 @@ func New(log *slog.Logger, addr string, db database.Database, bp providers.Backu
 }
 
 // Start starts the initializer, which includes a server component and the initializer itself, which is potentially restoring a backup
-func (i *Initializer) Start(ctx context.Context) {
+func (i *Initializer) Start(ctx context.Context) error {
 	opts := []grpc.ServerOption{
 		grpc.StreamInterceptor(grpc_middleware.ChainStreamServer(
 			grpc_ctxtags.StreamServerInterceptor(),
@@ -92,7 +92,7 @@ func (i *Initializer) Start(ctx context.Context) {
 	lis, err := net.Listen("tcp", i.addr)
 	if err != nil {
 		i.log.Error("failed to listen", "error", err)
-		panic(err)
+		return err
 	}
 
 	go func() {
@@ -111,20 +111,21 @@ func (i *Initializer) Start(ctx context.Context) {
 	err = i.initialize(ctx)
 	if err != nil {
 		i.log.Error("error initializing database, shutting down", "error", err)
-		panic(err)
+		return err
 	}
 
 	i.currentStatus.Status = v1.StatusResponse_UPGRADING
 	i.currentStatus.Message = "start upgrading database"
 	err = i.db.Upgrade(ctx)
 	if err != nil {
 		i.log.Error("upgrade database failed", "error", err)
-		panic(err)
+		return err
 	}
 
 	i.log.Info("initializer done")
 	i.currentStatus.Status = v1.StatusResponse_DONE
 	i.currentStatus.Message = "done"
+	return nil
 }
 
 func (i *Initializer) initialize(ctx context.Context) error {

cmd/main.go

@@ -150,7 +150,9 @@ var startCmd = &cobra.Command{
 		metrics := metrics.New()
 		metrics.Start(logger.WithGroup("metrics"))
 
-		initializer.New(logger.WithGroup("initializer"), addr, db, bp, comp, metrics, viper.GetString(databaseDatadirFlg)).Start(stop)
+		if err := initializer.New(logger.WithGroup("initializer"), addr, db, bp, comp, metrics, viper.GetString(databaseDatadirFlg)).Start(stop); err != nil {
+			return err
+		}
 
 		if err := probe.Start(stop, logger.WithGroup("probe"), db); err != nil {
 			return err