// Matrix Construct // // Copyright (C) Matrix Construct Developers, Authors & Contributors // Copyright (C) 2016-2018 Jason Volk // // Permission to use, copy, modify, and/or distribute this software for any // purpose with or without fee is hereby granted, provided that the above // copyright notice and this permission notice is present in all copies. The // full license for this software is available in the LICENSE file. #pragma once #define HAVE_IRCD_M_DBS_H /// Database Schema /// namespace ircd::m::dbs { struct init; struct write_opts; // Database instance extern std::shared_ptr events; // Event property columns constexpr const auto event_columns{event::size()}; extern std::array event_column; // Event metadata columns extern db::column event_idx; // event_id => event_idx extern db::column event_bad; // event_id => event_idx extern db::index room_head; // room_id | event_id => event_idx extern db::index room_events; // room_id | depth, event_idx => state_root extern db::index room_joined; // room_id | origin, member => event_idx extern db::index room_state; // room_id | type, state_key => event_idx extern db::column state_node; // node_id => state::node // Lowlevel util constexpr size_t ROOM_HEAD_KEY_MAX_SIZE {id::MAX_SIZE + 1 + id::MAX_SIZE}; string_view room_head_key(const mutable_buffer &out, const id::room &, const id::event &); string_view room_head_key(const string_view &amalgam); constexpr size_t ROOM_STATE_KEY_MAX_SIZE {id::MAX_SIZE + 256 + 256}; string_view room_state_key(const mutable_buffer &out, const id::room &, const string_view &type, const string_view &state_key); string_view room_state_key(const mutable_buffer &out, const id::room &, const string_view &type); std::pair room_state_key(const string_view &amalgam); constexpr size_t ROOM_JOINED_KEY_MAX_SIZE {id::MAX_SIZE + 256 + id::MAX_SIZE}; string_view room_joined_key(const mutable_buffer &out, const id::room &, const string_view &origin, const id::user &member); string_view room_joined_key(const mutable_buffer &out, const id::room &, const string_view &origin); std::pair room_joined_key(const string_view &amalgam); constexpr size_t ROOM_EVENTS_KEY_MAX_SIZE {id::MAX_SIZE + 1 + 8 + 8}; string_view room_events_key(const mutable_buffer &out, const id::room &, const uint64_t &depth, const event::idx &); string_view room_events_key(const mutable_buffer &out, const id::room &, const uint64_t &depth); std::pair room_events_key(const string_view &amalgam); // [GET] the state root for an event (with as much information as you have) string_view state_root(const mutable_buffer &out, const id::room &, const event::idx &, const uint64_t &depth); string_view state_root(const mutable_buffer &out, const id::room &, const event::id &, const uint64_t &depth); string_view state_root(const mutable_buffer &out, const id::room &, const event::idx &); string_view state_root(const mutable_buffer &out, const id::room &, const event::id &); string_view state_root(const mutable_buffer &out, const event::idx &); string_view state_root(const mutable_buffer &out, const event::id &); string_view state_root(const mutable_buffer &out, const event &); // [SET (txn)] Basic write suite string_view write(db::txn &, const event &, const write_opts &); void blacklist(db::txn &, const event::id &, const write_opts &); } struct ircd::m::dbs::write_opts { uint64_t event_idx {0}; string_view root_in; mutable_buffer root_out; db::op op {db::op::SET}; bool present {true}; bool history {true}; bool indexer {true}; bool head {true}; bool refs {true}; }; /// Database Schema Descriptors /// namespace ircd::m::dbs::desc { // Full description extern const database::description events; // // Direct columns // extern const database::descriptor events_auth_events; extern const database::descriptor events_content; extern const database::descriptor events_depth; extern const database::descriptor events_event_id; extern const database::descriptor events_hashes; extern const database::descriptor events_membership; extern const database::descriptor events_origin; extern const database::descriptor events_origin_server_ts; extern const database::descriptor events_prev_events; extern const database::descriptor events_prev_state; extern const database::descriptor events_redacts; extern const database::descriptor events_room_id; extern const database::descriptor events_sender; extern const database::descriptor events_signatures; extern const database::descriptor events_state_key; extern const database::descriptor events_type; // // Metadata columns // // events index extern const database::descriptor events__event_idx; // events blacklist extern const database::descriptor events__event_bad; // room head mapping sequence extern const db::prefix_transform events__room_head__pfx; extern const database::descriptor events__room_head; // room events sequence extern const db::prefix_transform events__room_events__pfx; extern const db::comparator events__room_events__cmp; extern const database::descriptor events__room_events; // room present joined members sequence extern const db::prefix_transform events__room_joined__pfx; extern const database::descriptor events__room_joined; // room present state mapping sequence extern const db::prefix_transform events__room_state__pfx; extern const database::descriptor events__room_state; // state btree node key-value store extern const database::descriptor events__state_node; } // Internal interface; not for public. namespace ircd::m::dbs { void _index__room_state(db::txn &, const event &, const write_opts &); void _index__room_events(db::txn &, const event &, const write_opts &, const string_view &); void _index__room_joined(db::txn &, const event &, const write_opts &); void _index__room_head(db::txn &, const event &, const write_opts &); string_view _index_state(db::txn &, const event &, const write_opts &); string_view _index_redact(db::txn &, const event &, const write_opts &); string_view _index_ephem(db::txn &, const event &, const write_opts &); void _index__event(db::txn &, const event &, const write_opts &); } struct ircd::m::dbs::init { init(std::string dbopts = {}); ~init() noexcept; };