mirror of
https://github.com/matrix-construct/construct
synced 2024-11-25 16:22:35 +01:00
ircd:Ⓜ️ Reorg event util related; break up pretty(event) around ostream argument.
This commit is contained in:
Jason Volk
parent
9df433e283
commit
f77b3aae7e
2 changed files with 285 additions and 249 deletions
|
|
@ -15,21 +15,14 @@ namespace ircd::m
|
|||
{
|
||||
struct event;
|
||||
|
||||
// General util
|
||||
bool my(const id::event &);
|
||||
bool my(const event &);
|
||||
|
||||
size_t degree(const event &);
|
||||
string_view membership(const event &);
|
||||
|
||||
bool check_size(std::nothrow_t, const event &);
|
||||
void check_size(const event &);
|
||||
|
||||
id::event make_id(const event &, id::event::buf &buf, const const_buffer &hash);
|
||||
id::event make_id(const event &, id::event::buf &buf);
|
||||
|
||||
std::string pretty(const event &);
|
||||
std::string pretty_oneline(const event &, const bool &content_keys = true);
|
||||
|
||||
// [GET]
|
||||
bool exists(const id::event &);
|
||||
|
||||
|
|
@ -41,6 +34,17 @@ namespace ircd::m
|
|||
|
||||
// Equality tests the event_id only! know this.
|
||||
bool operator==(const event &a, const event &b);
|
||||
|
||||
id::event make_id(const event &, id::event::buf &buf, const const_buffer &hash);
|
||||
id::event make_id(const event &, id::event::buf &buf);
|
||||
|
||||
// Informational pretty string condensed to single line.
|
||||
std::ostream &pretty_oneline(std::ostream &, const event &, const bool &content_keys = true);
|
||||
std::string pretty_oneline(const event &, const bool &content_keys = true);
|
||||
|
||||
// Informational pretty string on multiple lines.
|
||||
std::ostream &pretty(std::ostream &, const event &);
|
||||
std::string pretty(const event &);
|
||||
}
|
||||
|
||||
#pragma GCC diagnostic push
|
||||
|
|
@ -137,7 +141,10 @@ namespace ircd::m
|
|||
size_t degree(const event::prev &);
|
||||
size_t count(const event::prev &);
|
||||
|
||||
std::ostream &pretty(std::ostream &, const event::prev &);
|
||||
std::string pretty(const event::prev &);
|
||||
|
||||
std::ostream &pretty_oneline(std::ostream &, const event::prev &);
|
||||
std::string pretty_oneline(const event::prev &);
|
||||
}
|
||||
|
||||
|
|
|
|||
511
ircd/m/event.cc
511
ircd/m/event.cc
|
|
@ -8,251 +8,21 @@
|
|||
// copyright notice and this permission notice is present in all copies. The
|
||||
// full license for this software is available in the LICENSE file.
|
||||
|
||||
bool
|
||||
ircd::m::operator==(const event &a, const event &b)
|
||||
{
|
||||
assert(json::get<"room_id"_>(a) == json::get<"room_id"_>(b));
|
||||
return at<"event_id"_>(a) == at<"event_id"_>(b);
|
||||
}
|
||||
|
||||
bool
|
||||
ircd::m::operator>=(const event &a, const event &b)
|
||||
{
|
||||
assert(json::get<"room_id"_>(a) == json::get<"room_id"_>(b));
|
||||
return at<"depth"_>(a) >= at<"depth"_>(b);
|
||||
}
|
||||
|
||||
bool
|
||||
ircd::m::operator<=(const event &a, const event &b)
|
||||
{
|
||||
assert(json::get<"room_id"_>(a) == json::get<"room_id"_>(b));
|
||||
return at<"depth"_>(a) <= at<"depth"_>(b);
|
||||
}
|
||||
|
||||
bool
|
||||
ircd::m::operator>(const event &a, const event &b)
|
||||
{
|
||||
assert(json::get<"room_id"_>(a) == json::get<"room_id"_>(b));
|
||||
return at<"depth"_>(a) > at<"depth"_>(b);
|
||||
}
|
||||
|
||||
bool
|
||||
ircd::m::operator<(const event &a, const event &b)
|
||||
{
|
||||
assert(json::get<"room_id"_>(a) == json::get<"room_id"_>(b));
|
||||
return at<"depth"_>(a) < at<"depth"_>(b);
|
||||
}
|
||||
|
||||
ircd::m::id::event
|
||||
ircd::m::make_id(const event &event,
|
||||
id::event::buf &buf)
|
||||
{
|
||||
const crh::sha256::buf hash{event};
|
||||
return make_id(event, buf, hash);
|
||||
}
|
||||
|
||||
ircd::m::id::event
|
||||
ircd::m::make_id(const event &event,
|
||||
id::event::buf &buf,
|
||||
const const_buffer &hash)
|
||||
{
|
||||
char readable[b58encode_size(sha256::digest_size)];
|
||||
const id::event ret
|
||||
{
|
||||
buf, b58encode(readable, hash), my_host()
|
||||
};
|
||||
|
||||
buf.assigned(ret);
|
||||
return ret;
|
||||
}
|
||||
|
||||
void
|
||||
ircd::m::check_size(const event &event)
|
||||
{
|
||||
const size_t &event_size
|
||||
{
|
||||
serialized(event)
|
||||
};
|
||||
|
||||
if(event_size > size_t(event::max_size))
|
||||
throw m::BAD_JSON
|
||||
{
|
||||
"Event is %zu bytes which is larger than the maximum %zu bytes",
|
||||
event_size,
|
||||
size_t(event::max_size)
|
||||
};
|
||||
}
|
||||
|
||||
bool
|
||||
ircd::m::check_size(std::nothrow_t,
|
||||
const event &event)
|
||||
{
|
||||
const size_t &event_size
|
||||
{
|
||||
serialized(event)
|
||||
};
|
||||
|
||||
return event_size <= size_t(event::max_size);
|
||||
}
|
||||
|
||||
ircd::string_view
|
||||
ircd::m::membership(const event &event)
|
||||
{
|
||||
return json::get<"membership"_>(event)?
|
||||
string_view{json::get<"membership"_>(event)}:
|
||||
unquote(json::get<"content"_>(event).get("membership"));
|
||||
}
|
||||
|
||||
size_t
|
||||
ircd::m::degree(const event &event)
|
||||
{
|
||||
return degree(event::prev{event});
|
||||
}
|
||||
|
||||
size_t
|
||||
ircd::m::degree(const event::prev &prev)
|
||||
{
|
||||
size_t ret{0};
|
||||
json::for_each(prev, [&ret]
|
||||
(const auto &, const json::array &prevs)
|
||||
{
|
||||
ret += prevs.count();
|
||||
});
|
||||
|
||||
return ret;
|
||||
}
|
||||
|
||||
bool
|
||||
ircd::m::exists(const id::event &event_id)
|
||||
{
|
||||
auto &column
|
||||
{
|
||||
dbs::event_idx
|
||||
};
|
||||
|
||||
return has(column, event_id);
|
||||
}
|
||||
|
||||
size_t
|
||||
ircd::m::count(const event::prev &prev)
|
||||
{
|
||||
size_t ret{0};
|
||||
m::for_each(prev, [&ret](const event::id &event_id)
|
||||
{
|
||||
++ret;
|
||||
});
|
||||
|
||||
return ret;
|
||||
}
|
||||
|
||||
void
|
||||
ircd::m::for_each(const event::prev &prev,
|
||||
const std::function<void (const event::id &)> &closure)
|
||||
{
|
||||
json::for_each(prev, [&closure]
|
||||
(const auto &key, const json::array &prevs)
|
||||
{
|
||||
for(const json::array &prev : prevs)
|
||||
{
|
||||
const event::id &id{unquote(prev[0])};
|
||||
closure(id);
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
std::string
|
||||
ircd::m::pretty(const event::prev &prev)
|
||||
{
|
||||
std::string ret;
|
||||
std::stringstream s;
|
||||
pubsetbuf(s, ret, 4096);
|
||||
|
||||
const auto out{[&s]
|
||||
(const string_view &key, auto&& val)
|
||||
{
|
||||
if(json::defined(val))
|
||||
s << key << " :" << val << std::endl;
|
||||
}};
|
||||
|
||||
const auto &auth_events{json::get<"auth_events"_>(prev)};
|
||||
for(const json::array auth_event : auth_events)
|
||||
{
|
||||
s << std::setw(16) << std::right << "[auth event]"
|
||||
<< " :" << unquote(auth_event[0]);
|
||||
|
||||
for(const auto &hash : json::object{auth_event[1]})
|
||||
s << " " << unquote(hash.first)
|
||||
<< ": " << unquote(hash.second);
|
||||
|
||||
s << std::endl;
|
||||
}
|
||||
|
||||
const auto &prev_states{json::get<"prev_state"_>(prev)};
|
||||
for(const json::array prev_state : prev_states)
|
||||
{
|
||||
s << std::setw(16) << std::right << "[prev state]"
|
||||
<< " :" << unquote(prev_state[0]);
|
||||
|
||||
for(const auto &hash : json::object{prev_state[1]})
|
||||
s << " " << unquote(hash.first)
|
||||
<< ": " << unquote(hash.second);
|
||||
|
||||
s << std::endl;
|
||||
}
|
||||
|
||||
const auto &prev_events{json::get<"prev_events"_>(prev)};
|
||||
for(const json::array prev_event : prev_events)
|
||||
{
|
||||
s << std::setw(16) << std::right << "[prev_event]"
|
||||
<< " :" << unquote(prev_event[0]);
|
||||
|
||||
for(const auto &hash : json::object{prev_event[1]})
|
||||
s << " " << unquote(hash.first)
|
||||
<< ": " << unquote(hash.second);
|
||||
|
||||
s << std::endl;
|
||||
}
|
||||
|
||||
resizebuf(s, ret);
|
||||
return ret;
|
||||
}
|
||||
|
||||
std::string
|
||||
ircd::m::pretty_oneline(const event::prev &prev)
|
||||
{
|
||||
std::string ret;
|
||||
std::stringstream s;
|
||||
pubsetbuf(s, ret, 1024);
|
||||
|
||||
const auto &auth_events{json::get<"auth_events"_>(prev)};
|
||||
s << "A[ ";
|
||||
for(const json::array auth_event : auth_events)
|
||||
s << unquote(auth_event[0]) << " ";
|
||||
s << "] ";
|
||||
|
||||
const auto &prev_states{json::get<"prev_state"_>(prev)};
|
||||
s << "S[ ";
|
||||
for(const json::array prev_state : prev_states)
|
||||
s << unquote(prev_state[0]) << " ";
|
||||
s << "] ";
|
||||
|
||||
const auto &prev_events{json::get<"prev_events"_>(prev)};
|
||||
s << "E[ ";
|
||||
for(const json::array prev_event : prev_events)
|
||||
s << unquote(prev_event[0]) << " ";
|
||||
s << "] ";
|
||||
|
||||
resizebuf(s, ret);
|
||||
return ret;
|
||||
}
|
||||
|
||||
std::string
|
||||
ircd::m::pretty(const event &event)
|
||||
{
|
||||
std::string ret;
|
||||
std::stringstream s;
|
||||
pubsetbuf(s, ret, 4096);
|
||||
pretty(s, event);
|
||||
resizebuf(s, ret);
|
||||
return ret;
|
||||
}
|
||||
|
||||
std::ostream &
|
||||
ircd::m::pretty(std::ostream &s,
|
||||
const event &event)
|
||||
{
|
||||
const auto out{[&s]
|
||||
(const string_view &key, auto&& val)
|
||||
{
|
||||
|
|
@ -360,8 +130,7 @@ ircd::m::pretty(const event &event)
|
|||
<< ':' << content.first
|
||||
<< std::endl;
|
||||
|
||||
resizebuf(s, ret);
|
||||
return ret;
|
||||
return s;
|
||||
}
|
||||
|
||||
std::string
|
||||
|
|
@ -370,8 +139,17 @@ ircd::m::pretty_oneline(const event &event,
|
|||
{
|
||||
std::string ret;
|
||||
std::stringstream s;
|
||||
pubsetbuf(s, ret, 1024);
|
||||
pubsetbuf(s, ret, 4096);
|
||||
pretty_oneline(s, event, content_keys);
|
||||
resizebuf(s, ret);
|
||||
return ret;
|
||||
}
|
||||
|
||||
std::ostream &
|
||||
ircd::m::pretty_oneline(std::ostream &s,
|
||||
const event &event,
|
||||
const bool &content_keys)
|
||||
{
|
||||
const auto out{[&s]
|
||||
(const string_view &key, auto&& val)
|
||||
{
|
||||
|
|
@ -450,10 +228,261 @@ ircd::m::pretty_oneline(const event &event,
|
|||
s << content.first << " ";
|
||||
}
|
||||
|
||||
return s;
|
||||
}
|
||||
|
||||
ircd::m::id::event
|
||||
ircd::m::make_id(const event &event,
|
||||
id::event::buf &buf)
|
||||
{
|
||||
const crh::sha256::buf hash{event};
|
||||
return make_id(event, buf, hash);
|
||||
}
|
||||
|
||||
ircd::m::id::event
|
||||
ircd::m::make_id(const event &event,
|
||||
id::event::buf &buf,
|
||||
const const_buffer &hash)
|
||||
{
|
||||
char readable[b58encode_size(sha256::digest_size)];
|
||||
const id::event ret
|
||||
{
|
||||
buf, b58encode(readable, hash), my_host()
|
||||
};
|
||||
|
||||
buf.assigned(ret);
|
||||
return ret;
|
||||
}
|
||||
|
||||
bool
|
||||
ircd::m::operator==(const event &a, const event &b)
|
||||
{
|
||||
assert(json::get<"room_id"_>(a) == json::get<"room_id"_>(b));
|
||||
return at<"event_id"_>(a) == at<"event_id"_>(b);
|
||||
}
|
||||
|
||||
bool
|
||||
ircd::m::operator>=(const event &a, const event &b)
|
||||
{
|
||||
assert(json::get<"room_id"_>(a) == json::get<"room_id"_>(b));
|
||||
return at<"depth"_>(a) >= at<"depth"_>(b);
|
||||
}
|
||||
|
||||
bool
|
||||
ircd::m::operator<=(const event &a, const event &b)
|
||||
{
|
||||
assert(json::get<"room_id"_>(a) == json::get<"room_id"_>(b));
|
||||
return at<"depth"_>(a) <= at<"depth"_>(b);
|
||||
}
|
||||
|
||||
bool
|
||||
ircd::m::operator>(const event &a, const event &b)
|
||||
{
|
||||
assert(json::get<"room_id"_>(a) == json::get<"room_id"_>(b));
|
||||
return at<"depth"_>(a) > at<"depth"_>(b);
|
||||
}
|
||||
|
||||
bool
|
||||
ircd::m::operator<(const event &a, const event &b)
|
||||
{
|
||||
assert(json::get<"room_id"_>(a) == json::get<"room_id"_>(b));
|
||||
return at<"depth"_>(a) < at<"depth"_>(b);
|
||||
}
|
||||
|
||||
bool
|
||||
ircd::m::exists(const id::event &event_id)
|
||||
{
|
||||
auto &column
|
||||
{
|
||||
dbs::event_idx
|
||||
};
|
||||
|
||||
return has(column, event_id);
|
||||
}
|
||||
|
||||
void
|
||||
ircd::m::check_size(const event &event)
|
||||
{
|
||||
const size_t &event_size
|
||||
{
|
||||
serialized(event)
|
||||
};
|
||||
|
||||
if(event_size > size_t(event::max_size))
|
||||
throw m::BAD_JSON
|
||||
{
|
||||
"Event is %zu bytes which is larger than the maximum %zu bytes",
|
||||
event_size,
|
||||
size_t(event::max_size)
|
||||
};
|
||||
}
|
||||
|
||||
bool
|
||||
ircd::m::check_size(std::nothrow_t,
|
||||
const event &event)
|
||||
{
|
||||
const size_t &event_size
|
||||
{
|
||||
serialized(event)
|
||||
};
|
||||
|
||||
return event_size <= size_t(event::max_size);
|
||||
}
|
||||
|
||||
ircd::string_view
|
||||
ircd::m::membership(const event &event)
|
||||
{
|
||||
return json::get<"membership"_>(event)?
|
||||
string_view{json::get<"membership"_>(event)}:
|
||||
unquote(json::get<"content"_>(event).get("membership"));
|
||||
}
|
||||
|
||||
size_t
|
||||
ircd::m::degree(const event &event)
|
||||
{
|
||||
return degree(event::prev{event});
|
||||
}
|
||||
|
||||
size_t
|
||||
ircd::m::degree(const event::prev &prev)
|
||||
{
|
||||
size_t ret{0};
|
||||
json::for_each(prev, [&ret]
|
||||
(const auto &, const json::array &prevs)
|
||||
{
|
||||
ret += prevs.count();
|
||||
});
|
||||
|
||||
return ret;
|
||||
}
|
||||
|
||||
size_t
|
||||
ircd::m::count(const event::prev &prev)
|
||||
{
|
||||
size_t ret{0};
|
||||
m::for_each(prev, [&ret](const event::id &event_id)
|
||||
{
|
||||
++ret;
|
||||
});
|
||||
|
||||
return ret;
|
||||
}
|
||||
|
||||
void
|
||||
ircd::m::for_each(const event::prev &prev,
|
||||
const std::function<void (const event::id &)> &closure)
|
||||
{
|
||||
json::for_each(prev, [&closure]
|
||||
(const auto &key, const json::array &prevs)
|
||||
{
|
||||
for(const json::array &prev : prevs)
|
||||
{
|
||||
const event::id &id{unquote(prev[0])};
|
||||
closure(id);
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
std::string
|
||||
ircd::m::pretty(const event::prev &prev)
|
||||
{
|
||||
std::string ret;
|
||||
std::stringstream s;
|
||||
pubsetbuf(s, ret, 4096);
|
||||
pretty(s, prev);
|
||||
resizebuf(s, ret);
|
||||
return ret;
|
||||
}
|
||||
|
||||
std::ostream &
|
||||
ircd::m::pretty(std::ostream &s,
|
||||
const event::prev &prev)
|
||||
{
|
||||
const auto out{[&s]
|
||||
(const string_view &key, auto&& val)
|
||||
{
|
||||
if(json::defined(val))
|
||||
s << key << " :" << val << std::endl;
|
||||
}};
|
||||
|
||||
const auto &auth_events{json::get<"auth_events"_>(prev)};
|
||||
for(const json::array auth_event : auth_events)
|
||||
{
|
||||
s << std::setw(16) << std::right << "[auth event]"
|
||||
<< " :" << unquote(auth_event[0]);
|
||||
|
||||
for(const auto &hash : json::object{auth_event[1]})
|
||||
s << " " << unquote(hash.first)
|
||||
<< ": " << unquote(hash.second);
|
||||
|
||||
s << std::endl;
|
||||
}
|
||||
|
||||
const auto &prev_states{json::get<"prev_state"_>(prev)};
|
||||
for(const json::array prev_state : prev_states)
|
||||
{
|
||||
s << std::setw(16) << std::right << "[prev state]"
|
||||
<< " :" << unquote(prev_state[0]);
|
||||
|
||||
for(const auto &hash : json::object{prev_state[1]})
|
||||
s << " " << unquote(hash.first)
|
||||
<< ": " << unquote(hash.second);
|
||||
|
||||
s << std::endl;
|
||||
}
|
||||
|
||||
const auto &prev_events{json::get<"prev_events"_>(prev)};
|
||||
for(const json::array prev_event : prev_events)
|
||||
{
|
||||
s << std::setw(16) << std::right << "[prev_event]"
|
||||
<< " :" << unquote(prev_event[0]);
|
||||
|
||||
for(const auto &hash : json::object{prev_event[1]})
|
||||
s << " " << unquote(hash.first)
|
||||
<< ": " << unquote(hash.second);
|
||||
|
||||
s << std::endl;
|
||||
}
|
||||
|
||||
return s;
|
||||
}
|
||||
|
||||
std::string
|
||||
ircd::m::pretty_oneline(const event::prev &prev)
|
||||
{
|
||||
std::string ret;
|
||||
std::stringstream s;
|
||||
pubsetbuf(s, ret, 4096);
|
||||
pretty_oneline(s, prev);
|
||||
resizebuf(s, ret);
|
||||
return ret;
|
||||
}
|
||||
|
||||
std::ostream &
|
||||
ircd::m::pretty_oneline(std::ostream &s,
|
||||
const event::prev &prev)
|
||||
{
|
||||
const auto &auth_events{json::get<"auth_events"_>(prev)};
|
||||
s << "A[ ";
|
||||
for(const json::array auth_event : auth_events)
|
||||
s << unquote(auth_event[0]) << " ";
|
||||
s << "] ";
|
||||
|
||||
const auto &prev_states{json::get<"prev_state"_>(prev)};
|
||||
s << "S[ ";
|
||||
for(const json::array prev_state : prev_states)
|
||||
s << unquote(prev_state[0]) << " ";
|
||||
s << "] ";
|
||||
|
||||
const auto &prev_events{json::get<"prev_events"_>(prev)};
|
||||
s << "E[ ";
|
||||
for(const json::array prev_event : prev_events)
|
||||
s << unquote(prev_event[0]) << " ";
|
||||
s << "] ";
|
||||
|
||||
return s;
|
||||
}
|
||||
|
||||
bool
|
||||
ircd::m::my(const event &event)
|
||||
{
|
||||
|
|
|
|||
Loading…
Reference in a new issue