2676 Commits

Author SHA1 Message Date
Vladyslav_Prykhodko
6e7869ffbe Merge remote-tracking branch 'upstream/develop/3.5.2' into feature/timeseries-api-improvements 2023-08-09 18:03:48 +03:00
Andrew Shvayka
0c98b70216
Merge pull request #9052 from AndriiLandiak/feature/edge-crud-pubsub
Edge - Introduce Event Pub/Sub Model for Detecting Changes in Entities
2023-08-08 18:41:23 +03:00
YevhenBondarenko
2427539f22 merge with develop/3.5.2 2023-08-08 01:46:52 +02:00
Andrii Landiak
8faa1410b6
Edge crud notification: implement event publisher strategy to process pubsub model for detecting changes in entities
* Improve edge notification for entities' CRUD operations. Use service layer to notify instead of TbService

* Improve queue service, delete unused class for edge event updates

* Improve alarm delete and add handle fox delete dao event notification

* Refactoring: provide notification for relations and alarms. Improve logic and bad edge event type using

* Add entity type to SaveEvent to process correct message type to edge

* Improve relation service publish event

* Introduce EdgeEventSourcing service instead of saving edge events on controller/service layers. Part #2

* Improved stability of device edge test

* Push credential updated event only in case update

* Add tenantId to saveUser signature to send correct notification for listener

* Fix tests to send correct notification msg to edge

* Fix tests with correct action type

* Add delete msg to edge for customer

* Refactor ActionEntityEvent to use lombok builder

* Remove unnecessary comments

* Added edgeSynchronizationManager into BaseAlarmProcessor and BaseRelationProcessor

* Fixed license header

* Remove notification to edge from Version Control Service

* Fixed alarm del processing - find related edges inside edge processor

* Fix controller test for publish event to listener if entity was deleted

* Added check for edge imitator messages during login as tenant admin

* Refactoring: Added filtering of relation on EdgeEventSourcingListener

* Refactored to be in sync with PE

* Refactored edge test to be in sync with PE edge test changes

* EdgeControllerTest - moved await block into separate method to reuse it

* Fixed EdgeControllerTest

* Fixed testAssignEdgeToCustomerFromDifferentTenant test

* testSyncEdge - make stable

* Refacroting - update utils method name to pop* in EdgeControllerTest

* testSyncEdge - fixed order and nubmer of edge events

* testGetEdgeEvents - check by pop items, and not by index to improve stability on slow machines

* testGetEdgeEvents - added check that list is empty

* Removed test debug output

* EntityServiceTest - Fixed compilation error after merge

* Improve service layer event publisher to process each notification and validate in listener

* Improve BaseAlarmService to send notification to listener

* Fix asset-device notification action to send delete to all edges

* Delete unnecessary usage of sendMsgToEdge

* Improve processEntityNotification to be in sync with changed needed for PE

* Pull request review - minor refactoring

* Fix tests after review-refactoring

* Refactor tests to be in sync with PE

* Fixed repeated update - added check for old_edge_event table existance before migration

* DeviceEdgeProcessor - do edgeSynchronizationManager as soon as possible to avoid unnecessary downlinks

* BaseEdgeProcessor - refactoring and remove duplicate methods. Introduce EdgeEventType.isAllEdgesRelated

* Organize imports

* Improve Edge test: add sync completed message to await

* Minor refactoring for EdgeProcessor notification: asset and device

* EdgeEventSourcingListener - updated logging to avoid null pointer exception

* BaseAlarmService - added check for alarm to avoid NPE. EdgeEventSourcingListener - added try/catch blocks

* EdgeEventSourcingListener - fixed error message log level

---------

