Правка параметров проекта

.clang-tidy

@@ -37,7 +37,7 @@ CheckOptions:
   - key: readability-identifier-naming.ClassConstantCase
     value: CamelCase
   - key: readability-identifier-naming.ClassConstantPrefix
-    value: 'k_'
+    value: 'k'
   - key: readability-identifier-naming.ClassConstantSuffix
     value: ''
   - key: readability-identifier-naming.ClassMemberCase
@@ -55,7 +55,7 @@ CheckOptions:
   - key: readability-identifier-naming.ConstantCase
     value: CamelCase
   - key: readability-identifier-naming.ConstantPrefix
-    value: 'k_'
+    value: 'k'
   - key: readability-identifier-naming.ConstantSuffix
     value: POST
   - key: readability-identifier-naming.ConstantMemberCase
@@ -91,7 +91,7 @@ CheckOptions:
   - key: readability-identifier-naming.ConstexprVariableCase
     value: CamelCase
   - key: readability-identifier-naming.ConstexprVariablePrefix
-    value: 'k_'
+    value: 'k'
   - key: readability-identifier-naming.ConstexprVariableSuffix
     value: ''
   - key: readability-identifier-naming.EnumCase
@@ -119,7 +119,7 @@ CheckOptions:
   - key: readability-identifier-naming.GlobalConstantSuffix
     value: ''
   - key: readability-identifier-naming.GlobalConstantPointerCase
-    value: lower_case
+    value: CamelCase
   - key: readability-identifier-naming.GlobalConstantPointerPrefix
     value: ''
   - key: readability-identifier-naming.GlobalConstantPointerSuffix
@@ -142,6 +142,8 @@ CheckOptions:
     value: ''
   - key: readability-identifier-naming.GlobalVariableSuffix
     value: ''
+  - key: readability-identifier-naming.IgnoreMainLikeFunctions
+    value: 1
   - key: readability-identifier-naming.InlineNamespaceCase
     value: lower_case
   - key: readability-identifier-naming.InlineNamespacePrefix
@@ -245,15 +247,15 @@ CheckOptions:
   - key: readability-identifier-naming.PublicMethodSuffix
     value: ''
   - key: readability-identifier-naming.StaticConstantCase
-    value: camelBack
+    value: CamelCase
   - key: readability-identifier-naming.StaticConstantPrefix
-    value: 'k_'
+    value: 'k'
   - key: readability-identifier-naming.StaticConstantSuffix
     value: ''
   - key: readability-identifier-naming.StaticVariableCase
-    value: camelBack
+    value: CamelCase
   - key: readability-identifier-naming.StaticVariablePrefix
-    value: ''
+    value: 's'
   - key: readability-identifier-naming.StaticVariableSuffix
     value: ''
   - key: readability-identifier-naming.StructCase

cmake/cmlib

@@ -1 +1 @@
-Subproject commit 2ea38c32c8d6aa7ccdbdf84cff1d0b0d50cc2fb3
+Subproject commit 9df188963e5980d305dd50d721978ccdd997a8c3

cmake/etc/Variables.cmake

@@ -4,10 +4,8 @@ set(AUTHOR_NAME "Андрей Астафьев")
 set(DOXYGEN_PROJECT_TITLE "MyXLib")
 set(DOXYGEN_GENERATE_LATEX YES)
 set(DOXYGEN_GENERATE_HTML YES)
-set(DOXYGEN_GENERATE_SQLITE YES)
 
 set(CPACK_COMPONENTS_ALL examples)
-set(CPACK_GENERATOR "TXZ;DEB")
 set(CPACK_PACKAGE_CONTACT "Andrei Astafev <dev@246060.ru>")
 set(CPACK_PACKAGE_DESCRIPTION_SUMMARY "Mixed functions")
 

src/myx/redis/base-inl.hpp

