/*
 * 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 ngap_app.hpp
 \brief
 \author  Keliang DU, BUPT
 \date 2020
 \email: contact@openairinterface.org
 */

#ifndef _NGAP_APPLICATION_H_
#define _NGAP_APPLICATION_H_

#include <map>
#include <shared_mutex>
#include <string>

#include "gNB_context.hpp"
#include "sctp_server.hpp"

using namespace sctp;

namespace ngap {

static const char* const ng_gnb_state_str[] = {"NGAP_INIT", "NGAP_RESETTING",
                                               "NGAP_READY", "NGAP_SHUTDOWN"};

class ngap_app : public sctp_application {
 public:
  ngap_app(const std::string& address, const uint16_t port_num);
  ~ngap_app();
  uint32_t getPpid();

  /*
   * Handle SCTP payload (decode it and send ITTI msg to N2)
   * @param [bstring] payload: payload
   * @param [sctp_assoc_id_t] assoc_id: gNB association ID
   * @param [sctp_stream_id_t] stream: stream
   * @param [sctp_stream_id_t] instreams: instreams
   * @param [sctp_stream_id_t] outstreams: outstreams
   * @return void:
   */
  void handle_receive(
      bstring payload, sctp_assoc_id_t assoc_id, sctp_stream_id_t stream,
      sctp_stream_id_t instreams, sctp_stream_id_t outstreams);

  /*
   * Handle new SCTP TNL Association (clause 8.7.1.1, 3gpp ts38.413)
   * @param [sctp_assoc_id_t] assoc_id: gNB association ID
   * @param [sctp_stream_id_t] instreams: instreams
   * @param [sctp_stream_id_t] outstreams: outstreams
   * @return void:
   */
  void handle_sctp_new_association(
      sctp_assoc_id_t assoc_id, sctp_stream_id_t instreams,
      sctp_stream_id_t outstreams);

  void handle_sctp_shutdown(sctp_assoc_id_t assoc_id);

  bool is_assoc_id_2_gnb_context(const sctp_assoc_id_t& assoc_id) const;
  void set_assoc_id_2_gnb_context(
      const sctp_assoc_id_t& assoc_id, std::shared_ptr<gnb_context> gc);
  std::shared_ptr<gnb_context> assoc_id_2_gnb_context(
      const sctp_assoc_id_t& assoc_id) const;
  bool is_gnb_id_2_gnb_context(const long& gnb_id) const;
  void set_gnb_id_2_gnb_context(
      const long& gnb_id, std::shared_ptr<gnb_context> gc);
  std::shared_ptr<gnb_context> gnb_id_2_gnb_context(const long& gnb_id) const;

  void remove_gnb_context(const long& gnb_id);

 protected:
  sctp_server sctp_s_38412;
  uint32_t ppid_;
  std::map<sctp_assoc_id_t, std::shared_ptr<gnb_context>> assoc2gnbContext;
  mutable std::shared_mutex m_assoc2gnbContext;
  std::map<long, std::shared_ptr<gnb_context>> gnbid2gnbContext;
  mutable std::shared_mutex m_gnbid2gnbContext;
};

}  // namespace ngap

#endif
