commit e7a0daef377fba861e3f556c1a4925f1eccd74ef · edavis.dev/monarch

edavis.dev / monarch

an app.bsky.* indexer

fork atom

break out of pump repos if context is done

Eric Davis 4 months ago e7a0daef d417a1e3

options

unified split

Changed files

cmd

backfiller

backfiller.go

cmd/backfiller/backfiller.go

···

       127
       127
        
       

     

       128
       128
        
       	var curs string

     

       129
       129
        
       	for {

     

       130
       130
       +
       		select {

     

       131
       131
       +
       		case <-ctx.Done():

     

       132
       132
       +
       			sl.Info("stopping repo pump")

     

       133
       133
       +
       			return nil

     

       134
       134
       +
       		default:

     

       135
       135
       +
       		}

     

       136
       136
       +
       

     

       130
       137
        
       		sl.Info("listing repos", "cursor", curs)

     

       131
       138
        
       		res, err := atproto.SyncListRepos(ctx, xrpcc, curs, 1000)

     

       132
       139
        
       		if err != nil {