@@ -15,8 +15,6 @@ namespace myx {
 
 namespace redis {
 
-static const QByteArray Separator { "\r\n" }; //!< Строковый разделитель слов во фразе
-
 /*!
  * \brief Создает объект класса
  * \param host Имя хоста сервера
@@ -49,6 +47,12 @@ inline Base::Base( QObject* parent ) :
 }
 
 
+inline int Base::rwTimeout() const
+{
+	return( kRWTimeout );
+}
+
+
 inline QString Base::host() const
 {
 	return( m_host );
@@ -99,37 +103,6 @@ inline bool Base::isConnected() const
 }
 
 
-/// *!
-// * \brief Извлекает длину токена из буфера данных
-// * \param pos Позиция в буфере
-// * \param buffer Буфер данных
-// */
-// inline int Base::fetchLength( QByteArray& buffer, int& pos )
-// {
-//	if ( ( buffer[pos] != '$' ) && ( buffer[pos] != '*' ) && ( buffer[pos] != ':' ) )
-//	{
-//		buffer.clear();
-//		pos = 0;
-//		return( -1 );
-//	}
-//	pos++;
-//	QByteArray text;
-//	while ( pos < buffer.length() )
-//	{
-//		if ( QChar( buffer[pos] ).isNumber() )
-//		{
-//			text += buffer[pos++];
-//		}
-//		else
-//		{
-//			pos += Separator.length();
-//			return( text.toInt() );
-//		}
-//	}
-//	return( -1 );
-// } // Base::fetchLength
-
-
 /*!
  * \brief Добавляет к состоянию флаг Read
  */

src/myx/redis/base.hpp

@@ -47,7 +47,7 @@ public:
 	bool isConnected() const;
 
 private:
-	static constexpr int k_RwTimeout { 200 };                      //!< Таймаут на операции чтения и записи
+	static constexpr int kRWTimeout { 200 };                       //!< Таймаут на операции чтения и записи
 	int                  m_connectionFlags { kDisconnected };      //!< Флаги состояния соединения
 	quint16              m_port { 6379 };                          //!< Номер порта подключения к БД
 	QString              m_host { QStringLiteral( "127.0.0.1" ) }; //!< Имя хоста подключения к БД
@@ -56,7 +56,6 @@ private:
 
 protected:
 
-	int connectionTimeout() const;
 	int rwTimeout() const;
 
 	QString host() const;
@@ -68,7 +67,6 @@ protected:
 	int connectionFlags() const;
 	void setConnectionFlags( int connectionFlags );
 
-//	int fetchLength( QByteArray& buffer, int& pos );
 	Q_SLOT void onReadyRead();
 	Q_SLOT void onBytesWritten();
 	Q_SLOT void onSocketError();

src/myx/redis/containers-inl.hpp

@@ -14,6 +14,14 @@ namespace myx {
 
 namespace redis {
 
+namespace constants {
+
+static const QByteArray Separator { "\r\n" }; //!< Строковый разделитель слов во фразе
+
+} // namespace constants
+
+namespace C = constants;
+
 /*!
  * \brief Создает часть команды
  * \param value Значение для создани части команды
@@ -22,7 +30,7 @@ namespace redis {
 inline QByteArray part( const QVariant& value )
 {
 	auto bytes = value.toByteArray();
-	return( "$" + QByteArray::number( bytes.length() ) + Separator + bytes );
+	return( "$" + QByteArray::number( bytes.length() ) + C::Separator + bytes );
 }
 
 
@@ -37,7 +45,7 @@ inline QByteArray array( const QVariantList& parts )
 	std::transform( parts.cbegin(), parts.cend(), std::back_inserter( data ),
 	                []( const QVariant& iter ) { return( part( iter ) ); } );
 	data.prepend( "*" + QByteArray::number( data.size() ) );
-	return( data.join( Separator ) + Separator );
+	return( data.join( C::Separator ) + C::Separator );
 }
 
 
@@ -76,7 +84,7 @@ inline QByteArrayList split( const QByteArray& buffer, int* splitLength )
 	{
 		*splitLength = 0;
 	}
-	if ( !buffer.endsWith( Separator ) )
+	if ( !buffer.endsWith( C::Separator ) )
 	{
 		return {};
 	}
@@ -96,7 +104,7 @@ inline QByteArrayList split( const QByteArray& buffer, int* splitLength )
 			return {};
 		}
 		size = text.toInt();
-		pos += Separator.length();
+		pos += C::Separator.length();
 	}
 	QByteArrayList parts;
 	Token token { kUndefined };
@@ -131,7 +139,7 @@ inline QByteArrayList split( const QByteArray& buffer, int* splitLength )
 			{
 				parts.push_back( partLength );
 				token = kUndefined;
-				pos  += Separator.length();
+				pos  += C::Separator.length();
 			}
 			break;
 		case kFetchPart:
@@ -147,17 +155,17 @@ inline QByteArrayList split( const QByteArray& buffer, int* splitLength )
 				if ( length < 0 )
 				{
 					parts.push_back( "" );
-					pos += Separator.length();
+					pos += C::Separator.length();
 				}
 				else
 				{
-					pos += Separator.length();
+					pos += C::Separator.length();
 					if ( pos + length > buffer.length() )
 					{
 						return {};
 					}
 					parts.push_back( buffer.mid( pos, length ) );
-					pos += length + Separator.length();
+					pos += length + C::Separator.length();
 				}
 				token = kUndefined;
 			}

src/myx/redis/containers.hpp

@@ -12,8 +12,6 @@ namespace myx {
 
 namespace redis {
 
-static const QByteArray Separator { "\r\n" }; //!< Строковый разделитель слов во фразе
-
 QByteArray array( const QVariantList& parts );
 QByteArrayList split( const QByteArray& buffer, int* splitLength = nullptr );
 // QByteArray part( const QVariant& value );

src/myx/redis/pubsub-inl.hpp

@@ -19,7 +19,7 @@ namespace myx {
 
 namespace redis {
 
-const QString PubSub::k_KeySpacePrefix { QStringLiteral( "__key%1__:" ) };
+const QString PubSub::kKeySpacePrefix { QStringLiteral( "__key%1__:" ) };
 
 /*!
  * \brief Конструктор класса
@@ -49,6 +49,12 @@ inline PubSub::PubSub( QObject* parent ) :
 }
 
 
+inline int PubSub::connectionTimeout() const
+{
+	return( kConnectionTimeout );
+}
+
+
 /*!
  * \brief Инициирует работу с БД
  */
@@ -94,7 +100,7 @@ inline void PubSub::subscribe( const QString& channel, QObject* subscriber, cons
 	{
 		if ( m_socket->state() == QAbstractSocket::ConnectedState )
 		{
-			m_socket->write( array( { "SUBSCIBE", channel } ) );
+			m_socket->write( array( { "SUBSCRIBE", channel } ) );
 		}
 		m_subscribers[channel].emplace_back( subscriber, method );
 	}
@@ -108,6 +114,8 @@ inline void PubSub::subscribe( const QString& channel, QObject* subscriber, cons
 		if ( it == iter.value().end() )
 		{
 			iter.value().emplace_back( subscriber, method );
+			connect( subscriber, &QObject::destroyed, this, &PubSub::onSubscriberDestroyed,
+			         Qt::UniqueConnection );
 		}
 	}
 } // PubSub::subscribe
@@ -130,7 +138,7 @@ inline void PubSub::subscribe( QString channel, QObject* subscriber, const char*
 	auto iter = m_subscribers.find( channel );
 	if ( iter == m_subscribers.end() )
 	{
-		channel.prepend( k_KeySpacePrefix.arg( "space@" + QString::number( database ) ).toLocal8Bit() );
+		channel.prepend( kKeySpacePrefix.arg( "space@" + QString::number( database ) ).toLocal8Bit() );
 		if ( m_socket->state() == QAbstractSocket::ConnectedState )
 		{
 			m_socket->write( array( { "SUBSCRIBE", channel } ) );
@@ -147,6 +155,8 @@ inline void PubSub::subscribe( QString channel, QObject* subscriber, const char*
 		if ( it == iter.value().end() )
 		{
 			iter.value().emplace_back( subscriber, method );
+			connect( subscriber, &QObject::destroyed, this, &PubSub::onSubscriberDestroyed,
+			         Qt::UniqueConnection );
 		}
 	}
 } // PubSub::subscribe
@@ -184,6 +194,8 @@ inline void PubSub::psubscribe( const QString& channel, QObject* subscriber, con
 		if ( it == iter.value().end() )
 		{
 			iter.value().emplace_back( subscriber, method );
+			connect( subscriber, &QObject::destroyed, this, &PubSub::onSubscriberDestroyed,
+			         Qt::UniqueConnection );
 		}
 	}
 } // PubSub::psubscribe
@@ -208,11 +220,11 @@ inline void PubSub::psubscribe( QString channel, QObject* subscriber, const char
 	{
 		if ( database == -1 )
 		{
-			channel.prepend( k_KeySpacePrefix.arg( QStringLiteral( "*" ) ).toLocal8Bit() );
+			channel.prepend( kKeySpacePrefix.arg( QStringLiteral( "*" ) ).toLocal8Bit() );
 		}
 		else
 		{
-			channel.prepend( k_KeySpacePrefix.arg( "space@" + QString::number( database ) ).toLocal8Bit() );
+			channel.prepend( kKeySpacePrefix.arg( "space@" + QString::number( database ) ).toLocal8Bit() );
 		}
 		if ( m_socket->state() == QAbstractSocket::ConnectedState )
 		{
@@ -230,6 +242,8 @@ inline void PubSub::psubscribe( QString channel, QObject* subscriber, const char
 		if ( it == iter.value().end() )
 		{
 			iter.value().emplace_back( subscriber, method );
+			connect( subscriber, &QObject::destroyed, this, &PubSub::onSubscriberDestroyed,
+			         Qt::UniqueConnection );
 		}
 	}
 } // PubSub::psubscribe
@@ -288,11 +302,11 @@ inline void PubSub::unsubscribe( QString channel, QObject* subscriber, const cha
 	}
 	if ( database == -1 )
 	{
-		channel.prepend( k_KeySpacePrefix.arg( QStringLiteral( "*" ) ).toLocal8Bit() );
+		channel.prepend( kKeySpacePrefix.arg( QStringLiteral( "*" ) ).toLocal8Bit() );
 	}
 	else
 	{
-		channel.prepend( k_KeySpacePrefix.arg( "space@" + QString::number( database ) ).toLocal8Bit() );
+		channel.prepend( kKeySpacePrefix.arg( "space@" + QString::number( database ) ).toLocal8Bit() );
 	}
 	auto iter = m_subscribers.find( channel );
 	if ( iter != m_subscribers.end() )
@@ -372,11 +386,11 @@ inline void PubSub::punsubscribe( QString channel, QObject* subscriber,
 	}
 	if ( database == -1 )
 	{
-		channel.prepend( k_KeySpacePrefix.arg( QStringLiteral( "*" ) ).toLocal8Bit() );
+		channel.prepend( kKeySpacePrefix.arg( QStringLiteral( "*" ) ).toLocal8Bit() );
 	}
 	else
 	{
-		channel.prepend( k_KeySpacePrefix.arg( "space@" + QString::number( database ) ).toLocal8Bit() );
+		channel.prepend( kKeySpacePrefix.arg( "space@" + QString::number( database ) ).toLocal8Bit() );
 	}
 	auto iter = m_psubscribers.find( channel );
 	if ( iter != m_psubscribers.end() )
@@ -489,6 +503,68 @@ inline void PubSub::onSocketStateChanged()
 } // PubSub::onSocketStateChanged
 
 
+/*!
+ * \brief При удалении подписчика уничтожает все его подписки
+ * \param subscriber Удаленный подписчик
+ */
+inline void PubSub::onSubscriberDestroyed( QObject* subscriber )
+{
+	for ( auto i = m_subscribers.begin(); i != m_subscribers.end(); )
+	{
+		for ( auto j = i.value().begin(); j != i.value().end(); )
+		{
+			if ( j->first == subscriber )
+			{
+				j = i.value().erase( j );
+			}
+			else
+			{
+				j++;
+			}
+		}
+		if ( i.value().empty() )
+		{
+			if ( m_socket->state() == QAbstractSocket::ConnectedState )
+			{
+				m_socket->write( array( { "UNSUBSCRIBE", i.key() } ) );
+			}
+			i = m_subscribers.erase( i );
+		}
+		else
+		{
+			i++;
+		}
+	}
+
+	for ( auto i = m_psubscribers.begin(); i != m_psubscribers.end(); )
+	{
+		for ( auto j = i.value().begin(); j != i.value().end(); )
+		{
+			if ( j->first == subscriber )
+			{
+				j = i.value().erase( j );
+			}
+			else
+			{
+				j++;
+			}
+		}
+		if ( i.value().empty() )
+		{
+			if ( m_socket->state() == QAbstractSocket::ConnectedState )
+			{
+				m_socket->write( array( { "PUNSUBSCRIBE", i.key() } ) );
+			}
+			i = m_psubscribers.erase( i );
+		}
+		else
+		{
+			i++;
+		}
+	}
+} // PubSub::onSubscriberDestroyed
+
+
 /*!
  * \brief Возвращает сокет
  * \return Сокет

src/myx/redis/pubsub.hpp

@@ -14,7 +14,7 @@ namespace myx {
 namespace redis {
 
 /*!
- * \brief УПравляет подпиской и публикацией сообщений
+ * \brief Управляет подпиской и публикацией сообщений
  */
 
 class PubSub : public Base
@@ -24,6 +24,8 @@ class PubSub : public Base
 public:
 	explicit PubSub( QObject* parent = nullptr );
 	QTcpSocket* socket() const;
+	int connectionTimeout() const;
+
 	Q_SLOT void start();
 	Q_SLOT void stop();
 	Q_INVOKABLE void subscribe( const QString& channel, QObject* subscriber, const char* method );
@@ -50,19 +52,21 @@ public:
 private:
 	using Sub = QHash< QString, std::vector< std::pair< QObject*, const char* > > >;
 
-	static const QString k_KeySpacePrefix;             //!< Приставка для наблюдения за данными
+	static const QString kKeySpacePrefix;             //!< Приставка для наблюдения за данными
+	static constexpr int kConnectionTimeout { 2000 }; //!< Таймаут на сетевые операции
 	QTcpSocket*          m_socket;
-	QTimer*              m_connectionTimer;            //!< Таймер установления сетевого соединения
+	QTimer*              m_connectionTimer;           //!< Таймер установления сетевого соединения
-	static constexpr int k_ConnectionTimeout { 2000 }; //!< Таймаут на сетевые операции
+
 	/*!
 	 * \brief Таблица подписчиков
 	 */
-	QByteArray m_buffer;                               //!< Буффер прочитанных данных
+	QByteArray m_buffer;                              //!< Буффер прочитанных данных
-	Sub        m_subscribers;                          //!< Обработчики сообщений по каналу подписки
+	Sub        m_subscribers;                         //!< Обработчики сообщений по каналу подписки
-	Sub        m_psubscribers;                         //!< Обработчики сообщений по шаблону канала подписки
+	Sub        m_psubscribers;                        //!< Обработчики сообщений по шаблону канала подписки
 
 	Q_SLOT void read();
 	Q_SLOT void onSocketStateChanged();
+	Q_SLOT void onSubscriberDestroyed( QObject* subscriber );
 }; // class PubSub
 
 } // namespace redis