Th2 3673 common need to change the filter

src/main/java/com/exactpro/th2/common/schema/filter/strategy/impl/AbstractFilterStrategy.java

@@ -57,6 +57,7 @@ private MultiValuedMap<String, FieldFilterConfiguration> extractConfigMapFromRou
         MultiValuedMap<String, FieldFilterConfiguration> msgFieldFilters = MultiMapUtils.newListValuedHashMap();
         msgFieldFilters.putAll(routerFilter.getMessage());
         msgFieldFilters.putAll(routerFilter.getMetadata());
+        msgFieldFilters.putAll(routerFilter.getProperties());
         return msgFieldFilters;
     }
 

src/main/java/com/exactpro/th2/common/schema/filter/strategy/impl/AbstractTh2MsgFilterStrategy.java

@@ -47,6 +47,7 @@ public Map<String, String> getFields(com.google.protobuf.Message message) {
                 DIRECTION_KEY, messageID.getDirection().name()
         );
 
+        messageFields.putAll(th2Msg.getMetadata().getPropertiesMap());
         messageFields.putAll(metadataMsgFields);
 
         return messageFields;

src/main/kotlin/com/exactpro/th2/common/schema/filter/strategy/impl/AnyMessageFilterStrategy.kt

@@ -25,19 +25,21 @@ class AnyMessageFilterStrategy : AbstractFilterStrategy<Message>() {
     override fun getFields(message: Message): MutableMap<String, String> {
         check(message is AnyMessage) { "Message is not an ${AnyMessage::class.qualifiedName}: ${message.toJson()}" }
 
-        val result = HashMap<String, String>();
+        val result = HashMap<String, String>()
 
         when {
             message.hasMessage() -> {
                 result.putAll(message.message.fieldsMap.mapValues { it.value.simpleValue })
 
                 val metadata = message.message.metadata
+                result.putAll(message.message.metadata.propertiesMap)
                 result[AbstractTh2MsgFilterStrategy.SESSION_ALIAS_KEY] = metadata.id.connectionId.sessionAlias
                 result[AbstractTh2MsgFilterStrategy.MESSAGE_TYPE_KEY] = metadata.messageType
                 result[AbstractTh2MsgFilterStrategy.DIRECTION_KEY] = metadata.id.direction.name
             }
             message.hasRawMessage() -> {
                 val metadata = message.rawMessage.metadata
+                result.putAll(message.rawMessage.metadata.propertiesMap)
                 result[AbstractTh2MsgFilterStrategy.SESSION_ALIAS_KEY] = metadata.id.connectionId.sessionAlias
                 result[AbstractTh2MsgFilterStrategy.DIRECTION_KEY] = metadata.id.direction.name
             }

src/main/kotlin/com/exactpro/th2/common/schema/grpc/configuration/GrpcRawFilterStrategy.kt

@@ -30,7 +30,8 @@ data class GrpcRawFilterStrategy(var filters: List<GrpcRouterFilterConfiguration
 data class GrpcRouterFilterConfiguration(
     @JsonProperty(required = true) var endpoint: String,
     @JsonDeserialize(using = MultiMapFiltersDeserializer::class) override var metadata: MultiValuedMap<String, FieldFilterConfiguration> = emptyMultiMap(),
-    @JsonDeserialize(using = MultiMapFiltersDeserializer::class) override var message: MultiValuedMap<String, FieldFilterConfiguration> = emptyMultiMap()
+    @JsonDeserialize(using = MultiMapFiltersDeserializer::class) override var message: MultiValuedMap<String, FieldFilterConfiguration> = emptyMultiMap(),
+    @JsonDeserialize(using = MultiMapFiltersDeserializer::class) override var properties: MultiValuedMap<String, FieldFilterConfiguration> = emptyMultiMap()
 ) : RouterFilter, Configuration() {
 
     @JsonGetter("metadata")
@@ -39,4 +40,7 @@ data class GrpcRouterFilterConfiguration(
     @JsonGetter("message")
     fun getJsonMessage(): Collection<FieldFilterConfiguration> = message.values()
 
+    @JsonGetter("properties")
+    fun getJsonProperties(): Collection<FieldFilterConfiguration> = properties.values()
+
 }

src/main/kotlin/com/exactpro/th2/common/schema/message/configuration/MessageRouterConfiguration.kt

@@ -47,12 +47,14 @@ data class QueueConfiguration(
 
 data class MqRouterFilterConfiguration(
     @JsonDeserialize(using = MultiMapFiltersDeserializer::class) override var metadata: MultiValuedMap<String, FieldFilterConfiguration> = emptyMultiMap(),
-    @JsonDeserialize(using = MultiMapFiltersDeserializer::class) override var message: MultiValuedMap<String, FieldFilterConfiguration> = emptyMultiMap()
+    @JsonDeserialize(using = MultiMapFiltersDeserializer::class) override var message: MultiValuedMap<String, FieldFilterConfiguration> = emptyMultiMap(),
+    @JsonDeserialize(using = MultiMapFiltersDeserializer::class) override var properties: MultiValuedMap<String, FieldFilterConfiguration> = emptyMultiMap()
 ) : Configuration(), RouterFilter {
 
     constructor(
         metadata: Collection<FieldFilterConfiguration> = emptyList(),
-        message: Collection<FieldFilterConfiguration> = emptyList()
+        message: Collection<FieldFilterConfiguration> = emptyList(),
+        properties: Collection<FieldFilterConfiguration> = emptyList()
     ) : this(
         MultiMapUtils.newListValuedHashMap<String, FieldFilterConfiguration>().also { metadataMultiMap ->
             metadata.forEach {
@@ -63,6 +65,11 @@ data class MqRouterFilterConfiguration(
             message.forEach {
                 messageMultiMap.put(it.fieldName, it)
             }
+        },
+        MultiMapUtils.newListValuedHashMap<String, FieldFilterConfiguration>().also { propertiesMultiMap ->
+            properties.forEach {
+                propertiesMultiMap.put(it.fieldName, it)
+            }
         }
     )
 
@@ -71,6 +78,9 @@ data class MqRouterFilterConfiguration(
 
     @JsonGetter("message")
     fun getJsonMessage(): Collection<FieldFilterConfiguration> = message.values()
+
+    @JsonGetter("properties")
+    fun getJsonProperties(): Collection<FieldFilterConfiguration> = properties.values()
 }
 
 data class FieldFilterConfigurationOld(

src/main/kotlin/com/exactpro/th2/common/schema/message/configuration/RouterFilter.kt

@@ -20,4 +20,5 @@ import org.apache.commons.collections4.MultiValuedMap
 interface RouterFilter {
     val metadata: MultiValuedMap<String, FieldFilterConfiguration>
     val message: MultiValuedMap<String, FieldFilterConfiguration>
+    val properties: MultiValuedMap<String, FieldFilterConfiguration>
 }

src/test/kotlin/com/exactpro/th2/common/schema/TestJsonConfiguration.kt

@@ -183,7 +183,14 @@ class TestJsonConfiguration {
                                 FieldFilterOperation.EQUAL
                             )
                         ),
-                        listOf(FieldFilterConfiguration("test_field", "test_value", FieldFilterOperation.EQUAL))
+                        listOf(FieldFilterConfiguration("test_field", "test_value", FieldFilterOperation.EQUAL)),
+                        listOf(
+                            FieldFilterConfiguration(
+                                "method",
+                                "POST",
+                                FieldFilterOperation.EQUAL
+                            )
+                        ),
                     ),
                     MqRouterFilterConfiguration(
                         listOf(
@@ -196,6 +203,10 @@ class TestJsonConfiguration {
                         listOf(
                             FieldFilterConfiguration("test_field", "test_value0", FieldFilterOperation.EQUAL),
                             FieldFilterConfiguration("test_field", "test_value1", FieldFilterOperation.EQUAL)
+                        ),
+                        listOf(
+                            FieldFilterConfiguration("method1", "POST", FieldFilterOperation.EQUAL),
+                            FieldFilterConfiguration("method2", "GET", FieldFilterOperation.NOT_EQUAL)
                         )
                     )
                 )