/*

 * Licensed to Systerel under one or more contributor license

 * agreements. See the NOTICE file distributed with this work

 * for additional information regarding copyright ownership.

 * Systerel licenses this file to you 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.

 */

/******************************************************************************

 File Name            : subscription_mgr.c

 Date                 : 03/03/2026 16:24:20

 C Translator Version : tradc Java V1.2 (06/02/2022)

******************************************************************************/

/*------------------------

   Exported Declarations

  ------------------------*/

#include "subscription_mgr.h"

/*------------------------

   INITIALISATION Clause

  ------------------------*/

void subscription_mgr__INITIALISATION(void) {

}

/*--------------------

   OPERATIONS Clause

  --------------------*/

void subscription_mgr__fill_publish_response_msg(

   const constants__t_msg_i subscription_mgr__p_resp_msg,

   const constants__t_subscription_i subscription_mgr__p_subscription,

   const t_bool subscription_mgr__p_moreNotifs) {

   {

      constants__t_notifRepublishQueue_i subscription_mgr__l_republishQueue;

      t_entier4 subscription_mgr__l_nb_seq_nums;

      t_bool subscription_mgr__l_bres;

      subscription_core__get_subscription_notifRepublishQueue(subscription_mgr__p_subscription,

         &subscription_mgr__l_republishQueue);

      subscription_core__get_available_republish(subscription_mgr__l_republishQueue,

         &subscription_mgr__l_nb_seq_nums);

      if (subscription_mgr__l_nb_seq_nums > 0) {

         msg_subscription_publish_ack_bs__allocate_subscription_available_seq_nums(subscription_mgr__p_resp_msg,

            subscription_mgr__l_nb_seq_nums,

            &subscription_mgr__l_bres);

         if (subscription_mgr__l_bres == true) {

            subscription_mgr__fill_publish_response_msg_available_seq_nums(subscription_mgr__p_resp_msg,

               subscription_mgr__l_republishQueue,

               subscription_mgr__l_nb_seq_nums);

         }

      }

      subscription_core__set_msg_publish_resp_subscription(subscription_mgr__p_resp_msg,

         subscription_mgr__p_subscription);

      subscription_core__set_msg_publish_resp_notificationMsg(subscription_mgr__p_resp_msg,

         subscription_mgr__p_moreNotifs);

   }

}

void subscription_mgr__fill_publish_response_msg_ack_results(

   const constants__t_session_i subscription_mgr__p_session,

   const constants__t_msg_i subscription_mgr__p_req_msg,

   const constants__t_msg_i subscription_mgr__p_resp_msg,

   const t_entier4 subscription_mgr__p_nb_acks) {

   {

      t_bool subscription_mgr__l_is_valid;

      t_entier4 subscription_mgr__l_index;

      constants__t_subscription_i subscription_mgr__l_sub;

      constants__t_sub_seq_num_i subscription_mgr__l_seq_num;

      t_bool subscription_mgr__l_valid_seq_num;

      subscription_mgr__l_index = 1;

      while (subscription_mgr__l_index <= subscription_mgr__p_nb_acks) {

         msg_subscription_publish_ack_bs__getall_msg_publish_request_ack(subscription_mgr__p_req_msg,

            subscription_mgr__l_index,

            &subscription_mgr__l_sub,

            &subscription_mgr__l_seq_num);

         subscription_core__is_valid_subscription_on_session(subscription_mgr__p_session,

            subscription_mgr__l_sub,

            &subscription_mgr__l_is_valid);

         if (subscription_mgr__l_is_valid == true) {

            subscription_core__subscription_ack_notif_msg(subscription_mgr__l_sub,

               subscription_mgr__l_seq_num,

               &subscription_mgr__l_valid_seq_num);

            if (subscription_mgr__l_valid_seq_num == true) {

               msg_subscription_publish_ack_bs__setall_msg_publish_resp_ack_result(subscription_mgr__p_resp_msg,

                  subscription_mgr__l_index,

                  constants_statuscodes_bs__e_sc_ok);

            }

            else {

               msg_subscription_publish_ack_bs__setall_msg_publish_resp_ack_result(subscription_mgr__p_resp_msg,

                  subscription_mgr__l_index,

                  constants_statuscodes_bs__e_sc_bad_sequence_number_unknown);

            }

         }

         else {

            msg_subscription_publish_ack_bs__setall_msg_publish_resp_ack_result(subscription_mgr__p_resp_msg,

               subscription_mgr__l_index,

               constants_statuscodes_bs__e_sc_bad_subscription_id_invalid);

         }

         subscription_mgr__l_index = subscription_mgr__l_index +

            1;

      }

   }

}

void subscription_mgr__fill_publish_response_msg_available_seq_nums(

   const constants__t_msg_i subscription_mgr__p_resp_msg,

   const constants__t_notifRepublishQueue_i subscription_mgr__republishQueue,

   const t_entier4 subscription_mgr__nb_seq_nums) {

   {

      t_bool subscription_mgr__l_continue;

      constants__t_notifRepublishQueueIterator_i subscription_mgr__l_republishIterator;

      t_entier4 subscription_mgr__l_index;

      constants__t_sub_seq_num_i subscription_mgr__l_seq_num;

      subscription_mgr__l_index = 1;

      subscription_core__init_iter_notif_republish(subscription_mgr__republishQueue,

         &subscription_mgr__l_continue,

         &subscription_mgr__l_republishIterator);

      while ((subscription_mgr__l_continue == true) &&

         (subscription_mgr__l_index <= subscription_mgr__nb_seq_nums)) {

         subscription_core__continue_iter_notif_republish(subscription_mgr__republishQueue,

            subscription_mgr__l_republishIterator,

            &subscription_mgr__l_continue,

            &subscription_mgr__l_seq_num);

         msg_subscription_publish_ack_bs__setall_msg_publish_resp_available_seq_num(subscription_mgr__p_resp_msg,

            subscription_mgr__l_index,

            subscription_mgr__l_seq_num);

         subscription_mgr__l_index = subscription_mgr__l_index +

            1;

      }

      subscription_core__clear_notif_republish_iterator(subscription_mgr__republishQueue,

         subscription_mgr__l_republishIterator);

   }

}

