conference_user.c

AnyQ服务端源代码(2004/10/28)源码

    if(j_strlen(room->description) > 0)
    {
        message = jutil_msgnew("groupchat", jid_full(jid_fix(user->realid)), NULL, room->description);
	xmlnode_put_attrib(message,"from", jid_full(jid_fix(room->id)));
	deliver(dpacket_new(message), NULL);
    }

    /* Send Room protocol message to legacy clients */
    if(is_legacy(user))
    {
        message = jutil_msgnew("groupchat", jid_full(jid_fix(user->realid)), NULL, spools(user->p, "This room supports the MUC protocol.", user->p));
	xmlnode_put_attrib(message,"from", jid_full(jid_fix(room->id)));
//	deliver(dpacket_new(message), NULL);
    }

    /* Send Room Lock warning if necessary */
    if(room->locked > 0)
    {
        message = jutil_msgnew("groupchat", jid_full(jid_fix(user->realid)), NULL, spools(user->p, "This room is locked from entry until configuration is confirmed.", user->p));
	xmlnode_put_attrib(message,"from", jid_full(jid_fix(room->id)));
//	deliver(dpacket_new(message), NULL);
    }

    /* Update my roster with current users */
    htb_walk(&room->local, _con_user_enter, (void*)user);

    /* Switch to queue mode */
    //deliver__flag = 0;

    /* loop through history and send back */
    if(room->master->history == 0)
    {
        return;
    }

    h = room->hlast;
    while(1)
    {
        h++;

        if(h == room->master->history)
            h = 0;

        _con_user_history_send(user, xmlnode_dup(room->history[h]));

        if(xmlnode_get_tag(room->history[h],"subject") != NULL)
            tflag = 1;

        if(h == room->hlast)
            break;
    }

    /* Re-enable delivery */
    //deliver__flag = 1;
    /* Send queued messages */
    deliver(NULL, NULL);

    /* send last know topic */
    if(tflag == 0 && room->topic != NULL)
    {
        node = jutil_msgnew("groupchat", jid_full(jid_fix(user->realid)), xmlnode_get_attrib(room->topic,"subject"), xmlnode_get_data(room->topic));
        xmlnode_put_attrib(node, "from", jid_full(jid_fix(room->id)));
        deliver(dpacket_new(node), NULL);
    }

    /* send entrance notice if available */
    if(room->note_join != NULL && j_strlen(room->note_join) > 0)
        con_room_send(room, jutil_msgnew("groupchat", NULL, NULL, spools(user->p, nick, " ", room->note_join, user->p)), SEND_LEGACY);

    /* Send 'non-anonymous' message if necessary */
    if(room->visible == 1)
        con_send_alert(user, NULL, NULL, STATUS_MUC_SHOWN_JID);
}

void con_user_process(cnu to, cnu from, jpacket jp)
{
    xmlnode node, element;
    cnr room = to->room;
    char str[10];
    int t;

    /* we handle all iq's for this id, it's *our* id */
    if(jp->type == JPACKET_IQ)
    {
        if(NSCHECK(jp->iq,NS_BROWSE))
        {
            jutil_iqresult(jp->x);
            node = xmlnode_insert_tag(jp->x, "item");

            xmlnode_put_attrib(node, "category", "user");
            xmlnode_put_attrib(node, "xmlns", NS_BROWSE);
            xmlnode_put_attrib(node, "name", xmlnode_get_data(to->nick));

            element = xmlnode_insert_tag(node, "item");
            xmlnode_put_attrib(element, "category", "user");

            if(room->visible == 1 || is_moderator(room, from->realid))
                xmlnode_put_attrib(element, "jid", jid_full(jid_fix(to->realid)));
	    else
                xmlnode_put_attrib(element, "jid", jid_full(jid_fix(to->localid)));
	   
	    if(is_legacy(to))
                xmlnode_insert_cdata(xmlnode_insert_tag(node, "ns"), NS_GROUPCHAT, -1);
	    else
                xmlnode_insert_cdata(xmlnode_insert_tag(node, "ns"), NS_MUC, -1);

            deliver(dpacket_new(jp->x), NULL);
            return;
        }

        if(NSCHECK(jp->iq,NS_LAST))
        {
            jutil_iqresult(jp->x);

            node = xmlnode_insert_tag(jp->x, "query");
            xmlnode_put_attrib(node, "xmlns", NS_LAST);

            t = time(NULL) - to->last;
            sprintf(str,"%d",t);

            xmlnode_put_attrib(node ,"seconds", str);

            deliver(dpacket_new(jp->x), NULL);
            return;
        }

        /* deny any other iq's if it's private */
        if(to->private == 1)
        {
            jutil_error(jp->x, TERROR_FORBIDDEN);
            deliver(dpacket_new(jp->x), NULL);
            return;
        }

        /* if not, fall through and just forward em on I guess! */
    }

    /* Block possibly faked groupchat messages - groupchat is not meant for p2p chats */
    if(jp->type == JPACKET_MESSAGE)
    {
        if(jp->subtype == JPACKET__GROUPCHAT)
	{
	    jutil_error(jp->x, TERROR_BAD);
	    deliver(dpacket_new(jp->x), NULL);
	    return;
	}

	if(room->privmsg == 1 && !is_admin(room, from->realid))
	{
	    /* Only error on messages with body, otherwise just drop */
	    if(xmlnode_get_tag(jp->x, "body") != NULL)
            {	
	        jutil_error(jp->x, TERROR_MUC_PRIVMSG);
	        deliver(dpacket_new(jp->x), NULL);
	        return;
	    }
	    else
	    {
		xmlnode_free(jp->x);
		return;
	    }
	}
	
    }

    con_user_send(to, from, jp->x);
}

