2 * Dolda Connect - Modular multiuser Direct Connect-style client
3 * Copyright (C) 2004 Fredrik Tolf <fredrik@dolda2000.com>
5 * This program is free software; you can redistribute it and/or modify
6 * it under the terms of the GNU General Public License as published by
7 * the Free Software Foundation; either version 2 of the License, or
8 * (at your option) any later version.
10 * This program is distributed in the hope that it will be useful,
11 * but WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13 * GNU General Public License for more details.
15 * You should have received a copy of the GNU General Public License
16 * along with this program; if not, write to the Free Software
17 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
21 #include <sys/socket.h>
33 static void freepeer(struct fnetpeer *peer);
35 static struct fnet *networks = NULL;
36 struct fnetnode *fnetnodes = NULL;
38 GCBCHAIN(newfncb, struct fnetnode *);
40 static struct fnetnode *newfn(struct fnet *fnet)
45 new = smalloc(sizeof(*new));
46 memset(new, 0, sizeof(*new));
50 new->mynick = swcsdup(confgetstr("cli", "defnick"));
51 new->srchwait = confgetint("fnet", "srchwait");
53 CBCHAININIT(new, fnetnode_ac);
54 CBCHAININIT(new, fnetnode_chat);
55 CBCHAININIT(new, fnetnode_unlink);
56 CBCHAININIT(new, fnetnode_destroy);
57 CBCHAININIT(new, fnetpeer_new);
58 CBCHAININIT(new, fnetpeer_del);
59 CBCHAININIT(new, fnetpeer_chdi);
66 void killfnetnode(struct fnetnode *fn)
68 fnetsetstate(fn, FNN_DEAD);
73 void getfnetnode(struct fnetnode *fn)
77 fprintf(stderr, "getfnetnode on id %i at %p, refcount=%i\n", fn->id, fn, fn->refcount);
81 static void freepeers(struct btree *n)
91 void putfnetnode(struct fnetnode *fn)
96 fprintf(stderr, "putfnetnode on id %i at %p, refcount=%i\n", fn->id, fn, fn->refcount - 1);
100 for(cur = fnetnodes; cur != NULL; cur = cur->next)
103 flog(LOG_CRIT, "BUG: fnetnode reached refcount 0 while still in list - id %i", fn->id);
105 CBCHAINDOCB(fn, fnetnode_destroy, fn);
106 CBCHAINFREE(fn, fnetnode_ac);
107 CBCHAINFREE(fn, fnetnode_chat);
108 CBCHAINFREE(fn, fnetnode_unlink);
109 CBCHAINFREE(fn, fnetnode_destroy);
110 CBCHAINFREE(fn, fnetpeer_new);
111 CBCHAINFREE(fn, fnetpeer_del);
112 CBCHAINFREE(fn, fnetpeer_chdi);
113 if((fn->fnet->destroy != NULL) && fn->connected)
114 fn->fnet->destroy(fn);
115 while(fn->args != NULL)
116 freewcspair(fn->args, &fn->args);
117 freepeers(fn->peers);
118 if(fn->mynick != NULL)
120 if(fn->pubid != NULL)
124 if(fn->owner != NULL)
130 struct fnetnode *findfnetnode(int id)
134 for(fn = fnetnodes; (fn != NULL) && (fn->id != id); fn = fn->next);
138 void linkfnetnode(struct fnetnode *fn)
143 fn->next = fnetnodes;
144 if(fnetnodes != NULL)
145 fnetnodes->prev = fn;
148 GCBCHAINDOCB(newfncb, fn);
151 void unlinkfnetnode(struct fnetnode *fn)
156 fnetnodes = fn->next;
158 fn->next->prev = fn->prev;
160 fn->prev->next = fn->next;
162 CBCHAINDOCB(fn, fnetnode_unlink, fn);
166 static void conncb(struct socket *sk, int err, struct fnetnode *data)
174 fnetsetstate(data, FNN_HS);
175 socksettos(sk, confgetint("fnet", "fntos"));
176 data->fnet->connect(data, sk);
181 static void resolvecb(struct sockaddr *addr, int addrlen, struct fnetnode *data)
188 putsock(netcsconn(addr, addrlen, (void (*)(struct socket *, int, void *))conncb, data));
192 static struct fnetpeerdatum *finddatum(struct fnetnode *fn, wchar_t *id)
194 struct fnetpeerdatum *datum;
196 for(datum = fn->peerdata; datum != NULL; datum = datum->next)
198 if(!wcscmp(datum->id, id))
204 static struct fnetpeerdatum *adddatum(struct fnetnode *fn, wchar_t *id, int datatype)
206 struct fnetpeerdatum *new;
208 new = smalloc(sizeof(*new));
210 new->id = swcsdup(id);
211 new->datatype = datatype;
213 new->next = fn->peerdata;
214 if(fn->peerdata != NULL)
215 fn->peerdata->prev = new;
220 static struct fnetpeerdi *difindoradd(struct fnetpeer *peer, struct fnetpeerdatum *datum, int *isnew)
224 for(i = 0; i < peer->dinum; i++)
226 if(peer->peerdi[i].datum == datum)
231 peer->peerdi = srealloc(peer->peerdi, sizeof(struct fnetpeerdi) * (peer->dinum + 1));
232 memset(&peer->peerdi[peer->dinum], 0, sizeof(struct fnetpeerdi));
233 peer->peerdi[peer->dinum].datum = datum;
237 return(&peer->peerdi[peer->dinum++]);
241 return(&peer->peerdi[i]);
245 void fnetpeersetstr(struct fnetpeer *peer, wchar_t *id, wchar_t *value)
247 struct fnetpeerdatum *datum;
248 struct fnetpeerdi *di;
251 if((datum = finddatum(peer->fn, id)) == NULL)
252 datum = adddatum(peer->fn, id, FNPD_STR);
253 di = difindoradd(peer, datum, &changed);
254 if(di->data.str != NULL) {
255 changed = (changed || wcscmp(value, di->data.str));
260 di->data.str = swcsdup(value);
262 CBCHAINDOCB(peer->fn, fnetpeer_chdi, peer->fn, peer, di);
265 void fnetpeersetnum(struct fnetpeer *peer, wchar_t *id, int value)
267 struct fnetpeerdatum *datum;
268 struct fnetpeerdi *di;
271 if((datum = finddatum(peer->fn, id)) == NULL)
272 datum = adddatum(peer->fn, id, FNPD_INT);
273 di = difindoradd(peer, datum, &changed);
274 changed = (changed || (di->data.num != value));
275 di->data.num = value;
277 CBCHAINDOCB(peer->fn, fnetpeer_chdi, peer->fn, peer, di);
280 void fnetpeersetlnum(struct fnetpeer *peer, wchar_t *id, long long value)
282 struct fnetpeerdatum *datum;
283 struct fnetpeerdi *di;
286 if((datum = finddatum(peer->fn, id)) == NULL)
287 datum = adddatum(peer->fn, id, FNPD_LL);
288 di = difindoradd(peer, datum, &changed);
289 changed = (changed || (di->data.lnum != value));
290 di->data.lnum = value;
292 CBCHAINDOCB(peer->fn, fnetpeer_chdi, peer->fn, peer, di);
295 static void putdatum(struct fnetpeer *peer, struct fnetpeerdatum *datum)
297 if(--datum->refcount > 0)
299 if(datum->next != NULL)
300 datum->next->prev = datum->prev;
301 if(datum->prev != NULL)
302 datum->prev->next = datum->next;
303 if(datum == peer->fn->peerdata)
304 peer->fn->peerdata = datum->next;
309 void fnetpeerunset(struct fnetpeer *peer, wchar_t *id)
312 struct fnetpeerdatum *datum;
314 if((datum = finddatum(peer->fn, id)) == NULL)
316 for(i = 0; i < peer->dinum; i++)
318 if(peer->peerdi[i].datum == datum)
323 if((datum->datatype == FNPD_STR) && (peer->peerdi[i].data.str != NULL))
324 free(peer->peerdi[i].data.str);
326 memmove(&peer->peerdi[i], &peer->peerdi[i + 1], sizeof(struct fnetpeerdi) * (peer->dinum - i));
327 putdatum(peer, datum);
330 static int peercmpid(void *a, void *b)
332 return(wcscmp(((struct fnetpeer *)a)->id, ((struct fnetpeer *)b)->id));
335 struct fnetpeer *fnetaddpeer(struct fnetnode *fn, wchar_t *id, wchar_t *nick)
337 struct fnetpeer *new;
339 new = smalloc(sizeof(*new));
341 new->id = swcsdup(id);
342 new->nick = swcsdup(nick);
346 bbtreeput(&fn->peers, new, peercmpid);
348 CBCHAINDOCB(fn, fnetnode_ac, fn, L"numpeers");
349 CBCHAINDOCB(fn, fnetpeer_new, fn, new);
353 static void freepeer(struct fnetpeer *peer)
357 peer->fn->numpeers--;
360 for(i = 0; i < peer->dinum; i++)
362 if((peer->peerdi[i].datum->datatype == FNPD_STR) && (peer->peerdi[i].data.str != NULL))
363 free(peer->peerdi[i].data.str);
364 putdatum(peer, peer->peerdi[i].datum);
366 if(peer->peerdi != NULL)
371 void fnetdelpeer(struct fnetpeer *peer)
373 bbtreedel(&peer->fn->peers, peer, peercmpid);
374 CBCHAINDOCB(peer->fn, fnetnode_ac, peer->fn, L"numpeers");
375 CBCHAINDOCB(peer->fn, fnetpeer_del, peer->fn, peer);
379 void fnetpeerdm(struct fnetnode *fn)
382 struct fnetpeer *peer;
387 for(peer = btreeiter(fn->peers); peer != NULL; peer = btreeiter(NULL)) {
388 if(!peer->flags.b.delete) {
389 bbtreeput(&new, peer, peercmpid);
392 CBCHAINDOCB(peer->fn, fnetpeer_del, peer->fn, peer);
396 btreefree(fn->peers);
399 CBCHAINDOCB(peer->fn, fnetnode_ac, peer->fn, L"numpeers");
402 struct fnetpeer *fnetfindpeer(struct fnetnode *fn, wchar_t *id)
407 return(btreeget(fn->peers, &key, peercmpid));
410 int fnetsetnick(struct fnetnode *fn, wchar_t *newnick)
414 if((fn->fnet->setnick != NULL) && fn->connected)
415 ret = fn->fnet->setnick(fn, newnick);
420 if(fn->mynick != NULL)
422 fn->mynick = swcsdup(newnick);
427 int fnetsendchat(struct fnetnode *fn, int public, wchar_t *to, wchar_t *string)
429 if((fn->fnet->sendchat == NULL) || !fn->connected)
434 return(fn->fnet->sendchat(fn, public, to, string));
437 int fnetsearch(struct fnetnode *fn, struct search *srch, struct srchfnnlist *ln)
439 if(fn->fnet->search == NULL)
444 return(fn->fnet->search(fn, srch, ln));
447 void fnetsetname(struct fnetnode *fn, wchar_t *newname)
451 fn->name = swcsdup(newname);
452 CBCHAINDOCB(fn, fnetnode_ac, fn, L"name");
455 void fnetsetstate(struct fnetnode *fn, int newstate)
457 fn->state = newstate;
458 CBCHAINDOCB(fn, fnetnode_ac, fn, L"state");
461 wchar_t *fnfilebasename(wchar_t *path)
465 if((p = wcsrchr(path, L'/')) != NULL)
470 struct fnet *findfnet(wchar_t *name)
474 for(fnet = networks; fnet != NULL; fnet = fnet->next)
476 if(!wcscmp(name, fnet->name))
482 struct fnetnode *fnetinitconnect(wchar_t *name, wchar_t *owner, char *addr, struct wcspair *args)
488 if((fnet = findfnet(name)) == NULL)
490 errno = EPROTONOSUPPORT;
494 fn->owner = swcsdup(owner);
495 fn->pubid = icmbstowcs(addr, NULL);
496 if(fn->pubid == NULL)
497 fn->pubid = swcsdup(L"");
499 for(arg = fn->args; arg != NULL; arg = arg->next)
501 if(!wcscmp(arg->key, L"nick"))
502 fnetsetnick(fn, arg->val);
505 if(netresolve(addr, (void (*)(struct sockaddr *, int, void *))resolvecb, fn) < 0)
510 void regfnet(struct fnet *fnet)
512 fnet->next = networks;
517 * Note on the chat string: Must be in UNIX text file format - that
518 * is, LF line endings. The filenet-specific code must see to it that
519 * any other kind of format is converted into that. In the future,
520 * certain control characters and escape sequences will be parsed by
521 * the client. Make sure that any filenet-specific code strips any
522 * such that aren't supposed to be in the protocol.
524 * Note on "name": This is supposed to be an identifier for the
525 * source. If the chat is a public message, set "public" to non-zero
526 * and "name" to whatever "chat room" name is appropriate for the
527 * fnetnode, but not NULL. If there is a "default" channel in this
528 * filenet, set "name" to the empty string. If the chat is a private
529 * message, name is ignored.
531 void fnethandlechat(struct fnetnode *fn, int public, wchar_t *name, wchar_t *peer, wchar_t *chat)
533 CBCHAINDOCB(fn, fnetnode_chat, fn, public, name, peer, chat);
536 static struct configvar myvars[] =
538 /** The number of seconds to wait between searches. Most hubs
539 * require at least ten seconds, and quite often network lag will
540 * often make searches arrive to the hub more often than sent. It
541 * may be semi-dangerous to specify too low a value, since hubs
542 * will often kick users that search too often (even when the
543 * reason is network lag -- there is no way for the hub to know
544 * this), but it is quite annoying to set too high a value. 15 to
545 * 40 seconds are the recommended range (although the default is
546 * 15 seconds, it is recommended to set to 30 seconds). */
547 {CONF_VAR_INT, "srchwait", {.num = 15}},
548 /** The TOS value to use for hub connections (see the TOS VALUES
550 {CONF_VAR_INT, "fntos", {.num = 0}},
551 /** The TOS value to use for peer connections (see the TOS VALUES
553 {CONF_VAR_INT, "fnptos", {.num = 0}},
554 /** Specifies a maximum number of simultaneously connected
555 * hubs. Attempts to connect to new hubs beyond this limit will
556 * return an error. Set to zero to remove the limit. */
557 {CONF_VAR_INT, "maxnodes", {.num = 0}},
561 static struct module me =