mirror of
git://git.psyced.org/git/psyced
synced 2024-08-15 03:25:10 +00:00
192 lines
5.1 KiB
C
192 lines
5.1 KiB
C
// $Id: component.c,v 1.72 2008/10/01 10:59:24 lynx Exp $ // vim:syntax=lpc
|
|
//
|
|
// this implements a passive listener component
|
|
#define NO_INHERIT
|
|
#include "jabber.h"
|
|
#undef NO_INHERIT
|
|
#include <url.h>
|
|
|
|
inherit NET_PATH "xml/common";
|
|
|
|
inherit NET_PATH "jabber/mixin_parse";
|
|
inherit NET_PATH "jabber/mixin_render";
|
|
|
|
// in theory - or future - scheme plan will be implemented by
|
|
// a gateway/imtransport which inherits this file
|
|
#define SCHEME_PLAN
|
|
|
|
volatile protected mapping config;
|
|
volatile string streamid;
|
|
volatile string componentname;
|
|
volatile int authenticated;
|
|
|
|
|
|
logon(arg) {
|
|
#ifdef _flag_log_sockets_XMPP
|
|
D0( log_file("RAW_XMPP", "\n%O logon\t%O", ME, ctime()); )
|
|
#endif
|
|
#ifdef INPUT_NO_TELNET
|
|
input_to(#'feed, INPUT_IGNORE_BANG | INPUT_CHARMODE | INPUT_NO_TELNET);
|
|
#else
|
|
enable_telnet(0, ME);
|
|
input_to(#'feed, INPUT_IGNORE_BANG | INPUT_CHARMODE);
|
|
#endif
|
|
if (this_interactive()) set_prompt("");
|
|
set_combine_charset(COMBINE_CHARSET);
|
|
sTextPath(0, "en", "jabber");
|
|
}
|
|
|
|
reboot(reason, restart, pass) {
|
|
// close the stream according to XEP 0190
|
|
if (interactive(ME)) {
|
|
flags |= TCP_PENDING_DISCONNECT;
|
|
emitraw("</stream:stream>");
|
|
}
|
|
}
|
|
|
|
onHandshake() {
|
|
#ifdef SCHEME_PLAN
|
|
register_scheme(config["_scheme"]);
|
|
#else
|
|
register_target(XMPP + componentname);
|
|
#endif
|
|
}
|
|
|
|
#ifdef SCHEME_PLAN
|
|
jabberMsg(XMLNode node) {
|
|
mixed *su = parse_uniform(XMPP + node["@from"]);
|
|
string origin = config["_scheme"] + ":";
|
|
unless(su) {
|
|
P0(("%O could not find uniform source in %O\n", ME, node))
|
|
return;
|
|
}
|
|
if (su[UUser])
|
|
origin += su[UUser];
|
|
return ::jabberMsg(node, origin, su);
|
|
}
|
|
#endif
|
|
|
|
#ifdef SCHEME_PLAN
|
|
determine_targetjid(target, vars) {
|
|
mixed *tu;
|
|
unless(vars["_INTERNAL_target_jabber_bare"]) {
|
|
unless(target)
|
|
vars["_INTERNAL_target_jabber_bare"] = componentname;
|
|
else {
|
|
tu = parse_uniform(target);
|
|
if (stringp(tu[UBody]) && strlen(tu[UBody]))
|
|
vars["_INTERNAL_target_jabber_bare"] = tu[UBody] + "@" + componentname;
|
|
else
|
|
vars["_INTERNAL_target_jabber_bare"] = componentname;
|
|
}
|
|
}
|
|
|
|
unless (vars["_INTERNAL_target_jabber"]) {
|
|
vars["_INTERNAL_target_jabber"] = vars["_INTERNAL_target_jabber_bare"];
|
|
}
|
|
}
|
|
#endif
|
|
|
|
|
|
|
|
waitfor_handshake(XMLNode node) {
|
|
switch (node[Tag]) {
|
|
case "handshake":
|
|
if (node[Cdata] == sha1(streamid + config["_secret"])) {
|
|
PT(("%O component auth succeded as %O\n", ME, componentname))
|
|
nodeHandler = #'jabberMsg;
|
|
authenticated = 1;
|
|
emitraw("<handshake/>");
|
|
onHandshake();
|
|
} else {
|
|
monitor_report("_error_invalid_password",
|
|
sprintf("%O tried to link to %O using a wrong password",
|
|
query_ip_name(), componentname));
|
|
STREAM_ERROR("not-authorized", "");
|
|
remove_interactive(ME);
|
|
}
|
|
break;
|
|
default:
|
|
P0(("%O got %O while waiting for handshake\n", ME, node))
|
|
break;
|
|
}
|
|
}
|
|
|
|
int msg(string source, string mc, string data,
|
|
mapping vars, int showingLog, string target) {
|
|
#ifdef DEFLANG
|
|
unless(vars["_language"]) vars["_language"] = DEFLANG;
|
|
#else
|
|
unless(vars["_language"]) vars["_language"] = "en";
|
|
#endif
|
|
#ifdef PREFIXES
|
|
if (abbrev("_prefix", mc)) return 1;
|
|
#endif
|
|
#ifndef GAMMA // TODO: decide if this is good or bad
|
|
else if (abbrev("_status_person_absent", mc)) {
|
|
PT(("Intercepted absent from %O to %O\n", mc, source, ME))
|
|
return 1;
|
|
}
|
|
#endif
|
|
switch (mc){
|
|
case "_message_echo_private":
|
|
return 1;
|
|
}
|
|
// copied from active
|
|
unless (vars["_INTERNAL_mood_jabber"])
|
|
vars["_INTERNAL_mood_jabber"] = "neutral";
|
|
|
|
determine_sourcejid(source, vars);
|
|
determine_targetjid(target, vars);
|
|
|
|
if (vars["_place"]) vars["_place"] = mkjid(vars["_place"]);
|
|
unless (vars["_INTERNAL_target_jabber"]) return 1;
|
|
return ::msg(source, mc, data, vars, showingLog, target);
|
|
}
|
|
|
|
disconnected(remainder) {
|
|
/* unregistering scheme / target is a bad idea, as the target hostname
|
|
* does not resolve (in cases where we call it 'icq'), so we're going
|
|
* to enqueue until the component connects again
|
|
*/
|
|
authenticated = 0;
|
|
return 0; // unexpected
|
|
}
|
|
|
|
open_stream(node) {
|
|
string packet;
|
|
if (node["@xmlns"] != "jabber:component:accept") {
|
|
remove_interactive(ME); // disconnect
|
|
}
|
|
object o = find_object(CONFIG_PATH "config");
|
|
|
|
if (o) config = o->qConfig(node["@to"]);
|
|
P2(("\n%O loads config %O\n", ME, config))
|
|
|
|
streamid = RANDHEXSTRING;
|
|
packet = sprintf("<?xml version='1.0' encoding='UTF-8' ?>"
|
|
"<stream:stream "
|
|
"xmlns='%s' "
|
|
"xmlns:stream='http://etherx.jabber.org/streams' "
|
|
"xml:lang='en' id='%s' ", node["@xmlns"], streamid);
|
|
if (node["@to"]) {
|
|
packet += "from='" + node["@to"] + "' ";
|
|
} else {
|
|
packet += "from='" _host_XMPP "' ";
|
|
}
|
|
if (!config) {
|
|
/* reply with a stream error */
|
|
monitor_report("_error_unknown_host",
|
|
sprintf("%O tried to link to %O but we dont have a config for this",
|
|
ME, node["@to"]));
|
|
STREAM_ERROR("host-unknown", "")
|
|
remove_interactive(ME);
|
|
}
|
|
packet += "version='1.0'>";
|
|
emit(packet);
|
|
|
|
nodeHandler = #'waitfor_handshake;
|
|
componentname = node["@to"];
|
|
|
|
return;
|
|
}
|