2018-02-04 03:22:01 +01:00
|
|
|
// Matrix Construct
|
|
|
|
//
|
|
|
|
// Copyright (C) Matrix Construct Developers, Authors & Contributors
|
|
|
|
// Copyright (C) 2016-2018 Jason Volk <jason@zemos.net>
|
|
|
|
//
|
|
|
|
// 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.
|
2017-11-16 02:37:09 +01:00
|
|
|
|
2017-11-30 20:44:23 +01:00
|
|
|
#include <ircd/m/m.h>
|
|
|
|
|
2017-11-16 02:37:09 +01:00
|
|
|
namespace ircd::m
|
|
|
|
{
|
|
|
|
struct log::log log
|
|
|
|
{
|
|
|
|
"matrix", 'm'
|
|
|
|
};
|
|
|
|
|
|
|
|
std::map<std::string, ircd::module> modules;
|
2017-11-30 19:51:01 +01:00
|
|
|
std::list<ircd::net::listener> listeners;
|
2017-11-16 02:37:09 +01:00
|
|
|
|
|
|
|
static void leave_ircd_room();
|
|
|
|
static void join_ircd_room();
|
|
|
|
}
|
|
|
|
|
|
|
|
const ircd::m::user::id::buf
|
|
|
|
ircd_user_id
|
|
|
|
{
|
|
|
|
"ircd", ircd::my_host() //TODO: hostname
|
|
|
|
};
|
|
|
|
|
|
|
|
ircd::m::user
|
|
|
|
ircd::m::me
|
|
|
|
{
|
|
|
|
ircd_user_id
|
|
|
|
};
|
|
|
|
|
|
|
|
const ircd::m::room::id::buf
|
|
|
|
ircd_room_id
|
|
|
|
{
|
|
|
|
"ircd", ircd::my_host()
|
|
|
|
};
|
|
|
|
|
|
|
|
ircd::m::room
|
|
|
|
ircd::m::my_room
|
|
|
|
{
|
|
|
|
ircd_room_id
|
|
|
|
};
|
|
|
|
|
|
|
|
const ircd::m::room::id::buf
|
|
|
|
control_room_id
|
|
|
|
{
|
|
|
|
"control", ircd::my_host()
|
|
|
|
};
|
|
|
|
|
|
|
|
ircd::m::room
|
|
|
|
ircd::m::control
|
|
|
|
{
|
|
|
|
control_room_id
|
|
|
|
};
|
|
|
|
|
2017-12-12 21:33:14 +01:00
|
|
|
//
|
|
|
|
// init
|
|
|
|
//
|
|
|
|
|
|
|
|
ircd::m::init::init()
|
|
|
|
try
|
2018-03-02 09:35:02 +01:00
|
|
|
:config
|
2017-11-16 02:37:09 +01:00
|
|
|
{
|
2018-03-02 09:35:02 +01:00
|
|
|
ircd::conf::config //TODO: X
|
2017-11-16 02:37:09 +01:00
|
|
|
}
|
2017-12-12 21:33:14 +01:00
|
|
|
,_keys
|
2017-11-16 02:37:09 +01:00
|
|
|
{
|
2018-03-02 09:35:02 +01:00
|
|
|
this->config
|
2017-11-16 02:37:09 +01:00
|
|
|
}
|
|
|
|
{
|
2017-12-12 21:33:14 +01:00
|
|
|
modules();
|
2018-02-09 08:21:15 +01:00
|
|
|
if(db::sequence(*dbs::events) == 0)
|
2017-12-12 21:33:14 +01:00
|
|
|
bootstrap();
|
2017-11-16 02:37:09 +01:00
|
|
|
|
|
|
|
join_ircd_room();
|
2018-03-02 11:14:00 +01:00
|
|
|
listeners();
|
2017-11-16 02:37:09 +01:00
|
|
|
}
|
|
|
|
catch(const m::error &e)
|
|
|
|
{
|
2017-11-30 19:51:01 +01:00
|
|
|
log.error("%s %s", e.what(), e.content);
|
|
|
|
throw;
|
|
|
|
}
|
|
|
|
catch(const std::exception &e)
|
|
|
|
{
|
|
|
|
log.error("%s", e.what());
|
2017-11-26 01:20:42 +01:00
|
|
|
throw;
|
2017-11-16 02:37:09 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
ircd::m::init::~init()
|
|
|
|
noexcept try
|
|
|
|
{
|
|
|
|
leave_ircd_room();
|
2017-12-12 21:33:14 +01:00
|
|
|
m::listeners.clear();
|
|
|
|
m::modules.clear();
|
2017-11-16 02:37:09 +01:00
|
|
|
}
|
|
|
|
catch(const m::error &e)
|
|
|
|
{
|
|
|
|
log.critical("%s %s", e.what(), e.content);
|
2017-11-26 01:20:42 +01:00
|
|
|
ircd::terminate();
|
2017-11-16 02:37:09 +01:00
|
|
|
}
|
|
|
|
|
2017-12-12 21:33:14 +01:00
|
|
|
void
|
|
|
|
ircd::m::init::modules()
|
|
|
|
{
|
|
|
|
const string_view prefixes[]
|
|
|
|
{
|
|
|
|
"m_", "client_", "key_", "federation_", "media_"
|
|
|
|
};
|
|
|
|
|
2018-03-02 12:51:10 +01:00
|
|
|
m::modules.emplace("conf"s, "conf"s);
|
2017-12-12 21:33:14 +01:00
|
|
|
for(const auto &name : mods::available())
|
|
|
|
if(startswith_any(name, std::begin(prefixes), std::end(prefixes)))
|
|
|
|
m::modules.emplace(name, name);
|
|
|
|
|
2018-02-23 04:34:24 +01:00
|
|
|
m::modules.emplace("root"s, "root"s);
|
2017-12-12 21:33:14 +01:00
|
|
|
}
|
|
|
|
|
2017-11-30 19:51:01 +01:00
|
|
|
namespace ircd::m
|
|
|
|
{
|
2018-03-02 09:35:02 +01:00
|
|
|
static void init_listener(const json::object &config, const json::object &opts, const string_view &bindaddr);
|
|
|
|
static void init_listener(const json::object &config, const json::object &opts);
|
2017-11-30 19:51:01 +01:00
|
|
|
}
|
|
|
|
|
2017-12-12 21:33:14 +01:00
|
|
|
void
|
|
|
|
ircd::m::init::listeners()
|
2017-11-30 19:51:01 +01:00
|
|
|
{
|
|
|
|
const json::array listeners
|
|
|
|
{
|
2018-03-02 09:35:02 +01:00
|
|
|
config["listeners"]
|
2017-11-30 19:51:01 +01:00
|
|
|
};
|
|
|
|
|
2017-12-12 21:33:14 +01:00
|
|
|
if(m::listeners.empty())
|
2018-03-02 09:35:02 +01:00
|
|
|
init_listener(config, {});
|
2017-11-30 19:51:01 +01:00
|
|
|
else
|
|
|
|
for(const json::object opts : listeners)
|
2018-03-02 09:35:02 +01:00
|
|
|
init_listener(config, opts);
|
2017-11-30 19:51:01 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
static void
|
2018-03-02 09:35:02 +01:00
|
|
|
ircd::m::init_listener(const json::object &config,
|
2017-11-30 19:51:01 +01:00
|
|
|
const json::object &opts)
|
|
|
|
{
|
|
|
|
const json::array binds
|
|
|
|
{
|
|
|
|
opts["bind_addresses"]
|
|
|
|
};
|
|
|
|
|
|
|
|
if(binds.empty())
|
2018-03-02 09:35:02 +01:00
|
|
|
init_listener(config, opts, "0.0.0.0");
|
2017-11-30 19:51:01 +01:00
|
|
|
else
|
|
|
|
for(const auto &bindaddr : binds)
|
2018-03-02 09:35:02 +01:00
|
|
|
init_listener(config, opts, unquote(bindaddr));
|
2017-11-30 19:51:01 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
static void
|
2018-03-02 09:35:02 +01:00
|
|
|
ircd::m::init_listener(const json::object &config,
|
2017-11-30 19:51:01 +01:00
|
|
|
const json::object &opts,
|
|
|
|
const string_view &host)
|
|
|
|
{
|
|
|
|
const json::array resources
|
|
|
|
{
|
|
|
|
opts["resources"]
|
|
|
|
};
|
|
|
|
|
|
|
|
// resources has multiple names with different configs which are being
|
|
|
|
// ignored :-/
|
|
|
|
const std::string name{"Matrix"s};
|
|
|
|
|
|
|
|
// Translate synapse options to our options (which reflect asio::ssl)
|
|
|
|
const json::strung options{json::members
|
|
|
|
{
|
2018-03-02 09:35:02 +01:00
|
|
|
{ "name", name },
|
|
|
|
{ "host", host },
|
|
|
|
{ "port", opts.get("port", 8448L) },
|
|
|
|
{ "ssl_certificate_file_pem", config["tls_certificate_path"] },
|
|
|
|
{ "ssl_private_key_file_pem", config["tls_private_key_path"] },
|
|
|
|
{ "ssl_tmp_dh_file", config["tls_dh_params_path"] },
|
2017-11-30 19:51:01 +01:00
|
|
|
}};
|
|
|
|
|
2017-12-12 21:33:14 +01:00
|
|
|
m::listeners.emplace_back(options);
|
2017-11-16 02:37:09 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
void
|
2017-12-12 21:33:14 +01:00
|
|
|
ircd::m::init::bootstrap()
|
2017-11-16 02:37:09 +01:00
|
|
|
{
|
2018-02-08 22:23:01 +01:00
|
|
|
assert(dbs::events);
|
|
|
|
assert(db::sequence(*dbs::events) == 0);
|
2017-11-16 02:37:09 +01:00
|
|
|
|
|
|
|
ircd::log::notice
|
|
|
|
(
|
|
|
|
"This appears to be your first time running IRCd because the events "
|
|
|
|
"database is empty. I will be bootstrapping it with initial events now..."
|
|
|
|
);
|
|
|
|
|
2018-02-11 22:37:00 +01:00
|
|
|
create(user::users, me.user_id);
|
|
|
|
me.activate();
|
|
|
|
|
2017-11-16 02:37:09 +01:00
|
|
|
create(my_room, me.user_id);
|
2017-11-30 19:51:01 +01:00
|
|
|
send(my_room, me.user_id, "m.room.name", "",
|
|
|
|
{
|
|
|
|
{ "name", "IRCd's Room" }
|
|
|
|
});
|
|
|
|
|
2018-02-11 22:37:00 +01:00
|
|
|
send(my_room, me.user_id, "m.room.topic", "",
|
|
|
|
{
|
|
|
|
{ "topic", "The daemon's den." }
|
|
|
|
});
|
|
|
|
|
2017-11-16 02:37:09 +01:00
|
|
|
create(control, me.user_id);
|
2018-02-11 22:37:00 +01:00
|
|
|
join(control, me.user_id);
|
2017-11-30 19:51:01 +01:00
|
|
|
send(control, me.user_id, "m.room.name", "",
|
|
|
|
{
|
|
|
|
{ "name", "Control Room" }
|
|
|
|
});
|
|
|
|
|
2018-02-11 22:37:00 +01:00
|
|
|
send(user::users, me.user_id, "m.room.name", "",
|
2017-11-30 19:51:01 +01:00
|
|
|
{
|
2018-02-11 22:37:00 +01:00
|
|
|
{ "name", "Users" }
|
2017-11-30 19:51:01 +01:00
|
|
|
});
|
|
|
|
|
2018-02-11 22:37:00 +01:00
|
|
|
create(user::tokens, me.user_id);
|
|
|
|
send(user::tokens, me.user_id, "m.room.name", "",
|
2017-11-30 19:51:01 +01:00
|
|
|
{
|
2018-02-11 22:37:00 +01:00
|
|
|
{ "name", "User Tokens" }
|
2017-11-30 19:51:01 +01:00
|
|
|
});
|
|
|
|
|
2017-12-12 21:33:14 +01:00
|
|
|
_keys.bootstrap();
|
2017-11-16 02:37:09 +01:00
|
|
|
|
2018-03-02 12:42:16 +01:00
|
|
|
notice(control, me.user_id, "Welcome to the control room.");
|
|
|
|
notice(control, me.user_id, "I am the daemon. You can talk to me in this room by highlighting me.");
|
2017-11-16 02:37:09 +01:00
|
|
|
}
|
|
|
|
|
2017-12-12 21:33:14 +01:00
|
|
|
bool
|
|
|
|
ircd::m::self::host(const string_view &s)
|
|
|
|
{
|
|
|
|
return s == host();
|
|
|
|
}
|
|
|
|
|
|
|
|
ircd::string_view
|
|
|
|
ircd::m::self::host()
|
|
|
|
{
|
|
|
|
return "zemos.net"; //me.user_id.host();
|
|
|
|
}
|
|
|
|
|
|
|
|
void
|
|
|
|
ircd::m::join_ircd_room()
|
|
|
|
try
|
|
|
|
{
|
2018-03-02 16:45:32 +01:00
|
|
|
static conf::item<std::string> online_status_msg
|
|
|
|
{
|
|
|
|
{ "name", "m.ircd.online.status_msg" },
|
|
|
|
{ "default", "Wanna chat? IRCd at your service!" }
|
|
|
|
};
|
|
|
|
|
|
|
|
me.presence("online", online_status_msg);
|
2017-12-12 21:33:14 +01:00
|
|
|
join(my_room, me.user_id);
|
|
|
|
}
|
|
|
|
catch(const m::ALREADY_MEMBER &e)
|
|
|
|
{
|
|
|
|
log.warning("IRCd did not shut down correctly...");
|
|
|
|
}
|
|
|
|
|
|
|
|
void
|
|
|
|
ircd::m::leave_ircd_room()
|
|
|
|
{
|
2018-03-02 16:45:32 +01:00
|
|
|
static conf::item<std::string> offline_status_msg
|
|
|
|
{
|
|
|
|
{ "name", "m.ircd.offline.status_msg" },
|
|
|
|
{ "default", "Catch ya on the flip side..." }
|
|
|
|
};
|
|
|
|
|
2017-12-12 21:33:14 +01:00
|
|
|
leave(my_room, me.user_id);
|
2018-03-02 16:45:32 +01:00
|
|
|
me.presence("offline", offline_status_msg);
|
2017-12-12 21:33:14 +01:00
|
|
|
}
|
2018-02-22 23:29:01 +01:00
|
|
|
|
2018-03-02 16:25:37 +01:00
|
|
|
///////////////////////////////////////////////////////////////////////////////
|
|
|
|
//
|
|
|
|
// m/user.h
|
|
|
|
//
|
|
|
|
|
|
|
|
ircd::m::event::id::buf
|
|
|
|
ircd::m::user::presence(const string_view &presence,
|
|
|
|
const string_view &status_msg)
|
|
|
|
{
|
|
|
|
using prototype = event::id::buf (const id &, const string_view &, const string_view &);
|
|
|
|
|
|
|
|
static import<prototype> function
|
|
|
|
{
|
|
|
|
"client_presence", "set__user_presence_status"
|
|
|
|
};
|
|
|
|
|
|
|
|
return function(user_id, presence, status_msg);
|
|
|
|
}
|
|
|
|
|
2018-02-22 23:29:01 +01:00
|
|
|
///////////////////////////////////////////////////////////////////////////////
|
|
|
|
//
|
|
|
|
// m/room.h
|
|
|
|
//
|
|
|
|
|
|
|
|
ircd::m::room
|
|
|
|
ircd::m::create(const id::room &room_id,
|
|
|
|
const id::user &creator,
|
|
|
|
const string_view &type)
|
|
|
|
{
|
2018-02-23 04:34:24 +01:00
|
|
|
using prototype = room (const id::room &, const id::user &, const string_view &);
|
2018-02-22 23:29:01 +01:00
|
|
|
|
2018-02-23 04:34:24 +01:00
|
|
|
static import<prototype> function
|
2018-02-22 23:29:01 +01:00
|
|
|
{
|
2018-02-23 04:34:24 +01:00
|
|
|
"client_createroom", "createroom__type"
|
2018-02-22 23:29:01 +01:00
|
|
|
};
|
|
|
|
|
|
|
|
return function(room_id, creator, type);
|
|
|
|
}
|
|
|
|
|
|
|
|
ircd::m::room
|
|
|
|
ircd::m::create(const id::room &room_id,
|
|
|
|
const id::user &creator,
|
|
|
|
const id::room &parent,
|
|
|
|
const string_view &type)
|
|
|
|
{
|
2018-02-23 04:34:24 +01:00
|
|
|
using prototype = room (const id::room &, const id::user &, const id::room &, const string_view &);
|
2018-02-22 23:29:01 +01:00
|
|
|
|
2018-02-23 04:34:24 +01:00
|
|
|
static import<prototype> function
|
2018-02-22 23:29:01 +01:00
|
|
|
{
|
2018-02-23 04:34:24 +01:00
|
|
|
"client_createroom", "createroom__parent_type"
|
2018-02-22 23:29:01 +01:00
|
|
|
};
|
|
|
|
|
|
|
|
return function(room_id, creator, parent, type);
|
|
|
|
}
|
2018-02-23 00:52:43 +01:00
|
|
|
|
|
|
|
ircd::m::event::id::buf
|
|
|
|
ircd::m::join(const room &room,
|
|
|
|
const id::user &user_id)
|
|
|
|
{
|
2018-02-23 04:34:24 +01:00
|
|
|
using prototype = event::id::buf (const m::room &, const id::user &);
|
2018-02-23 00:52:43 +01:00
|
|
|
|
2018-02-23 04:34:24 +01:00
|
|
|
static import<prototype> function
|
2018-02-23 00:52:43 +01:00
|
|
|
{
|
2018-02-23 04:34:24 +01:00
|
|
|
"client_rooms", "join__room_user"
|
2018-02-23 00:52:43 +01:00
|
|
|
};
|
|
|
|
|
|
|
|
return function(room, user_id);
|
|
|
|
}
|
2018-02-23 04:43:23 +01:00
|
|
|
|
|
|
|
ircd::m::event::id::buf
|
|
|
|
ircd::m::leave(const room &room,
|
|
|
|
const id::user &user_id)
|
|
|
|
{
|
|
|
|
using prototype = event::id::buf (const m::room &, const id::user &);
|
|
|
|
|
|
|
|
static import<prototype> function
|
|
|
|
{
|
|
|
|
"client_rooms", "leave__room_user"
|
|
|
|
};
|
|
|
|
|
|
|
|
return function(room, user_id);
|
|
|
|
}
|
2018-02-23 04:50:48 +01:00
|
|
|
|
|
|
|
ircd::m::event::id::buf
|
|
|
|
ircd::m::redact(const room &room,
|
|
|
|
const id::user &sender,
|
|
|
|
const id::event &event_id,
|
|
|
|
const string_view &reason)
|
|
|
|
{
|
|
|
|
using prototype = event::id::buf (const m::room &, const id::user &, const id::event &, const string_view &);
|
|
|
|
|
|
|
|
static import<prototype> function
|
|
|
|
{
|
|
|
|
"client_rooms", "redact__"
|
|
|
|
};
|
|
|
|
|
|
|
|
return function(room, sender, event_id, reason);
|
|
|
|
}
|
2018-02-23 05:16:12 +01:00
|
|
|
|
2018-03-02 12:42:16 +01:00
|
|
|
ircd::m::event::id::buf
|
|
|
|
ircd::m::notice(const room &room,
|
|
|
|
const string_view &body)
|
|
|
|
{
|
|
|
|
return message(room, me.user_id, body, "m.notice");
|
|
|
|
}
|
|
|
|
|
|
|
|
ircd::m::event::id::buf
|
|
|
|
ircd::m::notice(const room &room,
|
|
|
|
const m::id::user &sender,
|
|
|
|
const string_view &body)
|
|
|
|
{
|
|
|
|
return message(room, sender, body, "m.notice");
|
|
|
|
}
|
|
|
|
|
2018-02-23 05:16:12 +01:00
|
|
|
ircd::m::event::id::buf
|
|
|
|
ircd::m::message(const room &room,
|
|
|
|
const m::id::user &sender,
|
|
|
|
const string_view &body,
|
|
|
|
const string_view &msgtype)
|
|
|
|
{
|
|
|
|
return message(room, sender,
|
|
|
|
{
|
|
|
|
{ "body", { body, json::STRING } },
|
|
|
|
{ "msgtype", { msgtype, json::STRING } },
|
|
|
|
});
|
|
|
|
}
|
|
|
|
|
|
|
|
ircd::m::event::id::buf
|
|
|
|
ircd::m::message(const room &room,
|
|
|
|
const m::id::user &sender,
|
|
|
|
const json::members &contents)
|
|
|
|
{
|
|
|
|
return send(room, sender, "m.room.message", contents);
|
|
|
|
}
|
|
|
|
|
|
|
|
ircd::m::event::id::buf
|
|
|
|
ircd::m::send(const room &room,
|
|
|
|
const m::id::user &sender,
|
|
|
|
const string_view &type,
|
|
|
|
const string_view &state_key,
|
|
|
|
const json::members &contents)
|
|
|
|
{
|
|
|
|
json::iov _content;
|
|
|
|
json::iov::push content[contents.size()];
|
|
|
|
return send(room, sender, type, state_key, make_iov(_content, content, contents.size(), contents));
|
|
|
|
}
|
|
|
|
|
|
|
|
ircd::m::event::id::buf
|
|
|
|
ircd::m::send(const room &room,
|
|
|
|
const m::id::user &sender,
|
|
|
|
const string_view &type,
|
|
|
|
const string_view &state_key,
|
|
|
|
const json::object &contents)
|
|
|
|
{
|
|
|
|
json::iov _content;
|
|
|
|
json::iov::push content[contents.size()];
|
|
|
|
return send(room, sender, type, state_key, make_iov(_content, content, contents.size(), contents));
|
|
|
|
}
|
|
|
|
|
|
|
|
ircd::m::event::id::buf
|
|
|
|
ircd::m::send(const room &room,
|
|
|
|
const m::id::user &sender,
|
|
|
|
const string_view &type,
|
|
|
|
const string_view &state_key,
|
|
|
|
const json::iov &content)
|
|
|
|
{
|
|
|
|
using prototype = event::id::buf (const m::room &, const id::user &, const string_view &, const string_view &, const json::iov &);
|
|
|
|
|
|
|
|
static import<prototype> function
|
|
|
|
{
|
|
|
|
"client_rooms", "state__iov"
|
|
|
|
};
|
|
|
|
|
|
|
|
return function(room, sender, type, state_key, content);
|
|
|
|
}
|
|
|
|
|
|
|
|
ircd::m::event::id::buf
|
|
|
|
ircd::m::send(const room &room,
|
|
|
|
const m::id::user &sender,
|
|
|
|
const string_view &type,
|
|
|
|
const json::members &contents)
|
|
|
|
{
|
|
|
|
json::iov _content;
|
|
|
|
json::iov::push content[contents.size()];
|
|
|
|
return send(room, sender, type, make_iov(_content, content, contents.size(), contents));
|
|
|
|
}
|
|
|
|
|
|
|
|
ircd::m::event::id::buf
|
|
|
|
ircd::m::send(const room &room,
|
|
|
|
const m::id::user &sender,
|
|
|
|
const string_view &type,
|
|
|
|
const json::object &contents)
|
|
|
|
{
|
|
|
|
json::iov _content;
|
|
|
|
json::iov::push content[contents.count()];
|
|
|
|
return send(room, sender, type, make_iov(_content, content, contents.count(), contents));
|
|
|
|
}
|
|
|
|
|
|
|
|
ircd::m::event::id::buf
|
|
|
|
ircd::m::send(const room &room,
|
|
|
|
const m::id::user &sender,
|
|
|
|
const string_view &type,
|
|
|
|
const json::iov &content)
|
|
|
|
{
|
|
|
|
using prototype = event::id::buf (const m::room &, const id::user &, const string_view &, const json::iov &);
|
|
|
|
|
|
|
|
static import<prototype> function
|
|
|
|
{
|
|
|
|
"client_rooms", "send__iov"
|
|
|
|
};
|
|
|
|
|
|
|
|
return function(room, sender, type, content);
|
|
|
|
}
|
2018-02-23 05:46:27 +01:00
|
|
|
|
|
|
|
ircd::m::event::id::buf
|
|
|
|
ircd::m::commit(const room &room,
|
|
|
|
json::iov &event,
|
|
|
|
const json::iov &contents)
|
|
|
|
{
|
|
|
|
using prototype = event::id::buf (const m::room &, json::iov &, const json::iov &);
|
|
|
|
|
|
|
|
static import<prototype> function
|
|
|
|
{
|
|
|
|
"client_rooms", "commit__iov_iov"
|
|
|
|
};
|
|
|
|
|
|
|
|
return function(room, event, contents);
|
|
|
|
}
|
2018-02-26 08:24:12 +01:00
|
|
|
|
2018-02-26 13:55:27 +01:00
|
|
|
ircd::m::id::room::buf
|
|
|
|
ircd::m::room_id(const id::room_alias &room_alias)
|
|
|
|
{
|
2018-02-28 07:37:10 +01:00
|
|
|
char buf[256];
|
|
|
|
return room_id(buf, room_alias);
|
2018-02-26 13:55:27 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
ircd::m::id::room
|
|
|
|
ircd::m::room_id(const mutable_buffer &out,
|
|
|
|
const id::room_alias &room_alias)
|
|
|
|
{
|
|
|
|
using prototype = id::room (const mutable_buffer &, const id::room_alias &);
|
|
|
|
|
|
|
|
static import<prototype> function
|
|
|
|
{
|
|
|
|
"client_directory_room", "room_id__room_alias"
|
|
|
|
};
|
|
|
|
|
|
|
|
return function(out, room_alias);
|
|
|
|
}
|
|
|
|
|
2018-02-26 08:24:12 +01:00
|
|
|
///////////////////////////////////////////////////////////////////////////////
|
|
|
|
//
|
|
|
|
// m/hook.h
|
|
|
|
//
|
|
|
|
|
2018-03-03 06:12:11 +01:00
|
|
|
/// Alternative hook ctor simply allowing the the function argument
|
|
|
|
/// first and description after.
|
|
|
|
ircd::m::hook::hook(decltype(function) function,
|
|
|
|
const json::members &members)
|
|
|
|
:hook
|
|
|
|
{
|
|
|
|
members, std::move(function)
|
|
|
|
}
|
|
|
|
{
|
|
|
|
}
|
|
|
|
|
|
|
|
/// Primary hook ctor
|
2018-02-26 08:24:12 +01:00
|
|
|
ircd::m::hook::hook(const json::members &members,
|
|
|
|
decltype(function) function)
|
|
|
|
try
|
|
|
|
:_feature
|
|
|
|
{
|
|
|
|
members
|
|
|
|
}
|
|
|
|
,feature
|
|
|
|
{
|
|
|
|
_feature
|
|
|
|
}
|
2018-02-26 09:07:53 +01:00
|
|
|
,matching
|
|
|
|
{
|
|
|
|
feature
|
|
|
|
}
|
2018-02-26 08:24:12 +01:00
|
|
|
,function
|
|
|
|
{
|
|
|
|
std::move(function)
|
|
|
|
}
|
|
|
|
,registered
|
|
|
|
{
|
|
|
|
list.add(*this)
|
|
|
|
}
|
|
|
|
{
|
|
|
|
}
|
|
|
|
catch(...)
|
|
|
|
{
|
|
|
|
if(registered)
|
|
|
|
list.del(*this);
|
|
|
|
}
|
|
|
|
|
|
|
|
ircd::m::hook::~hook()
|
|
|
|
noexcept
|
|
|
|
{
|
|
|
|
if(registered)
|
|
|
|
list.del(*this);
|
|
|
|
}
|
|
|
|
|
|
|
|
ircd::string_view
|
|
|
|
ircd::m::hook::site_name()
|
|
|
|
const try
|
|
|
|
{
|
|
|
|
return unquote(feature.at("_site"));
|
|
|
|
}
|
|
|
|
catch(const std::out_of_range &e)
|
|
|
|
{
|
|
|
|
throw assertive
|
|
|
|
{
|
|
|
|
"Hook %p must name a '_site' to register with.", this
|
|
|
|
};
|
|
|
|
}
|
|
|
|
|
2018-02-26 09:25:48 +01:00
|
|
|
bool
|
|
|
|
ircd::m::hook::match(const m::event &event)
|
|
|
|
const
|
|
|
|
{
|
|
|
|
if(json::get<"origin"_>(matching))
|
|
|
|
if(at<"origin"_>(matching) != at<"origin"_>(event))
|
|
|
|
return false;
|
|
|
|
|
|
|
|
if(json::get<"room_id"_>(matching))
|
|
|
|
if(at<"room_id"_>(matching) != at<"room_id"_>(event))
|
|
|
|
return false;
|
|
|
|
|
|
|
|
if(json::get<"sender"_>(matching))
|
|
|
|
if(at<"sender"_>(matching) != at<"sender"_>(event))
|
|
|
|
return false;
|
|
|
|
|
|
|
|
if(json::get<"type"_>(matching))
|
|
|
|
if(at<"type"_>(matching) != at<"type"_>(event))
|
|
|
|
return false;
|
|
|
|
|
|
|
|
if(json::get<"state_key"_>(matching))
|
|
|
|
if(at<"state_key"_>(matching) != json::get<"state_key"_>(event))
|
|
|
|
return false;
|
|
|
|
|
|
|
|
if(json::get<"membership"_>(matching))
|
|
|
|
if(at<"membership"_>(matching) != json::get<"membership"_>(event))
|
|
|
|
return false;
|
|
|
|
|
2018-03-03 06:13:11 +01:00
|
|
|
if(json::get<"content"_>(matching))
|
|
|
|
if(at<"type"_>(event) == "m.room.message")
|
|
|
|
if(at<"content"_>(matching).has("msgtype"))
|
|
|
|
if(at<"content"_>(matching).get("msgtype") != at<"content"_>(event).get("msgtype"))
|
|
|
|
return false;
|
|
|
|
|
2018-02-26 09:25:48 +01:00
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
|
|
|
|
2018-02-26 08:24:12 +01:00
|
|
|
//
|
|
|
|
// hook::site
|
|
|
|
//
|
|
|
|
|
|
|
|
ircd::m::hook::site::site(const json::members &members)
|
|
|
|
try
|
|
|
|
:_feature
|
|
|
|
{
|
|
|
|
members
|
|
|
|
}
|
|
|
|
,feature
|
|
|
|
{
|
|
|
|
_feature
|
|
|
|
}
|
|
|
|
,registered
|
|
|
|
{
|
|
|
|
list.add(*this)
|
|
|
|
}
|
|
|
|
{
|
|
|
|
}
|
|
|
|
catch(...)
|
|
|
|
{
|
|
|
|
if(registered)
|
|
|
|
list.del(*this);
|
|
|
|
}
|
|
|
|
|
|
|
|
ircd::m::hook::site::~site()
|
|
|
|
noexcept
|
|
|
|
{
|
|
|
|
if(registered)
|
|
|
|
list.del(*this);
|
|
|
|
}
|
|
|
|
|
|
|
|
void
|
|
|
|
ircd::m::hook::site::operator()(const event &event)
|
|
|
|
{
|
2018-02-26 09:07:53 +01:00
|
|
|
std::set<hook *> matching; //TODO: allocator
|
|
|
|
const auto site_match{[&matching]
|
2018-02-26 08:24:12 +01:00
|
|
|
(auto &map, const string_view &key)
|
|
|
|
{
|
|
|
|
auto pit{map.equal_range(key)};
|
|
|
|
for(; pit.first != pit.second; ++pit.first)
|
|
|
|
matching.emplace(pit.first->second);
|
|
|
|
}};
|
|
|
|
|
2018-02-26 09:07:53 +01:00
|
|
|
site_match(origin, at<"origin"_>(event));
|
|
|
|
site_match(room_id, at<"room_id"_>(event));
|
|
|
|
site_match(sender, at<"sender"_>(event));
|
|
|
|
site_match(type, at<"type"_>(event));
|
2018-02-26 08:24:12 +01:00
|
|
|
if(json::get<"state_key"_>(event))
|
2018-02-26 09:07:53 +01:00
|
|
|
site_match(state_key, at<"state_key"_>(event));
|
|
|
|
|
|
|
|
auto it(begin(matching));
|
|
|
|
while(it != end(matching))
|
|
|
|
{
|
2018-02-26 09:25:48 +01:00
|
|
|
const hook &hook(**it);
|
|
|
|
if(!hook.match(event))
|
2018-02-26 09:07:53 +01:00
|
|
|
it = matching.erase(it);
|
|
|
|
else
|
|
|
|
++it;
|
|
|
|
}
|
2018-02-26 08:24:12 +01:00
|
|
|
|
|
|
|
for(const auto &hook : matching)
|
|
|
|
hook->function(event);
|
|
|
|
}
|
|
|
|
|
|
|
|
bool
|
|
|
|
ircd::m::hook::site::add(hook &hook)
|
|
|
|
{
|
2018-02-26 09:07:53 +01:00
|
|
|
if(json::get<"origin"_>(hook.matching))
|
|
|
|
origin.emplace(at<"origin"_>(hook.matching), &hook);
|
2018-02-26 08:24:12 +01:00
|
|
|
|
2018-02-26 09:07:53 +01:00
|
|
|
if(json::get<"room_id"_>(hook.matching))
|
|
|
|
room_id.emplace(at<"room_id"_>(hook.matching), &hook);
|
2018-02-26 08:24:12 +01:00
|
|
|
|
2018-02-26 09:07:53 +01:00
|
|
|
if(json::get<"sender"_>(hook.matching))
|
|
|
|
sender.emplace(at<"sender"_>(hook.matching), &hook);
|
2018-02-26 08:24:12 +01:00
|
|
|
|
2018-02-26 09:07:53 +01:00
|
|
|
if(json::get<"state_key"_>(hook.matching))
|
|
|
|
state_key.emplace(at<"state_key"_>(hook.matching), &hook);
|
2018-02-26 08:24:12 +01:00
|
|
|
|
2018-02-26 09:07:53 +01:00
|
|
|
if(json::get<"type"_>(hook.matching))
|
|
|
|
type.emplace(at<"type"_>(hook.matching), &hook);
|
2018-02-26 08:24:12 +01:00
|
|
|
|
2018-02-26 09:07:53 +01:00
|
|
|
++count;
|
2018-02-26 08:24:12 +01:00
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
|
|
|
bool
|
|
|
|
ircd::m::hook::site::del(hook &hook)
|
|
|
|
{
|
|
|
|
const auto unmap{[&hook]
|
|
|
|
(auto &map, const string_view &key)
|
|
|
|
{
|
|
|
|
auto pit{map.equal_range(key)};
|
|
|
|
for(; pit.first != pit.second; ++pit.first)
|
|
|
|
if(pit.first->second == &hook)
|
|
|
|
return map.erase(pit.first);
|
|
|
|
|
|
|
|
assert(0);
|
|
|
|
}};
|
|
|
|
|
2018-02-26 09:07:53 +01:00
|
|
|
if(json::get<"origin"_>(hook.matching))
|
|
|
|
unmap(origin, at<"origin"_>(hook.matching));
|
2018-02-26 08:24:12 +01:00
|
|
|
|
2018-02-26 09:07:53 +01:00
|
|
|
if(json::get<"room_id"_>(hook.matching))
|
|
|
|
unmap(room_id, at<"room_id"_>(hook.matching));
|
2018-02-26 08:24:12 +01:00
|
|
|
|
2018-02-26 09:07:53 +01:00
|
|
|
if(json::get<"sender"_>(hook.matching))
|
|
|
|
unmap(sender, at<"sender"_>(hook.matching));
|
2018-02-26 08:24:12 +01:00
|
|
|
|
2018-02-26 09:07:53 +01:00
|
|
|
if(json::get<"state_key"_>(hook.matching))
|
|
|
|
unmap(state_key, at<"state_key"_>(hook.matching));
|
2018-02-26 08:24:12 +01:00
|
|
|
|
2018-02-26 09:07:53 +01:00
|
|
|
if(json::get<"type"_>(hook.matching))
|
|
|
|
unmap(type, at<"type"_>(hook.matching));
|
2018-02-26 08:24:12 +01:00
|
|
|
|
2018-02-26 09:07:53 +01:00
|
|
|
--count;
|
2018-02-26 08:24:12 +01:00
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
|
|
|
ircd::string_view
|
|
|
|
ircd::m::hook::site::name()
|
|
|
|
const try
|
|
|
|
{
|
|
|
|
return unquote(feature.at("name"));
|
|
|
|
}
|
|
|
|
catch(const std::out_of_range &e)
|
|
|
|
{
|
|
|
|
throw assertive
|
|
|
|
{
|
|
|
|
"Hook site %p requires a name", this
|
|
|
|
};
|
|
|
|
}
|
|
|
|
|
|
|
|
//
|
|
|
|
// hook::list
|
|
|
|
//
|
|
|
|
|
|
|
|
decltype(ircd::m::hook::list)
|
|
|
|
ircd::m::hook::list
|
|
|
|
{};
|
|
|
|
|
|
|
|
bool
|
|
|
|
ircd::m::hook::list::del(hook &hook)
|
|
|
|
try
|
|
|
|
{
|
|
|
|
const auto site(at(hook.site_name()));
|
|
|
|
assert(site != nullptr);
|
|
|
|
return site->add(hook);
|
|
|
|
}
|
|
|
|
catch(const std::out_of_range &e)
|
|
|
|
{
|
|
|
|
log::critical
|
|
|
|
{
|
|
|
|
"Tried to unregister hook(%p) from missing hook::site '%s'",
|
|
|
|
&hook,
|
|
|
|
hook.site_name()
|
|
|
|
};
|
|
|
|
|
|
|
|
assert(0);
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
|
|
|
|
bool
|
|
|
|
ircd::m::hook::list::add(hook &hook)
|
|
|
|
try
|
|
|
|
{
|
|
|
|
const auto site(at(hook.site_name()));
|
|
|
|
assert(site != nullptr);
|
|
|
|
return site->add(hook);
|
|
|
|
}
|
|
|
|
catch(const std::out_of_range &e)
|
|
|
|
{
|
|
|
|
throw error
|
|
|
|
{
|
|
|
|
"No hook::site named '%s' is registered...", hook.site_name()
|
|
|
|
};
|
|
|
|
}
|
|
|
|
|
|
|
|
bool
|
|
|
|
ircd::m::hook::list::del(site &site)
|
|
|
|
{
|
|
|
|
return erase(site.name());
|
|
|
|
}
|
|
|
|
|
|
|
|
bool
|
|
|
|
ircd::m::hook::list::add(site &site)
|
|
|
|
{
|
|
|
|
const auto iit
|
|
|
|
{
|
|
|
|
emplace(site.name(), &site)
|
|
|
|
};
|
|
|
|
|
|
|
|
if(unlikely(!iit.second))
|
|
|
|
throw error
|
|
|
|
{
|
|
|
|
"Hook site name '%s' already in use", site.name()
|
|
|
|
};
|
|
|
|
|
|
|
|
return true;
|
|
|
|
}
|