void subscription_mgr__local_treat_create_monitored_item_index(

   const constants__t_session_i subscription_mgr__p_session,

   const constants__t_subscription_i subscription_mgr__p_subscription,

   const constants__t_TimestampsToReturn_i subscription_mgr__p_tsToReturn,

   const constants__t_user_i subscription_mgr__p_user,

   const constants__t_LocaleIds_i subscription_mgr__p_locales,

   const constants__t_msg_i subscription_mgr__p_req_msg,

   const constants__t_msg_i subscription_mgr__p_resp_msg,

   const t_entier4 subscription_mgr__p_index) {

   {

      t_bool subscription_mgr__l_bres;

      constants__t_NodeId_i subscription_mgr__l_nid;

      constants__t_AttributeId_i subscription_mgr__l_aid;

      constants__t_monitoringMode_i subscription_mgr__l_monitMode;

      constants__t_client_handle_i subscription_mgr__l_clientHandle;

      constants__t_opcua_duration_i subscription_mgr__l_samplingItv;

      constants__t_monitoringFilter_i subscription_mgr__l_filter;

      t_bool subscription_mgr__l_discardOldest;

      t_entier4 subscription_mgr__l_queueSize;

      constants_statuscodes_bs__t_StatusCode_i subscription_mgr__l_sc;

      constants__t_monitoredItemId_i subscription_mgr__l_monitoredItemId;

      constants__t_opcua_duration_i subscription_mgr__l_revSamplingItv;

      t_entier4 subscription_mgr__l_revQueueSize;

      constants__t_IndexRange_i subscription_mgr__l_indexRange;

      constants__t_endpoint_config_idx_i subscription_mgr__l_endpoint_config_idx;

      t_bool subscription_mgr__l_bres_presentNode;

      constants__t_Node_i subscription_mgr__l_node;

      t_bool subscription_mgr__l_bres_absent_knownNode;

      constants__t_NodeClass_i subscription_mgr__l_knownNodeClass;

      constants__t_Variant_i subscription_mgr__l_value;

      constants__t_RawStatusCode subscription_mgr__l_valueSc;

      constants__t_Timestamp subscription_mgr__l_val_ts_src;

      constants__t_Timestamp subscription_mgr__l_val_ts_srv;

      constants__t_monitoredItemPointer_i subscription_mgr__l_monitoredItemPointer;

      constants__t_filterResult_i subscription_mgr__l_filterResult;

      subscription_mgr__l_monitoredItemId = constants__c_monitoredItemId_indet;

      subscription_mgr__l_revSamplingItv = constants__c_opcua_duration_indet;

      subscription_mgr__l_revQueueSize = 0;

      subscription_mgr__l_node = constants__c_Node_indet;

      subscription_mgr__l_value = constants__c_Variant_indet;

      subscription_mgr__l_sc = constants_statuscodes_bs__e_sc_bad_unexpected_error;

      subscription_mgr__l_filterResult = constants__c_filterResult_indet;

      session_mgr__session_get_endpoint_config(subscription_mgr__p_session,

         &subscription_mgr__l_endpoint_config_idx);

      channel_mgr__is_valid_endpoint_config_idx(subscription_mgr__l_endpoint_config_idx,

         &subscription_mgr__l_bres);

      if (subscription_mgr__l_bres == true) {

         msg_subscription_monitored_item__getall_create_monitored_item_req_params(subscription_mgr__p_req_msg,

            subscription_mgr__p_index,

            &subscription_mgr__l_bres,

            &subscription_mgr__l_sc,

            &subscription_mgr__l_nid,

            &subscription_mgr__l_aid,

            &subscription_mgr__l_monitMode,

            &subscription_mgr__l_clientHandle,

            &subscription_mgr__l_samplingItv,

            &subscription_mgr__l_filter,

            &subscription_mgr__l_discardOldest,

            &subscription_mgr__l_queueSize,

            &subscription_mgr__l_indexRange);

         if (subscription_mgr__l_bres == true) {

            address_space_itf__readall_AddressSpace_Node(subscription_mgr__l_nid,

               &subscription_mgr__l_bres_presentNode,

               &subscription_mgr__l_node);

            subscription_absent_node__if_not_present_is_Node_known(subscription_mgr__l_bres_presentNode,

               subscription_mgr__l_endpoint_config_idx,

               subscription_mgr__l_nid,

               &subscription_mgr__l_bres_absent_knownNode,

               &subscription_mgr__l_knownNodeClass,

               &subscription_mgr__l_valueSc);

            if ((subscription_mgr__l_bres_presentNode == false) &&

               (subscription_mgr__l_bres_absent_knownNode == false)) {

               subscription_mgr__l_sc = constants_statuscodes_bs__e_sc_bad_node_id_unknown;

            }

            else {

               if (subscription_mgr__l_bres_presentNode == true) {

                  address_space_itf__read_Node_Attribute(subscription_mgr__p_user,

                     subscription_mgr__p_locales,

                     subscription_mgr__l_node,

                     subscription_mgr__l_nid,

                     subscription_mgr__l_aid,

                     subscription_mgr__l_indexRange,

                     &subscription_mgr__l_sc,

                     &subscription_mgr__l_value,

                     &subscription_mgr__l_valueSc,

                     &subscription_mgr__l_val_ts_src,

                     &subscription_mgr__l_val_ts_srv);

               }

               else {

                  subscription_absent_node__eval_knownNode_requested_properties(subscription_mgr__l_nid,

                     subscription_mgr__l_knownNodeClass,

                     subscription_mgr__l_aid,

                     subscription_mgr__l_indexRange,

                     &subscription_mgr__l_sc,

                     &subscription_mgr__l_value,

                     &subscription_mgr__l_val_ts_src,

                     &subscription_mgr__l_val_ts_srv);

               }

               if ((subscription_mgr__l_sc != constants_statuscodes_bs__e_sc_ok) &&

                  (((subscription_mgr__l_sc == constants_statuscodes_bs__e_sc_bad_not_readable) ||

                  (subscription_mgr__l_sc == constants_statuscodes_bs__e_sc_bad_user_access_denied)) ||

                  (subscription_mgr__l_sc == constants_statuscodes_bs__e_sc_bad_index_range_no_data))) {

                  constants_statuscodes_bs__getall_conv_StatusCode_To_RawStatusCode(subscription_mgr__l_sc,

                     &subscription_mgr__l_valueSc);

                  subscription_mgr__l_sc = constants_statuscodes_bs__e_sc_ok;

               }

               if (subscription_mgr__l_sc == constants_statuscodes_bs__e_sc_ok) {

                  subscription_core__compute_create_monitored_item_revised_params(subscription_mgr__l_aid,

                     subscription_mgr__l_queueSize,

                     &subscription_mgr__l_revSamplingItv,

                     &subscription_mgr__l_revQueueSize);

                  subscription_core__create_monitored_item(subscription_mgr__p_subscription,

                     subscription_mgr__l_nid,

                     subscription_mgr__l_aid,

                     subscription_mgr__l_indexRange,

                     subscription_mgr__l_value,

                     subscription_mgr__l_valueSc,

                     subscription_mgr__l_val_ts_src,

                     subscription_mgr__l_val_ts_srv,

                     subscription_mgr__p_tsToReturn,

                     subscription_mgr__l_monitMode,

                     subscription_mgr__l_clientHandle,

                     subscription_mgr__l_filter,

                     subscription_mgr__l_discardOldest,

                     subscription_mgr__l_revQueueSize,

                     &subscription_mgr__l_sc,

                     &subscription_mgr__l_monitoredItemPointer,

                     &subscription_mgr__l_monitoredItemId,

                     &subscription_mgr__l_filterResult);

                  address_space_itf__read_AddressSpace_free_variant(subscription_mgr__l_value);

               }

            }

         }

      }

      msg_subscription_monitored_item__setall_msg_create_monitored_item_resp_params(subscription_mgr__p_resp_msg,

         subscription_mgr__p_index,

         subscription_mgr__l_sc,

         subscription_mgr__l_monitoredItemId,

         subscription_mgr__l_revSamplingItv,

         subscription_mgr__l_revQueueSize,

         subscription_mgr__l_filterResult);

   }

}

