nostr/strfry
1
0
Fork 0
mirror of https://github.com/hoytech/strfry.git synced 2025-06-21 18:15:24 +00:00
Code Issues Packages Projects Releases Wiki Activity

wip

Browse Source
This commit is contained in:
Doug Hoyte
2023-03-06 11:49:05 -05:00
parent bfc2d690b3
commit 85c26bcb7e
1 changed files with 15 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
src/xor.h
View File

@ -21,14 +21,7 @@ struct XorElem {
} }
XorElem& operator^=(const XorElem &other) { XorElem& operator^=(const XorElem &other) {
uint64_t *ours = reinterpret_cast<uint64_t*>(id); for (size_t i = 0; i < 32; i++) id[i] ^= other.id[i];
const uint64_t *theirs = reinterpret_cast<const uint64_t*>(other.id);
ours[0] ^= theirs[0];
ours[1] ^= theirs[1];
ours[2] ^= theirs[2];
ours[3] ^= theirs[3];
return *this; return *this;
} }
@ -71,7 +64,7 @@ struct XorView {
return output; return output;
} }
// FIXME: try/catch everywhere that calls this // FIXME: better name for this function, check try/catch everywhere that calls this
std::string handleQuery(std::string_view query, std::vector<std::string> &haveIds, std::vector<std::string> &needIds) { std::string handleQuery(std::string_view query, std::vector<std::string> &haveIds, std::vector<std::string> &needIds) {
if (!ready) throw herr("xor view not ready"); if (!ready) throw herr("xor view not ready");
@ -80,7 +73,7 @@ struct XorView {
uint64_t lastTimestampIn = 0; uint64_t lastTimestampIn = 0;
uint64_t lastTimestampOut = 0; uint64_t lastTimestampOut = 0;
auto decodeTimestampIn = [&](std::string_view &query){ auto decodeTimestampIn = [&]{
uint64_t timestamp = decodeVarInt(query); uint64_t timestamp = decodeVarInt(query);
timestamp = timestamp == 0 ? MAX_U64 : timestamp - 1; timestamp = timestamp == 0 ? MAX_U64 : timestamp - 1;
timestamp += lastTimestampIn; timestamp += lastTimestampIn;
@ -89,16 +82,19 @@ struct XorView {
return timestamp; return timestamp;
}; };
while (query.size()) { auto decodeBoundKey = [&](uint64_t &timestamp, std::string &key){
uint64_t lowerTimestamp = decodeTimestampIn(query); timestamp = decodeTimestampIn();
uint64_t lowerLength = decodeVarInt(query); uint64_t len = decodeVarInt(query);
if (lowerLength > idSize) throw herr("lower too long"); if (len > idSize) throw herr("bound key too long");
auto lowerKey = getBytes(query, lowerLength); key = getBytes(query, len);
};
uint64_t upperTimestamp = decodeTimestampIn(query); while (query.size()) {
uint64_t upperLength = decodeVarInt(query); uint64_t lowerTimestamp, upperTimestamp;
if (upperLength > idSize) throw herr("upper too long"); std::string lowerKey, upperKey;
auto upperKey = getBytes(query, upperLength);
decodeBoundKey(lowerTimestamp, lowerKey);
decodeBoundKey(upperTimestamp, upperKey);
auto lower = std::lower_bound(prevUpper, elems.end(), XorElem(lowerTimestamp, lowerKey)); auto lower = std::lower_bound(prevUpper, elems.end(), XorElem(lowerTimestamp, lowerKey));
auto upper = std::upper_bound(lower, elems.end(), XorElem(upperTimestamp, upperKey)); auto upper = std::upper_bound(lower, elems.end(), XorElem(upperTimestamp, upperKey));