Commit 1db7f333 authored by YannGarcia's avatar YannGarcia
Browse files

Validate ITS-S enrolment/authorization

parent 5e5bd48b

ccsrc/Framework/include/params.hh

+6 −4
Original line number Original line Diff line number Diff line
@@ -85,6 +85,8 @@ public: //! \publicsection 
  static const std::string& uu_transport;   //! Uu interafce transport (TCP, UDP)

  static const std::string& uu_transport;   //! Uu interafce transport (TCP, UDP)

  static const std::string& pc5_layer;      //! Radio specific layer for PC5 (e.g. Qualcomm, Commsignia)

  static const std::string& pc5_layer;      //! Radio specific layer for PC5 (e.g. Qualcomm, Commsignia)

  static const std::string& mqtt_topics;    //! Uu interafce MQTT topics

  static const std::string& mqtt_topics;    //! Uu interafce MQTT topics

  static const std::string& mqtt_protocol;  //! Uu interafce MQTT protocol name

  static const std::string& mqtt_client_id; //! Uu interafce MQTT client identity





  static const std::string& server;      //! HTTP server address (e.g. www.etsi.org)

  static const std::string& server;      //! HTTP server address (e.g. www.etsi.org)

  static const std::string& port;        //! HTTP server port. Default: 80

  static const std::string& port;        //! HTTP server port. Default: 80

ccsrc/Framework/src/params.cc

+2 −0
Original line number Original line Diff line number Diff line
@@ -76,6 +76,8 @@ const std::string& params::uu_protocol = std::string("uu_protocol"); 
const std::string& params::uu_transport = std::string("uu_transport");

const std::string& params::uu_transport = std::string("uu_transport");

const std::string& params::pc5_layer = std::string("pc5_layer");

const std::string& params::pc5_layer = std::string("pc5_layer");

const std::string& params::mqtt_topics  = std::string("mqtt_topics");

const std::string& params::mqtt_topics  = std::string("mqtt_topics");

const std::string& params::mqtt_protocol  = std::string("mqtt_protocol");

const std::string& params::mqtt_client_id  = std::string("mqtt_client_id");





const std::string& params::server      = std::string("server");

const std::string& params::server      = std::string("server");

const std::string& params::port        = std::string("port");

const std::string& params::port        = std::string("port");

ccsrc/Ports/LibIts_ports/Pki_ports/UpperTesterPkiPort.cc

+11 −0
Original line number Original line Diff line number Diff line
@@ -84,6 +84,15 @@ namespace LibItsPki__TestSystem { 
    loggers::get_instance().set_stop_time(_time_key, duration);

    loggers::get_instance().set_stop_time(_time_key, duration);

  }

  }





  void UpperTesterPkiPort::outgoing_send(const LibItsPki__TypesAndValues::UtPkiTriggerInd &send_par) {

    loggers::get_instance().log_msg(">>> UppertesterPort::outgoing_send: ", send_par);



    float duration;

    loggers::get_instance().set_start_time(_time_key);

    static_cast<uppertester_pki_layer *>(_layer)->sendMsg(send_par, _layer_params);

    loggers::get_instance().set_stop_time(_time_key, duration);

  }



  void UpperTesterPkiPort::receiveMsg(const Base_Type &p_ind, const params &p_params) {

  void UpperTesterPkiPort::receiveMsg(const Base_Type &p_ind, const params &p_params) {

    loggers::get_instance().log_msg(">>> UpperTesterPkiPort_Pki::receive_msg: ", p_ind);

    loggers::get_instance().log_msg(">>> UpperTesterPkiPort_Pki::receive_msg: ", p_ind);

    // Sanity check

    // Sanity check
@@ -93,6 +102,8 @@ namespace LibItsPki__TestSystem { 




    if (std::string(p_ind.get_descriptor()->name).compare("@LibItsPki_TypesAndValues.UtPkiResults") == 0) { // TODO To be refined

    if (std::string(p_ind.get_descriptor()->name).compare("@LibItsPki_TypesAndValues.UtPkiResults") == 0) { // TODO To be refined

      incoming_message(static_cast<const LibItsPki__TypesAndValues::UtPkiResults &>(p_ind));

      incoming_message(static_cast<const LibItsPki__TypesAndValues::UtPkiResults &>(p_ind));

    } else if (std::string(p_ind.get_descriptor()->name).compare("@LibItsPki_TypesAndValues.UtPkiTriggerInd") == 0) { // TODO To be refined

      incoming_message(static_cast<const LibItsPki__TypesAndValues::UtPkiTriggerInd &>(p_ind));

    } else {

    } else {

      loggers::get_instance().warning("UpperTesterPkiPort_Pki::receive_msg: Message not processed: %s", p_ind.get_descriptor()->name);

      loggers::get_instance().warning("UpperTesterPkiPort_Pki::receive_msg: Message not processed: %s", p_ind.get_descriptor()->name);

    }

    }

ccsrc/Ports/LibIts_ports/Pki_ports/UpperTesterPkiPort.hh

+2 −0
Original line number Original line Diff line number Diff line
@@ -40,6 +40,8 @@ namespace LibItsPki__TestSystem { 
    void outgoing_send(const LibItsPki__TypesAndValues::UtPkiInitialize &send_par);

    void outgoing_send(const LibItsPki__TypesAndValues::UtPkiInitialize &send_par);





    void outgoing_send(const LibItsPki__TypesAndValues::UtPkiTrigger &send_par);

    void outgoing_send(const LibItsPki__TypesAndValues::UtPkiTrigger &send_par);



    void outgoing_send(const LibItsPki__TypesAndValues::UtPkiTriggerInd &send_par);

  };

  };





} // namespace LibItsPki__TestSystem

} // namespace LibItsPki__TestSystem

