aboutsummaryrefslogtreecommitdiffstats
path: root/mail/mail-ops.c
blob: 489dda44022fa4e04643040bd0c43ac30b4eec95 (plain) (blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
695
696
697
698
699
700
/*
 * gnlp.c: LPQ/LPR stuff
 */

#include <sys/types.h>
#include <sys/stat.h>
#include <dirent.h>
#include <stdio.h>
#include <errno.h>
#include <unistd.h>
#include <time.h>
#include <string.h>

#include <gnome.h>
#include <config.h>

#include "gncal.h"
#include "calcs.h"
#include "clist.h"
#include "gncal-week-view.h"

void
prueba (void)
{
    GtkWidget *window;
    GtkWidget *wview;

    window = gtk_window_new (GTK_WINDOW_TOPLEVEL);
    gtk_window_set_policy (GTK_WINDOW (window), TRUE, TRUE, FALSE);
    gtk_container_border_width (GTK_CONTAINER (window), 6);

    wview = gncal_week_view_new (NULL, time (NULL));
    gtk_container_add (GTK_CONTAINER (window), wview);
    gtk_widget_show (wview);

    gtk_widget_show (window);
}

/* Function declarations */
void parse_args(int argc, char *argv[]);
static int save_state      (GnomeClient        *client,
                gint                phase,
                GnomeRestartStyle   save_style,
                gint                shutdown,
                GnomeInteractStyle  interact_style,
                gint                fast,
                gpointer            client_data);
static void connect_client (GnomeClient *client, 
                gint         was_restarted, 
                gpointer     client_data);

void discard_session (gchar *id);

static GtkMenuEntry menu_items[] =
{
        { N_("File/Exit"), N_("<control>Q"), menu_file_quit, NULL},
        { N_("Help/About"), N_("<control>A"), menu_help_about, NULL},
};

#define DAY_ARRAY_MAX 35
/* The naughty global variables */
int curr_day, old_day;
int curr_month, old_month;
int curr_year, old_year;
GtkWidget *month_label;
GtkWidget *year_label;
GtkWidget *dailylist;
GtkWidget *calendar_days[DAY_ARRAY_MAX];
GtkWidget *calendar_buttons[DAY_ARRAY_MAX];
GtkWidget *app;
GtkWidget *calendar;

int restarted = 0;
/* Stuff we use for session state */
int os_x = 0,
    os_y = 0,
    os_w = 0,
    os_h = 0;


/* True if parsing determined that all the work is already done.  */
int just_exit = 0;

/* These are the arguments that our application supports.  */
static struct argp_option arguments[] =
{
#define DISCARD_KEY -1
  { "discard-session", DISCARD_KEY, N_("ID"), 0, N_("Discard session"), 1 },
  { NULL, 0, NULL, 0, NULL, 0 }
};

/* Forward declaration of the function that gets called when one of
   our arguments is recognized.  */
static error_t parse_an_arg (int key, char *arg, struct argp_state *state);

/* This structure defines our parser.  It can be used to specify some
   options for how our parsing function should be called.  */
static struct argp parser =
{
  arguments,            /* Options.  */
  parse_an_arg,         /* The parser function.  */
  NULL,             /* Some docs.  */
  NULL,             /* Some more docs.  */
  NULL,             /* Child arguments -- gnome_init fills
                   this in for us.  */
  NULL,             /* Help filter.  */
  NULL              /* Translation domain; for the app it
                   can always be NULL.  */
};

#define ELEMENTS(x) (sizeof (x) / sizeof (x [0]))

GtkMenuFactory *
create_menu () 
{
  GtkMenuFactory *subfactory;
  int i;

  subfactory = gtk_menu_factory_new  (GTK_MENU_FACTORY_MENU_BAR);
  gtk_menu_factory_add_entries (subfactory, menu_items, ELEMENTS(menu_items));

  return subfactory;
}

/* place marker until i get get something better */
void print_error(char *text)
{
    GtkWidget *msgbox;
    char buf[512];

    if (errno == 0)
        sprintf(buf, "%s", text);
    else
        sprintf(buf, "%s (%s)", text, g_strerror(errno));

    g_warning("%s\n", buf);
    msgbox = gnome_message_box_new(buf, "error", "OK", NULL, NULL);

    gtk_widget_show(msgbox);
}


void menu_file_quit(GtkWidget *widget, gpointer data)
{
    gtk_main_quit();
}

void menu_help_about(GtkWidget *widget, gpointer data)
{
    GtkWidget *about;
    gchar *authors[] = {
        "Craig Small <csmall@small.dropbear.id.au>",
        NULL };
    about = gnome_about_new( _("Gnome Calendar"), VERSION,
                "(C) 1998",
                authors,
                /* Comments */
                _("This program shows a nice pretty "
                "calendar and will do scheduling "
                "real soon now!"),
                NULL);
                
    gtk_widget_show(about);
}

void dailylist_item_select(GtkWidget *widget, gpointer data)
{
    int *x = (int*)data;

    g_print("Selected %d\n", x);
}

void update_today_list(void)
{
    GtkWidget *listitem;
    GtkWidget *list_hbox;
    GtkWidget *hour_label;
    GtkWidget *event_label;
    char buf[50];
    int tmphr, tmpmin,i;

}

/*
 * updates the calendar that appears in the left collumn
 */
void month_changed(GtkWidget *widget, gpointer data)
{
    curr_month = GTK_CALENDAR(widget)->month;
    curr_year = GTK_CALENDAR(widget)->year;
}

void update_calendar()
{
    int tmpday;
    int i;
    char buf[50];
    int month_changed;
    static int offset;

    gtk_calendar_unmark_day(GTK_CALENDAR(calendar),old_day);
    gtk_calendar_mark_day(GTK_CALENDAR(calendar), curr_day);
    printf("Date changed (nothing happens much\n");
/*  gtk_calendar_select_day(GTK_CALENDAR(calendar), curr_day); */
#if 0
    /* Only update the whole calendar if the year or month has changed */
    tmpday=1;
    month_changed = FALSE;
    if (curr_month != old_month || curr_year != old_year)  {
        month_changed = TRUE;
        offset = weekday_of_date(tmpday, curr_month, curr_year) - 1;
    }

    for(i=0; i < DAY_ARRAY_MAX; i++) {
            tmpday = i - offset +1;
        if (valid_date(tmpday, curr_month, curr_year)) {
            sprintf(buf, "%2d", tmpday);
            /*if (month_changed) {*/
                gtk_label_set(GTK_LABEL(calendar_days[i]), buf);
                gtk_widget_show(calendar_buttons[i]);
            /*}*/
            if (tmpday == curr_day) {
                gtk_container_border_width(GTK_CONTAINER(calendar_buttons[i]), 2);
                gtk_widget_show(calendar_buttons[i]);
            } else {
                gtk_container_border_width(GTK_CONTAINER(calendar_buttons[i]), 0);
            }
        } else if (month_changed) {
            gtk_label_set(GTK_LABEL(calendar_days[i]), "");
            gtk_widget_hide(calendar_buttons[i]);
            gtk_container_border_width(GTK_CONTAINER(calendar_buttons[i]), 0);
        }
    } /* for i */   
#endif /* 0 */
}

/*
 * Updates all the main window widgets when the current day of interest is
 * changed
 */
void update_today(void)
{
    char buf[50];

    /* This needs to be fixed to get the right date order for the country*/
/*  if (curr_month != old_month) {
        gtk_label_set(GTK_LABEL(month_label), month_name(curr_month));
    }
    if (curr_year != old_year) {
        sprintf(buf, "%4d", curr_year);
        gtk_label_set(GTK_LABEL(year_label), buf);
    }*/
    update_today_list();
    update_calendar();
}

void next_day_but_clicked(GtkWidget *widget, gpointer data)
{
    old_day = curr_day;
    old_month = curr_month;
    old_year = curr_year;
    next_date(&curr_day, &curr_month, &curr_year);
    update_today();
}

void prev_day_but_clicked(GtkWidget *widget, gpointer data)
{
    old_day = curr_day;
    old_month = curr_month;
    old_year = curr_year;
    prev_date(&curr_day, &curr_month, &curr_year);
    update_today();
}

void today_but_clicked(GtkWidget *widget, gpointer data)
{
    old_day = curr_day;
    old_month = curr_month;
    old_year = curr_year;
    get_system_date(&curr_day, &curr_month, &curr_year);
    update_today();
}

void prev_month_but_clicked(GtkWidget *widget, gpointer data)
{
    if (curr_year == 0 && curr_month == MONTH_MIN) 
        return;
    old_day = curr_day;
    old_month = curr_month;
    old_year = curr_year;
    curr_month--;
    if (curr_month < MONTH_MIN) {
        curr_month = MONTH_MAX;
        curr_year--;
    }
    update_today();
}

void next_month_but_clicked(GtkWidget *widget, gpointer data)
{
    if (curr_year == 3000 && curr_month == MONTH_MAX) 
        return;
    old_day = curr_day;
    old_month = curr_month;
    old_year = curr_year;
    curr_month++;
    if (curr_month > MONTH_MAX ) {
        curr_month = MONTH_MIN;
        curr_year++;
    }
    update_today();
}

void prev_year_but_clicked(GtkWidget *widget, gpointer data)
{
    if (curr_year == 0) 
        return;

    old_day = curr_day;
    old_month = curr_month;
    old_year = curr_year;
    curr_year--;
    update_today();
}

    
void next_year_but_clicked(GtkWidget *widget, gpointer data)
{
    if (curr_year == 3000) 
        return;

    old_day = curr_day;
    old_month = curr_month;
    old_year = curr_year;
    curr_year++;
    update_today();
}


void calendar_but_clicked(GtkWidget *widget, gpointer data)
{
    char *ptr; 
    int x;

    ptr = GTK_LABEL(GTK_BUTTON(widget)->child)->label;
    x = atoi(ptr);

    if (valid_date(x, curr_month, curr_year)) {
        old_day = curr_day;
        old_month = curr_month;
        old_year = curr_year;
        curr_day = x;
        update_today();
    }
}

void test_foreach(GtkWidget *widget, gpointer data)
{
    char *ptr;

    ptr = GTK_LABEL(GTK_BUTTON(widget)->child)->label;
    g_print("%s\n", ptr);
}

void show_main_window()
{
    GtkWidget *main_vbox;
    /*GtkWidget *menubar;
    GtkAcceleratorTable *accel;*/
    GtkMenuFactory *menuf;
    GtkWidget *main_hbox;
    GtkWidget *left_vbox;
    GtkWidget *right_vbox;
    GtkWidget *date_hbox;
    GtkWidget *prev_mth_but;
    GtkWidget *next_mth_but;
    GtkWidget *prev_year_but;
    GtkWidget *next_year_but;
    GtkWidget *day_but_hbox;
    GtkWidget *prev_day_but;
    GtkWidget *today_but;
    GtkWidget *next_day_but;
    GtkWidget *separator;
    GtkWidget *cal_table;
    GtkWidget *day_name_label;
    GtkWidget *scrolledwindow;
    GtkWidget *scroll_hbox;
    GtkWidget *hour_list;
    GtkWidget *list_item;
    GtkWidget *dailylist_item;
    GtkWidget *event_label;
    int i,j;
    struct tm tm;
    char buf[50];

    bzero((char*)&tm, sizeof(struct tm));
    app = gnome_app_new("gncal", "Gnome Calendar");
    gtk_widget_realize(app);
    gtk_signal_connect(GTK_OBJECT(app), "delete_event",
               GTK_SIGNAL_FUNC(menu_file_quit), NULL);
    if (restarted) {
        gtk_widget_set_uposition(app, os_x, os_y);
        gtk_widget_set_usize(app, os_w, os_h);
    } else {
        gtk_widget_set_usize(app,300,300);
    }
    main_vbox = gtk_vbox_new(FALSE, 1);
    gnome_app_set_contents(GNOME_APP(app), main_vbox);
    gtk_widget_show(main_vbox);

    menuf = create_menu();
    gnome_app_set_menus(GNOME_APP(app), GTK_MENU_BAR(menuf->widget));

    main_hbox = gtk_hbox_new(FALSE,1);
    gtk_box_pack_start(GTK_BOX(main_vbox), main_hbox, TRUE, TRUE, 0);
    gtk_widget_show(main_hbox);

    left_vbox = gtk_vbox_new(FALSE, 1);
    gtk_box_pack_start(GTK_BOX(main_hbox), left_vbox, FALSE, TRUE,0);
    gtk_widget_show(left_vbox);

    separator = gtk_vseparator_new();
    gtk_box_pack_start(GTK_BOX(main_hbox), separator, FALSE, TRUE, 0);
    gtk_widget_show(separator);

    right_vbox = gtk_vbox_new(FALSE, 1);
    gtk_box_pack_start(GTK_BOX(main_hbox), right_vbox, TRUE, TRUE, 0);
    gtk_widget_show(right_vbox);

    date_hbox = gtk_hbox_new(FALSE, 1);
    gtk_box_pack_start(GTK_BOX(left_vbox), date_hbox, FALSE, FALSE, 0);
    gtk_widget_show(date_hbox);
/*
    prev_mth_but = gtk_button_new_with_label("<");
    gtk_box_pack_start(GTK_BOX(date_hbox), prev_mth_but, FALSE, FALSE, 0);
    gtk_signal_connect(GTK_OBJECT(prev_mth_but), "clicked", GTK_SIGNAL_FUNC(prev_month_but_clicked), NULL);
    gtk_widget_show(prev_mth_but);

    month_label = gtk_label_new("Fooary");
    gtk_box_pack_start(GTK_BOX(date_hbox), month_label, TRUE, FALSE, 0);
    gtk_widget_show(month_label);

    next_mth_but = gtk_button_new_with_label(">");
    gtk_box_pack_start(GTK_BOX(date_hbox), next_mth_but, FALSE, FALSE, 0);
    gtk_signal_connect(GTK_OBJECT(next_mth_but), "clicked", GTK_SIGNAL_FUNC(next_month_but_clicked), NULL);
    gtk_widget_show(next_mth_but);

    prev_year_but = gtk_button_new_with_label("<");
    gtk_box_pack_start(GTK_BOX(date_hbox), prev_year_but, FALSE, FALSE, 0);
    gtk_signal_connect(GTK_OBJECT(prev_year_but), "clicked", GTK_SIGNAL_FUNC(prev_year_but_clicked), NULL);
    gtk_widget_show(prev_year_but);

    year_label = gtk_label_new("1971");
    gtk_box_pack_start(GTK_BOX(date_hbox), year_label, TRUE, FALSE, 0);
    gtk_widget_show(year_label);
    
    next_year_but = gtk_button_new_with_label(">");
    gtk_box_pack_start(GTK_BOX(date_hbox), next_year_but, FALSE, FALSE, 0);
    gtk_signal_connect(GTK_OBJECT(next_year_but), "clicked", GTK_SIGNAL_FUNC(next_year_but_clicked), NULL);
    gtk_widget_show(next_year_but);
*/
    /* Build up the calendar table */
/*  cal_table = gtk_table_new(7,7,TRUE);
    gtk_box_pack_start(GTK_BOX(left_vbox), cal_table, FALSE, FALSE, 0);
    gtk_widget_show(cal_table);

    for(i=DAY_MIN; i <= DAY_MAX; i++) {
        day_name_label = gtk_label_new(short3_day_name(i));
        gtk_table_attach_defaults(GTK_TABLE(cal_table), day_name_label, i-1, i, 0, 1);
        gtk_widget_show(day_name_label);
    }
    for(j=0; j < 5; j++) {
        for(i=0; i < 7; i++) {
            calendar_buttons[i+j*7] = gtk_button_new();
            gtk_container_border_width(GTK_CONTAINER(calendar_buttons[i+j*7]), 0);
            gtk_table_attach_defaults(GTK_TABLE(cal_table), calendar_buttons[i+j*7], i, i+1, j+2, j+3);
            gtk_signal_connect(GTK_OBJECT(calendar_buttons[i+j*7]), "clicked",  GTK_SIGNAL_FUNC(calendar_but_clicked), NULL);
            gtk_widget_show(calendar_buttons[i+j*7]);
            calendar_days[i+j*7] = gtk_label_new("");
            gtk_container_add(GTK_CONTAINER(calendar_buttons[i+j*7]), calendar_days[i+j*7]);
            gtk_widget_show(calendar_days[i+j*7]);
        }
    }
*/
    calendar = gtk_calendar_new();
    gtk_calendar_display_options(GTK_CALENDAR(calendar), GTK_CALENDAR_SHOW_DAY_NAMES | GTK_CALENDAR_SHOW_HEADING);
    gtk_box_pack_start(GTK_BOX(left_vbox), calendar, FALSE, FALSE, 0);
    gtk_signal_connect(GTK_OBJECT(calendar), "month_changed",
        GTK_SIGNAL_FUNC(month_changed), NULL);
    gtk_widget_show(calendar);


    day_but_hbox = gtk_hbox_new(TRUE, 1);
    gtk_box_pack_start(GTK_BOX(left_vbox), day_but_hbox, FALSE, FALSE, 0);
    gtk_widget_show(day_but_hbox);

    prev_day_but = gtk_button_new_with_label("Prev");
    gtk_box_pack_start(GTK_BOX(day_but_hbox), prev_day_but, TRUE, TRUE, 0);
    gtk_signal_connect(GTK_OBJECT(prev_day_but), "clicked", GTK_SIGNAL_FUNC(prev_day_but_clicked), NULL);
    gtk_widget_show(prev_day_but);
    
    today_but = gtk_button_new_with_label("Today");
    gtk_box_pack_start(GTK_BOX(day_but_hbox), today_but, TRUE, TRUE, 0);
    gtk_signal_connect(GTK_OBJECT(today_but), "clicked", GTK_SIGNAL_FUNC(today_but_clicked), NULL);
    gtk_widget_show(today_but);
    
    next_day_but = gtk_button_new_with_label("Next");
    gtk_box_pack_start(GTK_BOX(day_but_hbox), next_day_but, TRUE, TRUE, 0);
    gtk_signal_connect(GTK_OBJECT(next_day_but), "clicked", GTK_SIGNAL_FUNC(next_day_but_clicked), NULL);
    gtk_widget_show(next_day_but);


    dailylist = create_clist();
    gtk_box_pack_start(GTK_BOX(right_vbox), dailylist, TRUE, TRUE, 0);
    gtk_widget_show(dailylist);
    setup_clist(dailylist);

    gtk_widget_show(app);

}


int 
main(int argc, char *argv[])
{
    GnomeClient *client;

    argp_program_version = VERSION;


    /* Initialise the i18n stuff */
    bindtextdomain(PACKAGE, GNOMELOCALEDIR);
    textdomain(PACKAGE);

    /* This create a default client and arrages for it to parse some
       command line arguments
     */
    client = gnome_client_new_default();

    /* Arrange to be told when something interesting happens.  */
    gtk_signal_connect (GTK_OBJECT (client), "save_yourself",
              GTK_SIGNAL_FUNC (save_state), (gpointer) argv[0]);
    gtk_signal_connect (GTK_OBJECT (client), "connect",
              GTK_SIGNAL_FUNC (connect_client), NULL);

    gnome_init("gncal", &parser, argc, argv, 0, NULL);

    show_main_window();

    /* Initialse date to the current day */
    old_day = old_month = old_year = 0;
    get_system_date(&curr_day, &curr_month, &curr_year);
    update_today();

    prueba ();

    gtk_main();

    return 0;
}

static error_t
parse_an_arg (int key, char *arg, struct argp_state *state)
{
  if (key == DISCARD_KEY)
    {
      discard_session (arg);
      just_exit = 1;
      return 0;
    }

  /* We didn't recognize it.  */
  return ARGP_ERR_UNKNOWN;
}


/* Session Management routines */


static int
save_state (GnomeClient        *client,
        gint                phase,
        GnomeRestartStyle   save_style,
        gint                shutdown,
        GnomeInteractStyle  interact_style,
        gint                fast,
        gpointer            client_data)
{
  gchar *session_id;
  gchar *sess;
  gchar *buf;
  gchar *argv[3];
  gint x, y, w, h;

  session_id= gnome_client_get_id (client);

  /* The only state that gnome-hello has is the window geometry. 
     Get it. */
  gdk_window_get_geometry (app->window, &x, &y, &w, &h, NULL);

  /* Save the state using gnome-config stuff. */
  sess = g_copy_strings ("/gncal/Saved-Session-",
                         session_id,
                         NULL);

  buf = g_copy_strings ( sess, "/x", NULL);
  gnome_config_set_int (buf, x);
  g_free(buf);
  buf = g_copy_strings ( sess, "/y", NULL);
  gnome_config_set_int (buf, y);
  g_free(buf);
  buf = g_copy_strings ( sess, "/w", NULL);
  gnome_config_set_int (buf, w);
  g_free(buf);
  buf = g_copy_strings ( sess, "/h", NULL);
  gnome_config_set_int (buf, h);
  g_free(buf);

  gnome_config_sync();
  g_free(sess);

  /* Here is the real SM code. We set the argv to the parameters needed
     to restart/discard the session that we've just saved and call
     the gnome_session_set_*_command to tell the session manager it. */
  argv[0] = (char*) client_data;
  argv[1] = "--discard-session";
  argv[2] = session_id;
  gnome_client_set_discard_command (client, 3, argv);

  /* Set commands to clone and restart this application.  Note that we
     use the same values for both -- the session management code will
     automatically add whatever magic option is required to set the
     session id on startup.  */
  gnome_client_set_clone_command (client, 1, argv);
  gnome_client_set_restart_command (client, 1, argv);

  g_print("save state\n");
  return TRUE;
}

/* Connected to session manager. If restarted from a former session:
   reads the state of the previous session. Sets os_* (prepare_app
   uses them) */
void
connect_client (GnomeClient *client, gint was_restarted, gpointer client_data)
{
  gchar *session_id;

  /* Note that information is stored according to our *old*
     session id.  The id can change across sessions.  */
  session_id = gnome_client_get_previous_id (client);

  if (was_restarted && session_id != NULL)
    {
      gchar *sess;
      gchar *buf;

      restarted = 1;

      sess = g_copy_strings ("/gncal/Saved-Session-", session_id, NULL);

      buf = g_copy_strings ( sess, "/x", NULL);
      os_x = gnome_config_get_int (buf);
      g_free(buf);
      buf = g_copy_strings ( sess, "/y", NULL);
      os_y = gnome_config_get_int (buf);
      g_free(buf);
      buf = g_copy_strings ( sess, "/w", NULL);
      os_w = gnome_config_get_int (buf);
      g_free(buf);
      buf = g_copy_strings ( sess, "/h", NULL);
      os_h = gnome_config_get_int (buf);
      g_free(buf);
    }

  /* If we had an old session, we clean up after ourselves.  */
  if (session_id != NULL)
    discard_session (session_id);

  return;
}

void
discard_session (gchar *id)
{
  gchar *sess;

  sess = g_copy_strings ("/gncal/Saved-Session-", id, NULL);

  /* we use the gnome_config_get_* to work around a bug in gnome-config 
     (it's going under a redesign/rewrite, so i didn't correct it) */
  gnome_config_get_int ("/gncal/Bug/work-around=0");

  gnome_config_clean_section (sess);
  gnome_config_sync ();

  g_free (sess);
  return;
}

:#ff00ff">/mail/pop3/cache-%s", evolution_dir, encoded_url); /* lame hack, but we can't expect user's to actually migrate their cache files - brain power requirements are too high. */ if (stat (filename, &st) == -1) { /* This is either the first time the user has checked mail with this POP provider or else their cache file is in the old location... */ old_location = g_strdup_printf ("%s/config/cache-%s", evolution_dir, encoded_url); if (stat (old_location, &st) == -1) { /* old location doesn't exist either so use the new location */ g_free (old_location); } else { /* old location exists, so I guess we use the old cache file location */ g_free (filename); filename = old_location; } } g_free (encoded_url); return filename; } static char * fetch_mail_describe (struct _mail_msg *mm, int complete) { return g_strdup (_("Fetching Mail")); } static void fetch_mail_fetch (struct _mail_msg *mm) { struct _fetch_mail_msg *m = (struct _fetch_mail_msg *)mm; struct _filter_mail_msg *fm = (struct _filter_mail_msg *)mm; int i; if (m->cancel) camel_operation_register (m->cancel); if ((fm->destination = mail_tool_get_local_inbox (&mm->ex)) == NULL) { if (m->cancel) camel_operation_unregister (m->cancel); return; } /* FIXME: this should support keep_on_server too, which would then perform a spool access thingy, right? problem is matching raw messages to uid's etc. */ if (!strncmp (m->source_uri, "mbox:", 5)) { char *path = mail_tool_do_movemail (m->source_uri, &mm->ex); if (path && !camel_exception_is_set (&mm->ex)) { camel_folder_freeze (fm->destination); camel_filter_driver_set_default_folder (fm->driver, fm->destination); camel_filter_driver_filter_mbox (fm->driver, path, m->source_uri, &mm->ex); camel_folder_thaw (fm->destination); if (!camel_exception_is_set (&mm->ex)) unlink (path); } g_free (path); } else { CamelFolder *folder = fm->source_folder = mail_tool_get_inbox (m->source_uri, &mm->ex); if (folder) { /* this handles 'keep on server' stuff, if we have any new uid's to copy across, we need to copy them to a new array 'cause of the way fetch_mail_free works */ CamelUIDCache *cache = NULL; char *cachename; cachename = uid_cachename_hack (folder->parent_store); cache = camel_uid_cache_new (cachename); g_free (cachename); if (cache) { GPtrArray *folder_uids, *cache_uids, *uids; folder_uids = camel_folder_get_uids (folder); cache_uids = camel_uid_cache_get_new_uids (cache, folder_uids); if (cache_uids) { /* need to copy this, sigh */ fm->source_uids = uids = g_ptr_array_new (); g_ptr_array_set_size (uids, cache_uids->len); for (i = 0; i < cache_uids->len; i++) uids->pdata[i] = g_strdup (cache_uids->pdata[i]); camel_uid_cache_free_uids (cache_uids); fm->cache = cache; filter_folder_filter (mm); /* if we are not to delete the messages or there was an * exception, save the UID cache */ if (!fm->delete || camel_exception_is_set (&mm->ex)) camel_uid_cache_save (cache); /* if we are deleting off the server and no exception occured * then iterate through the folder uids and mark them all * for deletion. */ if (fm->delete && !camel_exception_is_set (&mm->ex)) { camel_folder_freeze (folder); for (i = 0; i < folder_uids->len; i++) camel_folder_delete_message (folder, folder_uids->pdata[i]); /* sync and expunge */ camel_folder_sync (folder, TRUE, &mm->ex); camel_folder_thaw (folder); } } camel_uid_cache_destroy (cache); camel_folder_free_uids (folder, folder_uids); } else { filter_folder_filter (mm); } /* we unref the source folder here since we may now block in finalize (we try to disconnect cleanly) */ camel_object_unref (fm->source_folder); fm->source_folder = NULL; } } if (m->cancel) camel_operation_unregister (m->cancel); /* we unref this here as it may have more work to do (syncing folders and whatnot) before we are really done */ /* should this be cancellable too? (i.e. above unregister above) */ if (fm->driver) { camel_object_unref (fm->driver); fm->driver = NULL; } } static void fetch_mail_fetched (struct _mail_msg *mm) { struct _fetch_mail_msg *m = (struct _fetch_mail_msg *)mm; if (m->done) m->done (m->source_uri, m->data); } static void fetch_mail_free (struct _mail_msg *mm) { struct _fetch_mail_msg *m = (struct _fetch_mail_msg *)mm; g_free (m->source_uri); if (m->cancel) camel_operation_unref (m->cancel); filter_folder_free (mm); } static struct _mail_msg_op fetch_mail_op = { fetch_mail_describe, /* we do our own progress reporting */ fetch_mail_fetch, fetch_mail_fetched, fetch_mail_free, }; /* ouch, a 'do everything' interface ... */ void mail_fetch_mail (const char *source, int keep, const char *type, CamelOperation *cancel, CamelFilterGetFolderFunc get_folder, void *get_data, CamelFilterStatusFunc *status, void *status_data, void (*done)(char *source, void *data), void *data) { struct _fetch_mail_msg *m; struct _filter_mail_msg *fm; m = mail_msg_new (&fetch_mail_op, NULL, sizeof (*m)); fm = (struct _filter_mail_msg *)m; m->source_uri = g_strdup (source); fm->delete = !keep; fm->cache = NULL; if (cancel) { m->cancel = cancel; camel_operation_ref (cancel); } m->done = done; m->data = data; fm->driver = camel_session_get_filter_driver (session, type, NULL); camel_filter_driver_set_folder_func (fm->driver, get_folder, get_data); if (status) camel_filter_driver_set_status_func (fm->driver, status, status_data); e_thread_put (mail_thread_new, (EMsg *)m); } /* ********************************************************************** */ /* sending stuff */ /* ** SEND MAIL *********************************************************** */ extern CamelFolder *sent_folder; static char *normal_recipients[] = { CAMEL_RECIPIENT_TYPE_TO, CAMEL_RECIPIENT_TYPE_CC, CAMEL_RECIPIENT_TYPE_BCC }; static char *resent_recipients[] = { CAMEL_RECIPIENT_TYPE_RESENT_TO, CAMEL_RECIPIENT_TYPE_RESENT_CC, CAMEL_RECIPIENT_TYPE_RESENT_BCC }; /* send 1 message to a specific transport */ static void mail_send_message (CamelMimeMessage *message, const char *destination, CamelFilterDriver *driver, CamelException *ex) { EAccount *account = NULL; const CamelInternetAddress *iaddr; CamelAddress *from, *recipients; CamelMessageInfo *info; CamelTransport *xport = NULL; char *transport_url = NULL; char *sent_folder_uri = NULL; const char *resent_from; CamelFolder *folder = NULL; GString *err = NULL; XEvolution *xev; int i; camel_medium_set_header (CAMEL_MEDIUM (message), "X-Mailer", "Ximian Evolution " VERSION SUB_VERSION " " VERSION_COMMENT); camel_mime_message_set_date (message, CAMEL_MESSAGE_DATE_CURRENT, 0); xev = mail_tool_remove_xevolution_headers (message); if (xev->account) { char *name; name = g_strstrip (g_strdup (xev->account)); account = mail_config_get_account_by_name (name); g_free (name); if (account) { if (account->transport && account->transport->url) transport_url = g_strdup (account->transport->url); sent_folder_uri = g_strdup (account->sent_folder_uri); } } if (!account) { /* default back to these headers */ if (xev->transport) transport_url = g_strstrip (g_strdup (xev->transport)); if (xev->fcc) sent_folder_uri = g_strstrip (g_strdup (xev->fcc)); } xport = camel_session_get_transport (session, transport_url ? transport_url : destination, ex); g_free (transport_url); if (!xport) { mail_tool_restore_xevolution_headers (message, xev); mail_tool_destroy_xevolution (xev); g_free (sent_folder_uri); return; } from = (CamelAddress *) camel_internet_address_new (); resent_from = camel_medium_get_header (CAMEL_MEDIUM (message), "Resent-From"); if (resent_from) { camel_address_decode (from, resent_from); } else { iaddr = camel_mime_message_get_from (message); camel_address_copy (from, CAMEL_ADDRESS (iaddr)); } recipients = (CamelAddress *) camel_internet_address_new (); for (i = 0; i < 3; i++) { const char *type; type = resent_from ? resent_recipients[i] : normal_recipients[i]; iaddr = camel_mime_message_get_recipients (message, type); camel_address_cat (recipients, CAMEL_ADDRESS (iaddr)); } camel_transport_send_to (xport, message, from, recipients, ex); camel_object_unref (recipients); camel_object_unref (from); mail_tool_restore_xevolution_headers (message, xev); mail_tool_destroy_xevolution (xev); camel_object_unref (xport); if (camel_exception_is_set (ex)) { g_free (sent_folder_uri); return; } /* post-process */ info = camel_message_info_new (); info->flags = CAMEL_MESSAGE_SEEN; if (sent_folder_uri) { folder = mail_tool_uri_to_folder (sent_folder_uri, 0, ex); camel_exception_clear (ex); g_free (sent_folder_uri); } if (!folder) { camel_object_ref (sent_folder); folder = sent_folder; } if (driver) { camel_filter_driver_filter_message (driver, message, info, NULL, NULL, NULL, "", ex); if (camel_exception_is_set (ex)) { if (camel_exception_get_id (ex) == CAMEL_EXCEPTION_USER_CANCEL) goto exit; /* save this error */ err = g_string_new (""); g_string_append_printf (err, _("Failed to apply outgoing filters: %s"), camel_exception_get_description (ex)); } } retry_append: camel_exception_clear (ex); camel_folder_append_message (folder, message, info, NULL, ex); if (camel_exception_is_set (ex)) { if (camel_exception_get_id (ex) == CAMEL_EXCEPTION_USER_CANCEL) goto exit; if (err == NULL) err = g_string_new (""); else g_string_append (err, "\n\n"); if (folder != sent_folder) { const char *name; camel_object_get (folder, NULL, CAMEL_OBJECT_DESCRIPTION, (char **) &name, 0); g_string_append_printf (err, _("Failed to append to %s: %s\n" "Appending to local `Sent' folder instead."), name, camel_exception_get_description (ex)); camel_object_ref (sent_folder); camel_object_unref (folder); folder = sent_folder; goto retry_append; } else { g_string_append_printf (err, _("Failed to append to local `Sent' folder: %s"), camel_exception_get_description (ex)); } } if (err != NULL) { /* set the culmulative exception report */ camel_exception_set (ex, CAMEL_EXCEPTION_SYSTEM, err->str); } exit: camel_folder_sync (folder, FALSE, NULL); camel_message_info_free (info); camel_object_unref (folder); if (err != NULL) g_string_free (err, TRUE); } /* ********************************************************************** */ struct _send_mail_msg { struct _mail_msg msg; CamelFilterDriver *driver; char *destination; CamelMimeMessage *message; void (*done)(char *uri, CamelMimeMessage *message, gboolean sent, void *data); void *data; }; static char * send_mail_desc (struct _mail_msg *mm, int done) { struct _send_mail_msg *m = (struct _send_mail_msg *)mm; const char *subject; subject = camel_mime_message_get_subject (m->message); if (subject) return g_strdup_printf (_("Sending \"%s\""), subject); else return g_strdup (_("Sending message")); } static void send_mail_send (struct _mail_msg *mm) { struct _send_mail_msg *m = (struct _send_mail_msg *)mm; mail_send_message (m->message, m->destination, m->driver, &mm->ex); } static void send_mail_sent (struct _mail_msg *mm) { struct _send_mail_msg *m = (struct _send_mail_msg *)mm; if (m->done) m->done (m->destination, m->message, !camel_exception_is_set (&mm->ex), m->data); } static void send_mail_free (struct _mail_msg *mm) { struct _send_mail_msg *m = (struct _send_mail_msg *)mm; camel_object_unref (m->driver); camel_object_unref (m->message); g_free (m->destination); } static struct _mail_msg_op send_mail_op = { send_mail_desc, send_mail_send, send_mail_sent, send_mail_free, }; int mail_send_mail (const char *uri, CamelMimeMessage *message, void (*done) (char *uri, CamelMimeMessage *message, gboolean sent, void *data), void *data) { struct _send_mail_msg *m; int id; m = mail_msg_new (&send_mail_op, NULL, sizeof (*m)); m->destination = g_strdup (uri); m->message = message; camel_object_ref (message); m->data = data; m->done = done; id = m->msg.seq; m->driver = camel_session_get_filter_driver (session, FILTER_SOURCE_OUTGOING, NULL); e_thread_put (mail_thread_new, (EMsg *)m); return id; } /* ** SEND MAIL QUEUE ***************************************************** */ struct _send_queue_msg { struct _mail_msg msg; CamelFolder *queue; char *destination; CamelFilterDriver *driver; CamelOperation *cancel; /* we use camelfilterstatusfunc, even though its not the filter doing it */ CamelFilterStatusFunc *status; void *status_data; void (*done)(char *destination, void *data); void *data; }; static void report_status (struct _send_queue_msg *m, enum camel_filter_status_t status, int pc, const char *desc, ...) { va_list ap; char *str; if (m->status) { va_start (ap, desc); str = g_strdup_vprintf (desc, ap); va_end (ap); m->status (m->driver, status, pc, str, m->status_data); g_free (str); } } static void send_queue_send(struct _mail_msg *mm) { struct _send_queue_msg *m = (struct _send_queue_msg *)mm; extern CamelFolder *sent_folder; /* FIXME */ GPtrArray *uids; int i; d(printf("sending queue\n")); uids = camel_folder_get_uids (m->queue); if (uids == NULL || uids->len == 0) return; if (m->cancel) camel_operation_register (m->cancel); for (i = 0; i < uids->len; i++) { CamelMimeMessage *message; CamelMessageInfo *info; int pc = (100 * i) / uids->len; report_status (m, CAMEL_FILTER_STATUS_START, pc, _("Sending message %d of %d"), i+1, uids->len); info = camel_folder_get_message_info (m->queue, uids->pdata[i]); if (info && info->flags & CAMEL_MESSAGE_DELETED) continue; message = camel_folder_get_message (m->queue, uids->pdata[i], &mm->ex); if (camel_exception_is_set (&mm->ex)) break; mail_send_message (message, m->destination, m->driver, &mm->ex); if (camel_exception_is_set (&mm->ex)) break; camel_folder_set_message_flags (m->queue, uids->pdata[i], CAMEL_MESSAGE_DELETED, CAMEL_MESSAGE_DELETED); } if (camel_exception_is_set (&mm->ex)) report_status (m, CAMEL_FILTER_STATUS_END, 100, _("Failed on message %d of %d"), i+1, uids->len); else report_status (m, CAMEL_FILTER_STATUS_END, 100, _("Complete.")); if (m->driver) { camel_object_unref((CamelObject *)m->driver); m->driver = NULL; } camel_folder_free_uids (m->queue, uids); if (!camel_exception_is_set (&mm->ex)) camel_folder_expunge (m->queue, &mm->ex); if (sent_folder) camel_folder_sync (sent_folder, FALSE, NULL); if (m->cancel) camel_operation_unregister (m->cancel); } static void send_queue_sent(struct _mail_msg *mm) { struct _send_queue_msg *m = (struct _send_queue_msg *)mm; if (m->done) m->done(m->destination, m->data); } static void send_queue_free(struct _mail_msg *mm) { struct _send_queue_msg *m = (struct _send_queue_msg *)mm; if (m->driver) camel_object_unref(m->driver); camel_object_unref(m->queue); g_free(m->destination); if (m->cancel) camel_operation_unref(m->cancel); } static struct _mail_msg_op send_queue_op = { NULL, /* do our own reporting, as with fetch mail */ send_queue_send, send_queue_sent, send_queue_free, }; /* same interface as fetch_mail, just 'cause i'm lazy today (and we need to run it from the same spot?) */ void mail_send_queue(CamelFolder *queue, const char *destination, const char *type, CamelOperation *cancel, CamelFilterGetFolderFunc get_folder, void *get_data, CamelFilterStatusFunc *status, void *status_data, void (*done)(char *destination, void *data), void *data) { struct _send_queue_msg *m; m = mail_msg_new(&send_queue_op, NULL, sizeof(*m)); m->queue = queue; camel_object_ref(queue); m->destination = g_strdup(destination); if (cancel) { m->cancel = cancel; camel_operation_ref(cancel); } m->status = status; m->status_data = status_data; m->done = done; m->data = data; m->driver = camel_session_get_filter_driver (session, type, NULL); camel_filter_driver_set_folder_func (m->driver, get_folder, get_data); e_thread_put(mail_thread_new, (EMsg *)m); } /* ** APPEND MESSAGE TO FOLDER ******************************************** */ struct _append_msg { struct _mail_msg msg; CamelFolder *folder; CamelMimeMessage *message; CamelMessageInfo *info; char *appended_uid; void (*done)(CamelFolder *folder, CamelMimeMessage *msg, CamelMessageInfo *info, int ok, const char *appended_uid, void *data); void *data; }; static char * append_mail_desc (struct _mail_msg *mm, int done) { return g_strdup (_("Saving message to folder")); } static void append_mail_append (struct _mail_msg *mm) { struct _append_msg *m = (struct _append_msg *)mm; camel_mime_message_set_date(m->message, CAMEL_MESSAGE_DATE_CURRENT, 0); camel_folder_append_message(m->folder, m->message, m->info, &m->appended_uid, &mm->ex); } static void append_mail_appended (struct _mail_msg *mm) { struct _append_msg *m = (struct _append_msg *)mm; if (m->done) m->done(m->folder, m->message, m->info, !camel_exception_is_set(&mm->ex), m->appended_uid, m->data); } static void append_mail_free (struct _mail_msg *mm) { struct _append_msg *m = (struct _append_msg *)mm; camel_object_unref(m->message); camel_object_unref(m->folder); g_free (m->appended_uid); } static struct _mail_msg_op append_mail_op = { append_mail_desc, append_mail_append, append_mail_appended, append_mail_free }; void mail_append_mail (CamelFolder *folder, CamelMimeMessage *message, CamelMessageInfo *info, void (*done)(CamelFolder *folder, CamelMimeMessage *msg, CamelMessageInfo *info, int ok, const char *appended_uid, void *data), void *data) { struct _append_msg *m; g_assert(CAMEL_IS_FOLDER (folder)); g_assert(CAMEL_IS_MIME_MESSAGE (message)); m = mail_msg_new (&append_mail_op, NULL, sizeof (*m)); m->folder = folder; camel_object_ref(folder); m->message = message; camel_object_ref(message); m->info = info; m->done = done; m->data = data; e_thread_put (mail_thread_new, (EMsg *)m); } /* ** TRANSFER MESSAGES **************************************************** */ struct _transfer_msg { struct _mail_msg msg; CamelFolder *source; GPtrArray *uids; gboolean delete; char *dest_uri; guint32 dest_flags; void (*done)(gboolean ok, void *data); void *data; }; static char * transfer_messages_desc (struct _mail_msg *mm, int done) { struct _transfer_msg *m = (struct _transfer_msg *)mm; return g_strdup_printf(m->delete?_("Moving messages to %s"):_("Copying messages to %s"), m->dest_uri); } static void transfer_messages_transfer (struct _mail_msg *mm) { struct _transfer_msg *m = (struct _transfer_msg *)mm; CamelFolder *dest; dest = mail_tool_uri_to_folder (m->dest_uri, m->dest_flags, &mm->ex); if (camel_exception_is_set (&mm->ex)) return; if (dest == m->source) { camel_object_unref(dest); /* no-op */ return; } camel_folder_freeze (m->source); camel_folder_freeze (dest); camel_folder_transfer_messages_to (m->source, m->uids, dest, NULL, m->delete, &mm->ex); /* make sure all deleted messages are marked as seen */ if (m->delete) { int i; for (i = 0; i < m->uids->len; i++) camel_folder_set_message_flags (m->source, m->uids->pdata[i], CAMEL_MESSAGE_SEEN, CAMEL_MESSAGE_SEEN); } camel_folder_thaw (m->source); camel_folder_thaw (dest); camel_folder_sync (dest, FALSE, NULL); camel_object_unref (dest); } static void transfer_messages_transferred (struct _mail_msg *mm) { struct _transfer_msg *m = (struct _transfer_msg *)mm; if (m->done) m->done (!camel_exception_is_set (&mm->ex), m->data); } static void transfer_messages_free (struct _mail_msg *mm) { struct _transfer_msg *m = (struct _transfer_msg *)mm; int i; camel_object_unref (m->source); g_free (m->dest_uri); for (i = 0; i < m->uids->len; i++) g_free (m->uids->pdata[i]); g_ptr_array_free (m->uids, TRUE); } static struct _mail_msg_op transfer_messages_op = { transfer_messages_desc, transfer_messages_transfer, transfer_messages_transferred, transfer_messages_free, }; void mail_transfer_messages (CamelFolder *source, GPtrArray *uids, gboolean delete_from_source, const char *dest_uri, guint32 dest_flags, void (*done) (gboolean ok, void *data), void *data) { struct _transfer_msg *m; g_assert(CAMEL_IS_FOLDER (source)); g_assert(uids != NULL); g_assert(dest_uri != NULL); m = mail_msg_new(&transfer_messages_op, NULL, sizeof(*m)); m->source = source; camel_object_ref (source); m->uids = uids; m->delete = delete_from_source; m->dest_uri = g_strdup (dest_uri); m->dest_flags = dest_flags; m->done = done; m->data = data; e_thread_put(mail_thread_queued, (EMsg *)m); } /* ** SCAN SUBFOLDERS ***************************************************** */ struct _get_folderinfo_msg { struct _mail_msg msg; CamelStore *store; CamelFolderInfo *info; void (*done)(CamelStore *store, CamelFolderInfo *info, void *data); void *data; }; static char * get_folderinfo_desc (struct _mail_msg *mm, int done) { struct _get_folderinfo_msg *m = (struct _get_folderinfo_msg *)mm; char *ret, *name; name = camel_service_get_name((CamelService *)m->store, TRUE); ret = g_strdup_printf(_("Scanning folders in \"%s\""), name); g_free(name); return ret; } static void add_vtrash_info (CamelStore *store, CamelFolderInfo *info) { CamelFolderInfo *fi, *vtrash, *parent; char *uri, *path; CamelURL *url; g_return_if_fail (info != NULL); parent = NULL; for (fi = info; fi; fi = fi->sibling) { if (!strcmp (fi->name, CAMEL_VTRASH_NAME)) break; parent = fi; } /* create our vTrash URL */ url = camel_url_new (info->url, NULL); path = g_strdup_printf ("/%s", CAMEL_VTRASH_NAME); if (url->fragment) camel_url_set_fragment (url, path); else camel_url_set_path (url, path); g_free (path); uri = camel_url_to_string (url, CAMEL_URL_HIDE_ALL); camel_url_free (url); if (fi) { /* We're going to replace the physical Trash folder with our vTrash folder */ vtrash = fi; g_free (vtrash->full_name); g_free (vtrash->name); g_free (vtrash->url); } else { /* There wasn't a Trash folder so create a new folder entry */ vtrash = g_new0 (CamelFolderInfo, 1); g_assert(parent != NULL); /* link it into the right spot */ vtrash->sibling = parent->sibling; parent->sibling = vtrash; } /* Fill in the new fields */ vtrash->full_name = g_strdup (_("Trash")); vtrash->name = g_strdup(vtrash->full_name); vtrash->url = g_strdup_printf ("vtrash:%s", uri); vtrash->unread_message_count = -1; vtrash->path = g_strdup_printf("/%s", vtrash->name); g_free (uri); } static void add_unmatched_info(CamelFolderInfo *fi) { for (; fi; fi = fi->sibling) { if (!strcmp(fi->full_name, CAMEL_UNMATCHED_NAME)) { g_free(fi->name); fi->name = g_strdup(_("Unmatched")); g_free(fi->path); fi->path = g_strdup_printf("/%s", fi->name); break; } } } static void get_folderinfo_get (struct _mail_msg *mm) { struct _get_folderinfo_msg *m = (struct _get_folderinfo_msg *)mm; guint32 flags = CAMEL_STORE_FOLDER_INFO_RECURSIVE; if (camel_store_supports_subscriptions (m->store)) flags |= CAMEL_STORE_FOLDER_INFO_SUBSCRIBED; m->info = camel_store_get_folder_info (m->store, NULL, flags, &mm->ex); if (m->info) { if (m->info->url && (m->store->flags & CAMEL_STORE_VTRASH)) add_vtrash_info(m->store, m->info); if (CAMEL_IS_VEE_STORE(m->store)) add_unmatched_info(m->info); } } static void get_folderinfo_got (struct _mail_msg *mm) { struct _get_folderinfo_msg *m = (struct _get_folderinfo_msg *)mm; if (camel_exception_is_set (&mm->ex)) { char *url; url = camel_service_get_url (CAMEL_SERVICE (m->store)); w(g_warning ("Error getting folder info from store at %s: %s", url, camel_exception_get_description (&mm->ex))); g_free (url); } /* 'done' is probably guaranteed to fail, but... */ if (m->done) m->done (m->store, m->info, m->data); } static void get_folderinfo_free (struct _mail_msg *mm) { struct _get_folderinfo_msg *m = (struct _get_folderinfo_msg *)mm; if (m->info) camel_store_free_folder_info(m->store, m->info); camel_object_unref(m->store); } static struct _mail_msg_op get_folderinfo_op = { get_folderinfo_desc, get_folderinfo_get, get_folderinfo_got, get_folderinfo_free, }; int mail_get_folderinfo (CamelStore *store, CamelOperation *op, void (*done)(CamelStore *store, CamelFolderInfo *info, void *data), void *data) { struct _get_folderinfo_msg *m; int id; m = mail_msg_new(&get_folderinfo_op, NULL, sizeof(*m)); if (op) { camel_operation_unref(m->msg.cancel); m->msg.cancel = op; camel_operation_ref(op); } m->store = store; camel_object_ref(store); m->done = done; m->data = data; id = m->msg.seq; e_thread_put(mail_thread_new, (EMsg *)m); return id; } /* ** ATTACH MESSAGES ****************************************************** */ struct _build_data { void (*done)(CamelFolder *folder, GPtrArray *uids, CamelMimePart *part, char *subject, void *data); void *data; }; static void do_build_attachment (CamelFolder *folder, GPtrArray *uids, GPtrArray *messages, void *data) { struct _build_data *d = data; CamelMultipart *multipart; CamelMimePart *part; char *subject; int i; if (messages->len == 0) { d->done(folder, messages, NULL, NULL, d->data); g_free(d); return; } if (messages->len == 1) { part = mail_tool_make_message_attachment(messages->pdata[0]); } else { multipart = camel_multipart_new(); camel_data_wrapper_set_mime_type(CAMEL_DATA_WRAPPER (multipart), "multipart/digest"); camel_multipart_set_boundary(multipart, NULL); for (i=0;i<messages->len;i++) { part = mail_tool_make_message_attachment(messages->pdata[i]); camel_multipart_add_part(multipart, part); camel_object_unref(part); } part = camel_mime_part_new(); camel_medium_set_content_object(CAMEL_MEDIUM (part), CAMEL_DATA_WRAPPER(multipart)); camel_object_unref(multipart); camel_mime_part_set_description(part, _("Forwarded messages")); } subject = mail_tool_generate_forward_subject(messages->pdata[0]); d->done(folder, messages, part, subject, d->data); g_free(subject); camel_object_unref(part); g_free(d); } void mail_build_attachment(CamelFolder *folder, GPtrArray *uids, void (*done)(CamelFolder *folder, GPtrArray *messages, CamelMimePart *part, char *subject, void *data), void *data) { struct _build_data *d; d = g_malloc(sizeof(*d)); d->done = done; d->data = data; mail_get_messages(folder, uids, do_build_attachment, d); } /* ** LOAD FOLDER ********************************************************* */ /* there should be some way to merge this and create folder, since both can presumably create a folder ... */ struct _get_folder_msg { struct _mail_msg msg; char *uri; guint32 flags; CamelFolder *folder; void (*done) (char *uri, CamelFolder *folder, void *data); void *data; }; static char * get_folder_desc (struct _mail_msg *mm, int done) { struct _get_folder_msg *m = (struct _get_folder_msg *)mm; return g_strdup_printf(_("Opening folder %s"), m->uri); } static void get_folder_get (struct _mail_msg *mm) { struct _get_folder_msg *m = (struct _get_folder_msg *)mm; m->folder = mail_tool_uri_to_folder (m->uri, m->flags, &mm->ex); } static void get_folder_got (struct _mail_msg *mm) { struct _get_folder_msg *m = (struct _get_folder_msg *)mm; if (m->done) m->done (m->uri, m->folder, m->data); } static void get_folder_free (struct _mail_msg *mm) { struct _get_folder_msg *m = (struct _get_folder_msg *)mm; g_free (m->uri); if (m->folder) camel_object_unref (m->folder); } static struct _mail_msg_op get_folder_op = { get_folder_desc, get_folder_get, get_folder_got, get_folder_free, }; int mail_get_folder (const char *uri, guint32 flags, void (*done)(char *uri, CamelFolder *folder, void *data), void *data, EThread *thread) { struct _get_folder_msg *m; int id; m = mail_msg_new(&get_folder_op, NULL, sizeof(*m)); m->uri = g_strdup (uri); m->flags = flags; m->data = data; m->done = done; id = m->msg.seq; e_thread_put(thread, (EMsg *)m); return id; } /* ** GET STORE ******************************************************* */ struct _get_store_msg { struct _mail_msg msg; char *uri; CamelStore *store; void (*done) (char *uri, CamelStore *store, void *data); void *data; }; static char * get_store_desc (struct _mail_msg *mm, int done) { struct _get_store_msg *m = (struct _get_store_msg *)mm; return g_strdup_printf(_("Opening store %s"), m->uri); } static void get_store_get (struct _mail_msg *mm) { struct _get_store_msg *m = (struct _get_store_msg *)mm; /*camel_session_get_store connects us, which we don't want to do on startup. */ m->store = (CamelStore *) camel_session_get_service (session, m->uri, CAMEL_PROVIDER_STORE, &mm->ex); } static void get_store_got (struct _mail_msg *mm) { struct _get_store_msg *m = (struct _get_store_msg *)mm; if (m->done) m->done (m->uri, m->store, m->data); } static void get_store_free (struct _mail_msg *mm) { struct _get_store_msg *m = (struct _get_store_msg *)mm; g_free (m->uri); if (m->store) camel_object_unref (m->store); } static struct _mail_msg_op get_store_op = { get_store_desc, get_store_get, get_store_got, get_store_free, }; int mail_get_store (const char *uri, CamelOperation *op, void (*done) (char *uri, CamelStore *store, void *data), void *data) { struct _get_store_msg *m; int id; m = mail_msg_new (&get_store_op, NULL, sizeof (*m)); if (op) { camel_operation_unref(m->msg.cancel); m->msg.cancel = op; camel_operation_ref(op); } m->uri = g_strdup (uri); m->data = data; m->done = done; id = m->msg.seq; e_thread_put (mail_thread_new, (EMsg *)m); return id; } /* ** REMOVE FOLDER ******************************************************* */ struct _remove_folder_msg { struct _mail_msg msg; char *uri; gboolean removed; void (*done) (char *uri, gboolean removed, void *data); void *data; }; static char * remove_folder_desc (struct _mail_msg *mm, int done) { struct _remove_folder_msg *m = (struct _remove_folder_msg *)mm; return g_strdup_printf (_("Removing folder %s"), m->uri); } static void remove_folder_get (struct _mail_msg *mm) { struct _remove_folder_msg *m = (struct _remove_folder_msg *)mm; CamelStore *store; CamelFolder *folder; GPtrArray *uids; int i; m->removed = FALSE; folder = mail_tool_uri_to_folder (m->uri, 0, &mm->ex); if (!folder) return; store = folder->parent_store; /* Delete every message in this folder, then expunge it */ uids = camel_folder_get_uids (folder); camel_folder_freeze(folder); for (i = 0; i < uids->len; i++) camel_folder_delete_message (folder, uids->pdata[i]); camel_folder_sync (folder, TRUE, NULL); camel_folder_thaw(folder); camel_folder_free_uids (folder, uids); /* if the store supports subscriptions, unsubscribe from this folder... */ if (camel_store_supports_subscriptions (store)) camel_store_unsubscribe_folder (store, folder->full_name, NULL); /* Then delete the folder from the store */ camel_store_delete_folder (store, folder->full_name, &mm->ex); m->removed = !camel_exception_is_set (&mm->ex); camel_object_unref (folder); } static void remove_folder_got (struct _mail_msg *mm) { struct _remove_folder_msg *m = (struct _remove_folder_msg *)mm; if (m->removed) { /* FIXME: Remove this folder from the folder cache ??? */ } if (m->done) m->done (m->uri, m->removed, m->data); } static void remove_folder_free (struct _mail_msg *mm) { struct _remove_folder_msg *m = (struct _remove_folder_msg *)mm; g_free (m->uri); } static struct _mail_msg_op remove_folder_op = { remove_folder_desc, remove_folder_get, remove_folder_got, remove_folder_free, }; void mail_remove_folder (const char *uri, void (*done) (char *uri, gboolean removed, void *data), void *data) { struct _remove_folder_msg *m; m = mail_msg_new (&remove_folder_op, NULL, sizeof (*m)); m->uri = g_strdup (uri); m->data = data; m->done = done; e_thread_put (mail_thread_new, (EMsg *)m); } /* ** SYNC FOLDER ********************************************************* */ struct _sync_folder_msg { struct _mail_msg msg; CamelFolder *folder; void (*done) (CamelFolder *folder, void *data); void *data; }; static char *sync_folder_desc(struct _mail_msg *mm, int done) { struct _sync_folder_msg *m = (struct _sync_folder_msg *)mm; return g_strdup_printf (_("Storing folder \'%s\'"), camel_folder_get_full_name (m->folder)); } static void sync_folder_sync(struct _mail_msg *mm) { struct _sync_folder_msg *m = (struct _sync_folder_msg *)mm; camel_folder_sync(m->folder, FALSE, &mm->ex); } static void sync_folder_synced(struct _mail_msg *mm) { struct _sync_folder_msg *m = (struct _sync_folder_msg *)mm; if (m->done) m->done(m->folder, m->data); } static void sync_folder_free(struct _mail_msg *mm) { struct _sync_folder_msg *m = (struct _sync_folder_msg *)mm; camel_object_unref((CamelObject *)m->folder); } static struct _mail_msg_op sync_folder_op = { sync_folder_desc, sync_folder_sync, sync_folder_synced, sync_folder_free, }; void mail_sync_folder(CamelFolder *folder, void (*done) (CamelFolder *folder, void *data), void *data) { struct _sync_folder_msg *m; m = mail_msg_new(&sync_folder_op, NULL, sizeof(*m)); m->folder = folder; camel_object_ref(folder); m->data = data; m->done = done; e_thread_put(mail_thread_queued_slow, (EMsg *)m); } /* ******************************************************************************** */ static char *refresh_folder_desc(struct _mail_msg *mm, int done) { return g_strdup(_("Refreshing folder")); } static void refresh_folder_refresh(struct _mail_msg *mm) { struct _sync_folder_msg *m = (struct _sync_folder_msg *)mm; camel_folder_refresh_info(m->folder, &mm->ex); } /* we just use the sync stuff where we can, since it would be the same */ static struct _mail_msg_op refresh_folder_op = { refresh_folder_desc, refresh_folder_refresh, sync_folder_synced, sync_folder_free, }; void mail_refresh_folder(CamelFolder *folder, void (*done) (CamelFolder *folder, void *data), void *data) { struct _sync_folder_msg *m; m = mail_msg_new(&refresh_folder_op, NULL, sizeof(*m)); m->folder = folder; camel_object_ref(folder); m->data = data; m->done = done; e_thread_put(mail_thread_new, (EMsg *)m); } /* ******************************************************************************** */ static char *expunge_folder_desc(struct _mail_msg *mm, int done) { return g_strdup(_("Expunging folder")); } static void expunge_folder_expunge(struct _mail_msg *mm) { struct _sync_folder_msg *m = (struct _sync_folder_msg *)mm; camel_folder_expunge(m->folder, &mm->ex); } /* we just use the sync stuff where we can, since it would be the same */ static struct _mail_msg_op expunge_folder_op = { expunge_folder_desc, expunge_folder_expunge, sync_folder_synced, sync_folder_free, }; void mail_expunge_folder(CamelFolder *folder, void (*done) (CamelFolder *folder, void *data), void *data) { struct _sync_folder_msg *m; m = mail_msg_new(&expunge_folder_op, NULL, sizeof(*m)); m->folder = folder; camel_object_ref(folder); m->data = data; m->done = done; e_thread_put(mail_thread_queued_slow, (EMsg *)m); } /* ******************************************************************************** */ struct _empty_trash_msg { struct _mail_msg msg; EAccount *account; void (*done) (EAccount *account, void *data); void *data; }; static char *empty_trash_desc(struct _mail_msg *mm, int done) { /* FIXME after 1.4 is out and we're not in string freeze any more. */ #if 0 struct _empty_trash_msg *m = (struct _empty_trash_msg *)mm; return g_strdup_printf (_("Emptying trash in \'%s\'"), m->account ? m->account->name : _("Local Folders")); #else return g_strdup(_("Expunging folder")); #endif } static void empty_trash_empty(struct _mail_msg *mm) { struct _empty_trash_msg *m = (struct _empty_trash_msg *)mm; CamelFolder *trash; if (m->account) trash = mail_tool_get_trash (m->account->source->url, FALSE, &mm->ex); else trash = mail_tool_get_trash ("file:/", TRUE, &mm->ex); if (trash) camel_folder_expunge (trash, &mm->ex); camel_object_unref(trash); } static void empty_trash_emptied(struct _mail_msg *mm) { struct _empty_trash_msg *m = (struct _empty_trash_msg *)mm; if (m->done) m->done(m->account, m->data); } static void empty_trash_free(struct _mail_msg *mm) { struct _empty_trash_msg *m = (struct _empty_trash_msg *)mm; if (m->account) g_object_unref(m->account); } static struct _mail_msg_op empty_trash_op = { empty_trash_desc, empty_trash_empty, empty_trash_emptied, empty_trash_free, }; void mail_empty_trash(EAccount *account, void (*done) (EAccount *account, void *data), void *data) { struct _empty_trash_msg *m; m = mail_msg_new(&empty_trash_op, NULL, sizeof(*m)); m->account = account; if (account) g_object_ref(account); m->data = data; m->done = done; e_thread_put(mail_thread_queued_slow, (EMsg *)m); } /* ** GET MESSAGE(s) ***************************************************** */ struct _get_message_msg { struct _mail_msg msg; CamelFolder *folder; char *uid; void (*done) (CamelFolder *folder, const char *uid, CamelMimeMessage *msg, void *data); void *data; CamelMimeMessage *message; CamelOperation *cancel; }; static char *get_message_desc(struct _mail_msg *mm, int done) { struct _get_message_msg *m = (struct _get_message_msg *)mm; return g_strdup_printf(_("Retrieving message %s"), m->uid); } static void get_message_get(struct _mail_msg *mm) { struct _get_message_msg *m = (struct _get_message_msg *)mm; m->message = camel_folder_get_message(m->folder, m->uid, &mm->ex); } static void get_message_got(struct _mail_msg *mm) { struct _get_message_msg *m = (struct _get_message_msg *)mm; if (m->done) m->done(m->folder, m->uid, m->message, m->data); } static void get_message_free(struct _mail_msg *mm) { struct _get_message_msg *m = (struct _get_message_msg *)mm; g_free (m->uid); camel_object_unref (m->folder); camel_operation_unref (m->cancel); if (m->message) camel_object_unref (m->message); } static struct _mail_msg_op get_message_op = { get_message_desc, get_message_get, get_message_got, get_message_free, }; void mail_get_message(CamelFolder *folder, const char *uid, void (*done) (CamelFolder *folder, const char *uid, CamelMimeMessage *msg, void *data), void *data, EThread *thread) { struct _get_message_msg *m; m = mail_msg_new(&get_message_op, NULL, sizeof(*m)); m->folder = folder; camel_object_ref(folder); m->uid = g_strdup(uid); m->data = data; m->done = done; m->cancel = camel_operation_new(NULL, NULL); e_thread_put(thread, (EMsg *)m); } /* ********************************************************************** */ struct _get_messages_msg { struct _mail_msg msg; CamelFolder *folder; GPtrArray *uids; GPtrArray *messages; void (*done) (CamelFolder *folder, GPtrArray *uids, GPtrArray *msgs, void *data); void *data; }; static char * get_messages_desc(struct _mail_msg *mm, int done) { struct _get_messages_msg *m = (struct _get_messages_msg *)mm; return g_strdup_printf(_("Retrieving %d message(s)"), m->uids->len); } static void get_messages_get(struct _mail_msg *mm) { struct _get_messages_msg *m = (struct _get_messages_msg *)mm; int i; CamelMimeMessage *message; for (i=0; i<m->uids->len; i++) { int pc = ((i+1) * 100) / m->uids->len; message = camel_folder_get_message(m->folder, m->uids->pdata[i], &mm->ex); camel_operation_progress(mm->cancel, pc); if (message == NULL) break; g_ptr_array_add(m->messages, message); } } static void get_messages_got(struct _mail_msg *mm) { struct _get_messages_msg *m = (struct _get_messages_msg *)mm; if (m->done) m->done(m->folder, m->uids, m->messages, m->data); } static void get_messages_free(struct _mail_msg *mm) { struct _get_messages_msg *m = (struct _get_messages_msg *)mm; int i; for (i=0;i<m->uids->len;i++) g_free(m->uids->pdata[i]); g_ptr_array_free(m->uids, TRUE); for (i=0;i<m->messages->len;i++) { if (m->messages->pdata[i]) camel_object_unref(m->messages->pdata[i]); } g_ptr_array_free(m->messages, TRUE); camel_object_unref(m->folder); } static struct _mail_msg_op get_messages_op = { get_messages_desc, get_messages_get, get_messages_got, get_messages_free, }; void mail_get_messages(CamelFolder *folder, GPtrArray *uids, void (*done) (CamelFolder *folder, GPtrArray *uids, GPtrArray *msgs, void *data), void *data) { struct _get_messages_msg *m; m = mail_msg_new(&get_messages_op, NULL, sizeof(*m)); m->folder = folder; camel_object_ref(folder); m->uids = uids; m->messages = g_ptr_array_new(); m->data = data; m->done = done; e_thread_put(mail_thread_new, (EMsg *)m); } /* ** SAVE MESSAGES ******************************************************* */ struct _save_messages_msg { struct _mail_msg msg; CamelFolder *folder; GPtrArray *uids; char *path; void (*done)(CamelFolder *folder, GPtrArray *uids, char *path, void *data); void *data; }; static char *save_messages_desc(struct _mail_msg *mm, int done) { struct _save_messages_msg *m = (struct _save_messages_msg *)mm; return g_strdup_printf(_("Saving %d messsage(s)"), m->uids->len); } static void save_prepare_part (CamelMimePart *mime_part) { CamelDataWrapper *wrapper; int parts, i; wrapper = camel_medium_get_content_object (CAMEL_MEDIUM (mime_part)); if (!wrapper) return; if (CAMEL_IS_MULTIPART (wrapper)) { parts = camel_multipart_get_number (CAMEL_MULTIPART (wrapper)); for (i = 0; i < parts; i++) { CamelMimePart *part = camel_multipart_get_part (CAMEL_MULTIPART (wrapper), i); save_prepare_part (part); } } else { if (CAMEL_IS_MIME_MESSAGE (wrapper)) { /* prepare the message parts' subparts */ save_prepare_part (CAMEL_MIME_PART (wrapper)); } else { CamelContentType *type; /* We want to save textual parts as 8bit instead of encoded */ type = camel_data_wrapper_get_mime_type_field (wrapper); if (header_content_type_is (type, "text", "*")) camel_mime_part_set_encoding (mime_part, CAMEL_MIME_PART_ENCODING_8BIT); } } } static void save_messages_save (struct _mail_msg *mm) { struct _save_messages_msg *m = (struct _save_messages_msg *)mm; CamelStreamFilter *filtered_stream; CamelMimeFilterFrom *from_filter; CamelStream *stream; int fd, i; char *from; fd = open (m->path, O_WRONLY | O_CREAT | O_TRUNC, 0666); if (fd == -1) { camel_exception_setv(&mm->ex, CAMEL_EXCEPTION_SYSTEM, _("Unable to create output file: %s\n %s"), m->path, strerror(errno)); return; } stream = camel_stream_fs_new_with_fd(fd); from_filter = camel_mime_filter_from_new(); filtered_stream = camel_stream_filter_new_with_stream(stream); camel_stream_filter_add(filtered_stream, (CamelMimeFilter *)from_filter); camel_object_unref(from_filter); for (i=0; i<m->uids->len; i++) { CamelMimeMessage *message; int pc = ((i+1) * 100) / m->uids->len; message = camel_folder_get_message(m->folder, m->uids->pdata[i], &mm->ex); camel_operation_progress(mm->cancel, pc); if (message == NULL) break; save_prepare_part (CAMEL_MIME_PART (message)); /* we need to flush after each stream write since we are writing to the same fd */ from = camel_mime_message_build_mbox_from(message); if (camel_stream_write_string(stream, from) == -1 || camel_stream_flush(stream) == -1 || camel_data_wrapper_write_to_stream((CamelDataWrapper *)message, (CamelStream *)filtered_stream) == -1 || camel_stream_flush((CamelStream *)filtered_stream) == -1) { camel_exception_setv(&mm->ex, CAMEL_EXCEPTION_SYSTEM, _("Error saving messages to: %s:\n %s"), m->path, strerror(errno)); g_free(from); camel_object_unref((CamelObject *)message); break; } g_free(from); camel_object_unref(message); } camel_object_unref(filtered_stream); camel_object_unref(stream); } static void save_messages_saved(struct _mail_msg *mm) { struct _save_messages_msg *m = (struct _save_messages_msg *)mm; if (m->done) m->done(m->folder, m->uids, m->path, m->data); } static void save_messages_free(struct _mail_msg *mm) { struct _save_messages_msg *m = (struct _save_messages_msg *)mm; int i; for (i=0;i<m->uids->len;i++) g_free(m->uids->pdata[i]); g_ptr_array_free(m->uids, TRUE); camel_object_unref(m->folder); g_free(m->path); } static struct _mail_msg_op save_messages_op = { save_messages_desc, save_messages_save, save_messages_saved, save_messages_free, }; int mail_save_messages(CamelFolder *folder, GPtrArray *uids, const char *path, void (*done) (CamelFolder *folder, GPtrArray *uids, char *path, void *data), void *data) { struct _save_messages_msg *m; int id; m = mail_msg_new(&save_messages_op, NULL, sizeof(*m)); m->folder = folder; camel_object_ref(folder); m->uids = uids; m->path = g_strdup(path); m->data = data; m->done = done; id = m->msg.seq; e_thread_put(mail_thread_new, (EMsg *)m); return id; } /* ** SAVE PART ******************************************************* */ struct _save_part_msg { struct _mail_msg msg; CamelMimePart *part; char *path; void (*done)(CamelMimePart *part, char *path, int saved, void *data); void *data; }; static char *save_part_desc(struct _mail_msg *mm, int done) { return g_strdup(_("Saving attachment")); } static void save_part_save (struct _mail_msg *mm) { struct _save_part_msg *m = (struct _save_part_msg *)mm; CamelMimeFilterCharset *charsetfilter; CamelContentType *content_type; CamelStream *filtered_stream; CamelStream *stream_fs; CamelDataWrapper *data; const char *charset; stream_fs = camel_stream_fs_new_with_name (m->path, O_WRONLY | O_CREAT | O_TRUNC, 0666); if (stream_fs == NULL) { camel_exception_setv (&mm->ex, CAMEL_EXCEPTION_SYSTEM, _("Cannot create output file: %s:\n %s"), m->path, g_strerror (errno)); return; } /* we only convert text/ parts, and we only convert if we have to null charset param == us-ascii == utf8 always, and utf8 == utf8 obviously */ /* this will also let "us-ascii that isn't really" parts pass out in proper format, without us trying to treat it as what it isn't, which is the same algorithm camel uses */ data = camel_medium_get_content_object (CAMEL_MEDIUM (m->part)); content_type = camel_mime_part_get_content_type (m->part); if (header_content_type_is (content_type, "text", "*") && (charset = header_content_type_param (content_type, "charset")) && strcasecmp (charset, "utf-8") != 0) { charsetfilter = camel_mime_filter_charset_new_convert ("utf-8", charset); filtered_stream = (CamelStream *) camel_stream_filter_new_with_stream (stream_fs); camel_object_unref (CAMEL_OBJECT (stream_fs)); if (charsetfilter) { camel_stream_filter_add (CAMEL_STREAM_FILTER (filtered_stream), CAMEL_MIME_FILTER (charsetfilter)); camel_object_unref (charsetfilter); } } else { filtered_stream = stream_fs; } if (camel_data_wrapper_decode_to_stream (data, filtered_stream) == -1 || camel_stream_flush (filtered_stream) == -1) camel_exception_setv (&mm->ex, CAMEL_EXCEPTION_SYSTEM, _("Could not write data: %s"), g_strerror (errno)); camel_object_unref (filtered_stream); } static void save_part_saved (struct _mail_msg *mm) { struct _save_part_msg *m = (struct _save_part_msg *)mm; if (m->done) m->done (m->part, m->path, !camel_exception_is_set (&mm->ex), m->data); } static void save_part_free (struct _mail_msg *mm) { struct _save_part_msg *m = (struct _save_part_msg *)mm; camel_object_unref (m->part); g_free (m->path); } static struct _mail_msg_op save_part_op = { save_part_desc, save_part_save, save_part_saved, save_part_free, }; int mail_save_part (CamelMimePart *part, const char *path, void (*done)(CamelMimePart *part, char *path, int saved, void *data), void *data) { struct _save_part_msg *m; int id; m = mail_msg_new (&save_part_op, NULL, sizeof (*m)); m->part = part; camel_object_ref (part); m->path = g_strdup (path); m->data = data; m->done = done; id = m->msg.seq; e_thread_put (mail_thread_new, (EMsg *)m); return id; } /* ** PREPARE OFFLINE ***************************************************** */ struct _prep_offline_msg { struct _mail_msg msg; CamelOperation *cancel; char *uri; void (*done)(const char *uri, void *data); void *data; }; static void prep_offline_do(struct _mail_msg *mm) { struct _prep_offline_msg *m = (struct _prep_offline_msg *)mm; CamelFolder *folder; if (m->cancel) camel_operation_register(m->cancel); folder = mail_tool_uri_to_folder(m->uri, 0, &mm->ex); if (folder) { if (CAMEL_IS_DISCO_FOLDER(folder)) { camel_disco_folder_prepare_for_offline((CamelDiscoFolder *)folder, "(match-all (or (not (system-flag \"Seen\")) (system-flag \"Flagged\")))", &mm->ex); } /* prepare_for_offline should do this? */ /* of course it should all be atomic, but ... */ camel_folder_sync(folder, FALSE, NULL); camel_object_unref(folder); } if (m->cancel) camel_operation_unregister(m->cancel); } static void prep_offline_done(struct _mail_msg *mm) { struct _prep_offline_msg *m = (struct _prep_offline_msg *)mm; if (m->done) m->done(m->uri, m->data); } static void prep_offline_free(struct _mail_msg *mm) { struct _prep_offline_msg *m = (struct _prep_offline_msg *)mm; if (m->cancel) camel_operation_unref(m->cancel); g_free(m->uri); } static struct _mail_msg_op prep_offline_op = { NULL, /* DO NOT CHANGE THIS, IT MUST BE NULL FOR CANCELLATION TO WORK */ prep_offline_do, prep_offline_done, prep_offline_free, }; void mail_prep_offline(const char *uri, CamelOperation *cancel, void (*done)(const char *, void *data), void *data) { struct _prep_offline_msg *m; m = mail_msg_new(&prep_offline_op, NULL, sizeof(*m)); m->cancel = cancel; if (cancel) camel_operation_ref(cancel); m->uri = g_strdup(uri); m->data = data; m->done = done; e_thread_put(mail_thread_queued, (EMsg *)m); } /* ** GO OFFLINE ***************************************************** */ struct _set_offline_msg { struct _mail_msg msg; CamelStore *store; gboolean offline; void (*done)(CamelStore *store, void *data); void *data; }; static char *set_offline_desc(struct _mail_msg *mm, int done) { struct _set_offline_msg *m = (struct _set_offline_msg *)mm; char *service_name = camel_service_get_name (CAMEL_SERVICE (m->store), TRUE); char *msg; msg = g_strdup_printf(m->offline?_("Disconnecting from %s"):_("Reconnecting to %s"), service_name); g_free(service_name); return msg; } static void set_offline_do(struct _mail_msg *mm) { struct _set_offline_msg *m = (struct _set_offline_msg *)mm; if (CAMEL_IS_DISCO_STORE (m->store)) { if (!m->offline) { camel_disco_store_set_status (CAMEL_DISCO_STORE (m->store), CAMEL_DISCO_STORE_ONLINE, &mm->ex); return; } else if (camel_disco_store_can_work_offline (CAMEL_DISCO_STORE (m->store))) { camel_disco_store_set_status (CAMEL_DISCO_STORE (m->store), CAMEL_DISCO_STORE_OFFLINE, &mm->ex); return; } } if (m->offline) camel_service_disconnect (CAMEL_SERVICE (m->store), TRUE, &mm->ex); } static void set_offline_done(struct _mail_msg *mm) { struct _set_offline_msg *m = (struct _set_offline_msg *)mm; if (m->done) m->done(m->store, m->data); } static void set_offline_free(struct _mail_msg *mm) { struct _set_offline_msg *m = (struct _set_offline_msg *)mm; camel_object_unref(m->store); } static struct _mail_msg_op set_offline_op = { set_offline_desc, set_offline_do, set_offline_done, set_offline_free, }; int mail_store_set_offline (CamelStore *store, gboolean offline, void (*done)(CamelStore *, void *data), void *data) { struct _set_offline_msg *m; int id; /* Cancel any pending connect first so the set_offline_op * thread won't get queued behind a hung connect op. */ if (offline) camel_service_cancel_connect (CAMEL_SERVICE (store)); m = mail_msg_new(&set_offline_op, NULL, sizeof(*m)); m->store = store; camel_object_ref(store); m->offline = offline; m->data = data; m->done = done; id = m->msg.seq; e_thread_put(mail_thread_new, (EMsg *)m); return id; } /* ** Execute Shell Command ***************************************************** */ void mail_execute_shell_command (CamelFilterDriver *driver, int argc, char **argv, void *data) { if (argc <= 0) return; gnome_execute_async_fds (NULL, argc, argv, TRUE); }