diff --git a/sinksh/syntax_modules/sink_selftest.cpp b/sinksh/syntax_modules/sink_selftest.cpp index 0609720a..a1c7dcb7 100644 --- a/sinksh/syntax_modules/sink_selftest.cpp +++ b/sinksh/syntax_modules/sink_selftest.cpp @@ -1,153 +1,165 @@ /* * Copyright (C) 2018 Christian Mollekopf * * This program 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 2 of the License, or * (at your option) any later version. * * This program 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 this program; if not, write to the * Free Software Foundation, Inc., * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. */ #include #include #include // tr() #include #include #include "common/resource.h" #include "common/storage.h" #include "common/resourceconfig.h" #include "common/log.h" #include "common/storage.h" #include "common/definitions.h" #include "common/store.h" #include "common/propertyparser.h" +#include "common/resourceaccess.h" +#include "common/commands.h" #include "sinksh_utils.h" #include "state.h" #include "syntaxtree.h" namespace SinkSelfTest { bool selfTest(const QStringList &args_, State &state) { using namespace Sink::ApplicationDomain; auto options = SyntaxTree::parseOptions(args_); if (options.positionalArguments.contains("stresstest")) { auto resource = SinkshUtils::parseUid(options.options.value("resource").first().toUtf8()); qWarning() << "Stresstest on resource: " << resource; auto models = QSharedPointer>>::create(); //Simulate the maillist, where we scroll down and trigger lots of fetchMore calls { Sink::Query query; query.resourceFilter(resource); query.limit(100); query.request(); query.request(); query.request(); query.request(); query.request(); query.request(); query.request(); query.request(); query.request(); query.request(); query.request(); query.request(); query.sort(); query.reduce(Sink::Query::Reduce::Selector::max()) .count("count") .collect("unreadCollected") .collect("importantCollected"); auto model = Sink::Store::loadModel(query); models->append(model); QObject::connect(model.data(), &QAbstractItemModel::dataChanged, [models, model, &state](const QModelIndex &start, const QModelIndex &end, const QVector &roles) { if (roles.contains(Sink::Store::ChildrenFetchedRole)) { if (!model->canFetchMore({})) { qWarning() << "Model complete: " << models->count(); models->removeAll(model); } else { qWarning() << "Fetching more"; //Simulate superfluous fetchMore calls for (int i = 0; i < 10; i++) { model->fetchMore({}); } return; } if (models->isEmpty()) { state.commandFinished(); } } }); } //Simluate lot's of mailviewers doing a bunch of queries { Sink::Query query; query.resourceFilter(resource); query.limit(10); query.request(); query.request(); query.request(); query.request(); query.request(); query.request(); query.request(); query.request(); query.request(); query.request(); query.request(); query.request(); query.sort(); query.bloom(); for (int i = 0; i < 50; i++) { auto model = Sink::Store::loadModel(query); *models << model; QObject::connect(model.data(), &QAbstractItemModel::dataChanged, [models, model, &state](const QModelIndex &start, const QModelIndex &end, const QVector &roles) { if (roles.contains(Sink::Store::ChildrenFetchedRole)) { models->removeAll(model); qWarning() << "Model complete: " << models->count(); if (models->isEmpty()) { state.commandFinished(); } } }); } } return true; } state.printLine("Looking for resource plugins:"); if (!Sink::ResourceFactory::load("sink.imap")) { - state.printLine("Error: Failed to load the imap resource", 1); + state.printLine("Failure: Failed to load the imap resource", 1); } else { state.printLine("Success: Managed to load the imap resource", 1); + state.printLine("Trying to start and connect to a resource.", 1); + auto resourceAccess = Sink::ResourceAccessFactory::instance().getAccess("imap.selftest.resource", "sink.imap"); + resourceAccess->open(); + resourceAccess->sendCommand(Sink::Commands::PingCommand).addToContext(resourceAccess).then([&](const KAsync::Error &error) { + if (error) { + state.printLine("Failure: Failed to start/connect to the resource.", 1); + } else { + state.printLine("Success: Managed to start and connect to the resource.", 1); + } + }).exec().waitForFinished(); } return false; } Syntax::List syntax() { - Syntax syntax("selftest", QObject::tr("Selftext."), &SinkSelfTest::selfTest, Syntax::EventDriven); + Syntax syntax("selftest", QObject::tr("A selftest module."), &SinkSelfTest::selfTest, Syntax::EventDriven); return Syntax::List() << syntax; } REGISTER_SYNTAX(SinkSelfTest) }