kmail/agents/sendlateragent/sendlateragent.cpp

   1 /*
   2    Copyright (C) 2013-2016 Montel Laurent <montel@kde.org>
   3
   4    This program is free software; you can redistribute it and/or
   5    modify it under the terms of the GNU General Public
   6    License as published by the Free Software Foundation; either
   7    version 2 of the License, or (at your option) any later version.
   8
   9    This program is distributed in the hope that it will be useful,
  10    but WITHOUT ANY WARRANTY; without even the implied warranty of
  11    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  12    General Public License for more details.
  13
  14    You should have received a copy of the GNU General Public License
  15    along with this program; see the file COPYING.  If not, write to
  16    the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
  17    Boston, MA 02110-1301, USA.
  18 */
  19
  20 #include "sendlateragent.h"
  21 #include "sendlatermanager.h"
  22 #include "sendlaterconfiguredialog.h"
  23 #include "sendlaterinfo.h"
  24 #include "sendlaterutil.h"
  25 #include "sendlateragentadaptor.h"
  26 #include "sendlateragentsettings.h"
  27 #include "sendlaterremovemessagejob.h"
  28 #include "sendlateragent_debug.h"
  29 #include <Akonadi/KMime/SpecialMailCollections>
  30 #include <AgentInstance>
  31 #include <AgentManager>
  32 #include <kdbusconnectionpool.h>
  33 #include <changerecorder.h>
  34 #include <itemfetchscope.h>
  35 #include <AkonadiCore/session.h>
  36 #include <AttributeFactory>
  37 #include <CollectionFetchScope>
  38 #include <KMime/Message>
  39
  40 #include <KWindowSystem>
  41 #include <Kdelibs4ConfigMigrator>
  42
  43 #include <QPointer>
  44
  45 //#define DEBUG_SENDLATERAGENT 1
  46
  47 SendLaterAgent::SendLaterAgent(const QString &id)
  48     : Akonadi::AgentBase(id),
  49       mAgentInitialized(false)
  50 {
  51     Kdelibs4ConfigMigrator migrate(QStringLiteral("sendlateragent"));
  52     migrate.setConfigFiles(QStringList() << QStringLiteral("akonadi_sendlater_agentrc") << QStringLiteral("akonadi_sendlater_agent.notifyrc"));
  53     migrate.migrate();
  54
  55     mManager = new SendLaterManager(this);
  56     connect(mManager, &SendLaterManager::needUpdateConfigDialogBox, this, &SendLaterAgent::needUpdateConfigDialogBox);
  57     new SendLaterAgentAdaptor(this);
  58     KDBusConnectionPool::threadConnection().registerObject(QStringLiteral("/SendLaterAgent"), this, QDBusConnection::ExportAdaptors);
  59     KDBusConnectionPool::threadConnection().registerService(QStringLiteral("org.freedesktop.Akonadi.SendLaterAgent"));
  60
  61     changeRecorder()->setMimeTypeMonitored(KMime::Message::mimeType());
  62     changeRecorder()->itemFetchScope().setCacheOnly(true);
  63     changeRecorder()->itemFetchScope().setFetchModificationTime(false);
  64     changeRecorder()->setChangeRecordingEnabled(false);
  65     changeRecorder()->ignoreSession(Akonadi::Session::defaultSession());
  66     setNeedsNetwork(true);
  67
  68     if (SendLaterAgentSettings::enabled()) {
  69 #ifdef DEBUG_SENDLATERAGENT
  70         QTimer::singleShot(1000, this, &SendLaterAgent::slotStartAgent);
  71 #else
  72         QTimer::singleShot(1000 * 60 * 4, this, &SendLaterAgent::slotStartAgent);
  73 #endif
  74     }
  75     // For extra safety, check list every hour, in case we didn't properly get
  76     // notified about the network going up or down.
  77     QTimer *reloadListTimer = new QTimer(this);
  78     connect(reloadListTimer, &QTimer::timeout, this, &SendLaterAgent::reload);
  79     reloadListTimer->start(1000 * 60 * 60); //1 hour
  80 }
  81
  82 SendLaterAgent::~SendLaterAgent()
  83 {
  84 }
  85
  86 void SendLaterAgent::slotStartAgent()
  87 {
  88     mAgentInitialized = true;
  89     if (isOnline()) {
  90         mManager->load();
  91     }
  92 }
  93
  94 void SendLaterAgent::doSetOnline(bool online)
  95 {
  96     if (mAgentInitialized) {
  97         if (online) {
  98             reload();
  99         } else {
 100             mManager->stopAll();
 101         }
 102     }
 103 }
 104
 105 void SendLaterAgent::reload()
 106 {
 107     qCDebug(SENDLATERAGENT_LOG) << " void SendLaterAgent::reload()";
 108     if (SendLaterAgentSettings::enabled()) {
 109         mManager->load(true);
 110     }
 111 }
 112
 113 void SendLaterAgent::setEnableAgent(bool enabled)
 114 {
 115     if (SendLaterAgentSettings::enabled() == enabled) {
 116         return;
 117     }
 118
 119     SendLaterAgentSettings::setEnabled(enabled);
 120     SendLaterAgentSettings::self()->save();
 121     if (enabled) {
 122         mManager->load();
 123     } else {
 124         mManager->stopAll();
 125     }
 126 }
 127
 128 bool SendLaterAgent::enabledAgent() const
 129 {
 130     return SendLaterAgentSettings::enabled();
 131 }
 132
 133 void SendLaterAgent::configure(WId windowId)
 134 {
 135     showConfigureDialog((qlonglong)windowId);
 136 }
 137
 138 void SendLaterAgent::slotSendNow(Akonadi::Item::Id id)
 139 {
 140     mManager->sendNow(id);
 141 }
 142
 143 void SendLaterAgent::showConfigureDialog(qlonglong windowId)
 144 {
 145     QPointer<SendLaterConfigureDialog> dialog = new SendLaterConfigureDialog();
 146     if (windowId) {
 147 #ifndef Q_OS_WIN
 148         KWindowSystem::setMainWindow(dialog, windowId);
 149 #else
 150         KWindowSystem::setMainWindow(dialog, (HWND)windowId);
 151 #endif
 152     }
 153     connect(this, &SendLaterAgent::needUpdateConfigDialogBox, dialog.data(), &SendLaterConfigureDialog::slotNeedToReloadConfig);
 154     connect(dialog.data(), &SendLaterConfigureDialog::sendNow, this, &SendLaterAgent::slotSendNow);
 155     if (dialog->exec()) {
 156         mManager->load();
 157         QList<Akonadi::Item::Id> listMessage = dialog->messagesToRemove();
 158         if (!listMessage.isEmpty()) {
 159             //Will delete in specific job when done.
 160             SendLaterRemoveMessageJob *sendlaterremovejob = new SendLaterRemoveMessageJob(listMessage, this);
 161             sendlaterremovejob->start();
 162         }
 163     }
 164     delete dialog;
 165 }
 166
 167 void SendLaterAgent::itemsRemoved(const Akonadi::Item::List &items)
 168 {
 169     Q_FOREACH (const Akonadi::Item &item, items) {
 170         mManager->itemRemoved(item.id());
 171     }
 172 }
 173
 174 void SendLaterAgent::itemsMoved(const Akonadi::Item::List &items, const Akonadi::Collection &/*sourceCollection*/, const Akonadi::Collection &destinationCollection)
 175 {
 176     if (Akonadi::SpecialMailCollections::self()->specialCollectionType(destinationCollection) != Akonadi::SpecialMailCollections::Trash) {
 177         return;
 178     }
 179     itemsRemoved(items);
 180 }
 181
 182 QString SendLaterAgent::printDebugInfo()
 183 {
 184     return mManager->printDebugInfo();
 185 }
 186
 187 AKONADI_AGENT_MAIN(SendLaterAgent)
 188