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 struct fnet *networks = NULL;
34 struct fnetnode *fnetnodes = NULL;
36 GCBCHAIN(newfncb, struct fnetnode *);
38 static struct fnetnode *newfn(struct fnet *fnet)
43 new = smalloc(sizeof(*new));
44 memset(new, 0, sizeof(*new));
48 new->mynick = swcsdup(confgetstr("cli", "defnick"));
49 new->srchwait = confgetint("fnet", "srchwait");
51 CBCHAININIT(new, fnetnode_ac);
52 CBCHAININIT(new, fnetnode_chat);
53 CBCHAININIT(new, fnetnode_unlink);
54 CBCHAININIT(new, fnetnode_destroy);
55 CBCHAININIT(new, fnetpeer_new);
56 CBCHAININIT(new, fnetpeer_del);
57 CBCHAININIT(new, fnetpeer_chdi);
64 void killfnetnode(struct fnetnode *fn)
66 fnetsetstate(fn, FNN_DEAD);
75 struct fnetnode *getfnetnode(struct fnetnode *fn)
79 fprintf(stderr, "getfnetnode on id %i at %p, refcount=%i\n", fn->id, fn, fn->refcount);
84 void putfnetnode(struct fnetnode *fn)
89 fprintf(stderr, "putfnetnode on id %i at %p, refcount=%i\n", fn->id, fn, fn->refcount - 1);
93 for(cur = fnetnodes; cur != NULL; cur = cur->next)
96 flog(LOG_CRIT, "BUG: fnetnode reached refcount 0 while still in list - id %i", fn->id);
98 CBCHAINDOCB(fn, fnetnode_destroy, fn);
99 CBCHAINFREE(fn, fnetnode_ac);
100 CBCHAINFREE(fn, fnetnode_chat);
101 CBCHAINFREE(fn, fnetnode_unlink);
102 CBCHAINFREE(fn, fnetnode_destroy);
103 CBCHAINFREE(fn, fnetpeer_new);
104 CBCHAINFREE(fn, fnetpeer_del);
105 CBCHAINFREE(fn, fnetpeer_chdi);
106 if(fn->fnet->destroy != NULL)
107 fn->fnet->destroy(fn);
108 while(fn->args != NULL)
109 freewcspair(fn->args, &fn->args);
110 while(fn->peers != NULL)
111 fnetdelpeer(fn->peers);
112 if(fn->mynick != NULL)
114 if(fn->pubid != NULL)
120 if(fn->owner != NULL)
126 struct fnetnode *findfnetnode(int id)
130 for(fn = fnetnodes; (fn != NULL) && (fn->id != id); fn = fn->next);
134 void linkfnetnode(struct fnetnode *fn)
139 fn->next = fnetnodes;
140 if(fnetnodes != NULL)
141 fnetnodes->prev = fn;
144 GCBCHAINDOCB(newfncb, fn);
147 void unlinkfnetnode(struct fnetnode *fn)
152 fnetnodes = fn->next;
154 fn->next->prev = fn->prev;
156 fn->prev->next = fn->next;
158 CBCHAINDOCB(fn, fnetnode_unlink, fn);
162 static int conncb(struct socket *sk, int err, struct fnetnode *data)
171 fnetsetstate(data, FNN_HS);
172 socksettos(sk, confgetint("fnet", "fntos"));
173 data->fnet->connect(data);
178 static void resolvecb(struct sockaddr *addr, int addrlen, struct fnetnode *data)
185 netcsconn(addr, addrlen, (int (*)(struct socket *, int, void *))conncb, data);
189 static struct fnetpeerdatum *finddatum(struct fnetnode *fn, wchar_t *id)
191 struct fnetpeerdatum *datum;
193 for(datum = fn->peerdata; datum != NULL; datum = datum->next)
195 if(!wcscmp(datum->id, id))
201 static struct fnetpeerdatum *adddatum(struct fnetnode *fn, wchar_t *id, int datatype)
203 struct fnetpeerdatum *new;
205 new = smalloc(sizeof(*new));
207 new->id = swcsdup(id);
208 new->datatype = datatype;
210 new->next = fn->peerdata;
211 if(fn->peerdata != NULL)
212 fn->peerdata->prev = new;
217 static struct fnetpeerdi *difindoradd(struct fnetpeer *peer, struct fnetpeerdatum *datum, int *isnew)
221 for(i = 0; i < peer->dinum; i++)
223 if(peer->peerdi[i].datum == datum)
228 peer->peerdi = srealloc(peer->peerdi, sizeof(struct fnetpeerdi) * (peer->dinum + 1));
229 memset(&peer->peerdi[peer->dinum], 0, sizeof(struct fnetpeerdi));
230 peer->peerdi[peer->dinum].datum = datum;
234 return(&peer->peerdi[peer->dinum++]);
238 return(&peer->peerdi[i]);
242 void fnetpeersetstr(struct fnetpeer *peer, wchar_t *id, wchar_t *value)
244 struct fnetpeerdatum *datum;
245 struct fnetpeerdi *di;
248 if((datum = finddatum(peer->fn, id)) == NULL)
249 datum = adddatum(peer->fn, id, FNPD_STR);
250 di = difindoradd(peer, datum, &changed);
251 if(di->data.str != NULL) {
252 changed = (changed || wcscmp(value, di->data.str));
257 di->data.str = swcsdup(value);
259 CBCHAINDOCB(peer->fn, fnetpeer_chdi, peer->fn, peer, di);
262 void fnetpeersetnum(struct fnetpeer *peer, wchar_t *id, int value)
264 struct fnetpeerdatum *datum;
265 struct fnetpeerdi *di;
268 if((datum = finddatum(peer->fn, id)) == NULL)
269 datum = adddatum(peer->fn, id, FNPD_INT);
270 di = difindoradd(peer, datum, &changed);
271 changed = (changed || (di->data.num != value));
272 di->data.num = value;
274 CBCHAINDOCB(peer->fn, fnetpeer_chdi, peer->fn, peer, di);
277 void fnetpeersetlnum(struct fnetpeer *peer, wchar_t *id, long long value)
279 struct fnetpeerdatum *datum;
280 struct fnetpeerdi *di;
283 if((datum = finddatum(peer->fn, id)) == NULL)
284 datum = adddatum(peer->fn, id, FNPD_LL);
285 di = difindoradd(peer, datum, &changed);
286 changed = (changed || (di->data.lnum != value));
287 di->data.lnum = value;
289 CBCHAINDOCB(peer->fn, fnetpeer_chdi, peer->fn, peer, di);
292 static void putdatum(struct fnetpeer *peer, struct fnetpeerdatum *datum)
294 if(--datum->refcount > 0)
296 if(datum->next != NULL)
297 datum->next->prev = datum->prev;
298 if(datum->prev != NULL)
299 datum->prev->next = datum->next;
300 if(datum == peer->fn->peerdata)
301 peer->fn->peerdata = datum->next;
306 void fnetpeerunset(struct fnetpeer *peer, wchar_t *id)
309 struct fnetpeerdatum *datum;
311 if((datum = finddatum(peer->fn, id)) == NULL)
313 for(i = 0; i < peer->dinum; i++)
315 if(peer->peerdi[i].datum == datum)
320 if((datum->datatype == FNPD_STR) && (peer->peerdi[i].data.str != NULL))
321 free(peer->peerdi[i].data.str);
323 memmove(&peer->peerdi[i], &peer->peerdi[i + 1], sizeof(struct fnetpeerdi) * (peer->dinum - i));
324 putdatum(peer, datum);
327 struct fnetpeer *fnetaddpeer(struct fnetnode *fn, wchar_t *id, wchar_t *nick)
329 struct fnetpeer *new;
331 new = smalloc(sizeof(*new));
333 new->id = swcsdup(id);
334 new->nick = swcsdup(nick);
338 new->next = fn->peers;
340 if(fn->peers != NULL)
341 fn->peers->prev = new;
344 CBCHAINDOCB(fn, fnetnode_ac, fn, L"numpeers");
345 CBCHAINDOCB(fn, fnetpeer_new, fn, new);
349 void fnetdelpeer(struct fnetpeer *peer)
353 if(peer->next != NULL)
354 peer->next->prev = peer->prev;
355 if(peer->prev != NULL)
356 peer->prev->next = peer->next;
357 if(peer->fn->peers == peer)
358 peer->fn->peers = peer->next;
359 peer->fn->numpeers--;
360 CBCHAINDOCB(peer->fn, fnetnode_ac, peer->fn, L"numpeers");
361 CBCHAINDOCB(peer->fn, fnetpeer_del, peer->fn, peer);
364 for(i = 0; i < peer->dinum; i++)
366 if((peer->peerdi[i].datum->datatype == FNPD_STR) && (peer->peerdi[i].data.str != NULL))
367 free(peer->peerdi[i].data.str);
368 putdatum(peer, peer->peerdi[i].datum);
370 if(peer->peerdi != NULL)
375 struct fnetpeer *fnetfindpeer(struct fnetnode *fn, wchar_t *id)
377 struct fnetpeer *cur;
379 for(cur = fn->peers; (cur != NULL) && wcscmp(cur->id, id); cur = cur->next);
383 int fnetsetnick(struct fnetnode *fn, wchar_t *newnick)
387 if(fn->fnet->setnick != NULL)
388 ret = fn->fnet->setnick(fn, newnick);
393 if(fn->mynick != NULL)
395 fn->mynick = swcsdup(newnick);
400 int fnetsendchat(struct fnetnode *fn, int public, wchar_t *to, wchar_t *string)
402 if(fn->fnet->sendchat == NULL)
407 return(fn->fnet->sendchat(fn, public, to, string));
410 int fnetsearch(struct fnetnode *fn, struct search *srch, struct srchfnnlist *ln)
412 if(fn->fnet->search == NULL)
417 return(fn->fnet->search(fn, srch, ln));
420 void fnetsetname(struct fnetnode *fn, wchar_t *newname)
424 fn->name = swcsdup(newname);
425 CBCHAINDOCB(fn, fnetnode_ac, fn, L"name");
428 void fnetsetstate(struct fnetnode *fn, int newstate)
430 fn->state = newstate;
431 CBCHAINDOCB(fn, fnetnode_ac, fn, L"state");
434 struct fnet *findfnet(wchar_t *name)
438 for(fnet = networks; fnet != NULL; fnet = fnet->next)
440 if(!wcscmp(name, fnet->name))
446 struct fnetnode *fnetinitconnect(wchar_t *name, wchar_t *owner, char *addr, struct wcspair *args)
452 if((fnet = findfnet(name)) == NULL)
454 errno = EPROTONOSUPPORT;
458 fn->owner = swcsdup(owner);
459 fn->pubid = icmbstowcs(addr, NULL);
460 if(fn->pubid == NULL)
461 fn->pubid = swcsdup(L"");
463 for(arg = fn->args; arg != NULL; arg = arg->next)
465 if(!wcscmp(arg->key, L"nick"))
466 fnetsetnick(fn, arg->val);
469 if(netresolve(addr, (void (*)(struct sockaddr *, int, void *))resolvecb, fn) < 0)
474 void regfnet(struct fnet *fnet)
476 fnet->next = networks;
481 * Note on the chat string: Must be in UNIX text file format - that
482 * is, LF line endings. The filenet-specific code must see to it that
483 * any other kind of format is converted into that. In the future,
484 * certain control characters and escape sequences will be parsed by
485 * the client. Make sure that any filenet-specific code strips any
486 * such that aren't supposed to be in the protocol.
488 * Note on "name": This is supposed to be an identifier for the
489 * source. If the chat is a public message, set "public" to non-zero
490 * and "name" to whatever "chat room" name is appropriate for the
491 * fnetnode, but not NULL. If there is a "default" channel in this
492 * filenet, set "name" to the empty string. If the chat is a private
493 * message, name is ignored.
495 void fnethandlechat(struct fnetnode *fn, int public, wchar_t *name, wchar_t *peer, wchar_t *chat)
497 CBCHAINDOCB(fn, fnetnode_chat, fn, public, name, peer, chat);
500 static struct configvar myvars[] =
502 {CONF_VAR_INT, "srchwait", {.num = 15}},
503 {CONF_VAR_INT, "fntos", {.num = 0}},
504 {CONF_VAR_INT, "fnptos", {.num = 0}},
505 {CONF_VAR_INT, "maxnodes", {.num = 0}},
509 static struct module me =