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_finalize (GObject *obj);
41 static void modest_tny_send_queue_instance_init (GTypeInstance *instance, gpointer g_class);
44 static void _on_msg_start_sending (TnySendQueue *self, TnyMsg *msg, guint processed, guint total);
45 static void _on_msg_has_been_sent (TnySendQueue *self, TnyMsg *msg, guint processed, guint total);
55 typedef struct _ModestTnySendQueuePrivate ModestTnySendQueuePrivate;
56 struct _ModestTnySendQueuePrivate {
57 gchar *current_msg_id;
61 #define MODEST_TNY_SEND_QUEUE_GET_PRIVATE(o) (G_TYPE_INSTANCE_GET_PRIVATE((o), \
62 MODEST_TYPE_TNY_SEND_QUEUE, \
63 ModestTnySendQueuePrivate))
66 static TnyCamelSendQueueClass *parent_class = NULL;
68 /* uncomment the following if you have defined any signals */
69 /* static guint signals[LAST_SIGNAL] = {0}; */
72 * this thread actually tries to send all the mails in the outbox
77 modest_tny_send_queue_cancel (TnySendQueue *self, gboolean remove, GError **err)
79 TNY_CAMEL_SEND_QUEUE_CLASS(parent_class)->cancel_func (self, remove, err); /* FIXME */
83 modest_tny_send_queue_add (TnySendQueue *self, TnyMsg *msg, GError **err)
85 g_return_if_fail (TNY_IS_SEND_QUEUE(self));
86 g_return_if_fail (TNY_IS_CAMEL_MSG(msg));
88 /* FIXME: do something smart here... */
90 TNY_CAMEL_SEND_QUEUE_CLASS(parent_class)->add_func (self, msg, err); /* FIXME */
94 modest_tny_send_queue_get_sentbox (TnySendQueue *self)
97 TnyCamelTransportAccount *account;
99 g_return_val_if_fail (self, NULL);
101 account = tny_camel_send_queue_get_transport_account (TNY_CAMEL_SEND_QUEUE(self));
103 g_printerr ("modest: no account for send queue\n");
106 folder = modest_tny_account_get_special_folder (TNY_ACCOUNT(account),
107 TNY_FOLDER_TYPE_SENT);
108 g_object_unref (G_OBJECT(account));
115 modest_tny_send_queue_get_outbox (TnySendQueue *self)
118 TnyCamelTransportAccount *account;
120 g_return_val_if_fail (self, NULL);
122 account = tny_camel_send_queue_get_transport_account (TNY_CAMEL_SEND_QUEUE(self));
124 g_printerr ("modest: no account for send queue\n");
127 folder = modest_tny_account_get_special_folder (TNY_ACCOUNT(account),
128 TNY_FOLDER_TYPE_OUTBOX);
129 g_object_unref (G_OBJECT(account));
136 modest_tny_send_queue_get_type (void)
138 static GType my_type = 0;
141 static const GTypeInfo my_info = {
142 sizeof(ModestTnySendQueueClass),
143 NULL, /* base init */
144 NULL, /* base finalize */
145 (GClassInitFunc) modest_tny_send_queue_class_init,
146 NULL, /* class finalize */
147 NULL, /* class data */
148 sizeof(ModestTnySendQueue),
150 (GInstanceInitFunc) modest_tny_send_queue_instance_init,
153 my_type = g_type_register_static (TNY_TYPE_CAMEL_SEND_QUEUE,
154 "ModestTnySendQueue",
162 modest_tny_send_queue_class_init (ModestTnySendQueueClass *klass)
164 GObjectClass *gobject_class;
166 gobject_class = (GObjectClass*) klass;
168 parent_class = g_type_class_peek_parent (klass);
169 gobject_class->finalize = modest_tny_send_queue_finalize;
171 TNY_CAMEL_SEND_QUEUE_CLASS(klass)->add_func = modest_tny_send_queue_add;
172 TNY_CAMEL_SEND_QUEUE_CLASS(klass)->get_outbox_func = modest_tny_send_queue_get_outbox;
173 TNY_CAMEL_SEND_QUEUE_CLASS(klass)->get_sentbox_func = modest_tny_send_queue_get_sentbox;
174 TNY_CAMEL_SEND_QUEUE_CLASS(klass)->cancel_func = modest_tny_send_queue_cancel;
176 g_type_class_add_private (gobject_class, sizeof(ModestTnySendQueuePrivate));
180 modest_tny_send_queue_instance_init (GTypeInstance *instance, gpointer g_class)
182 ModestTnySendQueuePrivate *priv;
184 priv = MODEST_TNY_SEND_QUEUE_GET_PRIVATE (instance);
185 priv->current_msg_id = NULL;
190 modest_tny_send_queue_finalize (GObject *obj)
192 ModestTnySendQueuePrivate *priv;
194 priv = MODEST_TNY_SEND_QUEUE_GET_PRIVATE (obj);
195 if (priv->current_msg_id != NULL)
196 g_free(priv->current_msg_id);
198 G_OBJECT_CLASS(parent_class)->finalize (obj);
202 modest_tny_send_queue_new (TnyCamelTransportAccount *account)
204 ModestTnySendQueue *self;
206 g_return_val_if_fail (TNY_IS_CAMEL_TRANSPORT_ACCOUNT(account), NULL);
208 self = MODEST_TNY_SEND_QUEUE(g_object_new(MODEST_TYPE_TNY_SEND_QUEUE, NULL));
210 tny_camel_send_queue_set_transport_account (TNY_CAMEL_SEND_QUEUE(self),
213 /* Connect signals to control when a msg is being or has been sent */
214 /* TODO: this signal was implemented in tinymail camel send queue, but im
215 waiting for implement some unit tests nbefore commited changes */
217 g_signal_connect (G_OBJECT(self), "msg-sending",
218 G_CALLBACK(_on_msg_start_sending),
222 g_signal_connect (G_OBJECT(self), "msg-sent",
223 G_CALLBACK(_on_msg_has_been_sent),
231 modest_tny_send_queue_try_to_send (ModestTnySendQueue* self)
233 /* TODO: Rename this to tny_camel_send_queue_try_to_send() in tinymail
234 and check that it works, without creating a second worker. */
235 /* tny_camel_send_queue_flush (TNY_CAMEL_SEND_QUEUE(self)); */
239 modest_tny_send_queue_msg_is_being_sent (ModestTnySendQueue* self,
242 ModestTnySendQueuePrivate *priv;
244 g_return_val_if_fail (msg_id != NULL, FALSE);
245 priv = MODEST_TNY_SEND_QUEUE_GET_PRIVATE (self);
247 if (modest_tny_send_queue_sending_in_progress(self))
248 return g_ascii_strcasecmp(priv->current_msg_id, msg_id);
254 modest_tny_send_queue_sending_in_progress (ModestTnySendQueue* self)
256 ModestTnySendQueuePrivate *priv;
258 priv = MODEST_TNY_SEND_QUEUE_GET_PRIVATE (self);
260 return priv->current_msg_id != NULL;
265 _on_msg_start_sending (TnySendQueue *self,
270 ModestTnySendQueuePrivate *priv;
271 TnyHeader *header = NULL;
273 priv = MODEST_TNY_SEND_QUEUE_GET_PRIVATE (self);
275 /* Delete previous msg_id */
276 if (priv->current_msg_id != NULL)
277 g_free(priv->current_msg_id);
279 /* Set current msg_id */
280 header = tny_msg_get_header(msg);
281 priv->current_msg_id = g_strdup(tny_header_get_message_id (header));
285 _on_msg_has_been_sent (TnySendQueue *self,
290 ModestTnySendQueuePrivate *priv;
292 priv = MODEST_TNY_SEND_QUEUE_GET_PRIVATE (self);
294 /* Delete previous msg_id */
295 if (priv->current_msg_id != NULL)
296 g_free(priv->current_msg_id);
298 /* Unset current msg_id */
299 priv->current_msg_id = NULL;