Typo.
[doldaconnect.git] / clients / gaim / gaim-dolcon.c
CommitLineData
0af3c916 1/*
2 * Dolda Connect - Modular multiuser Direct Connect-style client
3 * Copyright (C) 2005 Fredrik Tolf (fredrik@dolda2000.com)
4 *
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.
9 *
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.
14 *
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
18*/
ccea96e5 19
ee5d122f 20#ifdef HAVE_CONFIG_H
21#include <config.h>
22#endif
23#include <string.h>
24#include <doldaconnect/uilib.h>
25#include <doldaconnect/uimisc.h>
26#include <doldaconnect/utils.h>
27#include <gaim.h>
28#include <plugin.h>
29#include <version.h>
30#include <accountopt.h>
31#include <roomlist.h>
32#include <util.h>
33#include <errno.h>
34
35struct conndata {
36 int fd;
37 int readhdl, writehdl;
38 GaimConnection *gc;
39 GaimRoomlist *roomlist;
40};
41
42static struct conndata *inuse = NULL;
43
44static void dcfdcb(struct conndata *data, int fd, GaimInputCondition condition);
45
46static void updatewrite(struct conndata *data)
47{
48 if(dc_wantwrite()) {
49 if(data->writehdl == -1)
50 data->writehdl = gaim_input_add(data->fd, GAIM_INPUT_WRITE, (void (*)(void *, int, GaimInputCondition))dcfdcb, data);
51 } else {
52 if(data->writehdl != -1) {
53 gaim_input_remove(data->writehdl);
54 data->writehdl = -1;
55 }
56 }
57}
58
59static void disconnected(struct conndata *data)
60{
61 if(inuse == data)
62 inuse = NULL;
63 if(data->readhdl != -1) {
64 gaim_input_remove(data->readhdl);
65 data->readhdl = -1;
66 }
67 if(data->writehdl != -1) {
68 gaim_input_remove(data->writehdl);
69 data->writehdl = -1;
70 }
71 data->fd = -1;
72}
73
74static int loginconv(int type, wchar_t *text, char **resp, struct conndata *data)
75{
76 switch(type) {
77 case DC_LOGIN_CONV_NOECHO:
78 if(data->gc->account->password == NULL) {
79 updatewrite(data);
80 return(1);
81 } else {
82 *resp = sstrdup(data->gc->account->password);
83 updatewrite(data);
84 return(0);
85 }
86 default:
87 updatewrite(data);
88 return(1);
89 }
90}
91
92static void newpeercb(struct dc_fnetpeer *peer)
93{
94 struct conndata *data;
95 GaimConversation *conv;
dc53e482 96 char *buf;
ee5d122f 97
98 data = peer->fn->udata;
99 if((conv = gaim_find_chat(data->gc, peer->fn->id)) != NULL)
100 {
dc53e482 101 buf = sprintf2("%i:%s", peer->fn->id, icswcstombs(peer->nick, "UTF-8", NULL));
102 gaim_conv_chat_add_user(GAIM_CONV_CHAT(conv), buf, NULL, GAIM_CBFLAGS_NONE, TRUE);
103 free(buf);
ee5d122f 104 }
105}
106
107static void delpeercb(struct dc_fnetpeer *peer)
108{
109 struct conndata *data;
110 GaimConversation *conv;
dc53e482 111 char *buf;
ee5d122f 112
113 data = peer->fn->udata;
114 if((conv = gaim_find_chat(data->gc, peer->fn->id)) != NULL)
115 {
dc53e482 116 buf = sprintf2("%i:%s", peer->fn->id, icswcstombs(peer->nick, "UTF-8", NULL));
117 gaim_conv_chat_remove_user(GAIM_CONV_CHAT(conv), buf, NULL);
118 free(buf);
ee5d122f 119 }
120}
121
122static void chpeercb(struct dc_fnetpeer *peer)
123{
124}
125
126static void fillpeerlist(struct dc_fnetnode *fn, int resp, struct conndata *data)
127{
128}
129
130static void getfnlistcb(int resp, struct conndata *data)
131{
132 struct dc_fnetnode *fn;
133
134 for(fn = dc_fnetnodes; fn != NULL; fn = fn->next)
135 {
136 dc_getpeerlistasync(fn, (void (*)(struct dc_fnetnode *, int, void *))fillpeerlist, data);
137 fn->udata = data;
138 fn->newpeercb = newpeercb;
139 fn->delpeercb = delpeercb;
140 fn->chpeercb = chpeercb;
141 }
142}
143
144static void logincb(int err, wchar_t *reason, struct conndata *data)
145{
146 if(err != DC_LOGIN_ERR_SUCCESS) {
147 dc_disconnect();
148 disconnected(data);
149 gaim_connection_error(data->gc, "Invalid login");
150 return;
151 }
152 gaim_connection_set_state(data->gc, GAIM_CONNECTED);
153 serv_finish_login(data->gc);
154 dc_queuecmd(NULL, NULL, L"notify", L"fn:chat", L"on", L"fn:act", L"on", L"fn:peer", L"on", NULL);
155 dc_getfnlistasync((void (*)(int, void *))getfnlistcb, data);
156}
157
158static void dcfdcb(struct conndata *data, int fd, GaimInputCondition condition)
159{
160 struct dc_response *resp;
161 struct dc_intresp *ires;
162 struct dc_fnetnode *fn;
163 GaimConversation *conv;
164 char *peer, *msg;
165
166 if(((condition & GAIM_INPUT_READ) && dc_handleread()) || ((condition & GAIM_INPUT_WRITE) && dc_handlewrite()))
167 {
168 disconnected(data);
169 gaim_connection_error(data->gc, "Server has disconnected");
170 return;
171 }
172 while((resp = dc_getresp()) != NULL) {
173 if(!wcscmp(resp->cmdname, L".connect")) {
174 if(resp->code == 200) {
175 gaim_connection_update_progress(data->gc, "Authenticating", 2, 3);
176 dc_loginasync(NULL, 1, (int (*)(int, wchar_t *, char **, void *))loginconv, (void (*)(int, wchar_t *, void *))logincb, data);
177 } else {
178 dc_disconnect();
179 disconnected(data);
180 gaim_connection_error(data->gc, "Server refused connection");
181 return;
182 }
183 } else if(!wcscmp(resp->cmdname, L".notify")) {
184 dc_uimisc_handlenotify(resp);
185 switch(resp->code) {
186 case 600:
187 if((ires = dc_interpret(resp)) != NULL)
188 {
189 if((fn = dc_findfnetnode(ires->argv[0].val.num)) != NULL)
190 {
191 if(ires->argv[1].val.num)
192 {
193 /* XXX: Handle different rooms */
194 if((conv = gaim_find_chat(data->gc, fn->id)) != NULL)
195 {
196 peer = icwcstombs(ires->argv[3].val.str, "UTF-8");
197 msg = gaim_escape_html(icswcstombs(ires->argv[4].val.str, "UTF-8", NULL));
198 serv_got_chat_in(data->gc, gaim_conv_chat_get_id(GAIM_CONV_CHAT(conv)), peer, 0, msg, time(NULL));
199 g_free(msg);
200 free(peer);
201 }
202 } else {
dc53e482 203 peer = sprintf2("%i:%s", fn->id, icswcstombs(ires->argv[3].val.str, "UTF-8", NULL));
ee5d122f 204 msg = gaim_escape_html(icswcstombs(ires->argv[4].val.str, "UTF-8", NULL));
205 if(!gaim_account_get_bool(data->gc->account, "represspm", FALSE) || (gaim_find_conversation_with_account(peer, data->gc->account) != NULL))
206 serv_got_im(data->gc, peer, msg, 0, time(NULL));
207 g_free(msg);
208 free(peer);
209 }
210 }
211 dc_freeires(ires);
212 }
213 break;
214 case 601:
215 case 602:
216 case 603:
dc53e482 217 break;
ee5d122f 218 case 604:
219 if((ires = dc_interpret(resp)) != NULL)
220 {
221 if((fn = dc_findfnetnode(ires->argv[0].val.num)) != NULL)
222 {
223 fn->udata = data;
224 fn->newpeercb = newpeercb;
225 fn->delpeercb = delpeercb;
226 fn->chpeercb = chpeercb;
227 }
228 dc_freeires(ires);
229 }
dc53e482 230 break;
ee5d122f 231 case 605:
232 break;
233 }
234 }
17221b02 235 dc_freeresp(resp);
ee5d122f 236 }
237 updatewrite(data);
238}
239
240static int gi_sendchat(GaimConnection *gc, int id, const char *what)
241{
242 struct conndata *data;
243 struct dc_fnetnode *fn;
244 wchar_t *wwhat;
245
246 data = gc->proto_data;
247 if((fn = dc_findfnetnode(id)) == NULL)
248 return(-EINVAL);
249 /* XXX: Handle chat rooms */
250 if((wwhat = icmbstowcs((char *)what, "UTF-8")) == NULL)
251 return(-errno);
252 dc_queuecmd(NULL, NULL, L"sendchat", L"%%i", fn->id, L"1", L"", L"%%ls", wwhat, NULL);
253 free(wwhat);
254 updatewrite(data);
255 return(0);
256}
257
258static int gi_sendim(GaimConnection *gc, const char *who, const char *what, GaimConvImFlags flags)
259{
260 struct conndata *data;
dc53e482 261 struct dc_fnetnode *fn;
262 struct dc_fnetpeer *peer;
263 wchar_t *wwho, *wwhat, *p;
264 int en, id;
ee5d122f 265
266 data = gc->proto_data;
267 if((wwho = icmbstowcs((char *)who, "UTF-8")) == NULL)
268 return(-errno);
dc53e482 269 if((p = wcschr(wwho, L':')) == NULL) {
270 free(wwho);
271 return(-ESRCH);
272 }
273 *(p++) = L'\0';
274 id = wcstol(wwho, NULL, 10);
275 if((fn = dc_findfnetnode(id)) == NULL) {
276 free(wwho);
277 return(-ESRCH);
ee5d122f 278 }
dc53e482 279 for(peer = fn->peers; peer != NULL; peer = peer->next) {
280 if(!wcscmp(peer->nick, p))
281 break;
282 }
283 if(peer == NULL) {
ee5d122f 284 free(wwho);
285 return(-ESRCH);
286 }
287 if((wwhat = icmbstowcs((char *)what, "UTF-8")) == NULL) {
288 en = errno;
289 free(wwho);
290 return(-en);
291 }
dc53e482 292 dc_queuecmd(NULL, NULL, L"sendchat", L"%%i", fn->id, L"0", L"%%ls", peer->nick, L"%%ls", wwhat, NULL);
ee5d122f 293 free(wwho);
294 free(wwhat);
295 updatewrite(data);
296 return(1);
297}
298
299static const char *gi_listicon(GaimAccount *a, GaimBuddy *b)
300{
301 return("dolcon");
302}
303
304static struct conndata *newconndata(void)
305{
306 struct conndata *new;
307
308 new = smalloc(sizeof(*new));
309 memset(new, 0, sizeof(*new));
310 new->fd = -1;
311 new->readhdl = new->writehdl = -1;
312 return(new);
313}
314
315static void freeconndata(struct conndata *data)
316{
317 if(data->roomlist != NULL)
318 gaim_roomlist_unref(data->roomlist);
319 if(inuse == data)
320 inuse = NULL;
321 if(data->readhdl != -1)
322 gaim_input_remove(data->readhdl);
323 if(data->writehdl != -1)
324 gaim_input_remove(data->writehdl);
325 if(data->fd >= 0)
326 dc_disconnect();
327 free(data);
328}
329
330static void gi_login(GaimAccount *act)
331{
332 GaimConnection *gc;
333 struct conndata *data;
334
335 gc = gaim_account_get_connection(act);
336 gc->proto_data = data = newconndata();
337 data->gc = gc;
338 if(inuse != NULL) {
339 gaim_connection_error(gc, "Dolda Connect library already in use");
340 return;
341 }
342 gaim_connection_update_progress(gc, "Connecting", 1, 3);
343 if((data->fd = dc_connect((char *)gaim_account_get_string(act, "server", "localhost"), -1)) < 0)
344 {
345 gaim_connection_error(gc, "Could not connect to server");
346 return;
347 }
348 data->readhdl = gaim_input_add(data->fd, GAIM_INPUT_READ, (void (*)(void *, int, GaimInputCondition))dcfdcb, data);
349 updatewrite(data);
350 inuse = data;
351}
352
353static void gi_close(GaimConnection *gc)
354{
355 struct conndata *data;
356
357 data = gc->proto_data;
358 freeconndata(data);
359}
360
361static GaimRoomlist *gi_getlist(GaimConnection *gc)
362{
363 struct conndata *data;
364 GList *fields;
365 GaimRoomlist *rl;
366 GaimRoomlistField *f;
367 GaimRoomlistRoom *r;
368 struct dc_fnetnode *fn;
369
370 data = gc->proto_data;
371 if(data->roomlist != NULL)
372 gaim_roomlist_unref(data->roomlist);
373 data->roomlist = rl = gaim_roomlist_new(gaim_connection_get_account(gc));
374 fields = NULL;
375 f = gaim_roomlist_field_new(GAIM_ROOMLIST_FIELD_INT, "", "id", TRUE);
376 fields = g_list_append(fields, f);
377 f = gaim_roomlist_field_new(GAIM_ROOMLIST_FIELD_INT, "Users", "users", FALSE);
378 fields = g_list_append(fields, f);
379 gaim_roomlist_set_fields(rl, fields);
380 for(fn = dc_fnetnodes; fn != NULL; fn = fn->next) {
381 if(fn->state != DC_FNN_STATE_EST)
382 continue;
383 r = gaim_roomlist_room_new(GAIM_ROOMLIST_ROOMTYPE_ROOM, icswcstombs(fn->name, "UTF-8", NULL), NULL);
384 gaim_roomlist_room_add_field(rl, r, GINT_TO_POINTER(fn->id));
385 gaim_roomlist_room_add_field(rl, r, GINT_TO_POINTER(fn->numusers));
386 gaim_roomlist_room_add(rl, r);
387 }
388 gaim_roomlist_set_in_progress(rl, FALSE);
389 return(rl);
390}
391
392static void gi_cancelgetlist(GaimRoomlist *rl)
393{
394 GaimConnection *gc;
395 struct conndata *data;
396
397 if((gc = gaim_account_get_connection(rl->account)) == NULL)
398 return;
399 data = gc->proto_data;
400 gaim_roomlist_set_in_progress(rl, FALSE);
401 if(data->roomlist == rl) {
402 data->roomlist = NULL;
403 gaim_roomlist_unref(rl);
404 }
405}
406
ee5d122f 407static void gi_joinchat(GaimConnection *gc, GHashTable *chatdata)
408{
409 struct conndata *data;
410 struct dc_fnetnode *fn;
dc53e482 411 GaimConversation *conv;
412 struct dc_fnetpeer *peer;
413 char *buf;
ee5d122f 414
415 data = gc->proto_data;
416 if((fn = dc_findfnetnode(GPOINTER_TO_INT(g_hash_table_lookup(chatdata, "id")))) == NULL)
417 return;
418 if(gaim_find_chat(gc, fn->id) != NULL)
419 return;
dc53e482 420 conv = serv_got_joined_chat(data->gc, fn->id, icswcstombs(fn->name, "UTF-8", NULL));
421 for(peer = fn->peers; peer != NULL; peer = peer->next) {
422 buf = sprintf2("%i:%s", fn->id, icswcstombs(peer->nick, "UTF-8", NULL));
423 gaim_conv_chat_add_user(GAIM_CONV_CHAT(conv), buf, NULL, GAIM_CBFLAGS_NONE, FALSE);
424 free(buf);
425 }
ee5d122f 426}
427
428static GaimPluginProtocolInfo protinfo = {
429 .options = OPT_PROTO_PASSWORD_OPTIONAL,
430 .icon_spec = NO_BUDDY_ICONS,
431 .list_icon = gi_listicon,
432 .login = gi_login,
433 .close = gi_close,
434 .roomlist_get_list = gi_getlist,
435 .roomlist_cancel = gi_cancelgetlist,
436 .join_chat = gi_joinchat,
437 .chat_send = gi_sendchat,
438 .send_im = gi_sendim,
439};
440
441static GaimPluginInfo info = {
442 .magic = GAIM_PLUGIN_MAGIC,
443 .major_version = GAIM_MAJOR_VERSION,
444 .minor_version = GAIM_MINOR_VERSION,
445 .type = GAIM_PLUGIN_PROTOCOL,
446 .priority = GAIM_PRIORITY_DEFAULT,
447 .id = "prpl-dolcon",
448 .name = "Dolda Connect",
449 .version = VERSION,
450 .summary = "Dolda Connect chat plugin",
451 .description = "Allows Gaim to be used as a chat user interface for the Dolda Connect daemon",
452 .author = "Fredrik Tolf <fredrik@dolda2000.com>",
453 .homepage = "http://www.dolda2000.com/~fredrik/doldaconnect/",
454 .extra_info = &protinfo
455};
456
457static void init(GaimPlugin *pl)
458{
459 GaimAccountOption *opt;
460
461 dc_init();
462 opt = gaim_account_option_string_new("Server", "server", "localhost");
463 protinfo.protocol_options = g_list_append(protinfo.protocol_options, opt);
464 opt = gaim_account_option_int_new("Port", "port", -1);
465 protinfo.protocol_options = g_list_append(protinfo.protocol_options, opt);
466 opt = gaim_account_option_bool_new("Do not pop up private messages automatically", "represspm", FALSE);
467 protinfo.protocol_options = g_list_append(protinfo.protocol_options, opt);
468}
469
470GAIM_INIT_PLUGIN(dolcon, init, info);