-2

ufos/src/storage_fjall.rs

Reviewed

··· 1171 1171 UFOsCommit::from_commit_info(event, did.clone(), Cursor::from_raw_u64(100))?; 1172 1172 1173 1173 let mut commits = CollectionCommits::default(); 1174 1174 - commits.total_seen += 1; 1175 1175 - commits.dids_estimate.insert(&did); 1176 1174 commits.truncating_insert(commit, 1); 1177 1175 1178 1176 let mut commits_by_nsid = HashMap::new();

+1 -2

ufos/src/store_types.rs

Reviewed

··· 146 146 impl LiveRecordsKey { 147 147 pub fn range_from_cursor(cursor: Cursor) -> Result<Range<Vec<u8>>, EncodingError> { 148 148 let prefix = LiveRecordsCursorPrefix::from_pair(Default::default(), cursor); 149 149 - let end = Self::prefix_range_end(&prefix)?; 150 150 - Ok(prefix.to_db_bytes()?..end.to_db_bytes()?) 149 149 + Ok(prefix.range_to_prefix_end()?) 151 150 } 152 151 pub fn cursor(&self) -> Cursor { 153 152 self.prefix.suffix