void subscription_mgr__local_treat_create_monitored_items(

   const constants__t_session_i subscription_mgr__p_session,

   const constants__t_subscription_i subscription_mgr__p_subscription,

   const constants__t_TimestampsToReturn_i subscription_mgr__p_tsToReturn,

   const constants__t_user_i subscription_mgr__p_user,

   const constants__t_LocaleIds_i subscription_mgr__p_locales,

   const constants__t_msg_i subscription_mgr__p_req_msg,

   const constants__t_msg_i subscription_mgr__p_resp_msg,

   const t_entier4 subscription_mgr__p_nb_monitored_items) {

   {

      t_bool subscription_mgr__l_continue;

      t_entier4 subscription_mgr__l_index;

      subscription_create_monitored_item_it__init_iter_monitored_item_request(subscription_mgr__p_nb_monitored_items,

         &subscription_mgr__l_continue);

      while (subscription_mgr__l_continue == true) {

         subscription_create_monitored_item_it__continue_iter_monitored_item_request(&subscription_mgr__l_continue,

            &subscription_mgr__l_index);

         subscription_mgr__local_treat_create_monitored_item_index(subscription_mgr__p_session,

            subscription_mgr__p_subscription,

            subscription_mgr__p_tsToReturn,

            subscription_mgr__p_user,

            subscription_mgr__p_locales,

            subscription_mgr__p_req_msg,

            subscription_mgr__p_resp_msg,

            subscription_mgr__l_index);

      }

   }

}

void subscription_mgr__local_check_filtered_subscription_and_monitored_item(

   const constants__t_session_i subscription_mgr__p_opt_session_to_filter,

   const constants__t_subscription_i subscription_mgr__p_opt_sub_to_filter,

   const constants__t_monitoredItemId_i subscription_mgr__p_opt_mi_to_fitler,

   const constants__t_session_i subscription_mgr__p_session,

   const constants__t_subscription_i subscription_mgr__p_sub,

   const constants__t_monitoredItemId_i subscription_mgr__p_mi,

   t_bool * const subscription_mgr__bres) {

   *subscription_mgr__bres = ((((subscription_mgr__p_opt_session_to_filter == constants__c_session_indet) ||

      (subscription_mgr__p_opt_session_to_filter == subscription_mgr__p_session)) &&

      ((subscription_mgr__p_opt_sub_to_filter == constants__c_subscription_indet) ||

      (subscription_mgr__p_opt_sub_to_filter == subscription_mgr__p_sub))) &&

      ((subscription_mgr__p_opt_mi_to_fitler == constants__c_monitoredItemId_indet) ||

      (subscription_mgr__p_opt_mi_to_fitler == subscription_mgr__p_mi)));

}

