]> jfr.im git - irc/rqf/shadowircd.git/blobdiff - src/client.c
presence: send..._with_capability...(): don't send if the client does not have the...
[irc/rqf/shadowircd.git] / src / client.c
index dd3ae34d0347d5b18c570263e2c7b4f237c952f4..5cee85867cb2f6074de948a072bbcb8324ececdf 100644 (file)
@@ -76,7 +76,7 @@ static rb_bh *client_heap = NULL;
 static rb_bh *lclient_heap = NULL;
 static rb_bh *pclient_heap = NULL;
 static rb_bh *user_heap = NULL;
-static rb_bh *away_heap = NULL;
+static rb_bh *metadata_heap = NULL;
 static char current_uid[IDLEN];
 
 struct Dictionary *nd_dict = NULL;
@@ -120,7 +120,7 @@ init_client(void)
        lclient_heap = rb_bh_create(sizeof(struct LocalUser), LCLIENT_HEAP_SIZE, "lclient_heap");
        pclient_heap = rb_bh_create(sizeof(struct PreClient), PCLIENT_HEAP_SIZE, "pclient_heap");
        user_heap = rb_bh_create(sizeof(struct User), USER_HEAP_SIZE, "user_heap");
-       away_heap = rb_bh_create(AWAYLEN, AWAY_HEAP_SIZE, "away_heap");
+       metadata_heap = rb_bh_create(sizeof(struct MetadataEntry), USER_HEAP_SIZE, "metadata_heap");
 
        rb_event_addish("check_pings", check_pings, NULL, 30);
        rb_event_addish("free_exited_clients", &free_exited_clients, NULL, 4);
@@ -235,8 +235,14 @@ free_local_client(struct Client *client_p)
        rb_free(client_p->localClient->fullcaps);
        rb_free(client_p->localClient->opername);
        rb_free(client_p->localClient->mangledhost);
+       if (client_p->localClient->privset)
+               privilegeset_unref(client_p->localClient->privset);
 
-       ssld_decrement_clicount(client_p->localClient->ssl_ctl);
+       if(IsSSL(client_p))
+           ssld_decrement_clicount(client_p->localClient->ssl_ctl);
+           
+       if(IsCapable(client_p, CAP_ZIP))
+           ssld_decrement_clicount(client_p->localClient->z_ctl);
 
        rb_bh_free(lclient_heap, client_p->localClient);
        client_p->localClient = NULL;
@@ -323,7 +329,7 @@ check_pings_list(rb_dlink_list * list)
                                {
                                        sendto_realops_snomask(SNO_GENERAL, L_ALL,
                                                             "No response from %s, closing link",
-                                                            get_server_name(client_p, HIDE_IP));
+                                                            client_p->name);
                                        ilog(L_SERVER,
                                             "No response from %s, closing link",
                                             log_client_name(client_p, HIDE_IP));
@@ -391,7 +397,7 @@ check_unknowns_list(rb_dlink_list * list)
                        {
                                sendto_realops_snomask(SNO_GENERAL, is_remote_connect(client_p) ? L_NETWIDE : L_ALL,
                                                     "No response from %s, closing link",
-                                                    get_server_name(client_p, HIDE_IP));
+                                                    client_p->name);
                                ilog(L_SERVER,
                                     "No response from %s, closing link",
                                     log_client_name(client_p, HIDE_IP));
