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
|
/* SylFilter - a message filter
*
* Copyright (C) 2011 Hiroyuki Yamamoto
* Copyright (C) 2011 Sylpheed Development Team
*/
#include <glib.h>
#include "filter.h"
#include "filter-manager.h"
#include "filter-private.h"
XFilterManager *xfilter_manager_new(void)
{
XFilterManager *mgr;
mgr = g_new0(XFilterManager, 1);
return mgr;
}
void xfilter_manager_free(XFilterManager *mgr)
{
XFilter *list;
XFilter *next;
if (!mgr)
return;
for (list = mgr->filter_list; list != NULL; list = next) {
next = list->next;
xfilter_free(list);
}
g_free(mgr->original_encoding);
g_free(mgr);
}
void xfilter_manager_filter_add(XFilterManager *mgr, XFilter *filter)
{
XFilter *list;
g_return_if_fail(mgr != NULL);
g_return_if_fail(filter != NULL);
list = mgr->filter_list;
if (list) {
while (list->next) {
list = list->next;
}
list->next = filter;
} else {
mgr->filter_list = filter;
}
filter->manager = mgr;
}
void xfilter_manager_filter_remove(XFilterManager *mgr, XFilter *filter)
{
XFilter *list;
XFilter *prev = NULL;
g_return_if_fail(mgr != NULL);
g_return_if_fail(filter != NULL);
for (list = mgr->filter_list; list != NULL; list = list->next) {
if (list == filter) {
if (prev)
prev->next = list->next;
list->next = NULL;
filter->manager = NULL;
break;
}
prev = list;
}
}
int xfilter_manager_add_filters(XFilterManager *mgr, XFilterConstructorFunc ctors[])
{
XFilter *filter;
int i;
for (i = 0; ctors[i] != NULL; i++) {
filter = ctors[i]();
if (!filter)
return -1;
xfilter_manager_filter_add(mgr, filter);
}
return 0;
}
void xfilter_manager_done(XFilterManager *mgr)
{
g_return_if_fail(mgr != NULL);
g_free(mgr->original_encoding);
mgr->original_encoding = NULL;
}
XFilterResult *xfilter_manager_run(XFilterManager *mgr, XMessageData *msgdata)
{
XFilter *list;
const XMessageData *curdata;
XFilterResult *res;
XFilterStatus status;
g_return_val_if_fail(mgr != NULL, NULL);
xfilter_debug_print("%s: %s: run filter chain\n", __FILE__, G_STRFUNC);
res = xfilter_result_new();
curdata = msgdata;
for (list = mgr->filter_list; list != NULL; list = list->next) {
xfilter_debug_print("exec filter: %s [%s] in data type: %s\n", xfilter_get_name(list), xfilter_get_type(list) == XF_CONTENT ? "content filter" : "test filter", xfilter_message_data_get_mime_type(curdata));
status = xfilter_exec(list, curdata, res);
if (res->msgdata)
curdata = res->msgdata;
xfilter_debug_print("exec filter: %s: status %d: out data type: %s\n", xfilter_get_name(list), status, xfilter_message_data_get_mime_type(curdata));
if (status == XF_JUNK) {
xfilter_debug_print("filter returned XF_JUNK, end filter chain\n");
break;
}
if (status == XF_UNSUPPORTED_TYPE || status == XF_ERROR) {
xfilter_debug_print("filter returned error, end filter chain\n");
break;
}
}
xfilter_manager_done(mgr);
return res;
}
|
