psyc-mirrors/psyced
1
0
Fork 0
mirror of git://git.psyced.org/git/psyced synced 2024-08-15 03:25:10 +00:00
Code Issues 2 Releases Wiki Activity
psyced/world/net/person.c
psyc://psyced.org/~lynX fd086c22a7 +
2009-04-02 09:57:05 +02:00

3033 lines
95 KiB
C
Raw Blame History

// vim:foldmethod=marker:syntax=lpc:noexpandtab
// $Id: person.c,v 1.722 2008/12/18 17:45:45 lynx Exp $
//
// person: a PSYC entity representing a human being
/*
the difference from person.c to user.c is currently
defined as follows: person.c implements the UNI logic
of PSYC, whereas user.c *only* does "client" logic for
dumb protocols. so everything that needs to work for an
external real PSYC clients belongs into here, and everything
that is not needed by a real PSYC client belongs outside.
this distinction is particularely tricky for the display
function w() which is actually more like a message to
oneself, therefore needs a minimum implementation which
forwards the stuff to the current location. so we also
need textdb support in here.. well.. TODO someday..
whenever we start using person without user.
there's a thought in my head that says it may become
useful to split this file some more so one can
implement "caches" for remote psyc people that are
*not* linked and represented by this server. just one
out of many possible approaches to solve the problem
of resolving nicknames into remote users. the other is
to keep nick-to-uni/unl data structures in each object.
but even basic information like uni and unl is already
more than just one string, so it's prolly worth an
object to handle it..
*/
// local debug messages - turn them on by using psyclpc -DDperson=<level>
#ifdef Dperson
# undef DEBUG
# define DEBUG Dperson
#endif
#include <driver.h>
#include <errno.h>
#include <net.h>
#include <person.h>
#include <psyc.h>
#include <storage.h>
#include <uniform.h>
#if __EFUN_DEFINED__(tls_query_connection_info)
# include <sys/tls.h>
#endif
inherit NET_PATH "group/master";
inherit NET_PATH "lastlog";
volatile mixed place;
volatile mapping places;
volatile int leaving, greeting;
volatile string lastmc;
volatile string nonce;
// this flag seems to indicate that any announce() has gone out
// not sure if ONLINE would do as well.. TODO
// TODO: remove logged_on, if (availability) provides same info
// but it probably doesn't - as avail is independent..
volatile int logged_on = 0;
#ifndef _flag_disable_module_presence
volatile int mood = MOOD_UNSPECIFIED;
// mood is one digit as defined in http://www.psyc.eu/presence
volatile mapping avail2mc; // shared_memory()
# ifdef JABBER_PATH
volatile mapping mood2jabber; // shared_memory()
# endif
# ifdef LASTAWAY
volatile mapping lastaway;
# endif
volatile mixed availability;
#endif // _flag_disable_module_presence
// complex data structure of peers. see peer.h
volatile mapping ppl;
// friends contains the currently available peers.
// technically, friends is a multi-dimensional mapping:
// uniforms or objects pointing to nick and availability.
// it should be 0-dimensional instead, only containing objects:
// local entities vs. context slaves for remote entities.
// in both cases providing the typical state information:
// availability, mood, presence text, icons and photos...
volatile mapping friends;
#ifdef RELAY
volatile string remotesource;
#endif
#ifdef PRO_PATH
volatile string odata;
#endif
#ifdef ALIASES
volatile mapping aliases, raliases;
#endif
// this becomes somewhat confusing...
// user.h contains log and ppl stuff that a psyc person needs, too
#define NO_INHERIT
#include <user.h>
#undef NO_INHERIT
// local prototypes
logon(string host);
qFriends();
quit(int immediate, string variant);
// outgoing psyc object name
psycName() { return "~"+ MYLOWERNICK; }
// this looks trivial but it may get more complex one day than
// just to look at the existence of a password.. so proper
// abstraction must be maintained. in fact the pro variant of
// psyced accepts other forms of registration, too..
//
isNewbie() { return IS_NEWBIE; }
// "novice" maybe a nicer word?
#include <trust.h>
int get_trust(string id, string trustee, string profile) {
int trust;
unless (profile) profile = ppl[id];
if (profile && stringp(profile)) {
trust = profile[PPL_TRUST];
if (trust == PPL_TRUST_DEFAULT) trust = profile[PPL_NOTIFY];
else trust += TRUST_OVER_NOTIFY;
PT(("%O get_trust(%O, %O, %O) = %d from profile\n", ME,
id, trustee, profile, trust - '0'))
return trust - '0';
}
#ifndef _flag_disable_module_trust
trust = ::get_trust(id, trustee);
PT(("%O get_trust(%O, %O, %O) = %d from trustiness\n", ME,
id, trustee, profile, trust))
return trust;
#else
return 0;
#endif
}
array(string) exposeGroups(int trustiness) {
#ifdef MAX_EXPOSE_GROUPS
array(string) list = allocate(MAX_EXPOSE_GROUPS);
#else
array(string) list = allocate(sizeof(places));
#endif
int defaul, i = 0;
string loc, name;
mixed k, t;
defaul = trustiness + ( v("groupsexpose") || DEFAULT_EXPOSE_GROUPS )
> EXPOSE_THRESHOLD;
foreach (k, name : places) {
if (objectp(k)) loc = psyc_name(k); // doesnt happen
else loc = k;
t = PPL_EXPOSE_DEFAULT;
// the user can have a profile for a place uniform
if (ppl[loc]) t = ppl[loc][PPL_EXPOSE];
PT(("%O -» %O, %O\n", k, t, to_int(t)))
if (t == PPL_EXPOSE_DEFAULT && defaul)
list[i++] = loc;
else {
t = t - '0';
if (t && t + trustiness > EXPOSE_THRESHOLD)
list[i++] = loc;
}
#ifdef MAX_EXPOSE_GROUPS
if (i == MAX_EXPOSE_GROUPS) return list;
#endif
}
PT(("exposeGroups outbound » %O «\n", list))
return i && list[.. i-1];
}
array(string) exposeFriends(int trustiness) {
string profile;
mixed k, t;
int defaul, i = 0;
#ifdef MAX_EXPOSE_FRIENDS
array(string) list = allocate(MAX_EXPOSE_FRIENDS);
#else
array(string) list = allocate(sizeof(ppl));
#endif
defaul = trustiness + ( v("friendsexpose") || DEFAULT_EXPOSE_FRIENDS )
> EXPOSE_THRESHOLD;
P4(("%O's exposeFriends(%O) -» %O .. (%O || %O)\n",
ME, trustiness, defaul,
v("friendsexpose"), DEFAULT_EXPOSE_FRIENDS ))
foreach (k, profile : ppl)
// only expose those we are also friends with
// this automatically skips places
if (profile[PPL_NOTIFY] >= PPL_NOTIFY_FRIEND) {
t = profile[PPL_EXPOSE];
// PT(("%O -» %O, %O\n", k, t, to_int(t)))
if (t == PPL_EXPOSE_DEFAULT && defaul)
list[i++] = UNIFORM(k);
else {
t = t - '0';
if (t && t + trustiness > EXPOSE_THRESHOLD)
list[i++] = UNIFORM(k);
}
#ifdef MAX_EXPOSE_FRIENDS
if (i == MAX_EXPOSE_FRIENDS) return list;
#endif
}
P4(("exposeFriends outbound » %O «\n", list))
return i && list[.. i-1];
}
// when calling this externally you are committing a capital crime if
// you pass false information here. please pass the identification of
// the caller (either object for local or UNI for remote). you can use
// lookup_identification() to figure those out. don't pass a profile,
// that's just for internal calls. you may as well leave source out.
// see also qPublicInfo()
qDescription(source, vars, profile, itsme) {
mapping dv;
int trust, idle = 0;
#if 0
unless(profile) {
// wieso der wiederholte lookup?
// .. bei examine via web ist das noch nicht gesetzt
P1(("%O description() request from %O for %O\n",
ME, previous_object(), source))
if (source) {
if (objectp(source))
profile = ppl[ source->qNameLower() ];
else profile = ppl[source];
}
} else
#endif
// unless (stringp(profile)) profile = 0;
// "ignore" == PPL_DISPLAY_NONE has already been handled in msg()
// is "knowing the nickname" a sufficient reason to give some
// kind of an answer, even if stripped down? not really.
// it's like EXPN and VRFY in SMTP. doomed to die by abuse.
// TRUST_MYSELF in a way, but we have the '0' offset here
if (itsme) trust = '9' + TRUST_OVER_NOTIFY; // that's me
else if (member(vars, "_trust") && intp(trust = vars["_trust"])) {
// lynx fragt: das ist niemals ein _trust, welches mir der
// anfragende untergejubelt hat?
// el verwirrt: ne, es sei denn nen object tut das
trust += '0';
} else trust = get_trust(objectp(source) ?
vars["_nick"] : source, 0, profile) + '0';
if (v("visibility") == "off" && trust < PPL_NOTIFY_FRIEND)
return 0;
// we could greatly simplify all these decisions what belongs into
// the outgoing description for whom, if we introduced a psyc2trust
// mapping into profiles.gen with 'trust <digit>' values for each
// entry. then avoid repetitive tasks like de facto duplicating the
// set2psyc mapping here by writing up these lines:
dv = ([ "_nick": v("name"),
// lynX, you can't add more fields here if you're not sure
// they actually exist! :( --lynX
"_identification": // v("identification") ||
v("_source"),
// similar code also in net/place/basic.c
#ifdef IRC_PATH
// TODO: right now we have the jid twice, but we should rather
// make _identification_scheme_* vars for each of these,
// then define a syntax which allows templates to collect
// all matches of _identification_scheme* or _identification*
// into a list-string for display.
// what about "Identifications: [_identification*]" ?
"_identification_alias":
// we need to make this http url more interesting first..
#if 0
# if HAS_PORT(HTTP_PORT, HTTP_PATH)
HTTP_URL +"/~"+ MYNICK +" "+
# else
# if HAS_PORT(HTTPS_PORT, HTTP_PATH)
HTTPS_URL +"/~"+ MYNICK +" "+
# endif
# endif
#endif
# if 0 // def SIP_PATH
"sip:"+ MYLOWERNICK +"@"+ SERVER_HOST +" "+
# endif
# ifdef _host_XMPP
"xmpp:"+ MYLOWERNICK +"@"+ _host_XMPP +" "+
# else
# ifdef JABBER_PATH
"xmpp:"+ MYLOWERNICK +"@"+ SERVER_HOST +" "+
# endif
# endif
"irc://"+ SERVER_HOST +"/~"+ MYNICK,
#endif
#ifdef JABBER_PATH
"_identification_scheme_XMPP":
# ifdef _host_XMPP
MYLOWERNICK +"@" _host_XMPP
# else
MYLOWERNICK +"@" SERVER_HOST
# endif
#endif
// yes, putting description data into an XML structured tree
// may also be a solution, but then we lose the advantage of
// a flat name access. it would require use to implement
// xpath to do our psyctext templates. jeez! so, as long as
// the psyc inheritance plan solves our problems, let's steer
// clear of xml, although we're not religious about this.
// xml may be an answer sometime somewhere.
]);
if (v("scheme")) {
dv["_protocol_agent"] = v("scheme");
if (v("layout"))
dv["_agent_design"] = v("layout");
}
#if __EFUN_DEFINED__(tls_query_connection_info)
if (interactive(ME) && tls_query_connection_state(ME)) {
array(mixed) tls = tls_query_connection_info(ME);
if (tls[TLS_COMP] > 1)
dv["_circuit_compression"] =
TLS_COMP_NAME(tls[TLS_COMP]);
if (tls[TLS_CIPHER])
dv["_circuit_encryption_cipher"] =
intp(tls[TLS_CIPHER]) ? TLS_CIPHER_NAME(tls[TLS_CIPHER])
: tls[TLS_CIPHER];
if (tls[TLS_PROT])
dv["_circuit_encryption_protocol"] =
intp(tls[TLS_PROT]) ? TLS_PROT_NAME(tls[TLS_PROT])
: tls[TLS_PROT];
}
#endif
// should idle time be visible to friends only?
// or should it be a /set visibility medium feature?
if (v("me")) dv["_action_motto"] = v("me");
if (v("languages"))
dv["_language_alternate"] = v("languages");
if (v("affiliation"))
dv["_affiliation"] = v("affiliation");
if (v("publicpage"))
dv["_page_public"] = v("publicpage");
if (v("publictext"))
dv["_description_public"] = v("publictext");
if (v("mottotext"))
dv["_description_motto"] = v("mottotext");
if (v("publicname"))
dv["_name_public"] = v("publicname");
if (v("stylefile"))
dv["_uniform_style"] = v("stylefile");
if (v("miniphotofile"))
dv["_uniform_photo_small"] = v("miniphotofile");
if (v("photopage"))
dv["_page_photo"] = v("photopage");
if (trust >= PPL_NOTIFY_FRIEND) {
unless (v("exposetime")) {
CALC_IDLE_TIME(idle);
if (idle)
dv["_time_idle"] = idle;
// if you need it as timedelta, create it out of _time_idle
// if (idle > 30)
// dv["_INTERNAL_time_idle"] = timedelta(idle);
}
if (v("age"))
dv["_time_age"] = v("age");
if (v("privatetext"))
dv["_description_private"] =
v("privatetext");
if (v("likestext"))
dv["_description_preferences"] =
v("likestext");
if (v("dislikestext"))
dv["_description_preferences_not"] =
v("dislikestext");
if (v("privatepage"))
dv["_page_private"] = v("privatepage");
if (v("keyfile"))
dv["_uniform_key_public"] = v("keyfile");
if (v("email"))
dv["_identification_scheme_mailto"] = v("email");
// this will most likely be renamed
if (v("photofile"))
dv["_uniform_photo"] = v("photofile");
if (v("animalfave"))
dv["_favorite_animal"] = v("animalfave");
if (v("popstarfave"))
dv["_favorite_popstar"] = v("popstarfave");
if (v("musicfave"))
dv["_favorite_music"] = v("musicfave");
if (v("color"))
dv["_color"] = v("color");
if (v("language"))
dv["_language"] = v("language");
if (v("timezone"))
dv["_address_zone_time"] = v("timezone");
if (v("telephone"))
dv["_contact_telephone"] = v("telephone");
// this is not compatible with vCard right now
// i just felt spontaneous.. sorry ;)
// so this may disappear in favour of such horrid
// things like /set skype ...
if (v("identities"))
dv["_contact_identities"] = v("identities");
if (v("groupsexpose") != "off" && sizeof(places)) {
array(string) l = exposeGroups( to_int(trust)-'0' );
if (l) dv["_list_groups"] = l; // _tab
}
// hab mir überlegt das tobijschiger zu lösen.. der /x selbst zeigt keine
// freunde an, sondern wir schicken einen _request_description mit friendivity
// level ab und lösen einen castmsg() aus. dann erfahren die freunde, dass
// jemand gerne mehr über sie wissen will, und sie können entscheiden darauf
// zu antworten. also das erforschen der freundschaften selbst als friendcast.
// dazu muss ein neuer befehl her.. /examine <user> friends oder /discover?
// die frage ist auch, antwortet man gleich mit descriptions? für guis wär
// das toll: kann man den friendspace gleich grafisch aufbereiten mit fotos -
// oder antwortet man erstmal dezent mit einem "hallo, mich gibt es"
//
// weiterer update: hat das noch irgendeinen sinn im dezentralen state?
// also im plex in dem wir über freundesfreunde per push bereits bescheid
// wissen sollten falls keiner was dagegen hat?
//
// plenty to be done here, but this is a simple start
if (v("friendsexpose") != "off" && sizeof(ppl)) {
array(string) l = exposeFriends( to_int(trust)-'0' );
if (l) dv["_list_friends"] = l; // _tab
}
}
else unless (FILTERED(source)) {
if (v("color"))
dv["_color"] = v("color");
if (v("language"))
dv["_language"] = v("language");
// we don't know if this person is a friend of a friend, but..
// you can set your level high enough if you don't mind at all
if (intp(v("friendsexpose")) && v("friendsexpose") > 0) {
array(string) l = exposeFriends( 0 );
if (l) dv["_list_friends"] = l; // _tab
}
}
if (boss(source)) {
if (v("agent"))
dv["_version_agent"] = v("agent");
if (v("forwarded"))
dv["_host_forwarded"] = v("forwarded");
if (v("host"))
dv["_host_name"] = v("host");
// else?
if (v("ip"))
dv["_host_IP"] = v("ip");
if (v("gender"))
dv["_gender"] = v("gender");
if (v("birth"))
dv["_date_birth"] = v("birth");
if (v("region"))
dv["_geographic_region"] = v("region");
if (v("fname"))
dv["_name_first"] = v("fname");
}
// PT(("sending: %O\n", dv))
return dv;
}
qLocation(string service) {
ASSERT("qLocation", v("locations"), v("locations"))
return v("locations")[service];
}
// returns 0 if that was just an update. 1 on success.
// this was originally used by sip/udp only, then slowly
// integrated into existing code
sLocation(string service, mixed data) {
ASSERT("sLocation", v("locations"), v("locations"))
// should this function also call register_location ?
// yes because a delivery error should remove clients
// from the location table, too.. not just proper
// unlink requests FIXME
if (v("locations")[service] == data) return 0;
unless (data) {
string retval = v("locations")[service];
m_delete(v("locations"), service);
return retval;
}
return v("locations")[service] = data;
}
static linkSet(service, location, source) {
P1(("linkSet(%O, %O, %O) called in %O: linking.\n",
service, location, source, ME));
// sLocation?
unless (location) location = source;
else unless (source) unless (source = location)
raise_error("You have to provide either source or location!\n");
v("locations")[service] = location;
register_location(location, ME);
if (service) sendmsg(source, "_notice_link_service", 0,
([ "_service" : service,
"_location" : location,
"_identification": v("_source"),
"_nick" : MYNICK ]));
else {
sendmsg(source, "_notice_link", 0, ([
"_location" : location,
"_identification": v("_source"),
"_nick" : MYNICK ]));
// <el> PSYCion users dont have queries.
// until there are more clients this will
// be enough
vDel("query");
// <lynX> clients either use _request_input
// and thus support current place and query,
// or otherwise _message to places and people
// and never use _request_input, therefore
// not get into trouble with query & place....?
// grmbl, this is making tons of trouble
// vDel("place");
// <lynX> psyced acts indeed too complicated
// for simple clients on link when a place is set
}
}
static linkDel(service, source, variant) {
string mc = "_notice_unlink";
string candidate = v("locations")[service];
unless (candidate) {
P3(("linkDel(%O, %O) called in %O: no such candidate!\n",
service, source, ME));
return 0;
}
P1(("linkDel(%O, %O) called in %O: unlinking %O.\n",
service, source, ME, candidate));
unless (source) source = candidate;
// sLocation?
register_location(candidate, 0);
// maybe actual deletion would need to be delayed after
// letting locations know. they might still be sending
// stuff to us, right?
m_delete(v("locations"), service || 0);
if (variant) mc += variant;
if (service) sendmsg(source, mc, 0,
([ "_service" : service,
"_location_service" : candidate,
"_identification" : v("_source") ]));
else sendmsg(source, mc, 0,
([ "_location" : candidate,
"_identification" : v("_source") ]));
return candidate;
}
static linkCleanUp(variant) {
mixed type, loc;
foreach (type, loc : v("locations")) {
P2(("linkCleanUp(%O) to %O's ex-%O-client %O\n",
variant, ME, type, loc))
linkDel(type, 0, variant);
}
}
// extend sName() from name.c
sName2(a) {
int e;
string b;
if (MYNICK) return 0;
b = lower_case(a);
e = load(PERSON_DATA_FILE(b));
if (e && e != ENOENT) {
log_file("PANIC", "load(%O) returned %O\n", a, e);
// D(S("PANIC! load(%O) returned %O!\n", a, e));
this_player()->w("_failure_object_restore_err" + e,
"Object could not be restored!");
#ifdef PANIC_ON_NO_ADMIN
shutdown();
#endif
destruct(ME);
return 0;
}
#ifdef PERSISTENT_MASTERS
// in persons it is easier to reconstruct it from scratch
_routes = ([ ]);
#endif
// backwards compatibility to the times before we had tokens
// unless (v("password")) vSet("password", v("token"));
// let user objects set it anew, otherwise we'll have probs
// distinguishing net/user from net/something/user
vDel("scheme");
#ifdef BRAIN
vDel("location"); // clean out from earlier versions
// we now use v("locations")[_service]
#endif
#if SYSTEM_CHARSET == "ISO-8859-15"
if (v("charset") == "ISO-8859-1") vDel("charset");
#endif
if ( (b = v("name")) &&! stricmp(a, b) ) {
// support for stored nickname writing style
a = b;
P3((" [ %O:sName %O ] ", ME, a))
} else {
// support for "cp oldnick.o newnick.o" w/out patching
vSet("name", a);
P3((" [ %O:sName %O override ] ", ME, a))
}
#ifdef ALIASES
if (v("aliases")) {
string k, l;
foreach (k, l : v("aliases")) {
aliases[lower_case(k)] = l;
raliases[l] = k;
}
} else vSet("aliases", ([]));
#endif
#ifndef _flag_disable_module_presence
// let's see if there's anything bad about
// persistent mood & availability.. if not,
// we should remove the local vars.
mood = v("mood") || MOOD_UNSPECIFIED;
availability = v("availability");
#endif // _flag_disable_module_presence
if (v("locations")) linkCleanUp("_crash");
else vSet("locations", ([ ]));
// protection against file read errors
if (IS_NEWBIE) {
if (boss(a)) {
log_file("PANIC", "load(%O) failed\n", a);
this_player()->w("_failure_object_restore_admin",
"You are registered as admin, but I could not restore your data!");
// raise_error("boss without password\n");
#ifdef PANIC_ON_NO_ADMIN
shutdown();
#endif
destruct(ME);
return 0;
}
#ifdef _flag_enable_administrator_by_nick
else if (strstr(lower_case(a), "admin") != -1) {
this_player()->w("_failure_object_create_admin",
"This nickname is available to administrators only.");
destruct(ME);
return 0;
}
#endif
} else {
if (v("emailvalidity") && v("email"))
register_target("mailto:"+ lower_case(v("email")));
}
::sName(a);
register_person(MYLOWERNICK, ME);
// maybe use v("identification") here?
vSet("_source", psyc_name(ME));
return MYNICK; // means new name accepted
}
remove() {
#ifndef USE_LIVING
register_person(MYLOWERNICK, 0);
#endif
}
// this is called by all login procedures, even psyc
//
// fippo has extended it with a closure to be able to do asynchronous
// credentials checks, but it is rather obvious that no other piece of
// code in psyced requires such a hard and ugly approach to solve such a
// problem, so this could probably be solved in a more elegant way..
//
// as I just noticed this... this MUST be asynchronous. What if you
// need to lookup the authentication data from a database first?
// from ldap? IF you find a more elegant solution to this go ahead, but
// until then this is necessary.
//
checkPassword(try, method, salt, args, cb, varargs cbargs) {
string HA1, HA2;
string t1, rc;
P3(("%O checkPassword(%O,%O,%O,%O,%O,%O)\n", ME,
try,method,salt,args,cb,cbargs))
#ifdef ASYNC_AUTH
// und endlich darf saga einen komma-operator im psyced bewundern:
# define ARETURN(RET) {\
P2(("returning async auth %O to %O in %O\n", RET, cbargs, ME)) \
return apply(cb, RET, cbargs), RET; \
}
#else
# echo Warning: ASYNC_AUTH not activated.
# define ARETURN(RET) return RET;
#endif
#ifdef NO_EXTERNAL_LOGINS
ARETURN(0) // used by some MUDs
#endif
// why here?
//while (remove_call_out(#'quit) != -1);
#ifndef REGISTERED_USERS_ONLY
if (IS_NEWBIE) ARETURN(1) // could auto-register here..
#endif
if (!try || try == "") ARETURN(0)
switch(method) {
#if __EFUN_DEFINED__(sha1)
case "SHA1":
case "sha1":
P3(("SHA1 given %O vs calculated %O\n",
try, sha1(salt + v("password"))));
rc = try == sha1(salt + v("password"));
ARETURN(rc)
#else
# echo Driver is missing SHA1 support (needed for jabber)
#endif
#if __EFUN_DEFINED__(md5)
case "MD5":
case "md5":
rc = try == md5(salt + v("password"));
ARETURN(rc)
case "http-digest": // see RFC 2617
unless(mappingp(args)) ARETURN(0)
// v("name") == args["username"] ???
HA1 = md5(args["_username"] + ":" + args["_realm"] + ":" + v("password"));
HA2 = md5(args["_method"] + ":" + args["_uri"]);
rc = try == md5(HA1 + ":" + salt + ":" + HA2);
ARETURN(rc)
// SASL digest-md5. fippo hotzenplotzt: digest-md5 ist ein sasl bastard
// den sogar die ietf abschaffen will
case "digest-md5":
// this assumes try set to 1 and args
// containing the sasl_parse'd response
// this will return the rspauth value if successful
t1 = sasl_calculate_digestMD5(args, v("password"), 0, v("prehash"));
P3(("sasl macht %O != %O\n", t1, args))
if (args["response"] == t1) {
rc = sasl_calculate_digestMD5(args, v("password"), 1, v("prehash"));
ARETURN(rc)
} else ARETURN(0)
#endif
default:
P4(("plain text pw %O == %O?\n", try, v("password")))
#ifdef PASSWORDCHECK
PASSWORDCHECK(v("password"), try)
#else
if (try == v("password")) ARETURN(1);
#endif
}
if (v("token") == try) {
// D("entry by token accepted once\n");
// vDel("token");
if (v("tokencredit") == v("email")) {
unless (v("emailvalidity")) {
// first time.. allocate mailaddr TODO
// for now we just save() into both files
}
vSet("emailvalidity", time());
}
vDel("tokencredit");
// save(); -- doesnt work here.. strange
ARETURN(1);
}
ARETURN(0);
}
/***
the stuff that follows used to be in user.c
***/
#ifndef _flag_disable_module_presence
static presence_management(source, mc, data, vars, profile, avail) {
int display = 1;
string t;
unless (avail)
avail = vars["_degree_availability"] || AVAILABILITY_HERE;
// don't display if we already know it .... optTODO
if (friends[source, FRIEND_AVAILABILITY] == avail) display = 0;
else if (v("presencefilter") == "all") display = 0;
P3(("pmgmt in %O from %O display %O filter %O\n", ME, source,
display, v("presencefilter")))
if (profile && profile[PPL_NOTIFY] >= PPL_NOTIFY_FRIEND) {
#if 0 //def ALIASES.. tobij.. what does this do?
// same code a few lines below
// and it is still not enough.. there are so many places
// where friends[] is accessed.. we need a more generic
// plan for handling aliases.. it's making me crazy. TODO
if (t = raliases[source])
friends[source, FRIEND_NICK] = t;
else if ((t = vars["_nick"]) && aliases[lower_case(t)])
friends[source, FRIEND_NICK] = 1;
else
#endif
t = vars["_nick"];
friends[source, FRIEND_NICK] = t || 1;
#ifdef IRC_FRIENDCHANNEL
vars["_degree_availability_old"] = friends[source, FRIEND_AVAILABILITY];
#endif
friends[source, FRIEND_AVAILABILITY] = avail;
#if 0 // alle freunde sind in unserem castmsg bereits drin, allein schon
// weil sie unsere freunde sind, und umgekehrt wir in ihrem.
// genau das wird in zeile 1666 etwa erledigt.
// ihre jeweilige derzeitige presence hat damit nichts zu tun -
// diese stelle ist so gesehen also redundant.
// gibt es gründe weswegen wir redundant sein sollten!??
// kann jemand während seiner abwesenheit aus unserer cast group
// gefallen sein, weil er nicht erreichbar war oder sowas?
// wenn sowas denkbar ist, dann wäre diese maßnahme zur
// rehabilitierung der person angemessen.. -lynX
//
// ausserdem verursachte das fiese bugs, weil unsachgemaess der nick
// herangezogen wurde statt der source
// add our friend to group/master, syncing..
if (t2 = parse_uniform(t)) {
insert_member(t, t2[URoot]); // outgoing presence
if (t2[UScheme] == "psyc")
register_context(ME, t, t2[URoot]); // incoming presence
} else
insert_member(summon_person(t) || t);
#endif
} else {
// let's look at this a bit more..
P1(("%O received %O from stranger (%O w/profile %O)\n",
ME, mc, source, profile))
display = 0;
}
return display;
}
#endif // _flag_disable_module_presence
// PSYC-conformant message receiving function
//
// this part of the standard message handler for people only
// handles stuff that doesnt get pr'inted..
//
// return value 1 means: go ahead and print something
// return value 0 means: ignore this silently
//
// BEWARE! the vars mapping is holy & untouchable!
// we never change it because we only use one instance in all of
// people's /log's to save a little memory and cpu, so be careful.
//
// i have added a #define VARS_IS_SACRED which may be defined for
// certain occasions but normally isn't. but you should still be careful.
//
msg(mixed source, mc, data, mapping vars, showingLog) {
int glyph, itsme = 0;
string k, display, profile, family;
mixed t, t2, psource;
// wrong to initialize here.. TODO
mixed rvars = ([ "_nick" : MYNICK ]); // replyvars
display = "";
#if DEBUG > 1
P3(("%O person:msg(%O,%O,%O..)\n", ME, source,mc,data))
unless (mappingp(vars)) raise_error("vars are no mapping\n");
#else
unless (mappingp(vars)) vars = ([]); // should never happen
#endif
// if (vars["_time"]) return 1; // logView() in action
if (showingLog) return display; // logView() in action
// btw, when reviewing log, all users are displayed equal size
#ifdef RELAY
remotesource = 0;
#endif
// person::msg() requires source to be non-zero and objectp for local
// objects. this has to be ensured before getting here, but it isn't.
// TODO!
#ifdef _flag_disable_module_trust
if (stringp(source)) {
#endif
#if 0
// has to be in user.c because of rplaces... hmm
if (vars["_context"] && !objectp(vars["_context"]) &&
!rplaces[vars["_context"]] &&
!abbrev("_notice_place", mc)) {
monitor_report("_warning_abuse_invalid_context",
S("Invalid context %O in %O apparently from %O",
vars["_context"], mc, source));
return 0;
}
#endif
psource = source;
//t = lookup_identification(source, vars["_identification"]);
// uni::msg finds the _identification for us
// psource then still contains the UNL while source has the UNI
// we sendmsg() to the UNI because uni::sendmsg will replace
// that with UNL
unless(::msg(&source, mc, data, vars)) return 0;
#ifndef _flag_disable_module_trust
if (stringp(source)) {
#endif
if (source == ME || ME == vars["_source_identification"]) itsme = 1;
// how did we get here with ppl undefined?
// oh we had an error earlier, that's why
else if (ppl) {
// entity.c handles _INTERNAL_identification for us
profile = ppl[source];
#ifdef RELAY
remotesource = vars && vars["_INTERNAL_identification"] ? vars["_INTERNAL_identification"] : source;
#endif
P3(("%O profile for %O = %O is %O\n",
ME, source, psource, profile))
#ifdef HOST_IGNORE
unless (profile) {
// check if this user ignores all users
// from a specific host, maybe cache the
// result?
}
#endif
}
P4(("%O got %O from %O. itsme: %O\n", ME, mc, source, itsme))
// here comes the psyc intelligence
PSYC_TRY(mc) {
#ifndef _flag_disable_module_authentication
case "_notice_processing_authentication":
P1(("asyncAUTH %O: %O is processing %O\n", ME, source, vars))
break;
case "_request_authentication":
case "_request_authenticate":
t = checkAuthentication(source, vars);
returnAuthentication(t, source, vars);
if (t) return 0;
// if automatic auth failed we display the request
// to the user so he can authenticate manually...
// but in fact he should have done /token first.
break;
#endif
case "_request_location":
// t == source if identification lookup didn't succeed?
unless (member(friends, t || source)) {
#if 0
if (vars["_service"]) {
if (services[vars["_service"]]) {
sendmsg(source, "_info_location_"
+ vars["_service"],
"[_service] has location "
"[_location].",
([
"_service" : vars["_service"],
"_location" : v("_source") + "/$"
+ vars["_service"],
]));
} else {
sendmsg(source, "_error_location_"
+ vars["_service"],
"No such service ([_service]).",
([
"_service" : vars["_service"]
]));
}
} else
#endif
{
sendmsg(source,
"_error_rejected_query_location", 0, ([]));
}
return 0;
}
if (vars["_service"] && member(v("locations"), vars["_service"])) {
// service
sendmsg(source, "_info_location_"+ vars["_service"],
"[_service] has location [_location].",
([
"_service" : vars["_service"],
"_tag" : vars["_tag"],
"_location" : v("locations")[vars["_service"]],
]));
} else
sendmsg(source, "_info_location", 0,
([
"_nick" : MYNICK,
"_tag" : vars["_tag"],
"_location" : v("locations")[0]
]));
return 0;
case "_request_link":
case "_set_password":
// TODO: shouldn't we use some kind of observer pattern on the
// current_interactive to become aware of disconnects?
// at least if the current interactive is not a server2server
// socket this is necessary
#ifdef ASYNC_AUTH
checkPassword(vars["_password"], vars["_method"], nonce, vars, (:
if ($1)
#else
if (checkPassword(vars["_password"], vars["_method"], nonce, vars))
#endif
{
string scheme;
mixed *u;
// TODO? add support for integer _service means multiple
// catch-all clients possible. do we want this?
if (vars["_service"]) {
// oh. we let it suggest a *different* location?
// interesting. why don't we also do this for clients?
// and who is using this code anyway?
linkDel(vars["_service"]);
linkSet(vars["_service"], vars["_location"], source);
return 0;
}
#if 0
if (vars["_password"]) {
#ifndef VOLATILE
// obviously similar code in usercmd:set()
if (!v("password") &&
(t = legal_password(vars["_password"],
MYNICK))) {
ME->pr(t[0], t[1]); // TODO
return;
}
// why do we check password here again
// if we are just after a checkPassword?
// what are we doing here?
#endif
} else if (ONLINE &&
v("locations")[0] != source) {
sendmsg(source,
"_error_status_person_connected");
return 0;
}
#else
// this code should also run for _service, but it
// needs a reorg
t = v("locations")[0];
if (t && t != source) {
// alright. we have another client
// already, or it is a ghost.
if (!vars["_password"] && ONLINE) {
// we are a newbie. reject the
// kick-out request.
sendmsg(source,
"_error_status_person_connected");
return 0;
}
// we are a legitimate new client.
// lets inform the old one
linkDel(0, t);
// now we leave the old client circuit
// to die off.. let's hope that's safe
}
#endif
#ifdef _flag_disable_module_trust
unless(stringp(source)) {
m_delete(v("locations"), 0);
return display;
}
#endif
scheme = v("scheme");
#if 1
// <el> in other cases this is done by
// morph. this may not be the very best
// solution, but until person/user is rewritten
// this is a fix for psyc-clients
// ...
// <lynX> in fact once there was a time when
// psyc clients could co-exist with one legacy
// client or access interface using that user.c
// no matter which one it was. i don't know why
// this no longer works, however i'd like doc
// this in case one day we can if 0 this again.
// .. or, as you correctly said, one day we
// detach UNI from client interface and allow
// all the protocols to coexist for each user
// unlimitedly .. it's on the TODO
//
// TODO: fippo - darum geht FORCE PLACE in
// die hose
// scheme != psyc
// allows two psyc clients to be logged in
// concurrently and is very suspicious
if (query_once_interactive(ME)
|| (scheme && scheme != "psyc")) {
// temporary fix for initially created psyc
// users. (they dont have a scheme)
object o;
save();
if (interactive(ME)) {
linkDel();
remove_interactive(ME);
}
o = named_clone(PSYC_PATH "user", MYNICK);
//o->sName(MYNICK);
// scheme is not set if a psyc/user is
// initially created...
o->vSet("scheme", "psyc");
o->msg(source, mc, data, vars);
return destruct(ME);
}
#endif
// used by _request_authentication
if (u = parse_uniform(source)) vSet("ip", u[UHost]);
// nicht wirklich logisch, unsere varnames!
if (t = vars["_version_agent"]
|| vars["_implementation"])
vSet("agent", t);
// in the protocol _nick at least determines
// the layout (case etc.) of the nick.
// if a client thinks he knows better than
// the identity, and sends _nick on
// _request_link, then the identity should
// accept that probably.
// there are discussions whether clients
// or the identity should determine the case,
// but _iff_ a client sends _nick, the identity
// must follow, imho. -- saga
t = vars["_nick"];
// das unwahrscheinlichste als erstes
// prüfen ist effizienter:
if (t && t != MYNICK
// redundant:
//&& !stricmp(v("name"), t)
// absichern und abstempeln:
&& lower_case(t) == MYLOWERNICK) {
if (::sName(t)) vSet("name", MYNICK);
}
// register location on IP address of source?
// no: psyc/parse should always produce the
// same source when the location speaks to us
// thus if there is a problem, the solution
// must be found elsewhere. also: registering
// the whole IP will produce uncontrollable
// side fx when several people come from the
// same firewall or NAT.
P2(("_request_link in %O: TI is %O, src is %O, vars is %O\n",
ME, this_interactive(), source, vars))
#if 0
ASSERT("origin == this_interactive",
vars["_INTERNAL_origin"] == this_interactive(), vars);
// language support for clients..
// done in w() instead.
vars["_INTERNAL_origin"]->sTextPath(v("layout"),
v("language"), scheme);
#endif
// yeah right..
//unless (interactive()) vSet("host", source);
linkSet(0, vars["_location"], source);
// moved logon after _notice_linked
// which is more appropriate for most clients
// lets see if theres any problem with that
logon(source);
// yes, there was:
// qFriends() is empty before logon, so
// we need to do this afterwards
// in http://about.psyc.eu/Client_coders kuchn states that this
// message is redundant anyway as we also have _list_friends_present.
#if 0 //ndef ASYNC_AUTH
// TODO THIS IS BROKEN DUE TO ASYNC AUTH!
// some closure expert should fix this
if (t = (mixed)qFriends()) sendmsg(source,
"_status_friends", 0,
([ "=_friends": t ]) ); // _tab
else sendmsg(source,
"_status_friends_none", 0, ([]));
#endif
return 0;
}
if (vars["_password"])
sendmsg(source,
"_error_invalid_password", 0,
([ "_nick": MYNICK ]));
else {
nonce = RANDHEXSTRING;
if (v("me")) sendmsg(source, "_info_description", 0,
([
"_nick" : MYNICK,
"_color" : v("color"),
"_description_action" : v("me"),
"_INTERNAL_tag_skip": 1,
#ifdef FORK
"=_action" : v("speakaction")
#else
"_action" : v("speakaction")
#endif
]) );
else sendmsg(source, "_info_nickname",
0, // "Hello [_nick].",
([
"_nick" : MYNICK,
"_color" : v("color"),
"_INTERNAL_tag_skip": 1,
#ifdef FORK
"=_action" : v("speakaction")
#else
"_action" : v("speakaction")
#endif
]) );
sendmsg(source, "_query_password", 0, ([
"_nick": MYNICK,
// see Handbook of applied cryptography p 397
"_nonce" : nonce,
// fippo thinks it is much more natural to show them here
#if 1
"_available_hashes": ""
#if __EFUN_DEFINED__(sha1)
"sha1;"
#endif
#if __EFUN_DEFINED__(md5)
"md5;http-digest;digest-md5"
#endif
#endif
]) );
}
#ifdef ASYNC_AUTH
return 0;
:)); // dont display, dont log, it is handled async
#endif
return 0;
// _request_do_exit currently logs out clients anyway
// don't use this:
case "_request_exit":
if (itsme && source == v("locations")[0]) {
linkDel(0, source);
quit();
return 0;
} else {
// report?
P0(("%O got invalid %O from %O\n",
ME, mc, source))
}
break;
case "_request_unlink_disconnect":
case "_request_unlink":
if (vars["_service"] &&
member(v("locations"), vars["_service"])) {
if (source == v("locations")[vars["_service"]]
|| checkPassword(vars["_password"])) {
linkDel(vars["_service"]);
return 0;
} else {
// report?
P0(("%O got invalid %O from %O for %O\n",
ME, mc, source, vars["_service"]))
}
} else if (member(v("locations"), 0)
&& source == v("locations")[0]) {
linkDel(0);
if (mc == "_request_unlink_disconnect" && !ONLINE) {
// manually calling disconnected() .. hmmm
disconnected();
}
} else {
// sendmsg(source, "_error_unavailable_function",
// "Who are you anyway?");
P0(("%O got invalid %O from %O. locations are %O. vars are %O.\n",
ME, mc, source, v("locations"), vars))
}
break;
case "_request_input":
if (itsme) {
// this should be renamed into _context but
// that cannot be done before _context is
// renamed into _channel .. hehe
if (stringp(t = vars["_focus"])) {
// check if the uniform is one of
// our places
if (places[t]) {
vSet("place", place = t);
} else {
// see if it is a local object
object o = psyc_object(t);
// object one of our places?
if (o && places[o]) {
place = o;
vSet("place", o->qName());
} else {
// must be a person then
ME->input(data, t);
// should be able to put o||t
// here.. TODO
return 0;
}
}
}
ME->input(data);
}
else sendmsg(source, "_error_rejected_input_person",
0, ([]));
// fall thru
case "_set_identification":
case "_assign_identification":
return 0; // skip
case "_message_echo_private":
#ifdef _flag_enable_measurement_network_latency
if (stringp(source) && vars["_time_sent"]
&& time() - vars["_time_sent"] > 3) {
P1(("Network latency from %s to %s was %O.\n",
MYNICK, source, time()-vars["_time_sent"]))
}
#endif
// fall thru
case "_message_echo_public":
case "_message_echo":
case "_message_public":
// avoid treating this as _message here
break;
case "_message":
// this is only visible in person.c, not user.c
// therefore probably useless
mc = "_message_private";
// fall thru
case "_message_private":
// this should get caught before even instantiating
// the user.. but that's not always easy
if (IS_NEWBIE && !ONLINE) {
P0(("sent a message to a user who is neither online nor newbie\n"))
sendmsg(source, "_error_unknown_name_user",
0,
([ "_nick_target" : MYNICK ]) );
// reset will destruct this.. no hurry
return 1;
}
break;
#if 0 //def PSYC_SYNCHRONIZE
//case "_notice_synchronize_set":
//case "_notice_synchronize":
// this abbrev actually might not work considering
// that incoming TCP doesn't come with the proper
// port number.. so we should be using trust here. TODO
if (!itsme && abbrev(PSYC_SYNCHRONIZE, source)) {
// it's not really me, but it does what i mean
itsme = 27;
}
#endif
#if 0 // did the same as the inheritance loop, but badly
default:
unless (sscanf(mc, "_request_do%s", t2))
break;
// fall thru
#endif
case "_request_do":
// extract the command from actual mc
if (mc != family) t2 = mc[strlen(family)..];
// fall thru
case "_request_execute":
if (itsme || vars["_INTERNAL_trust"] > 7) {
// this should be renamed into _context but
// that cannot be done before _context is
// renamed into _channel .. hehe
if (stringp(t = vars["_focus"]
|| vars["_group"])) {
// check if the uniform is one of
// our places
if (places[t]) {
vSet("place", place = t);
} else {
// see if it is a local object
object o = psyc_object(t);
// object one of our places?
if (o && places[o]) {
place = o;
vSet("place", o->qName());
} else unless (t2) {
// must be a person then
// ME->parsecmd(data, t);
parsecmd(data, t);
// should be able to put o||t
// here.. TODO
return 0;
}
}
}
// ME->parsecmd(data);
if (t2) {
unless (request(source, t2, vars, data)) {
sendmsg(source,
"_failure_unsupported_request",
0, ([]));
}
} else parsecmd(data);
}
// about time we provide some ctcp-like sth here.. ;)
else {
sendmsg(source,
"_failure_unsupported_execute_person",
0, ([ "_nick" : MYNICK ]) );
monitor_report("_warning"+ mc,
"Received unexpected "+ mc +" from "+
source);
}
return 0; // skip
case "_echo_place_leave":
case "_echo_place_enter_automatic_subscription":
case "_echo_place_enter_automatic":
case "_echo_place_enter":
case "_echo_place":
case "_echo":
case "_notice_presence_absent":
case "_notice_presence_away":
case "_notice_presence_here_busy":
case "_notice_presence_here":
case "_notice_presence":
case "_notice":
case "_request_description_vCard":
case "_request_description_time":
case "_request_description":
case "_request_list_feature":
case "_request_version":
case "_request_status_person":
case "_request_status":
case "_request":
case "_status_place_members":
case "_status_place":
case "_status_presence_away":
case "_status_presence_absent":
case "_status_presence_here_busy":
case "_status_presence_here":
case "_status_presence":
case "_status":
// optimization: reduce slicing here
break;
PSYC_SLICE_AND_REPEAT
}
}
else if (source == ME) itsme = 1;
else {
// this is the else of stringp, so we are an objectp here
if (stringp(vars["_nick"]))
profile = ppl[ lower_case(vars["_nick"]) ];
}
D4( unless (profile) PP(("%O nopro2 for %O from %O\n",
ME, vars["_nick"], source)); )
// {
// string service;
// if (sscanf(mc, "_request_link_%s", service)) {
//
// }
// }
if (profile) switch (profile[PPL_DISPLAY]) {
case PPL_DISPLAY_NONE: // ignore function
// vars["_display"] = "_none";
// TODO: implement /ignore <source> <mcmatch> ?
// or should we have a general setting for it
// as in /set ignoremethods _message;_notice_update_web
// so we don't have to figure out a place to define
// this per user? makes sense - since it only applies
// to those who have the /ignore flag set in their profile
// default ignore behaviour:
if (vars["_context"]) {
// filter public conversation even from a boss
if (abbrev("_message", mc) ||
// filter web updates and such from places
abbrev("_notice_update", mc))
return 0;
} else {
// filter private talk unless source is a boss
if (boss(source) < 60 &&
abbrev("_message", mc))
return 0;
// this does not send back echo, which is a way
// for the other side to know it is being ignored.
// we might have to change that! -lynX
}
break;
case PPL_DISPLAY_SMALL:
// vars["_display"] = "_reduce";
display = "_reduce";
break;
case PPL_DISPLAY_BIG:
// vars["_display"] = "_magnify";
display = "_magnify";
break;
}
/*
* syntax for _request_store:
*
* :_application_pypsyc_window_size 3000x2000
* :_application_pypsyc_skin darkstar
* :_character_command %
* _request_store
* .
*
* so whenever the client starts up it can connect
* the UNI and ask for its settings by issuing an
* empty _request_retrieve. one day we may specify
* subsets of the data pool.. using families i guess.
*/
PSYC_TRY(mc) {
case "_request_store":
if (itsme || vars["_INTERNAL_trust"] > 7) {
P1(("%O received %O, please migrate to _request_do\n",
ME, mc))
request(source, "_store", vars, data);
}
return 0; // or fall thru?
case "_request_retrieve":
if (itsme || vars["_INTERNAL_trust"] > 7) {
P1(("%O received %O, please migrate to _request_do\n",
ME, mc))
request(source, "_retrieve", vars, data);
}
return 0;
#if 0
case "_request_call_link":
// CALC_IDLE_TIME(t); unless (t)
if (itsme || (profile && profile[PPL_NOTIFY]
>= PPL_NOTIFY_FRIEND)) {
// this could be extended to actually have a
// confirmation from the user before replying (in a
// classic answer-call telephony paradigm). but the
// psyc way is to be more trusty of friends, which
// doesn't mean this can however be refined here, like..
// by checking how idle i am. then again.. since we
// are clicking on that user's psyced web access - he
// could use that to trigger opening of his own window,
// making this here unnecessary. ok. #if 0 this.
sendmsg(source, "_echo_call_link_automatic");
// http://about.psyc.eu/Telephony#Web-based_Telephony
}
//case "_request_call":
break;
#endif
case "_request_version":
P2(("Got a version request by %O\n", source))
if (v("agent") && (itsme || (profile && profile[PPL_NOTIFY]
>= PPL_NOTIFY_FRIEND))) {
sendmsg(source, "_status_version_agent",
0, ([
"_version_agent" : v("agent"),
"_version_description" : SERVER_DESCRIPTION,
"_version" : SERVER_VERSION,
"_nick" : MYNICK
]) );
return 0; // don't display.. it's a friend
} else sendmsg(source, "_status_version",
0, ([
"_version_description" : SERVER_DESCRIPTION,
"_version" : SERVER_VERSION,
"_nick" : MYNICK
]) );
return 0; // no, we don't send version requests end-2-end
// and we don't display version requests at all
// we should if the remote side request it.
// if I request a clients version, i want the remote
// client to answer, not the server making
// assumptions.
case "_request_examine": // don't use this, should be removed in 2009
case "_request_description":
case "_request_description_vCard":
t = qDescription(source, vars, profile || -1, itsme);
if (mappingp(t))
sendmsg(source, "_status_description_person", 0, t);
// else be quiet and do not reply
display = 0; // or should we display it for non-friends?
break;
case "_request_description_time":
unless(source && profile
&& profile[PPL_NOTIFY] != PPL_NOTIFY_NONE
&& profile[PPL_NOTIFY] != PPL_NOTIFY_OFFERED) {
return 0;
}
CALC_IDLE_TIME(t);
// dv["_time_idle"] = t;
sendmsg(source, "_status_description_time",
0, ([
"_nick" : MYNICK,
"_tag_reply" : vars["_tag"],
"_time_idle" : t ]) );
display = 0;
break;
case "_request_list_feature":
// TODO: wir muessen entscheiden, ob das an die uni
// oder die unl geht
if (IS_NEWBIE) rvars["_identity"] = "newbie";
#ifdef VISIBLE_SHERIFFS
// visible administratorship may be considered transparent
// thus friendly in some circumstances, but it has also
// led to vanity administratorships. current psyc policy
// is to keep this information private.
else if (boss(ME)) rvars["_identity" ] = "administrator";
#endif
else rvars["_identity"] = "person";
rvars["_name"] = v("longname") || MYNICK;
rvars["_list_feature"] = ({ "vCard", "list_feature" }); // _tab
sendmsg(source, "_notice_list_feature_person", 0, rvars);
display = 0;
break;
case "_request_list_item":
// jabber-only: should produce a /list of places
// (the subscriptions) so that the user can flag things
// for autojoin. that's okay for chatrooms, but inappropriate
// for newscasts. as you can tell, this is currently
// just a placebo anyway. FIXME
rvars["_list_item"] = ({ }); // _tab
rvars["_list_item_description"] = ({ }); // _tab
sendmsg(source, "_notice_list_item", 0, rvars);
display = 0;
break;
case "_request_ping":
sendmsg(source, "_echo_ping", 0, rvars);
display = 0;
break;
case "_notice_invitation":
// even if invitations are filtered, if the two are
// on the phone or something like that
// they can agree out of band to just "/follow" blindly
vSet("invitationplace", objectp(vars["_place"]) ?
vars["_nick_place"] : vars["_place"]);
// same filtering code as couple lines further below
if (( IS_NEWBIE || !itsme && FILTERED(source)) &&
(!profile || profile[PPL_NOTIFY] <= PPL_NOTIFY_PENDING)) {
sendmsg(source, "_failure_filter_strangers", 0,
([ "_nick" : MYNICK ]) );
unless (boss(source))
return 0; // dont display, dont log
}
break;
case "_message_private_question":
case "_message_private":
// same filtering code as couple lines above
if (( IS_NEWBIE || !itsme && FILTERED(source)) &&
(!profile || profile[PPL_NOTIFY] <= PPL_NOTIFY_PENDING)) {
PT(("_failure_filter_strangers to %O from %O\n", source, ME))
sendmsg(source, "_failure_filter_strangers", 0,
([ "_nick" : MYNICK ]) );
unless (boss(source))
return 0; // dont display, dont log
}
#ifndef LOCAL_ECHO
D3( D(data+" ... welcome to the remote echo feature.\n"); )
// dont know if i want to keep it this way, but it's a start..
# if 0 // def TAGGING
// echo tagging doesnt work yet
if (vars["_tag"])
// experimental _echo message with _tag_reply as provided
// by uni:sendmsg()
sendmsg(psource || source, "_echo"+ mc[8..], 0);
else
# else
# ifndef PRO_PATH
// why do we have psource here
// if sendmsg in entity.c is supposed
// to rewrite UNI into UNL??
sendmsg(psource || source, "_message_echo" + mc[8..], data, vars);
# else
sendmsg(psource || source, "_message_echo" + mc[8..], odata || data, vars);
# endif
# endif
// da muss die gegenseite selber dran denken:
//+ ([ "_nick_target" : MYNICK ]) );
#endif
#ifdef PSYC_SYNCHRONIZE
// huch, wieso privmsg weiterleiten? grübel
// vars["_source_relay"] = psource || source;
// sendmsg(PSYC_SYNCHRONIZE, "_message_relay" + mc[8 ..],
// data, vars);
// m_delete(vars, "_source_relay");
#endif
// remember last message sender
// i have the vague impression it doesn't work for clients!?
t = objectp(source)
? ((vars && vars["_nick"]) || "(?)")
: (source || psource);
if (t == v("reply")) break;
vSet("reply", t);
// generation of "away" message in irc-speak
#ifndef _flag_enable_unauthenticated_message_private
if (IS_NEWBIE) {
sendmsg(source, "_warning_unable_reply", 0,
([ "_nick": MYNICK ]));
// it is a litte noisy to send this every time
} else
#endif
if (profile && profile[PPL_NOTIFY] >= PPL_NOTIFY_FRIEND) {
if (ONLINE) {
// dies sendet die "redline" bei *jeder* privmsg und muss
// daher von den meisten user.c wieder gefiltert werden
// ausser der client hat sowas wie eine statuszeile.
// interpsyc und interjabber haben daran garantiert keine
// freude, daher objectp. für interpsyc könnte man sich
// überlegen dies ins _echo mit einzupflegen.. wär aber
// nicht richtig hübsch, nein. gewiss nicht.
if (objectp(source) && v("me"))
sendmsg(source, "_status_person_present",
"[_nick] [_action].", ([
"_nick": MYNICK,
"_action": v("me") ]) );
} else {
if (v("me")) {
sendmsg(source, "_status_person_absent_recorded",
0,
([ "_nick": MYNICK,
"_action": v("me") ]) );
}
else {
sendmsg(source, "_status_person_absent",
0,
([ "_nick": MYNICK ]) );
}
}
// } else {
// they already got echo
}
break;
#if 0
// causes recursions
case "_message_friends":
// sending message down the friendtree
if (vars["_depth"] != "0") {
//(int)vars["_depth"]--;
castmsg("_message_friends", data, vars);
}
break;
#endif
#ifndef _flag_disable_module_presence
// this one needs to be decided upon..
case "_request_notification_subscribe": // jaPSYC's Notification.java sollte
// nicht mehr verwendet werden, dafür gibt
// es Friends.java in jaPSYC. hier wird
// immerhin der begrüßungszustand hergestellt.
case "_request_status":
case "_request_status_person":
case "_request_presence":
if (itsme) return showMyPresence(1);
// hunting a mysterious bug.. ONLINE below crashes sometimes
// (for antagonist and cha0zz), and this should be the only
// logical reason why that can happen..
// according to trace we get here from sendmsg
// _notice_presence_here_quiet (which makes no sense either)
// and shortly before this is output:
//
// p-Show in S:xmpp:213.180.203.18:-38016, origin "xmpp:cha0zz@jabber.ru/Home", isstatus 0, vars ([ /* #1 */
// "_INTERNAL_identification": "xmpp:cha0zz@jabber.ru",
// "_nick": "cha0zz",
// "_source_identification": "xmpp:cha0zz@jabber.ru"
//])
if (!profile || profile[PPL_NOTIFY] == PPL_NOTIFY_NONE
|| profile[PPL_NOTIFY] == PPL_NOTIFY_OFFERED) {
// happens when friendships are async.. we already
// deal with this in _notice_presence so let's shut
// up here.. careful: jabber usually sends the query
// (this here) first and the presence notice after!
P2(("%O got %O from %O and ignored it.\n",
ME, mc, source))
return 0;
// ldmud 3.3.609 crashes with a completely absurd error
// after the 'return' statement. upgrade?
}
#if 1 // PARANOID ?
unless(mappingp(v("locations"))) {
// how the hell did i get here with a broken mapping?
monitor_report("_warning_abuse_invalid_friend",
S("Broken locations[] in %O (with %O from %O:%O)\n",
ME, mc, source, profile));
vSet("locations", ([]));
}
#endif
if (ONLINE) {
CALC_IDLE_TIME(t);
if (v("me")) sendmsg(source, "_status_person_" +
(stringp(availability) ? "away" : "present"),
"[_nick] [_action].", ([
"_nick": MYNICK,
"_time_idle" : t,
"_action": v("me") ]) );
else sendmsg(source,
"_status_person_present", "Present: [_nick].",
([ "_nick" : MYNICK, "_time_idle" : t ]) );
// both the _action and _offline trails are stupid choices
// to postpone the rename of the 'recorded' methods which
// obviously collide here
} else if (v("me"))
sendmsg(source, "_status_person_absent_action",
"[_nick] [_action].",
([ "_nick": MYNICK, "_action": v("me") ]) );
else sendmsg(source, "_status_person_absent_offline", 0,
([ "_nick" : MYNICK ]) );
if (v("presencefilter") == "none")
w("_notice_requested_status_person", 0, vars, source);
return 0; // skip
case "_notice_presence_here":
case "_notice_presence_here_busy":
if (objectp(source)) {
// remember last notification sender
vSet("greet", vars["_nick"]);
} else {
// should take into consideration host-trustfulness so
// we can let localhost perlscripts psycnotify us. TODO
unless (profile && profile[PPL_NOTIFY]
>= PPL_NOTIFY_MUTE) {
if (profile &&
profile[PPL_NOTIFY] == PPL_NOTIFY_OFFERED) {
// this happens when the other side is
// sending us presence and our user hasn't
// looked into '/show in' yet.
// let's pretty much ignore this.
P1(("%s got again notified by %O (%O)\n",
MYNICK, source, profile))
return 0;
} else if (profile &&
profile[PPL_NOTIFY] == PPL_NOTIFY_PENDING) {
// sometimes friendships end up being asynchronous.. then we get notifies
// even though we think our friendship is still pending from our side.
// this is certainly not worth yelling and screaming about. let's just
// log that this has occured and then correct our data.
log_file("NOTPENDING", "%O got %O from %O\n",
ME, mc, source);
profile[PPL_NOTIFY] = PPL_NOTIFY_DEFAULT;
// fall thru to greet and everything :)
} else {
// so far this has never happened for spam but
// always for async friendships (moving ids etc)
log_file("NOTOFFERED", "%O got %O from %O\n",
ME, mc, source);
// P1(("%s got notified unilaterally by %O (%O)\n",
// MYNICK, source, profile))
monitor_report("_warning_abuse_invalid_friend",
S("%s got notified unilaterally by %O (%O)",
MYNICK, source, profile));
// okay, the first time this happens we take
// a look at it. it just MIGHT be spam.
// after that we treat this as a friendship offer
// so that we don't get bombarded by the same
// reports over and over again.
//
// let's not intrude into people's lives as this
// would exactly be in the interest of a spammer
// but rather make the friendship available the
// next time the user goes into the '/show in' menu
sPerson(source, PPL_NOTIFY, PPL_NOTIFY_OFFERED);
return 0;
}
}
vSet("greet", source);
}
// currently just for xmpp:
// accept the notice without implying a presence reply.
if (!vars["_INTERNAL_quiet"] && ONLINE) {
P2(("%O got %O from %O.\n", ME, mc, source))
CALC_IDLE_TIME(t);
// TODO: update to current presence scheme..
// right now these messages appear when a person logs
// in - kind of impractical
if (v("me")) sendmsg(source, "_status_person_" +
(stringp(availability) ? "away" : "present"),
0, ([
"_nick": MYNICK,
"_time_idle" : t,
"_action": v("me") ]) );
else sendmsg(source,
"_status_person_present", 0,
([ "_nick" : MYNICK, "_time_idle" : t ]));
}
//if (member(friends, source)) display = 0;
unless (presence_management(source, mc, data, vars, profile))
display = 0;
P3(("post-pmgmt1 in %O from %O display %O logged_on %O\n", ME,
source, display, logged_on))
return logged_on && display;
#endif // _flag_disable_module_presence
#ifdef _flag_enable_alternate_location_forward
PSYC_SLICE_AND_REPEAT
}
// filtering needs to be done before forwarding to location.
// the PSYC_TRY methods above handle that. we used to have
// this part of code that seperates the first switch from
// the second and does forwarding. we currently do not forward
// messages from here though, we do it from w().
// the other solution would be to forward in user.c
// then we dont have to split the switches
t = v("locations")[0];
if (t && t != source) {
// no psyctext rendering happening in this variant
# ifdef _flag_enable_circuit_proxy_multiplexing
vars["_target_forward"] = t;
# endif
sendmsg(t, mc, data, vars, source);
lastmc = mc;
// net/user:msg shouldn't work on this any further,
// should it?
display = 0;
}
// here we can filter things that do not belong into the lastlog
// but shouldn't we simply log _message's only?
PSYC_TRY(mc) {
#endif
case "_notice_friendship_removed_implied":
case "_notice_friendship_removed":
case "_notice_context_leave": // future potential names of this function
case "_notice_context_leave_friends":
case "_request_context_leave":
case "_request_context_leave_friends":
if (profile && profile[PPL_NOTIFY] != PPL_NOTIFY_NONE) {
sPerson(source, PPL_NOTIFY, PPL_NOTIFY_NONE);
t = 1;
} else {
t = 0; // this person isn't *really* a friend of ours
}
// the redundancy of friends/members and the group/master
// data structures is driving me crazy
// especially as we have to make parse_uniform on every remove
m_delete(friends, source);
if (objectp(source)) // is_formal
remove_member(source);
else
remove_member(source, parse_uniform(source, 1)[URoot]);
// do not show people that weren't our friends
// do not reply with _removed_implied
// maybe we should even move this line before the m_delete?
unless (t) return 0;
showFriends();
// symmetric friendship removal unless we weren't friends already
sendmsg(source, "_notice_friendship_removed_implied", 0,
([ "_nick": MYNICK, "_possessive": "the" ]) );
break;
case "_notice_friendship_established":
if (!profile || profile[PPL_NOTIFY] != PPL_NOTIFY_OFFERED) {
PT(("%O shouldn't have gotten a %O from %O with PPL_NOTIFY %O (unless it's an acute case of jabber)\n",
ME, mc, source,
profile? profile[PPL_NOTIFY]: "(no profile)"))
return 0;
}
# ifndef _flag_disable_module_presence
// can we dare to make this a display-only event and
// rely on the new _request_friendship_implied for
// symmetric friendships? then we should be able to
// break; out of here.. TODO.. but for now let's just
// dont we lack some sPerson here?
if (ONLINE) {
CALC_IDLE_TIME(t);
if (v("me")) sendmsg(source, "_status_person_" +
(stringp(availability) ? "away" : "present"),
0, ([
"_nick": MYNICK,
"_time_idle" : t,
"_action": v("me") ]) );
else sendmsg(source,
"_status_person_present", 0,
([ "_nick" : MYNICK, "_time_idle" : t ]) );
}
# endif // _flag_disable_module_presence
return display;
// dont fall thru ...?
case "_status_friendship_established":
case "_request_context_enter": // future potential names of this function
case "_request_context_enter_friends":
case "_request_friendship":
case "_request_friendship_implied":
t = objectp(source) ? source->qName() : source;
// unless (t = vars["_nick"]) return 0;
PT(("%s in %O from %s(%O)\n", mc, ME, t, profile))
t2 = "_status_friendship_established";
data = "[_nick] is your friend already.";
if (profile) switch (profile[PPL_NOTIFY]) {
case PPL_NOTIFY_NONE:
// in this case, ask the user!
break;
case PPL_NOTIFY_OFFERED:
// ignore repeated offers..
return 0;
case PPL_NOTIFY_PENDING:
sPerson(t, PPL_NOTIFY, PPL_NOTIFY_DEFAULT);
t2 = "_notice_friendship_established";
data = "[_nick] is your friend now.";
//default: // might also work if it were placed here..
// but in all default cases the person should already be
// in the data structures below
#ifdef ALIASES
// same code a few lines above
if (t = raliases[source])
friends[source, FRIEND_NICK] = t;
else if ((t = vars["_nick"]) && aliases[lower_case(t)])
friends[source, FRIEND_NICK] = 1;
else
#endif
// nasty redundancy with group/master datastructures
friends[source, FRIEND_NICK] = vars["_nick"] || 1;
#ifdef AVAILABILITY_HERE
friends[source, FRIEND_AVAILABILITY] =
vars["_degree_availability"] || AVAILABILITY_HERE;
#endif
if (objectp(source))
insert_member(source);
else
insert_member(source, parse_uniform(source, 1)[URoot]);
showFriends();
// fall thru
// all other cases describe established friendships,
// but the other side may be confused or have lost its
// state, so we let it know once more
default:
// this stops loops of _status_friendship_established
// but maybe we should just never act on that mc
if (mc != t2) {
sendmsg(source, t2, data,
([ "_nick": MYNICK ]) );
// friendship with oneself..
// whatever it may be good 4
unless (itsme) {
w(t2, data, vars, source);
// special case for jabber once more..
// wenn das für jabber speziell ist
// kann man doch das format aufpeppen..
// dann müsste auch die methode _INTERNAL
// heissen und ich will nicht a priori
// ausschliessen, dass dies nochmal anderswo
// nützlich sein kann und ausserdem ist
// es sauberer so.
sendmsg(source,
"_status_person_present_implied", 0,
([ "_nick": MYNICK,
"_time_idle" : "0" ]) );
}
// why did we want to filter this?
// weil das zeug nervt.
//display = 0;
}
myLogAppend(source, mc, data, vars);
// display sollte hier gleich 0 sein wenn man
// schon mit der person befreundet ist...
return display;
}
sPerson(t, PPL_NOTIFY, PPL_NOTIFY_OFFERED);
myLogAppend(source, mc, data, vars);
if (IS_NEWBIE)
sendmsg(source, "_failure_necessary_registration", 0,
([ "_nick_target": MYNICK ]) );
return display;
#ifndef _flag_disable_module_presence
case "_status_person_absent":
case "_status_person_absent_recorded":
case "_status_person_absent_action":
case "_status_person_absent_offline":
case "_status_presence_absent_vacation":
case "_status_presence_absent":
case "_notice_presence_absent_vacation":
case "_notice_presence_absent":
if (!profile || profile[PPL_NOTIFY] == PPL_NOTIFY_NONE
|| profile[PPL_NOTIFY] == PPL_NOTIFY_OFFERED) {
P2(("%O got %O from %O and ignored it.\n",
ME, mc, source))
return 0;
}
P2(("%O got %O from %O.\n", ME, mc, source))
#ifdef IRC_FRIENDCHANNEL
vars["_degree_availability_old"] = friends[source, FRIEND_AVAILABILITY];
#endif
m_delete(friends, source); // in case he's a friend..
// if (v("greet") == source) vSet("greet", 0);
if (v("presencefilter") == "all") return 0;
#ifdef LASTAWAY
# ifdef PRO_PATH
// the webchat has a status line and likes to show info
// every time.. we could generalize this into a /set
// showawayonce (hello 1990)
unless (v("scheme") == "ht") { // copy from below
# endif
if (lastaway && lastaway["_description_presence"]
== vars["_description_presence"]
&& lastaway["_nick"] == vars["_nick"]) {
// we've seen this message already
return 0;
}
lastaway = vars;
# ifdef PRO_PATH
}
# endif
#endif
return ""; // dont apply display var; // display, but dont log
case "_notice_presence":
case "_status_presence":
P1(("TODO: family %O in mc %O with availability %O.\n",
family, mc, vars["_degree_availability"]))
break;
case "_notice_presence_away_manual":
t2 = "_manual";
case "_notice_presence_away_automatic":
unless (t2) t2 = "_automatic";
mc = "_notice_presence_away";
case "_status_person_away":
case "_status_presence_away":
case "_notice_presence_away":
if ((v("presencefilter") == "on" && t2 != "_manual") ||
((!v("presencefilter") || v("presencefilter") == "none")
&& t2 == "_automatic")) {
display = 0; // optTODO (move first check up)
}
#ifdef IRC_FRIENDCHANNEL
vars["_degree_availability_old"] = friends[source, FRIEND_AVAILABILITY];
#endif
t2 = vars["_degree_availability"] || AVAILABILITY_AWAY;
#ifdef LASTAWAY
# ifdef PRO_PATH
unless (v("scheme") == "ht") { // copy from above
# endif
// actually.. announce() doesn't retransmit the same
// messages.. so where could a double away come from..
// jabber?
if (lastaway && lastaway["_description_presence"]
== vars["_description_presence"]
&& lastaway["_nick"] == vars["_nick"]) {
// we've seen this message already
display = 0;
}
lastaway = vars;
# ifdef PRO_PATH
}
# endif
#endif
// fall thru
//case "_notice_presence_here_busy":
//case "_notice_presence_here":
case "_status_presence_here":
case "_status_presence_here_busy":
case "_status_person_present":
unless (presence_management(source, mc, data, vars,
profile, t2))
display = 0;
P3(("post-pmgmt2 in %O from %O display %O logged_on %O\n", ME,
source, display, logged_on))
return logged_on && display; // what about availability?
#endif // _flag_disable_module_presence
case "_notice_mail":
// on request by y0shi.. remember mail notifications
// even when offline
myLogAppend(source, mc, data, vars);
// fall thru
case "_notice_place_enter_automatic_subscription":
case "_notice_place_enter_automatic":
case "_notice_place_enter_login":
case "_notice_place_enter":
case "_notice_place_leave_logout":
case "_notice_place_leave":
case "_notice_place":
case "_notice_list_feature_server":
case "_notice_list_feature":
case "_notice_list_item":
case "_notice_list":
case "_notice":
// someone changed this to return display; without explanation
// so i change it back until an explanation is given.
// no voodoo hacking in the main psyc backbone!!
return ""; // dont apply display var;
case "_echo_place_leave":
case "_echo_place_enter_login":
case "_echo_place_enter_automatic_subscription":
case "_echo_place_enter_automatic":
case "_echo_place_enter":
case "_echo_place":
case "_echo":
case "_status_place_topic_official":
case "_status_place_topic":
case "_status_place_members":
case "_status_place":
case "_status":
// optimization: reduce slicing here
break;
PSYC_SLICE_AND_REPEAT
}
if (!vars["_time_place"]) {
if (abbrev("_message", mc)) {
// forward to v("id") from here
if (!ONLINE && v("id"))
sendmsg(v("id"), "_notice_forward"+mc, 0,
([ "_data_relay": data,
// gets overwritten if sender already provided one.. problem?
// do we ever get here for _message_public anyway?
"_source_relay": source,
]) + vars);
// one way to circumvent the object loss problem of
// ldmud persistence, the other is in user:w()
// if (objectp(vars["_context"]))
// vars["_context_uniform"] = psyc_name(vars["_context"]);
// and it is better because this one operates for each
// and every message whereas the other only does its job
// on /lastlog request
myLogAppend(source, mc, data, vars);
}
#if 0 //def JOBS
if (abbrev("_game", mc)) // is a job?
logAppend(source, mc, data, vars, _limit_amount_log, 0, 1);
#endif
}
D3( else D(S("not logged: %O\n", mc)); )
return display;
}
#ifndef _flag_disable_module_authentication
static returnAuthentication(result, source, vars) {
vars["_trust_result"] = result;
switch(result) {
case 1..9:
sendmsg(source, "_notice_authentication", 0, vars);
break;
case 0:
/* should this be an _echo or _warn? */
sendmsg(source, "_notice_processing_authentication", 0, vars);
P1(("asyncAUTH in %O for %O, %O\n", ME, source, vars))
break;
case -9..-1:
sendmsg(source, "_error_invalid_authentication", 0, vars);
break;
}
return result;
}
//
// result values are like trustworthy:
// 9 absolute trustworthy identity
// 6 this guy knows my token, good
// 4,5 this guy knows my UNL
// 3 my UNL after dns resolution
// 2 this guy knows my ip number
// 0 result delayed
// <0 errors
//
checkAuthentication(source, vars) {
string h, t;
P1(("%O got checkAuthentication from %O\n", ME, source))
if ((t = vars["_nonce"])) {
if (t == v("nonce")) {
vDel("nonce");
return 6;
}
return -1;
}
// a bit chaotic here.. the protocol needs a reorganization..
// does that even work in case of async auth???
// password auth is bad anyway
if (vars["_password"]) {
return checkPassword(vars["_password"], vars["_method"], nonce, vars,
symbol_function("returnAuthentication"), source, vars);
}
if (h = vars["_host_IP"]) {
if (h == v("ip") || h == query_ip_number(ME)) return 2;
}
if (vars["_location"] && v("locations")[0]) {
mixed *u;
// we should probably foreach this too TODO
if (v("locations")[0] == vars["_location"]) return 5;
// assumes v("locations")[X] is lower_case according to policy
if (v("locations")[0] == lower_case(vars["_location"]))
return 4;
unless (u = parse_uniform(vars["_location"])) return -1;
if (sscanf(u[UHost], "%~D.%~D.%~D.%~D") == 4) {
// why not check for equality of v("ip") and u[UHost]
dns_rresolve(u[UHost], (:
unless (stringp($1)) return;
register_host($4, $1);
return returnAuthentication(same_host($1, $5)
&& 3, $2, $3);
:), source, vars, u[UHost], v("ip"));
} else {
dns_resolve(u[UHost], (:
register_host($1, $4);
return returnAuthentication(same_host($4, $5)
&& 3, $2, $3);
:), source, vars, u[UHost], v("ip"));
}
return 0; // result delayed
}
return -1;
}
#endif
// with both HTTP and PSYC the user might be "online" even though the
// object isn't "interactive" (connected to a TCP stream).
#if 1
online(notnewbie) {
if (ONLINE) return 1;
if (notnewbie &&! IS_NEWBIE) return -1;
return 0;
}
#else
online() { return ONLINE; }
#endif
sName(a) {
P2(("%O(%O): sName(%O) from %O\n", ME, MYNICK,
a, previous_object()))
unless (a = sName2(a)) return ME;
ppl = v("people");
unless (ppl) {
ppl = ([ ]);
vSet("people", ppl);
}
//logInit();
if (v("log")) { logInit(v("log")); vDel("log"); }
else logInit();
// this line defeats the ability to find out when someone was
// online last.. so-called /seen.. as it clears the timestamp
// vSet("aliveTime", time()); // this doesnt make sense!?
return ME;
}
// this is not the logon function that gets called automatically.
// either the psyc server calls it for psyc users, or its called
// by the inheriting user object.
// argument should be the hostname or ip of the host
// the user is calling from (typically query_ip_name())
//
logon(host) {
#if 0
// PT(("pre rename: %O\n", ME))
// should i prefix it with a / ? maybe maybe
rename_object(ME, psycName());
// PT(("postrename: %O\n", ME))
#endif
#ifdef CACHE_PRESENCE
int s, amount = 0, ask4upd8s = 0;
mixed person;
string profile;
foreach(person, profile : ppl) {
#ifdef BRAIN
// user%host rauspatchen? ne doch lieber offline
#endif
// fippo thinks we should also show the presence of all
// our enemies. i don't agree with that policy. ;)
if (profile[PPL_NOTIFY] < PPL_NOTIFY_MUTE) continue;
amount++;
// not exactly efficient having to ask for each.
s = persistent_presence(person);
// also: we keep asking about local users so we have
// zero chance of coming with an ask4upd8s == 0
// should we make local users *always* reply to a _notice?
if (s == AVAILABILITY_UNKNOWN) {
ask4upd8s++;
} else if (s > AVAILABILITY_OFFLINE) { // was: just "else"
friends[person, FRIEND_NICK] = 1;
friends[person, FRIEND_AVAILABILITY] = s;
}
}
P2(("%O has %O friends of which %O have unknown state.\n",
ME, amount, ask4upd8s))
#endif
// greeting function disabled for psyc clients. they are
// auto-intelligent and they need the _notice_login
greeting = v("greeting") == "on" || v("scheme") == "psyc" ||
(!v("greeting") && (v("scheme") != "jabber" || IS_NEWBIE));
#ifndef _flag_disable_info_session
if (greeting && v("lastTime")) {
string hi, ctim;
# ifdef _flag_log_hosts
hi = v("host")==v("ip") ? v("ip") : v("host")+" ("+v("ip")+")";
# else
hi = "*";
# endif
ctim = ctime(v("lastTime"));
w("_notice_logon_last", 0,
([ "_date" : isotime(ctim, 0),
"_time" : hhmmss(ctim),
"_time_unix" : v("lastTime"),
"_host" : hi ])
);
# ifdef _flag_disable_notice_news_software
if (v("softnews") != SERVER_VERSION) {
w("_notice_news_software", 0,
([ "_version": SERVER_VERSION ]) );
vSet("softnews", SERVER_VERSION);
}
# endif
vDel("lastHost");
}
#endif
vSet("lastTime", time());
vSet("lastTime2", time());
vSet("aliveTime", time()); // a better place to update this
#ifdef _flag_log_hosts
if (host) vSet("host", host);
else
#endif
host = "?";
P2(("%O person:logon %s, logged_on = %O\n", ME,
IS_NEWBIE? "(newbie)": "(registered)",
logged_on ))
log_file("LOGON", "[%s] %s %s %s(%s) %s/%s/%s \"%s\"\n", ctime(),
logged_on ? "O" : IS_NEWBIE ? "*" : "+", MYNICK,
#ifdef _flag_log_hosts
query_ip_number() || v("ip") || "?",
#else
"?",
#endif
host,
v("layout") || "-", v("language") || "-",
v("scheme") || "-", v("agent") || "" );
unless (logged_on++) {
#ifdef PSYC_SYNCHRONIZE
// do not submit sign_on if a person has only done a quick
// reconnect
// thought 1: should have its one channel?
// thought 2: should log file be generated out of channel? no.. boh
synchro_report("_notice_synchronize_sign_on",
"[_nick] has logged in from [_host_name] using [_version_agent] over [_protocol_agent].", ([
"_nick": MYNICK, "_time_age": v("age"),
"_version_agent": v("agent") || "?",
"_protocol_agent": v("scheme") || "?",
"_host_name": host,
# ifdef _flag_log_hosts
"_host_IP": v("ip") || query_ip_number(),
# endif
]));
#endif
}
#ifdef SMART_UNICAST_FRIENDS
// join cslaves for our remote friends and build our
// data structure for group/master so we can use it for
// castmsg()
// bugs with notify / announce are most likely due to lack of sync
foreach (string ni, string mode : ppl) {
array(mixed) u;
mixed o;
// D(S("walkPeople(%O,%O,%O,%O)\n", ni, mode, o, level));
unless (mode && strlen(mode) > PPL_NOTIFY
// && mode[PPL_NOTIFY] != PPL_NOTIFY_NONE) continue;
&& mode[PPL_NOTIFY] >= PPL_NOTIFY_FRIEND) continue;
if (u = parse_uniform(ni)) {
// <lynX> first we change the ppl, then we need this code
// if (is_localhost(u[UHost])) {
// o = summon_person(u[UNick]);
// insert_member(o);
// } else {
o = ni;
insert_member(o, u[URoot]); // outgoing presence
// only psyc supports multicast presence
if (u[UScheme] == "psyc")
register_context(ME, o, u); // incoming presence
// }
} else {
o = summon_person(ni) || ni;
insert_member(o);
// <el> change the mapping?
// <lynX> no, if a change needs to be made to old .o data
// we should do it only once at load() time and simplify
// check by raising a version counter
}
}
P3(("smarticast distribution structure in %O: %O\n", ME, _routes))
#endif
#ifndef _flag_disable_module_presence
switch(v("scheme")) {
case "jabber":
case "psyc":
# ifdef _flag_enable_manual_announce_telnet
case "tn":
# endif
# ifdef _flag_enable_manual_announce_IRC
case "irc":
# endif
showMyPresence(1);
break;
default:
# ifdef CACHE_PRESENCE
announce(AVAILABILITY_HERE, 0, ask4upd8s == 0);
# else
announce(AVAILABILITY_HERE);
# endif
showMyPresence(0);
}
// showMyPresence(logged_on > 1);
#endif // _flag_disable_module_presence
if (v("new")) {
// TODO: displaying these messages seems to trigger a bug
// in net/jabber/user whereas the connection breaks, still
// receiving them is better than not.. huh?
w("_status_log_new", 0,
([ "_amount_new" : v("new") ]) );
logView(v("new"), 1);
vDel("new");
} else {
#ifndef _flag_disable_info_session
if (greeting &&! IS_NEWBIE)
w("_status_log_none");
#endif
}
nonce = 0;
vDel("nonce");
}
// called by obj/master at shutdown
reboot(reason, restart, pass) {
// clonep(): Objects with replaced programs no longer count as clones.
// so this doesn't work!!!! wicked wicked wicked bug!
//unless (clonep(ME)) return;
if (blueprint(ME) == ME) return;
P2(("%O shutting down\n", ME))
// temporary, please remove after 2009-04
if (!v("locations")) vSet("locations", ([]));
#if !defined(SLAVE) && !defined(_flag_disable_info_session)
if (ONLINE) {
// same in net/psyc/circuit.c
if (restart)
w("_warning_server_shutdown_temporary", 0,
([ "_reason": reason ]) );
else
w("_warning_server_shutdown", 0,
([ "_reason": reason ]) );
}
#endif
// availability = 0;
return quit(pass); // was: 2 for immediate landing
}
// called from usercmd.i ( /bye )
// called by server.c for scheme switch
//
// what do we do with those call_outs? here you go:
// x, y local users.
// R remote room.
// x and y are members of R.
// now x quits. y gets an _notice_place_leave w/ source x, context R, thus
// meaning he gets that _notice_leave from R, not x.
// if we'd destruct x immediately, object recognition cannot find x's object,
// so display will get fuckeredup. but we don't. we destruct after 20 seconds,
// which gives those _notice_leaves plenty of time for travelling through the
// whole internet, object recognition will find x's object, y will see nicely
// formatted output .. and not even care!
quit(immediate, variant) {
// keep an eye on the prototype right above checkPassword()
int rc;
P3(("person:QUIT(%O,%O) in %O\n", immediate,variant, ME))
// keeping services running while logging out should be possible.. but
//linkDel(0);
if (v("locations")) {
linkCleanUp();
// so the if should only trigger at first pass
vDel("locations");
}
if (immediate == 1 || (immediate && find_call_out(#'quit) != -1)) {
rc = save();
if (sizeof(places)) {
P2(("%O stayin' alive because of places %O"
" and corresponding permanent subscriptions %O\n",
ME, places, v("subscriptions")));
} else {
destruct(ME);
}
return rc;
}
if (leaving++) {
P1(("intercepted recursive QUIT %O\n", ME || MYNICK ))
return 0;
}
P4(("** QUITTING %O: av %O, sc %O\n", ME, availability, v("scheme")))
#ifndef _flag_disable_module_presence
switch(v("scheme")) {
case 0:
// scheme is 0 when a user entity has never been logged
// in, like friends in a roster that get incarnated
break;
// jabber/user:quit() is called on @type 'unavailable'
// so it relies on quit() to announce offline status
//case "jabber":
// break;
# ifdef _flag_enable_manual_announce_telnet
case "tn":
break;
# endif
# ifdef _flag_enable_manual_announce_IRC
case "irc":
break;
# endif
// psyc clients are supposed to explicitely set a user's presence
// status before exiting, if the user wishes so. only if they are
// not performing a clean exit, we will presume that an OFFLINE
// availability is appropriate. maybe a separate AVAILABILITY_LOST
// value would be nice. and we should have a delayed unavailability
// automation feature here to avoid frequent relogin announcements.
case "psyc":
if (variant != "_disconnect") {
P3(("++SKIP psyc client %O %O. announce yourself!\n",
variant, ME))
break;
}
// fall thru in case of _disconnect
// which indicates, we died an irregular death
default:
# ifdef ALPHA
if (availability > AVAILABILITY_OFFLINE) {
# if 0 //def CACHE_PRESENCE
announce(AVAILABILITY_OFFLINE, 0, ask4upd8s == 0);
# else
announce(AVAILABILITY_OFFLINE);
# endif
}
# else
if (availability) {
announce(AVAILABILITY_OFFLINE);
availability = 0;
}
# endif
}
#endif // _flag_disable_module_presence
// TODO: here we need to leave all our friends cslaves
if (v("lastTime2")) {
if (query_once_interactive(ME)) {
int delta = time() - v("lastTime2");
// we need to keep track of user's age for security
// reasons
vSet("age", delta + v("age"));
#ifndef _flag_disable_info_session
w("_notice_session_end", 0,
([ "_time_duration" : timedelta(delta) ]) );
#endif
}
vDel("lastTime2"); // don't keep this tmp copy
}
#if DEBUG > 0
rc = save();
#else
if (immediate) rc = save();
#endif
if (ME) { // in what situation are we !ME?
// well, sure, if the object is marked for destruction
// (by destruct(), of course). but when does that happen?
// no longer log non-interactive quits
// query_once_interactive(ME) doesn't work for psyc clients
if (logged_on) {
log_file("LOGON", "[%s] %s %s (%O) %O\n", ctime(),
IS_NEWBIE ?
(interactive(ME) ? "/" : "#") :
(interactive(ME) ? "-" : ">"), MYNICK, ME,
logged_on);
#ifdef PSYC_SYNCHRONIZE
synchro_report("_notice_synchronize_sign_off"
+ (variant || ""),
"[_nick] is logging out using [_version_agent].",
([ "_nick": MYNICK,
"_version_agent": v("agent") || "?" ]));
#endif
logged_on = 0;
}
if (immediate) {
destruct(ME);
} else {
vDel("scheme");
remove_interactive(ME);
leaving = 0;
call_out(#'quit, 20, 1, variant);
return rc;
}
} else {
// sometimes this stuff gets called when ME is already destroyed
log_file("LOGON", "[%s] $ %s\n", ctime(), MYNICK);
// no, apparently it never happens..
P1(("Logging out a destroyed %O.\n", MYNICK))
}
P3(("QUIT %O\n", ME || MYNICK ))
return rc;
}
save() {
int howmany;
if ( IS_NEWBIE || !MYNICK ) return 0;
howmany = logClip(2 * _limit_amount_log_persistent,
_limit_amount_log_persistent);
::save(PERSON_DATA_FILE(MYLOWERNICK));
return howmany;
}
#ifndef _flag_disable_module_presence
showMyPresence(verbose) {
if (v("presencetext"))
w("_status_presence_description",
"Your presence: [_description_presence]", ([
"_nick": MYNICK, //"_time_idle" : t,
"_degree_availability": availability,
"_degree_mood": mood,
"_description_presence": v("presencetext") ]));
else if (verbose || mood || availability != AVAILABILITY_HERE)
// doubtlessly needs a nicer message.. or none
w("_status_presence", 0, // "I know this sounds funny, but your availability degree is [_degree_availability] and your mood is [_degree_mood]."
([ "_nick": MYNICK, //"_time_idle" : t,
"_degree_availability": availability,
"_degree_mood": mood ]));
}
// more compliant to http://www.psyc.eu/presence these days
announce(level, manual, verbose, text) {
mapping vars;
int changed = 1;
if (text && strlen(text)) vSet("presencetext", text);
else {
if (v("presencetext")) vDel("presencetext");
else changed = 0;
text = v("me");
text = text ? (MYNICK +" "+ text +".") : "";
// fun: "Reclaim your chat. Use PSYC. PSYC delivers.";
}
if (!changed && availability == level) {
// this check ensures that we do not send "fake" announces
// for user entities which are being deallocated but
// were never actually logged in (absent friends of users)
// ... maybe this stops now that i added 'case 0:'
//
// we also get here when user objects are force quitted
// by keepUserObject() even if they were created just now
// ... see irc/server.. it's a FIXME
//
// unfortunately it seems to also affect other scenarios
P3(("++SKIP %O announce %O(%O,%O) %O changed: %d, av: %O\n",
ME, level, manual, verbose, text, changed, availability))
return 0;
}
if (level) vSet("availability", availability = level);
else level = availability; // sending EXPIRED not permitted here
P2(("%O announce %O(%O,%O) %O changed: %d, mood: %O\n", ME,
level, manual, verbose, text, changed, mood))
# if 0 //def CACHE_PRESENCE
// this define could also by dynamic to reflect whether we need a
// reply from the other side or not
// for now, we expect replies but cache nonetheless.
// this is a temporary test behaviour
# define _NOTICE_FRIEND_PRESENT \
(verbose? "_notice_presence_here": "_notice_presence_here_quiet")
# else
# define _NOTICE_FRIEND_PRESENT "_notice_presence_here"
# endif
# ifdef SMART_UNICAST_FRIENDS
vars = ([ "_nick": MYNICK,
"_source": v("_source"),
"_description_presence": text,
"_degree_availability": level ]);
if (mood) vars["_degree_mood"] = mood;
# ifdef JABBER_PATH
vars["_INTERNAL_mood_jabber"] = mood2jabber[mood];
# endif
# ifdef PSYC_SYNCHRONIZE
// 0 makes this message invisible when an admin is in the @sync
synchro_report("_notice_presence_synchronize", 0, vars);
# endif
// manual = manual? "_manual": "_automatic"; ?
// or just manual = manual? "": "_automatic"; ?
switch(level) {
case AVAILABILITY_AWAY:
castmsg(manual? "_notice_presence_away_manual":
"_notice_presence_away_automatic", 0, vars);
// "[_nick] is away. [_description_presence]", vars);
break;
default:
// ignoring manual here.. TODO
castmsg("_notice_presence"+ avail2mc[level], 0, vars);
break;
}
# else //{{{ SMART_UNICAST_FRIENDS
# echo Warning: person.c running without SMART_UNICAST_FRIENDS
# echo About time to delete this part of the code..
foreach (string ni, string mode : ppl) {
object o;
// D(S("walkPeople(%O,%O,%O,%O)\n", ni, mode, o, level));
unless (mode && strlen(mode) > PPL_NOTIFY
&& mode[PPL_NOTIFY] != PPL_NOTIFY_NONE) continue;
if( o = find_person(ni) ) {
unless( o->online() ) {
m_delete(friends, o);
continue;
}
}
else if (is_formal(ni)) {
o = ni; // remote buddy
} else {
continue; // offline local buddy
}
P3(("%O announce(%O): %O for %O (%O)\n", ME, level, o, ni,
mode[PPL_NOTIFY]))
switch(level) {
case AVAILABILITY_OFFLINE:
if (friends[o, FRIEND_NICK])
sendmsg(o, "_notice_presence_absent", 0,
([ "_nick": MYNICK ]) );
continue;
case AVAILABILITY_HERE:
switch (mode[PPL_NOTIFY]) {
case PPL_NOTIFY_IMMEDIATE:
sendmsg(o, _NOTICE_FRIEND_PRESENT, 0,
([ "_nick": MYNICK ]) );
break;
case PPL_NOTIFY_DELAYED:
call_out(symbol_function("sendmsg"),
TIME_DELAY_NOTIFY,
o, _NOTICE_FRIEND_PRESENT, 0,
([ "_nick": MYNICK ]) );
break;
case PPL_NOTIFY_DELAYED_MORE:
call_out(symbol_function("sendmsg"),
2 * TIME_DELAY_NOTIFY,
o, _NOTICE_FRIEND_PRESENT, 0,
([ "_nick": MYNICK ]) );
// fall thru
case PPL_NOTIFY_MUTE:
break;
default:
// not the most efficient way to
// skip pends+offers TODO
continue;
}
if (objectp(o)) friends[o, FRIEND_NICK] = ni || 1; // to be removed one day..?
// TODO: the most correct way would be to expect a _status_person_present
}
}
# endif //}}} SMART_UNICAST_FRIENDS
#ifndef _flag_disable_module_presence
if (verbose) showMyPresence(1);
#endif
return ++logged_on; // might aswell use it as an announcement counter ;)
}
#endif // _flag_disable_module_presence
static qFriends() {
int i;
string present;
array(mixed) k;
mixed o, n;
P2(("%O's qFriends inbound » %O «\n", ME, friends))
k = m_indices(friends);
unless(k) return;
present = "";
for(i=sizeof(k); i;) {
o = k[--i];
if (objectp(o)) { // a local user
// present += o -> psycName();
n = friends[o, FRIEND_NICK];
unless(stringp(n)) friends[o, FRIEND_NICK] = n = o->qName();
present += " ~"+ lower_case(n);
} else if (stringp(o)) {
present += " "+ o; // a psyc: uni
}
}
if (strlen(present) < 3) return D3("~lynx");
P2(("qFriends outbound » %s «\n", present[1..]))
return present[1..];
}
sPerson(person, ix, value) {
P2(("%O: sPerson(%O, %O, %O) bfor: %O\n", MYNICK, person, ix, value, ppl))
// TODO: we need some register_context / deregister_context here
if (objectp(person)) person = person->qNameLower();
else person = lower_case(person); // both nicks and UNIs. very good.
unless( ppl[person] ) {
ppl[person] = " ";
}
ppl[person][ix] = value;
if (ppl[person] == " ") {
m_delete(ppl, person);
// save();
// return 2;
}
save();
#ifdef PSYC_SYNCHRONIZE
unless (synchronize_contact(MYNICK, person, ix, value)) {
P1(("broken synchronize_contact for %O %O %O %O\n",
MYNICK, person, ix, value))
}
#endif
P2(("%O: sPerson(%O, %O, %O) afta: %O\n", MYNICK, person, ix, value, ppl))
return 1;
}
htinfo(prot, query, headers, qs) {
string me;
P3(("htinfo(%O, %O, %O, %O)\n", prot, query, headers, qs))
#ifdef EXPERIMENTAL
// this extension is disputed and not in use
// we should probably do net/http/register instead..
if (member(query, "register")) {
unless (IS_NEWBIE) {
me = "This user is already registered by someone else.";
} else {
string password = query["register"];
// checkVar is stupid function. where does the w() go??? he? something not helpy helpy!
if (checkVar("password", password)) {
me = "Hoooray, you registered yourself to something else which is somehow yourself. gaga.";
vSet("password", password);
} else {
me = "this is not okay password!";
}
}
} else
#endif
htok(prot);
if (member(query, "motto")) {
// intended for little (i)frames: just one line
// showing nickname and motto message.
me = v("publicpage") ? "<a href=\""+ v("publicpage")
+"\" target=x>"+ MYNICK +"</a>" : MYNICK;
if (v("me")) me += " "+ htquote(v("me"));
write( ( // T("_HTML_status_head",
"<title>/~"+ MYNICK +"</title>\n\
<body bgcolor=#000000 text=#cccccc link=#ffffff vlink=#999999>\n\
<center><font face=helvetica>") +"["+ me + "]\n");
} else {
P3(("anonymous profile inspection in %O with %O and %O\n",
ME, query, headers))
w("_notice_examine_web_person", 0, ([
"_web_on": headers["referer"] || headers["host"],
"_web_from": headers["user-agent"]
|| query_ip_name(this_interactive()) || "",
"_nick" : MYNICK,
]) );
write( htDescription(1, query, headers, qs, "_anonymous",
qDescription(0, ([ "_trust": 0 ]), -1, 0)) );
}
return 1;
}
qNameLong() { return v("coolname") || v("longname") || MYNICK; }
void reset(int again) {
P2((" [~ %O] ", ME))
// clonep(): Objects with replaced programs no longer count as clones.
// so this doesn't work!!!! wicked wicked wicked bug!
//unless (clonep(ME)) return;
if (blueprint(ME) == ME) return;
// name::reset(again); storage::reset(again);
if (again) {
if (ONLINE) {
P4(("RESET: saving %O\n", ME))
save();
#if 0
} else {
P3(("RESET: quitting %O\n", ME))
if (find_call_out(#'quit) == -1) quit();
#endif
}
} else { // hmm.. why do we still use reset(0) for this?
mixed o;
P2(("CREATE: %O\n", ME))
vInit();
#ifdef ALIASES
vSet("aliases", ([]));
aliases = ([]);
raliases = ([]);
#endif
vSet("locations", ([]));
friends = m_allocate(0, 2);
leaving = 0;
#ifndef _flag_disable_module_presence
avail2mc = shared_memory("avail2mc");
# ifdef JABBER_PATH
mood2jabber = shared_memory("mood2jabber");
# endif
#endif // _flag_disable_module_presence
// _tags = ([ ]); -- shouldnt be here
}
}
void create() {
P2((" {~ %O} ", ME))
::create();
return reset(0);
}
#if 1 //ndef XMPPERIMENTAL
// does this really apply to person only, or should
// it go into group/master? apparently places don't need this..
// but why does person need it?
//
insert_member(source, route) {
P4(("%O insert_member(%O, %O)\n", ME, source, route))
if (stringp(source)
&& !abbrev("psyc:", source)
// && !abbrev("xmpp:", source)
) {
P2(("%O person:insert_member(%O, %O) removing route\n",
ME, source, route))
route = 0;
}
::insert_member(source, route);
}
remove_member(source, route) {
if (stringp(source)
&& !abbrev("psyc:", source)
// && !abbrev("xmpp:", source)
) route = 0;
::remove_member(source, route);
}
#endif
castmsg(mc, data, vars) {
vars["_nick"] = MYNICK;
return ::castmsg(ME, mc, data, vars);
}
Reference in a new issue View git blame Copy permalink