void subscription_mgr__local_create_notification_on_monitored_item_if_event_selected(

   const constants__t_monitoredItemPointer_i subscription_mgr__p_monitoredItemPointer,

   const constants__t_Event_i subscription_mgr__p_event,

   const constants__t_session_i subscription_mgr__p_session,

   const constants__t_subscription_i subscription_mgr__p_sub_id,

   const constants__t_monitoredItemId_i subscription_mgr__p_mi_id) {

   {

      constants__t_monitoredItemId_i subscription_mgr__l_monitoredItemId;

      constants__t_subscription_i subscription_mgr__l_subscription;

      t_bool subscription_mgr__l_valid_subscription;

      t_bool subscription_mgr__l_filter_sub_and_mi;

      constants__t_session_i subscription_mgr__l_session;

      t_bool subscription_mgr__l_session_valid;

      constants__t_user_i subscription_mgr__l_user;

      constants__t_ApplicationDescription_i subscription_mgr__l_client_app_desc;

      constants__t_CertThumbprint_i subscription_mgr__l_client_cert_tb;

      constants__t_SessionName_i subscription_mgr__l_session_name;

      t_bool subscription_mgr__l_valid_user_access;

      constants__t_LocaleIds_i subscription_mgr__l_locales;

      constants__t_NodeId_i subscription_mgr__l_nid;

      constants__t_AttributeId_i subscription_mgr__l_aid;

      constants__t_IndexRange_i subscription_mgr__l_indexRange;

      constants__t_TimestampsToReturn_i subscription_mgr__l_timestampToReturn;

      constants__t_monitoringMode_i subscription_mgr__l_monitoringMode;

      constants__t_client_handle_i subscription_mgr__l_clientHandle;

      constants__t_sessionRoles_i subscription_mgr__l_roles;

      subscription_core__getall_monitoredItemPointer(subscription_mgr__p_monitoredItemPointer,

         &subscription_mgr__l_monitoredItemId,

         &subscription_mgr__l_subscription,

         &subscription_mgr__l_nid,

         &subscription_mgr__l_aid,

         &subscription_mgr__l_indexRange,

         &subscription_mgr__l_timestampToReturn,

         &subscription_mgr__l_monitoringMode,

         &subscription_mgr__l_clientHandle);

      subscription_core__is_valid_subscription(subscription_mgr__l_subscription,

         &subscription_mgr__l_valid_subscription);

      subscription_mgr__l_session = constants__c_session_indet;

      if (subscription_mgr__l_valid_subscription == true) {

         subscription_core__getall_session(subscription_mgr__l_subscription,

            &subscription_mgr__l_session);

      }

      subscription_mgr__local_check_filtered_subscription_and_monitored_item(subscription_mgr__p_session,

         subscription_mgr__p_sub_id,

         subscription_mgr__p_mi_id,

         subscription_mgr__l_session,

         subscription_mgr__l_subscription,

         subscription_mgr__l_monitoredItemId,

         &subscription_mgr__l_filter_sub_and_mi);

      session_mgr__is_valid_session(subscription_mgr__l_session,

         &subscription_mgr__l_session_valid);

      subscription_mgr__l_valid_user_access = false;

      subscription_mgr__l_locales = constants__c_LocaleIds_empty;

      if (((subscription_mgr__l_session_valid == true) &&

         (subscription_mgr__l_filter_sub_and_mi == true)) &&

         (subscription_mgr__l_aid == constants__e_aid_EventNotifier)) {

         session_mgr__get_session_user_server(subscription_mgr__l_session,

            &subscription_mgr__l_user);

         session_mgr__get_session_roles(subscription_mgr__l_session,

            &subscription_mgr__l_roles);

         session_mgr__get_server_session_preferred_locales(subscription_mgr__l_session,

            &subscription_mgr__l_locales);

         session_mgr__get_server_session_client_app_desc(subscription_mgr__l_session,

            &subscription_mgr__l_client_app_desc);

         session_mgr__get_server_session_client_cert_tb(subscription_mgr__l_session,

            &subscription_mgr__l_client_cert_tb);

         session_mgr__get_server_session_name(subscription_mgr__l_session,

            &subscription_mgr__l_session_name);

         app_cb_call_context_bs__set_app_call_context_session(subscription_mgr__l_session,

            subscription_mgr__l_client_app_desc,

            subscription_mgr__l_client_cert_tb,

            subscription_mgr__l_session_name,

            subscription_mgr__l_user);

         subscription_core__get_event_user_authorization(subscription_mgr__p_event,

            subscription_mgr__l_user,

            subscription_mgr__l_roles,

            &subscription_mgr__l_valid_user_access);

         app_cb_call_context_bs__clear_app_call_context();

      }

      if ((((subscription_mgr__l_session_valid == true) &&

         (subscription_mgr__l_filter_sub_and_mi == true)) &&

         (subscription_mgr__l_monitoringMode == constants__e_monitoringMode_reporting)) &&

         (subscription_mgr__l_aid == constants__e_aid_EventNotifier)) {

         subscription_core__server_subscription_add_notification_on_event_if_triggered(subscription_mgr__l_valid_user_access,

            subscription_mgr__l_locales,

            subscription_mgr__p_monitoredItemPointer,

            subscription_mgr__l_clientHandle,

            subscription_mgr__l_timestampToReturn,

            subscription_mgr__p_event);

      }

   }

}

