···

       
304
       
304
       
 
       
                to.ingest_events(hits.map(|hit| {

     

       
305
       
305
       
 
       
                    count += 1;

     

       
306
       
306
       
 
       
                    let hit = hit.expect("cant decode hit");

     

       
307
       
307
       
+
       
                    let mut timestamp = hit.timestamp;

     

       
308
       
308
       
+
       
                    // check if timestamp is microseconds, convert to seconds if it is

     

       
309
       
309
       
+
       
                    if timestamp > 10_000_000_000 {

     

       
310
       
310
       
+
       
                        timestamp /= 1_000_000;

     

       
311
       
311
       
+
       
                    }

     

       
307
       
312
       
 
       
                    EventRecord {

     

       
308
       
313
       
 
       
                        nsid: nsid.to_smolstr(),

     

       
309
       
309
       
-
       
                        timestamp: hit.timestamp,

     

       
314
       
314
       
+
       
                        timestamp,

     

       
310
       
315
       
 
       
                        deleted: hit.deser().unwrap().deleted,

     

       
311
       
316
       
 
       
                    }

     

       
312
       
317
       
 
       
                }))