commit e247a230d3c995a281ea6bb17e3c10ac84105bb0 · hailey.at/photocopy

cmd/photocopy/main.go

···

       124
       124
        
       		sig := <-exitSignals

     

       125
       125
        
       

     

       126
       126
        
       		l.Info("received os exit signal", "signal", sig)

     

       127
       127
       +
       		cancel()

     

       127
       128
        
       	}()

     

       128
       129
        
       

     

       129
       130
        
       	if err := p.Run(ctx); err != nil {

+48

photocopy.go

···

       225
       225
        
       			}()

     

       226
       226
        
       		}

     

       227
       227
        
       

     

       228
       228
       +
       		if p.inserters.interactionsInserter != nil {

     

       229
       229
       +
       			p.wg.Add(1)

     

       230
       230
       +
       			go func() {

     

       231
       231
       +
       				defer p.wg.Done()

     

       232
       232
       +
       				if err := p.inserters.interactionsInserter.Close(ctx); err != nil {

     

       233
       233
       +
       					p.logger.Error("failed to close interactions inserter", "error", err)

     

       234
       234
       +
       					return

     

       235
       235
       +
       				}

     

       236
       236
       +
       				p.logger.Info("interactions inserter closed")

     

       237
       237
       +
       			}()

     

       238
       238
       +
       		}

     

       239
       239
       +
       

     

       240
       240
       +
       		if p.inserters.postsInserter != nil {

     

       241
       241
       +
       			p.wg.Add(1)

     

       242
       242
       +
       			go func() {

     

       243
       243
       +
       				defer p.wg.Done()

     

       244
       244
       +
       				if err := p.inserters.postsInserter.Close(ctx); err != nil {

     

       245
       245
       +
       					p.logger.Error("failed to close posts inserter", "error", err)

     

       246
       246
       +
       					return

     

       247
       247
       +
       				}

     

       248
       248
       +
       				p.logger.Info("posts inserter closed")

     

       249
       249
       +
       			}()

     

       250
       250
       +
       		}

     

       251
       251
       +
       

     

       252
       252
       +
       		if p.inserters.recordsInserter != nil {

     

       253
       253
       +
       			p.wg.Add(1)

     

       254
       254
       +
       			go func() {

     

       255
       255
       +
       				defer p.wg.Done()

     

       256
       256
       +
       				if err := p.inserters.recordsInserter.Close(ctx); err != nil {

     

       257
       257
       +
       					p.logger.Error("failed to close records inserter", "error", err)

     

       258
       258
       +
       					return

     

       259
       259
       +
       				}

     

       260
       260
       +
       				p.logger.Info("records inserter closed")

     

       261
       261
       +
       			}()

     

       262
       262
       +
       		}

     

       263
       263
       +
       

     

       264
       264
       +
       		if p.inserters.deletesInserter != nil {

     

       265
       265
       +
       			p.wg.Add(1)

     

       266
       266
       +
       			go func() {

     

       267
       267
       +
       				defer p.wg.Done()

     

       268
       268
       +
       				if err := p.inserters.deletesInserter.Close(ctx); err != nil {

     

       269
       269
       +
       					p.logger.Error("failed to close deletes inserter", "error", err)

     

       270
       270
       +
       					return

     

       271
       271
       +
       				}

     

       272
       272
       +
       				p.logger.Info("deletes inserter closed")

     

       273
       273
       +
       			}()

     

       274
       274
       +
       		}

     

       275
       275
       +
       

     

       228
       276
        
       		if p.inserters.plcInserter != nil {

     

       229
       277
        
       			p.wg.Add(1)

     

       230
       278
        
       			go func() {