#include <thread>
#include <iostream>
#include <memory>
-
+#include <algorithm>
#include <set>
#include <map>
#include <vector>
#include <string>
#include <unordered_map>
-
+#include<deque>
#include <rapidjson/document.h>
#include <rapidjson/writer.h>
#include <rapidjson/stringbuffer.h>
#include <rmr/RIC_message_types.h>
#include <ricxfcpp/xapp.hpp>
#include <ricxfcpp/config.hpp>
+#include<sstream>
/*
FIXME unfortunately this RMR flag has to be disabled
#include <grpcpp/client_context.h>
#include <grpcpp/create_channel.h>
#include <grpcpp/security/credentials.h>
-#include "protobuf/api.grpc.pb.h"
+#include "protobuf/rc.grpc.pb.h"
#include "utils/restclient.hpp"
// ----------------------------------------------------------
std::unique_ptr<Xapp> xfw;
-std::unique_ptr<api::MsgComm::Stub> rc_stub;
+std::unique_ptr<rc::MsgComm::Stub> rc_stub;
int downlink_threshold = 0; // A1 policy type 20008 (in percentage)
int serving_cell_rsrp;
}; */
+
+//https://stackoverflow.com/a/34571089/15098882
+
+static std::string base64_decode(const std::string &in) {
+
+ std::string out;
+
+ std::vector<int> T(256, -1);
+ for (int i = 0; i < 64; i++) T["ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/"[i]] = i;
+
+ int val = 0, valb = -8;
+ for (unsigned char c : in) {
+ if (T[c] == -1) break;
+ val = (val << 6) + T[c];
+ valb += 6;
+ if (valb >= 0) {
+ out.push_back(char((val >> valb) & 0xFF));
+ valb -= 8;
+ }
+ }
+ return out;
+}
+
struct PolicyHandler : public BaseReaderHandler<UTF8<>, PolicyHandler> {
/*
Assuming we receive the following payload from A1 Mediator
};
struct NodebHandler : public BaseReaderHandler<UTF8<>, NodebHandler> {
- string curr_key = "";
- shared_ptr<nodeb_t> nodeb = make_shared<nodeb_t>();
-
- bool Key(const Ch* str, SizeType length, bool copy) {
- curr_key = str;
- return true;
- }
-
- bool String(const Ch* str, SizeType length, bool copy) {
- if( curr_key.compare( "ranName" ) == 0 ) {
- nodeb->ran_name = str;
- } else if( curr_key.compare( "plmnId" ) == 0 ) {
- nodeb->global_nb_id.plmn_id = str;
- } else if( curr_key.compare( "nbId" ) == 0 ) {
- nodeb->global_nb_id.nb_id = str;
- } else if( curr_key.compare( "cellId" ) == 0 ) {
- cell_map[str] = nodeb;
- }
- return true;
- }
+ string curr_key = "";
+ shared_ptr<nodeb_t> nodeb = make_shared<nodeb_t>();
+ std::string meid;
+ std::vector<string> cells;
+
+ bool Key(const Ch* str, SizeType length, bool copy) {
+ curr_key = str;
+ return true;
+ }
+
+ bool String(const Ch* str, SizeType length, bool copy) {
+
+ if (curr_key.compare("ranName") == 0) {
+ //std::cout << str << "\n";
+ nodeb->ran_name = str;
+ meid= str;
+ //std::cout << "\n meid = " << meid;
+
+ }
+ else if (curr_key.compare("plmnId") == 0) {
+ //std::cout << str << "\n";
+ nodeb->global_nb_id.plmn_id = str;
+ }
+ else if (curr_key.compare("nbId") == 0) {
+ //std::cout <<str<< "\n";
+ nodeb->global_nb_id.nb_id = str;
+ }
+ else if (curr_key.compare("e2nodeComponentRequestPart") == 0) {
+ //std::cout << str<<"\n";
+ auto message = base64_decode(str);
+ //std::cout << message<<"\n";
+ int len = meid.length();
+ //std::cout << "\n meid = " << meid;
+ int counter = 0;
+ for (int i = 0; i <len; i++ ){
+ if (meid[i] == '_') {
+ counter++;
+ }
+ if( counter == 3) {
+ counter = i + 1;
+ break;
+ }
+ }
+ std::string last_matching_bits = meid.substr(counter, meid.length());
+ len = last_matching_bits.size();
+ char b;
+
+ for (int i = 0; i < len; i++) {
+ b = last_matching_bits[i];
+ b = toupper(b);
+ // b = to lower(b); //alternately
+ last_matching_bits[i] = b;
+ }
+ len = message.length();
+ //std::cout << "\nlast_matching_bits = " << last_matching_bits;
+ int matching_len = last_matching_bits.length();;
+
+ for (int i = 0; i <= len - matching_len; i++ ){
+ //std::cout << "\n" << message.substr(i, matching_len);
+
+ if (message.substr(i,matching_len)== last_matching_bits){
+ //std::cout << "\nmatched!\n";
+ cells.push_back(message.substr(i,10));//cell id is 36 bit long , last 4 bit unused
+
+ }
+ }
+ len = cells.size();
+ for (int i = 0; i < len; i++) {
+ cell_map[cells[i]] = nodeb;
+ }
+
+ }
+ return true;
+ }
};
-
/* struct UEDataHandler : public BaseReaderHandler<UTF8<>, UEDataHandler> {
unordered_map<string, string> cell_pred;
std::string serving_cell_id;
cout << "[INFO] Sending a HandOff CONTROL message to \"" << ts_control_ep << "\"\n";
cout << "[INFO] HandOff request is " << msg << endl;
- // sending request
- restclient::RestClient client( ts_control_ep );
- restclient::response_t resp = client.do_post( "", msg ); // we already have the full path in ts_control_ep
+ try {
+ // sending request
+ restclient::RestClient client( ts_control_ep );
+ restclient::response_t resp = client.do_post( "", msg ); // we already have the full path in ts_control_ep
+
+ if( resp.status_code == 200 ) {
+ // ============== DO SOMETHING USEFUL HERE ===============
+ // Currently, we only print out the HandOff reply
+ rapidjson::Document document;
+ document.Parse( resp.body.c_str() );
+ rapidjson::StringBuffer s;
+ rapidjson::PrettyWriter<rapidjson::StringBuffer> writer(s);
+ document.Accept( writer );
+ cout << "[INFO] HandOff reply is " << s.GetString() << endl;
- if( resp.status_code == 200 ) {
- // ============== DO SOMETHING USEFUL HERE ===============
- // Currently, we only print out the HandOff reply
- rapidjson::Document document;
- document.Parse( resp.body.c_str() );
- rapidjson::StringBuffer s;
- rapidjson::PrettyWriter<rapidjson::StringBuffer> writer(s);
- document.Accept( writer );
- cout << "[INFO] HandOff reply is " << s.GetString() << endl;
+ } else {
+ cout << "[ERROR] Unexpected HTTP code " << resp.status_code << " from " << \
+ client.getBaseUrl() << \
+ "\n[ERROR] HTTP payload is " << resp.body.c_str() << endl;
+ }
+
+ } catch( const restclient::RestClientException &e ) {
+ cout << "[ERROR] " << e.what() << endl;
- } else {
- cout << "[ERROR] Unexpected HTTP code " << resp.status_code << " from " << \
- client.getBaseUrl() << \
- "\n[ERROR] HTTP payload is " << resp.body.c_str() << endl;
}
}
void send_grpc_control_request( string ue_id, string target_cell_id ) {
grpc::ClientContext context;
- api::RicControlGrpcRsp response;
- shared_ptr<api::RicControlGrpcReq> request = make_shared<api::RicControlGrpcReq>();
+ rc::RicControlGrpcRsp response;
+ shared_ptr<rc::RicControlGrpcReq> request = make_shared<rc::RicControlGrpcReq>();
- api::RICE2APHeader *apHeader = request->mutable_rice2apheaderdata();
- apHeader->set_ranfuncid( 300 );
- apHeader->set_ricrequestorid( 1001 );
+ rc::RICE2APHeader *apHeader = request->mutable_rice2apheaderdata();
+ apHeader->set_ranfuncid(3);
+ apHeader->set_ricrequestorid( 1 );
- api::RICControlHeader *ctrlHeader = request->mutable_riccontrolheaderdata();
+ rc::RICControlHeader *ctrlHeader = request->mutable_riccontrolheaderdata();
ctrlHeader->set_controlstyle( 3 );
ctrlHeader->set_controlactionid( 1 );
- ctrlHeader->set_ueid( ue_id );
-
- api::RICControlMessage *ctrlMsg = request->mutable_riccontrolmessagedata();
- ctrlMsg->set_riccontrolcelltypeval( api::RIC_CONTROL_CELL_UNKWON );
- ctrlMsg->set_targetcellid( target_cell_id );
-
- auto data = cell_map.find( target_cell_id );
+ rc::UeId *ueid = ctrlHeader->mutable_ueid();
+ rc::gNBUEID* gnbue= ueid->mutable_gnbueid();
+ gnbue->set_amfuengapid(stoi(ue_id));
+ gnbue->add_gnbcuuef1apid(stoi(ue_id));
+ gnbue->add_gnbcucpuee1apid(stoi(ue_id));
+ rc::Guami* gumi=gnbue->mutable_guami();
+ //As of now hardcoded according to the value setted in VIAVI RSG TOOL
+ gumi->set_amfregionid("10100000");
+ gumi->set_amfsetid("0000000000");
+ gumi->set_amfpointer("000001");
+
+ //ctrlHeader->set_ueid( ue_id );
+
+ rc::RICControlMessage *ctrlMsg = request->mutable_riccontrolmessagedata();
+ ctrlMsg->set_riccontrolcelltypeval( rc::RICControlCellTypeEnum::RIC_CONTROL_CELL_UNKWON );
+ //ctrlMsg->set_riccontrolcelltypeval( api::RIC_CONTROL_CELL_UNKWON);
+
+ ctrlMsg->set_targetcellid( target_cell_id);
+
+ auto data = cell_map.find(target_cell_id);
if( data != cell_map.end() ) {
request->set_e2nodeid( data->second->global_nb_id.nb_id );
request->set_plmnid( data->second->global_nb_id.plmn_id );
request->set_ranname( data->second->ran_name );
+ gumi->set_plmnidentity(data->second->global_nb_id.plmn_id);
} else {
+ cout << "[INFO] Cannot find RAN name corresponding to cell id = "<<target_cell_id<<endl;
+ return;
request->set_e2nodeid( "unknown_e2nodeid" );
request->set_plmnid( "unknown_plmnid" );
request->set_ranname( "unknown_ranname" );
+ gumi->set_plmnidentity("unknown_plmnid");
}
- request->set_riccontrolackreqval( api::RIC_CONTROL_ACK_UNKWON ); // not yet used in api.proto
-
+ request->set_riccontrolackreqval( rc::RICControlAckEnum::RIC_CONTROL_ACK_UNKWON );
+ //request->set_riccontrolackreqval( api::RIC_CONTROL_ACK_UNKWON); // not yet used in api.proto
+ cout<<"\nin ts xapp grpc message content \n"<< request->DebugString()<<"\n";
grpc::Status status = rc_stub->SendRICControlReqServiceGrpc( &context, *request, &response );
if( status.ok() ) {
base_url = string( data );
}
- restclient::RestClient client( base_url );
-
- vector<string> nb_list = get_nodeb_list( client );
+ try {
+ restclient::RestClient client( base_url );
+
+ vector<string> nb_list = get_nodeb_list( client );
+
+ for( string nb : nb_list ) {
+ string full_path = string("/v1/nodeb/") + nb;
+ restclient::response_t response = client.do_get( full_path );
+ if( response.status_code != 200 ) {
+ if( response.body.empty() ) {
+ cout << "[ERROR] Unexpected HTTP code " << response.status_code << " from " << \
+ client.getBaseUrl() + full_path << endl;
+ } else {
+ cout << "[ERROR] Unexpected HTTP code " << response.status_code << " from " << \
+ client.getBaseUrl() + full_path << ". HTTP payload is " << response.body.c_str() << endl;
+ }
+ return false;
+ }
- for( string nb : nb_list ) {
- string full_path = string("/v1/nodeb/") + nb;
- restclient::response_t response = client.do_get( full_path );
- if( response.status_code != 200 ) {
- if( response.body.empty() ) {
- cout << "[ERROR] Unexpected HTTP code " << response.status_code << " from " << \
- client.getBaseUrl() + full_path << endl;
- } else {
- cout << "[ERROR] Unexpected HTTP code " << response.status_code << " from " << \
- client.getBaseUrl() + full_path << ". HTTP payload is " << response.body.c_str() << endl;
+ try {
+ NodebHandler handler;
+ Reader reader;
+ StringStream ss( response.body.c_str() );
+ reader.Parse( ss, handler );
+ } catch (...) {
+ cout << "[ERROR] Got an exception on parsing nodeb (stringstream read parse)\n";
+ return false;
}
- return false;
}
- try {
- NodebHandler handler;
- Reader reader;
- StringStream ss( response.body.c_str() );
- reader.Parse( ss, handler );
- } catch (...) {
- cout << "[ERROR] Got an exception on parsing nodeb (stringstream read parse)\n";
- return false;
- }
+ } catch( const restclient::RestClientException &e ) {
+ cout << "[ERROR] " << e.what() << endl;
+ return false;
}
return true;
}
channel = grpc::CreateChannel(ts_control_ep, grpc::InsecureChannelCredentials());
- rc_stub = api::MsgComm::NewStub(channel, grpc::StubOptions());
+ rc_stub = rc::MsgComm::NewStub(channel, grpc::StubOptions());
}
- fprintf( stderr, "[TS xApp] listening on port %s\n", port );
+ fprintf( stderr, "[INFO] listening on port %s\n", port );
xfw = std::unique_ptr<Xapp>( new Xapp( port, true ) );
xfw->Add_msg_cb( A1_POLICY_REQ, policy_callback, NULL ); // msg type 20010
Code Review / ric-app / ts.git / blobdiff