/***************************************************************************
- * Copyright (C) 2005-07 by The Quassel IRC Development Team *
+ * Copyright (C) 2005-07 by the Quassel IRC Team *
* devel@quassel-irc.org *
* *
* 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. *
+ * (at your option) version 3. *
* *
* This program is distributed in the hope that it will be useful, *
* but WITHOUT ANY WARRANTY; without even the implied warranty of *
#include "core.h"
#include "coresession.h"
+#include "coresettings.h"
+#include "signalproxy.h"
#include "sqlitestorage.h"
-#include "util.h"
+
+#include <QMetaObject>
+#include <QMetaMethod>
Core *Core::instanceptr = 0;
-Core * Core::instance() {
+Core *Core::instance() {
if(instanceptr) return instanceptr;
instanceptr = new Core();
instanceptr->init();
}
Core::Core() {
-
+ storage = 0;
}
void Core::init() {
- if(!SqliteStorage::isAvailable()) {
- qFatal("Sqlite is currently required! Please make sure your Qt library has sqlite support enabled.");
+
+ // TODO: Remove this again at some point
+ // Check if old core settings need to be migrated in order to make the switch to the
+ // new location less painful.
+ CoreSettings cs;
+ QVariant foo = cs.databaseSettings();
+ if(!foo.isValid()) {
+ // ok, no settings stored yet. check for old ones.
+ QSettings os("Quassel IRC Development Team", "Quassel IRC");
+ QVariant bar = os.value("Core/DatabaseSettings");
+ if(bar.isValid()) {
+ // old settings available -- migrate!
+ qWarning() << "\n\nOld settings detected. Will migrate core settings to the new location...\nNOTE: GUI style settings won't be migrated!\n";
+ QSettings ncs("Quassel Project", "Quassel Core");
+ ncs.setValue("Core/CoreState", os.value("Core/CoreState"));
+ ncs.setValue("Core/DatabaseSettings", os.value("Core/DatabaseSettings"));
+ os.beginGroup("SessionData");
+ foreach(QString group, os.childGroups()) {
+ ncs.setValue(QString("SessionData/%1/Identities").arg(group), os.value(QString("%1/Identities").arg(group)));
+ ncs.setValue(QString("SessionData/%1/Networks").arg(group), os.value(QString("%1/Networks").arg(group)));
+ }
+ os.endGroup();
+
+ QSettings ngs("Quassel Project", "Quassel Client");
+ os.beginGroup("Accounts");
+ foreach(QString key, os.childKeys()) {
+ ngs.setValue(QString("Accounts/%1").arg(key), os.value(key));
+ }
+ foreach(QString group, os.childGroups()) {
+ ngs.setValue(QString("Accounts/%1/AccountData").arg(group), os.value(QString("%1/AccountData").arg(group)));
+ }
+ os.endGroup();
+ os.beginGroup("Geometry");
+ foreach(QString key, os.childKeys()) {
+ ngs.setValue(QString("UI/%1").arg(key), os.value(key));
+ }
+ os.endGroup();
+
+ ncs.sync();
+ ngs.sync();
+ qWarning() << "Migration successfully finished. You may now delete $HOME/.config/Quassel IRC Development Team/ (on Linux).\n\n";
+ }
}
- //SqliteStorage::init();
- storage = new SqliteStorage();
+ // END
+
+ CoreSettings s;
+ configured = false;
+
+ QVariantMap dbSettings = s.databaseSettings().toMap();
+ QString hname = dbSettings["Type"].toString().toLower();
+ hname[0] = hname[0].toUpper();
+ hname = "initStorage" + hname;
+ if (!QMetaObject::invokeMethod(this, hname.toAscii(), Q_RETURN_ARG(bool, configured), Q_ARG(QVariantMap, dbSettings), Q_ARG(bool, false))) {
+ qWarning("No database backend configured.");
+ }
+
+ if (!configured) {
+ qWarning("Core is currently not configured!");
+ }
+
connect(&server, SIGNAL(newConnection()), this, SLOT(incomingConnection()));
- startListening(); // FIXME make configurable
+ startListening(s.port());
guiUser = 0;
+
+}
+
+bool Core::initStorageSqlite(QVariantMap dbSettings, bool setup) {
+ if (!SqliteStorage::isAvailable()) {
+ qFatal("Sqlite is currently required! Please make sure your Qt library has sqlite support enabled.");
+ }
+ if (storage) {
+ qDebug() << "Deleting old storage object.";
+ delete storage;
+ storage = NULL;
+ }
+
+ storage = new SqliteStorage();
+ if (setup && !storage->setup(dbSettings)) {
+ return false;
+ }
+
+ return storage->init(dbSettings);
}
Core::~Core() {
qDeleteAll(sessions);
- delete storage;
+ if (storage) {
+ delete storage;
+ storage = NULL;
+ }
+}
+
+void Core::restoreState() {
+ Q_ASSERT(!instance()->sessions.count());
+ CoreSettings s;
+ QList<QVariant> users = s.coreState().toList();
+ if(users.count() > 0) {
+ qDebug() << "Restoring previous core state...";
+ foreach(QVariant v, users) {
+ QVariantMap m = v.toMap();
+ if(m.contains("UserId")) {
+ CoreSession *sess = createSession(m["UserId"].toUInt());
+ sess->restoreState(m["State"]);
+ }
+ }
+ }
+}
+
+void Core::saveState() {
+ CoreSettings s;
+ QList<QVariant> users;
+ foreach(CoreSession *sess, instance()->sessions.values()) {
+ QVariantMap m;
+ m["UserId"] = sess->userId();
+ m["State"] = sess->state();
+ users << m;
+ }
+ s.setCoreState(users);
}
CoreSession *Core::session(UserId uid) {
return sess;
}
-
bool Core::startListening(uint port) {
if(!server.listen(QHostAddress::Any, port)) {
qWarning(QString(QString("Could not open GUI client port %1: %2").arg(port).arg(server.errorString())).toAscii());
void Core::incomingConnection() {
// TODO implement SSL
- // TODO While
- QTcpSocket *socket = server.nextPendingConnection();
- connect(socket, SIGNAL(disconnected()), this, SLOT(clientDisconnected()));
- connect(socket, SIGNAL(readyRead()), this, SLOT(clientHasData()));
- blockSizes.insert(socket, (quint32)0);
- qDebug() << "Client connected from " << socket->peerAddress().toString();
+ while (server.hasPendingConnections()) {
+ QTcpSocket *socket = server.nextPendingConnection();
+ connect(socket, SIGNAL(disconnected()), this, SLOT(clientDisconnected()));
+ connect(socket, SIGNAL(readyRead()), this, SLOT(clientHasData()));
+ blockSizes.insert(socket, (quint32)0);
+ qDebug() << "Client connected from " << socket->peerAddress().toString();
+
+ if (!configured) {
+ server.close();
+ qDebug() << "Closing server for basic setup.";
+ }
+ }
}
void Core::clientHasData() {
Q_ASSERT(socket && blockSizes.contains(socket));
quint32 bsize = blockSizes.value(socket);
QVariant item;
- if(readDataFromDevice(socket, bsize, item)) {
+ if(SignalProxy::readDataFromDevice(socket, bsize, item)) {
// we need to auth the client
try {
- processClientInit(socket, item);
+ QVariantMap msg = item.toMap();
+ if (msg["GuiProtocol"].toUInt() != GUI_PROTOCOL) {
+ throw Exception("GUI client version mismatch");
+ }
+ if (configured) {
+ processClientInit(socket, msg);
+ } else {
+ processCoreSetup(socket, msg);
+ }
} catch(Storage::AuthError) {
- qWarning() << "Authentification error!"; // FIXME
+ qWarning() << "Authentification error!"; // FIXME: send auth error to client
socket->close();
return;
} catch(Exception e) {
return;
}
}
- blockSizes[socket] = bsize = 0; // FIXME blockSizes aufräum0rn!
+ blockSizes[socket] = bsize = 0; // FIXME blockSizes aufr�um0rn!
}
// FIXME: no longer called, since connection handling is now in SignalProxy
+// No, it is called as long as core is not configured. (kaffeedoktor)
void Core::clientDisconnected() {
QTcpSocket *socket = dynamic_cast<QTcpSocket*>(sender());
blockSizes.remove(socket);
qDebug() << "Client disconnected.";
+
+ // make server listen again if still not configured
+ if (!configured) {
+ startListening();
+ }
+
// TODO remove unneeded sessions - if necessary/possible...
}
instance()->guiUser = 0;
}
-void Core::processClientInit(QTcpSocket *socket, const QVariant &v) {
- QVariantMap msg = v.toMap();
- if(msg["GuiProtocol"].toUInt() != GUI_PROTOCOL) {
- //qWarning() << "Client version mismatch.";
- throw Exception("GUI client version mismatch");
- }
- // Auth
- UserId uid = storage->validateUser(msg["User"].toString(), msg["Password"].toString()); // throws exception if this failed
- QVariant reply = initSession(uid);
+void Core::processClientInit(QTcpSocket *socket, const QVariantMap &msg) {
+ // Auth
+ QVariantMap reply;
+ UserId uid = storage->validateUser(msg["User"].toString(), msg["Password"].toString()); // throws exception if this failed
+ reply["StartWizard"] = false;
+ reply["Reply"] = initSession(uid);
disconnect(socket, 0, this, 0);
sessions[uid]->addClient(socket);
- writeDataToDevice(socket, reply);
+ qDebug() << "Client initialized successfully.";
+ SignalProxy::writeDataToDevice(socket, reply);
+}
+
+void Core::processCoreSetup(QTcpSocket *socket, QVariantMap &msg) {
+ if(msg["HasSettings"].toBool()) {
+ QVariantMap auth;
+ auth["User"] = msg["User"];
+ auth["Password"] = msg["Password"];
+ msg.remove("User");
+ msg.remove("Password");
+ qDebug() << "Initializing storage provider" << msg["Type"].toString();
+ QString hname = msg["Type"].toString().toLower();
+ hname[0] = hname[0].toUpper();
+ hname = "initStorage" + hname;
+ if (!QMetaObject::invokeMethod(this, hname.toAscii(), Q_RETURN_ARG(bool, configured), Q_ARG(QVariantMap, msg), Q_ARG(bool, true))) {
+ qWarning("No database backend configured.");
+ }
+ if (!configured) {
+ // notify client to start wizard again
+ qWarning("Core is currently not configured!");
+ QVariantMap reply;
+ reply["StartWizard"] = true;
+ reply["StorageProviders"] = availableStorageProviders();
+ SignalProxy::writeDataToDevice(socket, reply);
+ } else {
+ // write coresettings
+ CoreSettings s;
+ s.setDatabaseSettings(msg);
+ // write admin user to database & make the core listen again to connections
+ storage->addUser(auth["User"].toString(), auth["Password"].toString());
+ startListening();
+ // continue the normal procedure
+ processClientInit(socket, auth);
+ }
+ } else {
+ // notify client to start wizard
+ QVariantMap reply;
+ reply["StartWizard"] = true;
+ reply["StorageProviders"] = availableStorageProviders();
+ SignalProxy::writeDataToDevice(socket, reply);
+ }
}
QVariant Core::initSession(UserId uid) {
// Find or create session for validated user
CoreSession *sess;
- if(sessions.contains(uid)) sess = sessions[uid];
- else {
+ if(sessions.contains(uid))
+ sess = sessions[uid];
+ else
sess = createSession(uid);
- }
QVariantMap reply;
reply["SessionState"] = sess->sessionState();
return reply;
}
+
+QStringList Core::availableStorageProviders() {
+ QStringList storageProviders;
+ if (SqliteStorage::isAvailable()) {
+ storageProviders.append(SqliteStorage::displayName());
+ }
+ // TODO: temporary
+ storageProviders.append("MySQL");
+
+ return storageProviders;
+}