···

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

     

       
323
       
323
       
 
       
                    count += 1;

     

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

     

       
325
       
325
       
-
       
                    let mut timestamp = hit.timestamp;

     

       
326
       
326
       
-
       
                    // check if timestamp is microseconds, convert to seconds if it is

     

       
327
       
327
       
-
       
                    if timestamp > 10_000_000_000 {

     

       
328
       
328
       
-
       
                        timestamp /= 1_000_000;

     

       
329
       
329
       
-
       
                    }

     

       
330
       
325
       
 
       
                    EventRecord {

     

       
331
       
326
       
 
       
                        nsid: nsid.to_smolstr(),

     

       
332
       
332
       
-
       
                        timestamp,

     

       
327
       
327
       
+
       
                        timestamp: hit.timestamp,

     

       
333
       
328
       
 
       
                        deleted: hit.deser().unwrap().deleted,

     

       
334
       
329
       
 
       
                    }

     

       
335
       
330
       
 
       
                }))