void subscription_mgr__local_create_notification_on_monitored_items_if_event_selected(

   const constants__t_monitoredItemQueue_i subscription_mgr__p_monitoredItemQueue,

   const constants__t_Event_i subscription_mgr__p_event,

   const constants__t_session_i subscription_mgr__p_session,

   const constants__t_subscription_i subscription_mgr__p_sub_id,

   const constants__t_monitoredItemId_i subscription_mgr__p_mi_id) {

   {

      t_bool subscription_mgr__l_continue;

      constants__t_monitoredItemQueueIterator_i subscription_mgr__l_iterator;

      constants__t_monitoredItemPointer_i subscription_mgr__l_monitoredItemPointer;

      subscription_core__init_iter_monitored_item(subscription_mgr__p_monitoredItemQueue,

         &subscription_mgr__l_continue,

         &subscription_mgr__l_iterator);

      while (subscription_mgr__l_continue == true) {

         subscription_core__continue_iter_monitored_item(subscription_mgr__l_iterator,

            subscription_mgr__p_monitoredItemQueue,

            &subscription_mgr__l_continue,

            &subscription_mgr__l_monitoredItemPointer);

         subscription_mgr__local_create_notification_on_monitored_item_if_event_selected(subscription_mgr__l_monitoredItemPointer,

            subscription_mgr__p_event,

            subscription_mgr__p_session,

            subscription_mgr__p_sub_id,

            subscription_mgr__p_mi_id);

      }

      subscription_core__clear_iter_monitored_item(subscription_mgr__l_iterator);

   }

}

void subscription_mgr__local_create_notification_on_monitored_items_if_data_changed(

   const constants__t_monitoredItemPointer_i subscription_mgr__p_monitoredItemPointer,

   const constants__t_WriteValuePointer_i subscription_mgr__p_old_wv_pointer,

   const constants__t_WriteValuePointer_i subscription_mgr__p_new_wv_pointer) {

   {

      t_bool subscription_mgr__l_notification_triggered;

      constants__t_monitoredItemId_i subscription_mgr__l_monitoredItemId;

      constants__t_subscription_i subscription_mgr__l_subscription;

      t_bool subscription_mgr__l_valid_subscription;

      constants__t_session_i subscription_mgr__l_session;

      t_bool subscription_mgr__l_session_valid;

      constants__t_user_i subscription_mgr__l_user;

      constants__t_ApplicationDescription_i subscription_mgr__l_client_app_desc;

      constants__t_CertThumbprint_i subscription_mgr__l_client_cert_tb;

      constants__t_SessionName_i subscription_mgr__l_session_name;

      t_bool subscription_mgr__l_valid_user_access;

      constants__t_LocaleIds_i subscription_mgr__l_locales;

      constants__t_NodeId_i subscription_mgr__l_nid;

      constants__t_AttributeId_i subscription_mgr__l_aid;

      constants__t_IndexRange_i subscription_mgr__l_indexRange;

      constants__t_TimestampsToReturn_i subscription_mgr__l_timestampToReturn;

      constants__t_monitoringMode_i subscription_mgr__l_monitoringMode;

      constants__t_client_handle_i subscription_mgr__l_clientHandle;

      constants__t_sessionRoles_i subscription_mgr__l_roles;

      subscription_core__getall_monitoredItemPointer(subscription_mgr__p_monitoredItemPointer,

         &subscription_mgr__l_monitoredItemId,

         &subscription_mgr__l_subscription,

         &subscription_mgr__l_nid,

         &subscription_mgr__l_aid,

         &subscription_mgr__l_indexRange,

         &subscription_mgr__l_timestampToReturn,

         &subscription_mgr__l_monitoringMode,

         &subscription_mgr__l_clientHandle);

      subscription_core__is_valid_subscription(subscription_mgr__l_subscription,

         &subscription_mgr__l_valid_subscription);

      subscription_mgr__l_notification_triggered = false;

      subscription_mgr__l_valid_user_access = false;

      subscription_mgr__l_locales = constants__c_LocaleIds_empty;

      if (subscription_mgr__l_valid_subscription == true) {

         subscription_core__getall_session(subscription_mgr__l_subscription,

            &subscription_mgr__l_session);

         session_mgr__is_valid_session(subscription_mgr__l_session,

            &subscription_mgr__l_session_valid);

         if (subscription_mgr__l_session_valid == true) {

            session_mgr__get_session_user_server(subscription_mgr__l_session,

               &subscription_mgr__l_user);

            session_mgr__get_server_session_client_app_desc(subscription_mgr__l_session,

               &subscription_mgr__l_client_app_desc);

            session_mgr__get_server_session_client_cert_tb(subscription_mgr__l_session,

               &subscription_mgr__l_client_cert_tb);

            session_mgr__get_server_session_name(subscription_mgr__l_session,

               &subscription_mgr__l_session_name);

            app_cb_call_context_bs__set_app_call_context_session(subscription_mgr__l_session,

               subscription_mgr__l_client_app_desc,

               subscription_mgr__l_client_cert_tb,

               subscription_mgr__l_session_name,

               subscription_mgr__l_user);

            session_mgr__get_session_roles(subscription_mgr__l_session,

               &subscription_mgr__l_roles);

            address_space_itf__get_user_authorization(constants__e_operation_type_read,

               subscription_mgr__l_nid,

               subscription_mgr__l_aid,

               subscription_mgr__l_user,

               subscription_mgr__l_roles,

               &subscription_mgr__l_valid_user_access);

            session_mgr__get_server_session_preferred_locales(subscription_mgr__l_session,

               &subscription_mgr__l_locales);

            app_cb_call_context_bs__clear_app_call_context();

         }

      }

      if (subscription_mgr__l_valid_user_access == true) {

         subscription_core__is_notification_triggered(subscription_mgr__l_locales,

            subscription_mgr__p_monitoredItemPointer,

            subscription_mgr__p_old_wv_pointer,

            subscription_mgr__p_new_wv_pointer,

            &subscription_mgr__l_notification_triggered);

      }

      if ((subscription_mgr__l_notification_triggered == true) &&

         (subscription_mgr__l_monitoringMode == constants__e_monitoringMode_reporting)) {

         subscription_core__server_subscription_add_notification_on_value_change(subscription_mgr__l_locales,

            subscription_mgr__p_monitoredItemPointer,

            subscription_mgr__l_timestampToReturn,

            subscription_mgr__p_new_wv_pointer);

      }

   }

}

