src/o1/SessionHandler.cpp

   1 /*******************************************************************************
   2 ################################################################################
   3 #   Copyright (c) [2020] [HCL Technologies Ltd.]                               #
   4 #                                                                              #
   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                                    #
   8 #                                                                              #
   9 #       http://www.apache.org/licenses/LICENSE-2.0                             #
  10 #                                                                              #
  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 ################################################################################
  17 *******************************************************************************/
  18
  19 /* This file contains methods of Session/Connection creation and Subscription to
  20    YANG modules */
  21
  22 #include <stdio.h>
  23 #include <stdlib.h>
  24 #include "sysrepo.h"
  25 #include "SessionHandler.hpp"
  26 #include "InitConfig.hpp"
  27 #include <iostream>
  28
  29 using namespace std;
  30 /* Default constructor */
  31 SessionHandler::SessionHandler()
  32 {
  33 }
  34
  35
  36 /* Destructor */
  37 SessionHandler::~SessionHandler()
  38 {
  39 }
  40
  41 /**********************************************************************
  42    Description : This function will create Connection, Session, and
  43                  subscribe. These sysrepo class provide netconf connection
  44                  related services.
  45    Params[In]  : void
  46    Return      : true  - started successful
  47                  false - start failed
  48 **********************************************************************/
  49 bool SessionHandler::init()
  50 {
  51    try
  52    {
  53       O1_LOG("\nO1 SessionHandler : Initialization done");
  54       mConn = createConnection();
  55       O1_LOG("\nO1 SessionHandler : Initialization done");
  56       mSess = createSession(mConn);
  57       mSub  = createSubscribe(mSess);
  58       O1_LOG("\nO1 SessionHandler : Initialization done");
  59       //InitConfig initConf;
  60       InitConfig::instance().init(mSess);
  61       return true;
  62    }
  63    catch( const std::exception& e )
  64    {
  65       O1_LOG("\nO1 SessionHandler : Exception : %s", e.what());
  66       return false;
  67    }
  68 }
  69
  70 /**********************************************************************
  71    Description : This function will create Connection instance and
  72                  return the same
  73    Params[In]  : void
  74    Return      : sysrepo::S_Connection instance
  75 **********************************************************************/
  76 sysrepo::S_Connection SessionHandler::createConnection()
  77 {
  78    sysrepo::S_Connection conn(new sysrepo::Connection());
  79    return conn;
  80 }
  81
  82
  83 /**********************************************************************
  84    Description : This function will create Session instance and
  85                  return the same
  86    Params[In]  : sysrepo::S_Connection
  87    Return      : sysrepo::S_Session instance
  88 **********************************************************************/
  89 sysrepo::S_Session SessionHandler::createSession(sysrepo::S_Connection conn)
  90 {
  91    sysrepo::S_Session sess(new sysrepo::Session(conn));
  92    return sess;
  93 }
  94
  95
  96
  97 /**********************************************************************
  98    Description : This function will create Subscribe instance and
  99                  return the same
 100    Params[In]  : sysrepo::S_Session
 101    Return      : sysrepo::S_Subscribe instance
 102 **********************************************************************/
 103 sysrepo::S_Subscribe SessionHandler::createSubscribe(sysrepo::S_Session sess)
 104 {
 105    sysrepo::S_Subscribe subscrb(new sysrepo::Subscribe(sess));
 106    if(subscribeModule(subscrb))
 107    {
 108       O1_LOG("\nO1 SessionHandler : Subscription done successfully");
 109    }
 110    return subscrb;
 111 }
 112
 113
 114 /**********************************************************************
 115    Description : This function will create a callback object and register
 116                  it for callback.
 117    Params[In]  : sysrepo::S_Subscribe
 118    Return      : true   - on success
 119 **********************************************************************/
 120 bool SessionHandler::subscribeModule(sysrepo::S_Subscribe subscrb)
 121 {
 122    sysrepo::S_Callback alarmOranCb(new AlarmOranYangModel());
 123
 124    subscrb->oper_get_items_subscribe(ALARM_MODULE_NAME_ORAN, \
 125                                      ALARM_MODULE_PATH_ORAN, \
 126                                      alarmOranCb);
 127    return true;
 128 }
 129
 130 /**********************************************************************
 131          End of file
 132 **********************************************************************/