Kolab Groupware OBS

_service:set_version:akonadi.spec Changed

_service:recompress:tar_scm:akonadi-1.12.42.99.git20160627.935537a.tar.gz/CMakeLists.txt -> _service:recompress:tar_scm:akonadi-1.12.42.99.git20161205.3850437.tar.gz/CMakeLists.txt Changed

_service:recompress:tar_scm:akonadi-1.12.42.99.git20160627.935537a.tar.gz/interfaces/org.freedesktop.Akonadi.NotificationManager.xml -> _service:recompress:tar_scm:akonadi-1.12.42.99.git20161205.3850437.tar.gz/interfaces/org.freedesktop.Akonadi.NotificationManager.xml Changed

_service:recompress:tar_scm:akonadi-1.12.42.99.git20160627.935537a.tar.gz/server/src/notificationmanager.cpp -> _service:recompress:tar_scm:akonadi-1.12.42.99.git20161205.3850437.tar.gz/server/src/notificationmanager.cpp Changed

@@ -39,7 +39,8 @@
 NotificationManager *NotificationManager::mSelf = 0;
 
 NotificationManager::NotificationManager()
-  : QObject( 0 )
+  : QObject( 0 ),
+    mNotificationCounter( 0 )
 {
   NotificationMessage::registerDBusTypes();
   NotificationMessageV2::registerDBusTypes();
@@ -81,6 +82,8 @@
 void NotificationManager::slotNotify( const Akonadi::NotificationMessageV3::List &msgs )
 {
   //akDebug() << Q_FUNC_INFO << "Appending" << msgs.count() << "notifications to current list of " << mNotifications.count() << "notifications";
+  mNotificationCounter += msgs.count();
+
   Q_FOREACH ( const NotificationMessageV3 &msg, msgs )
     NotificationMessageV3::appendAndCompress( mNotifications, msg );
   //akDebug() << Q_FUNC_INFO << "We have" << mNotifications.count() << "notifications queued in total after appendAndCompress()";
@@ -190,7 +193,10 @@
 
   // FIXME KF5: Emit the QDBusObjectPath instead of the identifier
   Q_EMIT subscribed( paths.at( 1 ) );
-
+  mDebugMessages.append(QDateTime::currentDateTime().toString() + QLatin1String(" SUBSCRIBE ") + identifier);
+  if (mDebugMessages.size() > 1100) {
+    mDebugMessages = mDebugMessages.mid(100);
+  }
   return source->dbusPath();
 }
 
@@ -207,6 +213,10 @@
 
 void NotificationManager::unsubscribe( const QString &identifier )
 {
+  mDebugMessages.append(QDateTime::currentDateTime().toString() + QLatin1String(" UNSUBSCRIBE ") + identifier);
+  if (mDebugMessages.size() > 1100) {
+    mDebugMessages = mDebugMessages.mid(100);
+  }
   NotificationSource *source = mNotificationSources.value( identifier );
   if ( source ) {
     unregisterSource( source );
@@ -232,3 +242,37 @@
 
   return identifiers;
 }
+
+int NotificationManager::notificationCounter() const
+{
+    return mNotificationCounter;
+}
+
+int NotificationManager::notificationCount() const
+{
+    return mNotifications.size();
+}
+
+QStringList NotificationManager::listNotifications() const
+{
+    QStringList list;
+    Q_FOREACH ( const NotificationMessageV3 &n, mNotifications ) {
+        list << n.toString();
+    }
+    return list;
+}
+
+QStringList NotificationManager::debugMessages() const
+{
+    return mDebugMessages;
+}
+
+QStringList NotificationManager::triggerTimer()
+{
+    QStringList ret;
+    ret << QString::fromUtf8("The timer is currently %1").arg(mTimer.isActive() ? QString::fromUtf8("active"): QString::fromUtf8("inactive"));
+    ret << QString::fromUtf8("The intervall is currently %1 msec").arg(mTimer.interval());
+    mTimer.stop();
+    emitPendingNotifications();
+    return ret;
+}

_service:recompress:tar_scm:akonadi-1.12.42.99.git20160627.935537a.tar.gz/server/src/notificationmanager.h -> _service:recompress:tar_scm:akonadi-1.12.42.99.git20161205.3850437.tar.gz/server/src/notificationmanager.h Changed

_service:recompress:tar_scm:akonadi-1.12.42.99.git20160627.935537a.tar.gz/server/src/storage/mysql-global.conf -> _service:recompress:tar_scm:akonadi-1.12.42.99.git20161205.3850437.tar.gz/server/src/storage/mysql-global.conf Changed

_service:set_version:akonadi.dsc Changed

Changes of Revision 27