Co-authored-by: Volodymyr Babak <volodymyr.babak@gmail.com>
2023-08-07 13:21:02 +03:00
dashevchenko
6bc9148f77 added optional nosxss validation for attribute/telemetry value 2023-08-07 11:20:53 +03:00
Andrew Shvayka
173e229da1
Merge pull request #8786 from ShvaykaD/feature/filter-nodes-improvements
Filter nodes improvements && fixes for enrichment rule nodes && added TbMsgType enum and enforced use of it in corresponding places.
2023-08-04 13:57:10 +03:00
nick
eaf8ef0f14 fix_bug: default VARCHAR length for notification_request.info = 1M (old value = 1K) 2023-08-03 12:36:15 +03:00
Andrew Shvayka
581c02bf6b
Merge pull request #8938 from thingsboard/feature/check-connectivity-device
Added check connectivity in device
2023-07-31 18:50:02 +03:00
Andrii Shvaika
75fd37428a Merge with master 2023-07-31 13:59:20 +03:00
Sergey Matvienko
9e92d10dc5 Cassandra: AbstractBufferedRateExecutor improved logging to clarify whether the Read or Write operations logged 2023-07-31 12:05:23 +02:00
Sergey Matvienko
161d7c3eda Cassandra: unlimited cached thread pool replaced with limited pool to prevent stack memory peaks. New env CASSANDRA_QUERY_RESULT_PROCESSING_THREADS introduced. 2023-07-31 11:59:31 +02:00
Vladyslav_Prykhodko
2d2117e9ac Merge remote-tracking branch 'upstream/develop/3.5.2' into feature/check-connectivity-device 2023-07-28 10:11:54 +03:00
YevhenBondarenko
329a24c019 added sparkplug 2023-07-26 11:05:50 +02:00
imbeacon
f9a621bcfb Merge remote-tracking branch 'upstream/develop/3.5.2' into fix/removing-relations 2023-07-26 11:18:38 +03:00
YevhenBondarenko
3c6c565732 added docker coap commands and refactoring 2023-07-26 10:06:38 +02:00
Vladyslav_Prykhodko
1dff25518f Merge remote-tracking branch 'upstream/develop/3.5.2' into feature/check-connectivity-device 2023-07-25 10:17:32 +03:00
Vladyslav_Prykhodko
6a3be7fbaa UI: fixed show commands in mqtt 2023-07-24 11:07:10 +03:00
dashevchenko
8b19b5d169 added curl command for mqtts 2023-07-21 18:56:52 +03:00
dashevchenko
2ad30336ea deleted valur for mqqtt docker command when creds are X509 2023-07-21 13:51:49 +03:00
dashevchenko
d99c08fbbb changed response data structure 2023-07-21 12:52:15 +03:00
dashevchenko
fc499c74e3 deleted redundant imports 2023-07-20 17:22:33 +03:00
dashevchenko
e3ef58c603 added notnull check for http commands 2023-07-20 15:33:02 +03:00
dashevchenko
db46b7988d refactored code to take into account operating system 2023-07-20 12:33:15 +03:00
YevhenBondarenko
881861d80d deleted 'remove latest api' 2023-07-19 19:44:47 +02:00
Andrew Shvayka
15b192aad9
Merge pull request #8898 from dashevchenko/resourceDeleteValidation
Resource deletion validation
2023-07-18 16:26:09 +03:00
dashevchenko
295a145d2d fixed tests 2023-07-18 11:51:18 +03:00
dashevchenko
c3e775c353 added mqtt server chain certificate 2023-07-18 11:38:41 +03:00
YevhenBondarenko
f9aa9b6a92 added ability to rewrite latest 2023-07-14 14:43:32 +02:00
dashevchenko
d156d91ac9 make X509 certificate doc link be always available 2023-07-14 13:29:51 +03:00
dashevchenko
0d55ac9760 make X509 certificate doc link be always available 2023-07-14 13:24:02 +03:00
YevhenBondarenko
4b7cc4571d added deleteLatest api 2023-07-12 19:48:25 +02:00
dashevchenko
8f154e6f1c added test 2023-07-11 14:39:57 +03:00
dashevchenko
0da9affe18 fixed user phone display in entities table 2023-07-10 16:48:13 +03:00
dashevchenko
cce56b9547 added test 2023-07-10 13:28:38 +03:00
dashevchenko
9ddc5e5b8d added resource delete validation 2023-07-07 17:42:44 +03:00
dashevchenko
1a2214f7b2 merged with develop/3.5.2 2023-07-07 15:07:09 +03:00
dashevchenko
21329bf74e refactoring 2023-07-07 14:14:06 +03:00
dashevchenko
2eeb3a1639 refactoring 2023-07-07 10:59:52 +03:00
ShvaykaD
d9ede8bf50 merge with develop/3.5.2 2023-07-06 15:44:01 +03:00
dashevchenko
686f770b46 minor refactoring 2023-07-06 15:06:07 +03:00
dashevchenko
14216a4882 fixed security transport cases 2023-07-06 15:03:32 +03:00
YevhenBondarenko
3be53a3605 fixed saveDeviceWithCredentials api 2023-07-05 14:40:44 +02:00
dashevchenko
3baa12ce77 refactored config properties 2023-07-05 15:06:42 +03:00
dashevchenko
fee8aa359a refactoring 2023-07-04 18:18:23 +03:00
Andrew Shvayka
ab56f651c7
Merge pull request #8839 from dashevchenko/resourceInfoCache
Added cache for resource info
2023-06-30 16:00:08 +03:00
dashevchenko
f70fba33f0 added cache config properties 2023-06-28 14:50:17 +03:00
dashevchenko
e2ba34bbf3 refactoring 2023-06-28 13:48:46 +03:00
dashevchenko
eab633632a added cache for TBResourceInfo 2023-06-28 11:35:54 +03:00
Volodymyr Babak
4a0ff8b968
Edge event seq (#82)
* edge event - added seq id auto generated column to fix issue with concurrent write of multiple edge events with the same created time

* kotlin Pair replaced by springframework class

* Handle cases when seq_id column started new cycle

* Added check for null in case entity was deleted

* GeneralEdgeEventFetched - sort order by seqId and not created time

* Edge event table - added migration script to add seq_id column

* Code review updates to be in sync with PE

* Improved handling cases when edge_event.seqId started new cycle

* Edge event table - seq_id column make to be cycled

* Improved handling of cases when seq_id column of edge_event table started new cycle

* Improved stability by properly handling exceptions
2023-06-27 15:42:23 +03:00
dashevchenko
5acd5b3658 refactoring 2023-06-26 11:45:20 +03:00