···

       
70
       
 
       
	sched := parallel.NewScheduler(1, 50, "firehose", rsc.EventHandler)

     

       
71
       
 
       


     

       
72
       
 
       
	if err := events.HandleRepoStream(ctx, app.wsconn, sched, nil); err != nil {

     

       
73
       
-
       
		return fmt.Errorf("error starting repo stream handler: %w", err)

     

       
74
       
 
       
	}

     

       
75
       
 
       


     

       
76
       
 
       
	return nil

     
···

       
83
       
 
       
			return fmt.Errorf("error getting raw DB: %w", err)

     

       
84
       
 
       
		}

     

       
85
       
 
       
		if err := raw.Close(); err != nil {

     

       
86
       
-
       
			return fmt.Errorf("error closing DB: %w", err)

     

       
87
       
 
       
		}

     

       
88
       
 
       
		return nil

     

       
89
       
 
       
	}

     

       
90
       
 
       


     

       
91
       
-
       
	app.backfill.Stop(ctx)

     

       
0
       
 
       

     

       
0
       
 
       

     

       
92
       
 
       


     

       
93
       
-
       
	closeDatabase(app.state)

     

       
94
       
-
       
	closeDatabase(app.content)

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
95
       
 
       


     

       
96
       
 
       
	return nil

     

       
97
       
 
       
}

     
···

       
108
       
 
       
	<-ctx.Done()

     

       
109
       
 
       
	slog.Info("shutting down")

     

       
110
       
 
       


     

       
111
       
-
       
	endctx, cancel := context.WithTimeout(context.TODO(), time.Second*15)

     

       
112
       
 
       
	defer cancel()

     

       
113
       
 
       


     

       
114
       
 
       
	if err := app.Stop(endctx); err != nil {

     

···

       
70
       
 
       
	sched := parallel.NewScheduler(1, 50, "firehose", rsc.EventHandler)

     

       
71
       
 
       


     

       
72
       
 
       
	if err := events.HandleRepoStream(ctx, app.wsconn, sched, nil); err != nil {

     

       
73
       
+
       
		slog.Info("exiting repo stream handler", "err", err)

     

       
74
       
 
       
	}

     

       
75
       
 
       


     

       
76
       
 
       
	return nil

     
···

       
83
       
 
       
			return fmt.Errorf("error getting raw DB: %w", err)

     

       
84
       
 
       
		}

     

       
85
       
 
       
		if err := raw.Close(); err != nil {

     

       
86
       
+
       
			return fmt.Errorf("DB close failed: %w", err)

     

       
87
       
 
       
		}

     

       
88
       
 
       
		return nil

     

       
89
       
 
       
	}

     

       
90
       
 
       


     

       
91
       
+
       
	if err := app.backfill.Stop(ctx); err != nil {

     

       
92
       
+
       
		slog.Error("error stopping backfiller", "err", err)

     

       
93
       
+
       
	}

     

       
94
       
 
       


     

       
95
       
+
       
	if err := closeDatabase(app.state); err != nil {

     

       
96
       
+
       
		slog.Error("error closing DB", "err", err)

     

       
97
       
+
       
	}

     

       
98
       
+
       
	if err := closeDatabase(app.content); err != nil {

     

       
99
       
+
       
		slog.Error("error closing DB", "err", err)

     

       
100
       
+
       
	}

     

       
101
       
 
       


     

       
102
       
 
       
	return nil

     

       
103
       
 
       
}

     
···

       
114
       
 
       
	<-ctx.Done()

     

       
115
       
 
       
	slog.Info("shutting down")

     

       
116
       
 
       


     

       
117
       
+
       
	endctx, cancel := context.WithTimeout(context.TODO(), time.Minute)

     

       
118
       
 
       
	defer cancel()

     

       
119
       
 
       


     

       
120
       
 
       
	if err := app.Stop(endctx); err != nil {