ccsrc/Ports/LibIts_ports/RSUsSimulator_ports/ConfigRsuSimulatorLayer.cc

+20 −8
Original line number Original line Diff line number Diff line
@@ -57,7 +57,8 @@ void ConfigRsuSimulatorLayer::sendMsg(const LibItsGeoNetworking__TypesAndValues: 
  }

  }





  OCTETSTRING os(encoding_buffer.get_len(), encoding_buffer.get_data());

  OCTETSTRING os(encoding_buffer.get_len(), encoding_buffer.get_data());

  send_data(os, _params);



  send_data(os, params);

}

}





void ConfigRsuSimulatorLayer::sendMsg(const LibItsGeoNetworking__TypesAndValues::UtGnEventInd &send_par, params &params) {

void ConfigRsuSimulatorLayer::sendMsg(const LibItsGeoNetworking__TypesAndValues::UtGnEventInd &send_par, params &params) {
@@ -88,7 +89,7 @@ void ConfigRsuSimulatorLayer::sendMsg(const LibItsCam__TypesAndValues::UtCamResu 
  }

  }





  OCTETSTRING os(encoding_buffer.get_len(), encoding_buffer.get_data());

  OCTETSTRING os(encoding_buffer.get_len(), encoding_buffer.get_data());

  send_data(os, _params);

  send_data(os, params);

}

}





void ConfigRsuSimulatorLayer::sendMsg(const LibItsCam__TypesAndValues::UtCamEventInd &send_par, params &params) {

void ConfigRsuSimulatorLayer::sendMsg(const LibItsCam__TypesAndValues::UtCamEventInd &send_par, params &params) {
@@ -137,7 +138,7 @@ void ConfigRsuSimulatorLayer::sendMsg(const LibItsDenm__TypesAndValues::UtDenmRe 
  }

  }





  OCTETSTRING os(encoding_buffer.get_len(), encoding_buffer.get_data());

  OCTETSTRING os(encoding_buffer.get_len(), encoding_buffer.get_data());

  send_data(os, _params);

  send_data(os, params);

}

}





void ConfigRsuSimulatorLayer::sendMsg(const LibItsDenm__TypesAndValues::UtDenmEventInd &send_par, params &params) {

void ConfigRsuSimulatorLayer::sendMsg(const LibItsDenm__TypesAndValues::UtDenmEventInd &send_par, params &params) {
@@ -170,7 +171,18 @@ void ConfigRsuSimulatorLayer::sendMsg(const LibItsPki__TypesAndValues::UtPkiResu 
  }

  }





  OCTETSTRING os(encoding_buffer.get_len(), encoding_buffer.get_data());

  OCTETSTRING os(encoding_buffer.get_len(), encoding_buffer.get_data());

  send_data(os, _params);

  send_data(os, params);

}



