···

       
259
       
259
       
 
       


     

       
260
       
260
       
 
       
	fmt.Println("querying clickhouse for dids and services...")

     

       
261
       
261
       
 
       


     

       
262
       
262
       
-
       
	var alreadyFetched []string

     

       
262
       
262
       
+
       
	type alreadyFetchedItem struct {

     

       
263
       
263
       
+
       
		Did string `ch:"did"`

     

       
264
       
264
       
+
       
	}

     

       
265
       
265
       
+
       
	var alreadyFetched []alreadyFetchedItem

     

       
263
       
266
       
 
       
	if err := p.conn.Select(ctx, &alreadyFetched, "SELECT DISTINCT(did) FROM default.record WHERE created_at < '2025-07-01'"); err != nil {

     

       
264
       
267
       
 
       
		return err

     

       
265
       
268
       
 
       
	}

     

       
266
       
269
       
 
       


     

       
267
       
270
       
 
       
	alreadyFetchedMap := map[string]bool{}

     

       
268
       
271
       
 
       
	for _, d := range alreadyFetched {

     

       
269
       
269
       
-
       
		alreadyFetchedMap[d] = true

     

       
272
       
272
       
+
       
		alreadyFetchedMap[d.Did] = true

     

       
270
       
273
       
 
       
	}

     

       
271
       
274
       
 
       


     

       
272
       
275
       
 
       
	fmt.Println("getting dids")