@@ -441,84 +447,9 @@ notify_banned_client(struct Client *client_p, struct ConfItem *aconf, int ban)
 void
 check_banned_lines(void)
 {
-       struct Client *client_p;        /* current local client_p being examined */
-       struct ConfItem *aconf = NULL;
-       rb_dlink_node *ptr, *next_ptr;
-
-       RB_DLINK_FOREACH_SAFE(ptr, next_ptr, lclient_list.head)
-       {
-               client_p = ptr->data;
-
-               if(IsMe(client_p))
-                       continue;
-
-               /* if there is a returned struct ConfItem then kill it */
-               if((aconf = find_dline((struct sockaddr *)&client_p->localClient->ip, client_p->localClient->ip.ss_family)))
-               {
-                       if(aconf->status & CONF_EXEMPTDLINE)
-                               continue;
-
-                       sendto_realops_snomask(SNO_GENERAL, L_ALL,
-                                            "DLINE active for %s",
-                                            get_client_name(client_p, HIDE_IP));
-
-                       notify_banned_client(client_p, aconf, D_LINED);
-                       continue;       /* and go examine next fd/client_p */
-               }
-
-               if(!IsPerson(client_p))
-                       continue;
-
-               if((aconf = find_kline(client_p)) != NULL)
-               {
-                       if(IsExemptKline(client_p))
-                       {
-                               sendto_realops_snomask(SNO_GENERAL, L_ALL,
-                                               "KLINE over-ruled for %s, client is kline_exempt [%s@%s]",
-                                               get_client_name(client_p, HIDE_IP),
-                                               aconf->user, aconf->host);
-                               continue;
-                       }
-
-                       sendto_realops_snomask(SNO_GENERAL, L_ALL,
-                                       "KLINE active for %s",
-                                       get_client_name(client_p, HIDE_IP));
-                       notify_banned_client(client_p, aconf, K_LINED);
-                       continue;
-               }
-               else if((aconf = find_xline(client_p->info, 1)) != NULL)
-               {
-                       if(IsExemptKline(client_p))
-                       {
-                               sendto_realops_snomask(SNO_GENERAL, L_ALL,
-                                               "XLINE over-ruled for %s, client is kline_exempt [%s]",
-                                               get_client_name(client_p, HIDE_IP),
-                                               aconf->name);
-                               continue;
-                       }
-
-                       sendto_realops_snomask(SNO_GENERAL, L_ALL, "XLINE active for %s",
-                                       get_client_name(client_p, HIDE_IP));
-
-                       (void) exit_client(client_p, client_p, &me, "Bad user info");
-                       continue;
-               }
-       }
-
-       /* also check the unknowns list for new dlines */
-       RB_DLINK_FOREACH_SAFE(ptr, next_ptr, unknown_list.head)
-       {
-               client_p = ptr->data;
-
-               if((aconf = find_dline((struct sockaddr *)&client_p->localClient->ip,client_p->localClient->ip.ss_family)))
-               {
-                       if(aconf->status & CONF_EXEMPTDLINE)
-                               continue;
-
-                       notify_banned_client(client_p, aconf, D_LINED);
-               }
-       }
-
+       check_dlines();
+       check_klines();
+       check_xlines();
 }
 
 /* check_klines_event()
@@ -560,8 +491,9 @@ check_klines(void)
                        if(IsExemptKline(client_p))
                        {
                                sendto_realops_snomask(SNO_GENERAL, L_ALL,
-                                                    "KLINE over-ruled for %s, client is kline_exempt",
-                                                    get_client_name(client_p, HIDE_IP));
+                                                    "KLINE over-ruled for %s, client is kline_exempt [%s@%s]",
+                                                    get_client_name(client_p, HIDE_IP),
+                                                    aconf->user, aconf->host);
                                continue;
                        }
 
@@ -651,8 +583,9 @@ check_xlines(void)
                        if(IsExemptKline(client_p))
                        {
                                sendto_realops_snomask(SNO_GENERAL, L_ALL,
-                                                    "XLINE over-ruled for %s, client is kline_exempt",
-                                                    get_client_name(client_p, HIDE_IP));
+                                                    "XLINE over-ruled for %s, client is kline_exempt [%s]",
+                                                    get_client_name(client_p, HIDE_IP),
+                                                    aconf->name);
                                continue;
                        }
 
@@ -850,10 +783,8 @@ get_client_name(struct Client *client, int showip)
                if(ConfigFileEntry.hide_spoof_ips && 
                   showip == SHOW_IP && IsIPSpoof(client))
                        showip = MASK_IP;
-#ifdef HIDE_SERVERS_IPS
                if(IsAnyServer(client))
                        showip = MASK_IP;
-#endif
 
                /* And finally, let's get the host information, ip or name */
                switch (showip)
@@ -879,49 +810,6 @@ get_client_name(struct Client *client, int showip)
         */
        return client->name;
 }
