mirror of
https://bitbucket.org/smil3y/kde-playground.git
synced 2025-02-24 02:42:51 +00:00
232 lines
8.6 KiB
C++
232 lines
8.6 KiB
C++
|
/***************************************************************************
|
||
|
|
* Copyright (C) 2007 by Tobias Koenig <tokoe@kde.org> *
|
||
|
|
* *
|
||
|
|
* This program is free software; you can redistribute it and/or modify *
|
||
|
|
* it under the terms of the GNU Library 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 Library 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 <QtCore/QCoreApplication>
|
||
|
|
#include <QtCore/QDebug>
|
||
|
|
#include <QtCore/QDir>
|
||
|
|
#include <QtCore/QString>
|
||
|
|
#include <QtCore/QStringList>
|
||
|
|
#include <QtCore/QSettings>
|
||
|
|
#include <QtDBus/QDBusConnection>
|
||
|
|
#include <QtDBus/QDBusConnectionInterface>
|
||
|
|
#include <QtDBus/QDBusInterface>
|
||
|
|
#include <QtDBus/QDBusReply>
|
||
|
|
|
||
|
|
#include <config-akonadi.h>
|
||
|
|
|
||
|
|
#include <akapplication.h>
|
||
|
|
#include <akdbus.h>
|
||
|
|
#include <akdebug.h>
|
||
|
|
#include "protocol_p.h"
|
||
|
|
|
||
|
|
#include "controlmanagerinterface.h"
|
||
|
|
#include "akonadistarter.h"
|
||
|
|
#include "xdgbasedirs_p.h"
|
||
|
|
#include <QSettings>
|
||
|
|
|
||
|
|
#if defined(HAVE_UNISTD_H) && !defined(Q_WS_WIN)
|
||
|
|
#include <unistd.h>
|
||
|
|
#else
|
||
|
|
#define WIN32_LEAN_AND_MEAN
|
||
|
|
#include <Windows.h>
|
||
|
|
#endif
|
||
|
|
|
||
|
|
static bool startServer()
|
||
|
|
{
|
||
|
|
if ( QDBusConnection::sessionBus().interface()->isServiceRegistered( AkDBus::serviceName( AkDBus::Control ) )
|
||
|
|
|| QDBusConnection::sessionBus().interface()->isServiceRegistered( AkDBus::serviceName( AkDBus::Server ) ) ) {
|
||
|
|
qWarning() << "Akonadi is already running.";
|
||
|
|
return false;
|
||
|
|
}
|
||
|
|
AkonadiStarter starter;
|
||
|
|
return starter.start();
|
||
|
|
}
|
||
|
|
|
||
|
|
static bool stopServer()
|
||
|
|
{
|
||
|
|
org::freedesktop::Akonadi::ControlManager iface( AkDBus::serviceName( AkDBus::Control ),
|
||
|
|
QLatin1String( "/ControlManager" ),
|
||
|
|
QDBusConnection::sessionBus(), 0 );
|
||
|
|
if ( !iface.isValid() ) {
|
||
|
|
qWarning() << "Akonadi is not running.";
|
||
|
|
return false;
|
||
|
|
}
|
||
|
|
|
||
|
|
iface.shutdown();
|
||
|
|
|
||
|
|
return true;
|
||
|
|
}
|
||
|
|
|
||
|
|
static bool checkAkonadiControlStatus()
|
||
|
|
{
|
||
|
|
const bool registered = QDBusConnection::sessionBus().interface()->isServiceRegistered( AkDBus::serviceName( AkDBus::Control ) );
|
||
|
|
fprintf( stderr, "Akonadi Control: %s\n", registered ? "running" : "stopped" );
|
||
|
|
return registered;
|
||
|
|
}
|
||
|
|
|
||
|
|
static bool checkAkonadiServerStatus()
|
||
|
|
{
|
||
|
|
const bool registered = QDBusConnection::sessionBus().interface()->isServiceRegistered( AkDBus::serviceName( AkDBus::Server ) );
|
||
|
|
fprintf( stderr, "Akonadi Server: %s\n", registered ? "running" : "stopped" );
|
||
|
|
return registered;
|
||
|
|
}
|
||
|
|
|
||
|
|
static bool checkSearchSupportStatus()
|
||
|
|
{
|
||
|
|
QStringList searchMethods;
|
||
|
|
searchMethods << QLatin1String( "Remote Search" );
|
||
|
|
|
||
|
|
const QString pluginOverride = QString::fromLatin1( qgetenv( "AKONADI_OVERRIDE_SEARCHPLUGIN" ) );
|
||
|
|
if ( !pluginOverride.isEmpty() ) {
|
||
|
|
searchMethods << pluginOverride;
|
||
|
|
} else {
|
||
|
|
const QStringList dirs = Akonadi::XdgBaseDirs::findPluginDirs();
|
||
|
|
Q_FOREACH ( const QString &pluginDir, dirs ) {
|
||
|
|
QDir dir( pluginDir + QLatin1String( "/akonadi" ) );
|
||
|
|
const QStringList desktopFiles = dir.entryList( QStringList() << QLatin1String( "*.desktop" ), QDir::Files );
|
||
|
|
Q_FOREACH ( const QString &desktopFileName, desktopFiles ) {
|
||
|
|
QSettings desktop( pluginDir + QLatin1String( "/akonadi/" ) + desktopFileName, QSettings::IniFormat );
|
||
|
|
desktop.beginGroup( QLatin1String( "Desktop Entry" ) );
|
||
|
|
if ( desktop.value( QLatin1String( "Type" ) ).toString() != QLatin1String( "AkonadiSearchPlugin" ) ) {
|
||
|
|
continue;
|
||
|
|
}
|
||
|
|
if ( !desktop.value( QLatin1String( "X-Akonadi-LoadByDefault" ), true ).toBool() ) {
|
||
|
|
continue;
|
||
|
|
}
|
||
|
|
|
||
|
|
searchMethods << desktop.value( QLatin1String( "Name" ) ).toString();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
// There's always at least server-search available
|
||
|
|
fprintf( stderr, "Akonadi Server Search Support: available (%s)\n", qPrintable( searchMethods.join( QLatin1String( ", " ) ) ) );
|
||
|
|
return true;
|
||
|
|
}
|
||
|
|
|
||
|
|
static bool checkAvailableAgentTypes()
|
||
|
|
{
|
||
|
|
const QStringList dirs = Akonadi::XdgBaseDirs::findAllResourceDirs( "data", QLatin1String( "akonadi/agents" ) );
|
||
|
|
QStringList types;
|
||
|
|
Q_FOREACH ( const QString &pluginDir, dirs ) {
|
||
|
|
QDir dir( pluginDir );
|
||
|
|
const QStringList plugins = dir.entryList( QStringList() << QLatin1String( "*.desktop" ), QDir::Files );
|
||
|
|
Q_FOREACH ( const QString &plugin, plugins ) {
|
||
|
|
QSettings pluginInfo( pluginDir + QLatin1String("/") + plugin, QSettings::IniFormat );
|
||
|
|
pluginInfo.beginGroup( QLatin1String( "Desktop Entry" ) );
|
||
|
|
types << pluginInfo.value( QLatin1String( "X-Akonadi-Identifier" ) ).toString();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
// Remove duplicates from multiple pluginDirs
|
||
|
|
types.removeDuplicates();
|
||
|
|
types.sort();
|
||
|
|
|
||
|
|
fprintf( stderr, "Available Agent Types: ");
|
||
|
|
if ( types.isEmpty() ) {
|
||
|
|
fprintf( stderr, "No agent types found! \n");
|
||
|
|
} else {
|
||
|
|
fprintf( stderr, "%s\n", qPrintable( types.join( QLatin1String( ", " ) ) ) );
|
||
|
|
}
|
||
|
|
|
||
|
|
return true;
|
||
|
|
}
|
||
|
|
|
||
|
|
static bool statusServer()
|
||
|
|
{
|
||
|
|
checkAkonadiControlStatus();
|
||
|
|
checkAkonadiServerStatus();
|
||
|
|
checkSearchSupportStatus();
|
||
|
|
checkAvailableAgentTypes();
|
||
|
|
return true;
|
||
|
|
}
|
||
|
|
|
||
|
|
int main( int argc, char **argv )
|
||
|
|
{
|
||
|
|
AkCoreApplication app( argc, argv );
|
||
|
|
app.setDescription( QLatin1String( "Akonadi server manipulation tool\n"
|
||
|
|
"Usage: akonadictl [command]\n\n"
|
||
|
|
"Commands:\n"
|
||
|
|
" start : Starts the Akonadi server with all its processes\n"
|
||
|
|
" stop : Stops the Akonadi server and all its processes cleanly\n"
|
||
|
|
" restart : Restart Akonadi server with all its processes\n"
|
||
|
|
" status : Shows a status overview of the Akonadi server\n"
|
||
|
|
" vacuum : Vacuum internal storage (WARNING: needs a lot of time and disk space!)\n"
|
||
|
|
" fsck : Check (and attempt to fix) consistency of the internal storage (can take some time)" ) );
|
||
|
|
|
||
|
|
app.parseCommandLine();
|
||
|
|
|
||
|
|
QStringList optionsList;
|
||
|
|
optionsList.append( QLatin1String( "start" ) );
|
||
|
|
optionsList.append( QLatin1String( "stop" ) );
|
||
|
|
optionsList.append( QLatin1String( "status" ) );
|
||
|
|
optionsList.append( QLatin1String( "restart" ) );
|
||
|
|
optionsList.append( QLatin1String( "vacuum" ) );
|
||
|
|
optionsList.append( QLatin1String( "fsck" ) );
|
||
|
|
|
||
|
|
QStringList arguments = QCoreApplication::instance()->arguments();
|
||
|
|
if ( AkApplication::hasInstanceIdentifier() ) { // HACK: we should port all of this to boost::program_options...
|
||
|
|
arguments.removeFirst();
|
||
|
|
arguments.removeFirst();
|
||
|
|
}
|
||
|
|
if ( arguments.count() != 2 ) {
|
||
|
|
app.printUsage();
|
||
|
|
return 1;
|
||
|
|
} else if ( !optionsList.contains( arguments[1] ) ) {
|
||
|
|
app.printUsage();
|
||
|
|
return 2;
|
||
|
|
}
|
||
|
|
|
||
|
|
if ( arguments[1] == QLatin1String( "start" ) ) {
|
||
|
|
if ( !startServer() ) {
|
||
|
|
return 3;
|
||
|
|
}
|
||
|
|
} else if ( arguments[1] == QLatin1String( "stop" ) ) {
|
||
|
|
if ( !stopServer() ) {
|
||
|
|
return 4;
|
||
|
|
}
|
||
|
|
} else if ( arguments[1] == QLatin1String( "status" ) ) {
|
||
|
|
if ( !statusServer() ) {
|
||
|
|
return 5;
|
||
|
|
}
|
||
|
|
} else if ( arguments[1] == QLatin1String( "restart" ) ) {
|
||
|
|
if ( !stopServer() ) {
|
||
|
|
return 4;
|
||
|
|
} else {
|
||
|
|
do {
|
||
|
|
#if defined(HAVE_UNISTD_H) && !defined(Q_WS_WIN)
|
||
|
|
usleep( 100000 );
|
||
|
|
#else
|
||
|
|
Sleep( 100000 );
|
||
|
|
#endif
|
||
|
|
} while ( QDBusConnection::sessionBus().interface()->isServiceRegistered( AkDBus::serviceName( AkDBus::Control ) ) );
|
||
|
|
if ( !startServer() ) {
|
||
|
|
return 3;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
} else if ( arguments[1] == QLatin1String( "vacuum" ) ) {
|
||
|
|
QDBusInterface iface( AkDBus::serviceName( AkDBus::StorageJanitor ), QLatin1String( AKONADI_DBUS_STORAGEJANITOR_PATH ) );
|
||
|
|
iface.call( QDBus::NoBlock, QLatin1String( "vacuum" ) );
|
||
|
|
} else if ( arguments[1] == QLatin1String( "fsck" ) ) {
|
||
|
|
QDBusInterface iface( AkDBus::serviceName( AkDBus::StorageJanitor ), QLatin1String( AKONADI_DBUS_STORAGEJANITOR_PATH ) );
|
||
|
|
iface.call( QDBus::NoBlock, QLatin1String( "check" ) );
|
||
|
|
}
|
||
|
|
return 0;
|
||
|
|
}
|