Commit Graph

345 Commits

Author SHA1 Message Date
Sviatoslav Boichuk
f90d4fb03f Handle Topomap Generate Timeout 2025-03-17 18:52:34 +02:00
Olexandr, Mazur
2103ac187e Merge pull request #137 from Telecominfraproject/dev-cgw-parser-fixes
Dev cgw parser fixes
2025-03-12 07:38:56 +02:00
Sviatoslav Boichuk
9dc4239795 Change sender_id type for ConsumerMetadata field to string 2025-03-11 17:43:01 +02:00
Sviatoslav Boichuk
a823f85cb0 Added new NB API to report NB once CGW failed to parse NB request 2025-03-11 17:42:36 +02:00
Sviatoslav Boichuk
944693e08b Send Reply as RealState event, no matter if result type is pending or done 2025-03-11 14:44:25 +02:00
Olexandr, Mazur
3e52339787 Merge pull request #136 from Telecominfraproject/dev-update-ap-pasers
Dev update ap pasers
2025-03-10 11:11:10 +02:00
Sviatoslav Boichuk
1302f3c165 Do not flush device ram cache on sync with redis 2025-03-07 18:51:41 +02:00
Sviatoslav Boichuk
1482977a74 Handle Generic Events 2025-03-07 17:28:19 +02:00
Sviatoslav Boichuk
f657856e4a Enhance Result Reply event parser 2025-03-07 17:28:19 +02:00
Sviatoslav Boichuk
1f0ffabc45 Save origin connect message inside connection processor. Use connect message on gid change event (CGW send [un]assigned infra join/leave) 2025-03-07 17:28:19 +02:00
Sviatoslav Boichuk
47a5052108 Envelop original infra response message into infra_request_result 2025-03-07 17:28:04 +02:00
Sviatoslav Boichuk
e093028199 Parse Generic events 2025-03-07 16:45:52 +02:00
Sviatoslav Boichuk
2b0ab34427 Search 'id' filed in result message root/result/result:state scope 2025-03-07 16:29:00 +02:00
Sviatoslav Boichuk
8e6151f554 Drop CONFIG infra request messages for those infrastructure devices that hasn't beed connected to CGW. 2025-03-06 19:19:42 +02:00
Sviatoslav Boichuk
e6fdce82b0 Merge pull request #128 from Telecominfraproject/api_revamp
API: add optional / mandatory fields specificators
2025-03-04 13:15:48 +02:00
Oleksandr Mazur
cbc1ca38f8 API revamp: add optional / mandatory fields specificators, fix description(s)
* Update API to fix some spelling issues;
* Add specificators that specify the mandatoriness of fields in API;
* Add a simple table that maps req->kaka_topic;

