fenli gnbCONtext uecontext ue_ngao_context

.vscode/settings.json

+{
+    "files.associations": {
+        "*.ipp": "cpp",
+        "array": "cpp",
+        "*.tcc": "cpp",
+        "memory": "cpp",
+        "future": "cpp",
+        "istream": "cpp",
+        "functional": "cpp",
+        "tuple": "cpp",
+        "utility": "cpp"
+    }
+}
\ No newline at end of file

etc/amf_openxg.conf

@@ -60,21 +60,30 @@ AMF =
     # AMF binded interface for N1/N2 interface (NGAP) 
     NGAP_AMF: 
     {
-      INTERFACE_NAME = "ens3";  # YOUR NETWORK CONFIG HERE
+      INTERFACE_NAME = "eno1";  # YOUR NETWORK CONFIG HERE
       IPV4_ADDRESS   = "read";
-      PORT           = 38412;                            # YOUR NETWORK CONFIG HERE
+      PORT           = 38478;                            # YOUR NETWORK CONFIG HERE
       PPID           = 60;                               # YOUR NETWORK CONFIG HERE
     };
+
+     # AMF binded interface for Nausf interface
+    NAUSF:
+    {
+      INTERFACE_NAME = "eno1";            # YOUR NETWORK CONFIG HERE
+      IPV4_ADDRESS   = "read";
+      PORT           = 8383;               # YOUR NETWORK CONFIG HERE
+    };
+
     
     # AMF binded interface for N11 
     N11:
     {
-      INTERFACE_NAME = "ens3"; # YOUR NETWORK CONFIG HERE
+      INTERFACE_NAME = "eno1"; # YOUR NETWORK CONFIG HERE
       IPV4_ADDRESS   = "read"; 
       PORT           = 8282;                             # YOUR NETWORK CONFIG HERE
       
       SMF_INSTANCES_POOL = (
-        {SMF_INSTANCE_ID = 1; IPV4_ADDRESS = "192.168.122.197"; PORT = "8889"; VERSION = "v2"; SELECTED = "true"},   # YOUR SMF CONFIG HERE
+        {SMF_INSTANCE_ID = 1; IPV4_ADDRESS = "10.112.202.24"; PORT = "8890"; VERSION = "v2"; SELECTED = "true"},   # YOUR SMF CONFIG HERE
         {SMF_INSTANCE_ID = 2; IPV4_ADDRESS = "192.168.122.2"; PORT = "80"; VERSION = "v1"; SELECTED = "false"} # YOUR SMF CONFIG HERE
       );
     };
@@ -86,7 +95,7 @@ AMF =
     ## MySQL mandatory options
     MYSQL_server = "127.0.0.1"; # MySQL Server address
     MYSQL_user   = "root";   # Database server login
-    MYSQL_pass   = "linux";   # Database server password
+    MYSQL_pass   = "123";   # Database server password
     MYSQL_db     = "OPENXG_DB";     # Your database name
     
     ## OP

etc/stateless.conf

+################################################################################
+# Licensed to the OpenAirInterface (OAI) Software Alliance under one or more
+# contributor license agreements.  See the NOTICE file distributed with
+# this work for additional information regarding copyright ownership.
+# The OpenAirInterface Software Alliance licenses this file to You under
+# the OAI Public License, Version 1.1  (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.openairinterface.org/?page_id=698
+#
+# 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.
+#-------------------------------------------------------------------------------
+# For more information about the OpenAirInterface (OAI) Software Alliance:
+#      contact@openairinterface.org
+################################################################################
+
+AMF = 
+{
+  INSTANCE_ID = 10;            # 0 is the default
+  PID_DIRECTORY = "/var/run";   # /var/run is the default
+  
+  AMF_NAME = "OAI-AMF";
+  
+  RELATIVE_CAPACITY = 30;
+  # Display statistics about whole system (in seconds)
+  STATISTICS_TIMER_INTERVAL = 20;  # YOUR CONFIG HERE
+  
+  CORE_CONFIGURATION:
+  {
+    EMERGENCY_SUPPORT = "false";
+  };
+  
+  GUAMI: 
+  {
+    MCC = "460"; MNC = "33"; RegionID = "128"; AMFSetID = "1"; AMFPointer = "1" # YOUR GUAMI CONFIG HERE
+  }
+  
+  SERVED_GUAMI_LIST = (
+    {MCC = "460"; MNC = "33"; RegionID = "128"; AMFSetID = "1"; AMFPointer = "0"} #48bits <MCC><MNC><RegionID><AMFSetID><AMFPointer>
+    #{MCC = "110"; MNC = "11"; RegionID = "10"; AMFSetID = "1"; AMFPointer = "1"}  #48bits <MCC><MNC><RegionID><AMFSetID><AMFPointer>
+  );
+    
+  PLMN_SUPPORT_LIST = (
+  {
+    MCC = "460"; MNC = "33"; TAC = 100;  # YOUR PLMN CONFIG HERE
+    SLICE_SUPPORT_LIST = (
+      {SST = "1"; SD = "none"},  # YOUR NSSAI CONFIG HERE
+      {SST = "1"; SD = "12"}   # YOUR NSSAI CONFIG HERE
+     )
+  }
+  );
+    
+  INTERFACES:
+  {
+    # AMF binded interface for N1/N2 interface (NGAP) 
+    NGAP_AMF: 
+    {
+      INTERFACE_NAME = "eno1";  # YOUR NETWORK CONFIG HERE
+      IPV4_ADDRESS   = "read";
+      PORT           = 38414;                            # YOUR NETWORK CONFIG HERE
+      PPID           = 60;                               # YOUR NETWORK CONFIG HERE
+    };
+
+     # AMF binded interface for Nausf interface
+    NAUSF:
+    {
+      INTERFACE_NAME = "eno1";            # YOUR NETWORK CONFIG HERE
+      IPV4_ADDRESS   = "read";
+      PORT           = 8383;               # YOUR NETWORK CONFIG HERE
+    };
+
+    
+    # AMF binded interface for N11 
+    N11:
+    {
+      INTERFACE_NAME = "eno1"; # YOUR NETWORK CONFIG HERE
+      IPV4_ADDRESS   = "read"; 
+      PORT           = 8282;                             # YOUR NETWORK CONFIG HERE
+      
+      SMF_INSTANCES_POOL = (
+        {SMF_INSTANCE_ID = 1; IPV4_ADDRESS = "10.112.202.24"; PORT = "8890"; VERSION = "v2"; SELECTED = "true"},   # YOUR SMF CONFIG HERE
+        {SMF_INSTANCE_ID = 2; IPV4_ADDRESS = "192.168.122.2"; PORT = "80"; VERSION = "v1"; SELECTED = "false"} # YOUR SMF CONFIG HERE
+      );
+    };
+  };
+  
+
+  AUTHENTICATION:
+  {
+    ## MySQL mandatory options
+    MYSQL_server = "127.0.0.1"; # MySQL Server address
+    MYSQL_user   = "root";   # Database server login
+    MYSQL_pass   = "123";   # Database server password
+    MYSQL_db     = "OPENXG_DB";     # Your database name
+    
+    ## OP
+    OPERATOR_key = "63bfa50ee6523365ff14c1f45f88737d"; # OP key matching your database
+    RANDOM = "true";
+  };
+  
+  NAS:
+  {
+    ORDERED_SUPPORTED_INTEGRITY_ALGORITHM_LIST = [ "NIA1" , "NIA1" , "NIA1" ];
+    ORDERED_SUPPORTED_CIPHERING_ALGORITHM_LIST = [ "NEA0" , "NEA1" , "NEA2" ];
+  };
+  
+};
+
+
+MODULES =
+{
+  NGAP_MESSAGE = (
+    {MSG_NAME = "NGSetupRequest"; ProcedureCode = 21; TypeOfMessage = "initialMessage"}
+  );
+};

