commit 5b5b07d04c01e720c46d46352b512535c2a1ae47 · edavis.dev/bsky-feeds

cmd/mostliked/main.go

···

       52
        
       		for {

     

       53
        
       			_, message, err := conn.ReadMessage()

     

       54
        
       			if err != nil {

     

       0
        
       
     

       55
        
       				stop()

     

       0
        
       
     

       56
        
       			}

     

       57
        
       			jetstreamEvents <- message

     

       58
        
       		}

···

       52
        
       		for {

     

       53
        
       			_, message, err := conn.ReadMessage()

     

       54
        
       			if err != nil {

     

       55
       +
       				log.Printf("ReadJSON error: %v\n", err)

     

       56
        
       				stop()

     

       57
       +
       				break

     

       58
        
       			}

     

       59
        
       			jetstreamEvents <- message

     

       60
        
       		}

pkg/mostliked/handler.go

···

       86
        
       		eventCount int

     

       87
        
       	)

     

       88
        
       

     

       0
        
       
     

       89
        
       	for evt := range events {

     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       90
        
       		if !txOpen {

     

       91
        
       			dbTx, err = dbCnx.BeginTx(ctx, nil)

     

       92
        
       			if err != nil {

···

       86
        
       		eventCount int

     

       87
        
       	)

     

       88
        
       

     

       89
       +
       forLoop:

     

       90
        
       	for evt := range events {

     

       91
       +
       		select {

     

       92
       +
       		case <-ctx.Done():

     

       93
       +
       			break forLoop

     

       94
       +
       		default:

     

       95
       +
       		}

     

       96
       +
       

     

       97
        
       		if !txOpen {

     

       98
        
       			dbTx, err = dbCnx.BeginTx(ctx, nil)

     

       99
        
       			if err != nil {