# 0 "SCCP_Adapter.ttcnpp"
# 0 "<built-in>"
# 0 "<command-line>"
# 1 "SCCP_Adapter.ttcnpp"
module SCCP_Adapter {
# 18 "SCCP_Adapter.ttcnpp"
import from General_Types all;
import from Osmocom_Types all;

import from M3UA_Emulation all;
import from MTP3asp_Types all;
import from MTP3asp_PortType all;

import from IPA_Emulation all;

import from SCCP_Types all;
import from SCCPasp_Types all;
import from SCCP_Emulation all;
import from SCCP_Templates all;

import from SCTPasp_Types all;
import from SCTPasp_PortType all;

type enumerated SCCP_Adapter_Transport {
 SCCP_TRANSPORT_SIGTRAN,
 SCCP_TRANSPORT_SCCPlite
};

type record SCCP_Adapter_Config_Sigtran {
 SCTP_Association_Address sctp_addr

};

type record SCCP_Adapter_Config_Sccplite {
 SCTP_Association_Address tcp_addr,
 boolean tcp_is_server,
 IPA_CCM_Parameters ipa_ccm_pars optional
};

type union SCCP_Adapter_Transport_ConfigUnion {
 SCCP_Adapter_Config_Sigtran sigtran,
 SCCP_Adapter_Config_Sccplite sccplite
};

type record SCCP_Adapter_Config {
 SCCP_Adapter_Transport transport,
 SCCP_Adapter_Transport_ConfigUnion tpars,
 charstring sccp_service_type,
 integer own_pc,
 integer own_ssn,
 integer peer_pc,
 integer peer_ssn,
 octetstring sio,
 integer rctx
} with { variant (tpars) "CROSSTAG(sigtran, 	transport = SCCP_TRANSPORT_SIGTRAN;
       sccplite, transport = SCCP_TRANSPORT_SCCPlite;)"
};
type record of SCCP_Adapter_Config SCCP_Adapter_Configs;

type record SCCP_Adapter {

 M3UA_CT vc_M3UA,
 IPA_Emulation_CT vc_IPA,
 IPA_EventWaiter_CT vc_WAIT,
 SCCP_CT vc_SCCP,

 MSC_SCCP_MTP3_parameters sccp_pars,
 SCCP_PAR_Address sccp_addr_own,
 SCCP_PAR_Address sccp_addr_peer,
 SCCP_Adapter_Config cfg
};


private function init_pars(inout SCCP_Adapter ba, in SCCP_Adapter_Config cfg) {
 ba.sccp_pars := {
  sio := {
   ni := substr(oct2bit(cfg.sio),0,2),
   prio := substr(oct2bit(cfg.sio),2,2),
   si := substr(oct2bit(cfg.sio),4,4)
  },
  opc := cfg.own_pc,
  dpc := cfg.peer_pc,
  sls := 0,
  sccp_serviceType := cfg.sccp_service_type,
  ssn := cfg.own_ssn
 };
 ba.sccp_addr_own := valueof(ts_SccpAddr_PC_SSN(cfg.own_pc, cfg.own_ssn, cfg.sio, cfg.sccp_service_type));
 ba.sccp_addr_peer := valueof(ts_SccpAddr_PC_SSN(cfg.peer_pc, cfg.peer_ssn, cfg.sio, cfg.sccp_service_type));

 if (ischosen(cfg.tpars.sccplite)) {
  if (not ispresent(cfg.tpars.sccplite.ipa_ccm_pars)) {
   cfg.tpars.sccplite.ipa_ccm_pars := c_IPA_default_ccm_pars;
  }
 }

 ba.cfg := cfg;
}

function f_sccp_adapter_init(inout SCCP_Adapter ba, in SCCP_Adapter_Config cfg, charstring id) {
 init_pars(ba, cfg);


 ba.vc_SCCP := SCCP_CT.create(id & "-SCCP") alive;
 select (ba.cfg.transport) {
 case (SCCP_TRANSPORT_SIGTRAN) {
  var template (omit) integer rctx;
  if (not ispresent(ba.cfg.rctx)) {
   rctx := omit;
  } else {
   rctx := ba.cfg.rctx;
  }
  ba.vc_M3UA := M3UA_CT.create(id & "-M3UA") alive;
  map(ba.vc_M3UA:SCTP_PORT, system:sctp);

  connect(ba.vc_M3UA:MTP3_SP_PORT, ba.vc_SCCP:MTP3_SCCP_PORT);
  ba.vc_M3UA.start(f_M3UA_Emulation(ba.cfg.tpars.sigtran.sctp_addr, rctx));
  }
# 155 "SCCP_Adapter.ttcnpp"
 case else {
  setverdict(fail, "Unsuppored RAN_Transport");
  mtc.stop;
  }
 }


}

function f_sccp_adapter_start(inout SCCP_Adapter ba) {
 ba.vc_SCCP.start(SCCPStart(ba.sccp_pars));
}

function f_sccp_adapter_cleanup(inout SCCP_Adapter ba) {
 if (ba.cfg.transport == SCCP_TRANSPORT_SIGTRAN) {
  unmap(ba.vc_M3UA:SCTP_PORT, system:sctp);
  disconnect(ba.vc_M3UA:MTP3_SP_PORT, ba.vc_SCCP:MTP3_SCCP_PORT);
  ba.vc_M3UA.stop;
 }
 ba.vc_SCCP.stop;
}

} with { encode "RAW" };