src/amf-app/amf_app.cpp

@@ -34,6 +34,8 @@
 #include "itti.hpp"
 
 #include "DLNASTransport.hpp"
+#include <nlohmann/json.hpp>
+#include "ngap_app.hpp"
 #include "amf_config.hpp"
 #include "amf_n1.hpp"
 #include "amf_n11.hpp"
@@ -277,7 +279,7 @@ void amf_app::handle_itti_message(
     amf_ue_ngap_id = generate_amf_ue_ngap_id();
   }
   string ue_context_key = "app_ue_ranid_" + to_string(itti_msg.ran_ue_ngap_id) +
-                          ":amfid_" + to_string(amf_ue_ngap_id);
+                          "-amfid_" + to_string(amf_ue_ngap_id);
   // if(!is_amf_ue_id_2_ue_context(amf_ue_ngap_id)){
   if (!is_ran_amf_id_2_ue_context(ue_context_key)) {
     Logger::amf_app().debug(
@@ -325,6 +327,69 @@ void amf_app::handle_itti_message(
     if (is_guti_valid) {
       itti_n1_msg->guti = guti;
     }
+    
+  /**********************   hxs add *******************************/
+  std::string udsf_url = "http://10.112.202.24:7123/nudsf-dr/v1/amfdata/" + std::string("ue_context/records/") + ue_context_key ;
+  nlohmann::json udsf_ue_context;
+  nlohmann::json  cgi;
+  cgi["Content-ID"] = "cgi";
+  cgi["Content-Type"] = "JSON";
+  cgi["content"]["mcc"] = uc.get()->cgi.mcc;
+  cgi["content"]["mnc"] = uc.get()->cgi.mnc; 
+  cgi["content"]["nrCellID"] = to_string(uc.get()->cgi.nrCellID);
+  nlohmann::json  tai;
+  tai["Content-ID"] = "tai";
+  tai["Content-Type"] = "JSON";
+  tai["content"]["mcc"] = uc.get()->tai.mcc;
+  tai["content"]["mnc"] = uc.get()->tai.mnc; 
+  tai["content"]["tac"] = to_string(uc.get()->tai.tac);
+  udsf_ue_context["meta"] ["tags"] = {
+                                       {"RECORD_ID",nlohmann::json::array({ue_context_key})},
+                                       {"from_nf_ID",nlohmann::json::array({"AMF_1234"})}
+                                       } ;
+  udsf_ue_context["blocks"] = nlohmann::json::array({
+                                               {{"Content-ID", "ran_ue_ngap_id"},{"Content-Type", "varchar(32)"},{"content", to_string(uc.get()->ran_ue_ngap_id)}},
+                                               {{"Content-ID", "amf_ue_ngap_id"},{"Content-Type", "varchar(32)"},{"content", to_string(uc.get()->amf_ue_ngap_id)}},
+                                               {{"Content-ID", "rrc_estb_cause"},{"Content-Type", "varchar(32)"},{"content",to_string(uc.get()->rrc_estb_cause)}},
+                                               {{"Content-ID", "isUeContextRequest"},{"Content-Type", "varchar(32)"},{"content", to_string(uc.get()->isUeContextRequest)}}
+                                          });              
+  udsf_ue_context["blocks"].push_back(cgi);    
+  udsf_ue_context["blocks"].push_back(tai);  
+  std::string json_part = udsf_ue_context.dump();
+  //amf_n2_inst->curl_http_client_udsf(udsf_url,json_part,"PUT",udsf_ue_context);
+  nlohmann::json udsf_response;
+  amf_n2_inst->curl_http_client_udsf(udsf_url,json_part,"PUT",udsf_response);
+  // udsf_url = "http://10.112.202.24:7123/nudsf-dr/v1/amfdata/" + std::string("gnb_context/records/") + std::to_string(itti_msg.assoc_id) ;
+  // if(!amf_n2_inst->curl_http_client_udsf(udsf_url,"","GET",udsf_response)){
+  //   Logger::amf_n2().error("No existing gNG context with assoc_id (%d)", itti_msg.assoc_id);
+  //   return;
+  // }
+  // Logger::amf_n2().debug("udsf_response: %s", udsf_response.dump().c_str());\
+  // gnb_context *gc1 = new gnb_context();
+  // std::shared_ptr<gnb_context> gc2;
+  // gc1->gnb_context_from_json(udsf_response);
+  // gc2 = std::shared_ptr<gnb_context>(gc1);
+
+  // udsf_url = "http://10.112.202.24:7123/nudsf-dr/v1/amfdata/" + std::string("ue_context/records/") + std::to_string(uc.get()->ran_ue_ngap_id) ;
+  // if(!amf_n2_inst->curl_http_client_udsf(udsf_url,"","GET",udsf_response)){
+  //   Logger::amf_n2().error("No existing gNG context with assoc_id (%d)", uc.get()->ran_ue_ngap_id);
+  //   return;
+  // }
+  // Logger::amf_n2().debug("udsf_response: %s", udsf_response.dump().c_str());
+
+
+  // ue_context *uc1 = new ue_context();
+  // std::shared_ptr<ue_context> uc2;
+  // uc1->ue_context_from_json(udsf_response);
+  // uc2 = std::shared_ptr<ue_context>(uc1);
+
+//printf("ran_ue_ngap_id-%d\n",uc2.get()->ran_ue_ngap_id);
+//printf("ng_ue_state-%d\n",unc2.get()->ng_ue_state);
+
+
+
+
+  /**********************   hxs add *******************************/  
     std::shared_ptr<itti_uplink_nas_data_ind> i =
         std::shared_ptr<itti_uplink_nas_data_ind>(itti_n1_msg);
     int ret = itti_inst->send_msg(i);
@@ -345,14 +410,27 @@ void amf_app::handle_post_sm_context_response_error_400() {
 bool amf_app::generate_5g_guti(
     uint32_t ranid, long amfid, string& mcc, string& mnc, uint32_t& tmsi) {
   string ue_context_key =
-      "app_ue_ranid_" + to_string(ranid) + ":amfid_" + to_string(amfid);
-  if (!is_ran_amf_id_2_ue_context(ue_context_key)) {
-    Logger::amf_app().error(
-        "No UE context for ran_amf_id %s, exit", ue_context_key.c_str());
+      "app_ue_ranid_" + to_string(ranid) + "-amfid_" + to_string(amfid);
+  // if (!is_ran_amf_id_2_ue_context(ue_context_key)) {
+  //   Logger::amf_app().error(
+  //       "No UE context for ran_amf_id %s, exit", ue_context_key.c_str());
+  //   return false;
+  // }
+  // std::shared_ptr<ue_context> uc;
+  // uc   = ran_amf_id_2_ue_context(ue_context_key);
+  ue_context *uc1 = new ue_context();
+  nlohmann::json udsf_response;
+  std::string udsf_url = "http://10.112.202.24:7123/nudsf-dr/v1/amfdata/" + std::string("ue_context/records/") + ue_context_key ;
+  if(!amf_n2_inst->curl_http_client_udsf(udsf_url,"","GET",udsf_response)){
+    Logger::amf_n2().error("No existing gNG context with assoc_id");
     return false;
   }
+  Logger::amf_n2().debug("udsf_response: %s", udsf_response.dump().c_str());
+  uc1->ue_context_from_json(udsf_response);
   std::shared_ptr<ue_context> uc;
-  uc   = ran_amf_id_2_ue_context(ue_context_key);
+  uc = std::shared_ptr<ue_context>(uc1);
+
+
   mcc  = uc.get()->tai.mcc;
   mnc  = uc.get()->tai.mnc;
   tmsi = golbal_tmsi;

src/amf-app/amf_n2.hpp

@@ -35,11 +35,14 @@
 #include "PduSessionResourceReleaseCommand.hpp"
 #include "itti_msg_n2.hpp"
 #include "ngap_app.hpp"
-#include "ue_ngap_context.hpp"
 
+#include "ue_ngap_context.hpp"
 #include "amf.hpp"
+#include <nlohmann/json.hpp>
 
-namespace amf_application {
+namespace amf_application{
+    
+#define UDSF_CURL_TIMEOUT_MS 100L
 
 class amf_n2 : public ngap::ngap_app {
  public:
@@ -73,6 +76,8 @@ class amf_n2 : public ngap::ngap_app {
   void set_ran_ue_ngap_id_2_ue_ngap_context(
       const uint32_t& ran_ue_ngap_id, std::shared_ptr<ue_ngap_context> unc);
 
+  bool curl_http_client_udsf(std::string remoteUri,std::string jsonData,std::string http_mothed,nlohmann::json &udsf_response) ;
+
  private:
   std::map<uint32_t, std::shared_ptr<ue_ngap_context>>
       ranid2uecontext;  // ran ue ngap id

src/contexts/CMakeLists.txt

@@ -35,10 +35,13 @@ include_directories(${SRC_TOP_DIR}/secu_algorithms/5gaka)
 include_directories(${SRC_TOP_DIR}/secu_algorithms/nas_enc_int)
 include_directories(${SRC_TOP_DIR}/utils)
 include_directories(${SRC_TOP_DIR}/utils/bstr)
+include_directories(${SRC_TOP_DIR}/sbi/amf_server/model)
 
 add_library (CONTEXTS STATIC
   ${CMAKE_CURRENT_SOURCE_DIR}/gNB_context.cpp
+  ${CMAKE_CURRENT_SOURCE_DIR}/ue_context.cpp
   ${CMAKE_CURRENT_SOURCE_DIR}/nas_context.cpp
+  ${CMAKE_CURRENT_SOURCE_DIR}/ue_ngap_context.cpp
   ${CMAKE_CURRENT_SOURCE_DIR}/pdu_session_context.cpp
 )
 

src/contexts/gNB_context.cpp

@@ -27,3 +27,173 @@
  */
 
 #include "gNB_context.hpp"
+#include <nlohmann/json.hpp>
+#include "logger.hpp"
+#include "Record.h"
+using namespace std;
+using namespace oai::amf::model;
+bool get_value_string(const nlohmann::json &j, const string & nm, string &value){
+
+  Record record;
+  nlohmann::json::parse(j.dump()).get_to(record);
+  std::set<nlohmann::json> block_set = record.getBlocks();   
+  std::set<nlohmann::json>::iterator it_block;  
+  for(it_block=block_set.begin();it_block!=block_set.end();)
+  {  
+      
+      if(it_block->at("Content-ID") == nm)
+      {
+        //if((it_block->at("Content-Type") == "varhcar")
+        value = it_block->at("content");
+        return true;
+      }
+      block_set.erase(it_block++); 
+  } 
+  return false;
+}
+// bool get_value_int(const nlohmann::json &j, const string & nm, long &value){
+//    Record record;
+//   nlohmann::json::parse(j.dump()).get_to(record);
+//   std::set<nlohmann::json> block_set = record.getBlocks();   
+//   std::set<nlohmann::json>::iterator it_block;  
+//   for(it_block=block_set.begin();it_block!=block_set.end();)
+//   {  
+      
+//       if(it_block->at("Content-ID") == nm)
+//       { 
+//         string  s  = it_block->at("content");
+//         value = atoi(s.c_str());
+//         return true;
+//       }
+//       block_set.erase(it_block++); 
+//   } 
+//   return false;
+// }
+long gnb_context::gnb_context_globalRanNodeId_from_json(nlohmann::json j)
+{
+    Record record;
+    nlohmann::json::parse(j.dump()).get_to(record);
+    std::set<nlohmann::json> block_set = record.getBlocks();   
+    std::set<nlohmann::json>::iterator it_block;  
+    for(it_block=block_set.begin();it_block!=block_set.end();)
+    {  
+        
+        if(it_block->at("Content-ID") == "globalRanNodeId")
+        { 
+            string  s  = it_block->at("content");
+            return atoi(s.c_str());
+        }
+        block_set.erase(it_block++); 
+    } 
+    Logger::amf_server().error("get_value from json  is error");
+    // long a;
+    // if(!get_value_int(j,"globalRanNodeId",a))
+    //     Logger::amf_server().error("get_value from json  is error");
+    // return a;
+}
+std::string gnb_context::gnb_context_gnb_name_from_json(nlohmann::json j)
+{
+    Record record;
+    nlohmann::json::parse(j.dump()).get_to(record);
+    std::set<nlohmann::json> block_set = record.getBlocks();   
+    std::set<nlohmann::json>::iterator it_block;  
+    for(it_block=block_set.begin();it_block!=block_set.end();)
+    {  
+        
+        if(it_block->at("Content-ID") == "gnb_name")
+        { 
+            string  s  = it_block->at("content");
+            return s;
+        }
+        block_set.erase(it_block++); 
+    } 
+    Logger::amf_server().error("get_value from json  is error");
+}
+int gnb_context::gnb_context_ng_state_from_json(nlohmann::json j)
+{
+    Record record;
+    nlohmann::json::parse(j.dump()).get_to(record);
+    std::set<nlohmann::json> block_set = record.getBlocks();   
+    std::set<nlohmann::json>::iterator it_block;  
+    for(it_block=block_set.begin();it_block!=block_set.end();)
+    {  
+        
+        if(it_block->at("Content-ID") == "ng_state")
+        { 
+            string  s  = it_block->at("content");
+            return atoi(s.c_str());
+        }
+        block_set.erase(it_block++); 
+    } 
+    Logger::amf_server().error("get_value from json  is error");
+}
+sctp_stream_id_t gnb_context::gnb_context_next_sctp_stream_from_json(nlohmann::json j)
+{
+    Record record;
+    nlohmann::json::parse(j.dump()).get_to(record);
+    std::set<nlohmann::json> block_set = record.getBlocks();   
+    std::set<nlohmann::json>::iterator it_block;  
+    for(it_block=block_set.begin();it_block!=block_set.end();)
+    {  
+        
+        if(it_block->at("Content-ID") == "next_sctp_stream")
+        { 
+            string  s  = it_block->at("content");
+            return atoi(s.c_str());
+        }
+        block_set.erase(it_block++); 
+    } 
+    Logger::amf_server().error("get_value from json  is error");
+}
+uint32_t gnb_context::gnb_context_sctp_assoc_id_from_json(nlohmann::json j)
+{
+    Record record;
+    nlohmann::json::parse(j.dump()).get_to(record);
+    std::set<nlohmann::json> block_set = record.getBlocks();   
+    std::set<nlohmann::json>::iterator it_block;  
+    for(it_block=block_set.begin();it_block!=block_set.end();)
+    {  
+        
+        if(it_block->at("Content-ID") == "sctp_assoc_id")
+        { 
+            string  s  = it_block->at("content");
+            return atoi(s.c_str());
+        }
+        block_set.erase(it_block++); 
+    } 
+    Logger::amf_server().error("get_value from json  is error");
+}
+sctp_stream_id_t gnb_context::gnb_context_instreams_from_json(nlohmann::json j)
+{
+    Record record;
+    nlohmann::json::parse(j.dump()).get_to(record);
+    std::set<nlohmann::json> block_set = record.getBlocks();   
+    std::set<nlohmann::json>::iterator it_block;  
+    for(it_block=block_set.begin();it_block!=block_set.end();)
+    {  
+        
+        if(it_block->at("Content-ID") == "instreams")
+        { 
+            string  s  = it_block->at("content");
+            return atoi(s.c_str());
+        }
+        block_set.erase(it_block++); 
+    } 
+    Logger::amf_server().error("get_value from json  is error");
+}
+bool gnb_context::gnb_context_from_json(nlohmann::json j)
+{
+    //std::shared_ptr<gnb_context> gc1;
+    sctp_assoc_id = gnb_context_sctp_assoc_id_from_json( j);
+    globalRanNodeId = gnb_context_globalRanNodeId_from_json(j);
+    gnb_name = gnb_context_gnb_name_from_json(j);
+    ng_state = amf_ng_gnb_state_s(gnb_context_ng_state_from_json(j));
+    next_sctp_stream = gnb_context_next_sctp_stream_from_json(j);
+    next_sctp_stream = gnb_context_instreams_from_json(j);
+
+    //     printf("gnbname-%s\n",gnb_name.c_str());
+    // printf("globalgnbid-%d\n",globalRanNodeId);
+    // printf("next stream-%d\n",next_sctp_stream);
+
+    return true;
+}

src/contexts/gNB_context.hpp

@@ -32,7 +32,7 @@
 #include <stdint.h>
 #include <string>
 #include <vector>
-
+#include <nlohmann/json.hpp>
 #include "sctp_server.hpp"
 #include "NgapIEsStruct.hpp"
 
@@ -43,10 +43,18 @@ extern "C" {
 
 using namespace sctp;
 using namespace ngap;
+using namespace std;
 
 enum amf_ng_gnb_state_s { NGAP_INIT, NGAP_RESETING, NGAP_READY, NGAP_SHUTDOWN };
 class gnb_context {
  public:
+ uint32_t gnb_context_sctp_assoc_id_from_json(nlohmann::json j);
+  long gnb_context_globalRanNodeId_from_json(nlohmann::json j);
+  std::string gnb_context_gnb_name_from_json(nlohmann::json j);
+  int gnb_context_ng_state_from_json(nlohmann::json j);
+  sctp_stream_id_t gnb_context_next_sctp_stream_from_json(nlohmann::json j);
+  sctp_stream_id_t gnb_context_instreams_from_json(nlohmann::json j);
+  bool gnb_context_from_json(nlohmann::json j);
   enum amf_ng_gnb_state_s ng_state;
 
   std::string gnb_name;

src/contexts/nas_context.cpp

@@ -27,7 +27,11 @@
  */
 
 #include "nas_context.hpp"
-
+#include <nlohmann/json.hpp>
+#include "logger.hpp"
+#include "Record.h"
+using namespace std;
+using namespace oai::amf::model;
 //------------------------------------------------------------------------------
 nas_context::nas_context() {
   security_ctx                                          = NULL;
@@ -49,3 +53,109 @@ nas_context::nas_context() {
 
 //------------------------------------------------------------------------------
 nas_context::~nas_context() {}
+
+uint32_t nas_context::nas_context_ran_ue_ngap_id_from_json(nlohmann::json j)
+{
+    Record record;
+    nlohmann::json::parse(j.dump()).get_to(record);
+    std::set<nlohmann::json> block_set = record.getBlocks();   
+    std::set<nlohmann::json>::iterator it_block;  
+    for(it_block=block_set.begin();it_block!=block_set.end();)
+    {  
+        
+        if(it_block->at("Content-ID") == "ran_ue_ngap_id")
+        { 
+            string  s  = it_block->at("content");
+            return atoi(s.c_str());
+        }
+        block_set.erase(it_block++); 
+    } 
+    Logger::amf_server().error("get_value from json  is error");
+}
+
+long nas_context::nas_context_amf_ue_ngap_id_from_json(nlohmann::json j)
+{
+    Record record;
+    nlohmann::json::parse(j.dump()).get_to(record);
+    std::set<nlohmann::json> block_set = record.getBlocks();   
+    std::set<nlohmann::json>::iterator it_block;  
+    for(it_block=block_set.begin();it_block!=block_set.end();)
+    {  
+        
+        if(it_block->at("Content-ID") == "amf_ue_ngap_id")
+        { 
+            string  s  = it_block->at("content");
+            return atoi(s.c_str());
+        }
+        block_set.erase(it_block++); 
+    } 
+    Logger::amf_server().error("get_value from json  is error");
+}
+
+bool nas_context::nas_context_ctx_avaliability_ind_from_json(nlohmann::json j)
+{
+    Record record;
+    nlohmann::json::parse(j.dump()).get_to(record);
+    std::set<nlohmann::json> block_set = record.getBlocks();   
+    std::set<nlohmann::json>::iterator it_block;  
+    for(it_block=block_set.begin();it_block!=block_set.end();)
+    {  
+        
+        if(it_block->at("Content-ID") == "ctx_avaliability_ind")
+        { 
+            string  s  = it_block->at("content");
+            return atoi(s.c_str());
+        }
+        block_set.erase(it_block++); 
+    } 
+    Logger::amf_server().error("get_value from json  is error");
+}
+
+std::string nas_context::nas_context_nas_status_from_json(nlohmann::json j)
+{
+    Record record;
+    nlohmann::json::parse(j.dump()).get_to(record);
+    std::set<nlohmann::json> block_set = record.getBlocks();   
+    std::set<nlohmann::json>::iterator it_block;  
+    for(it_block=block_set.begin();it_block!=block_set.end();)
+    {  
+        
+        if(it_block->at("Content-ID") == "nas_status")
+        { 
+            string  s  = it_block->at("content");
+            return s;
+        }
+        block_set.erase(it_block++); 
+    } 
+    Logger::amf_server().error("get_value from json  is error");
+}
+
+std::string nas_context::nas_context_serving_network_from_json(nlohmann::json j)
+{
+    Record record;
+    nlohmann::json::parse(j.dump()).get_to(record);
+    std::set<nlohmann::json> block_set = record.getBlocks();   
+    std::set<nlohmann::json>::iterator it_block;  
+    for(it_block=block_set.begin();it_block!=block_set.end();)
+    {  
+        
+        if(it_block->at("Content-ID") == "serving_network")
+        { 
+            string  s  = it_block->at("content");
+            return s;
+        }
+        block_set.erase(it_block++); 
+    } 
+    Logger::amf_server().error("get_value from json  is error");
+}
+
+bool nas_context::nas_context_from_json(nlohmann::json j)
+{
+  
+  ran_ue_ngap_id = nas_context_ran_ue_ngap_id_from_json(j);
+  amf_ue_ngap_id = nas_context_amf_ue_ngap_id_from_json(j);
+  ctx_avaliability_ind = nas_context_ctx_avaliability_ind_from_json(j);
+  nas_status = nas_context_nas_status_from_json(j);
+  serving_network = nas_context_serving_network_from_json(j);
+    return true;
+}
\ No newline at end of file

src/contexts/nas_context.hpp

@@ -36,6 +36,12 @@
 #include "nas_security_context.hpp"
 #include "security_def.hpp"
 #include "authentication_algorithms_with_5gaka.hpp"
+#include <nlohmann/json.hpp>
+#include "NgapIEsStruct.hpp"
+
+extern "C" {
+#include "Ngap_RRCEstablishmentCause.h"
+}
 
 typedef enum {
   _5GMM_STATE_MIN     = 0,
@@ -59,6 +65,12 @@ class nas_context {
  public:
   nas_context();
   ~nas_context();
+  bool nas_context_from_json(nlohmann::json j);
+  uint32_t nas_context_ran_ue_ngap_id_from_json(nlohmann::json j);
+  long nas_context_amf_ue_ngap_id_from_json(nlohmann::json j);
+  bool nas_context_ctx_avaliability_ind_from_json(nlohmann::json j);
+  std::string nas_context_nas_status_from_json(nlohmann::json j);
+  std::string nas_context_serving_network_from_json(nlohmann::json j);
   bool ctx_avaliability_ind;
   bool is_stacs_available;
   long amf_ue_ngap_id;

src/contexts/ue_context.cpp

+/*
+ * Licensed to the OpenAirInterface (OAI) Software Alliance under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The OpenAirInterface Software Alliance licenses this file to You under
+ * the OAI Public License, Version 1.1  (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.openairinterface.org/?page_id=698
+ *
+ * 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.
+ *-------------------------------------------------------------------------------
+ * For more information about the OpenAirInterface (OAI) Software Alliance:
+ *      contact@openairinterface.org
+ */
+
+/*! \file gNB_context.cpp
+ \brief
+ \author  Keliang DU, BUPT
+ \date 2020
+ \email: contact@openairinterface.org
+ */
+
+#include "ue_context.hpp"
+#include <nlohmann/json.hpp>
+#include "logger.hpp"
+#include "Record.h"
+using namespace std;
+using namespace oai::amf::model;
+
+
+uint32_t ue_context::ue_context_ran_ue_ngap_id_from_json(nlohmann::json j)
+{
+    Record record;
+    nlohmann::json::parse(j.dump()).get_to(record);
+    std::set<nlohmann::json> block_set = record.getBlocks();   
+    std::set<nlohmann::json>::iterator it_block;  
+    for(it_block=block_set.begin();it_block!=block_set.end();)
+    {  
+        
+        if(it_block->at("Content-ID") == "ran_ue_ngap_id")
+        { 
+            string  s  = it_block->at("content");
+            return atoi(s.c_str());
+        }
+        block_set.erase(it_block++); 
+    } 
+    Logger::amf_server().error("get_value from json  is error");
+}
+void ue_context::ue_context_tai_from_json(nlohmann::json j,Tai_t &tai_json)
+{
+    Record record;
+    nlohmann::json::parse(j.dump()).get_to(record);
+    std::set<nlohmann::json> block_set = record.getBlocks();   
+    std::set<nlohmann::json>::iterator it_block;  
+    for(it_block=block_set.begin();it_block!=block_set.end();)
+    {  
+        
+        if(it_block->at("Content-ID") == "tai")
+        { 
+            nlohmann::json  s;
+            string j;
+            j = it_block->at("content");
+            // s  = nlohmann::json::parse(j);
+            // s.at("mnc").get_to(tai_json.mnc);
+            // s.at("mcc").get_to(tai_json.mcc);
+
+        }
+        block_set.erase(it_block++); 
+    } 
+    Logger::amf_server().error("get_value from json  is error");
+}
+bool ue_context::ue_context_from_json(nlohmann::json j)
+{
+    //std::shared_ptr<gnb_context> gc1;
+    // globalRanNodeId = gnb_context_globalRanNodeId_from_json(j);
+    // gnb_name = gnb_context_gnb_name_from_json(j);
+    // ng_state = amf_ng_gnb_state_s(gnb_context_ng_state_from_json(j));
+    // next_sctp_stream = gnb_context_next_sctp_stream_from_json(j);
+    // next_sctp_stream = gnb_context_instreams_from_json(j);
+  ue_context_tai_from_json(j,tai);
+  ran_ue_ngap_id = ue_context_ran_ue_ngap_id_from_json(j);
+    //     printf("gnbname-%s\n",gnb_name.c_str());
+    // printf("globalgnbid-%d\n",globalRanNodeId);
+    // printf("next stream-%d\n",next_sctp_stream);
+
+    return true;
+}

src/contexts/ue_context.hpp

@@ -30,7 +30,7 @@
 #define _UE_CONTEXT_H_
 
 #include <stdint.h>
-
+#include <nlohmann/json.hpp>
 #include "NgapIEsStruct.hpp"
 
 extern "C" {
@@ -41,6 +41,9 @@ using namespace ngap;
 
 class ue_context {
  public:
+  void ue_context_tai_from_json(nlohmann::json j,Tai_t &tai_json);
+  bool ue_context_from_json(nlohmann::json j);
+  uint32_t ue_context_ran_ue_ngap_id_from_json(nlohmann::json j);
   uint32_t ran_ue_ngap_id;   // 32bits
   long amf_ue_ngap_id : 40;  // 40bits
 

src/contexts/ue_ngap_context.cpp

+/*
+ * Licensed to the OpenAirInterface (OAI) Software Alliance under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The OpenAirInterface Software Alliance licenses this file to You under
+ * the OAI Public License, Version 1.1  (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.openairinterface.org/?page_id=698
+ *
+ * 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.
+ *-------------------------------------------------------------------------------
+ * For more information about the OpenAirInterface (OAI) Software Alliance:
+ *      contact@openairinterface.org
+ */
+
+/*! \file gNB_context.cpp
+ \brief
+ \author  Keliang DU, BUPT
+ \date 2020
+ \email: contact@openairinterface.org
+ */
+
+#include "ue_ngap_context.hpp"
+#include <nlohmann/json.hpp>
+#include "logger.hpp"
+#include "Record.h"
+using namespace std;
+using namespace oai::amf::model;
+// long gnb_context::gnb_context_globalRanNodeId_from_json(nlohmann::json j)
+// {
+//     Record record;
+//     nlohmann::json::parse(j.dump()).get_to(record);
+//     std::set<nlohmann::json> block_set = record.getBlocks();   
+//     std::set<nlohmann::json>::iterator it_block;  
+//     for(it_block=block_set.begin();it_block!=block_set.end();)
+//     {  
+        
+//         if(it_block->at("Content-ID") == "globalRanNodeId")
+//         { 
+//             string  s  = it_block->at("content");
+//             return atoi(s.c_str());
+//         }
+//         block_set.erase(it_block++); 
+//     } 
+//     Logger::amf_server().error("get_value from json  is error");
+//     // long a;
+//     // if(!get_value_int(j,"globalRanNodeId",a))
+//     //     Logger::amf_server().error("get_value from json  is error");
+//     // return a;
+// }
+// std::string gnb_context::gnb_context_gnb_name_from_json(nlohmann::json j)
+// {
+//     Record record;
+//     nlohmann::json::parse(j.dump()).get_to(record);
+//     std::set<nlohmann::json> block_set = record.getBlocks();   
+//     std::set<nlohmann::json>::iterator it_block;  
+//     for(it_block=block_set.begin();it_block!=block_set.end();)
+//     {  
+        
+//         if(it_block->at("Content-ID") == "gnb_name")
+//         { 
+//             string  s  = it_block->at("content");
+//             return s;
+//         }
+//         block_set.erase(it_block++); 
+//     } 
+//     Logger::amf_server().error("get_value from json  is error");
+// }
+// int gnb_context::gnb_context_ng_state_from_json(nlohmann::json j)
+// {
+//     Record record;
+//     nlohmann::json::parse(j.dump()).get_to(record);
+//     std::set<nlohmann::json> block_set = record.getBlocks();   
+//     std::set<nlohmann::json>::iterator it_block;  
+//     for(it_block=block_set.begin();it_block!=block_set.end();)
+//     {  
+        
+//         if(it_block->at("Content-ID") == "ng_state")
+//         { 
+//             string  s  = it_block->at("content");
+//             return atoi(s.c_str());
+//         }
+//         block_set.erase(it_block++); 
+//     } 
+//     Logger::amf_server().error("get_value from json  is error");
+// }
+// sctp_stream_id_t gnb_context::gnb_context_next_sctp_stream_from_json(nlohmann::json j)
+// {
+//     Record record;
+//     nlohmann::json::parse(j.dump()).get_to(record);
+//     std::set<nlohmann::json> block_set = record.getBlocks();   
+//     std::set<nlohmann::json>::iterator it_block;  
+//     for(it_block=block_set.begin();it_block!=block_set.end();)
+//     {  
+        
+//         if(it_block->at("Content-ID") == "next_sctp_stream")
+//         { 
+//             string  s  = it_block->at("content");
+//             return atoi(s.c_str());
+//         }
+//         block_set.erase(it_block++); 
+//     } 
+//     Logger::amf_server().error("get_value from json  is error");
+// }
+uint32_t ue_ngap_context::ue_ngap_context_ran_ue_ngap_id_from_json(nlohmann::json j)
+{
+    Record record;
+    nlohmann::json::parse(j.dump()).get_to(record);
+    std::set<nlohmann::json> block_set = record.getBlocks();   
+    std::set<nlohmann::json>::iterator it_block;  
+    for(it_block=block_set.begin();it_block!=block_set.end();)
+    {  
+        
+        if(it_block->at("Content-ID") == "ran_ue_ngap_id")
+        { 
+            string  s  = it_block->at("content");
+            return atoi(s.c_str());
+        }
+        block_set.erase(it_block++); 
+    } 
+    Logger::amf_server().error("get_value from json  is error");
+}
+
+uint32_t ue_ngap_context::ue_ngap_context_gnb_assoc_id_from_json(nlohmann::json j)
+{
+    Record record;
+    nlohmann::json::parse(j.dump()).get_to(record);
+    std::set<nlohmann::json> block_set = record.getBlocks();   
+    std::set<nlohmann::json>::iterator it_block;  
+    for(it_block=block_set.begin();it_block!=block_set.end();)
+    {  
+        
+        if(it_block->at("Content-ID") == "gnb_assoc_id")
+        { 
+            string  s  = it_block->at("content");
+            return atoi(s.c_str());
+        }
+        block_set.erase(it_block++); 
+    } 
+    Logger::amf_server().error("get_value from json  is error");
+}
+
+
+int ue_ngap_context::ue_ngap_context_ng_ue_state_from_json(nlohmann::json j)
+{
+    Record record;
+    nlohmann::json::parse(j.dump()).get_to(record);
+    std::set<nlohmann::json> block_set = record.getBlocks();   
+    std::set<nlohmann::json>::iterator it_block;  
+    for(it_block=block_set.begin();it_block!=block_set.end();)
+    {  
+        
+        if(it_block->at("Content-ID") == "ng_ue_state")
+        { 
+            string  s  = it_block->at("content");
+            return atoi(s.c_str());
+        }
+        block_set.erase(it_block++); 
+    } 
+    Logger::amf_server().error("get_value from json  is error");
+}
+
+bool ue_ngap_context::ue_ngap_context_from_json(nlohmann::json j)
+{
+    //std::shared_ptr<gnb_context> gc1;
+    // globalRanNodeId = gnb_context_globalRanNodeId_from_json(j);
+    // gnb_name = gnb_context_gnb_name_from_json(j);
+    // ng_state = amf_ng_gnb_state_s(gnb_context_ng_state_from_json(j));
+    // next_sctp_stream = gnb_context_next_sctp_stream_from_json(j);
+    // next_sctp_stream = gnb_context_instreams_from_json(j);
+    gnb_assoc_id = ue_ngap_context_gnb_assoc_id_from_json( j);
+    ng_ue_state = ng_ue_state_t(ue_ngap_context_ng_ue_state_from_json(j));
+    ran_ue_ngap_id = ue_ngap_context_ran_ue_ngap_id_from_json(j);
+    //     printf("gnbname-%s\n",gnb_name.c_str());
+    // printf("globalgnbid-%d\n",globalRanNodeId);
+    // printf("next stream-%d\n",next_sctp_stream);
+
+    return true;
+}

src/contexts/ue_ngap_context.hpp

@@ -36,7 +36,6 @@
 
 using namespace sctp;
 using namespace ngap;
-
 typedef enum {
   NGAP_UE_INVALID_STATE,
   NGAP_UE_WAITING_CSR,  // Context Setup Response(CSR)
@@ -47,6 +46,10 @@ typedef enum {
 
 class ue_ngap_context {
  public:
+  sctp_assoc_id_t ue_ngap_context_ran_ue_ngap_id_from_json(nlohmann::json j);
+  uint32_t ue_ngap_context_gnb_assoc_id_from_json(nlohmann::json j);
+  int ue_ngap_context_ng_ue_state_from_json(nlohmann::json j);
+  bool ue_ngap_context_from_json(nlohmann::json j);
   uint32_t ran_ue_ngap_id;   // 32bits
   long amf_ue_ngap_id : 40;  // 40bits