···

       
173
       
173
       
 
       
				continue

     

       
174
       
174
       
 
       
			}

     

       
175
       
175
       
 
       
			drafts.Delete(like.Subject.Uri)

     

       
176
       
176
       
-
       
			log.Println("graduating", like.Subject.Uri)

     

       
176
       
176
       
+
       
			log.Println("storing", like.Subject.Uri, "in database")

     

       
177
       
177
       
 
       
			err := queries.InsertPost(ctx, mostliked.InsertPostParams{

     

       
178
       
178
       
 
       
				Uri:      like.Subject.Uri,

     

       
179
       
179
       
 
       
				CreateTs: draftPost.Created,

     
···

       
208
       
208
       
 
       
	jetstreamEvents := make(chan []byte)

     

       
209
       
209
       
 
       
	go processEvents(jetstreamEvents)

     

       
210
       
210
       
 
       


     

       
211
       
211
       
+
       
	log.Println("starting up")

     

       
211
       
212
       
 
       
	for {

     

       
212
       
213
       
 
       
		_, message, err := conn.ReadMessage()

     

       
213
       
214
       
 
       
		if err != nil {