void ConfigRsuSimulatorLayer::sendMsg(const LibItsPki__TypesAndValues::UtPkiTriggerInd &send_par, params &params) {

  loggers::get_instance().log_msg(">>> ConfigRsuSimulatorLayer::sendMsg: ", send_par);



  TTCN_Buffer encoding_buffer;

  encoding_buffer.put_c(static_cast<const unsigned char>(uppertester_pki_codec::c_utPkiTriggerInd));

  encoding_buffer.put_c(static_cast<const unsigned char>(send_par.state()));



  OCTETSTRING os(encoding_buffer.get_len(), encoding_buffer.get_data());

  send_data(os, params);

}

}





void ConfigRsuSimulatorLayer::sendMsg(const LibItsIvim__TypesAndValues::UtIvimResults &send_par, params &params) {

void ConfigRsuSimulatorLayer::sendMsg(const LibItsIvim__TypesAndValues::UtIvimResults &send_par, params &params) {
@@ -203,7 +215,7 @@ void ConfigRsuSimulatorLayer::sendMsg(const LibItsIvim__TypesAndValues::UtIvimRe 
  }

  }





  OCTETSTRING os(encoding_buffer.get_len(), encoding_buffer.get_data());

  OCTETSTRING os(encoding_buffer.get_len(), encoding_buffer.get_data());

  send_data(os, _params);

  send_data(os, params);

}

}





void ConfigRsuSimulatorLayer::sendMsg(const LibItsIvim__TypesAndValues::UtIvimEventInd &send_par, params &params) {

void ConfigRsuSimulatorLayer::sendMsg(const LibItsIvim__TypesAndValues::UtIvimEventInd &send_par, params &params) {
@@ -236,7 +248,7 @@ void ConfigRsuSimulatorLayer::sendMsg(const LibItsMapemSpatem__TypesAndValues::U 
  }

  }





  OCTETSTRING os(encoding_buffer.get_len(), encoding_buffer.get_data());

  OCTETSTRING os(encoding_buffer.get_len(), encoding_buffer.get_data());

  send_data(os, _params);

  send_data(os, params);

}

}





void ConfigRsuSimulatorLayer::sendMsg(const LibItsMapemSpatem__TypesAndValues::UtMapemEventInd &send_par, params &params) {

void ConfigRsuSimulatorLayer::sendMsg(const LibItsMapemSpatem__TypesAndValues::UtMapemEventInd &send_par, params &params) {
@@ -289,7 +301,7 @@ void ConfigRsuSimulatorLayer::sendMsg(const LibItsSremSsem__TypesAndValues::UtSr 
  }

  }





  OCTETSTRING os(encoding_buffer.get_len(), encoding_buffer.get_data());

  OCTETSTRING os(encoding_buffer.get_len(), encoding_buffer.get_data());

  send_data(os, _params);

  send_data(os, params);

}

}





void ConfigRsuSimulatorLayer::sendMsg(const LibItsSremSsem__TypesAndValues::UtSremEventInd &send_par, params &params) {

void ConfigRsuSimulatorLayer::sendMsg(const LibItsSremSsem__TypesAndValues::UtSremEventInd &send_par, params &params) {
@@ -342,7 +354,7 @@ void ConfigRsuSimulatorLayer::sendMsg(const LibItsRtcmem__TypesAndValues::UtRtcm 
  }

  }





  OCTETSTRING os(encoding_buffer.get_len(), encoding_buffer.get_data());

  OCTETSTRING os(encoding_buffer.get_len(), encoding_buffer.get_data());

  send_data(os, _params);

  send_data(os, params);

}

}





void ConfigRsuSimulatorLayer::sendMsg(const LibItsRtcmem__TypesAndValues::UtRtcmemEventInd &send_par, params &params) {

void ConfigRsuSimulatorLayer::sendMsg(const LibItsRtcmem__TypesAndValues::UtRtcmemEventInd &send_par, params &params) {