-
-const char *
-get_server_name(struct Client *target_p, int showip)
-{
-       static char nbuf[HOSTLEN * 2 + USERLEN + 5];
-
-       if(target_p == NULL)
-               return NULL;
-
-       if(!MyConnect(target_p) || !irccmp(target_p->name, target_p->host))
-               return target_p->name;
-
-#ifdef HIDE_SERVERS_IPS
-       if(EmptyString(target_p->name))
-       {
-               rb_snprintf(nbuf, sizeof(nbuf), "[%s@255.255.255.255]",
-                               target_p->username);
-               return nbuf;
-       }
-       else
-               return target_p->name;
-#endif
-
-       switch (showip)
-       {
-               case SHOW_IP:
-                       rb_snprintf(nbuf, sizeof(nbuf), "%s[%s@%s]",
-                               target_p->name, target_p->username, 
-                               target_p->sockhost);
-                       break;
-
-               case MASK_IP:
-                       rb_snprintf(nbuf, sizeof(nbuf), "%s[%s@255.255.255.255]",
-                               target_p->name, target_p->username);
-
-               default:
-                       rb_snprintf(nbuf, sizeof(nbuf), "%s[%s@%s]",
-                               target_p->name, target_p->username,
-                               target_p->host);
-       }
-
-       return nbuf;
-}
        
 /* log_client_name()
  *
@@ -1200,7 +1088,7 @@ exit_aborted_clients(void *unused)
                if(IsAnyServer(abt->client))
                        sendto_realops_snomask(SNO_GENERAL, L_ALL,
                                             "Closing link to %s: %s",
-                                            get_server_name(abt->client, HIDE_IP), abt->notice);
+                                             abt->client->name, abt->notice);
 
                /* its no longer on abort list - we *must* remove
                 * FLAGS_CLOSING otherwise exit_client() will not run --fl
@@ -1325,7 +1213,6 @@ exit_unknown_client(struct Client *client_p, struct Client *source_p, struct Cli
                delete_resolver_queries(source_p->localClient->dnsquery);
                rb_free(source_p->localClient->dnsquery);
        }
-       del_unknown_ip(source_p);
        rb_dlinkDelete(&source_p->localClient->tnode, &unknown_list);
 
        if(!IsIOError(source_p))
@@ -1407,15 +1294,12 @@ static int
 qs_server(struct Client *client_p, struct Client *source_p, struct Client *from, 
                  const char *comment)
 {
-       struct Client *target_p;
-
        if(source_p->servptr && source_p->servptr->serv)
                rb_dlinkDelete(&source_p->lnode, &source_p->servptr->serv->servers);
        else
                s_assert(0);
 
        rb_dlinkFindDestroy(source_p, &global_serv_list);
-       target_p = source_p->from;
        
        if(has_id(source_p))
                del_from_id_hash(source_p->id, source_p);
@@ -1533,10 +1417,11 @@ exit_local_client(struct Client *client_p, struct Client *source_p, struct Clien
 
        on_for = rb_current_time() - source_p->localClient->firsttime;
 
-       ilog(L_USER, "%s (%3lu:%02lu:%02lu): %s!%s@%s %d/%d",
+       ilog(L_USER, "%s (%3lu:%02lu:%02lu): %s!%s@%s %s %d/%d",
                rb_ctime(rb_current_time(), tbuf, sizeof(tbuf)), on_for / 3600,
                (on_for % 3600) / 60, on_for % 60,
                source_p->name, source_p->username, source_p->host,
+               source_p->sockhost,
                source_p->localClient->sendK, source_p->localClient->receiveK);
 
        sendto_one(source_p, "ERROR :Closing Link: %s (%s)", source_p->host, comment);
@@ -1722,10 +1607,6 @@ show_ip(struct Client *source_p, struct Client *target_p)
 {
        if(IsAnyServer(target_p))
        {
-#ifndef HIDE_SERVERS_IPS
-               if(source_p == NULL || IsOper(source_p))
-                       return 1;
-#endif
                return 0;
        }
        else if(IsIPSpoof(target_p))
@@ -1776,8 +1657,10 @@ make_user(struct Client *client_p)
        {
                user = (struct User *) rb_bh_alloc(user_heap);
                user->refcnt = 1;
+               user->metadata = irc_dictionary_create(irccmp);
                client_p->user = user;
        }
+
        return user;
 }
 
@@ -1814,12 +1697,8 @@ make_server(struct Client *client_p)
 void
 free_user(struct User *user, struct Client *client_p)
 {
-       free_away(client_p);
-
        if(--user->refcnt <= 0)
        {
-               if(user->away)
-                       rb_free((char *) user->away);
                /*
                 * sanity check
                 */
