2 * Dolda Connect - Modular multiuser Direct Connect-style client
3 * Copyright (C) 2007 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
39 static void settags(void);
41 static regex_t *filter = NULL;
42 static int itag = -1, otag = -1;
43 static int (*handler)(int, char *, size_t) = NULL;
45 static struct htconn *hc;
46 static bz_stream *bzs;
47 /* Only needed because of bzlib: */
49 static size_t mybufsize, mybufdata;
51 #include "mainwnd.gtkh"
53 void aborthublist(void)
58 mybufsize = mybufdata = 0;
61 gtk_widget_hide(main_pubhubbarbox);
63 gdk_input_remove(itag);
65 gdk_input_remove(otag);
70 BZ2_bzDecompressEnd(bzs);
79 handler(PHO_FINI, NULL, 0);
85 int validhub(char *field, ...)
93 va_start(args, field);
95 if(!regexec(filter, field, 0, NULL, 0)) {
99 } while((field = va_arg(args, char *)) != NULL);
104 static void fdcb(gpointer data, gint source, GdkInputCondition cond)
106 int ret, bzret, hret;
109 gdk_input_remove(itag);
111 gdk_input_remove(otag);
113 ret = htprocess(hc, ((cond & GDK_INPUT_READ)?POLLIN:0) | ((cond & GDK_INPUT_WRITE)?POLLOUT:0));
115 msgbox(GTK_MESSAGE_ERROR, GTK_BUTTONS_OK, _("Could not read hublist from server: %s"), strerror(errno));
120 if(hc->rescode != 0) {
121 if(hc->rescode != 200) {
122 msgbox(GTK_MESSAGE_ERROR, GTK_BUTTONS_OK, _("The hublist server returned an error: \"%i %s\""), hc->rescode, hc->resstr);
127 gtk_progress_bar_set_text(GTK_PROGRESS_BAR(main_pubhubbar), _("Getting list..."));
132 gtk_progress_bar_set_fraction(GTK_PROGRESS_BAR(main_pubhubbar), ((double)hc->rxd) / ((double)hc->tlen));
134 gtk_progress_bar_set_pulse_step(GTK_PROGRESS_BAR(main_pubhubbar), ((double)hc->databufdata) / 10000.0);
135 gtk_progress_bar_pulse(GTK_PROGRESS_BAR(main_pubhubbar));
137 if(hc->databufdata > 0) {
139 bufcat(mybuf, hc->databuf, hc->databufdata);
142 bzs->next_in = hc->databuf;
143 bzs->avail_in = hc->databufdata;
145 sizebuf2(mybuf, mybufdata + 1024, 1);
146 bzs->next_out = mybuf + mybufdata;
147 bzs->avail_out = mybufsize - mybufdata;
148 bzret = BZ2_bzDecompress(bzs);
149 if((bzret != BZ_OK) && (bzret != BZ_STREAM_END)) {
150 msgbox(GTK_MESSAGE_ERROR, GTK_BUTTONS_OK, _("Could not decompress hublist (%i)"), hret);
154 mybufdata = mybufsize - bzs->avail_out;
155 if(bzret == BZ_STREAM_END) {
159 } while(bzs->avail_out == 0);
160 memmove(hc->databuf, bzs->next_in, hc->databufdata -= (bzs->next_in - hc->databuf));
162 if((hret = handler(PHO_DATA, mybuf, mybufdata)) < 0)
165 memmove(mybuf, mybuf + hret, mybufdata -= hret);
168 gtk_progress_bar_set_fraction(GTK_PROGRESS_BAR(main_pubhubbar), 1);
169 gtk_progress_bar_set_text(GTK_PROGRESS_BAR(main_pubhubbar), _("Finalizing list..."));
170 gdk_window_process_updates(main_pubhubbar->window, FALSE);
171 handler(PHO_EOF, NULL, 0);
179 static void settags(void)
181 if(htpollflags(hc) & POLLIN)
182 itag = gdk_input_add(hc->fd, GDK_INPUT_READ, fdcb, NULL);
183 if(htpollflags(hc) & POLLOUT)
184 otag = gdk_input_add(hc->fd, GDK_INPUT_WRITE, fdcb, NULL);
187 void fetchhublist(char *url, regex_t *flt)
200 gtk_widget_show(main_pubhubbarbox);
201 gtk_progress_bar_set_text(GTK_PROGRESS_BAR(main_pubhubbar), _("Connecting..."));
202 gtk_progress_bar_set_fraction(GTK_PROGRESS_BAR(main_pubhubbar), 0);
203 gdk_window_process_updates(main_pubhubbarbox->window, TRUE);
207 if((len > 4) && !strncmp(p - 4, ".bz2", 4)) {
210 bzs = memset(smalloc(sizeof(*bzs)), 0, sizeof(*bzs));
211 if(BZ2_bzDecompressInit(bzs, 0, 0) != BZ_OK) {
212 msgbox(GTK_MESSAGE_ERROR, GTK_BUTTONS_OK, _("Could not initialize decompression library"));
219 if((len > 4) && !strncmp(p - 4, ".xml", 4)) {
222 handler = pubhubxmlhandler;
224 handler = pubhuboldhandler;
226 handler(PHO_INIT, NULL, 0);