Andrii Shvaika
4 years ago
45 changed files with 809 additions and 189 deletions
@ -0,0 +1,117 @@ |
|||
/** |
|||
* Copyright © 2016-2022 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.math; |
|||
|
|||
import com.fasterxml.jackson.databind.node.ObjectNode; |
|||
import org.junit.Assert; |
|||
import org.junit.Test; |
|||
import org.thingsboard.common.util.JacksonUtil; |
|||
import org.thingsboard.rule.engine.math.TbMathArgument; |
|||
import org.thingsboard.rule.engine.math.TbMathArgumentType; |
|||
import org.thingsboard.rule.engine.math.TbMathArgumentValue; |
|||
import org.thingsboard.server.common.msg.TbMsgMetaData; |
|||
|
|||
import java.util.Optional; |
|||
|
|||
import static org.junit.jupiter.api.Assertions.assertThrows; |
|||
|
|||
public class TbMathArgumentValueTest { |
|||
|
|||
@Test |
|||
public void test_fromMessageBody_then_defaultValue() { |
|||
TbMathArgument tbMathArgument = new TbMathArgument(TbMathArgumentType.MESSAGE_BODY, "TestKey"); |
|||
tbMathArgument.setDefaultValue(5.0); |
|||
TbMathArgumentValue result = TbMathArgumentValue.fromMessageBody(tbMathArgument, Optional.ofNullable(JacksonUtil.newObjectNode())); |
|||
Assert.assertEquals(5.0, result.getValue(), 0d); |
|||
} |
|||
|
|||
@Test |
|||
public void test_fromMessageBody_then_emptyBody() { |
|||
TbMathArgument tbMathArgument = new TbMathArgument(TbMathArgumentType.MESSAGE_BODY, "TestKey"); |
|||
Throwable thrown = assertThrows(RuntimeException.class, () -> { |
|||
TbMathArgumentValue result = TbMathArgumentValue.fromMessageBody(tbMathArgument, Optional.empty()); |
|||
}); |
|||
Assert.assertNotNull(thrown.getMessage()); |
|||
} |
|||
|
|||
@Test |
|||
public void test_fromMessageBody_then_noKey() { |
|||
TbMathArgument tbMathArgument = new TbMathArgument(TbMathArgumentType.MESSAGE_BODY, "TestKey"); |
|||
Throwable thrown = assertThrows(RuntimeException.class, () -> TbMathArgumentValue.fromMessageBody(tbMathArgument, Optional.ofNullable(JacksonUtil.newObjectNode()))); |
|||
Assert.assertNotNull(thrown.getMessage()); |
|||
} |
|||
|
|||
@Test |
|||
public void test_fromMessageBody_then_valueEmpty() { |
|||
TbMathArgument tbMathArgument = new TbMathArgument(TbMathArgumentType.MESSAGE_BODY, "TestKey"); |
|||
ObjectNode msgData = JacksonUtil.newObjectNode(); |
|||
msgData.putNull("TestKey"); |
|||
|
|||
//null value
|
|||
Throwable thrown = assertThrows(RuntimeException.class, () -> TbMathArgumentValue.fromMessageBody(tbMathArgument, Optional.of(msgData))); |
|||
Assert.assertNotNull(thrown.getMessage()); |
|||
|
|||
//empty value
|
|||
msgData.put("TestKey", ""); |
|||
thrown = assertThrows(RuntimeException.class, () -> TbMathArgumentValue.fromMessageBody(tbMathArgument, Optional.of(msgData))); |
|||
Assert.assertNotNull(thrown.getMessage()); |
|||
} |
|||
|
|||
@Test |
|||
public void test_fromMessageBody_then_valueCantConvert_to_double() { |
|||
TbMathArgument tbMathArgument = new TbMathArgument(TbMathArgumentType.MESSAGE_BODY, "TestKey"); |
|||
ObjectNode msgData = JacksonUtil.newObjectNode(); |
|||
msgData.put("TestKey", "Test"); |
|||
|
|||
//string value
|
|||
Throwable thrown = assertThrows(RuntimeException.class, () -> TbMathArgumentValue.fromMessageBody(tbMathArgument, Optional.of(msgData))); |
|||
Assert.assertNotNull(thrown.getMessage()); |
|||
|
|||
//object value
|
|||
msgData.set("TestKey", JacksonUtil.newObjectNode()); |
|||
thrown = assertThrows(RuntimeException.class, () -> TbMathArgumentValue.fromMessageBody(tbMathArgument, Optional.of(msgData))); |
|||
Assert.assertNotNull(thrown.getMessage()); |
|||
} |
|||
|
|||
@Test |
|||
public void test_fromMessageMetadata_then_noKey() { |
|||
TbMathArgument tbMathArgument = new TbMathArgument(TbMathArgumentType.MESSAGE_BODY, "TestKey"); |
|||
Throwable thrown = assertThrows(RuntimeException.class, () -> TbMathArgumentValue.fromMessageMetadata(tbMathArgument, new TbMsgMetaData())); |
|||
Assert.assertNotNull(thrown.getMessage()); |
|||
} |
|||
|
|||
@Test |
|||
public void test_fromMessageMetadata_then_valueEmpty() { |
|||
TbMathArgument tbMathArgument = new TbMathArgument(TbMathArgumentType.MESSAGE_BODY, "TestKey"); |
|||
Throwable thrown = assertThrows(RuntimeException.class, () -> TbMathArgumentValue.fromMessageMetadata(tbMathArgument, null)); |
|||
Assert.assertNotNull(thrown.getMessage()); |
|||
} |
|||
|
|||
@Test |
|||
public void test_fromString_thenOK() { |
|||
var value = "5.0"; |
|||
TbMathArgumentValue result = TbMathArgumentValue.fromString(value); |
|||
Assert.assertNotNull(result); |
|||
Assert.assertEquals(5.0, result.getValue(), 0d); |
|||
} |
|||
|
|||
@Test |
|||
public void test_fromString_then_failure() { |
|||
var value = "Test"; |
|||
Throwable thrown = assertThrows(RuntimeException.class, () -> TbMathArgumentValue.fromString(value)); |
|||
Assert.assertNotNull(thrown.getMessage()); |
|||
} |
|||
} |
|||
@ -0,0 +1,65 @@ |
|||
#### Clustering marker function |
|||
|
|||
<div class="divider"></div> |
|||
<br/> |
|||
|
|||
*function (data, childCount): string* |
|||
|
|||
A JavaScript function used to compute clustering marker color. |
|||
|
|||
**Parameters:** |
|||
|
|||
<ul> |
|||
<li><b>data:</b> <code><a href="https://github.com/thingsboard/thingsboard/blob/5bb6403407aa4898084832d6698aa9ea6d484889/ui-ngx/src/app/modules/home/components/widget/lib/maps/map-models.ts#L108" target="_blank">FormattedData[]</a></code> |
|||
- the array of total markers contained within each cluster.<br/> |
|||
Represents basic entity properties (ex. <code>entityId</code>, <code>entityName</code>)<br/>and provides access to other entity attributes/timeseries declared in widget datasource configuration. |
|||
</li> |
|||
<li><b>childCount:</b> <code>number</code> - the total number of markers contained within that cluster |
|||
</li> |
|||
</ul> |
|||
|
|||
**Returns:** |
|||
|
|||
Should return string value presenting color of the marker. |
|||
|
|||
In case no data is returned, color value from **Color** settings field will be used. |
|||
|
|||
<div class="divider"></div> |
|||
|
|||
##### Examples |
|||
|
|||
<ul> |
|||
<li> |
|||
Calculate color depending on temperature telemetry value: |
|||
</li> |
|||
|
|||
|
|||
```javascript |
|||
let customColor; |
|||
for (let markerData of data) { |
|||
if (markerData.temperature > 40) { |
|||
customColor = 'red' |
|||
} |
|||
} |
|||
return customColor ? customColor : 'green'; |
|||
{:copy-code} |
|||
``` |
|||
|
|||
<li> |
|||
Calculate color depending on childCount: |
|||
</li> |
|||
|
|||
```javascript |
|||
if (childCount < 10) { |
|||
return 'green'; |
|||
} else if (childCount < 100) { |
|||
return 'yellow'; |
|||
} else { |
|||
return 'red'; |
|||
} |
|||
{:copy-code} |
|||
``` |
|||
|
|||
</ul> |
|||
<br> |
|||
<br> |
|||
@ -0,0 +1,24 @@ |
|||
///
|
|||
/// Copyright © 2016-2022 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.
|
|||
///
|
|||
|
|||
import { FormattedData } from '@shared/models/widget.models'; |
|||
|
|||
// redeclare module, maintains compatibility with @types/leaflet
|
|||
declare module 'leaflet' { |
|||
interface MarkerOptions { |
|||
tbMarkerData?: FormattedData; |
|||
} |
|||
} |
|||
Loading…
Reference in new issue