1 /*************************************************************************
3 * Copyright 2020 highstreet technologies GmbH and others
5 * Licensed under the Apache License, Version 2.0 (the "License");
6 * you may not use this file except in compliance with the License.
7 * You may obtain a copy of the License at
9 * http://www.apache.org/licenses/LICENSE-2.0
11 * Unless required by applicable law or agreed to in writing, software
12 * distributed under the License is distributed on an "AS IS" BASIS,
13 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14 * See the License for the specific language governing permissions and
15 * limitations under the License.
16 ***************************************************************************/
20 #include "nts_utils.h"
21 #include "utils/log_utils.h"
22 #include "utils/sys_utils.h"
23 #include "core/framework.h"
24 #include "core/session.h"
25 #include "core/xpath.h"
31 cJSON* ves_create_common_event_header(const char *domain, const char *event_type, const char *hostname, int port, const char *priority, int seq_id) {
38 long useconds = get_microseconds_since_epoch();
40 asprintf(&eventId, "%s-%d", event_type, seq_id);
42 log_error("asprintf failed\n");
46 cJSON *common_event_header = cJSON_CreateObject();
47 if(common_event_header == 0) {
48 log_error("could not create JSON object\n");
53 if(cJSON_AddStringToObject(common_event_header, "domain", domain) == 0) {
54 log_error("cJSON AddStringToObject error\n");
56 cJSON_Delete(common_event_header);
60 if(cJSON_AddStringToObject(common_event_header, "eventId", eventId) == 0) {
61 log_error("cJSON AddStringToObject error\n");
63 cJSON_Delete(common_event_header);
69 if(cJSON_AddStringToObject(common_event_header, "eventName", event_type) == 0) {
70 log_error("cJSON AddStringToObject error\n");
71 cJSON_Delete(common_event_header);
75 if(cJSON_AddNumberToObject(common_event_header, "sequence", (double)(seq_id)) == 0) {
76 log_error("cJSON AddNumberToObject error\n");
77 cJSON_Delete(common_event_header);
81 if(cJSON_AddStringToObject(common_event_header, "priority", priority) == 0) {
82 log_error("cJSON AddStringToObject error\n");
83 cJSON_Delete(common_event_header);
87 if(cJSON_AddStringToObject(common_event_header, "reportingEntityId", "") == 0) {
88 log_error("cJSON AddStringToObject error\n");
89 cJSON_Delete(common_event_header);
93 char source_name[512];
95 sprintf(source_name, "%s-%d", hostname, port);
98 sprintf(source_name, "%s", hostname);
101 if(cJSON_AddStringToObject(common_event_header, "reportingEntityName", source_name) == 0) {
102 log_error("cJSON AddStringToObject error\n");
103 cJSON_Delete(common_event_header);
107 if(cJSON_AddStringToObject(common_event_header, "sourceId", "") == 0) {
108 log_error("cJSON AddStringToObject error\n");
109 cJSON_Delete(common_event_header);
113 if(cJSON_AddStringToObject(common_event_header, "sourceName", source_name) == 0) {
114 log_error("cJSON AddStringToObject error\n");
115 cJSON_Delete(common_event_header);
119 if(cJSON_AddNumberToObject(common_event_header, "startEpochMicrosec", (double)(useconds)) == 0) {
120 log_error("cJSON AddNumberToObject error\n");
121 cJSON_Delete(common_event_header);
125 if(cJSON_AddNumberToObject(common_event_header, "lastEpochMicrosec", (double)(useconds)) == 0) {
126 log_error("cJSON AddNumberToObject error\n");
127 cJSON_Delete(common_event_header);
131 if(cJSON_AddStringToObject(common_event_header, "nfNamingCode", "sdn controller") == 0) {
132 log_error("cJSON AddStringToObject error\n");
133 cJSON_Delete(common_event_header);
137 if(cJSON_AddStringToObject(common_event_header, "nfVendorName", "sdn") == 0) {
138 log_error("cJSON AddStringToObject error\n");
139 cJSON_Delete(common_event_header);
143 if(cJSON_AddStringToObject(common_event_header, "timeZoneOffset", "+00:00") == 0) {
144 log_error("cJSON AddStringToObject error\n");
145 cJSON_Delete(common_event_header);
149 if(cJSON_AddStringToObject(common_event_header, "version", "4.1") == 0) {
150 log_error("cJSON AddStringToObject error\n");
151 cJSON_Delete(common_event_header);
155 if(cJSON_AddStringToObject(common_event_header, "vesEventListenerVersion", framework_environment.ves_endpoint.common_header_version) == 0) {
156 log_error("cJSON AddStringToObject error\n");
157 cJSON_Delete(common_event_header);
161 return common_event_header;
164 nts_mount_point_addressing_method_t nts_mount_point_addressing_method_get(sr_session_ctx_t *current_session) {
167 nts_mount_point_addressing_method_t ret = UNKNOWN_MAPPING;
170 bool session_started = false;
171 if(current_session == 0) {
172 rc = sr_session_start(session_connection, SR_DS_RUNNING, ¤t_session);
173 if(rc != SR_ERR_OK) {
174 log_error("could not start sysrepo session\n");
177 session_started = true;
181 rc = sr_get_item(current_session, NTS_NF_NETWORK_FUNCTION_MPAM_SCHEMA_XPATH, 0, &value);
182 if(rc == SR_ERR_OK) {
183 if(strcmp(value->data.enum_val, "host-mapping") == 0) {
187 ret = DOCKER_MAPPING;
192 if(session_started) {
193 rc = sr_session_stop(current_session);
194 if(rc != SR_ERR_OK) {
195 log_error("could not stop sysrepo session\n");
203 // checkAS authentication via certificate not supported yet
204 ves_details_t *ves_endpoint_details_get(sr_session_ctx_t *current_session) {
208 bool session_started = false;
209 if(current_session == 0) {
210 rc = sr_session_start(session_connection, SR_DS_RUNNING, ¤t_session);
211 if(rc != SR_ERR_OK) {
212 log_error("could not start sysrepo session\n");
215 session_started = true;
218 struct lyd_node *data = 0;
221 if(framework_arguments.nts_mode == NTS_MODE_MANAGER) {
222 xpath_to_get = NTS_MANAGER_VES_ENDPOINT_CONFIG_XPATH;
225 xpath_to_get = NTS_NF_VES_ENDPOINT_CONFIG_XPATH;
228 rc = sr_get_subtree(current_session, xpath_to_get, 0, &data);
229 if(rc != SR_ERR_OK) {
230 log_error("could not get value for xPath=%s from the running datastore\n", xpath_to_get);
231 if(session_started) {
232 sr_session_stop(current_session);
237 if(session_started) {
238 rc = sr_session_stop(current_session);
239 if(rc != SR_ERR_OK) {
240 log_error("could not stop sysrepo session\n");
246 if(data->child == 0) {
247 log_error("ves-endpoint probably not set yet\n", xpath_to_get);
252 ves_details_t *ret = (ves_details_t *)malloc(sizeof(ves_details_t));
254 log_error("malloc failed\n");
262 ret->auth_method = 0;
266 struct lyd_node *chd = 0;
267 LY_TREE_FOR(data->child, chd) {
268 const char *val = ((const struct lyd_node_leaf_list *)chd)->value_str;
270 if(strcmp(chd->schema->name, "ves-endpoint-protocol") == 0) {
271 ret->protocol = strdup(val);
273 else if(strcmp(chd->schema->name, "ves-endpoint-ip") == 0) {
274 ret->ip = strdup(val);
276 else if(strcmp(chd->schema->name, "ves-endpoint-port") == 0) {
277 ret->port = ((const struct lyd_node_leaf_list *)chd)->value.uint16;
279 else if(strcmp(chd->schema->name, "ves-endpoint-auth-method") == 0) {
280 ret->auth_method = strdup(val);
282 else if(strcmp(chd->schema->name, "ves-endpoint-username") == 0) {
283 ret->username = strdup(val);
285 else if(strcmp(chd->schema->name, "ves-endpoint-password") == 0) {
286 ret->password = strdup(val);
291 if (strstr(ret->ip, ":")) {
293 asprintf(&ret->url, "%s://[%s]:%d/eventListener/v7", ret->protocol, ret->ip, ret->port);
296 asprintf(&ret->url, "%s://%s:%d/eventListener/v7", ret->protocol, ret->ip, ret->port);
299 if((ret->protocol == 0) || (ret->ip == 0) || (ret->auth_method == 0) || (ret->username == 0) || (ret->password == 0) || (ret->url == 0)) {
302 free(ret->auth_method);
313 void ves_details_free(ves_details_t *instance) {
316 free(instance->protocol);
319 free(instance->auth_method);
320 free(instance->username);
321 free(instance->password);
326 // checkAS authentication via certificate not supported yet
327 controller_details_t *controller_details_get(sr_session_ctx_t *current_session) {
331 bool session_started = false;
332 if(current_session == 0) {
333 rc = sr_session_start(session_connection, SR_DS_RUNNING, ¤t_session);
334 if(rc != SR_ERR_OK) {
335 log_error("could not start sysrepo session\n");
338 session_started = true;
341 struct lyd_node *data = 0;
344 if(framework_arguments.nts_mode == NTS_MODE_MANAGER) {
345 xpath_to_get = NTS_MANAGER_SDN_CONTROLLER_CONFIG_XPATH;
348 xpath_to_get = NTS_NF_SDN_CONTROLLER_CONFIG_XPATH;
351 rc = sr_get_subtree(current_session, xpath_to_get, 0, &data);
352 if(rc != SR_ERR_OK) {
353 log_error("could not get value for xPath=%s from the running datastore\n", xpath_to_get);
354 if(session_started) {
355 sr_session_stop(current_session);
360 if(session_started) {
361 rc = sr_session_stop(current_session);
362 if(rc != SR_ERR_OK) {
363 log_error("could not stop sysrepo session\n");
369 if(data->child == 0) {
370 log_error("sdn-controller probably not set yet\n");
375 controller_details_t *ret = (controller_details_t *)malloc(sizeof(controller_details_t));
377 log_error("malloc failed\n");
385 ret->nc_callhome_port = 0;
386 ret->auth_method = 0;
390 ret->auth_method = strdup("basic");
392 struct lyd_node *chd = 0;
393 LY_TREE_FOR(data->child, chd) {
394 const char *val = ((const struct lyd_node_leaf_list *)chd)->value_str;
396 if(strcmp(chd->schema->name, "controller-protocol") == 0) {
397 ret->protocol = strdup(val);
399 else if(strcmp(chd->schema->name, "controller-ip") == 0) {
400 ret->ip = strdup(val);
402 else if(strcmp(chd->schema->name, "controller-port") == 0) {
403 ret->port = ((const struct lyd_node_leaf_list *)chd)->value.uint16;
405 else if(strcmp(chd->schema->name, "controller-netconf-call-home-port") == 0) {
406 ret->nc_callhome_port = ((const struct lyd_node_leaf_list *)chd)->value.uint16;
408 else if(strcmp(chd->schema->name, "controller-username") == 0) {
409 ret->username = strdup(val);
411 else if(strcmp(chd->schema->name, "controller-password") == 0) {
412 ret->password = strdup(val);
417 if (strstr(ret->ip, ":")) {
419 asprintf(&ret->base_url, "%s://[%s]:%d", ret->protocol, ret->ip, ret->port);
422 asprintf(&ret->base_url, "%s://%s:%d", ret->protocol, ret->ip, ret->port);
425 if((ret->protocol == 0) || (ret->ip == 0) || (ret->auth_method == 0) || (ret->username == 0) || (ret->password == 0) || (ret->base_url == 0)) {
428 free(ret->auth_method);
439 void controller_details_free(controller_details_t *instance) {
442 free(instance->protocol);
444 free(instance->base_url);
445 free(instance->auth_method);
446 free(instance->username);
447 free(instance->password);
451 int nts_vercmp(const char *ver1, const char *ver2) {
456 int v1 = 0, v2 = 0, v3 = 0;
457 while(ver1[i] && (ver1[i] != '.')) {
465 while(ver1[i] && (ver1[i] != '.')) {
473 while(ver1[i] && (ver1[i] != '.')) {
482 int V1 = 0, V2 = 0, V3 = 0;
484 while(ver2[i] && (ver2[i] != '.')) {
492 while(ver2[i] && (ver2[i] != '.')) {
500 while(ver2[i] && (ver2[i] != '.')) {
532 int nts_utils_populate_info(sr_session_ctx_t *current_session, const char *function_type) {
533 assert(current_session);
534 assert(function_type);
536 bool manager = (strcmp(function_type, "NTS_FUNCTION_TYPE_MANAGER") == 0);
540 //setup sdn-controller defaults
541 if(strlen(framework_environment.sdn_controller.protocol)) {
543 rc = sr_set_item_str(current_session, NTS_MANAGER_SDN_CONTROLLER_CONFIG_XPATH"/controller-protocol", (const char*)framework_environment.sdn_controller.protocol, 0, 0);
546 rc = sr_set_item_str(current_session, NTS_NF_SDN_CONTROLLER_CONFIG_XPATH"/controller-protocol", (const char*)framework_environment.sdn_controller.protocol, 0, 0);
548 if(rc != SR_ERR_OK) {
549 log_error("sr_set_item_str failed\n");
550 return NTS_ERR_FAILED;
554 if(strlen(framework_environment.sdn_controller.ip)) {
556 rc = sr_set_item_str(current_session, NTS_MANAGER_SDN_CONTROLLER_CONFIG_XPATH"/controller-ip", (const char*)framework_environment.sdn_controller.ip, 0, 0);
559 rc = sr_set_item_str(current_session, NTS_NF_SDN_CONTROLLER_CONFIG_XPATH"/controller-ip", (const char*)framework_environment.sdn_controller.ip, 0, 0);
561 if(rc != SR_ERR_OK) {
562 log_error("sr_set_item_str failed\n");
563 return NTS_ERR_FAILED;
567 sprintf(int_to_str, "%d", framework_environment.sdn_controller.port);
569 rc = sr_set_item_str(current_session, NTS_MANAGER_SDN_CONTROLLER_CONFIG_XPATH"/controller-port", (const char*)int_to_str, 0, 0);
572 rc = sr_set_item_str(current_session, NTS_NF_SDN_CONTROLLER_CONFIG_XPATH"/controller-port", (const char*)int_to_str, 0, 0);
574 if(rc != SR_ERR_OK) {
575 log_error("sr_set_item_str failed\n");
576 return NTS_ERR_FAILED;
579 sprintf(int_to_str, "%d", framework_environment.sdn_controller.callhome_port);
581 rc = sr_set_item_str(current_session, NTS_MANAGER_SDN_CONTROLLER_CONFIG_XPATH"/controller-netconf-call-home-port", (const char*)int_to_str, 0, 0);
584 rc = sr_set_item_str(current_session, NTS_NF_SDN_CONTROLLER_CONFIG_XPATH"/controller-netconf-call-home-port", (const char*)int_to_str, 0, 0);
586 if(rc != SR_ERR_OK) {
587 log_error("sr_set_item_str failed\n");
588 return NTS_ERR_FAILED;
591 if(strlen(framework_environment.sdn_controller.username)) {
593 rc = sr_set_item_str(current_session, NTS_MANAGER_SDN_CONTROLLER_CONFIG_XPATH"/controller-username", (const char*)framework_environment.sdn_controller.username, 0, 0);
596 rc = sr_set_item_str(current_session, NTS_NF_SDN_CONTROLLER_CONFIG_XPATH"/controller-username", (const char*)framework_environment.sdn_controller.username, 0, 0);
598 if(rc != SR_ERR_OK) {
599 log_error("sr_set_item_str failed\n");
600 return NTS_ERR_FAILED;
604 if(strlen(framework_environment.sdn_controller.password)) {
606 rc = sr_set_item_str(current_session, NTS_MANAGER_SDN_CONTROLLER_CONFIG_XPATH"/controller-password", (const char*)framework_environment.sdn_controller.password, 0, 0);
609 rc = sr_set_item_str(current_session, NTS_NF_SDN_CONTROLLER_CONFIG_XPATH"/controller-password", (const char*)framework_environment.sdn_controller.password, 0, 0);
611 if(rc != SR_ERR_OK) {
612 log_error("sr_set_item_str failed\n");
613 return NTS_ERR_FAILED;
617 //setup ves-endpoint details
618 if(strlen(framework_environment.ves_endpoint.protocol)) {
620 rc = sr_set_item_str(current_session, NTS_MANAGER_VES_ENDPOINT_CONFIG_XPATH"/ves-endpoint-protocol", (const char*)framework_environment.ves_endpoint.protocol, 0, 0);
623 rc = sr_set_item_str(current_session, NTS_NF_VES_ENDPOINT_CONFIG_XPATH"/ves-endpoint-protocol", (const char*)framework_environment.ves_endpoint.protocol, 0, 0);
625 if(rc != SR_ERR_OK) {
626 log_error("sr_set_item_str failed\n");
627 return NTS_ERR_FAILED;
631 if(strlen(framework_environment.ves_endpoint.ip)) {
633 rc = sr_set_item_str(current_session, NTS_MANAGER_VES_ENDPOINT_CONFIG_XPATH"/ves-endpoint-ip", (const char*)framework_environment.ves_endpoint.ip, 0, 0);
636 rc = sr_set_item_str(current_session, NTS_NF_VES_ENDPOINT_CONFIG_XPATH"/ves-endpoint-ip", (const char*)framework_environment.ves_endpoint.ip, 0, 0);
638 if(rc != SR_ERR_OK) {
639 log_error("sr_set_item_str failed\n");
640 return NTS_ERR_FAILED;
644 sprintf(int_to_str, "%d", framework_environment.ves_endpoint.port);
646 rc = sr_set_item_str(current_session, NTS_MANAGER_VES_ENDPOINT_CONFIG_XPATH"/ves-endpoint-port", (const char*)int_to_str, 0, 0);
649 rc = sr_set_item_str(current_session, NTS_NF_VES_ENDPOINT_CONFIG_XPATH"/ves-endpoint-port", (const char*)int_to_str, 0, 0);
651 if(rc != SR_ERR_OK) {
652 log_error("sr_set_item_str failed\n");
653 return NTS_ERR_FAILED;
656 if(strlen(framework_environment.ves_endpoint.auth_method)) {
658 rc = sr_set_item_str(current_session, NTS_MANAGER_VES_ENDPOINT_CONFIG_XPATH"/ves-endpoint-auth-method", (const char*)framework_environment.ves_endpoint.auth_method, 0, 0);
661 rc = sr_set_item_str(current_session, NTS_NF_VES_ENDPOINT_CONFIG_XPATH"/ves-endpoint-auth-method", (const char*)framework_environment.ves_endpoint.auth_method, 0, 0);
663 if(rc != SR_ERR_OK) {
664 log_error("sr_set_item_str failed\n");
665 return NTS_ERR_FAILED;
669 if(strlen(framework_environment.ves_endpoint.username)) {
671 rc = sr_set_item_str(current_session, NTS_MANAGER_VES_ENDPOINT_CONFIG_XPATH"/ves-endpoint-username", (const char*)framework_environment.ves_endpoint.username, 0, 0);
674 rc = sr_set_item_str(current_session, NTS_NF_VES_ENDPOINT_CONFIG_XPATH"/ves-endpoint-username", (const char*)framework_environment.ves_endpoint.username, 0, 0);
676 if(rc != SR_ERR_OK) {
677 log_error("sr_set_item_str failed\n");
678 return NTS_ERR_FAILED;
682 if(strlen(framework_environment.ves_endpoint.password)) {
684 rc = sr_set_item_str(current_session, NTS_MANAGER_VES_ENDPOINT_CONFIG_XPATH"/ves-endpoint-password", (const char*)framework_environment.ves_endpoint.password, 0, 0);
687 rc = sr_set_item_str(current_session, NTS_NF_VES_ENDPOINT_CONFIG_XPATH"/ves-endpoint-password", (const char*)framework_environment.ves_endpoint.password, 0, 0);
689 if(rc != SR_ERR_OK) {
690 log_error("sr_set_item_str failed\n");
691 return NTS_ERR_FAILED;
695 if(strlen(framework_environment.ves_endpoint.certificate)) {
697 rc = sr_set_item_str(current_session, NTS_MANAGER_VES_ENDPOINT_CONFIG_XPATH"/ves-endpoint-certificate", (const char*)framework_environment.ves_endpoint.certificate, 0, 0);
700 rc = sr_set_item_str(current_session, NTS_NF_VES_ENDPOINT_CONFIG_XPATH"/ves-endpoint-certificate", (const char*)framework_environment.ves_endpoint.certificate, 0, 0);
702 if(rc != SR_ERR_OK) {
703 log_error("sr_set_item_str failed\n");
704 return NTS_ERR_FAILED;
708 if(manager == false) {
709 //presence containers
710 rc = sr_set_item_str(current_session, NTS_NF_FAULT_GENERATION_SCHEMA_XPATH, 0, 0, 0);
711 if(rc != SR_ERR_OK) {
712 log_error("sr_set_item_str failed\n");
713 return NTS_ERR_FAILED;
716 rc = sr_set_item_str(current_session, NTS_NF_NETCONF_SCHEMA_XPATH, 0, 0, 0);
717 if(rc != SR_ERR_OK) {
718 log_error("sr_set_item_str failed\n");
719 return NTS_ERR_FAILED;
722 rc = sr_set_item_str(current_session, NTS_NF_VES_SCHEMA_XPATH, 0, 0, 0);
723 if(rc != SR_ERR_OK) {
724 log_error("sr_set_item_str failed\n");
725 return NTS_ERR_FAILED;
729 //also set the network-function module for easy identifying the function type
730 rc = sr_set_item_str(current_session, NTS_NF_NETWORK_FUNCTION_FTYPE_SCHEMA_XPATH, function_type, 0, 0);
731 if(rc != SR_ERR_OK) {
732 log_error("sr_set_item_str failed\n");
733 return NTS_ERR_FAILED;
736 //mount-point-addressing-method
737 rc = sr_set_item_str(current_session, NTS_NF_NETWORK_FUNCTION_MPAM_SCHEMA_XPATH, framework_environment.nts.nf_mount_point_addressing_method, 0, 0);
738 if(rc != SR_ERR_OK) {
739 log_error("sr_set_item_str failed\n");
740 return NTS_ERR_FAILED;
744 rc = sr_apply_changes(current_session, 0, 0);
745 if(rc != SR_ERR_OK) {
746 log_error("sr_apply_changes failed: %s\n", sr_strerror(rc));
747 return NTS_ERR_FAILED;