added tests for Geofencing filter node

common/message/src/main/java/org/thingsboard/server/common/msg/TbMsg.java

@@ -42,6 +42,8 @@ import java.util.UUID;
 @Slf4j
 public final class TbMsg implements Serializable {
 
+    public static final String EMPTY = "{}";
+
     private final String queueName;
     private final UUID id;
     private final long ts;

rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/geo/AbstractGeofencingNode.java

@@ -48,14 +48,14 @@ public abstract class AbstractGeofencingNode<T extends TbGpsGeofencingFilterNode
     abstract protected Class<T> getConfigClazz();
 
     protected boolean checkMatches(TbMsg msg) throws TbNodeException {
-        JsonElement msgDataElement = new JsonParser().parse(msg.getData());
+        JsonElement msgDataElement = JsonParser.parseString(msg.getData());
         if (!msgDataElement.isJsonObject()) {
-            throw new TbNodeException("Incoming Message is not a valid JSON object");
+            throw new TbNodeException("Incoming Message is not a valid JSON object!");
         }
         JsonObject msgDataObj = msgDataElement.getAsJsonObject();
         double latitude = getValueFromMessageByName(msg, msgDataObj, config.getLatitudeKeyName());
         double longitude = getValueFromMessageByName(msg, msgDataObj, config.getLongitudeKeyName());
-        List<Perimeter> perimeters = getPerimeters(msg, msgDataObj);
+        List<Perimeter> perimeters = getPerimeters(msg);
         boolean matches = false;
         for (Perimeter perimeter : perimeters) {
             if (checkMatches(perimeter, latitude, longitude)) {
@@ -74,11 +74,11 @@ public abstract class AbstractGeofencingNode<T extends TbGpsGeofencingFilterNode
         } else if (perimeter.getPerimeterType() == PerimeterType.POLYGON) {
             return GeoUtil.contains(perimeter.getPolygonsDefinition(), new Coordinates(latitude, longitude));
         } else {
-            throw new TbNodeException("Unsupported perimeter type: " + perimeter.getPerimeterType());
+            throw new TbNodeException("Unsupported perimeter type: " + perimeter.getPerimeterType()  + "!");
         }
     }
 
-    protected List<Perimeter> getPerimeters(TbMsg msg, JsonObject msgDataObj) throws TbNodeException {
+    protected List<Perimeter> getPerimeters(TbMsg msg) throws TbNodeException {
         if (config.isFetchPerimeterInfoFromMessageMetadata()) {
             if (StringUtils.isEmpty(config.getPerimeterKeyName())) {
                 // Old configuration before "perimeterKeyName" was introduced

rule-engine/rule-engine-components/src/main/java/org/thingsboard/rule/engine/geo/GeoUtil.java

@@ -45,8 +45,6 @@ public class GeoUtil {
     private static final SpatialContext distCtx = SpatialContext.GEO;
     private static final JtsSpatialContext jtsCtx;
 
-    private static final JsonParser JSON_PARSER = new JsonParser();
-
     static {
         JtsSpatialContextFactory factory = new JtsSpatialContextFactory();
         factory.normWrapLongitude = true;
@@ -64,7 +62,7 @@ public class GeoUtil {
             throw new RuntimeException("Polygon string can't be empty or null!");
         }
 
-        JsonArray polygonsJson = normalizePolygonsJson(JSON_PARSER.parse(polygonInString).getAsJsonArray());
+        JsonArray polygonsJson = normalizePolygonsJson(JsonParser.parseString(polygonInString).getAsJsonArray());
         List<Geometry> polygons = buildPolygonsFromJson(polygonsJson);
         Set<Geometry> holes = extractHolesFrom(polygons);
         polygons.removeIf(holes::contains);

rule-engine/rule-engine-components/src/test/java/org/thingsboard/rule/engine/filter/TbAssetTypeSwitchNodeTest.java

@@ -50,9 +50,6 @@ import static org.thingsboard.server.common.data.msg.TbMsgType.POST_ATTRIBUTES_R
 
 class TbAssetTypeSwitchNodeTest {
 
-    private static final TbMsgMetaData EMPTY_METADATA = new TbMsgMetaData();
-    private static final String EMPTY_DATA = "{}";
-
     private AssetId assetId;
     private AssetId assetIdDeleted;
     private TbContext ctx;
@@ -121,7 +118,7 @@ class TbAssetTypeSwitchNodeTest {
     }
 
     private TbMsg getTbMsg(EntityId entityId) {
-        return TbMsg.newMsg(POST_ATTRIBUTES_REQUEST.name(), entityId, EMPTY_METADATA, EMPTY_DATA, callback);
+        return TbMsg.newMsg(POST_ATTRIBUTES_REQUEST.name(), entityId, TbMsgMetaData.EMPTY, TbMsg.EMPTY, callback);
     }
 
 }

rule-engine/rule-engine-components/src/test/java/org/thingsboard/rule/engine/filter/TbCheckAlarmStatusNodeTest.java

@@ -52,7 +52,6 @@ class TbCheckAlarmStatusNodeTest {
     private static final DeviceId DEVICE_ID = new DeviceId(UUID.randomUUID());
     private static final AlarmId ALARM_ID = new AlarmId(UUID.randomUUID());
     private static final TestDbCallbackExecutor DB_EXECUTOR = new TestDbCallbackExecutor();
-    private static final TbMsgMetaData EMPTY_METADATA = new TbMsgMetaData();
 
     private TbCheckAlarmStatusNode node;
 
@@ -160,7 +159,7 @@ class TbCheckAlarmStatusNodeTest {
     }
 
     private TbMsg getTbMsg(String msgData) {
-        return TbMsg.newMsg(POST_ATTRIBUTES_REQUEST.name(), DEVICE_ID, EMPTY_METADATA, msgData);
+        return TbMsg.newMsg(POST_ATTRIBUTES_REQUEST.name(), DEVICE_ID, TbMsgMetaData.EMPTY, msgData);
     }
 
 }

rule-engine/rule-engine-components/src/test/java/org/thingsboard/rule/engine/filter/TbCheckMessageNodeTest.java

@@ -46,9 +46,7 @@ import static org.thingsboard.server.common.data.msg.TbMsgType.POST_ATTRIBUTES_R
 class TbCheckMessageNodeTest {
 
     private static final DeviceId DEVICE_ID = new DeviceId(UUID.randomUUID());
-    private static final TbMsgMetaData EMPTY_METADATA = new TbMsgMetaData();
+    private static final TbMsg EMPTY_POST_ATTRIBUTES_MSG = TbMsg.newMsg(POST_ATTRIBUTES_REQUEST.name(), DEVICE_ID, TbMsgMetaData.EMPTY, TbMsg.EMPTY);
-    private static final String EMPTY_DATA = "{}";
-    private static final TbMsg EMPTY_POST_ATTRIBUTES_MSG = TbMsg.newMsg(POST_ATTRIBUTES_REQUEST.name(), DEVICE_ID, EMPTY_METADATA, EMPTY_DATA);
 
     private TbCheckMessageNode node;
 
@@ -195,7 +193,7 @@ class TbCheckMessageNodeTest {
     }
 
     private TbMsg getTbMsg(boolean emptyData) {
-        String data = emptyData ? EMPTY_DATA : "{\"temperature-0\": 25}";
+        String data = emptyData ? TbMsg.EMPTY : "{\"temperature-0\": 25}";
         var metadata = new TbMsgMetaData();
         metadata.putValue(DEVICE_NAME, "Test Device");
         metadata.putValue(DEVICE_TYPE, DEFAULT_DEVICE_TYPE);

rule-engine/rule-engine-components/src/test/java/org/thingsboard/rule/engine/filter/TbCheckRelationNodeTest.java

@@ -26,7 +26,6 @@ import org.thingsboard.rule.engine.TestDbCallbackExecutor;
 import org.thingsboard.rule.engine.api.TbContext;
 import org.thingsboard.rule.engine.api.TbNodeConfiguration;
 import org.thingsboard.rule.engine.api.TbNodeException;
-import org.thingsboard.server.common.data.EntityType;
 import org.thingsboard.server.common.data.id.AssetId;
 import org.thingsboard.server.common.data.id.DeviceId;
 import org.thingsboard.server.common.data.id.TenantId;
@@ -62,9 +61,7 @@ class TbCheckRelationNodeTest {
     private static final TenantId TENANT_ID = new TenantId(UUID.randomUUID());
     private static final DeviceId ORIGINATOR_ID = new DeviceId(UUID.randomUUID());
     private static final TestDbCallbackExecutor DB_EXECUTOR = new TestDbCallbackExecutor();
-    private static final TbMsgMetaData EMPTY_METADATA = new TbMsgMetaData();
+    private static final TbMsg EMPTY_POST_ATTRIBUTES_MSG = TbMsg.newMsg(POST_ATTRIBUTES_REQUEST.name(), ORIGINATOR_ID, TbMsgMetaData.EMPTY, TbMsg.EMPTY);
-    private static final String EMPTY_DATA = "{}";
-    private static final TbMsg EMPTY_POST_ATTRIBUTES_MSG = TbMsg.newMsg(POST_ATTRIBUTES_REQUEST.name(), ORIGINATOR_ID, EMPTY_METADATA, EMPTY_DATA);
 
     private TbCheckRelationNode node;
 

rule-engine/rule-engine-components/src/test/java/org/thingsboard/rule/engine/filter/TbDeviceTypeSwitchNodeTest.java

@@ -118,6 +118,6 @@ class TbDeviceTypeSwitchNodeTest {
     }
 
     private TbMsg getTbMsg(EntityId entityId) {
-        return TbMsg.newMsg(POST_ATTRIBUTES_REQUEST.name(), entityId, new TbMsgMetaData(), "{}", callback);
+        return TbMsg.newMsg(POST_ATTRIBUTES_REQUEST.name(), entityId, TbMsgMetaData.EMPTY, TbMsg.EMPTY, callback);
     }
 }

rule-engine/rule-engine-components/src/test/java/org/thingsboard/rule/engine/filter/TbJsFilterNodeTest.java

@@ -59,7 +59,7 @@ public class TbJsFilterNodeTest {
     @Test
     public void falseEvaluationDoNotSendMsg() throws TbNodeException {
         initWithScript();
-        TbMsg msg = TbMsg.newMsg(EntityType.USER.name(), null, new TbMsgMetaData(), TbMsgDataType.JSON, "{}", ruleChainId, ruleNodeId);
+        TbMsg msg = TbMsg.newMsg(EntityType.USER.name(), null, new TbMsgMetaData(), TbMsgDataType.JSON, TbMsg.EMPTY, ruleChainId, ruleNodeId);
         when(scriptEngine.executeFilterAsync(msg)).thenReturn(Futures.immediateFuture(false));
 
         node.onMsg(ctx, msg);
@@ -71,7 +71,7 @@ public class TbJsFilterNodeTest {
     public void exceptionInJsThrowsException() throws TbNodeException {
         initWithScript();
         TbMsgMetaData metaData = new TbMsgMetaData();
-        TbMsg msg = TbMsg.newMsg(EntityType.USER.name(), null, metaData, TbMsgDataType.JSON, "{}", ruleChainId, ruleNodeId);
+        TbMsg msg = TbMsg.newMsg(EntityType.USER.name(), null, metaData, TbMsgDataType.JSON, TbMsg.EMPTY, ruleChainId, ruleNodeId);
         when(scriptEngine.executeFilterAsync(msg)).thenReturn(Futures.immediateFailedFuture(new ScriptException("error")));
 
 
@@ -83,7 +83,7 @@ public class TbJsFilterNodeTest {
     public void metadataConditionCanBeTrue() throws TbNodeException {
         initWithScript();
         TbMsgMetaData metaData = new TbMsgMetaData();
-        TbMsg msg = TbMsg.newMsg(EntityType.USER.name(), null, metaData, TbMsgDataType.JSON, "{}", ruleChainId, ruleNodeId);
+        TbMsg msg = TbMsg.newMsg(EntityType.USER.name(), null, metaData, TbMsgDataType.JSON, TbMsg.EMPTY, ruleChainId, ruleNodeId);
         when(scriptEngine.executeFilterAsync(msg)).thenReturn(Futures.immediateFuture(true));
 
         node.onMsg(ctx, msg);

rule-engine/rule-engine-components/src/test/java/org/thingsboard/rule/engine/filter/TbMsgTypeFilterNodeTest.java

@@ -97,7 +97,7 @@ class TbMsgTypeFilterNodeTest {
     }
 
     private TbMsg getTbMsg(EntityId entityId, TbMsgType msgType) {
-        return TbMsg.newMsg(msgType.name(), entityId, new TbMsgMetaData(), "{}");
+        return TbMsg.newMsg(msgType.name(), entityId, TbMsgMetaData.EMPTY, TbMsg.EMPTY);
     }
 
 }

rule-engine/rule-engine-components/src/test/java/org/thingsboard/rule/engine/filter/TbMsgTypeSwitchNodeTest.java

@@ -40,8 +40,6 @@ import static org.mockito.Mockito.verify;
 class TbMsgTypeSwitchNodeTest {
 
     private static final DeviceId DEVICE_ID = new DeviceId(UUID.randomUUID());
-    private static final TbMsgMetaData EMPTY_METADATA = new TbMsgMetaData();
-    private static final String EMPTY_DATA = "{}";
 
     private TbMsgTypeSwitchNode node;
 
@@ -90,7 +88,7 @@ class TbMsgTypeSwitchNodeTest {
     }
 
     private TbMsg getTbMsg(TbMsgType msgType) {
-        return TbMsg.newMsg(msgType.name(), DEVICE_ID, EMPTY_METADATA, EMPTY_DATA);
+        return TbMsg.newMsg(msgType.name(), DEVICE_ID, TbMsgMetaData.EMPTY, TbMsg.EMPTY);
     }
 
 }

rule-engine/rule-engine-components/src/test/java/org/thingsboard/rule/engine/filter/TbOriginatorTypeFilterNodeTest.java

@@ -96,7 +96,7 @@ class TbOriginatorTypeFilterNodeTest {
     }
 
     private TbMsg getTbMsg(EntityId entityId) {
-        return TbMsg.newMsg(POST_ATTRIBUTES_REQUEST.name(), entityId, new TbMsgMetaData(), "{}");
+        return TbMsg.newMsg(POST_ATTRIBUTES_REQUEST.name(), entityId, TbMsgMetaData.EMPTY, TbMsg.EMPTY);
     }
 
 }

rule-engine/rule-engine-components/src/test/java/org/thingsboard/rule/engine/filter/TbOriginatorTypeSwitchNodeTest.java

@@ -42,8 +42,6 @@ import static org.thingsboard.server.common.data.msg.TbMsgType.POST_ATTRIBUTES_R
 class TbOriginatorTypeSwitchNodeTest {
 
     private static final UUID RANDOM_UUID = UUID.randomUUID();
-    private static final TbMsgMetaData EMPTY_METADATA = new TbMsgMetaData();
-    private static final String EMPTY_DATA = "{}";
 
     private TbOriginatorTypeSwitchNode node;
 
@@ -92,7 +90,7 @@ class TbOriginatorTypeSwitchNodeTest {
     }
 
     private TbMsg getTbMsg(EntityId entityId) {
-        return TbMsg.newMsg(POST_ATTRIBUTES_REQUEST.name(), entityId, EMPTY_METADATA, EMPTY_DATA);
+        return TbMsg.newMsg(POST_ATTRIBUTES_REQUEST.name(), entityId, TbMsgMetaData.EMPTY, TbMsg.EMPTY);
     }
 
 }

rule-engine/rule-engine-components/src/test/java/org/thingsboard/rule/engine/geo/TbGeoUtilTest.java → rule-engine/rule-engine-components/src/test/java/org/thingsboard/rule/engine/geo/GeoUtilTest.java

@@ -21,7 +21,7 @@ import org.junit.runner.RunWith;
 import org.mockito.junit.MockitoJUnitRunner;
 
 @RunWith(MockitoJUnitRunner.class)
-public class TbGeoUtilTest {
+public class GeoUtilTest {
 
     public static final String SIMPLE_RECT = "[[51.903762928405555,23.642220786948297],[44.669801219635644,41.83345155830211]]";
     public static final String SIMPLE_RECT_WITH_HOLE_IN_CENTER = "[[[44.66980121963565,23.642220786948297],[44.66980121963565,41.83345155830211],[51.903762928405555,41.83345155830211],[51.903762928405555,23.642220786948297]],[[46.10464044504632,26.234282119122227],[50.8755868028522,26.25625220459488],[51.04164771375101,38.5595000692786],[45.99790855491869,38.75723083853248]]]";

rule-engine/rule-engine-components/src/test/java/org/thingsboard/rule/engine/geo/TbGpsGeofencingFilterNodeTest.java

@@ -0,0 +1,460 @@
+/**
+ * Copyright © 2016-2023 The Thingsboard Authors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.thingsboard.rule.engine.geo;
+
+import com.fasterxml.jackson.databind.node.ObjectNode;
+import org.junit.jupiter.api.AfterEach;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.mockito.ArgumentCaptor;
+import org.thingsboard.common.util.JacksonUtil;
+import org.thingsboard.rule.engine.api.TbContext;
+import org.thingsboard.rule.engine.api.TbNodeConfiguration;
+import org.thingsboard.rule.engine.api.TbNodeException;
+import org.thingsboard.server.common.data.id.DeviceId;
+import org.thingsboard.server.common.data.id.EntityId;
+import org.thingsboard.server.common.data.msg.TbNodeConnectionType;
+import org.thingsboard.server.common.msg.TbMsg;
+import org.thingsboard.server.common.msg.TbMsgMetaData;
+
+import java.util.UUID;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.junit.jupiter.api.Assertions.assertThrows;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.ArgumentMatchers.eq;
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.never;
+import static org.mockito.Mockito.times;
+import static org.mockito.Mockito.verify;
+import static org.thingsboard.rule.engine.geo.GeoUtilTest.POINT_INSIDE_SIMPLE_RECT_CENTER;
+import static org.thingsboard.rule.engine.geo.GeoUtilTest.POINT_OUTSIDE_SIMPLE_RECT;
+import static org.thingsboard.server.common.data.msg.TbMsgType.POST_ATTRIBUTES_REQUEST;
+
+class TbGpsGeofencingFilterNodeTest {
+
+    private static final double CIRCLE_RANGE = 1.0;
+    private static final Coordinates CIRCLE_CENTER = new Coordinates(49.0384, 31.4513);
+    private static final Coordinates POINT_INSIDE_CIRCLE = new Coordinates(49.0354, 31.4513); // distance from center: 0.334 km
+    private static final Coordinates POINT_OUTSIDE_CIRCLE = new Coordinates(49.0284, 31.4513); // distance from center: 1.112 km
+
+    private TbContext ctx;
+    private TbGpsGeofencingFilterNode node;
+
+    @BeforeEach
+    void setUp() {
+        ctx = mock(TbContext.class);
+        node = new TbGpsGeofencingFilterNode();
+    }
+
+    @AfterEach
+    void tearDown() {
+        node.destroy();
+    }
+
+    // Exception tests
+
+    @Test
+    void givenDefaultConfig_whenOnMsg_thenExceptionInvalidMsg() throws TbNodeException {
+        // GIVEN
+        var config = new TbGpsGeofencingFilterNodeConfiguration().defaultConfiguration();
+        node.init(ctx, new TbNodeConfiguration(JacksonUtil.valueToTree(config)));
+
+        DeviceId deviceId = new DeviceId(UUID.randomUUID());
+        TbMsg msg = getEmptyArrayTbMsg(deviceId);
+
+        // WHEN
+        var exception = assertThrows(TbNodeException.class, () -> node.onMsg(ctx, msg));
+
+        // THEN
+        assertThat(exception.getMessage()).isEqualTo("Incoming Message is not a valid JSON object!");
+    }
+
+    @Test
+    void givenDefaultConfig_whenOnMsg_thenExceptionMissingPerimeterDefinitionNewVersion() throws TbNodeException {
+        // GIVEN
+        var config = new TbGpsGeofencingFilterNodeConfiguration().defaultConfiguration();
+        node.init(ctx, new TbNodeConfiguration(JacksonUtil.valueToTree(config)));
+
+        DeviceId deviceId = new DeviceId(UUID.randomUUID());
+        TbMsg msg = getTbMsg(deviceId, TbMsgMetaData.EMPTY,
+                POINT_INSIDE_SIMPLE_RECT_CENTER.getLatitude(), POINT_INSIDE_SIMPLE_RECT_CENTER.getLongitude());
+
+        // WHEN
+        var exception = assertThrows(TbNodeException.class, () -> node.onMsg(ctx, msg));
+
+        // THEN
+        assertThat(exception.getMessage()).isEqualTo("Missing perimeter definition!");
+    }
+
+    @Test
+    void givenTypePolygonAndConfigWithoutPerimeterKeyName_whenOnMsg_thenExceptionMissingPerimeterDefinitionOldVersion() throws TbNodeException {
+        // GIVEN
+        var config = new TbGpsGeofencingFilterNodeConfiguration().defaultConfiguration();
+        config.setPerimeterKeyName(null);
+        node.init(ctx, new TbNodeConfiguration(JacksonUtil.valueToTree(config)));
+
+        DeviceId deviceId = new DeviceId(UUID.randomUUID());
+        TbMsg msg = getTbMsg(deviceId, TbMsgMetaData.EMPTY,
+                POINT_INSIDE_SIMPLE_RECT_CENTER.getLatitude(), POINT_INSIDE_SIMPLE_RECT_CENTER.getLongitude());
+
+        // WHEN
+        var exception = assertThrows(TbNodeException.class, () -> node.onMsg(ctx, msg));
+
+        // THEN
+        assertThat(exception.getMessage()).isEqualTo("Missing perimeter definition!");
+    }
+
+    // Polygon tests
+
+    @Test
+    void givenTypePolygonAndConfigWithoutPerimeterKeyName_whenOnMsg_thenTrue() throws TbNodeException {
+        // GIVEN
+        var config = new TbGpsGeofencingFilterNodeConfiguration().defaultConfiguration();
+        config.setPerimeterKeyName(null);
+        node.init(ctx, new TbNodeConfiguration(JacksonUtil.valueToTree(config)));
+
+        DeviceId deviceId = new DeviceId(UUID.randomUUID());
+        TbMsgMetaData metadata = getMetadataForOldVersionPolygonPerimeter();
+        TbMsg msg = getTbMsg(deviceId, metadata,
+                POINT_INSIDE_SIMPLE_RECT_CENTER.getLatitude(), POINT_INSIDE_SIMPLE_RECT_CENTER.getLongitude());
+
+        // WHEN
+        node.onMsg(ctx, msg);
+
+        // THEN
+        ArgumentCaptor<TbMsg> newMsgCaptor = ArgumentCaptor.forClass(TbMsg.class);
+        verify(ctx, times(1)).tellNext(newMsgCaptor.capture(), eq(TbNodeConnectionType.TRUE));
+        verify(ctx, never()).tellFailure(any(), any());
+        TbMsg newMsg = newMsgCaptor.getValue();
+        assertThat(newMsg).isNotNull();
+        assertThat(newMsg).isSameAs(msg);
+    }
+
+    @Test
+    void givenTypePolygonAndConfigWithoutPerimeterKeyName_whenOnMsg_thenFalse() throws TbNodeException {
+        // GIVEN
+        var config = new TbGpsGeofencingFilterNodeConfiguration().defaultConfiguration();
+        config.setPerimeterKeyName(null);
+        node.init(ctx, new TbNodeConfiguration(JacksonUtil.valueToTree(config)));
+
+        DeviceId deviceId = new DeviceId(UUID.randomUUID());
+        TbMsgMetaData metadata = getMetadataForOldVersionPolygonPerimeter();
+        TbMsg msg = getTbMsg(deviceId, metadata,
+                POINT_OUTSIDE_SIMPLE_RECT.getLatitude(), POINT_OUTSIDE_SIMPLE_RECT.getLongitude());
+
+        // WHEN
+        node.onMsg(ctx, msg);
+
+        // THEN
+        ArgumentCaptor<TbMsg> newMsgCaptor = ArgumentCaptor.forClass(TbMsg.class);
+        verify(ctx, times(1)).tellNext(newMsgCaptor.capture(), eq(TbNodeConnectionType.FALSE));
+        verify(ctx, never()).tellFailure(any(), any());
+        TbMsg newMsg = newMsgCaptor.getValue();
+        assertThat(newMsg).isNotNull();
+        assertThat(newMsg).isSameAs(msg);
+    }
+
+    @Test
+    void givenDefaultConfig_whenOnMsg_thenTrue() throws TbNodeException {
+        // GIVEN
+        var config = new TbGpsGeofencingFilterNodeConfiguration().defaultConfiguration();
+        node.init(ctx, new TbNodeConfiguration(JacksonUtil.valueToTree(config)));
+
+        DeviceId deviceId = new DeviceId(UUID.randomUUID());
+        TbMsgMetaData metadata = getMetadataForNewVersionPolygonPerimeter();
+        TbMsg msg = getTbMsg(deviceId, metadata,
+                POINT_INSIDE_SIMPLE_RECT_CENTER.getLatitude(), POINT_INSIDE_SIMPLE_RECT_CENTER.getLongitude());
+
+        // WHEN
+        node.onMsg(ctx, msg);
+
+        // THEN
+        ArgumentCaptor<TbMsg> newMsgCaptor = ArgumentCaptor.forClass(TbMsg.class);
+        verify(ctx, times(1)).tellNext(newMsgCaptor.capture(), eq(TbNodeConnectionType.TRUE));
+        verify(ctx, never()).tellFailure(any(), any());
+        TbMsg newMsg = newMsgCaptor.getValue();
+        assertThat(newMsg).isNotNull();
+        assertThat(newMsg).isSameAs(msg);
+    }
+
+    @Test
+    void givenDefaultConfig_whenOnMsg_thenFalse() throws TbNodeException {
+        // GIVEN
+        var config = new TbGpsGeofencingFilterNodeConfiguration().defaultConfiguration();
+        node.init(ctx, new TbNodeConfiguration(JacksonUtil.valueToTree(config)));
+
+        DeviceId deviceId = new DeviceId(UUID.randomUUID());
+        TbMsgMetaData metadata = getMetadataForNewVersionPolygonPerimeter();
+        TbMsg msg = getTbMsg(deviceId, metadata,
+                POINT_OUTSIDE_SIMPLE_RECT.getLatitude(), POINT_OUTSIDE_SIMPLE_RECT.getLongitude());
+
+        // WHEN
+        node.onMsg(ctx, msg);
+
+        // THEN
+        ArgumentCaptor<TbMsg> newMsgCaptor = ArgumentCaptor.forClass(TbMsg.class);
+        verify(ctx, times(1)).tellNext(newMsgCaptor.capture(), eq(TbNodeConnectionType.FALSE));
+        verify(ctx, never()).tellFailure(any(), any());
+        TbMsg newMsg = newMsgCaptor.getValue();
+        assertThat(newMsg).isNotNull();
+        assertThat(newMsg).isSameAs(msg);
+    }
+
+    @Test
+    void givenTypePolygonAndConfigWithPolygonDefined_whenOnMsg_thenTrue() throws TbNodeException {
+        // GIVEN
+        var config = new TbGpsGeofencingFilterNodeConfiguration().defaultConfiguration();
+        config.setFetchPerimeterInfoFromMessageMetadata(false);
+        config.setPolygonsDefinition(GeoUtilTest.SIMPLE_RECT);
+        node.init(ctx, new TbNodeConfiguration(JacksonUtil.valueToTree(config)));
+
+        DeviceId deviceId = new DeviceId(UUID.randomUUID());
+        TbMsg msg = getTbMsg(deviceId, TbMsgMetaData.EMPTY,
+                POINT_INSIDE_SIMPLE_RECT_CENTER.getLatitude(), POINT_INSIDE_SIMPLE_RECT_CENTER.getLongitude());
+
+        // WHEN
+        node.onMsg(ctx, msg);
+
+        // THEN
+        ArgumentCaptor<TbMsg> newMsgCaptor = ArgumentCaptor.forClass(TbMsg.class);
+        verify(ctx, times(1)).tellNext(newMsgCaptor.capture(), eq(TbNodeConnectionType.TRUE));
+        verify(ctx, never()).tellFailure(any(), any());
+        TbMsg newMsg = newMsgCaptor.getValue();
+        assertThat(newMsg).isNotNull();
+        assertThat(newMsg).isSameAs(msg);
+    }
+
+    @Test
+    void givenTypePolygonAndConfigWithPolygonDefined_whenOnMsg_thenFalse() throws TbNodeException {
+        // GIVEN
+        var config = new TbGpsGeofencingFilterNodeConfiguration().defaultConfiguration();
+        config.setFetchPerimeterInfoFromMessageMetadata(false);
+        config.setPolygonsDefinition(GeoUtilTest.SIMPLE_RECT);
+        node.init(ctx, new TbNodeConfiguration(JacksonUtil.valueToTree(config)));
+
+        DeviceId deviceId = new DeviceId(UUID.randomUUID());
+        TbMsg msg = getTbMsg(deviceId, TbMsgMetaData.EMPTY,
+                POINT_OUTSIDE_SIMPLE_RECT.getLatitude(), POINT_OUTSIDE_SIMPLE_RECT.getLongitude());
+
+        // WHEN
+        node.onMsg(ctx, msg);
+
+        // THEN
+        ArgumentCaptor<TbMsg> newMsgCaptor = ArgumentCaptor.forClass(TbMsg.class);
+        verify(ctx, times(1)).tellNext(newMsgCaptor.capture(), eq(TbNodeConnectionType.FALSE));
+        verify(ctx, never()).tellFailure(any(), any());
+        TbMsg newMsg = newMsgCaptor.getValue();
+        assertThat(newMsg).isNotNull();
+        assertThat(newMsg).isSameAs(msg);
+    }
+
+    private TbMsgMetaData getMetadataForOldVersionPolygonPerimeter() {
+        var metadata = new TbMsgMetaData();
+        metadata.putValue("perimeter", GeoUtilTest.SIMPLE_RECT);
+        return metadata;
+    }
+
+    private TbMsgMetaData getMetadataForNewVersionPolygonPerimeter() {
+        var metadata = new TbMsgMetaData();
+        metadata.putValue("ss_perimeter", GeoUtilTest.SIMPLE_RECT);
+        return metadata;
+    }
+
+    // Circle tests
+
+    @Test
+    void givenTypeCircleAndConfigWithoutPerimeterKeyName_whenOnMsg_thenTrue() throws TbNodeException {
+        // GIVEN
+        var config = new TbGpsGeofencingFilterNodeConfiguration().defaultConfiguration();
+        config.setPerimeterKeyName(null);
+        node.init(ctx, new TbNodeConfiguration(JacksonUtil.valueToTree(config)));
+
+        DeviceId deviceId = new DeviceId(UUID.randomUUID());
+        TbMsgMetaData metadata = getMetadataForOldVersionCirclePerimeter();
+        TbMsg msg = getTbMsg(deviceId, metadata,
+                POINT_INSIDE_CIRCLE.getLatitude(), POINT_INSIDE_CIRCLE.getLongitude());
+
+        // WHEN
+        node.onMsg(ctx, msg);
+
+        // THEN
+        ArgumentCaptor<TbMsg> newMsgCaptor = ArgumentCaptor.forClass(TbMsg.class);
+        verify(ctx, times(1)).tellNext(newMsgCaptor.capture(), eq(TbNodeConnectionType.TRUE));
+        verify(ctx, never()).tellFailure(any(), any());
+        TbMsg newMsg = newMsgCaptor.getValue();
+        assertThat(newMsg).isNotNull();
+        assertThat(newMsg).isSameAs(msg);
+    }
+
+    @Test
+    void givenTypeCircleAndConfigWithoutPerimeterKeyName_whenOnMsg_thenFalse() throws TbNodeException {
+        // GIVEN
+        var config = new TbGpsGeofencingFilterNodeConfiguration().defaultConfiguration();
+        config.setPerimeterKeyName(null);
+        node.init(ctx, new TbNodeConfiguration(JacksonUtil.valueToTree(config)));
+
+        DeviceId deviceId = new DeviceId(UUID.randomUUID());
+        TbMsgMetaData metadata = getMetadataForOldVersionCirclePerimeter();
+        TbMsg msg = getTbMsg(deviceId, metadata,
+                POINT_OUTSIDE_CIRCLE.getLatitude(), POINT_OUTSIDE_CIRCLE.getLongitude());
+
+        // WHEN
+        node.onMsg(ctx, msg);
+
+        // THEN
+        ArgumentCaptor<TbMsg> newMsgCaptor = ArgumentCaptor.forClass(TbMsg.class);
+        verify(ctx, times(1)).tellNext(newMsgCaptor.capture(), eq(TbNodeConnectionType.FALSE));
+        verify(ctx, never()).tellFailure(any(), any());
+        TbMsg newMsg = newMsgCaptor.getValue();
+        assertThat(newMsg).isNotNull();
+        assertThat(newMsg).isSameAs(msg);
+    }
+
+    @Test
+    void givenTypeCircle_whenOnMsg_thenTrue() throws TbNodeException {
+        // GIVEN
+        var config = new TbGpsGeofencingFilterNodeConfiguration().defaultConfiguration();
+        config.setPerimeterType(PerimeterType.CIRCLE);
+        node.init(ctx, new TbNodeConfiguration(JacksonUtil.valueToTree(config)));
+
+        DeviceId deviceId = new DeviceId(UUID.randomUUID());
+        TbMsgMetaData metadata = getMetadataForNewVersionCirclePerimeter();
+        TbMsg msg = getTbMsg(deviceId, metadata,
+                POINT_INSIDE_CIRCLE.getLatitude(), POINT_INSIDE_CIRCLE.getLongitude());
+
+        // WHEN
+        node.onMsg(ctx, msg);
+
+        // THEN
+        ArgumentCaptor<TbMsg> newMsgCaptor = ArgumentCaptor.forClass(TbMsg.class);
+        verify(ctx, times(1)).tellNext(newMsgCaptor.capture(), eq(TbNodeConnectionType.TRUE));
+        verify(ctx, never()).tellFailure(any(), any());
+        TbMsg newMsg = newMsgCaptor.getValue();
+        assertThat(newMsg).isNotNull();
+        assertThat(newMsg).isSameAs(msg);
+    }
+
+    @Test
+    void givenTypeCircle_whenOnMsg_thenFalse() throws TbNodeException {
+        // GIVEN
+        var config = new TbGpsGeofencingFilterNodeConfiguration().defaultConfiguration();
+        config.setPerimeterType(PerimeterType.CIRCLE);
+        node.init(ctx, new TbNodeConfiguration(JacksonUtil.valueToTree(config)));
+
+        DeviceId deviceId = new DeviceId(UUID.randomUUID());
+        TbMsgMetaData metadata = getMetadataForNewVersionCirclePerimeter();
+        TbMsg msg = getTbMsg(deviceId, metadata,
+                POINT_OUTSIDE_CIRCLE.getLatitude(), POINT_OUTSIDE_CIRCLE.getLongitude());
+
+        // WHEN
+        node.onMsg(ctx, msg);
+
+        // THEN
+        ArgumentCaptor<TbMsg> newMsgCaptor = ArgumentCaptor.forClass(TbMsg.class);
+        verify(ctx, times(1)).tellNext(newMsgCaptor.capture(), eq(TbNodeConnectionType.FALSE));
+        verify(ctx, never()).tellFailure(any(), any());
+        TbMsg newMsg = newMsgCaptor.getValue();
+        assertThat(newMsg).isNotNull();
+        assertThat(newMsg).isSameAs(msg);
+    }
+
+    @Test
+    void givenTypeCircleAndConfigWithCircleDefined_whenOnMsg_thenTrue() throws TbNodeException {
+        // GIVEN
+        var config = new TbGpsGeofencingFilterNodeConfiguration().defaultConfiguration();
+        config.setFetchPerimeterInfoFromMessageMetadata(false);
+        config.setPerimeterType(PerimeterType.CIRCLE);
+        config.setCenterLatitude(CIRCLE_CENTER.getLatitude());
+        config.setCenterLongitude(CIRCLE_CENTER.getLongitude());
+        config.setRange(CIRCLE_RANGE);
+        config.setRangeUnit(RangeUnit.KILOMETER);
+        node.init(ctx, new TbNodeConfiguration(JacksonUtil.valueToTree(config)));
+
+        DeviceId deviceId = new DeviceId(UUID.randomUUID());
+        TbMsg msg = getTbMsg(deviceId, TbMsgMetaData.EMPTY,
+                POINT_INSIDE_CIRCLE.getLatitude(), POINT_INSIDE_CIRCLE.getLongitude());
+
+        // WHEN
+        node.onMsg(ctx, msg);
+
+        // THEN
+        ArgumentCaptor<TbMsg> newMsgCaptor = ArgumentCaptor.forClass(TbMsg.class);
+        verify(ctx, times(1)).tellNext(newMsgCaptor.capture(), eq(TbNodeConnectionType.TRUE));
+        verify(ctx, never()).tellFailure(any(), any());
+        TbMsg newMsg = newMsgCaptor.getValue();
+        assertThat(newMsg).isNotNull();
+        assertThat(newMsg).isSameAs(msg);
+    }
+
+    @Test
+    void givenTypeCircleAndConfigWithCircleDefined_whenOnMsg_thenFalse() throws TbNodeException {
+        // GIVEN
+        var config = new TbGpsGeofencingFilterNodeConfiguration().defaultConfiguration();
+        config.setFetchPerimeterInfoFromMessageMetadata(false);
+        config.setPerimeterType(PerimeterType.CIRCLE);
+        config.setCenterLatitude(CIRCLE_CENTER.getLatitude());
+        config.setCenterLongitude(CIRCLE_CENTER.getLongitude());
+        config.setRange(CIRCLE_RANGE);
+        config.setRangeUnit(RangeUnit.KILOMETER);
+        node.init(ctx, new TbNodeConfiguration(JacksonUtil.valueToTree(config)));
+
+        DeviceId deviceId = new DeviceId(UUID.randomUUID());
+        TbMsg msg = getTbMsg(deviceId, TbMsgMetaData.EMPTY,
+                POINT_OUTSIDE_CIRCLE.getLatitude(), POINT_OUTSIDE_CIRCLE.getLongitude());
+
+        // WHEN
+        node.onMsg(ctx, msg);
+
+        // THEN
+        ArgumentCaptor<TbMsg> newMsgCaptor = ArgumentCaptor.forClass(TbMsg.class);
+        verify(ctx, times(1)).tellNext(newMsgCaptor.capture(), eq(TbNodeConnectionType.FALSE));
+        verify(ctx, never()).tellFailure(any(), any());
+        TbMsg newMsg = newMsgCaptor.getValue();
+        assertThat(newMsg).isNotNull();
+        assertThat(newMsg).isSameAs(msg);
+    }
+
+    private TbMsgMetaData getMetadataForOldVersionCirclePerimeter() {
+        var metadata = new TbMsgMetaData();
+        metadata.putValue("centerLatitude", String.valueOf(CIRCLE_CENTER.getLatitude()));
+        metadata.putValue("centerLongitude", String.valueOf(CIRCLE_CENTER.getLongitude()));
+        metadata.putValue("range", String.valueOf(CIRCLE_RANGE));
+        metadata.putValue("rangeUnit", String.valueOf(RangeUnit.KILOMETER));
+        return metadata;
+    }
+
+    private TbMsgMetaData getMetadataForNewVersionCirclePerimeter() {
+        ObjectNode perimeter = JacksonUtil.newObjectNode();
+        perimeter.put("latitude", CIRCLE_CENTER.getLatitude());
+        perimeter.put("longitude", CIRCLE_CENTER.getLongitude());
+        perimeter.put("radius", CIRCLE_RANGE);
+        perimeter.put("radiusUnit", String.valueOf(RangeUnit.KILOMETER));
+        var metadata = new TbMsgMetaData();
+        metadata.putValue("ss_perimeter", JacksonUtil.toString(perimeter));
+        return metadata;
+    }
+
+    private TbMsg getTbMsg(EntityId entityId, TbMsgMetaData metadata, double latitude, double longitude) {
+        String data = "{\"latitude\": " + latitude + ", \"longitude\": " + longitude + "}";
+        return TbMsg.newMsg(POST_ATTRIBUTES_REQUEST.name(), entityId, metadata, data);
+    }
+
+    private TbMsg getEmptyArrayTbMsg(EntityId entityId) {
+        return TbMsg.newMsg(POST_ATTRIBUTES_REQUEST.name(), entityId, TbMsgMetaData.EMPTY, "[]");
+    }
+
+}