void subscription_mgr__create_notification_on_monitored_items_if_data_changed(

   const constants__t_monitoredItemQueue_i subscription_mgr__p_monitoredItemQueue,

   const constants__t_WriteValuePointer_i subscription_mgr__p_old_wv_pointer,

   const constants__t_WriteValuePointer_i subscription_mgr__p_new_wv_pointer) {

   {

      t_bool subscription_mgr__l_continue;

      constants__t_monitoredItemQueueIterator_i subscription_mgr__l_iterator;

      constants__t_monitoredItemPointer_i subscription_mgr__l_monitoredItemPointer;

      subscription_core__init_iter_monitored_item(subscription_mgr__p_monitoredItemQueue,

         &subscription_mgr__l_continue,

         &subscription_mgr__l_iterator);

      while (subscription_mgr__l_continue == true) {

         subscription_core__continue_iter_monitored_item(subscription_mgr__l_iterator,

            subscription_mgr__p_monitoredItemQueue,

            &subscription_mgr__l_continue,

            &subscription_mgr__l_monitoredItemPointer);

         subscription_mgr__local_create_notification_on_monitored_items_if_data_changed(subscription_mgr__l_monitoredItemPointer,

            subscription_mgr__p_old_wv_pointer,

            subscription_mgr__p_new_wv_pointer);

      }

      subscription_core__clear_iter_monitored_item(subscription_mgr__l_iterator);

   }

}

void subscription_mgr__local_create_notification_if_node_changed_or_monitMode_enabling(

   const constants__t_monitoredItemPointer_i subscription_mgr__p_monitoredItemPointer,

   const t_bool subscription_mgr__p_added_or_monitMode,

   const t_bool subscription_mgr__p_monitMode_enabling) {

   {

      constants__t_monitoredItemId_i subscription_mgr__l_monitoredItemId;

      constants__t_subscription_i subscription_mgr__l_subscription;

      constants__t_session_i subscription_mgr__l_session;

      t_bool subscription_mgr__l_session_valid;

      constants__t_user_i subscription_mgr__l_user;

      constants__t_LocaleIds_i subscription_mgr__l_locales;

      constants__t_NodeId_i subscription_mgr__l_nid;

      constants__t_AttributeId_i subscription_mgr__l_aid;

      constants__t_IndexRange_i subscription_mgr__l_indexRange;

      constants__t_TimestampsToReturn_i subscription_mgr__l_timestampToReturn;

      constants__t_monitoringMode_i subscription_mgr__l_monitoringMode;

      constants__t_client_handle_i subscription_mgr__l_clientHandle;

      t_bool subscription_mgr__l_valid_subscription;

      t_bool subscription_mgr__l_bres;

      constants__t_Node_i subscription_mgr__l_node;

      constants_statuscodes_bs__t_StatusCode_i subscription_mgr__l_sc;

      constants__t_Variant_i subscription_mgr__l_value;

      constants__t_RawStatusCode subscription_mgr__l_valueSc;

      constants__t_Timestamp subscription_mgr__l_val_ts_src;

      constants__t_Timestamp subscription_mgr__l_val_ts_srv;

      subscription_mgr__l_bres = true;

      subscription_core__getall_monitoredItemPointer(subscription_mgr__p_monitoredItemPointer,

         &subscription_mgr__l_monitoredItemId,

         &subscription_mgr__l_subscription,

         &subscription_mgr__l_nid,

         &subscription_mgr__l_aid,

         &subscription_mgr__l_indexRange,

         &subscription_mgr__l_timestampToReturn,

         &subscription_mgr__l_monitoringMode,

         &subscription_mgr__l_clientHandle);

      subscription_core__is_valid_subscription(subscription_mgr__l_subscription,

         &subscription_mgr__l_valid_subscription);

      if (subscription_mgr__l_valid_subscription == true) {

         subscription_core__getall_session(subscription_mgr__l_subscription,

            &subscription_mgr__l_session);

         session_mgr__is_valid_session(subscription_mgr__l_session,

            &subscription_mgr__l_session_valid);

         if (subscription_mgr__l_session_valid == true) {

            subscription_mgr__l_value = constants__c_Variant_indet;

            subscription_mgr__l_val_ts_src = constants__c_Timestamp_null;

            subscription_mgr__l_val_ts_srv = constants__c_Timestamp_null;

            subscription_mgr__l_sc = constants_statuscodes_bs__e_sc_bad_unexpected_error;

            constants_statuscodes_bs__getall_conv_StatusCode_To_RawStatusCode(subscription_mgr__l_sc,

               &subscription_mgr__l_valueSc);

            if (subscription_mgr__p_added_or_monitMode == true) {

               session_mgr__get_session_user_server(subscription_mgr__l_session,

                  &subscription_mgr__l_user);

               session_mgr__get_server_session_preferred_locales(subscription_mgr__l_session,

                  &subscription_mgr__l_locales);

               address_space_itf__readall_AddressSpace_Node(subscription_mgr__l_nid,

                  &subscription_mgr__l_bres,

                  &subscription_mgr__l_node);

               if (subscription_mgr__l_bres == true) {

                  address_space_itf__read_Node_Attribute(subscription_mgr__l_user,

                     subscription_mgr__l_locales,

                     subscription_mgr__l_node,

                     subscription_mgr__l_nid,

                     subscription_mgr__l_aid,

                     subscription_mgr__l_indexRange,

                     &subscription_mgr__l_sc,

                     &subscription_mgr__l_value,

                     &subscription_mgr__l_valueSc,

                     &subscription_mgr__l_val_ts_src,

                     &subscription_mgr__l_val_ts_srv);

                  if (((subscription_mgr__l_sc == constants_statuscodes_bs__e_sc_bad_not_readable) ||

                     (subscription_mgr__l_sc == constants_statuscodes_bs__e_sc_bad_user_access_denied)) ||

                     (subscription_mgr__l_sc == constants_statuscodes_bs__e_sc_bad_index_range_no_data)) {

                     constants_statuscodes_bs__getall_conv_StatusCode_To_RawStatusCode(subscription_mgr__l_sc,

                        &subscription_mgr__l_valueSc);

                     subscription_mgr__l_sc = constants_statuscodes_bs__e_sc_ok;

                  }

               }

               else if (subscription_mgr__p_monitMode_enabling == true) {

                  subscription_mgr__l_sc = constants_statuscodes_bs__e_sc_bad_node_id_unknown;

                  constants_statuscodes_bs__getall_conv_StatusCode_To_RawStatusCode(subscription_mgr__l_sc,

                     &subscription_mgr__l_valueSc);

               }

            }

            else {

               subscription_mgr__l_sc = constants_statuscodes_bs__e_sc_bad_node_id_unknown;

               constants_statuscodes_bs__getall_conv_StatusCode_To_RawStatusCode(subscription_mgr__l_sc,

                  &subscription_mgr__l_valueSc);

            }

            if (subscription_mgr__l_bres == true) {

               subscription_core__server_subscription_add_notification_on_node_or_monitMode_change(subscription_mgr__p_monitoredItemPointer,

                  subscription_mgr__l_nid,

                  subscription_mgr__l_aid,

                  subscription_mgr__l_value,

                  subscription_mgr__l_valueSc,

                  subscription_mgr__l_val_ts_src,

                  subscription_mgr__l_val_ts_srv,

                  &subscription_mgr__l_bres);

               address_space_itf__read_AddressSpace_free_variant(subscription_mgr__l_value);

            }

         }

      }

   }

}

