* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
*/
+/* This file is a complete and total mess, mostly because of my
+ * inability to structure GUI programs properly. Looking at it too
+ * closely may cause ocular hemorrhaging. */
+
+#include <stdlib.h>
#include <stdio.h>
#include <unistd.h>
#include <string.h>
-#include <malloc.h>
#include <stdarg.h>
#include <gtk/gtk.h>
#include <sys/socket.h>
#include <regex.h>
#include <signal.h>
#include <time.h>
+#include <sys/time.h>
#include <pwd.h>
#include <locale.h>
#include <libintl.h>
#include <assert.h>
+/* "Programming with libxml2 is like the thrilling embrace of an
+ * exotic strangler."
+ * --Me */
+#include <libxml/parser.h>
+#include <libxml/tree.h>
+
#ifdef HAVE_CONFIG_H
#include <config.h>
#endif
#include "progressbar.h"
+#define TRHISTSIZE 10
+#define PHO_INIT 0
+#define PHO_DATA 1
+#define PHO_EOF 2
+#define PHO_FINI 3
+
+struct trdata
+{
+ size_t poshist[TRHISTSIZE];
+ double timehist[TRHISTSIZE];
+ int hc;
+};
struct fndata
{
};
GtkWidget *inpdialog;
-GtkListStore *fnmodel, *ulmodel, *dlmodel, *pubhubmodel;
+GtkListStore *fnmodel, *ulmodel, *dlmodel, *reslist;
+int (*pubhubhandler)(int, char *, size_t *) = NULL;
GtkTreeStore *srchmodel;
GtkTreeModelFilter *srchmodelfilter;
GtkTextTagTable *chattags;
time_t srcheta;
struct srchsize *srchsizes = NULL;
struct knownspeed *knownspeeds = NULL;
-int numsizes = 0, numspeeds = 0, ksqueryseq = -1, ksquerytag = -1;
+int numsizes = 0, numspeeds = 0, ksqueryseq = -1, ksquerytag = -1, lsrestag = -1;
gboolean initdeath(GtkWidget *, gpointer);
void cb_main_connmenu_activate(GtkWidget *widget, gpointer data);
void cb_main_dconnmenu_activate(GtkWidget *widget, gpointer data);
void cb_main_prefmenu_activate(GtkWidget *widget, gpointer data);
+void cb_main_lsres_activate(GtkWidget *widget, gpointer data);
void cb_main_sdmenu_activate(GtkWidget *widget, gpointer data);
void cb_inpdialog_entry_activate(GtkWidget *widget, gpointer data);
void cb_main_fnaddr_activate(GtkWidget *widget, gpointer data);
gboolean cb_main_trlist_keypress(GtkWidget *widget, GdkEventKey *event, gpointer data);
void cb_main_filternoslots_toggled(GtkToggleButton *widget, gpointer data);
void cb_main_srhash_activate(GtkWidget *widget, gpointer data);
+void cb_main_srcopy_activate(GtkWidget *widget, gpointer data);
void cb_main_trhash_activate(GtkWidget *widget, gpointer data);
+void cb_main_trcopy_activate(GtkWidget *widget, gpointer data);
void cb_main_trcancel_activate(GtkWidget *widget, gpointer data);
gboolean cb_main_srpopup(GtkWidget *widget, GdkEventButton *event, gpointer data);
gboolean cb_main_trpopup(GtkWidget *widget, GdkEventButton *event, gpointer data);
+void cb_reslist_reload_clicked(GtkWidget *widget, gpointer data);
+void cb_reslist_delete_clicked(GtkWidget *widget, gpointer data);
+void cb_reslist_search_clicked(GtkWidget *widget, gpointer data);
+void cb_reslist_list_cchange(GtkWidget *widget, gpointer data);
+void cb_reslist_list_activate(GtkWidget *widget, GtkTreePath *path, GtkTreeViewColumn *col, gpointer data);
+gboolean cb_reslist_list_keypress(GtkWidget *widget, GdkEventKey *event, gpointer data);
void dcfdcallback(gpointer data, gint source, GdkInputCondition condition);
void srchstatupdate(void);
void transnicebytefunc(GtkTreeViewColumn *col, GtkCellRenderer *rend, GtkTreeModel *model, GtkTreeIter *iter, gpointer data);
+void transnicebytefunc2(GtkTreeViewColumn *col, GtkCellRenderer *rend, GtkTreeModel *model, GtkTreeIter *iter, gpointer data);
+void transspeedinfo(GtkTreeViewColumn *col, GtkCellRenderer *rend, GtkTreeModel *model, GtkTreeIter *iter, gpointer data);
void transerrorinfo(GtkTreeViewColumn *col, GtkCellRenderer *rend, GtkTreeModel *model, GtkTreeIter *iter, gpointer data);
void percentagefunc(GtkTreeViewColumn *col, GtkCellRenderer *rend, GtkTreeModel *model, GtkTreeIter *iter, gpointer data);
void hidezerofunc(GtkTreeViewColumn *col, GtkCellRenderer *rend, GtkTreeModel *model, GtkTreeIter *iter, gpointer data);
#include "mainwnd.gtk"
#include "inpdialog.gtk"
#include "pref.gtk"
+#include "reslist.gtk"
void updatewrite(void)
{
}
}
+double ntime(void)
+{
+ struct timeval tv;
+
+ gettimeofday(&tv, NULL);
+ return((double)tv.tv_sec + ((double)tv.tv_usec / 1000000.0));
+}
+
void fndestroycb(struct dc_fnetnode *fn)
{
struct fndata *data;
fn->udata = data;
}
+void trdestroycb(struct dc_transfer *tr)
+{
+ free(tr->udata);
+}
+
+void addtrdata(struct dc_transfer *tr)
+{
+ struct trdata *data;
+
+ if(tr->udata != NULL)
+ return;
+ tr->destroycb = trdestroycb;
+ data = smalloc(sizeof(*data));
+ memset(data, 0, sizeof(*data));
+ tr->udata = data;
+}
+
+void updatetrdata(struct dc_transfer *tr)
+{
+ int i;
+ struct trdata *data;
+
+ data = tr->udata;
+ if(data->hc < TRHISTSIZE)
+ {
+ data->poshist[data->hc] = tr->curpos;
+ data->timehist[data->hc] = ntime();
+ data->hc++;
+ } else {
+ for(i = 0; i < TRHISTSIZE - 1; i++)
+ {
+ data->poshist[i] = data->poshist[i + 1];
+ data->timehist[i] = data->timehist[i + 1];
+ }
+ data->poshist[i] = tr->curpos;
+ data->timehist[i] = ntime();
+ }
+}
+
char *getfnstatestock(int state)
{
if(state == DC_FNN_STATE_SYN)
}
}
+char *bytes2si(long long bytes)
+{
+ int i;
+ double b;
+ char *sd;
+ static char ret[64];
+
+ b = bytes;
+ for(i = 0; (b >= 1024) && (i < 4); i++)
+ b /= 1024;
+ if(i == 0)
+ sd = "B";
+ else if(i == 1)
+ sd = "kiB";
+ else if(i == 2)
+ sd = "MiB";
+ else if(i == 3)
+ sd = "GiB";
+ else
+ sd = "TiB";
+ snprintf(ret, 64, "%.1f %s", b, sd);
+ return(ret);
+}
+
void percentagefunc(GtkTreeViewColumn *col, GtkCellRenderer *rend, GtkTreeModel *model, GtkTreeIter *iter, gpointer data)
{
int colnum;
g_object_set(rend, "text", buf, NULL);
}
+void transnicebytefunc2(GtkTreeViewColumn *col, GtkCellRenderer *rend, GtkTreeModel *model, GtkTreeIter *iter, gpointer data)
+{
+ int colnum;
+ long long val;
+ char buf[64];
+
+ colnum = (int)data;
+ gtk_tree_model_get(model, iter, colnum, &val, -1);
+ if(val >= 0)
+ strcpy(buf, bytes2si(val));
+ else
+ strcpy(buf, _("Unknown"));
+ g_object_set(rend, "text", buf, NULL);
+}
+
void hidezerofunc(GtkTreeViewColumn *col, GtkCellRenderer *rend, GtkTreeModel *model, GtkTreeIter *iter, gpointer data)
{
int colnum, val;
g_object_set(rend, "text", buf, NULL);
}
+void transspeedinfo(GtkTreeViewColumn *col, GtkCellRenderer *rend, GtkTreeModel *model, GtkTreeIter *iter, gpointer data)
+{
+ int id;
+ struct dc_transfer *tr;
+ struct trdata *d;
+ char buf[64];
+ int speed;
+
+ gtk_tree_model_get(model, iter, 0, &id, -1);
+ if((tr = dc_findtransfer(id)) != NULL)
+ {
+ d = tr->udata;
+ if((tr->state != DC_TRNS_MAIN) || (d == NULL))
+ {
+ buf[0] = 0;
+ } else if(d->hc < 2) {
+ strcpy(buf, "...");
+ } else {
+ speed = (((double)(d->poshist[d->hc - 1] - d->poshist[0])) / (d->timehist[d->hc - 1] - d->timehist[0]));
+ snprintf(buf, 64, "%s/s", bytes2si(speed));
+ }
+ } else {
+ buf[0] = 0;
+ }
+ g_object_set(rend, "text", buf, NULL);
+}
+
void transerrorinfo(GtkTreeViewColumn *col, GtkCellRenderer *rend, GtkTreeModel *model, GtkTreeIter *iter, gpointer data)
{
int error;
return(NULL);
}
+gint updatetransfers(gpointer data)
+{
+ struct dc_transfer *tr;
+ struct trdata *d;
+ double now;
+
+ now = ntime();
+ for(tr = dc_transfers; tr != NULL; tr = tr->next)
+ {
+ if((d = tr->udata) != NULL)
+ {
+ if((d->hc > 0) && ((now - d->timehist[d->hc - 1]) > 2))
+ updatetrdata(tr);
+ }
+ }
+ return(TRUE);
+}
+
void updatetransferlists(void)
{
int i;
if(size != transfer->size)
gtk_list_store_set(stores[i], &iter, 6, transfer->size, -1);
if(curpos != transfer->curpos)
+ {
gtk_list_store_set(stores[i], &iter, 7, transfer->curpos, -1);
+ if(transfer->udata != NULL)
+ updatetrdata(transfer);
+ }
if(error != transfer->error)
gtk_list_store_set(stores[i], &iter, 10, transfer->error, -1);
if(errortime != transfer->errortime)
free(path);
if(transfer->hash != NULL)
free(hash);
+ addtrdata(transfer);
}
}
}
}
}
if(oldnum != numspeeds)
- knownspeeds = srealloc(knownspeeds, numspeeds * sizeof(*knownspeeds));
+ {
+ if(numspeeds == 0)
+ {
+ free(knownspeeds);
+ knownspeeds = NULL;
+ } else {
+ knownspeeds = srealloc(knownspeeds, numspeeds * sizeof(*knownspeeds));
+ }
+ }
gtk_tree_model_foreach(GTK_TREE_MODEL(srchmodel), ksupdaterow, NULL);
if(ksqueryseq == -2)
{
}
ksquerytag = -1;
ksupdatecb(NULL);
+ } else if((lsrestag >= 0) && (lsrestag == resp->tag)) {
+ for(i = 0; i < resp->numlines; i++)
+ {
+ if(!wcsncmp(resp->rlines[i].argv[1], L"id:", 3))
+ {
+ gtk_list_store_append(reslist, &titer);
+ gtk_list_store_set(reslist, &titer, 0, icswcstombs(resp->rlines[i].argv[1] + 3, "UTF-8", NULL), -1);
+ } else if(!wcsncmp(resp->rlines[i].argv[1], L"size:", 5)) {
+ gtk_list_store_set(reslist, &titer, 1, wcstol(resp->rlines[i].argv[1] + 5, NULL, 10), -1);
+ } else if(!wcsncmp(resp->rlines[i].argv[1], L"prog:", 5)) {
+ gtk_list_store_set(reslist, &titer, 2, wcstol(resp->rlines[i].argv[1] + 5, NULL, 10), -1);
+ } else if(!wcsncmp(resp->rlines[i].argv[1], L"name:", 5)) {
+ gtk_list_store_set(reslist, &titer, 3, icswcstombs(resp->rlines[i].argv[1] + 5, "UTF-8", NULL), -1);
+ } else if(!wcsncmp(resp->rlines[i].argv[1], L"lock:", 5)) {
+ if(!wcscmp(resp->rlines[i].argv[1] + 5, L"yes"))
+ gtk_list_store_set(reslist, &titer, 4, TRUE, -1);
+ else
+ gtk_list_store_set(reslist, &titer, 4, FALSE, -1);
+ } else if(!wcsncmp(resp->rlines[i].argv[1], L"hash:", 5)) {
+ gtk_list_store_set(reslist, &titer, 5, icswcstombs(resp->rlines[i].argv[1] + 5, "UTF-8", NULL), -1);
+ }
+ }
+ lsrestag = -1;
+ gtk_widget_set_sensitive(reslist_reload, TRUE);
}
}
dc_freeresp(resp);
gtk_widget_destroy(dialog);
}
+void cb_main_lsres_activate(GtkWidget *widget, gpointer data)
+{
+ gtk_list_store_clear(reslist);
+ gtk_widget_set_sensitive(reslist_delete, FALSE);
+ gtk_widget_set_sensitive(reslist_search, FALSE);
+ gtk_widget_show(reslist_wnd);
+ if(lsrestag == -1)
+ {
+ lsrestag = dc_queuecmd(NULL, NULL, L"filtercmd", L"lsres", NULL);
+ gtk_widget_set_sensitive(reslist_reload, FALSE);
+ }
+}
+
void dcconnect(char *host)
{
- dcfd = dc_connect(host, -1);
+ dcfd = dc_connect(host);
if(dcfd < 0)
{
msgbox(GTK_MESSAGE_ERROR, GTK_BUTTONS_OK, _("Could not connect:\n\n%s"), strerror(errno));
void cb_main_fnaddr_activate(GtkWidget *widget, gpointer data)
{
int tag;
- char *buf;
struct dc_response *resp;
+ wchar_t **toks;
if(dcfd < 0)
{
msgbox(GTK_MESSAGE_ERROR, GTK_BUTTONS_OK, _("Not connected to DC server"));
return;
}
- buf = sstrdup(gtk_entry_get_text(GTK_ENTRY(main_fnaddr)));
- if(strchr(buf, ':') == NULL)
+ toks = dc_lexsexpr(icsmbstowcs((char *)gtk_entry_get_text(GTK_ENTRY(main_fnaddr)), "UTF-8", NULL));
+ if(*toks == NULL)
{
- buf = srealloc(buf, strlen(buf) + 5);
- strcat(buf, ":411");
+ msgbox(GTK_MESSAGE_ERROR, GTK_BUTTONS_OK, _("Illegal address entered"));
+ return;
}
- tag = dc_queuecmd(NULL, NULL, L"cnct", L"dc", L"%%s", buf, NULL);
- free(buf);
+ if(wcschr(toks[0], L':') == NULL)
+ {
+ toks[0] = srealloc(toks[0], (wcslen(toks[0]) + 5) * sizeof(wchar_t));
+ wcscat(toks[0], L":411");
+ }
+ tag = dc_queuecmd(NULL, NULL, L"cnct", L"dc", L"%%a", toks, NULL);
+ dc_freewcsarr(toks);
if((resp = dc_gettaggedrespsync(tag)) != NULL)
{
if(resp->code == 502)
msgbox(GTK_MESSAGE_WARNING, GTK_BUTTONS_OK, _("You do not have permission to do that"));
if(resp->code == 509)
msgbox(GTK_MESSAGE_WARNING, GTK_BUTTONS_OK, _("The server could not parse that address"));
+ if(resp->code == 515)
+ msgbox(GTK_MESSAGE_WARNING, GTK_BUTTONS_OK, _("There are too many hubs connected"));
dc_freeresp(resp);
}
gtk_entry_set_text(GTK_ENTRY(main_fnaddr), "");
handleresps();
}
-void pubhubfdcallback(gpointer data, gint source, GdkInputCondition condition)
+void setpubhubmodel(GtkTreeModel *model, int sortcol, int numcols, int *cols, char **names)
{
- static char buf[65536];
- static int bufpos = 0;
- int ret, i;
+ GtkTreeViewColumn *col;
+ GtkCellRenderer *rnd;
+ GtkTreeModel *sortmodel;
+ int i;
+
+ while((col = gtk_tree_view_get_column(GTK_TREE_VIEW(main_phublist), 0)) != NULL)
+ gtk_tree_view_remove_column(GTK_TREE_VIEW(main_phublist), col);
+ for(i = 0; i < numcols; i++) {
+ if(gtk_tree_model_get_column_type(model, cols[i]) == G_TYPE_INT64)
+ {
+ col = gtk_tree_view_column_new();
+ gtk_tree_view_column_set_title(col, names[i]);
+ rnd = gtk_cell_renderer_text_new();
+ gtk_tree_view_column_pack_start(col, rnd, TRUE);
+ gtk_tree_view_column_set_cell_data_func(col, rnd, transnicebytefunc2, (gpointer)cols[i], NULL);
+ } else {
+ col = gtk_tree_view_column_new_with_attributes(names[i], gtk_cell_renderer_text_new(), "text", cols[i], NULL);
+ }
+ gtk_tree_view_column_set_sort_column_id(col, cols[i]);
+ gtk_tree_view_column_set_resizable(col, TRUE);
+ gtk_tree_view_append_column(GTK_TREE_VIEW(main_phublist), col);
+ }
+ sortmodel = gtk_tree_model_sort_new_with_model(model);
+ gtk_tree_sortable_set_sort_column_id(GTK_TREE_SORTABLE(sortmodel), sortcol, GTK_SORT_DESCENDING);
+ gtk_tree_view_set_model(GTK_TREE_VIEW(main_phublist), sortmodel);
+ g_object_unref(sortmodel);
+}
+
+xmlNodePtr findnode(xmlNodePtr node, char *name)
+{
+ for(; node != NULL; node = node->next)
+ {
+ if(!strcmp((char *)node->name, name))
+ break;
+ }
+ return(node);
+}
+
+int pubhubxmlhandler(int op, char *buf, size_t *len)
+{
+ static xmlParserCtxtPtr ctxt = NULL;
+ int i, match;
+ xmlNodePtr dr, r, cr, c, n;
+ int numcols, *cols, sortcol;
+ GType type, *types;
+ char **names, *name, *stype, *attr;
+ GtkListStore *model;
+ GtkTreeIter iter;
+
+ numcols = 0;
+ names = NULL;
+ types = NULL;
+ switch(op)
+ {
+ case PHO_INIT:
+ break;
+ case PHO_DATA:
+ if(ctxt == NULL) {
+ ctxt = xmlCreatePushParserCtxt(NULL, NULL, buf, *len, pubhubaddr);
+ *len = 0;
+ if(ctxt == NULL)
+ return(1);
+ } else {
+ xmlParseChunk(ctxt, buf, *len, 0);
+ *len = 0;
+ }
+ break;
+ case PHO_EOF:
+ xmlParseChunk(ctxt, NULL, 0, 1);
+ if(!ctxt->wellFormed)
+ {
+ msgbox(GTK_MESSAGE_ERROR, GTK_BUTTONS_OK, _("The hub list at %s is not valid"), pubhubaddr);
+ break;
+ }
+ dr = r = cr = NULL;
+ dr = xmlDocGetRootElement(ctxt->myDoc);
+ if(dr != NULL)
+ r = findnode(dr->children, "Hubs");
+ if(r != NULL)
+ cr = findnode(r->children, "Columns");
+ if(cr == NULL)
+ {
+ msgbox(GTK_MESSAGE_WARNING, GTK_BUTTONS_OK, _("The hub list at %s cannot be understood"), pubhubaddr);
+ break;
+ }
+ for(c = findnode(cr->children, "Column"); c != NULL; c = findnode(c->next, "Column"))
+ {
+ name = (char *)xmlGetProp(c, (xmlChar *)"Name");
+ stype = (char *)xmlGetProp(c, (xmlChar *)"Type");
+ type = G_TYPE_INVALID;
+ if(stype != NULL)
+ {
+ if(!strcmp(stype, "string"))
+ type = G_TYPE_STRING;
+ else if(!strcmp(stype, "int"))
+ type = G_TYPE_INT;
+ else if(!strcmp(stype, "bytes"))
+ type = G_TYPE_INT64;
+ }
+ if((name != NULL) && (type != G_TYPE_INVALID))
+ {
+ names = srealloc(names, (numcols + 1) * sizeof(*names));
+ types = srealloc(types, (numcols + 1) * sizeof(*names));
+ names[numcols] = sstrdup(name);
+ types[numcols] = type;
+ numcols++;
+ }
+ if(name != NULL)
+ xmlFree(name);
+ if(stype != NULL)
+ xmlFree(stype);
+ }
+ if(numcols == 0)
+ {
+ msgbox(GTK_MESSAGE_WARNING, GTK_BUTTONS_OK, _("The hub list at %s did not contain any columns"), pubhubaddr);
+ break;
+ }
+ for(i = 0; i < numcols; i++)
+ {
+ if(!strcmp(names[i], "Address"))
+ {
+ name = names[0];
+ names[0] = names[i];
+ names[i] = name;
+ type = types[0];
+ types[0] = types[i];
+ types[i] = type;
+ break;
+ }
+ }
+ if(i == numcols)
+ {
+ msgbox(GTK_MESSAGE_WARNING, GTK_BUTTONS_OK, _("The hub list at %s did not contain the address to any hubs"));
+ break;
+ }
+ model = gtk_list_store_newv(numcols, types);
+ for(n = findnode(r->children, "Hub"); n != NULL; n = findnode(n->next, "Hub"))
+ {
+ if(!xmlHasProp(n, (xmlChar *)"Address") || !xmlHasProp(n, (xmlChar *)"Name"))
+ continue;
+ if(filterpubhub)
+ {
+ match = 0;
+ attr = (char *)xmlGetProp(n, (xmlChar *)"Name");
+ if(!regexec(&pubhubfilter, attr, 0, NULL, 0))
+ match = 1;
+ xmlFree(attr);
+ if((attr = (char *)xmlGetProp(n, (xmlChar *)"Description")) != NULL)
+ {
+ if(!regexec(&pubhubfilter, attr, 0, NULL, 0))
+ match = 1;
+ xmlFree(attr);
+ }
+ if(!match)
+ continue;
+ }
+ gtk_list_store_append(model, &iter);
+ for(i = 0; i < numcols; i++)
+ {
+ attr = (char *)xmlGetProp(n, (xmlChar *)names[i]);
+ if(attr != NULL)
+ {
+ if(types[i] == G_TYPE_STRING)
+ gtk_list_store_set(model, &iter, i, attr, -1);
+ else if(types[i] == G_TYPE_INT)
+ gtk_list_store_set(model, &iter, i, atoi(attr), -1);
+ else if(types[i] == G_TYPE_INT64)
+ gtk_list_store_set(model, &iter, i, strtoll(attr, NULL, 0), -1);
+ xmlFree(attr);
+ }
+ }
+ }
+ cols = smalloc((numcols - 1) * sizeof(*cols));
+ for(i = 1; i < numcols; i++)
+ cols[i - 1] = i;
+ sortcol = 0;
+ for(i = 0; i < numcols; i++)
+ {
+ if(!strcmp(names[i], "Users"))
+ sortcol = i;
+ }
+ setpubhubmodel(GTK_TREE_MODEL(model), sortcol, numcols - 1, cols, names + 1);
+ free(cols);
+ g_object_unref(model);
+ break;
+ case PHO_FINI:
+ if(ctxt != NULL)
+ {
+ if(ctxt->myDoc != NULL)
+ xmlFreeDoc(ctxt->myDoc);
+ xmlFreeParserCtxt(ctxt);
+ ctxt = NULL;
+ }
+ break;
+ }
+ if(numcols != 0)
+ {
+ for(i = 0; i < numcols; i++)
+ free(names[i]);
+ free(names);
+ free(types);
+ }
+ return(0);
+}
+
+int pubhuboldhandler(int op, char *buf, size_t *len)
+{
+ static GtkListStore *model = NULL;
+ int i;
char *p, *p2;
- char *fields[4];
wchar_t *wbuf;
+ char *fields[4], *names[3];
+ int cols[3];
GtkTreeIter iter;
- int sorted, sortcol;
- GtkSortType sortorder;
- GtkTreeModel *sortmodel;
+
+ switch(op)
+ {
+ case PHO_INIT:
+ model = gtk_list_store_new(4, G_TYPE_STRING, G_TYPE_STRING, G_TYPE_STRING, G_TYPE_INT);
+ break;
+ case PHO_DATA:
+ while((p = memchr(buf, '\n', *len)) != NULL)
+ {
+ *(p++) = 0;
+ for(i = 0, p2 = buf; i < 4; i++) {
+ fields[i] = p2;
+ if((p2 = strchr(p2, '|')) == NULL)
+ break;
+ *(p2++) = 0;
+ }
+ if(i == 4) {
+ for(i = 0; i < 4; i++) {
+ if((wbuf = icsmbstowcs(fields[i], DCCHARSET, NULL)) == NULL) {
+ fields[i] = sstrdup(_("(Invalid character)"));
+ } else {
+ if((fields[i] = icwcstombs(wbuf, "UTF-8")) == NULL)
+ break;
+ }
+ }
+ if(i == 4) {
+ if(!filterpubhub || !regexec(&pubhubfilter, fields[0], 0, NULL, 0) || !regexec(&pubhubfilter, fields[2], 0, NULL, 0)) {
+ gtk_list_store_append(model, &iter);
+ gtk_list_store_set(model, &iter, 0, fields[1], 1, fields[0], 2, fields[2], 3, atoi(fields[3]), -1);
+ }
+ }
+ for(i--; i >= 0; i--)
+ free(fields[i]);
+ }
+ memmove(buf, p, *len -= p - buf);
+ }
+ break;
+ case PHO_EOF:
+ cols[0] = 3; names[0] = _("# users");
+ cols[1] = 1; names[1] = _("Name");
+ cols[2] = 2; names[2] = _("Description");
+ setpubhubmodel(GTK_TREE_MODEL(model), 3, 3, cols, names);
+ break;
+ case PHO_FINI:
+ if(model != NULL)
+ g_object_unref(model);
+ model = NULL;
+ break;
+ }
+ return(0);
+}
+
+void pubhubfdcallback(gpointer data, gint source, GdkInputCondition condition)
+{
+ static char buf[65536];
+ static size_t bufpos = 0;
+ int ret, reset;
if(!(condition & GDK_INPUT_READ))
return;
- if(bufpos == 1024)
+ if(bufpos == sizeof(buf))
bufpos = 0;
ret = read(pubhubfd, buf + bufpos, sizeof(buf) - bufpos);
+ reset = 0;
if(ret <= 0)
{
if(ret < 0)
msgbox(GTK_MESSAGE_ERROR, GTK_BUTTONS_OK, _("Could not read from public hub listing process: %s"), strerror(errno));
- close(pubhubfd);
+ else
+ pubhubhandler(PHO_EOF, NULL, NULL);
+ reset = 1;
+ } else {
+ bufpos += ret;
+ if(pubhubhandler(PHO_DATA, buf, &bufpos))
+ reset = 1;
+ }
+ if(reset)
+ {
+ pubhubhandler(PHO_FINI, NULL, NULL);
+ pubhubhandler = NULL;
gdk_input_remove(pubhubtag);
+ close(pubhubfd);
kill(pubhubproc, SIGINT);
pubhubfd = pubhubtag = -1;
pubhubproc = 0;
regfree(&pubhubfilter);
filterpubhub = 0;
}
- return;
- }
- bufpos += ret;
- sortmodel = gtk_tree_view_get_model(GTK_TREE_VIEW(main_phublist));
- sorted = gtk_tree_sortable_get_sort_column_id(GTK_TREE_SORTABLE(sortmodel), &sortcol, &sortorder);
- gtk_tree_view_set_model(GTK_TREE_VIEW(main_phublist), NULL);
- while((p = memchr(buf, '\n', bufpos)) != NULL)
- {
- *(p++) = 0;
- if(!filterpubhub || !regexec(&pubhubfilter, buf, 0, NULL, 0))
- {
- p2 = buf;
- for(i = 0; i < 4; i++)
- {
- fields[i] = p2;
- if((p2 = strchr(p2, '|')) == NULL)
- break;
- *(p2++) = 0;
- }
- if(i == 4)
- {
- for(i = 0; i < 4; i++)
- {
- if((wbuf = icsmbstowcs(fields[i], DCCHARSET, NULL)) == NULL)
- {
- msgbox(GTK_MESSAGE_ERROR, GTK_BUTTONS_OK, _("Could not decode hublist - aborting at this point: %s"), strerror(errno));
- kill(pubhubproc, SIGINT);
- break;
- }
- if((fields[i] = icwcstombs(wbuf, "UTF-8")) == NULL)
- break;
- }
- if(i == 4)
- {
- gtk_list_store_append(pubhubmodel, &iter);
- gtk_list_store_set(pubhubmodel, &iter, 0, fields[0], 1, fields[1], 2, fields[2], 3, atoi(fields[3]), -1);
- }
- for(i--; i >= 0; i--)
- free(fields[i]);
- }
- }
- memmove(buf, p, bufpos -= p - buf);
}
- sortmodel = gtk_tree_model_sort_new_with_model(GTK_TREE_MODEL(pubhubmodel));
- if(sorted)
- gtk_tree_sortable_set_sort_column_id(GTK_TREE_SORTABLE(sortmodel), sortcol, sortorder);
- gtk_tree_view_set_model(GTK_TREE_VIEW(main_phublist), sortmodel);
}
void cb_main_pubhubfilter_activate(GtkWidget *widget, gpointer data)
{
int pipe1[2], pipe2[2];
int len, err;
- const char *buf;
+ const char *buf, *p;
char errbuf[1024];
if(pubhubtag >= 0)
close(pubhubfd);
if(pubhubproc > 0)
kill(pubhubproc, SIGINT);
+ if(pubhubhandler != NULL)
+ {
+ pubhubhandler(PHO_FINI, NULL, NULL);
+ pubhubhandler = NULL;
+ }
if(filterpubhub)
{
regfree(&pubhubfilter);
}
filterpubhub = 1;
}
- gtk_list_store_clear(pubhubmodel);
pipe(pipe1);
if((pubhubproc = fork()) == 0)
{
close(pipe1[1]);
pubhubfd = pipe1[0];
len = strlen(pubhubaddr);
- if((len > 4) && !strcmp(pubhubaddr + len - 4, ".bz2"))
+ p = pubhubaddr + len;
+ if((len > 4) && !strncmp(p - 4, ".bz2", 4))
{
+ p -= 4;
+ len -= 4;
pipe(pipe2);
if(fork() == 0)
{
close(pipe2[1]);
pubhubfd = pipe2[0];
}
+ if((len > 4) && !strncmp(p - 4, ".xml", 4))
+ {
+ p -= 4;
+ len -= 4;
+ pubhubhandler = pubhubxmlhandler;
+ } else {
+ pubhubhandler = pubhuboldhandler;
+ }
+ pubhubhandler(PHO_INIT, NULL, NULL);
pubhubtag = gdk_input_add(pubhubfd, GDK_INPUT_READ, pubhubfdcallback, NULL);
}
if(!gtk_tree_selection_get_selected(gtk_tree_view_get_selection(GTK_TREE_VIEW(main_phublist)), &model, &iter))
return;
- gtk_tree_model_get(GTK_TREE_MODEL(model), &iter, 1, &addr, -1);
+ gtk_tree_model_get(GTK_TREE_MODEL(model), &iter, 0, &addr, -1);
gtk_entry_set_text(GTK_ENTRY(main_fnaddr), addr);
g_free(addr);
}
model = gtk_tree_view_get_model(GTK_TREE_VIEW(widget));
if(!gtk_tree_model_get_iter(GTK_TREE_MODEL(model), &iter, path))
return;
- gtk_tree_model_get(GTK_TREE_MODEL(model), &iter, 1, &buf, -1);
+ gtk_tree_model_get(GTK_TREE_MODEL(model), &iter, 0, &buf, -1);
if(strchr(buf, ':') == NULL)
{
buf = g_realloc(buf, strlen(buf) + 5);
msgbox(GTK_MESSAGE_WARNING, GTK_BUTTONS_OK, _("You do not have permission to do that"));
if(resp->code == 509)
msgbox(GTK_MESSAGE_WARNING, GTK_BUTTONS_OK, _("The server could not parse that address"));
+ if(resp->code == 515)
+ msgbox(GTK_MESSAGE_WARNING, GTK_BUTTONS_OK, _("There are too many hubs connected"));
dc_freeresp(resp);
}
handleresps();
}
}
+void cb_main_srcopy_activate(GtkWidget *widget, gpointer data)
+{
+ GtkClipboard *cb;
+ GtkTreeSelection *sel;
+ GtkTreeModel *model;
+ GtkTreeIter iter;
+ char *hash;
+
+ if(nextsrch != -1)
+ return;
+ sel = gtk_tree_view_get_selection(GTK_TREE_VIEW(main_srchres));
+ if(!gtk_tree_selection_get_selected(sel, &model, &iter))
+ return;
+ gtk_tree_model_get(model, &iter, 9, &hash, -1);
+ cb = gtk_clipboard_get(gdk_atom_intern("PRIMARY", FALSE));
+ gtk_clipboard_set_text(cb, hash, -1);
+ g_free(hash);
+}
+
void cb_main_trhash_activate(GtkWidget *widget, gpointer data)
{
GtkTreeSelection *sel;
}
}
+void cb_main_trcopy_activate(GtkWidget *widget, gpointer data)
+{
+ GtkClipboard *cb;
+ GtkTreeSelection *sel;
+ GtkTreeModel *model;
+ GtkTreeIter iter;
+ char *hash;
+
+ sel = gtk_tree_view_get_selection(GTK_TREE_VIEW(main_downloads));
+ if(!gtk_tree_selection_get_selected(sel, &model, &iter))
+ return;
+ gtk_tree_model_get(model, &iter, 12, &hash, -1);
+ cb = gtk_clipboard_get(gdk_atom_intern("PRIMARY", FALSE));
+ gtk_clipboard_set_text(cb, hash, -1);
+ g_free(hash);
+}
+
void cb_main_trcancel_activate(GtkWidget *widget, gpointer data)
{
GtkTreeSelection *sel;
if(gtk_tree_selection_get_selected(sel, &model, &iter))
{
gtk_tree_model_get(model, &iter, 9, &hash, -1);
- if((nextsrch != -1) || (hash == NULL) || (*hash == 0))
+ if((hash == NULL) || (*hash == 0))
+ {
gtk_widget_set_sensitive(main_srhash, FALSE);
- else
- gtk_widget_set_sensitive(main_srhash, TRUE);
+ gtk_widget_set_sensitive(main_srcopy, FALSE);
+ } else {
+ if(nextsrch == -1)
+ gtk_widget_set_sensitive(main_srhash, TRUE);
+ else
+ gtk_widget_set_sensitive(main_srhash, FALSE);
+ gtk_widget_set_sensitive(main_srcopy, TRUE);
+ }
g_free(hash);
} else {
return(FALSE);
if(gtk_tree_selection_get_selected(sel, &model, &iter))
{
gtk_tree_model_get(model, &iter, 12, &hash, -1);
- if((nextsrch != -1) || (hash == NULL) || (*hash == 0))
+ if((hash == NULL) || (*hash == 0))
+ {
gtk_widget_set_sensitive(main_trhash, FALSE);
- else
- gtk_widget_set_sensitive(main_trhash, TRUE);
+ gtk_widget_set_sensitive(main_trcopy, FALSE);
+ } else {
+ if(nextsrch == -1)
+ gtk_widget_set_sensitive(main_trhash, TRUE);
+ else
+ gtk_widget_set_sensitive(main_trhash, FALSE);
+ gtk_widget_set_sensitive(main_trcopy, TRUE);
+ }
g_free(hash);
} else {
return(FALSE);
return(FALSE);
}
+void cb_reslist_reload_clicked(GtkWidget *widget, gpointer data)
+{
+ if(lsrestag != -1)
+ return;
+ gtk_widget_set_sensitive(reslist_delete, FALSE);
+ gtk_widget_set_sensitive(reslist_search, FALSE);
+ gtk_list_store_clear(reslist);
+ lsrestag = dc_queuecmd(NULL, NULL, L"filtercmd", L"lsres", NULL);
+ gtk_widget_set_sensitive(reslist_reload, FALSE);
+}
+
+int rmres(char *id)
+{
+ int tag, ret;
+ struct dc_response *resp;
+
+ ret = -1;
+ tag = dc_queuecmd(NULL, NULL, L"filtercmd", L"rmres", L"%%s", id, NULL);
+ if((resp = dc_gettaggedrespsync(tag)) != NULL)
+ {
+ if(resp->numlines > 0)
+ {
+ if(!wcscmp(resp->rlines[0].argv[1], L"ok"))
+ ret = 0;
+ else if(!wcsncmp(resp->rlines[0].argv[1], L"err:", 4))
+ msgbox(GTK_MESSAGE_WARNING, GTK_BUTTONS_OK, _("An error occurred (%ls)"), resp->rlines[0].argv[1] + 4);
+ }
+ dc_freeresp(resp);
+ }
+ handleresps();
+ return(ret);
+}
+
+void cb_reslist_delete_clicked(GtkWidget *widget, gpointer data)
+{
+ GtkTreeIter iter;
+ GtkTreeModel *model;
+ char *id;
+ gboolean locked;
+
+ if(nextsrch != -1)
+ return;
+ if(!gtk_tree_selection_get_selected(gtk_tree_view_get_selection(GTK_TREE_VIEW(reslist_list)), &model, &iter))
+ return;
+ gtk_tree_model_get(GTK_TREE_MODEL(model), &iter, 0, &id, 4, &locked, -1);
+ if(locked)
+ {
+ g_free(id);
+ return;
+ }
+ if(!rmres(id))
+ gtk_list_store_remove(GTK_LIST_STORE(model), &iter);
+ g_free(id);
+}
+
+void cb_reslist_search_clicked(GtkWidget *widget, gpointer data)
+{
+ GtkTreeIter iter;
+ GtkTreeModel *model;
+ char *hash, *buf;
+
+ if(nextsrch != -1)
+ return;
+ if(!gtk_tree_selection_get_selected(gtk_tree_view_get_selection(GTK_TREE_VIEW(reslist_list)), &model, &iter))
+ return;
+ gtk_tree_model_get(GTK_TREE_MODEL(model), &iter, 5, &hash, -1);
+ buf = sprintf2("H=%s", hash);
+ gtk_entry_set_text(GTK_ENTRY(main_realsrch), buf);
+ free(buf);
+ g_free(hash);
+ cb_main_srchbtn_clicked(widget, NULL);
+}
+
+void cb_reslist_list_cchange(GtkWidget *widget, gpointer data)
+{
+ GtkTreeIter iter;
+ GtkTreeModel *model;
+ gboolean locked;
+ char *hash;
+
+ if(!gtk_tree_selection_get_selected(gtk_tree_view_get_selection(GTK_TREE_VIEW(reslist_list)), &model, &iter))
+ {
+ gtk_widget_set_sensitive(reslist_delete, FALSE);
+ gtk_widget_set_sensitive(reslist_search, FALSE);
+ return;
+ }
+ gtk_tree_model_get(GTK_TREE_MODEL(model), &iter, 4, &locked, 5, &hash, -1);
+ gtk_widget_set_sensitive(reslist_delete, !locked);
+ gtk_widget_set_sensitive(reslist_search, hash && *hash);
+ g_free(hash);
+}
+
+void cb_reslist_list_activate(GtkWidget *widget, GtkTreePath *path, GtkTreeViewColumn *col, gpointer data)
+{
+ GtkTreeIter iter;
+ GtkTreeModel *model;
+ char *hash, *buf;
+
+ model = gtk_tree_view_get_model(GTK_TREE_VIEW(widget));
+ if(!gtk_tree_model_get_iter(GTK_TREE_MODEL(model), &iter, path))
+ return;
+ if(nextsrch != -1)
+ return;
+ gtk_tree_model_get(model, &iter, 5, &hash, -1);
+ buf = sprintf2("H=%s", hash);
+ gtk_entry_set_text(GTK_ENTRY(main_realsrch), buf);
+ free(buf);
+ g_free(hash);
+ cb_main_srchbtn_clicked(widget, NULL);
+}
+
+gboolean cb_reslist_list_keypress(GtkWidget *widget, GdkEventKey *event, gpointer data)
+{
+ GtkTreeSelection *sel;
+ GtkTreeModel *model;
+ GtkTreeIter iter;
+ char *id;
+ gboolean locked;
+
+ if((event->type == GDK_KEY_PRESS) && (event->keyval == GDK_Delete))
+ {
+ sel = gtk_tree_view_get_selection(GTK_TREE_VIEW(widget));
+ if(gtk_tree_selection_get_selected(sel, &model, &iter))
+ {
+ gtk_tree_model_get(model, &iter, 0, &id, 4, &locked, -1);
+ if(!locked)
+ {
+ if(!rmres(id))
+ gtk_list_store_remove(GTK_LIST_STORE(model), &iter);
+ }
+ g_free(id);
+ }
+ return(TRUE);
+ }
+ return(FALSE);
+}
+
void srchstatupdate(void)
{
char buf[1024];
gtk_init(&argc, &argv);
dc_init();
signal(SIGCHLD, SIG_IGN);
- pubhubaddr = sstrdup("http://www.neo-modus.com/PublicHubList.config");
- dcserver = sstrdup("localhost");
+ pubhubaddr = sstrdup("http://www.hublist.org/PublicHubList.xml.bz2");
+ dcserver = sstrdup("");
if((pwent = getpwuid(getuid())) == NULL)
{
fprintf(stderr, "could not get your passwd data");
}
connectas = sstrdup(pwent->pw_name);
wnd = create_main_wnd();
+ create_reslist_wnd();
+ gtk_window_resize(GTK_WINDOW(reslist_wnd), 600, 400);
initchattags();
fnmodel = gtk_list_store_new(6, G_TYPE_INT, G_TYPE_STRING, G_TYPE_INT, G_TYPE_INT, G_TYPE_STRING, G_TYPE_STRING);
gtk_tree_view_set_model(GTK_TREE_VIEW(main_fnetnodes), GTK_TREE_MODEL(fnmodel));
gtk_tree_view_set_model(GTK_TREE_VIEW(main_chatnodes), GTK_TREE_MODEL(fnmodel));
-
- pubhubmodel = gtk_list_store_new(4, G_TYPE_STRING, G_TYPE_STRING, G_TYPE_STRING, G_TYPE_INT);
- sortmodel = gtk_tree_model_sort_new_with_model(GTK_TREE_MODEL(pubhubmodel));
- gtk_tree_sortable_set_sort_column_id(GTK_TREE_SORTABLE(sortmodel), 3, GTK_SORT_DESCENDING);
- gtk_tree_view_set_model(GTK_TREE_VIEW(main_phublist), GTK_TREE_MODEL(sortmodel));
- g_object_unref(sortmodel);
-
+
+ reslist = gtk_list_store_new(6, G_TYPE_STRING, G_TYPE_INT, G_TYPE_INT, G_TYPE_STRING, G_TYPE_BOOLEAN, G_TYPE_STRING);
+ gtk_tree_view_set_model(GTK_TREE_VIEW(reslist_list), GTK_TREE_MODEL(reslist));
+
dlmodel = gtk_list_store_new(13, G_TYPE_INT, /* id */
G_TYPE_INT, /* dir */
G_TYPE_INT, /* state */
dcconnect(dcserver);
g_timeout_add(500, srchstatupdatecb, NULL);
g_timeout_add(5000, ksupdatecb, NULL);
+ g_timeout_add(1000, updatetransfers, NULL);
gtk_main();
return(0);
}
Dolda2000 GitWeb / doldaconnect.git / blobdiff