void con_user_send(cnu to, cnu from, xmlnode node)
{
    jid fullid;

    if(to == NULL || from == NULL || node == NULL)
    {
        return;
    }

    fullid = jid_new(xmlnode_pool(node), jid_full(jid_fix(from->localid)));
    xmlnode_put_attrib(node, "to", jid_full(jid_fix(to->realid)));

    if(xmlnode_get_attrib(node, "cnu") != NULL)
        xmlnode_hide_attrib(node, "cnu");

    jid_set(fullid, xmlnode_get_data(from->nick), JID_RESOURCE);

    xmlnode_put_attrib(node, "from", jid_full(jid_fix(fullid)));
    deliver(dpacket_new(node), NULL);
}

void con_user_zap(cnu user, xmlnode data)
{
    cnr room;
    char *reason;
    char *status;
    char *key;

    if(user == NULL)
    {
        xmlnode_free(data);
        return;
    }
    
    user->leaving = 1;

    key = pstrdup(user->p, jid_full(jid_fix(user->realid)));

    status = xmlnode_get_attrib(data, "status");
    reason = xmlnode_get_data(data);

    room = user->room;

    if(room == NULL)
    {
	log_debug(NAME, "[%s] Unable to zap user %s <%s-%s> : Room does not exist", FZONE, jid_full(jid_fix(user->realid)), status, reason);
        xmlnode_free(data);
        return;
    }
    
    log_debug(NAME, "[%s] zapping user %s <%s-%s>", FZONE, jid_full(jid_fix(user->realid)), status, reason);

    if(user->localid != NULL)
    {
        con_user_nick(user, NULL, data); /* sends unavailve */
        htb_zap(&room->local, user->localid->resource);
        room->count--;

        /* send departure notice if available*/
	if(room->note_leave != NULL && j_strlen(room->note_leave) > 0)
	{
	    if(reason != NULL)
            {
		if(j_strcmp(status, STATUS_MUC_KICKED) == 0)
		{
	            con_room_send(room,jutil_msgnew("groupchat",NULL,NULL,spools(user->p, xmlnode_get_attrib(user->nick,"old")," ",room->note_leave,": [Kicked] ", reason, user->p)), SEND_LEGACY);
	        }
		else if(j_strcmp(status, STATUS_MUC_BANNED) == 0)
		{
	            con_room_send(room,jutil_msgnew("groupchat",NULL,NULL,spools(user->p,xmlnode_get_attrib(user->nick,"old")," ",room->note_leave,": [Banned] ", reason, user->p)), SEND_LEGACY);
		}
	        else
	        {
	            con_room_send(room,jutil_msgnew("groupchat",NULL,NULL,spools(user->p,xmlnode_get_attrib(user->nick,"old")," ",room->note_leave,": ", reason, user->p)), SEND_LEGACY);
		}
	    }
            else 
	    {
	        con_room_send(room,jutil_msgnew("groupchat",NULL,NULL,spools(user->p,xmlnode_get_attrib(user->nick,"old")," ",room->note_leave,user->p)), SEND_LEGACY);
	    }
	}
    }

    xmlnode_free(data);

    remove_affiliate(room->admin, user->realid);
    remove_affiliate(room->member, user->realid);

    revoke_role(room->moderator, user);
    revoke_role(room->participant, user);

    remove_roster(room, user->realid);

    htb_zap(&room->remote, jid_full(jid_fix(user->realid)));

    xmlnode_free(user->presence);
    xmlnode_free(user->nick);
    pool_free(user->p);
}