2015-10-30 11:41:02 +01:00
|
|
|
// This file is part of RSS Guard.
|
|
|
|
//
|
|
|
|
// Copyright (C) 2011-2015 by Martin Rotter <rotter.martinos@gmail.com>
|
|
|
|
//
|
|
|
|
// RSS Guard is free software: you can redistribute it and/or modify
|
|
|
|
// it under the terms of the GNU General Public License as published by
|
|
|
|
// the Free Software Foundation, either version 3 of the License, or
|
|
|
|
// (at your option) any later version.
|
|
|
|
//
|
|
|
|
// RSS Guard is distributed in the hope that it will be useful,
|
|
|
|
// but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
|
|
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
|
|
// GNU General Public License for more details.
|
|
|
|
//
|
|
|
|
// You should have received a copy of the GNU General Public License
|
|
|
|
// along with RSS Guard. If not, see <http://www.gnu.org/licenses/>.
|
|
|
|
|
|
|
|
#include "services/standard/standardserviceroot.h"
|
|
|
|
|
2015-10-30 12:15:27 +01:00
|
|
|
#include "definitions/definitions.h"
|
|
|
|
#include "miscellaneous/application.h"
|
|
|
|
#include "miscellaneous/settings.h"
|
2015-11-06 09:41:36 +01:00
|
|
|
#include "miscellaneous/iconfactory.h"
|
2015-11-11 08:21:17 +01:00
|
|
|
#include "miscellaneous/mutex.h"
|
2015-11-03 10:06:34 +01:00
|
|
|
#include "core/feedsmodel.h"
|
2015-11-10 08:59:10 +01:00
|
|
|
#include "gui/messagebox.h"
|
|
|
|
#include "gui/dialogs/formmain.h"
|
|
|
|
#include "exceptions/applicationexception.h"
|
2015-10-30 12:15:27 +01:00
|
|
|
#include "services/standard/standardserviceentrypoint.h"
|
2015-10-30 13:07:42 +01:00
|
|
|
#include "services/standard/standardrecyclebin.h"
|
|
|
|
#include "services/standard/standardfeed.h"
|
|
|
|
#include "services/standard/standardcategory.h"
|
2015-11-03 10:06:34 +01:00
|
|
|
#include "services/standard/standardfeedsimportexportmodel.h"
|
2015-11-10 13:47:24 +01:00
|
|
|
#include "services/standard/gui/formstandardcategorydetails.h"
|
|
|
|
#include "services/standard/gui/formstandardfeeddetails.h"
|
2015-11-11 08:21:17 +01:00
|
|
|
#include "services/standard/gui/formstandardimportexport.h"
|
2015-10-30 12:15:27 +01:00
|
|
|
|
2015-10-30 13:07:42 +01:00
|
|
|
#include <QSqlQuery>
|
|
|
|
#include <QSqlError>
|
2015-11-03 10:06:34 +01:00
|
|
|
#include <QStack>
|
2015-11-08 19:48:29 +01:00
|
|
|
#include <QAction>
|
2015-11-10 13:47:24 +01:00
|
|
|
#include <QPointer>
|
2015-11-19 13:21:38 +01:00
|
|
|
#include <QSqlTableModel>
|
2015-10-30 11:41:02 +01:00
|
|
|
|
2015-10-30 13:07:42 +01:00
|
|
|
|
2015-11-30 12:53:04 +01:00
|
|
|
StandardServiceRoot::StandardServiceRoot(bool load_from_db, RootItem *parent)
|
|
|
|
: ServiceRoot(parent), m_recycleBin(new StandardRecycleBin(this)),
|
2015-11-11 08:21:17 +01:00
|
|
|
m_actionExportFeeds(NULL), m_actionImportFeeds(NULL), m_serviceMenu(QList<QAction*>()),
|
2015-11-08 19:48:29 +01:00
|
|
|
m_addItemMenu(QList<QAction*>()), m_feedContextMenu(QList<QAction*>()), m_actionFeedFetchMetadata(NULL) {
|
2015-11-17 07:41:23 +01:00
|
|
|
|
2015-11-09 09:40:26 +01:00
|
|
|
setTitle(qApp->system()->getUsername() + QL1S("@") + QL1S(APP_LOW_NAME));
|
|
|
|
setIcon(StandardServiceEntryPoint().icon());
|
|
|
|
setDescription(tr("This is obligatory service account for standard RSS/RDF/ATOM feeds."));
|
|
|
|
setCreationDate(QDateTime::currentDateTime());
|
2015-10-30 13:07:42 +01:00
|
|
|
|
2015-11-06 11:30:39 +01:00
|
|
|
if (load_from_db) {
|
|
|
|
loadFromDatabase();
|
|
|
|
}
|
2015-10-30 11:41:02 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
StandardServiceRoot::~StandardServiceRoot() {
|
2015-11-11 08:21:17 +01:00
|
|
|
qDeleteAll(m_serviceMenu);
|
2015-11-08 19:48:29 +01:00
|
|
|
qDeleteAll(m_addItemMenu);
|
|
|
|
qDeleteAll(m_feedContextMenu);
|
2015-10-30 11:41:02 +01:00
|
|
|
}
|
|
|
|
|
2015-11-10 08:59:10 +01:00
|
|
|
void StandardServiceRoot::start() {
|
|
|
|
if (qApp->isFirstRun()) {
|
2015-11-17 07:41:23 +01:00
|
|
|
if (MessageBox::show(qApp->mainForm(), QMessageBox::Question, QObject::tr("Load initial set of feeds"),
|
|
|
|
tr("You started %1 for the first time, now you can load initial set of feeds.").arg(APP_NAME),
|
|
|
|
tr("Do you want to load initial set of feeds?"),
|
2015-11-10 08:59:10 +01:00
|
|
|
QString(), QMessageBox::Yes | QMessageBox::No) == QMessageBox::Yes) {
|
|
|
|
QString target_opml_file = APP_INITIAL_FEEDS_PATH + QDir::separator() + FEED_INITIAL_OPML_PATTERN;
|
|
|
|
QString current_locale = qApp->localization()->loadedLanguage();
|
|
|
|
QString file_to_load;
|
|
|
|
|
|
|
|
if (QFile::exists(target_opml_file.arg(current_locale))) {
|
|
|
|
file_to_load = target_opml_file.arg(current_locale);
|
|
|
|
}
|
|
|
|
else if (QFile::exists(target_opml_file.arg(DEFAULT_LOCALE))) {
|
|
|
|
file_to_load = target_opml_file.arg(DEFAULT_LOCALE);
|
|
|
|
}
|
|
|
|
|
|
|
|
FeedsImportExportModel model;
|
|
|
|
QString output_msg;
|
|
|
|
|
|
|
|
try {
|
|
|
|
model.importAsOPML20(IOFactory::readTextFile(file_to_load));
|
|
|
|
model.checkAllItems();
|
|
|
|
mergeImportExportModel(&model, output_msg);
|
|
|
|
}
|
|
|
|
catch (ApplicationException &ex) {
|
|
|
|
MessageBox::show(qApp->mainForm(), QMessageBox::Critical, tr("Error when loading initial feeds"), ex.message());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
void StandardServiceRoot::stop() {
|
2015-11-17 07:41:23 +01:00
|
|
|
qDebug("Stopping StandardServiceRoot instance.");
|
2015-11-10 08:59:10 +01:00
|
|
|
}
|
|
|
|
|
2015-11-30 10:50:37 +01:00
|
|
|
QString StandardServiceRoot::code() {
|
|
|
|
return SERVICE_CODE_STD_RSS;
|
|
|
|
}
|
|
|
|
|
2015-10-30 12:15:27 +01:00
|
|
|
bool StandardServiceRoot::canBeEdited() {
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
|
|
|
|
bool StandardServiceRoot::canBeDeleted() {
|
2015-11-29 20:27:52 +01:00
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
|
|
|
bool StandardServiceRoot::deleteViaGui() {
|
|
|
|
QSqlDatabase connection = qApp->database()->connection(metaObject()->className(), DatabaseFactory::FromSettings);
|
|
|
|
|
|
|
|
// Remove all messages.
|
|
|
|
if (!QSqlQuery(connection).exec(QSL("DELETE FROM Messages;"))) {
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
|
|
|
|
// Remove all feeds.
|
|
|
|
if (!QSqlQuery(connection).exec(QSL("DELETE FROM Feeds;"))) {
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
|
|
|
|
// Remove all categories.
|
|
|
|
if (!QSqlQuery(connection).exec(QSL("DELETE FROM Categories;"))) {
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
|
|
|
|
// Switch "existence" flag.
|
2015-12-02 13:32:19 +01:00
|
|
|
bool data_removed = QSqlQuery(connection).exec(QString("DELETE FROM Accounts WHERE id = %1;").arg(QString::number(id())));
|
2015-11-29 20:27:52 +01:00
|
|
|
|
|
|
|
if (data_removed) {
|
2015-11-30 12:53:04 +01:00
|
|
|
requestItemRemoval(this);
|
2015-11-29 20:27:52 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
return data_removed;
|
2015-10-30 12:15:27 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
QVariant StandardServiceRoot::data(int column, int role) const {
|
|
|
|
switch (role) {
|
|
|
|
case Qt::ToolTipRole:
|
|
|
|
if (column == FDS_MODEL_TITLE_INDEX) {
|
2015-11-03 19:06:21 +01:00
|
|
|
return tr("This is service account for standard RSS/RDF/ATOM feeds.");
|
2015-10-30 12:15:27 +01:00
|
|
|
}
|
|
|
|
else if (column == FDS_MODEL_COUNTS_INDEX) {
|
|
|
|
//: Tooltip for "unread" column of feed list.
|
|
|
|
return tr("%n unread message(s).", 0, countOfUnreadMessages());
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
return QVariant();
|
|
|
|
}
|
|
|
|
|
|
|
|
default:
|
2015-11-09 09:40:26 +01:00
|
|
|
return ServiceRoot::data(column, role);
|
2015-10-30 12:15:27 +01:00
|
|
|
}
|
|
|
|
}
|
2015-10-30 13:07:42 +01:00
|
|
|
|
2015-11-25 09:37:40 +01:00
|
|
|
Qt::ItemFlags StandardServiceRoot::additionalFlags() const {
|
|
|
|
return Qt::ItemIsDropEnabled;
|
|
|
|
}
|
|
|
|
|
2015-11-24 09:13:43 +01:00
|
|
|
RecycleBin *StandardServiceRoot::recycleBin() {
|
|
|
|
return m_recycleBin;
|
|
|
|
}
|
|
|
|
|
2015-11-12 10:53:17 +01:00
|
|
|
bool StandardServiceRoot::markFeedsReadUnread(QList<Feed*> items, ReadStatus read) {
|
2015-11-24 09:13:43 +01:00
|
|
|
QSqlDatabase db_handle = qApp->database()->connection(metaObject()->className(), DatabaseFactory::FromSettings);
|
2015-11-12 10:53:17 +01:00
|
|
|
|
|
|
|
if (!db_handle.transaction()) {
|
|
|
|
qWarning("Starting transaction for feeds read change.");
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
|
|
|
|
QSqlQuery query_read_msg(db_handle);
|
|
|
|
query_read_msg.setForwardOnly(true);
|
|
|
|
|
|
|
|
if (!query_read_msg.prepare(QString("UPDATE Messages SET is_read = :read "
|
|
|
|
"WHERE feed IN (%1) AND is_deleted = 0;").arg(textualFeedIds(items).join(QSL(", "))))) {
|
|
|
|
qWarning("Query preparation failed for feeds read change.");
|
|
|
|
|
|
|
|
db_handle.rollback();
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
|
|
|
|
query_read_msg.bindValue(QSL(":read"), read == RootItem::Read ? 1 : 0);
|
|
|
|
|
|
|
|
if (!query_read_msg.exec()) {
|
|
|
|
qDebug("Query execution for feeds read change failed.");
|
|
|
|
db_handle.rollback();
|
|
|
|
}
|
|
|
|
|
|
|
|
// Commit changes.
|
|
|
|
if (db_handle.commit()) {
|
2015-11-20 13:29:32 +01:00
|
|
|
// Messages are cleared, now inform model about need to reload data.
|
|
|
|
QList<RootItem*> itemss;
|
|
|
|
|
|
|
|
foreach (Feed *feed, items) {
|
|
|
|
feed->updateCounts(true);
|
|
|
|
itemss.append(feed);
|
|
|
|
}
|
|
|
|
|
2015-11-23 13:13:03 +01:00
|
|
|
itemChanged(itemss);
|
|
|
|
requestReloadMessageList(read == RootItem::Read);
|
2015-11-12 10:53:17 +01:00
|
|
|
return true;
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
return db_handle.rollback();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2015-11-12 10:59:41 +01:00
|
|
|
bool StandardServiceRoot::markRecycleBinReadUnread(RootItem::ReadStatus read) {
|
2015-11-24 09:13:43 +01:00
|
|
|
QSqlDatabase db_handle = qApp->database()->connection(metaObject()->className(), DatabaseFactory::FromSettings);
|
2015-11-12 10:59:41 +01:00
|
|
|
|
|
|
|
if (!db_handle.transaction()) {
|
|
|
|
qWarning("Starting transaction for recycle bin read change.");
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
|
|
|
|
QSqlQuery query_read_msg(db_handle);
|
|
|
|
query_read_msg.setForwardOnly(true);
|
|
|
|
|
|
|
|
if (!query_read_msg.prepare("UPDATE Messages SET is_read = :read WHERE is_deleted = 1;")) {
|
|
|
|
qWarning("Query preparation failed for recycle bin read change.");
|
|
|
|
|
|
|
|
db_handle.rollback();
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
|
|
|
|
query_read_msg.bindValue(QSL(":read"), read == RootItem::Read ? 1 : 0);
|
|
|
|
|
|
|
|
if (!query_read_msg.exec()) {
|
|
|
|
qDebug("Query execution for recycle bin read change failed.");
|
|
|
|
db_handle.rollback();
|
|
|
|
}
|
|
|
|
|
|
|
|
// Commit changes.
|
|
|
|
if (db_handle.commit()) {
|
2015-11-20 13:29:32 +01:00
|
|
|
m_recycleBin->updateCounts(true);
|
|
|
|
|
2015-11-23 13:13:03 +01:00
|
|
|
itemChanged(QList<RootItem*>() << m_recycleBin);
|
|
|
|
requestReloadMessageList(read == RootItem::Read);
|
2015-11-12 10:59:41 +01:00
|
|
|
return true;
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
return db_handle.rollback();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2015-11-12 10:53:17 +01:00
|
|
|
bool StandardServiceRoot::cleanFeeds(QList<Feed*> items, bool clean_read_only) {
|
2015-11-24 09:13:43 +01:00
|
|
|
QSqlDatabase db_handle = qApp->database()->connection(metaObject()->className(), DatabaseFactory::FromSettings);
|
2015-11-12 10:53:17 +01:00
|
|
|
QSqlQuery query_delete_msg(db_handle);
|
|
|
|
query_delete_msg.setForwardOnly(true);
|
|
|
|
|
|
|
|
if (clean_read_only) {
|
|
|
|
if (!query_delete_msg.prepare(QString("UPDATE Messages SET is_deleted = :deleted "
|
|
|
|
"WHERE feed IN (%1) AND is_deleted = 0 AND is_read = 1;").arg(textualFeedIds(items).join(QSL(", "))))) {
|
|
|
|
qWarning("Query preparation failed for feeds clearing.");
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
if (!query_delete_msg.prepare(QString("UPDATE Messages SET is_deleted = :deleted "
|
|
|
|
"WHERE feed IN (%1) AND is_deleted = 0;").arg(textualFeedIds(items).join(QSL(", "))))) {
|
|
|
|
qWarning("Query preparation failed for feeds clearing.");
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
query_delete_msg.bindValue(QSL(":deleted"), 1);
|
|
|
|
|
|
|
|
if (!query_delete_msg.exec()) {
|
|
|
|
qDebug("Query execution for feeds clearing failed.");
|
2015-11-20 13:29:32 +01:00
|
|
|
return false;
|
2015-11-12 10:53:17 +01:00
|
|
|
}
|
2015-11-20 13:29:32 +01:00
|
|
|
else {
|
|
|
|
// Messages are cleared, now inform model about need to reload data.
|
|
|
|
QList<RootItem*> itemss;
|
2015-11-12 10:53:17 +01:00
|
|
|
|
2015-11-20 13:29:32 +01:00
|
|
|
foreach (Feed *feed, items) {
|
|
|
|
feed->updateCounts(true);
|
|
|
|
itemss.append(feed);
|
|
|
|
}
|
|
|
|
|
|
|
|
m_recycleBin->updateCounts(true);
|
|
|
|
itemss.append(m_recycleBin);
|
|
|
|
|
2015-11-23 13:13:03 +01:00
|
|
|
itemChanged(itemss);
|
|
|
|
requestReloadMessageList(true);
|
2015-11-12 10:53:17 +01:00
|
|
|
return true;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2015-11-24 09:13:43 +01:00
|
|
|
bool StandardServiceRoot::restoreBin() {
|
|
|
|
QSqlDatabase db_handle = qApp->database()->connection(metaObject()->className(), DatabaseFactory::FromSettings);
|
|
|
|
|
|
|
|
if (!db_handle.transaction()) {
|
|
|
|
qWarning("Starting transaction for recycle bin restoring.");
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
|
|
|
|
QSqlQuery query_empty_bin(db_handle);
|
|
|
|
query_empty_bin.setForwardOnly(true);
|
|
|
|
|
|
|
|
if (!query_empty_bin.exec(QSL("UPDATE Messages SET is_deleted = 0 WHERE is_deleted = 1 AND is_pdeleted = 0;"))) {
|
|
|
|
qWarning("Query execution failed for recycle bin restoring.");
|
|
|
|
|
|
|
|
db_handle.rollback();
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
|
|
|
|
// Commit changes.
|
|
|
|
if (db_handle.commit()) {
|
|
|
|
updateCounts(true);
|
|
|
|
itemChanged(getSubTree());
|
|
|
|
requestReloadMessageList(true);
|
|
|
|
requestFeedReadFilterReload();
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
return db_handle.rollback();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
bool StandardServiceRoot::emptyBin() {
|
|
|
|
QSqlDatabase db_handle = qApp->database()->connection(metaObject()->className(), DatabaseFactory::FromSettings);
|
|
|
|
|
|
|
|
if (!db_handle.transaction()) {
|
|
|
|
qWarning("Starting transaction for recycle bin emptying.");
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
|
|
|
|
QSqlQuery query_empty_bin(db_handle);
|
|
|
|
query_empty_bin.setForwardOnly(true);
|
|
|
|
|
|
|
|
if (!query_empty_bin.exec(QSL("UPDATE Messages SET is_pdeleted = 1 WHERE is_deleted = 1;"))) {
|
|
|
|
qWarning("Query execution failed for recycle bin emptying.");
|
|
|
|
|
|
|
|
db_handle.rollback();
|
|
|
|
return false;
|
|
|
|
}
|
|
|
|
|
|
|
|
// Commit changes.
|
|
|
|
if (db_handle.commit()) {
|
|
|
|
m_recycleBin->updateCounts(true);
|
|
|
|
itemChanged(QList<RootItem*>() << m_recycleBin);
|
|
|
|
requestReloadMessageList(true);
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
return db_handle.rollback();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2015-10-30 13:07:42 +01:00
|
|
|
void StandardServiceRoot::loadFromDatabase(){
|
2015-11-24 09:13:43 +01:00
|
|
|
QSqlDatabase database = qApp->database()->connection(metaObject()->className(), DatabaseFactory::FromSettings);
|
2015-10-30 13:07:42 +01:00
|
|
|
CategoryAssignment categories;
|
|
|
|
FeedAssignment feeds;
|
|
|
|
|
|
|
|
// Obtain data for categories from the database.
|
|
|
|
QSqlQuery query_categories(database);
|
|
|
|
query_categories.setForwardOnly(true);
|
|
|
|
|
|
|
|
if (!query_categories.exec(QSL("SELECT * FROM Categories;")) || query_categories.lastError().isValid()) {
|
|
|
|
qFatal("Query for obtaining categories failed. Error message: '%s'.",
|
|
|
|
qPrintable(query_categories.lastError().text()));
|
|
|
|
}
|
|
|
|
|
|
|
|
while (query_categories.next()) {
|
|
|
|
CategoryAssignmentItem pair;
|
|
|
|
pair.first = query_categories.value(CAT_DB_PARENT_ID_INDEX).toInt();
|
|
|
|
pair.second = new StandardCategory(query_categories.record());
|
|
|
|
|
|
|
|
categories << pair;
|
|
|
|
}
|
|
|
|
|
|
|
|
// All categories are now loaded.
|
|
|
|
QSqlQuery query_feeds(database);
|
|
|
|
query_feeds.setForwardOnly(true);
|
|
|
|
|
|
|
|
if (!query_feeds.exec(QSL("SELECT * FROM Feeds;")) || query_feeds.lastError().isValid()) {
|
|
|
|
qFatal("Query for obtaining feeds failed. Error message: '%s'.",
|
|
|
|
qPrintable(query_feeds.lastError().text()));
|
|
|
|
}
|
|
|
|
|
|
|
|
while (query_feeds.next()) {
|
|
|
|
// Process this feed.
|
|
|
|
StandardFeed::Type type = static_cast<StandardFeed::Type>(query_feeds.value(FDS_DB_TYPE_INDEX).toInt());
|
|
|
|
|
|
|
|
switch (type) {
|
|
|
|
case StandardFeed::Atom10:
|
|
|
|
case StandardFeed::Rdf:
|
|
|
|
case StandardFeed::Rss0X:
|
|
|
|
case StandardFeed::Rss2X: {
|
|
|
|
FeedAssignmentItem pair;
|
|
|
|
pair.first = query_feeds.value(FDS_DB_CATEGORY_INDEX).toInt();
|
|
|
|
pair.second = new StandardFeed(query_feeds.record());
|
|
|
|
pair.second->setType(type);
|
|
|
|
|
|
|
|
feeds << pair;
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
|
|
|
|
default:
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
// All data are now obtained, lets create the hierarchy.
|
|
|
|
assembleCategories(categories);
|
|
|
|
assembleFeeds(feeds);
|
|
|
|
|
|
|
|
// As the last item, add recycle bin, which is needed.
|
|
|
|
appendChild(m_recycleBin);
|
|
|
|
}
|
|
|
|
|
2015-11-03 10:06:34 +01:00
|
|
|
QHash<int,StandardCategory*> StandardServiceRoot::categoriesForItem(RootItem *root) {
|
|
|
|
QHash<int,StandardCategory*> categories;
|
2015-10-30 13:07:42 +01:00
|
|
|
QList<RootItem*> parents;
|
|
|
|
|
|
|
|
parents.append(root->childItems());
|
|
|
|
|
|
|
|
while (!parents.isEmpty()) {
|
|
|
|
RootItem *item = parents.takeFirst();
|
|
|
|
|
2015-11-03 10:06:34 +01:00
|
|
|
if (item->kind() == RootItemKind::Category) {
|
2015-10-30 13:07:42 +01:00
|
|
|
// This item is category, add it to the output list and
|
|
|
|
// scan its children.
|
|
|
|
int category_id = item->id();
|
2015-11-03 10:06:34 +01:00
|
|
|
StandardCategory *category = static_cast<StandardCategory*>(item);
|
2015-10-30 13:07:42 +01:00
|
|
|
|
|
|
|
if (!categories.contains(category_id)) {
|
|
|
|
categories.insert(category_id, category);
|
|
|
|
}
|
|
|
|
|
|
|
|
parents.append(category->childItems());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
return categories;
|
|
|
|
}
|
|
|
|
|
2015-11-03 10:06:34 +01:00
|
|
|
QHash<int,StandardCategory*> StandardServiceRoot::allCategories() {
|
|
|
|
return categoriesForItem(this);
|
|
|
|
}
|
|
|
|
|
2015-11-06 12:47:12 +01:00
|
|
|
QList<QAction*> StandardServiceRoot::getContextMenuForFeed(StandardFeed *feed) {
|
2015-11-08 19:48:29 +01:00
|
|
|
if (m_feedContextMenu.isEmpty()) {
|
|
|
|
// Initialize.
|
|
|
|
m_actionFeedFetchMetadata = new QAction(qApp->icons()->fromTheme(QSL("download-manager")), tr("Fetch metadata"), NULL);
|
|
|
|
m_feedContextMenu.append(m_actionFeedFetchMetadata);
|
|
|
|
}
|
2015-11-06 09:41:36 +01:00
|
|
|
|
2015-11-08 19:48:29 +01:00
|
|
|
// Make connections.
|
|
|
|
disconnect(m_actionFeedFetchMetadata, SIGNAL(triggered()), 0, 0);
|
|
|
|
connect(m_actionFeedFetchMetadata, SIGNAL(triggered()), feed, SLOT(fetchMetadataForItself()));
|
2015-11-06 09:41:36 +01:00
|
|
|
|
2015-11-08 19:48:29 +01:00
|
|
|
return m_feedContextMenu;
|
2015-11-06 09:41:36 +01:00
|
|
|
}
|
|
|
|
|
2015-10-30 13:07:42 +01:00
|
|
|
void StandardServiceRoot::assembleFeeds(FeedAssignment feeds) {
|
2015-11-03 10:06:34 +01:00
|
|
|
QHash<int,StandardCategory*> categories = categoriesForItem(this);
|
2015-10-30 13:07:42 +01:00
|
|
|
|
|
|
|
foreach (const FeedAssignmentItem &feed, feeds) {
|
|
|
|
if (feed.first == NO_PARENT_CATEGORY) {
|
|
|
|
// This is top-level feed, add it to the root item.
|
|
|
|
appendChild(feed.second);
|
|
|
|
}
|
|
|
|
else if (categories.contains(feed.first)) {
|
|
|
|
// This feed belongs to this category.
|
|
|
|
categories.value(feed.first)->appendChild(feed.second);
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
qWarning("Feed '%s' is loose, skipping it.", qPrintable(feed.second->title()));
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2015-11-03 10:06:34 +01:00
|
|
|
bool StandardServiceRoot::mergeImportExportModel(FeedsImportExportModel *model, QString &output_message) {
|
|
|
|
QStack<RootItem*> original_parents; original_parents.push(this);
|
|
|
|
QStack<RootItem*> new_parents; new_parents.push(model->rootItem());
|
|
|
|
bool some_feed_category_error = false;
|
|
|
|
|
|
|
|
// Iterate all new items we would like to merge into current model.
|
|
|
|
while (!new_parents.isEmpty()) {
|
|
|
|
RootItem *target_parent = original_parents.pop();
|
|
|
|
RootItem *source_parent = new_parents.pop();
|
|
|
|
|
|
|
|
foreach (RootItem *source_item, source_parent->childItems()) {
|
|
|
|
if (!model->isItemChecked(source_item)) {
|
|
|
|
// We can skip this item, because it is not checked and should not be imported.
|
|
|
|
// NOTE: All descendants are thus skipped too.
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (source_item->kind() == RootItemKind::Category) {
|
|
|
|
StandardCategory *source_category = static_cast<StandardCategory*>(source_item);
|
|
|
|
StandardCategory *new_category = new StandardCategory(*source_category);
|
|
|
|
QString new_category_title = new_category->title();
|
|
|
|
|
|
|
|
// Add category to model.
|
|
|
|
new_category->clearChildren();
|
|
|
|
|
|
|
|
if (new_category->addItself(target_parent)) {
|
2015-11-30 12:53:04 +01:00
|
|
|
requestItemReassignment(new_category, target_parent);
|
2015-11-03 10:06:34 +01:00
|
|
|
|
|
|
|
// Process all children of this category.
|
|
|
|
original_parents.push(new_category);
|
|
|
|
new_parents.push(source_category);
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
delete new_category;
|
|
|
|
|
|
|
|
// Add category failed, but this can mean that the same category (with same title)
|
|
|
|
// already exists. If such a category exists in current parent, then find it and
|
|
|
|
// add descendants to it.
|
|
|
|
RootItem *existing_category = NULL;
|
|
|
|
foreach (RootItem *child, target_parent->childItems()) {
|
|
|
|
if (child->kind() == RootItemKind::Category && child->title() == new_category_title) {
|
|
|
|
existing_category = child;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
if (existing_category != NULL) {
|
|
|
|
original_parents.push(existing_category);
|
|
|
|
new_parents.push(source_category);
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
some_feed_category_error = true;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
else if (source_item->kind() == RootItemKind::Feed) {
|
|
|
|
StandardFeed *source_feed = static_cast<StandardFeed*>(source_item);
|
|
|
|
StandardFeed *new_feed = new StandardFeed(*source_feed);
|
|
|
|
|
|
|
|
// Append this feed and end this iteration.
|
2015-11-04 14:05:33 +01:00
|
|
|
if (new_feed->addItself(target_parent)) {
|
2015-11-30 12:53:04 +01:00
|
|
|
requestItemReassignment(new_feed, target_parent);
|
2015-11-04 14:05:33 +01:00
|
|
|
}
|
|
|
|
else {
|
2015-11-03 10:06:34 +01:00
|
|
|
delete new_feed;
|
|
|
|
some_feed_category_error = true;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
if (some_feed_category_error) {
|
|
|
|
output_message = tr("Import successfull, but some feeds/categories were not imported due to error.");
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
output_message = tr("Import was completely successfull.");
|
|
|
|
}
|
|
|
|
|
|
|
|
return !some_feed_category_error;
|
|
|
|
}
|
|
|
|
|
2015-11-10 13:47:24 +01:00
|
|
|
void StandardServiceRoot::addNewCategory() {
|
|
|
|
QPointer<FormStandardCategoryDetails> form_pointer = new FormStandardCategoryDetails(this, qApp->mainForm());
|
|
|
|
form_pointer.data()->exec(NULL, NULL);
|
|
|
|
delete form_pointer.data();
|
|
|
|
}
|
|
|
|
|
|
|
|
void StandardServiceRoot::addNewFeed() {
|
|
|
|
QPointer<FormStandardFeedDetails> form_pointer = new FormStandardFeedDetails(this, qApp->mainForm());
|
|
|
|
form_pointer.data()->exec(NULL, NULL);
|
|
|
|
delete form_pointer.data();
|
|
|
|
}
|
|
|
|
|
2015-11-11 08:21:17 +01:00
|
|
|
void StandardServiceRoot::importFeeds() {
|
|
|
|
QPointer<FormStandardImportExport> form = new FormStandardImportExport(this, qApp->mainForm());
|
|
|
|
form.data()->setMode(FeedsImportExportModel::Import);
|
|
|
|
form.data()->exec();
|
|
|
|
delete form.data();
|
|
|
|
}
|
|
|
|
|
|
|
|
void StandardServiceRoot::exportFeeds() {
|
|
|
|
QPointer<FormStandardImportExport> form = new FormStandardImportExport(this, qApp->mainForm());
|
|
|
|
form.data()->setMode(FeedsImportExportModel::Export);
|
|
|
|
form.data()->exec();
|
|
|
|
delete form.data();
|
|
|
|
}
|
|
|
|
|
2015-11-12 10:53:17 +01:00
|
|
|
QStringList StandardServiceRoot::textualFeedIds(const QList<Feed*> &feeds) {
|
|
|
|
QStringList stringy_ids;
|
|
|
|
stringy_ids.reserve(feeds.size());
|
|
|
|
|
|
|
|
foreach (Feed *feed, feeds) {
|
|
|
|
stringy_ids.append(QString::number(feed->id()));
|
|
|
|
}
|
|
|
|
|
|
|
|
return stringy_ids;
|
|
|
|
}
|
|
|
|
|
2015-11-08 19:48:29 +01:00
|
|
|
QList<QAction*> StandardServiceRoot::addItemMenu() {
|
|
|
|
if (m_addItemMenu.isEmpty()) {
|
2015-11-10 13:47:24 +01:00
|
|
|
QAction *action_new_category = new QAction(qApp->icons()->fromTheme("folder-category"), tr("Add new category"), this);
|
|
|
|
connect(action_new_category, SIGNAL(triggered()), this, SLOT(addNewCategory()));
|
|
|
|
|
|
|
|
QAction *action_new_feed = new QAction(qApp->icons()->fromTheme("folder-feed"), tr("Add new feed"), this);
|
|
|
|
connect(action_new_feed, SIGNAL(triggered()), this, SLOT(addNewFeed()));
|
|
|
|
|
|
|
|
m_addItemMenu.append(action_new_category);
|
|
|
|
m_addItemMenu.append(action_new_feed);
|
2015-11-08 10:53:13 +01:00
|
|
|
}
|
2015-11-06 11:30:39 +01:00
|
|
|
|
2015-11-08 10:53:13 +01:00
|
|
|
return m_addItemMenu;
|
2015-11-06 11:30:39 +01:00
|
|
|
}
|
|
|
|
|
2015-11-09 10:17:48 +01:00
|
|
|
QList<QAction*> StandardServiceRoot::serviceMenu() {
|
2015-11-11 08:21:17 +01:00
|
|
|
if (m_serviceMenu.isEmpty()) {
|
|
|
|
m_actionExportFeeds = new QAction(qApp->icons()->fromTheme("document-export"), tr("Export feeds"), this);
|
|
|
|
m_actionImportFeeds = new QAction(qApp->icons()->fromTheme("document-import"), tr("Import feeds"), this);
|
|
|
|
|
|
|
|
connect(m_actionExportFeeds, SIGNAL(triggered()), this, SLOT(exportFeeds()));
|
|
|
|
connect(m_actionImportFeeds, SIGNAL(triggered()), this, SLOT(importFeeds()));
|
|
|
|
|
|
|
|
m_serviceMenu.append(m_actionExportFeeds);
|
|
|
|
m_serviceMenu.append(m_actionImportFeeds);
|
|
|
|
}
|
|
|
|
|
|
|
|
return m_serviceMenu;
|
2015-11-09 10:17:48 +01:00
|
|
|
}
|
|
|
|
|
2015-11-25 08:36:58 +01:00
|
|
|
QList<QAction*> StandardServiceRoot::contextMenuActions() {
|
|
|
|
return serviceMenu();
|
|
|
|
}
|
|
|
|
|
2015-11-19 13:21:38 +01:00
|
|
|
bool StandardServiceRoot::loadMessagesForItem(RootItem *item, QSqlTableModel *model) {
|
|
|
|
if (item->kind() == RootItemKind::Bin) {
|
|
|
|
model->setFilter(QSL("is_deleted = 1 AND is_pdeleted = 0"));
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
QList<Feed*> children = item->getSubTreeFeeds();
|
|
|
|
QStringList stringy_ids;
|
|
|
|
|
|
|
|
foreach (Feed *child, children) {
|
|
|
|
stringy_ids.append(QString::number(child->id()));
|
|
|
|
}
|
|
|
|
|
|
|
|
QString filter_clause = stringy_ids.join(QSL(", "));
|
|
|
|
|
2015-11-20 13:29:32 +01:00
|
|
|
model->setFilter(QString(QSL("feed IN (%1) AND is_deleted = 0 AND is_pdeleted = 0")).arg(filter_clause));
|
2015-11-19 13:21:38 +01:00
|
|
|
qDebug("Loading messages from feeds: %s.", qPrintable(filter_clause));
|
|
|
|
}
|
|
|
|
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
2015-11-20 09:52:29 +01:00
|
|
|
bool StandardServiceRoot::onBeforeSetMessagesRead(RootItem *selected_item, QList<int> message_db_ids, RootItem::ReadStatus read) {
|
|
|
|
Q_UNUSED(message_db_ids)
|
|
|
|
Q_UNUSED(read)
|
|
|
|
Q_UNUSED(selected_item)
|
|
|
|
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
|
|
|
bool StandardServiceRoot::onAfterSetMessagesRead(RootItem *selected_item, QList<int> message_db_ids, RootItem::ReadStatus read) {
|
|
|
|
Q_UNUSED(message_db_ids)
|
|
|
|
Q_UNUSED(read)
|
|
|
|
|
|
|
|
selected_item->updateCounts(false);
|
|
|
|
|
2015-11-24 09:13:43 +01:00
|
|
|
itemChanged(QList<RootItem*>() << selected_item);
|
|
|
|
requestFeedReadFilterReload();
|
2015-11-20 09:52:29 +01:00
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
2015-11-20 10:33:38 +01:00
|
|
|
bool StandardServiceRoot::onBeforeSwitchMessageImportance(RootItem *selected_item,
|
|
|
|
QList<QPair<int,RootItem::Importance> > changes) {
|
2015-11-20 09:52:29 +01:00
|
|
|
Q_UNUSED(selected_item)
|
2015-11-20 10:33:38 +01:00
|
|
|
Q_UNUSED(changes)
|
2015-11-20 09:52:29 +01:00
|
|
|
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
2015-11-20 10:33:38 +01:00
|
|
|
bool StandardServiceRoot::onAfterSwitchMessageImportance(RootItem *selected_item,
|
|
|
|
QList<QPair<int,RootItem::Importance> > changes) {
|
2015-11-20 09:52:29 +01:00
|
|
|
Q_UNUSED(selected_item)
|
2015-11-20 10:33:38 +01:00
|
|
|
Q_UNUSED(changes)
|
2015-11-20 09:52:29 +01:00
|
|
|
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
2015-11-20 13:29:32 +01:00
|
|
|
bool StandardServiceRoot::onBeforeMessagesDelete(RootItem *selected_item, QList<int> message_db_ids) {
|
|
|
|
Q_UNUSED(selected_item)
|
|
|
|
Q_UNUSED(message_db_ids)
|
|
|
|
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
|
|
|
bool StandardServiceRoot::onAfterMessagesDelete(RootItem *selected_item, QList<int> message_db_ids) {
|
|
|
|
Q_UNUSED(message_db_ids)
|
|
|
|
|
|
|
|
// User deleted some messages he selected in message list.
|
|
|
|
selected_item->updateCounts(true);
|
|
|
|
|
|
|
|
if (selected_item->kind() == RootItemKind::Bin) {
|
2015-11-24 09:13:43 +01:00
|
|
|
itemChanged(QList<RootItem*>() << m_recycleBin);
|
2015-11-20 13:29:32 +01:00
|
|
|
}
|
|
|
|
else {
|
|
|
|
m_recycleBin->updateCounts(true);
|
2015-11-24 09:13:43 +01:00
|
|
|
itemChanged(QList<RootItem*>() << selected_item << m_recycleBin);
|
2015-11-20 13:29:32 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
|
2015-11-24 09:13:43 +01:00
|
|
|
requestFeedReadFilterReload();
|
2015-11-20 13:29:32 +01:00
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
2015-11-23 10:55:44 +01:00
|
|
|
bool StandardServiceRoot::onBeforeMessagesRestoredFromBin(RootItem *selected_item, QList<int> message_db_ids) {
|
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
|
|
|
bool StandardServiceRoot::onAfterMessagesRestoredFromBin(RootItem *selected_item, QList<int> message_db_ids) {
|
|
|
|
Q_UNUSED(selected_item)
|
|
|
|
Q_UNUSED(message_db_ids)
|
|
|
|
|
2015-11-23 19:31:03 +01:00
|
|
|
updateCounts(true);
|
2015-11-24 09:13:43 +01:00
|
|
|
itemChanged(getSubTree());
|
|
|
|
requestFeedReadFilterReload();
|
2015-11-23 10:55:44 +01:00
|
|
|
return true;
|
|
|
|
}
|
|
|
|
|
2015-10-30 13:07:42 +01:00
|
|
|
void StandardServiceRoot::assembleCategories(CategoryAssignment categories) {
|
2015-11-20 13:29:32 +01:00
|
|
|
QHash<int,RootItem*> assignments;
|
2015-10-30 13:07:42 +01:00
|
|
|
assignments.insert(NO_PARENT_CATEGORY, this);
|
|
|
|
|
|
|
|
// Add top-level categories.
|
|
|
|
while (!categories.isEmpty()) {
|
|
|
|
for (int i = 0; i < categories.size(); i++) {
|
|
|
|
if (assignments.contains(categories.at(i).first)) {
|
|
|
|
// Parent category of this category is already added.
|
|
|
|
assignments.value(categories.at(i).first)->appendChild(categories.at(i).second);
|
|
|
|
|
|
|
|
// Now, added category can be parent for another categories, add it.
|
2015-11-03 10:06:34 +01:00
|
|
|
assignments.insert(categories.at(i).second->id(), categories.at(i).second);
|
2015-10-30 13:07:42 +01:00
|
|
|
|
|
|
|
// Remove the category from the list, because it was
|
|
|
|
// added to the final collection.
|
|
|
|
categories.removeAt(i);
|
|
|
|
i--;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|