Signed-off-by: Oleksandr Mazur <oleksandr.mazur@plvision.eu>
2025-03-03 18:53:41 +02:00
Olexandr, Mazur
8c0d34d449 Merge pull request #131 from Telecominfraproject/dev-ref-topomap
[TopoMap] Refactoring: use proper structs instead of multiple tuplse
2025-03-03 18:05:03 +02:00
Olexandr, Mazur
f9df3de4e7 Merge pull request #130 from Telecominfraproject/dev-fix-multi-cgw-run
Fixed Multi CGW run on clean environment
2025-02-28 18:48:48 +02:00
Olexandr, Mazur
18213f68e3 Merge pull request #129 from ailchuk/ailchuk/dev-refactor-handlers
refactor: unify response handling in infra handlers
2025-02-28 18:48:03 +02:00
Sviatoslav Boichuk
ec8d8d56be [TopoMap] Refactoring: use proper structs instead of multiple tuplse 2025-02-28 18:13:17 +02:00
Sviatoslav Boichuk
82b68b8686 Fixed Multi CGW run on clean environment 2025-02-27 17:53:43 +02:00
ailchuk
ad56814d71 standardize variable names from mac to infra
Signed-off-by: ailchuk <an.ilchuk27@gmail.com>
2025-02-27 17:39:05 +02:00
ailchuk
7e70d0e89b refactor: unify response handling in infra handlers
Signed-off-by: ailchuk <an.ilchuk27@gmail.com>
2025-02-27 15:43:39 +02:00
Olexandr, Mazur
b741e9dd39 Merge pull request #127 from Telecominfraproject/dev-nb-api-16digits-ts
Added 16 digits timestamp to NB APIs
2025-02-27 12:40:58 +02:00
Sviatoslav Boichuk
07ed817577 Added 16 digits timestamp to NB APIs 2025-02-26 15:12:41 +02:00
Olexandr, Mazur
04dc0773b6 Merge pull request #126 from Telecominfraproject/dev-consumer-metadata
Added consumer metadata to cnc/cnc_res messages
2025-02-25 18:27:40 +02:00
Olexandr, Mazur
a64aaaa432 Merge pull request #125 from Telecominfraproject/dev-enh-kafka-certs
Use system default certs if CGW_KAFKA_CERT is not specified
2025-02-25 18:27:28 +02:00
Sviatoslav Boichuk
f10e5622ee Added consumer metadata to cnc/cnc_res messages 2025-02-21 20:04:57 +02:00
Olexandr, Mazur
d59fe9c8ac Merge pull request #124 from Telecominfraproject/dev-enh-cloud-header
Add cloud header to: InfraJoin, InfraLeave, ForeignInfra, Capabilitie…
2025-02-21 13:28:48 +02:00
Sviatoslav Boichuk
14950847b8 Use system default certs if CGW_KAFKA_CERT is not specified 2025-02-19 18:45:45 +02:00
Sviatoslav Boichuk
a4506fe5c1 Add cloud header to: InfraJoin, InfraLeave, ForeignInfra, CapabilitiesChange, AP Join/Leave/Migrate events 2025-02-19 15:41:58 +02:00
Olexandr, Mazur
d5e7540e98 Merge pull request #123 from Telecominfraproject/dev-enh-infra-nb-api
Dev enh infra nb api
2025-02-18 17:21:55 +02:00
Sviatoslav Boichuk
5fb6dea276 Validate infra gid for infra request (config, reboot etc...) 2025-02-17 09:33:07 +02:00
Sviatoslav Boichuk
64868ecb73 Fix clippy issues 2025-02-17 09:17:55 +02:00
Sviatoslav Boichuk
910e513e7d Do not use capital letter in Kafka topocs name 2025-02-17 09:17:55 +02:00
Sviatoslav Boichuk
a058c572ad Fix spell issues. Update infra events tests 2025-02-17 09:17:55 +02:00
Sviatoslav Boichuk
50c26a3139 Do not send unassigned infras state/realtime events to NB! 2025-02-17 09:17:55 +02:00
Sviatoslav Boichuk
81811361b2 Merge pull request #119 from Telecominfraproject/feat/server_nbapi_msg_refactoring
Feat/server nbapi msg refactoring
2025-02-10 18:51:54 +02:00
Oleksandr Mazur
a0d651ae1b CGW: Connection server: Refactoring: move NB message parsing to separate functions
Changes also require some fields to be <somewhat> globally accessible
(at least from the Server's perspective):
+    pub infras_capacity: i32,
Capacity needs to be set upon start / shared across interested modules
or components of the Server itself;

+    pub local_shard_partition_key: RwLock<Option<String>>,
Partition key is accessible from several places within
the server, hence has to be wrapped into a separate
mut wrap (rw lock)

+    pub last_update_timestamp: RwLock<i64>,
Redis last update timestamp is crucial in deciding
whether cache has to be synced back.
Accessed from several places, has to be wrapped into a lock
to provide access from functions within server.

Signed-off-by: Oleksandr Mazur <oleksandr.mazur@plvision.eu>
2025-02-10 18:13:25 +02:00
Oleksandr Mazur
c8c878adad README: fix invalid env var naming
Signed-off-by: Oleksandr Mazur <oleksandr.mazur@plvision.eu>
2025-02-10 17:27:18 +02:00
Olexandr, Mazur
0bd89d5b0f Merge pull request #122 from Telecominfraproject/dev-bugs-fix
Dev bugs fix
2025-02-07 10:59:02 +02:00
Sviatoslav Boichuk
823baa1b13 Send infra join when device become assigned, and unassigned infra join when device become unassigned 2025-02-07 10:43:17 +02:00
Sviatoslav Boichuk
91ea00b4ba Update Kafka topics creation 2025-02-07 10:38:45 +02:00
Olexandr, Mazur
5e71fb641d Merge pull request #120 from Telecominfraproject/dev-cloud-headers
Handle cloud headers
2025-02-07 10:33:17 +02:00
Sviatoslav Boichuk
4e82e27079 Impl TryFrom instead From to avoid panic if PSQL table are corrupted or malformed! 2025-02-05 15:35:56 +02:00
Sviatoslav Boichuk
e206ce4158 Update events APIs 2025-02-05 10:29:26 +02:00
Sviatoslav Boichuk
64f114e427 Update CnC & CnC_Res APIs 2025-02-05 10:07:50 +02:00
Sviatoslav Boichuk
53498f0cf8 Handle cloud headers 2025-02-04 13:37:01 +02:00
Olexandr, Mazur
0edd6bdadd Merge pull request #118 from Telecominfraproject/dev-nb-apis-update
Change NB API infra_group_id type from string to integer
2025-02-01 21:00:04 +02:00
Olexandr, Mazur
5da83345eb Merge pull request #116 from Telecominfraproject/dev-multi-kafka-topics
Send foreign connection to device with shard owner host and port
2025-01-27 17:28:23 +02:00