@@ -1846,21 +1725,56 @@ free_user(struct User *user, struct Client *client_p)
        }
 }
 
-void
-allocate_away(struct Client *client_p)
+const char *
+get_metadata(struct Client *client_p, const char *key)
 {
-       if(client_p->user->away == NULL)
-               client_p->user->away = rb_bh_alloc(away_heap);  
+       struct MetadataEntry *md;
+
+       if (client_p->user != NULL)
+       {
+               md = irc_dictionary_retrieve(client_p->user->metadata, key);
+               if (md == NULL)
+                       return NULL;
+
+               return md->value;
+       }
+
+       return NULL;
 }
 
+void
+set_metadata(struct Client *client_p, const char *key, const char *value)
+{
+       struct MetadataEntry *md;
+
+       delete_metadata(client_p, key);
+       if(client_p->user != NULL)
+       {
+               md = rb_bh_alloc(metadata_heap);
+               rb_strlcpy(md->key, key, NICKLEN);
+               rb_strlcpy(md->value, value, TOPICLEN);
+
+               irc_dictionary_add(client_p->user->metadata, md->key, md);
+       }
+
+       sendto_common_channels_local_with_capability(client_p, CLICAP_PRESENCE, form_str(RPL_METADATACHG), me.name, client_p->name, key, value);
+}
 
 void
-free_away(struct Client *client_p)
+delete_metadata(struct Client *client_p, const char *key)
 {
-       if(client_p->user != NULL && client_p->user->away != NULL) {
-               rb_bh_free(away_heap, client_p->user->away);
-               client_p->user->away = NULL;
+       struct MetadataEntry *md;
+
+       if(client_p->user != NULL)
+       {
+               md = irc_dictionary_delete(client_p->user->metadata, key);
+               if (md == NULL)
+                       return;
+
+               rb_bh_free(metadata_heap, md);
        }
+
+       sendto_common_channels_local_with_capability(client_p, CLICAP_PRESENCE, form_str(RPL_METADATACHG), me.name, client_p->name, key, "");
 }
 
 void
@@ -1934,7 +1848,7 @@ close_connection(struct Client *client_p)
                ServerStats.is_sv++;
                ServerStats.is_sbs += client_p->localClient->sendB;
                ServerStats.is_sbr += client_p->localClient->receiveB;
-               ServerStats.is_sti += rb_current_time() - client_p->localClient->firsttime;
+               ServerStats.is_sti += (unsigned long long)(rb_current_time() - client_p->localClient->firsttime);
 
                /*
                 * If the connection has been up for a long amount of time, schedule
@@ -1960,7 +1874,7 @@ close_connection(struct Client *client_p)
                ServerStats.is_cl++;
                ServerStats.is_cbs += client_p->localClient->sendB;
                ServerStats.is_cbr += client_p->localClient->receiveB;
-               ServerStats.is_cti += rb_current_time() - client_p->localClient->firsttime;
+               ServerStats.is_cti += (unsigned long long)(rb_current_time() - client_p->localClient->firsttime);
        }
        else
                ServerStats.is_ni++;
@@ -2013,7 +1927,7 @@ error_exit_client(struct Client *client_p, int error)
                {
                        sendto_realops_snomask(SNO_GENERAL, is_remote_connect(client_p) && !IsServer(client_p) ? L_NETWIDE : L_ALL,
                                             "Server %s closed the connection",
-                                            get_server_name(client_p, SHOW_IP));
+                                            client_p->name);
 
                        ilog(L_SERVER, "Server %s closed the connection",
                             log_client_name(client_p, SHOW_IP));