void subscription_mgr__create_notification_on_monitored_items_if_node_changed(

   const constants__t_monitoredItemQueue_i subscription_mgr__p_monitoredItemQueue,

   const t_bool subscription_mgr__p_added) {

   {

      t_bool subscription_mgr__l_continue;

      constants__t_monitoredItemQueueIterator_i subscription_mgr__l_iterator;

      constants__t_monitoredItemPointer_i subscription_mgr__l_monitoredItemPointer;

      subscription_core__init_iter_monitored_item(subscription_mgr__p_monitoredItemQueue,

         &subscription_mgr__l_continue,

         &subscription_mgr__l_iterator);

      while (subscription_mgr__l_continue == true) {

         subscription_core__continue_iter_monitored_item(subscription_mgr__l_iterator,

            subscription_mgr__p_monitoredItemQueue,

            &subscription_mgr__l_continue,

            &subscription_mgr__l_monitoredItemPointer);

         subscription_mgr__local_create_notification_if_node_changed_or_monitMode_enabling(subscription_mgr__l_monitoredItemPointer,

            subscription_mgr__p_added,

            false);

      }

      subscription_core__clear_iter_monitored_item(subscription_mgr__l_iterator);

   }

}

void subscription_mgr__fill_response_subscription_modify_monitored_items(

   const constants__t_subscription_i subscription_mgr__p_subscription,

   const constants__t_TimestampsToReturn_i subscription_mgr__p_tsToReturn,

   const constants__t_msg_i subscription_mgr__p_req_msg,

   const constants__t_msg_i subscription_mgr__p_resp_msg,

   const t_entier4 subscription_mgr__p_nb_monitored_items) {

   {

      t_bool subscription_mgr__l_continue;

      t_entier4 subscription_mgr__l_index;

      constants__t_monitoredItemId_i subscription_mgr__l_id;

      t_bool subscription_mgr__l_bres;

      constants_statuscodes_bs__t_StatusCode_i subscription_mgr__l_sc;

      constants__t_client_handle_i subscription_mgr__l_clientHandle;

      constants__t_opcua_duration_i subscription_mgr__l_samplingItv;

      constants__t_monitoringFilter_i subscription_mgr__l_filter;

      t_bool subscription_mgr__l_discardOldest;

      t_entier4 subscription_mgr__l_queueSize;

      t_entier4 subscription_mgr__l_revQueueSize;

      constants__t_opcua_duration_i subscription_mgr__l_revSamplingItv;

      constants__t_filterResult_i subscription_mgr__l_filterResult;

      subscription_mgr__l_revSamplingItv = constants__c_opcua_duration_indet;

      subscription_mgr__l_revQueueSize = 0;

      subscription_mgr__l_filterResult = constants__c_filterResult_indet;

      subscription_create_monitored_item_it__init_iter_monitored_item_request(subscription_mgr__p_nb_monitored_items,

         &subscription_mgr__l_continue);

      while (subscription_mgr__l_continue == true) {

         subscription_create_monitored_item_it__continue_iter_monitored_item_request(&subscription_mgr__l_continue,

            &subscription_mgr__l_index);

         msg_subscription_monitored_item__getall_modify_monitored_item_req_params(subscription_mgr__p_req_msg,

            subscription_mgr__l_index,

            &subscription_mgr__l_bres,

            &subscription_mgr__l_sc,

            &subscription_mgr__l_id,

            &subscription_mgr__l_clientHandle,

            &subscription_mgr__l_samplingItv,

            &subscription_mgr__l_filter,

            &subscription_mgr__l_discardOldest,

            &subscription_mgr__l_queueSize);

         if (subscription_mgr__l_bres == true) {

            subscription_core__modify_monitored_item(subscription_mgr__p_subscription,

               subscription_mgr__l_id,

               subscription_mgr__p_tsToReturn,

               subscription_mgr__l_clientHandle,

               subscription_mgr__l_filter,

               subscription_mgr__l_discardOldest,

               subscription_mgr__l_queueSize,

               &subscription_mgr__l_sc,

               &subscription_mgr__l_filterResult,

               &subscription_mgr__l_revSamplingItv,

               &subscription_mgr__l_revQueueSize);

         }

         msg_subscription_monitored_item__setall_msg_modify_monitored_item_resp_params(subscription_mgr__p_resp_msg,

            subscription_mgr__l_index,

            subscription_mgr__l_sc,

            subscription_mgr__l_revSamplingItv,

            subscription_mgr__l_revQueueSize,

            subscription_mgr__l_filterResult);

      }

   }

}

