1use anyhow::{Context, Result};
17use std::collections::HashMap;
18use std::fs::{File, OpenOptions};
19use std::io::Write;
20use std::path::{Path, PathBuf};
21
22pub type Trigram = u32;
24
25const MAGIC: &[u8; 4] = b"RFTG"; const VERSION: u32 = 3; #[allow(dead_code)]
30const HEADER_SIZE: usize = 24;
31
32fn write_varint(writer: &mut impl Write, mut value: u32) -> std::io::Result<()> {
35 loop {
36 let mut byte = (value & 0x7F) as u8;
37 value >>= 7;
38 if value != 0 {
39 byte |= 0x80; }
41 writer.write_all(&[byte])?;
42 if value == 0 {
43 break;
44 }
45 }
46 Ok(())
47}
48
49fn read_varint(data: &[u8]) -> Result<(u32, usize)> {
51 let mut value: u32 = 0;
52 let mut shift = 0;
53 let mut pos = 0;
54
55 loop {
56 if pos >= data.len() {
57 anyhow::bail!("Truncated varint");
58 }
59 let byte = data[pos];
60 pos += 1;
61
62 value |= ((byte & 0x7F) as u32) << shift;
63 if byte & 0x80 == 0 {
64 break;
65 }
66 shift += 7;
67 if shift >= 32 {
68 anyhow::bail!("Varint too large");
69 }
70 }
71
72 Ok((value, pos))
73}
74
75fn decompress_posting_list(
85 mmap: &[u8],
86 offset: u64,
87 size: u32,
88) -> Result<Vec<FileLocation>> {
89 let start = offset as usize;
90 let end = start + size as usize;
91
92 if end > mmap.len() {
93 anyhow::bail!(
94 "Posting list out of bounds: offset={}, size={}, mmap_len={}",
95 offset,
96 size,
97 mmap.len()
98 );
99 }
100
101 let compressed_data = &mmap[start..end];
102
103 let mut locations = Vec::new();
105 let mut pos = 0;
106 let mut prev_file_id = 0u32;
107 let mut prev_line_no = 0u32;
108 let mut prev_byte_offset = 0u32;
109
110 while pos < compressed_data.len() {
111 let (file_id_delta, consumed) = read_varint(&compressed_data[pos..])?;
113 pos += consumed;
114
115 let (line_no_delta, consumed) = read_varint(&compressed_data[pos..])?;
117 pos += consumed;
118
119 let (byte_offset_delta, consumed) = read_varint(&compressed_data[pos..])?;
121 pos += consumed;
122
123 let file_id = prev_file_id.wrapping_add(file_id_delta);
125 let line_no = prev_line_no.wrapping_add(line_no_delta);
126 let byte_offset = prev_byte_offset.wrapping_add(byte_offset_delta);
127
128 locations.push(FileLocation {
129 file_id,
130 line_no,
131 byte_offset,
132 });
133
134 prev_file_id = file_id;
136 prev_line_no = line_no;
137 prev_byte_offset = byte_offset;
138 }
139
140 Ok(locations)
141}
142
143#[derive(Debug, Clone, Copy, PartialEq, Eq, PartialOrd, Ord)]
145pub struct FileLocation {
146 pub file_id: u32,
148 pub line_no: u32,
150 pub byte_offset: u32,
152}
153
154impl FileLocation {
155 pub fn new(file_id: u32, line_no: u32, byte_offset: u32) -> Self {
156 Self {
157 file_id,
158 line_no,
159 byte_offset,
160 }
161 }
162}
163
164#[derive(Debug, Clone)]
169struct DirectoryEntry {
170 trigram: Trigram,
172 data_offset: u64,
174 compressed_size: u32,
176}
177
178pub struct TrigramIndex {
189 index: Vec<(Trigram, Vec<FileLocation>)>,
192 files: Vec<PathBuf>,
194 temp_index: Option<HashMap<Trigram, Vec<FileLocation>>>,
196 mmap: Option<memmap2::Mmap>,
198 directory: Vec<DirectoryEntry>,
200 partial_indices: Vec<PathBuf>,
202 temp_dir: Option<PathBuf>,
204 max_posting_list_entries: usize,
207}
208
209impl TrigramIndex {
210 pub fn new() -> Self {
212 Self {
213 index: Vec::new(),
214 files: Vec::new(),
215 temp_index: Some(HashMap::new()),
216 mmap: None,
217 directory: Vec::new(),
218 partial_indices: Vec::new(),
219 temp_dir: None,
220 max_posting_list_entries: 0,
221 }
222 }
223
224 pub fn set_max_posting_list_entries(&mut self, cap: usize) {
226 self.max_posting_list_entries = cap;
227 }
228
229 pub fn enable_batch_flush(&mut self, temp_dir: PathBuf) -> Result<()> {
234 std::fs::create_dir_all(&temp_dir)
235 .context("Failed to create temp directory for batch flushing")?;
236 self.temp_dir = Some(temp_dir);
237 log::info!("Enabled batch-flush mode for trigram index");
238 Ok(())
239 }
240
241 pub fn flush_batch(&mut self) -> Result<()> {
246 let temp_dir = self.temp_dir.as_ref()
247 .ok_or_else(|| anyhow::anyhow!("Batch flush not enabled - call enable_batch_flush() first"))?;
248
249 let temp_map = self.temp_index.take()
251 .ok_or_else(|| anyhow::anyhow!("No temp index to flush"))?;
252
253 if temp_map.is_empty() {
254 self.temp_index = Some(HashMap::new());
256 return Ok(());
257 }
258
259 let mut partial_index: Vec<(Trigram, Vec<FileLocation>)> = temp_map.into_iter().collect();
261
262 for (_, list) in partial_index.iter_mut() {
264 list.sort_unstable();
265 list.dedup();
266 }
267
268 partial_index.sort_unstable_by_key(|(trigram, _)| *trigram);
270
271 let partial_file = temp_dir.join(format!("partial_{}.bin", self.partial_indices.len()));
273 self.write_partial_index(&partial_file, &partial_index)?;
274
275 self.partial_indices.push(partial_file);
276
277 self.temp_index = Some(HashMap::new());
279
280 log::debug!(
281 "Flushed batch {} with {} trigrams to disk",
282 self.partial_indices.len(),
283 partial_index.len()
284 );
285
286 Ok(())
287 }
288
289 fn write_partial_index(
291 &self,
292 path: &Path,
293 index: &[(Trigram, Vec<FileLocation>)],
294 ) -> Result<()> {
295 use std::io::BufWriter;
296
297 let file = OpenOptions::new()
298 .create(true)
299 .write(true)
300 .truncate(true)
301 .open(path)?;
302
303 let mut writer = BufWriter::with_capacity(16 * 1024 * 1024, file);
304
305 writer.write_all(&(index.len() as u64).to_le_bytes())?;
307
308 for (trigram, locations) in index {
310 writer.write_all(&trigram.to_le_bytes())?;
311 writer.write_all(&(locations.len() as u32).to_le_bytes())?;
312
313 for loc in locations {
314 writer.write_all(&loc.file_id.to_le_bytes())?;
315 writer.write_all(&loc.line_no.to_le_bytes())?;
316 writer.write_all(&loc.byte_offset.to_le_bytes())?;
317 }
318 }
319
320 writer.flush()?;
321 Ok(())
322 }
323
324 pub fn add_file(&mut self, path: PathBuf) -> u32 {
326 let file_id = self.files.len() as u32;
327 self.files.push(path);
328 file_id
329 }
330
331 pub fn get_file(&self, file_id: u32) -> Option<&PathBuf> {
333 self.files.get(file_id as usize)
334 }
335
336 pub fn file_count(&self) -> usize {
338 self.files.len()
339 }
340
341 pub fn trigram_count(&self) -> usize {
343 if !self.directory.is_empty() {
344 self.directory.len()
346 } else {
347 self.index.len()
349 }
350 }
351
352 pub fn index_file(&mut self, file_id: u32, content: &str) {
357 let trigrams = extract_trigrams_with_locations(content, file_id);
358
359 if let Some(ref mut temp_map) = self.temp_index {
361 for (trigram, location) in trigrams {
362 temp_map
363 .entry(trigram)
364 .or_insert_with(Vec::new)
365 .push(location);
366 }
367 } else {
368 panic!("Cannot call index_file() after finalize(). Index is read-only.");
369 }
370 }
371
372 pub fn build_from_trigrams(&mut self, trigrams: Vec<(Trigram, FileLocation)>) {
377 let mut temp_map: HashMap<Trigram, Vec<FileLocation>> = HashMap::new();
378
379 for (trigram, location) in trigrams {
381 temp_map
382 .entry(trigram)
383 .or_insert_with(Vec::new)
384 .push(location);
385 }
386
387 self.index = temp_map.into_iter().collect();
389
390 self.temp_index = None;
392
393 self.finalize();
395 }
396
397 pub fn finalize(&mut self) {
405 if !self.partial_indices.is_empty() {
408 log::info!("Deferring finalization - will stream merge {} partial indices during write()",
409 self.partial_indices.len());
410
411 if let Some(ref temp_map) = self.temp_index {
413 if !temp_map.is_empty() {
414 self.flush_batch().expect("Failed to flush final batch");
415 }
416 }
417
418 return;
420 }
421
422 if let Some(temp_map) = self.temp_index.take() {
425 self.index = temp_map.into_iter().collect();
426 }
427
428 let cap = self.max_posting_list_entries;
430 for (trigram, list) in self.index.iter_mut() {
431 list.sort_unstable();
432 list.dedup(); if cap > 0 && list.len() > cap {
434 log::warn!("Trigram 0x{:06X} posting list has {} entries (cap {}); truncating.", trigram, list.len(), cap);
435 list.truncate(cap);
436 }
437 }
438
439 self.index.sort_unstable_by_key(|(trigram, _)| *trigram);
441 }
442
443 fn merge_partial_indices_to_file(&mut self, output_path: &Path) -> Result<()> {
451 use std::io::{BufReader, BufWriter, Read};
452 use std::cmp::Ordering;
453 use std::collections::BinaryHeap;
454
455 log::info!("Streaming merge of {} partial indices to {:?}",
456 self.partial_indices.len(), output_path);
457
458 struct PartialIndexReader {
460 reader: BufReader<File>,
461 current_trigram: Option<Trigram>,
462 current_posting_list: Vec<FileLocation>,
463 reader_id: usize,
464 }
465
466 let mut readers: Vec<PartialIndexReader> = Vec::new();
467
468 for (idx, partial_path) in self.partial_indices.iter().enumerate() {
469 let file = File::open(partial_path)
470 .with_context(|| format!("Failed to open partial index: {:?}", partial_path))?;
471 let mut reader = BufReader::with_capacity(16 * 1024 * 1024, file);
472
473 let mut buf = [0u8; 8];
475 reader.read_exact(&mut buf)?;
476
477 readers.push(PartialIndexReader {
478 reader,
479 current_trigram: None,
480 current_posting_list: Vec::new(),
481 reader_id: idx,
482 });
483 }
484
485 fn read_next_trigram(reader: &mut PartialIndexReader) -> Result<bool> {
487 let mut trigram_buf = [0u8; 4];
489 match reader.reader.read_exact(&mut trigram_buf) {
490 Ok(_) => {
491 let trigram = u32::from_le_bytes(trigram_buf);
492
493 let mut len_buf = [0u8; 4];
495 reader.reader.read_exact(&mut len_buf)?;
496 let list_len = u32::from_le_bytes(len_buf) as usize;
497
498 let mut locations = Vec::with_capacity(list_len);
500 for _ in 0..list_len {
501 let mut loc_buf = [0u8; 12];
502 reader.reader.read_exact(&mut loc_buf)?;
503
504 let file_id = u32::from_le_bytes([loc_buf[0], loc_buf[1], loc_buf[2], loc_buf[3]]);
505 let line_no = u32::from_le_bytes([loc_buf[4], loc_buf[5], loc_buf[6], loc_buf[7]]);
506 let byte_offset = u32::from_le_bytes([loc_buf[8], loc_buf[9], loc_buf[10], loc_buf[11]]);
507
508 locations.push(FileLocation { file_id, line_no, byte_offset });
509 }
510
511 reader.current_trigram = Some(trigram);
512 reader.current_posting_list = locations;
513 Ok(true)
514 }
515 Err(e) if e.kind() == std::io::ErrorKind::UnexpectedEof => {
516 reader.current_trigram = None;
517 Ok(false)
518 }
519 Err(e) => Err(e.into()),
520 }
521 }
522
523 for reader in &mut readers {
525 read_next_trigram(reader)?;
526 }
527
528 #[derive(Eq, PartialEq)]
530 struct HeapEntry {
531 trigram: Trigram,
532 reader_id: usize,
533 }
534
535 impl Ord for HeapEntry {
536 fn cmp(&self, other: &Self) -> Ordering {
537 other.trigram.cmp(&self.trigram)
539 .then_with(|| other.reader_id.cmp(&self.reader_id))
540 }
541 }
542
543 impl PartialOrd for HeapEntry {
544 fn partial_cmp(&self, other: &Self) -> Option<Ordering> {
545 Some(self.cmp(other))
546 }
547 }
548
549 let mut heap: BinaryHeap<HeapEntry> = BinaryHeap::new();
551 for reader in &readers {
552 if let Some(trigram) = reader.current_trigram {
553 heap.push(HeapEntry {
554 trigram,
555 reader_id: reader.reader_id,
556 });
557 }
558 }
559
560 let file = OpenOptions::new()
562 .create(true)
563 .write(true)
564 .truncate(true)
565 .open(output_path)
566 .with_context(|| format!("Failed to create {}", output_path.display()))?;
567
568 let mut writer = BufWriter::with_capacity(16 * 1024 * 1024, file);
569
570 writer.write_all(MAGIC)?;
572 writer.write_all(&VERSION.to_le_bytes())?;
573 writer.write_all(&0u64.to_le_bytes())?; writer.write_all(&(self.files.len() as u64).to_le_bytes())?; let mut directory: Vec<DirectoryEntry> = Vec::new();
578 let mut num_trigrams = 0u64;
579
580 let mut current_trigram: Option<Trigram> = None;
582 let mut merged_locations: Vec<FileLocation> = Vec::new();
583
584 while let Some(entry) = heap.pop() {
585 let reader = &mut readers[entry.reader_id];
586
587 if current_trigram.is_some() && current_trigram != Some(entry.trigram) {
589 let trigram = current_trigram.unwrap();
591 merged_locations.sort_unstable();
592 merged_locations.dedup();
593
594 let cap = self.max_posting_list_entries;
595 if cap > 0 && merged_locations.len() > cap {
596 log::warn!("Trigram 0x{:06X} posting list has {} entries (cap {}); truncating.", trigram, merged_locations.len(), cap);
597 merged_locations.truncate(cap);
598 }
599
600 let data_offset = writer.stream_position()?;
602 let compressed_size = self.write_compressed_posting_list(&mut writer, &merged_locations)?;
603
604 directory.push(DirectoryEntry {
605 trigram,
606 data_offset,
607 compressed_size,
608 });
609
610 num_trigrams += 1;
611 merged_locations.clear();
612 }
613
614 current_trigram = Some(entry.trigram);
616
617 merged_locations.extend_from_slice(&reader.current_posting_list);
619
620 if read_next_trigram(reader)? {
622 if let Some(next_trigram) = reader.current_trigram {
623 heap.push(HeapEntry {
624 trigram: next_trigram,
625 reader_id: entry.reader_id,
626 });
627 }
628 }
629 }
630
631 if let Some(trigram) = current_trigram {
633 merged_locations.sort_unstable();
634 merged_locations.dedup();
635
636 let cap = self.max_posting_list_entries;
637 if cap > 0 && merged_locations.len() > cap {
638 log::warn!("Trigram 0x{:06X} posting list has {} entries (cap {}); truncating.", trigram, merged_locations.len(), cap);
639 merged_locations.truncate(cap);
640 }
641
642 let data_offset = writer.stream_position()?;
643 let compressed_size = self.write_compressed_posting_list(&mut writer, &merged_locations)?;
644
645 directory.push(DirectoryEntry {
646 trigram,
647 data_offset,
648 compressed_size,
649 });
650
651 num_trigrams += 1;
652 }
653
654 log::info!("Merged {} trigrams from {} partial indices", num_trigrams, self.partial_indices.len());
655
656 let _data_end_pos = writer.stream_position()?;
658
659 for file_path in &self.files {
661 let path_str = file_path.to_string_lossy();
662 let path_bytes = path_str.as_bytes();
663 write_varint(&mut writer, path_bytes.len() as u32)?;
664 writer.write_all(path_bytes)?;
665 }
666
667 writer.flush()?;
669 drop(writer);
670
671 use std::io::{Seek, SeekFrom};
674
675 let mut temp_data = Vec::new();
677 {
678 let mut file = File::open(output_path)?;
679 file.seek(SeekFrom::Start(HEADER_SIZE as u64))?;
680 file.read_to_end(&mut temp_data)?;
681 }
682
683 let file = OpenOptions::new().write(true).truncate(true).open(output_path)?;
685 let mut writer = BufWriter::with_capacity(16 * 1024 * 1024, file);
686
687 writer.write_all(MAGIC)?;
689 writer.write_all(&VERSION.to_le_bytes())?;
690 writer.write_all(&num_trigrams.to_le_bytes())?;
691 writer.write_all(&(self.files.len() as u64).to_le_bytes())?;
692
693 for entry in &directory {
695 writer.write_all(&entry.trigram.to_le_bytes())?;
696 let adjusted_offset = entry.data_offset + (directory.len() * 16) as u64;
698 writer.write_all(&adjusted_offset.to_le_bytes())?;
699 writer.write_all(&entry.compressed_size.to_le_bytes())?;
700 }
701
702 writer.write_all(&temp_data)?;
704
705 writer.flush()?;
707 writer.get_ref().sync_all()?;
708
709 for partial_path in &self.partial_indices {
711 let _ = std::fs::remove_file(partial_path);
712 }
713 if let Some(ref temp_dir) = self.temp_dir {
714 let _ = std::fs::remove_dir(temp_dir);
715 }
716
717 log::info!("Wrote {} trigrams to {:?}", num_trigrams, output_path);
718
719 Ok(())
720 }
721
722 fn write_compressed_posting_list(
724 &self,
725 writer: &mut impl Write,
726 locations: &[FileLocation],
727 ) -> Result<u32> {
728 let mut compressed = Vec::new();
729
730 let mut prev_file_id = 0u32;
732 let mut prev_line_no = 0u32;
733 let mut prev_byte_offset = 0u32;
734
735 for loc in locations {
736 let file_id_delta = loc.file_id.wrapping_sub(prev_file_id);
738 let line_no_delta = loc.line_no.wrapping_sub(prev_line_no);
739 let byte_offset_delta = loc.byte_offset.wrapping_sub(prev_byte_offset);
740
741 write_varint(&mut compressed, file_id_delta)?;
743 write_varint(&mut compressed, line_no_delta)?;
744 write_varint(&mut compressed, byte_offset_delta)?;
745
746 prev_file_id = loc.file_id;
748 prev_line_no = loc.line_no;
749 prev_byte_offset = loc.byte_offset;
750 }
751
752 let compressed_size = compressed.len() as u32;
753 writer.write_all(&compressed)?;
754
755 Ok(compressed_size)
756 }
757
758 #[allow(dead_code)]
760 fn merge_partial_indices(&mut self) -> Result<()> {
761 use std::io::{BufReader, Read};
762
763 let mut all_entries: Vec<(Trigram, FileLocation)> = Vec::new();
765
766 for partial_path in &self.partial_indices {
767 let file = File::open(partial_path)
768 .with_context(|| format!("Failed to open partial index: {:?}", partial_path))?;
769 let mut reader = BufReader::with_capacity(16 * 1024 * 1024, file);
770
771 let mut buf = [0u8; 8];
773 reader.read_exact(&mut buf)?;
774 let num_trigrams = u64::from_le_bytes(buf) as usize;
775
776 for _ in 0..num_trigrams {
778 let mut trigram_buf = [0u8; 4];
780 reader.read_exact(&mut trigram_buf)?;
781 let trigram = u32::from_le_bytes(trigram_buf);
782
783 let mut len_buf = [0u8; 4];
785 reader.read_exact(&mut len_buf)?;
786 let list_len = u32::from_le_bytes(len_buf) as usize;
787
788 for _ in 0..list_len {
790 let mut loc_buf = [0u8; 12]; reader.read_exact(&mut loc_buf)?;
792
793 let file_id = u32::from_le_bytes([loc_buf[0], loc_buf[1], loc_buf[2], loc_buf[3]]);
794 let line_no = u32::from_le_bytes([loc_buf[4], loc_buf[5], loc_buf[6], loc_buf[7]]);
795 let byte_offset = u32::from_le_bytes([loc_buf[8], loc_buf[9], loc_buf[10], loc_buf[11]]);
796
797 all_entries.push((trigram, FileLocation { file_id, line_no, byte_offset }));
798 }
799 }
800 }
801
802 log::info!("Read {} total trigram entries from {} partial indices",
803 all_entries.len(), self.partial_indices.len());
804
805 let mut index_map: HashMap<Trigram, Vec<FileLocation>> = HashMap::new();
807 for (trigram, location) in all_entries {
808 index_map
809 .entry(trigram)
810 .or_insert_with(Vec::new)
811 .push(location);
812 }
813
814 self.index = index_map.into_iter().collect();
816
817 for (_, list) in self.index.iter_mut() {
819 list.sort_unstable();
820 list.dedup();
821 }
822
823 self.index.sort_unstable_by_key(|(trigram, _)| *trigram);
825
826 for partial_path in &self.partial_indices {
828 let _ = std::fs::remove_file(partial_path);
829 }
830 if let Some(ref temp_dir) = self.temp_dir {
831 let _ = std::fs::remove_dir(temp_dir);
832 }
833
834 log::info!("Merged into final index with {} trigrams", self.index.len());
835
836 Ok(())
837 }
838
839 pub fn search(&self, pattern: &str) -> Vec<FileLocation> {
847 if pattern.len() < 3 {
848 return vec![];
850 }
851
852 let trigrams = extract_trigrams(pattern);
853 if trigrams.is_empty() {
854 return vec![];
855 }
856
857 if let Some(ref mmap) = self.mmap {
859 let mut posting_lists: Vec<Vec<FileLocation>> = Vec::new();
861
862 for trigram in &trigrams {
863 match self.directory.binary_search_by_key(trigram, |e| e.trigram) {
865 Ok(idx) => {
866 let entry = &self.directory[idx];
867 match decompress_posting_list(mmap, entry.data_offset, entry.compressed_size) {
869 Ok(locations) => posting_lists.push(locations),
870 Err(e) => {
871 log::warn!("Failed to decompress posting list for trigram {}: {}", trigram, e);
872 return vec![];
873 }
874 }
875 }
876 Err(_) => {
877 return vec![];
879 }
880 }
881 }
882
883 if posting_lists.is_empty() || posting_lists.len() < trigrams.len() {
884 return vec![];
885 }
886
887 posting_lists.sort_by_key(|list| list.len());
889
890 intersect_by_file_owned(&posting_lists)
892 } else {
893 let mut posting_lists: Vec<&Vec<FileLocation>> = trigrams
895 .iter()
896 .filter_map(|t| {
897 self.index
898 .binary_search_by_key(t, |(trigram, _)| *trigram)
899 .ok()
900 .map(|idx| &self.index[idx].1)
901 })
902 .collect();
903
904 if posting_lists.is_empty() {
905 return vec![];
906 }
907
908 if posting_lists.len() < trigrams.len() {
909 return vec![];
911 }
912
913 posting_lists.sort_by_key(|list| list.len());
915
916 intersect_by_file(&posting_lists)
918 }
919 }
920
921 pub fn get_posting_list(&self, trigram: Trigram) -> Option<&Vec<FileLocation>> {
923 self.index
924 .binary_search_by_key(&trigram, |(t, _)| *t)
925 .ok()
926 .map(|idx| &self.index[idx].1)
927 }
928
929 pub fn write(&mut self, path: impl AsRef<Path>) -> Result<()> {
943 let path = path.as_ref();
944
945 if !self.partial_indices.is_empty() {
947 log::info!("Using streaming merge to write {} partial indices", self.partial_indices.len());
948 return self.merge_partial_indices_to_file(path);
949 }
950
951 let file = OpenOptions::new()
953 .create(true)
954 .write(true)
955 .truncate(true)
956 .open(path)
957 .with_context(|| format!("Failed to create {}", path.display()))?;
958
959 let mut writer = std::io::BufWriter::with_capacity(16 * 1024 * 1024, file);
961
962 writer.write_all(MAGIC)?;
964 writer.write_all(&VERSION.to_le_bytes())?;
965 writer.write_all(&(self.index.len() as u64).to_le_bytes())?; writer.write_all(&(self.files.len() as u64).to_le_bytes())?; let mut directory: Vec<DirectoryEntry> = Vec::with_capacity(self.index.len());
970
971 let directory_start = HEADER_SIZE as u64;
973 let directory_size = self.index.len() * 16;
974
975 let data_start = directory_start + directory_size as u64;
977 let mut current_offset = data_start;
978
979 let mut compressed_lists: Vec<(Trigram, Vec<u8>)> = Vec::with_capacity(self.index.len());
985
986 for (trigram, locations) in &self.index {
987 let mut compressed = Vec::new();
989 let mut prev_file_id = 0u32;
990 let mut prev_line_no = 0u32;
991 let mut prev_byte_offset = 0u32;
992
993 for loc in locations {
994 let file_id_delta = loc.file_id.wrapping_sub(prev_file_id);
995 let line_no_delta = loc.line_no.wrapping_sub(prev_line_no);
996 let byte_offset_delta = loc.byte_offset.wrapping_sub(prev_byte_offset);
997
998 write_varint(&mut compressed, file_id_delta)?;
999 write_varint(&mut compressed, line_no_delta)?;
1000 write_varint(&mut compressed, byte_offset_delta)?;
1001
1002 prev_file_id = loc.file_id;
1003 prev_line_no = loc.line_no;
1004 prev_byte_offset = loc.byte_offset;
1005 }
1006
1007 directory.push(DirectoryEntry {
1008 trigram: *trigram,
1009 data_offset: current_offset,
1010 compressed_size: compressed.len() as u32,
1011 });
1012 current_offset += compressed.len() as u64;
1013
1014 compressed_lists.push((*trigram, compressed));
1015 }
1016
1017 for entry in &directory {
1019 writer.write_all(&entry.trigram.to_le_bytes())?;
1020 writer.write_all(&entry.data_offset.to_le_bytes())?;
1021 writer.write_all(&entry.compressed_size.to_le_bytes())?;
1022 }
1023
1024 for (_, compressed) in &compressed_lists {
1026 writer.write_all(compressed)?;
1027 }
1028
1029 for file_path in &self.files {
1031 let path_str = file_path.to_string_lossy();
1032 let path_bytes = path_str.as_bytes();
1033 write_varint(&mut writer, path_bytes.len() as u32)?;
1034 writer.write_all(path_bytes)?;
1035 }
1036
1037 writer.flush()?;
1039 writer.get_ref().sync_all()?;
1040
1041 log::info!(
1042 "Wrote lazy-loadable trigram index: {} trigrams, {} files to {:?}",
1043 self.index.len(),
1044 self.files.len(),
1045 path
1046 );
1047
1048 Ok(())
1049 }
1050
1051 pub fn load(path: impl AsRef<Path>) -> Result<Self> {
1056 let path = path.as_ref();
1057
1058 let file = File::open(path)
1059 .with_context(|| format!("Failed to open {}", path.display()))?;
1060
1061 let mmap = unsafe {
1063 memmap2::Mmap::map(&file)
1064 .with_context(|| format!("Failed to mmap {}", path.display()))?
1065 };
1066
1067 if mmap.len() < HEADER_SIZE {
1069 anyhow::bail!("trigrams.bin too small (expected at least {} bytes)", HEADER_SIZE);
1070 }
1071
1072 if &mmap[0..4] != MAGIC {
1073 anyhow::bail!("Invalid trigrams.bin (wrong magic bytes)");
1074 }
1075
1076 let version = u32::from_le_bytes([mmap[4], mmap[5], mmap[6], mmap[7]]);
1077 if version != VERSION {
1078 anyhow::bail!(
1079 "Unsupported trigrams.bin version: {} (expected {}). Please re-index with 'reflex index'.",
1080 version, VERSION
1081 );
1082 }
1083
1084 let num_trigrams = u64::from_le_bytes([
1085 mmap[8], mmap[9], mmap[10], mmap[11],
1086 mmap[12], mmap[13], mmap[14], mmap[15],
1087 ]) as usize;
1088
1089 let num_files = u64::from_le_bytes([
1090 mmap[16], mmap[17], mmap[18], mmap[19],
1091 mmap[20], mmap[21], mmap[22], mmap[23],
1092 ]) as usize;
1093
1094 log::debug!("Loading lazy trigram index: {} trigrams, {} files", num_trigrams, num_files);
1095
1096 let mut directory = Vec::with_capacity(num_trigrams);
1098 let mut pos = HEADER_SIZE;
1099 let directory_size = num_trigrams * 16; for _ in 0..num_trigrams {
1102 if pos + 16 > mmap.len() {
1103 anyhow::bail!("Truncated directory entry at pos={}", pos);
1104 }
1105
1106 let trigram = u32::from_le_bytes([
1107 mmap[pos],
1108 mmap[pos + 1],
1109 mmap[pos + 2],
1110 mmap[pos + 3],
1111 ]);
1112 pos += 4;
1113
1114 let data_offset = u64::from_le_bytes([
1115 mmap[pos],
1116 mmap[pos + 1],
1117 mmap[pos + 2],
1118 mmap[pos + 3],
1119 mmap[pos + 4],
1120 mmap[pos + 5],
1121 mmap[pos + 6],
1122 mmap[pos + 7],
1123 ]);
1124 pos += 8;
1125
1126 let compressed_size = u32::from_le_bytes([
1127 mmap[pos],
1128 mmap[pos + 1],
1129 mmap[pos + 2],
1130 mmap[pos + 3],
1131 ]);
1132 pos += 4;
1133
1134 directory.push(DirectoryEntry {
1135 trigram,
1136 data_offset,
1137 compressed_size,
1138 });
1139 }
1140
1141 directory.sort_unstable_by_key(|e| e.trigram);
1143
1144 let data_section_size: u64 = directory.iter().map(|e| e.compressed_size as u64).sum();
1146 let files_section_offset = HEADER_SIZE + directory_size + data_section_size as usize;
1147 pos = files_section_offset;
1148
1149 let mut files = Vec::with_capacity(num_files);
1151 for _ in 0..num_files {
1152 let (path_len, consumed) = read_varint(&mmap[pos..])?;
1154 pos += consumed;
1155 let path_len = path_len as usize;
1156
1157 if pos + path_len > mmap.len() {
1158 anyhow::bail!("Truncated file path at pos={}", pos);
1159 }
1160
1161 let path_bytes = &mmap[pos..pos + path_len];
1162 let path_str = std::str::from_utf8(path_bytes)
1163 .context("Invalid UTF-8 in file path")?;
1164 files.push(PathBuf::from(path_str));
1165 pos += path_len;
1166 }
1167
1168 log::info!(
1169 "Loaded lazy trigram index: {} trigrams, {} files (directory: {} KB)",
1170 num_trigrams,
1171 num_files,
1172 directory_size / 1024
1173 );
1174
1175 Ok(Self {
1176 index: Vec::new(), files,
1178 temp_index: None,
1179 mmap: Some(mmap), directory,
1181 partial_indices: Vec::new(),
1182 temp_dir: None,
1183 max_posting_list_entries: 0,
1184 })
1185 }
1186}
1187
1188impl Default for TrigramIndex {
1189 fn default() -> Self {
1190 Self::new()
1191 }
1192}
1193
1194pub fn extract_trigrams(text: &str) -> Vec<Trigram> {
1198 let bytes = text.as_bytes();
1199 let mut trigrams = Vec::new();
1200
1201 for i in 0..bytes.len().saturating_sub(2) {
1202 let trigram = bytes_to_trigram(&bytes[i..i + 3]);
1203 trigrams.push(trigram);
1204 }
1205
1206 trigrams
1207}
1208
1209pub fn extract_trigrams_with_locations(text: &str, file_id: u32) -> Vec<(Trigram, FileLocation)> {
1213 let bytes = text.as_bytes();
1214 let mut result = Vec::new();
1215
1216 let mut line_no = 1;
1217
1218 for (i, &byte) in bytes.iter().enumerate() {
1219 if byte == b'\n' {
1221 line_no += 1;
1222 }
1223
1224 if i + 2 < bytes.len() {
1226 let trigram = bytes_to_trigram(&bytes[i..i + 3]);
1227 let location = FileLocation::new(file_id, line_no, i as u32);
1228 result.push((trigram, location));
1229 }
1230 }
1231
1232 result
1233}
1234
1235#[inline]
1237fn bytes_to_trigram(bytes: &[u8]) -> Trigram {
1238 debug_assert_eq!(bytes.len(), 3);
1239 (bytes[0] as u32) << 16 | (bytes[1] as u32) << 8 | (bytes[2] as u32)
1240}
1241
1242#[allow(dead_code)]
1244fn trigram_to_bytes(trigram: Trigram) -> [u8; 3] {
1245 [
1246 ((trigram >> 16) & 0xFF) as u8,
1247 ((trigram >> 8) & 0xFF) as u8,
1248 (trigram & 0xFF) as u8,
1249 ]
1250}
1251
1252fn intersect_by_file(lists: &[&Vec<FileLocation>]) -> Vec<FileLocation> {
1257 if lists.is_empty() {
1258 return vec![];
1259 }
1260
1261 use std::collections::HashSet;
1262
1263 let mut candidates: HashSet<(u32, u32)> = lists[0]
1265 .iter()
1266 .map(|loc| (loc.file_id, loc.line_no))
1267 .collect();
1268
1269 for &list in &lists[1..] {
1271 let list_pairs: HashSet<(u32, u32)> = list
1272 .iter()
1273 .map(|loc| (loc.file_id, loc.line_no))
1274 .collect();
1275 candidates.retain(|pair| list_pairs.contains(pair));
1276 }
1277
1278 let mut result = Vec::new();
1280 for &(file_id, line_no) in &candidates {
1281 if let Some(loc) = lists[0]
1283 .iter()
1284 .find(|loc| loc.file_id == file_id && loc.line_no == line_no)
1285 {
1286 result.push(*loc);
1287 }
1288 }
1289
1290 result.sort_unstable();
1291 result
1292}
1293
1294fn intersect_by_file_owned(lists: &[Vec<FileLocation>]) -> Vec<FileLocation> {
1301 if lists.is_empty() {
1302 return vec![];
1303 }
1304
1305 use std::collections::HashSet;
1306
1307 let mut candidates: HashSet<(u32, u32)> = lists[0]
1309 .iter()
1310 .map(|loc| (loc.file_id, loc.line_no))
1311 .collect();
1312
1313 for list in &lists[1..] {
1315 let list_pairs: HashSet<(u32, u32)> = list
1316 .iter()
1317 .map(|loc| (loc.file_id, loc.line_no))
1318 .collect();
1319 candidates.retain(|pair| list_pairs.contains(pair));
1320 }
1321
1322 let mut result = Vec::new();
1324 for &(file_id, line_no) in &candidates {
1325 if let Some(loc) = lists[0]
1327 .iter()
1328 .find(|loc| loc.file_id == file_id && loc.line_no == line_no)
1329 {
1330 result.push(*loc);
1331 }
1332 }
1333
1334 result.sort_unstable();
1335 result
1336}
1337
1338#[cfg(test)]
1339mod tests {
1340 use super::*;
1341
1342 #[test]
1343 fn test_extract_trigrams() {
1344 let text = "hello";
1345 let trigrams = extract_trigrams(text);
1346
1347 assert_eq!(trigrams.len(), 3);
1349
1350 let expected = vec![
1352 bytes_to_trigram(b"hel"),
1353 bytes_to_trigram(b"ell"),
1354 bytes_to_trigram(b"llo"),
1355 ];
1356 assert_eq!(trigrams, expected);
1357 }
1358
1359 #[test]
1360 fn test_extract_trigrams_short() {
1361 assert_eq!(extract_trigrams("ab").len(), 0);
1362 assert_eq!(extract_trigrams("abc").len(), 1);
1363 }
1364
1365 #[test]
1366 fn test_bytes_to_trigram() {
1367 let trigram1 = bytes_to_trigram(b"abc");
1368 let trigram2 = bytes_to_trigram(b"abc");
1369 let trigram3 = bytes_to_trigram(b"xyz");
1370
1371 assert_eq!(trigram1, trigram2);
1372 assert_ne!(trigram1, trigram3);
1373 }
1374
1375 #[test]
1376 fn test_trigram_roundtrip() {
1377 let original = b"foo";
1378 let trigram = bytes_to_trigram(original);
1379 let recovered = trigram_to_bytes(trigram);
1380 assert_eq!(original, &recovered);
1381 }
1382
1383 #[test]
1384 fn test_extract_with_locations() {
1385 let text = "hello\nworld";
1386 let locs = extract_trigrams_with_locations(text, 0);
1387
1388 assert_eq!(locs.len(), 9);
1391
1392 assert_eq!(locs[0].1.line_no, 1);
1394
1395 let world_start = text.find("world").unwrap();
1397 let world_trigram_idx = locs
1398 .iter()
1399 .position(|(_, loc)| loc.byte_offset as usize == world_start)
1400 .unwrap();
1401 assert_eq!(locs[world_trigram_idx].1.line_no, 2);
1402 }
1403
1404 #[test]
1405 fn test_trigram_index_basic() {
1406 let mut index = TrigramIndex::new();
1407
1408 let file_id = index.add_file(PathBuf::from("test.txt"));
1409 index.index_file(file_id, "hello world");
1410 index.finalize();
1411
1412 let results = index.search("hello");
1414 assert!(!results.is_empty());
1415
1416 let results = index.search("world");
1418 assert!(!results.is_empty());
1419
1420 let results = index.search("goodbye");
1422 assert!(results.is_empty());
1423 }
1424
1425 #[test]
1426 fn test_search_multifile() {
1427 let mut index = TrigramIndex::new();
1428
1429 let file1 = index.add_file(PathBuf::from("file1.txt"));
1430 let file2 = index.add_file(PathBuf::from("file2.txt"));
1431
1432 index.index_file(file1, "extract_symbols is here");
1433 index.index_file(file2, "extract_symbols is also here");
1434 index.finalize();
1435
1436 let results = index.search("extract_symbols");
1437 assert_eq!(results.len(), 2); let file_ids: Vec<u32> = results.iter().map(|loc| loc.file_id).collect();
1441 assert!(file_ids.contains(&file1));
1442 assert!(file_ids.contains(&file2));
1443 }
1444
1445 #[test]
1446 fn test_persistence_write() {
1447 use tempfile::TempDir;
1448
1449 let temp = TempDir::new().unwrap();
1450 let trigrams_path = temp.path().join("trigrams.bin");
1451
1452 let mut index = TrigramIndex::new();
1454 let file1 = index.add_file(PathBuf::from("src/main.rs"));
1455 let file2 = index.add_file(PathBuf::from("src/lib.rs"));
1456
1457 index.index_file(file1, "fn main() { println!(\"hello\"); }");
1458 index.index_file(file2, "pub fn hello() -> String { String::from(\"hello\") }");
1459 index.finalize();
1460
1461 index.write(&trigrams_path).unwrap();
1463
1464 assert!(trigrams_path.exists());
1466
1467 let metadata = std::fs::metadata(&trigrams_path).unwrap();
1469 assert!(metadata.len() > HEADER_SIZE as u64);
1470
1471 use std::io::Read;
1473 let mut file = File::open(&trigrams_path).unwrap();
1474 let mut magic = [0u8; 4];
1475 file.read_exact(&mut magic).unwrap();
1476 assert_eq!(&magic, MAGIC);
1477
1478 }
1481
1482 #[test]
1483 fn test_posting_list_cap_enforced() {
1484 let cap: usize = 10;
1485 let content = "aaa ".repeat(200);
1486 let mut index = TrigramIndex::new();
1487 index.set_max_posting_list_entries(cap);
1488 let file_id = index.add_file(PathBuf::from("dense.txt"));
1489 index.index_file(file_id, &content);
1490 index.finalize();
1491 let aaa = bytes_to_trigram(b"aaa");
1492 let list = index.get_posting_list(aaa).expect("aaa trigram should exist");
1493 assert!(list.len() <= cap, "cap exceeded: {} > {}", list.len(), cap);
1494 }
1495
1496 #[test]
1497 fn test_posting_list_cap_zero_means_unlimited() {
1498 let repetitions = 50;
1499 let content = "aaa ".repeat(repetitions);
1500 let mut index = TrigramIndex::new();
1501 index.set_max_posting_list_entries(0);
1502 let file_id = index.add_file(PathBuf::from("dense.txt"));
1503 index.index_file(file_id, &content);
1504 index.finalize();
1505 let aaa = bytes_to_trigram(b"aaa");
1506 let list = index.get_posting_list(aaa).expect("aaa trigram should exist");
1507 assert!(list.len() >= repetitions, "expected >= {} entries, got {}", repetitions, list.len());
1508 }
1509}