1 /* Copyright (c) 2006, Nokia Corporation
4 * Redistribution and use in source and binary forms, with or without
5 * modification, are permitted provided that the following conditions are
8 * * Redistributions of source code must retain the above copyright
9 * notice, this list of conditions and the following disclaimer.
10 * * Redistributions in binary form must reproduce the above copyright
11 * notice, this list of conditions and the following disclaimer in the
12 * documentation and/or other materials provided with the distribution.
13 * * Neither the name of the Nokia Corporation nor the names of its
14 * contributors may be used to endorse or promote products derived from
15 * this software without specific prior written permission.
17 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS
18 * IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
19 * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A
20 * PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER
21 * OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
22 * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
23 * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
24 * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
25 * LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
26 * NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
27 * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
31 #include <modest-tny-send-queue.h>
32 #include <tny-simple-list.h>
33 #include <tny-iterator.h>
34 #include <tny-folder.h>
35 #include <tny-camel-msg.h>
36 #include <modest-tny-account.h>
38 /* 'private'/'protected' functions */
39 static void modest_tny_send_queue_class_init (ModestTnySendQueueClass *klass);
40 static void modest_tny_send_queue_init (gpointer g, gpointer iface_data);
41 static void modest_tny_send_queue_finalize (GObject *obj);
42 static void modest_tny_send_queue_instance_init (GTypeInstance *instance, gpointer g_class);
51 typedef struct _ModestTnySendQueuePrivate ModestTnySendQueuePrivate;
52 struct _ModestTnySendQueuePrivate {
53 TnyTransportAccount *account;
54 GThread *flush_outbox_thread;
58 #define MODEST_TNY_SEND_QUEUE_GET_PRIVATE(o) (G_TYPE_INSTANCE_GET_PRIVATE((o), \
59 MODEST_TYPE_TNY_SEND_QUEUE, \
60 ModestTnySendQueuePrivate))
62 static GObjectClass *parent_class = NULL;
64 /* uncomment the following if you have defined any signals */
65 /* static guint signals[LAST_SIGNAL] = {0}; */
69 * this thread actually tries to send all the mails in the outbox
72 flush_outbox_thread (TnySendQueue *self)
74 TnyFolder *outbox, *sentbox;
81 ModestTnySendQueuePrivate *priv;
83 priv = MODEST_TNY_SEND_QUEUE_GET_PRIVATE (self);
85 outbox = tny_send_queue_get_outbox (self);
86 sentbox = tny_send_queue_get_sentbox (self);
88 headers = tny_simple_list_new ();
90 g_mutex_lock (priv->flush_lock);
91 tny_folder_get_headers (outbox, headers, TRUE, NULL); /* FIXME: err */
92 iter = tny_list_create_iterator (headers);
94 while (!tny_iterator_is_done (iter)) {
95 header = TNY_HEADER(tny_iterator_get_current(iter));
96 msg = tny_folder_get_msg (outbox, header, NULL);
97 tny_transport_account_send (priv->account,
98 msg, NULL); /* FIXME: err */
99 tny_folder_add_msg (sentbox, msg, NULL); /* FIXME: err */
100 tny_folder_remove_msg (outbox, header, NULL); /* FIXME: err */
102 g_object_unref (G_OBJECT(header));
103 g_object_unref (G_OBJECT(msg));
105 tny_iterator_next (iter);
109 g_object_unref (G_OBJECT(headers));
110 g_object_unref (G_OBJECT(iter));
112 priv->flush_outbox_thread = NULL;
113 g_mutex_unlock (priv->flush_lock);
115 g_thread_exit (NULL);
120 modest_tny_send_queue_cancel (TnySendQueue *self, gboolean remove)
122 MODEST_TNY_SEND_QUEUE_GET_CLASS(self)->cancel_func (self, remove);
126 modest_tny_send_queue_add (TnySendQueue *self, TnyMsg *msg)
128 MODEST_TNY_SEND_QUEUE_GET_CLASS(self)->add_func (self, msg);
133 modest_tny_send_queue_get_sentbox (TnySendQueue *self)
135 return MODEST_TNY_SEND_QUEUE_GET_CLASS(self)->get_sentbox_func (self);
140 modest_tny_send_queue_get_outbox (TnySendQueue *self)
142 return MODEST_TNY_SEND_QUEUE_GET_CLASS(self)->get_outbox_func (self);
149 modest_tny_send_queue_cancel_default (TnySendQueue *self, gboolean remove)
156 modest_tny_send_queue_add_default (TnySendQueue *self, TnyMsg *msg)
158 ModestTnySendQueuePrivate *priv;
161 g_return_if_fail (self);
162 g_return_if_fail (TNY_IS_CAMEL_MSG(msg));
164 priv = MODEST_TNY_SEND_QUEUE_GET_PRIVATE (self);
166 outbox = tny_send_queue_get_outbox (self);
167 tny_folder_add_msg (outbox, msg, NULL);
169 priv->flush_outbox_thread = g_thread_create (
170 (GThreadFunc)flush_outbox_thread,
175 modest_tny_send_queue_get_sentbox_default (TnySendQueue *self)
177 ModestTnySendQueuePrivate *priv;
179 g_return_val_if_fail (self, NULL);
181 priv = MODEST_TNY_SEND_QUEUE_GET_PRIVATE (self);
183 return modest_tny_account_get_special_folder (TNY_ACCOUNT(priv->account),
184 TNY_FOLDER_TYPE_SENT);
189 modest_tny_send_queue_get_outbox_default (TnySendQueue *self)
191 ModestTnySendQueuePrivate *priv;
193 g_return_val_if_fail (self, NULL);
195 priv = MODEST_TNY_SEND_QUEUE_GET_PRIVATE (self);
197 return modest_tny_account_get_special_folder (TNY_ACCOUNT(priv->account),
198 TNY_FOLDER_TYPE_OUTBOX);
205 modest_tny_send_queue_get_type (void)
207 static GType my_type = 0;
209 if (G_UNLIKELY (!camel_type_init_done)) {
210 if (!g_thread_supported ())
211 g_thread_init (NULL);
213 camel_type_init_done = TRUE;
217 static const GTypeInfo my_info = {
218 sizeof(ModestTnySendQueueClass),
219 NULL, /* base init */
220 NULL, /* base finalize */
221 (GClassInitFunc) modest_tny_send_queue_class_init,
222 NULL, /* class finalize */
223 NULL, /* class data */
224 sizeof(ModestTnySendQueue),
226 (GInstanceInitFunc) modest_tny_send_queue_instance_init,
230 static const GInterfaceInfo tny_send_queue_info = {
231 (GInterfaceInitFunc) modest_tny_send_queue_init,
233 NULL, /* interface_finalize */
234 NULL /* interface_data */
237 my_type = g_type_register_static (G_TYPE_OBJECT,
238 "ModestTnySendQueue",
240 g_type_add_interface_static (my_type, TNY_TYPE_SEND_QUEUE,
241 &tny_send_queue_info);
249 modest_tny_send_queue_init (gpointer g, gpointer iface_data)
251 TnySendQueueIface *klass = (TnySendQueueIface*)g;
253 klass->add_func = modest_tny_send_queue_add;
254 klass->get_outbox_func = modest_tny_send_queue_get_outbox;
255 klass->get_sentbox_func = modest_tny_send_queue_get_sentbox;
256 klass->cancel_func = modest_tny_send_queue_cancel;
262 modest_tny_send_queue_class_init (ModestTnySendQueueClass *klass)
264 GObjectClass *gobject_class;
266 gobject_class = (GObjectClass*) klass;
268 parent_class = g_type_class_peek_parent (klass);
269 gobject_class->finalize = modest_tny_send_queue_finalize;
271 klass->add_func = modest_tny_send_queue_add_default;
272 klass->get_outbox_func = modest_tny_send_queue_get_outbox_default;
273 klass->get_sentbox_func = modest_tny_send_queue_get_sentbox_default;
274 klass->cancel_func = modest_tny_send_queue_cancel_default;
276 g_type_class_add_private (gobject_class, sizeof(ModestTnySendQueuePrivate));
280 modest_tny_send_queue_instance_init (GTypeInstance *instance, gpointer g_class)
282 ModestTnySendQueue *self;
283 ModestTnySendQueuePrivate *priv;
285 self = (ModestTnySendQueue*)instance;
286 priv = MODEST_TNY_SEND_QUEUE_GET_PRIVATE (self);
288 priv->flush_lock = g_mutex_new ();
289 priv->flush_outbox_thread = NULL;
290 priv->account = NULL;
294 modest_tny_send_queue_finalize (GObject *obj)
296 ModestTnySendQueuePrivate *priv;
297 priv = MODEST_TNY_SEND_QUEUE_GET_PRIVATE (obj);
300 g_object_unref (priv->account);
301 priv->account = NULL;
304 if (priv->flush_lock) {
305 g_mutex_free (priv->flush_lock);
306 priv->flush_lock = NULL;
309 G_OBJECT_CLASS(parent_class)->finalize (obj);
313 modest_tny_send_queue_new (TnyTransportAccount *account)
315 ModestTnySendQueue *self;
316 ModestTnySendQueuePrivate *priv;
318 g_return_val_if_fail (account, NULL);
320 self = MODEST_TNY_SEND_QUEUE(g_object_new(MODEST_TYPE_TNY_SEND_QUEUE, NULL));
321 priv = MODEST_TNY_SEND_QUEUE_GET_PRIVATE (self);
323 priv->account = account;
324 g_object_ref (G_OBJECT(priv->account));