void subscription_mgr__fill_response_subscription_delete_monitored_items(

   const constants__t_subscription_i subscription_mgr__p_subscription,

   const constants__t_msg_i subscription_mgr__p_req_msg,

   const constants__t_msg_i subscription_mgr__p_resp_msg,

   const t_entier4 subscription_mgr__p_nb_monitored_items) {

   {

      t_bool subscription_mgr__l_continue;

      t_entier4 subscription_mgr__l_index;

      constants__t_monitoredItemId_i subscription_mgr__l_id;

      constants_statuscodes_bs__t_StatusCode_i subscription_mgr__l_sc;

      subscription_create_monitored_item_it__init_iter_monitored_item_request(subscription_mgr__p_nb_monitored_items,

         &subscription_mgr__l_continue);

      while (subscription_mgr__l_continue == true) {

         subscription_create_monitored_item_it__continue_iter_monitored_item_request(&subscription_mgr__l_continue,

            &subscription_mgr__l_index);

         msg_subscription_monitored_item__getall_delete_monitored_item_req_params(subscription_mgr__p_req_msg,

            subscription_mgr__l_index,

            &subscription_mgr__l_id);

         subscription_core__delete_monitored_item(subscription_mgr__p_subscription,

            subscription_mgr__l_id,

            &subscription_mgr__l_sc);

         msg_subscription_monitored_item__setall_msg_delete_monitored_item_resp_params(subscription_mgr__p_resp_msg,

            subscription_mgr__l_index,

            subscription_mgr__l_sc);

      }

   }

}

void subscription_mgr__local_create_delete_notification_on_set_monit_mode_change(

   const constants__t_monitoredItemPointer_i subscription_mgr__p_monitoredItemPointer,

   const constants__t_monitoringMode_i subscription_mgr__p_prevMonitMode,

   const constants__t_monitoringMode_i subscription_mgr__p_newMonitMode) {

   if ((subscription_mgr__p_prevMonitMode == constants__e_monitoringMode_disabled) &&

      (subscription_mgr__p_newMonitMode != constants__e_monitoringMode_disabled)) {

      subscription_mgr__local_create_notification_if_node_changed_or_monitMode_enabling(subscription_mgr__p_monitoredItemPointer,

         true,

         true);

   }

   else if ((subscription_mgr__p_prevMonitMode != constants__e_monitoringMode_disabled) &&

      (subscription_mgr__p_newMonitMode == constants__e_monitoringMode_disabled)) {

      subscription_core__clear_monitored_item_notifications(subscription_mgr__p_monitoredItemPointer);

   }

}

void subscription_mgr__fill_response_subscription_set_monit_mode_monitored_items(

   const constants__t_subscription_i subscription_mgr__p_subscription,

   const constants__t_monitoringMode_i subscription_mgr__p_monitoring_mode,

   const constants__t_msg_i subscription_mgr__p_req_msg,

   const constants__t_msg_i subscription_mgr__p_resp_msg,

   const t_entier4 subscription_mgr__p_nb_monitored_items) {

   {

      t_bool subscription_mgr__l_continue;

      t_entier4 subscription_mgr__l_index;

      constants__t_monitoredItemId_i subscription_mgr__l_id;

      constants_statuscodes_bs__t_StatusCode_i subscription_mgr__l_sc;

      constants__t_monitoredItemPointer_i subscription_mgr__l_mi_pointer;

      constants__t_monitoringMode_i subscription_mgr__l_mi_prevMonitMode;

      subscription_create_monitored_item_it__init_iter_monitored_item_request(subscription_mgr__p_nb_monitored_items,

         &subscription_mgr__l_continue);

      while (subscription_mgr__l_continue == true) {

         subscription_create_monitored_item_it__continue_iter_monitored_item_request(&subscription_mgr__l_continue,

            &subscription_mgr__l_index);

         msg_subscription_monitored_item__getall_set_monit_mode_monitored_item_req_params(subscription_mgr__p_req_msg,

            subscription_mgr__l_index,

            &subscription_mgr__l_id);

         subscription_core__set_monit_mode_monitored_item(subscription_mgr__p_subscription,

            subscription_mgr__l_id,

            subscription_mgr__p_monitoring_mode,

            &subscription_mgr__l_sc,

            &subscription_mgr__l_mi_pointer,

            &subscription_mgr__l_mi_prevMonitMode);

         msg_subscription_monitored_item__setall_msg_set_monit_mode_monitored_item_resp_params(subscription_mgr__p_resp_msg,

            subscription_mgr__l_index,

            subscription_mgr__l_sc);

         if (subscription_mgr__l_sc == constants_statuscodes_bs__e_sc_ok) {

            subscription_mgr__local_create_delete_notification_on_set_monit_mode_change(subscription_mgr__l_mi_pointer,

               subscription_mgr__l_mi_prevMonitMode,

               subscription_mgr__p_monitoring_mode);

         }

      }

   }

}

void subscription_mgr__fill_delete_subscriptions_response(

   const constants__t_msg_i subscription_mgr__p_req_msg,

   const constants__t_msg_i subscription_mgr__p_resp_msg,

   const constants__t_session_i subscription_mgr__p_session,

   const t_entier4 subscription_mgr__p_nb_reqs) {

   {

      t_entier4 subscription_mgr__l_index;