blob: fb9f98bcce0e45a2dbce4fcf6f01bdb19cc38f71 [file] [log] [blame]
Pau Espin Pedrol965ac642023-10-16 18:12:45 +02001module EPDG_Tests {
2
3import from Misc_Helpers all;
4import from General_Types all;
Pau Espin Pedrold19fdf52023-10-19 16:58:24 +02005import from Native_Functions all;
Pau Espin Pedrol965ac642023-10-16 18:12:45 +02006import from Osmocom_Types all;
7import from L3_Common all;
Pau Espin Pedrolc2cfd552024-02-07 17:51:55 +01008import from DNS_Helpers all;
Pau Espin Pedrolbf03d772024-03-01 16:15:21 +01009import from IP_Types all;
10import from ICMP_Types all;
11import from ICMP_Templates all;
Pau Espin Pedrol965ac642023-10-16 18:12:45 +020012
13import from IPA_Emulation all;
Pau Espin Pedrolce1d3cb2024-02-21 17:40:59 +010014import from PCO_Types all;
Pau Espin Pedrol965ac642023-10-16 18:12:45 +020015import from GSUP_Types all;
Pau Espin Pedrol8f1403a2024-01-18 20:08:43 +010016import from GSUP_Templates all;
17import from GSUP_Emulation all;
Pau Espin Pedrol965ac642023-10-16 18:12:45 +020018
19import from DIAMETER_Types all;
20import from DIAMETER_Templates all;
Pau Espin Pedrol4669b612023-10-23 17:43:14 +020021import from DIAMETER_ts29_273_Templates all;
Pau Espin Pedrol965ac642023-10-16 18:12:45 +020022import from DIAMETER_Emulation all;
23
Pau Espin Pedrol65a7f762024-02-29 21:07:58 +010024import from GTPv1U_CodecPort all;
25import from GTPU_Types all;
26import from GTPv1U_Templates all;
27
Pau Espin Pedrold19fdf52023-10-19 16:58:24 +020028import from GTPv2_Types all;
29import from GTPv2_Templates all;
Pau Espin Pedrol965ac642023-10-16 18:12:45 +020030import from GTPv2_Emulation all;
31
32modulepar {
33 /* our emulated GSUP strongswan (CEAI iface) */
34 charstring mp_gsup_local_ip := "127.0.0.100";
35 integer mp_gsup_local_port := 0;
36 charstring mp_gsup_remote_ip := "127.0.0.1";
37 integer mp_gsup_remote_port := 4222;
38
39 /* our emulated HSS */
40 charstring mp_swx_local_ip := "127.0.0.100";
41 integer mp_swx_local_port := 3868;
42
43 /* our emulated PGW (Diameter S6b) */
44 charstring mp_s6b_local_ip := "127.0.0.100";
45 integer mp_s6b_local_port := 3869;
Pau Espin Pedrolcdd41622023-10-23 14:38:20 +020046 charstring mp_s6b_remote_ip := "127.0.0.1";
47 integer mp_s6b_remote_port := 3869;
Pau Espin Pedrol8586b262024-02-09 18:12:21 +010048 /* 3GPP TS 23.003 clause 19: "nai.epc.mnc<MNC>.mcc<MCC>.3gppnetwork.org" */
49 charstring mp_s6b_nai_realm := "nai.epc.mnc001.mcc01.3gppnetwork.org";
Pau Espin Pedrol965ac642023-10-16 18:12:45 +020050
51 /* our emulated PGW (GTPv2C S2b) */
52 charstring mp_s2b_local_ip := "127.0.0.100";
53 integer mp_s2b_local_port := GTP2C_PORT;
54 charstring mp_s2b_remote_ip := "127.0.0.1";
55 integer mp_s2b_remote_port := GTP2C_PORT;
Pau Espin Pedrolf2925862024-02-22 20:12:30 +010056 charstring mp_s2b_dns_ipv4 := "1.2.3.4";
57 charstring mp_s2b_dns_ipv6 := "::1";
58 charstring mp_s2b_pcscf_ipv4 := "5.6.7.8";
59 charstring mp_s2b_pcscf_ipv6 := "::2";
Pau Espin Pedrol65a7f762024-02-29 21:07:58 +010060 /* our emulated PGW /* GTP1U */
61 charstring mp_upf_gtpu_local_ip := "127.0.0.100";
Pau Espin Pedrol965ac642023-10-16 18:12:45 +020062
63 charstring mp_diam_realm := "localdomain";
Pau Espin Pedrolc13a4cd2024-01-16 17:28:25 +010064 integer mp_diam_watchdog_initial_wait_sec := 6*3;
Pau Espin Pedrol965ac642023-10-16 18:12:45 +020065}
66
Pau Espin Pedrol285a2b62024-02-27 18:25:45 +010067type port Coord_PT message
68{
69 inout charstring;
70} with { extension "internal" };
71private const charstring COORD_CMD_READY := "COORD_CMD_READY";
72private const charstring COORD_CMD_START := "COORD_CMD_START";
73private const charstring COORD_CMD_ATTACHED := "COORD_CMD_ATTACHED";
74private const charstring COORD_CMD_STOP := "COORD_CMD_STOP";
Pau Espin Pedrol965ac642023-10-16 18:12:45 +020075
76type component MTC_CT {
77 var DIAMETER_Emulation_CT vc_SWx;
78 port DIAMETER_PT SWx_UNIT;
79 port DIAMETEREM_PROC_PT SWx_PROC;
80
81 var DIAMETER_Emulation_CT vc_S6b;
82 port DIAMETER_PT S6b_UNIT;
83 port DIAMETEREM_PROC_PT S6b_PROC;
84
85 var GSUP_Emulation_CT vc_GSUP;
86 var IPA_Emulation_CT vc_GSUP_IPA;
87 port IPA_CTRL_PT GSUP_IPA_EVENT;
88
89 var GTPv2_Emulation_CT vc_GTP2;
90 port GTP2EM_PT TEID0;
91
Pau Espin Pedrol285a2b62024-02-27 18:25:45 +010092 port Coord_PT COORD;
93
Pau Espin Pedrol965ac642023-10-16 18:12:45 +020094 timer g_Tguard;
95};
96
97private altstep as_Tguard() runs on MTC_CT {
98 [] g_Tguard.timeout {
99 Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail, "Tguard timeout");
100 }
101}
102
103type component DIAMETER_ConnHdlr_CT extends DIAMETER_ConnHdlr {
104 port DIAMETER_Conn_PT DIAMETER_CLIENT;
105 port DIAMETEREM_PROC_PT DIAMETER_PROC_CLIENT;
106}
107
108function f_diam_connhldr_ct_main(hexstring imsi) runs on DIAMETER_ConnHdlr_CT {
109 var DIAMETER_ConnHdlr vc_conn_unused;
110 var PDU_DIAMETER msg;
111 var UINT32 ete_id;
112
113 f_diameter_expect_imsi(imsi);
114
Pau Espin Pedrol965ac642023-10-16 18:12:45 +0200115 while (true) {
116 alt {
117 [] DIAMETER_CLIENT.receive(PDU_DIAMETER:?) -> value msg {
118 DIAMETER.send(msg);
119 }
120 [] DIAMETER.receive(PDU_DIAMETER:?) -> value msg {
121 DIAMETER_CLIENT.send(msg);
122 }
123 [] DIAMETER_PROC_CLIENT.getcall(DIAMETEREM_register_eteid:{?,?}) -> param(ete_id, vc_conn_unused) {
124 DIAMETER_PROC.call(DIAMETEREM_register_eteid:{ete_id, self}) {
125 [] DIAMETER_PROC.getreply(DIAMETEREM_register_eteid:{?,?}) {};
126 }
127 DIAMETER_PROC_CLIENT.reply(DIAMETEREM_register_eteid:{ete_id, vc_conn_unused});
128 }
129 }
130 }
131}
132
133type component EPDG_ConnHdlr extends DIAMETER_ConnHdlr, GSUP_ConnHdlr, GTP2_ConnHdlr {
134 var EPDG_ConnHdlrPars g_pars;
135
136 port DIAMETER_Conn_PT SWx;
137 port DIAMETEREM_PROC_PT SWx_PROC;
138 port DIAMETER_Conn_PT S6b;
139 port DIAMETEREM_PROC_PT S6b_PROC;
Pau Espin Pedrol285a2b62024-02-27 18:25:45 +0100140 port Coord_PT COORD;
Pau Espin Pedrol965ac642023-10-16 18:12:45 +0200141};
Pau Espin Pedrol285a2b62024-02-27 18:25:45 +0100142type record of EPDG_ConnHdlr EPDG_ConnHdlrList;
Pau Espin Pedrol965ac642023-10-16 18:12:45 +0200143
Pau Espin Pedrold4a20082023-10-23 19:59:24 +0200144type record BearerConfig {
145 /* EPS Bearer ID */
146 uint4_t ebi optional,
147 /* TEI (Data) local side */
148 OCT4 teid_local optional,
149 /* TEI (Data) remote side */
Pau Espin Pedrola9b65f12024-02-29 21:08:15 +0100150 OCT4 teid_remote optional,
151 /* GTP-U address of the peer (ePDG) */
152 charstring gtpu_addr_remote optional
Pau Espin Pedrold4a20082023-10-23 19:59:24 +0200153};
154
Pau Espin Pedrol965ac642023-10-16 18:12:45 +0200155type record EPDG_ConnHdlrPars {
156 hexstring imsi,
Pau Espin Pedrol2c2e1872023-10-23 18:31:03 +0200157 charstring apn,
Pau Espin Pedrold19fdf52023-10-19 16:58:24 +0200158 charstring ue_ip,
159
Pau Espin Pedrold19fdf52023-10-19 16:58:24 +0200160 /* TEI (Control) local side */
Pau Espin Pedrold4a20082023-10-23 19:59:24 +0200161 OCT4 teic_local,
Pau Espin Pedrold19fdf52023-10-19 16:58:24 +0200162 /* TEI (Control) remote side */
163 OCT4 teic_remote optional,
164
Pau Espin Pedrold4a20082023-10-23 19:59:24 +0200165 BearerConfig bearer optional,
166
Pau Espin Pedrol965ac642023-10-16 18:12:45 +0200167 AuthVector vec optional
168};
169
170private function f_epdg_connhldr_SWx_expect_eteid(UINT32 ete_id) runs on EPDG_ConnHdlr {
171 SWx_PROC.call(DIAMETEREM_register_eteid:{ete_id, null}) {
172 [] SWx_PROC.getreply(DIAMETEREM_register_eteid:{?,?}) {};
173 }
174}
175private function f_epdg_connhldr_S6b_expect_eteid(UINT32 ete_id) runs on EPDG_ConnHdlr {
176 S6b_PROC.call(DIAMETEREM_register_eteid:{ete_id, null}) {
177 [] S6b_PROC.getreply(DIAMETEREM_register_eteid:{?,?}) {};
178 }
179}
180
Pau Espin Pedrol285a2b62024-02-27 18:25:45 +0100181private function f_gen_addr_in_pool(integer idx := 0) return charstring
182{
183 /* Skip first 2 addresses reserved for TUN */
184 var integer internal_idx := idx + 2;
185 var integer suffix := internal_idx rem (256*256);
186 var integer C := suffix / 256;
187 var integer D := suffix rem 256;
188 return "192.168." & int2str(C) & "." & int2str(D);
189}
190
191private function f_init_pars(integer idx := 0)
Pau Espin Pedrol965ac642023-10-16 18:12:45 +0200192runs on MTC_CT return EPDG_ConnHdlrPars {
193 var EPDG_ConnHdlrPars pars := {
Pau Espin Pedrol285a2b62024-02-27 18:25:45 +0100194 imsi := f_rnd_imsi('26242'H),
Pau Espin Pedrol2c2e1872023-10-23 18:31:03 +0200195 apn := "internet",
Pau Espin Pedrol285a2b62024-02-27 18:25:45 +0100196 ue_ip := f_gen_addr_in_pool(idx),
Pau Espin Pedrold4a20082023-10-23 19:59:24 +0200197 teic_local := '00000000'O,
Pau Espin Pedrold19fdf52023-10-19 16:58:24 +0200198 teic_remote := omit,
Pau Espin Pedrold4a20082023-10-23 19:59:24 +0200199 bearer := {
200 ebi := omit,
201 teid_local := omit,
Pau Espin Pedrola9b65f12024-02-29 21:08:15 +0100202 teid_remote := omit,
203 gtpu_addr_remote := omit
Pau Espin Pedrold4a20082023-10-23 19:59:24 +0200204 },
Pau Espin Pedrol965ac642023-10-16 18:12:45 +0200205 vec := f_gen_auth_vec_3g()
206 };
207 return pars;
208}
209
210private function f_init_gsup(charstring id) runs on MTC_CT {
211 id := id & "-GSUP";
212 var GsupOps ops := {
213 create_cb := refers(GSUP_Emulation.ExpectedCreateCallback)
214 };
215
216 vc_GSUP_IPA := IPA_Emulation_CT.create(id & "-IPA");
217 vc_GSUP := GSUP_Emulation_CT.create(id);
218
219 map(vc_GSUP_IPA:IPA_PORT, system:IPA_CODEC_PT);
220 connect(vc_GSUP:GSUP, vc_GSUP_IPA:IPA_GSUP_PORT);
221 /* we use this hack to get events like ASP_IPA_EVENT_UP */
222 connect(vc_GSUP_IPA:IPA_CTRL_PORT, self:GSUP_IPA_EVENT);
223
224 vc_GSUP.start(GSUP_Emulation.main(ops, id));
225 vc_GSUP_IPA.start(IPA_Emulation.main_client(mp_gsup_remote_ip, mp_gsup_remote_port,
226 mp_gsup_local_ip, mp_gsup_local_port));
227
228 /* wait for incoming connection to GSUP port before proceeding */
229 timer T := 10.0;
230 T.start;
231 alt {
232 [] GSUP_IPA_EVENT.receive(tr_ASP_IPA_EV(ASP_IPA_EVENT_UP)) { }
233 [] T.timeout {
234 Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail, "No connection to GSUP Port");
235 }
236 }
237}
238
239private function DiameterForwardUnitdataCallback(PDU_DIAMETER msg)
240runs on DIAMETER_Emulation_CT return template PDU_DIAMETER {
241 DIAMETER_UNIT.send(msg);
242 return omit;
243}
244
245private function f_init_diameter(charstring id) runs on MTC_CT {
246 var DIAMETEROps ops := {
247 create_cb := refers(DIAMETER_Emulation.ExpectedCreateCallback),
248 unitdata_cb := refers(DiameterForwardUnitdataCallback),
249 raw := false /* handler mode (IMSI based routing) */
250 };
251 var DIAMETER_conn_parameters pars;
252
253 /* SWx setup: */
254 pars := {
255 remote_ip := "",
256 remote_sctp_port := -1, /* server mode */
257 local_ip := mp_swx_local_ip,
258 local_sctp_port := mp_swx_local_port,
259 origin_host := "hss." & mp_diam_realm,
260 origin_realm := mp_diam_realm,
261 auth_app_id := omit,
262 vendor_app_id := c_DIAMETER_3GPP_SWx_AID
263 };
264 vc_SWx := DIAMETER_Emulation_CT.create(id);
265 map(vc_SWx:DIAMETER, system:DIAMETER_CODEC_PT);
266 connect(vc_SWx:DIAMETER_UNIT, self:SWx_UNIT);
267 connect(vc_SWx:DIAMETER_PROC, self:SWx_PROC);
268 vc_SWx.start(DIAMETER_Emulation.main(ops, pars, id));
269
270 /* S6b setup: */
271 pars := {
Pau Espin Pedrolcdd41622023-10-23 14:38:20 +0200272 remote_ip := mp_s6b_remote_ip,
273 remote_sctp_port := mp_s6b_remote_port, /* client mode */
Pau Espin Pedrol965ac642023-10-16 18:12:45 +0200274 local_ip := mp_s6b_local_ip,
275 local_sctp_port := mp_s6b_local_port,
Pau Espin Pedrolcdd41622023-10-23 14:38:20 +0200276 origin_host := "pgw." & mp_diam_realm,
Pau Espin Pedrol965ac642023-10-16 18:12:45 +0200277 origin_realm := mp_diam_realm,
Pau Espin Pedrolcdd41622023-10-23 14:38:20 +0200278 auth_app_id := c_DIAMETER_3GPP_S6b_AID,
279 vendor_app_id := c_DIAMETER_3GPP_S6b_AID
Pau Espin Pedrol965ac642023-10-16 18:12:45 +0200280 };
281 vc_S6b := DIAMETER_Emulation_CT.create(id);
282 map(vc_S6b:DIAMETER, system:DIAMETER_CODEC_PT);
283 connect(vc_S6b:DIAMETER_UNIT, self:S6b_UNIT);
284 connect(vc_S6b:DIAMETER_PROC, self:S6b_PROC);
285 vc_S6b.start(DIAMETER_Emulation.main(ops, pars, id));
286
287 f_diameter_wait_capability(SWx_UNIT);
Pau Espin Pedrolcdd41622023-10-23 14:38:20 +0200288 f_diameter_wait_capability(S6b_UNIT);
Pau Espin Pedrol965ac642023-10-16 18:12:45 +0200289
290 /* Give some time for our emulation to get out of SUSPECT list of SUT (3 watchdog ping-pongs):
291 * RFC6733 sec 5.1
292 * RFC3539 sec 3.4.1 [5]
293 * https://github.com/freeDiameter/freeDiameter/blob/master/libfdcore/p_psm.c#L49
294 */
Pau Espin Pedrolc13a4cd2024-01-16 17:28:25 +0100295 f_sleep(int2float(mp_diam_watchdog_initial_wait_sec));
Pau Espin Pedrol965ac642023-10-16 18:12:45 +0200296}
297
298private function f_init_gtp(charstring id) runs on MTC_CT {
299 var Gtp2EmulationCfg cfg := {
300 gtpc_bind_ip := mp_s2b_local_ip,
301 gtpc_bind_port := mp_s2b_local_port,
302 gtpc_remote_ip := mp_s2b_remote_ip,
303 gtpc_remote_port := mp_s2b_remote_port,
Pau Espin Pedrol65a7f762024-02-29 21:07:58 +0100304 gtpu_bind_ip := mp_upf_gtpu_local_ip,
305 gtpu_bind_port := GTP1U_PORT,
Pau Espin Pedrol965ac642023-10-16 18:12:45 +0200306 sgw_role := false,
307 use_gtpu_daemon := false /* TODO: maybe use, set to true */
308 };
309
Pau Espin Pedrold19fdf52023-10-19 16:58:24 +0200310 vc_GTP2 := GTPv2_Emulation_CT.create(id & "-GTPV2");
Pau Espin Pedrol965ac642023-10-16 18:12:45 +0200311 map(vc_GTP2:GTP2C, system:GTP2C);
312 connect(vc_GTP2:TEID0, self:TEID0);
313 vc_GTP2.start(GTPv2_Emulation.main(cfg));
314}
315
316private function f_init(float t_guard := 40.0) runs on MTC_CT {
317
318 g_Tguard.start(t_guard);
319 activate(as_Tguard());
320
321 f_init_gsup(testcasename());
322 f_init_diameter(testcasename());
323 f_init_gtp(testcasename());
324}
325
326private type function void_fn(charstring id) runs on EPDG_ConnHdlr;
327
328private function f_init_handler(void_fn fn, charstring id, EPDG_ConnHdlrPars pars) runs on EPDG_ConnHdlr {
329 g_pars := pars;
330
331 /* tell GSUP dispatcher to send this IMSI to us */
332 f_create_gsup_expect(hex2str(g_pars.imsi));
333
Pau Espin Pedrold19fdf52023-10-19 16:58:24 +0200334 /* tell GTPv2 dispatcher to send this IMSI to us */
335 f_gtp2_register_imsi(g_pars.imsi);
336
Pau Espin Pedrol965ac642023-10-16 18:12:45 +0200337 fn.apply(id);
338}
339
340private function f_start_handler(void_fn fn, EPDG_ConnHdlrPars pars)
341runs on MTC_CT return EPDG_ConnHdlr {
342 var EPDG_ConnHdlr vc_conn;
343 var charstring id := testcasename();
344 var DIAMETER_ConnHdlr_CT vc_conn_swx, vc_conn_s6b;
345
346 vc_conn := EPDG_ConnHdlr.create(id);
347
Pau Espin Pedrold19fdf52023-10-19 16:58:24 +0200348 /* GSUP */
Pau Espin Pedrol965ac642023-10-16 18:12:45 +0200349 connect(vc_conn:GSUP, vc_GSUP:GSUP_CLIENT);
350 connect(vc_conn:GSUP_PROC, vc_GSUP:GSUP_PROC);
351
Pau Espin Pedrold19fdf52023-10-19 16:58:24 +0200352 /* GTP2 */
353 connect(vc_conn:GTP2, vc_GTP2:CLIENT);
354 connect(vc_conn:GTP2_PROC, vc_GTP2:CLIENT_PROC);
355
Pau Espin Pedrol965ac642023-10-16 18:12:45 +0200356 /* SWx */
357 vc_conn_swx := DIAMETER_ConnHdlr_CT.create(id);
358 connect(vc_conn_swx:DIAMETER, vc_SWx:DIAMETER_CLIENT);
359 connect(vc_conn_swx:DIAMETER_PROC, vc_SWx:DIAMETER_PROC);
360 connect(vc_conn:SWx, vc_conn_swx:DIAMETER_CLIENT);
361 connect(vc_conn:SWx_PROC, vc_conn_swx:DIAMETER_PROC_CLIENT);
362 vc_conn_swx.start(f_diam_connhldr_ct_main(pars.imsi));
363
364 /* S6b */
365 vc_conn_s6b := DIAMETER_ConnHdlr_CT.create(id);
366 connect(vc_conn_s6b:DIAMETER, vc_S6b:DIAMETER_CLIENT);
367 connect(vc_conn_s6b:DIAMETER_PROC, vc_S6b:DIAMETER_PROC);
368 connect(vc_conn:S6b, vc_conn_s6b:DIAMETER_CLIENT);
369 connect(vc_conn:S6b_PROC, vc_conn_s6b:DIAMETER_PROC_CLIENT);
370 vc_conn_s6b.start(f_diam_connhldr_ct_main(pars.imsi));
371
Pau Espin Pedrol285a2b62024-02-27 18:25:45 +0100372 /* COORD */
373 connect(vc_conn:COORD, self:COORD);
374
Pau Espin Pedrol965ac642023-10-16 18:12:45 +0200375 vc_conn.start(f_init_handler(fn, id, pars));
376 return vc_conn;
377}
378
Pau Espin Pedrol8586b262024-02-09 18:12:21 +0100379private function f_nai() runs on EPDG_ConnHdlr return charstring {
380 return hex2str(g_pars.imsi) & "@" & mp_s6b_nai_realm;
381}
382
Pau Espin Pedrol965ac642023-10-16 18:12:45 +0200383/* Diameter SWx MAR + MAA. */
384private altstep as_DIA_SWx_MA_success() runs on EPDG_ConnHdlr {
385 var PDU_DIAMETER rx_dia;
386 var template (omit) AVP avp;
387 var octetstring sess_id;
388 var template (value) GenericAVP sip_auth_data_item;
389 [] SWx.receive(tr_DIA_SWx_MAR(g_pars.imsi)) -> value rx_dia {
390 avp := f_DIAMETER_get_avp(rx_dia, c_AVP_Code_BASE_NONE_Session_Id);
391 sess_id := valueof(avp.avp_data.avp_BASE_NONE_Session_Id);
392 sip_auth_data_item := ts_AVP_3GPP_SIPAuthDataItem(0,
393 g_pars.vec.rand,
394 g_pars.vec.ik,
395 g_pars.vec.ck,
396 g_pars.vec.autn,
397 g_pars.vec.auts);
398 /* Send MAA to translator; expect it to show up on GSUP side */
399 SWx.send(ts_DIA_SWx_MAA(g_pars.imsi, sip_auth_data_item,
400 sess_id := sess_id,
401 hbh_id := rx_dia.hop_by_hop_id,
402 ete_id := rx_dia.end_to_end_id));
403 setverdict(pass);
404 }
405 [] SWx.receive(PDU_DIAMETER:?) -> value rx_dia {
406 Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail, log2str("Unexpected Diameter msg rx: ", rx_dia));
407 }
408}
409
410/* Diameter SWx SAR + SAA. */
Pau Espin Pedrol4944a5c2024-01-24 17:23:01 +0100411private altstep as_DIA_SWx_SA_success(template (present) CxDx_3GPP_Server_Assignment_Type server_ass_type := ?) runs on EPDG_ConnHdlr {
Pau Espin Pedrol965ac642023-10-16 18:12:45 +0200412 var PDU_DIAMETER rx_dia;
413 var template (omit) AVP avp;
414 var octetstring sess_id;
415 [] SWx.receive(tr_DIA_SWx_SAR(g_pars.imsi)) -> value rx_dia {
416 avp := f_DIAMETER_get_avp(rx_dia, c_AVP_Code_BASE_NONE_Session_Id);
417 sess_id := valueof(avp.avp_data.avp_BASE_NONE_Session_Id);
418 /* Send SAA to translator; expect it to show up on GSUP side */
419 SWx.send(ts_DIA_SWx_SAA(g_pars.imsi,
420 sess_id := sess_id,
421 hbh_id := rx_dia.hop_by_hop_id,
422 ete_id := rx_dia.end_to_end_id));
423 setverdict(pass);
424 }
425 [] SWx.receive(PDU_DIAMETER:?) -> value rx_dia {
426 Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail, log2str("Unexpected Diameter msg rx: ", rx_dia));
427 }
428}
429
Pau Espin Pedrolcdd41622023-10-23 14:38:20 +0200430/* Send AAR as PGW to AAA server, expect back AAA */
431private function f_S6b_AA_success() runs on EPDG_ConnHdlr {
432 var PDU_DIAMETER rx_dia;
433 var UINT32 hbh_id := f_rnd_octstring(4);
434 var UINT32 ete_id := f_rnd_octstring(4);
435
436 /* Unlike AAR, AAA contains no IMSI. Register ete_id in DIAMETER_Emulation,
437 * so AIA is forwarded back to us in DIAMETER port instead of MTC_CT.DIAMETER_UNIT.
438 */
439 f_epdg_connhldr_S6b_expect_eteid(ete_id);
440
Pau Espin Pedrol8586b262024-02-09 18:12:21 +0100441 S6b.send(ts_DIA_S6b_AAR(f_nai(),
Pau Espin Pedrol2c2e1872023-10-23 18:31:03 +0200442 int2oct(DIA_TS29_373_MIP6_Feature_Vector_GTPv2_SUPPORTED, 8),
443 g_pars.apn, hbh_id := hbh_id, ete_id := ete_id));
Pau Espin Pedrolc119ba02024-01-29 11:55:39 +0100444
445 /* AAR in S6b in AAA-Server triggers Service-Assignment Request/Answer towards HSS: */
446 as_DIA_SWx_SA_success();
447
Pau Espin Pedrolcdd41622023-10-23 14:38:20 +0200448 alt {
449 [] S6b.receive(tr_DIA_S6b_AAA) -> value rx_dia {}
450 [] S6b.receive(PDU_DIAMETER:?) -> value rx_dia {
451 Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail, log2str("Unexpected Diameter S6b msg rx: ", rx_dia));
452 }
453 }
454}
455
Pau Espin Pedrol4944a5c2024-01-24 17:23:01 +0100456/* Send STR as PGW to AAA server, expect back STA */
457private function f_S6b_ST_success() runs on EPDG_ConnHdlr {
458 var PDU_DIAMETER rx_dia;
459 var UINT32 hbh_id := f_rnd_octstring(4);
460 var UINT32 ete_id := f_rnd_octstring(4);
461
462 /* Unlike STR, STA contains no IMSI. Register ete_id in DIAMETER_Emulation,
463 * so AIA is forwarded back to us in DIAMETER port instead of MTC_CT.DIAMETER_UNIT.
464 */
465 f_epdg_connhldr_S6b_expect_eteid(ete_id);
466
467 S6b.send(ts_DIA_S6b_STR(g_pars.imsi, DIAMETER_LOGOUT,
468 hbh_id := hbh_id, ete_id := ete_id));
469 alt {
470 [] S6b.receive(tr_DIA_S6b_STA(DIAMETER_SUCCESS)) -> value rx_dia {}
471 [] S6b.receive(PDU_DIAMETER:?) -> value rx_dia {
472 Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail, log2str("Unexpected Diameter S6b msg rx: ", rx_dia));
473 }
474 }
475}
476
Pau Espin Pedrolf2925862024-02-22 20:12:30 +0100477private function f_exp_tr_GTP2C_APCO_in_CreateSessionReq()
478 runs on EPDG_ConnHdlr return template (present) APCO {
479 var template ProtocolIDs_and_ContainerIDs protos, protosV4, protosV6, protosV46;
480 protosV4 := {tr_GTP2C_PCO_P_DNS_IPv4(''O), tr_GTP2C_PCO_P_PCSCF_IPv4(''O)};
481 protosV6 := {tr_GTP2C_PCO_P_DNS_IPv6(''O), tr_GTP2C_PCO_P_PCSCF_IPv6(''O)};
482 protosV46 := {tr_GTP2C_PCO_P_DNS_IPv4(''O), tr_GTP2C_PCO_P_PCSCF_IPv4(''O),
483 tr_GTP2C_PCO_P_DNS_IPv6(''O), tr_GTP2C_PCO_P_PCSCF_IPv6(''O)}
484 /* TODO: pick proto based on req_type v4, v6 or v4v6 */
485 protos := protosV4;
486 return tr_GTP2C_APCO('0000'B, protos);
487}
488
489private function f_GTPv2C_gen_APCO_response(APCO apco_req) runs on EPDG_ConnHdlr return template (value) APCO {
490 var ProtocolIDs_and_ContainerIDs proto_list_resp := {};
491
492 for (var integer i := 0; i < lengthof(apco_req.protocolIDs_and_ContainerIDs); i := i + 1) {
493 var ProtocolID_or_ContainerID proto_req := apco_req.protocolIDs_and_ContainerIDs[i];
494 select (proto_req.protocolID_or_ContainerID) {
495 case (PCO_P_to_OCT2(PCO_P_DNS_IPv4_ADDR)) {
496 proto_list_resp := proto_list_resp & { valueof(ts_GTP2C_PCO_P_DNS_IPv4(f_inet_addr(mp_s2b_dns_ipv4))) };
497 }
498 case (PCO_P_to_OCT2(PCO_P_DNS_IPv6_ADDR)) {
499 proto_list_resp := proto_list_resp & { valueof(ts_GTP2C_PCO_P_DNS_IPv6(f_inet_addr(mp_s2b_dns_ipv6))) };
500 }
501 case (PCO_P_to_OCT2(PCO_P_PCSCF_IPv4_ADDR)) {
502 proto_list_resp := proto_list_resp & { valueof(ts_GTP2C_PCO_P_PCSCF_IPv4(f_inet_addr(mp_s2b_pcscf_ipv4))) };
503 }
504 case (PCO_P_to_OCT2(PCO_P_PCSCF_ADDR)) {
505 proto_list_resp := proto_list_resp & { valueof(ts_GTP2C_PCO_P_PCSCF_IPv6(f_inet_addr(mp_s2b_pcscf_ipv6))) };
506 }
507 case else {
508 log("Ignoring unknown PCO Protocol ID: ", proto_req);
509 }
510 }
511 }
512
513 return ts_GTP2C_APCO(apco_req.instance, proto_list_resp);
514}
515
Pau Espin Pedrol7b2cc922024-02-28 16:14:15 +0100516private function f_EPDG_ConnHdlr_parse_CreateSessionReq(PDU_GTPCv2 rx_msg) runs on EPDG_ConnHdlr {
517 var BearerContextIEs rx_bctx_ies;
Pau Espin Pedrola9b65f12024-02-29 21:08:15 +0100518 var FullyQualifiedTEID rx_fteid_gtpu;
Pau Espin Pedrol7b2cc922024-02-28 16:14:15 +0100519
520 /* Parse TEIC and Bearer EBI and TEID and store it in g_pars */
521 g_pars.teic_remote := rx_msg.gtpcv2_pdu.createSessionRequest.fullyQualifiedTEID[0].tEID_GRE_Key;
522 rx_bctx_ies := rx_msg.gtpcv2_pdu.createSessionRequest.bearerContextGrouped[0].bearerContextIEs;
523 g_pars.bearer.ebi := rx_bctx_ies.ePS_Bearer_ID.ePS_Bearer_ID_Value;
Pau Espin Pedrola9b65f12024-02-29 21:08:15 +0100524
525 rx_fteid_gtpu := rx_bctx_ies.fullyQualifiedTEID[0];
526 g_pars.bearer.teid_remote := rx_fteid_gtpu.tEID_GRE_Key;
527 if (rx_fteid_gtpu.v4_Flag == '1'B) {
528 g_pars.bearer.gtpu_addr_remote := f_inet_ntoa(rx_fteid_gtpu.iPv4_Address);
529 }
530 /*if (rx_fteid_gtpu.v6_Flag == '1'B) {
531 g_gtpu6_remote := rx_fteid_gtpu.iPv6_Address;
532 }*/
Pau Espin Pedrol7b2cc922024-02-28 16:14:15 +0100533
534 /* allocate + register TEID-C on local side */
535 g_pars.teic_local := f_gtp2_allocate_teid();
536 g_pars.bearer.teid_local := g_pars.teic_local;
537}
538
Pau Espin Pedrol4944a5c2024-01-24 17:23:01 +0100539/* ePDG Creates session at the PGW. PGW sends Diameter s6b AAR + AAA. */
Pau Espin Pedrold19fdf52023-10-19 16:58:24 +0200540private altstep as_GTP2C_CreateSession_success() runs on EPDG_ConnHdlr {
541 var PDU_GTPCv2 rx_msg;
542 var template (value) FullyQualifiedTEID fteid_c_ie, fteid_u_ie;
543 var template (value) PDN_AddressAllocation paa;
Pau Espin Pedrol8c746492023-10-23 20:56:09 +0200544 var template (value) BearerContextIEs bctx_ies;
Pau Espin Pedrold19fdf52023-10-19 16:58:24 +0200545
Pau Espin Pedrolf2925862024-02-22 20:12:30 +0100546 [] GTP2.receive(tr_GTP2C_CreateSessionReq(g_pars.imsi, apco := f_exp_tr_GTP2C_APCO_in_CreateSessionReq())) -> value rx_msg {
Pau Espin Pedrol7b2cc922024-02-28 16:14:15 +0100547 f_EPDG_ConnHdlr_parse_CreateSessionReq(rx_msg);
Pau Espin Pedrold19fdf52023-10-19 16:58:24 +0200548
Pau Espin Pedrolcdd41622023-10-23 14:38:20 +0200549 /* Upon rx of CreateSession, emulate PGW asking the AAA server. */
550 f_S6b_AA_success();
551
Pau Espin Pedrol24b08592024-02-09 18:48:53 +0100552 fteid_c_ie := ts_GTP2C_FTEID(FTEID_IF_S2b_PGW_GTPC, g_pars.teic_local, 1,
Pau Espin Pedrold19fdf52023-10-19 16:58:24 +0200553 f_inet_addr(mp_s2b_local_ip), omit);
Pau Espin Pedrol24b08592024-02-09 18:48:53 +0100554 fteid_u_ie := ts_GTP2C_FTEID(FTEID_IF_S2bU_PGW_GTPU, g_pars.bearer.teid_local, 4,
Pau Espin Pedrold19fdf52023-10-19 16:58:24 +0200555 f_inet_addr(mp_s2b_local_ip), omit);
556 paa := ts_GTP2C_PdnAddrAlloc_v4(f_inet_addr(g_pars.ue_ip));
Pau Espin Pedrold4a20082023-10-23 19:59:24 +0200557 bctx_ies := ts_GTP2C_BcContextIE(ebi := g_pars.bearer.ebi,
Pau Espin Pedrol8c746492023-10-23 20:56:09 +0200558 teid_list := { fteid_u_ie },
559 qos := ts_GTP2C_BearerQos('09'O, 0,0,0,0),
Pau Espin Pedrold4a20082023-10-23 19:59:24 +0200560 charging_id := ts_GTP2C_ChargingID(g_pars.teic_local));
Pau Espin Pedrolfa2b3842023-12-13 18:49:19 +0100561 GTP2.send(ts_GTP2C_CreateSessionResp(g_pars.teic_remote, rx_msg.sequenceNumber,
Pau Espin Pedrol7b2cc922024-02-28 16:14:15 +0100562 Request_accepted,
Pau Espin Pedrolfa2b3842023-12-13 18:49:19 +0100563 { fteid_c_ie }, paa,
Pau Espin Pedrolf2925862024-02-22 20:12:30 +0100564 { ts_GTP2C_BcGrouped(bctx_ies) },
565 f_GTPv2C_gen_APCO_response(rx_msg.gtpcv2_pdu.createSessionRequest.aPCO) ));
Pau Espin Pedrold19fdf52023-10-19 16:58:24 +0200566 setverdict(pass);
567 }
568 [] GTP2.receive(PDU_GTPCv2:?) -> value rx_msg {
569 Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail, log2str("Unexpected GTP2C msg rx: ", rx_msg));
570 }
571}
Pau Espin Pedrol4944a5c2024-01-24 17:23:01 +0100572
Pau Espin Pedrol7b2cc922024-02-28 16:14:15 +0100573/* ePDG Creates session at the PGW. PGW sends Diameter s6b AAR + AAA. */
574private altstep as_GTP2C_CreateSession_error(GTP2C_Cause resp_cause, boolean do_s6b_aar := false) runs on EPDG_ConnHdlr {
575 var PDU_GTPCv2 rx_msg;
576 var template (value) FullyQualifiedTEID fteid_c_ie, fteid_u_ie;
577 var template (value) PDN_AddressAllocation paa;
578 var template (value) BearerContextIEs bctx_ies;
579
580 [] GTP2.receive(tr_GTP2C_CreateSessionReq(g_pars.imsi, apco := f_exp_tr_GTP2C_APCO_in_CreateSessionReq())) -> value rx_msg {
581 f_EPDG_ConnHdlr_parse_CreateSessionReq(rx_msg);
582
583 /* Upon rx of CreateSession, emulate PGW asking the AAA server. */
584 if (do_s6b_aar) {
585 f_S6b_AA_success();
586 }
587
588 fteid_c_ie := ts_GTP2C_FTEID(FTEID_IF_S2b_PGW_GTPC, g_pars.teic_local, 1,
589 f_inet_addr(mp_s2b_local_ip), omit);
590 fteid_u_ie := ts_GTP2C_FTEID(FTEID_IF_S2bU_PGW_GTPU, g_pars.bearer.teid_local, 4,
591 f_inet_addr(mp_s2b_local_ip), omit);
592 GTP2.send(ts_GTP2C_CreateSessionResp(g_pars.teic_remote, rx_msg.sequenceNumber,
593 resp_cause));
594 setverdict(pass);
595 }
596 [] GTP2.receive(PDU_GTPCv2:?) -> value rx_msg {
597 Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail, log2str("Unexpected GTP2C msg rx: ", rx_msg));
598 }
599}
600
Pau Espin Pedrol4944a5c2024-01-24 17:23:01 +0100601/* ePDG Deletes session at the PGW. PGW sends Diameter s6b AAR + AAA. */
602private altstep as_GTP2C_DeleteSession_success() runs on EPDG_ConnHdlr {
603 var PDU_GTPCv2 rx_msg;
604 var BearerContextIEs rx_bctx_ies;
605 var template (value) FullyQualifiedTEID fteid_c_ie, fteid_u_ie;
606 var template (value) PDN_AddressAllocation paa;
607 var template (value) BearerContextIEs bctx_ies;
608
609 [] GTP2.receive(tr_GTP2C_DeleteSessionReq(g_pars.teic_local)) -> value rx_msg {
610 /* Upon rx of DeleteSession, emulate PGW requesting the AAA server for Sesssion Termination. */
611 f_S6b_ST_success();
612
613 GTP2.send(ts_GTP2C_DeleteSessionResp(g_pars.teic_remote,
614 rx_msg.sequenceNumber,
615 Request_accepted));
616 setverdict(pass);
617 }
618 [] GTP2.receive(PDU_GTPCv2:?) -> value rx_msg {
619 Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail, log2str("Unexpected GTP2C msg rx: ", rx_msg));
620 }
Pau Espin Pedrold19fdf52023-10-19 16:58:24 +0200621}
622
Pau Espin Pedrol14abac52024-02-05 21:05:17 +0100623/* Expect CreateBearerResponse */
624private altstep as_GTP2C_CreateBearer_success() runs on EPDG_ConnHdlr {
625 var PDU_GTPCv2 rx_msg;
626
627 [] GTP2.receive(tr_GTP2C_CreateBearerResp(g_pars.teic_local)) -> value rx_msg {
628 setverdict(pass);
629 }
630 [] GTP2.receive(PDU_GTPCv2:?) -> value rx_msg {
631 Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail, log2str("Unexpected GTP2C msg rx: ", rx_msg));
632 }
633}
634private function f_GTP2C_CreateBearer_success(uint4_t dedicated_bearer_id := 6) runs on EPDG_ConnHdlr {
635
636 var template (value) FullyQualifiedTEID fteid_u_ie := ts_GTP2C_FTEID(FTEID_IF_S2bU_ePDG_GTPU, g_pars.bearer.teid_local, dedicated_bearer_id,
637 f_inet_addr(mp_s2b_local_ip), omit);
638 var template (value) FullyQualifiedTEID_List teid_list := { fteid_u_ie };
639
640 var template (value) FullyQualifiedPDN_ConnectionSetID pgw_fq_csid := ts_GTP2C_FQCSID_IPv4(f_inet_addr(mp_s2b_local_ip), int2oct(dedicated_bearer_id, 2));
641 var template (value) FullyQualifiedPDN_ConnectionSetID_List csid_list := { pgw_fq_csid };
642
643 var template (value) BearerContextGrouped_List bcg_list := {
644 ts_GTP2C_BcGrouped({
645 ePS_Bearer_ID := ts_GTP2C_EpsBearerId(dedicated_bearer_id),
646 cause := omit,
647 ePS_Bearer_TFT := omit,
648 fullyQualifiedTEID := teid_list,
649 bearerLevel_QoS := ts_GTP2C_BearerQos('09'O, 0,0,0,0),
650 chargingID := ts_GTP2C_ChargingID(f_rnd_octstring(4)),
651 bearerFlags := omit,
652 transactionIdentifier := omit,
653 protocolConfigOptions := omit,
654 rAN_NASCause := omit,
655 additionalProtocolConfigOptions := omit,
656 extendedProtocolConfigOptions := omit
657 })
658 };
659 GTP2.send(ts_GTP2C_CreateBearerReq(g_pars.teic_remote, omit, g_pars.bearer.ebi,
660 dedicated_bearer_id, bcg_list, csid_list));
661 as_GTP2C_CreateBearer_success();
662}
663
Pau Espin Pedrold4a20082023-10-23 19:59:24 +0200664/* Expect DeleteBearerResponse */
665private altstep as_GTP2C_DeleteBearer_success() runs on EPDG_ConnHdlr {
666 var PDU_GTPCv2 rx_msg;
667 var template (value) FullyQualifiedTEID fteid_c_ie, fteid_u_ie;
668 var template (value) PDN_AddressAllocation paa;
669
670 [] GTP2.receive(tr_GTP2C_DeleteBearerResp(g_pars.teic_local)) -> value rx_msg {
671 setverdict(pass);
672 }
673 [] GTP2.receive(PDU_GTPCv2:?) -> value rx_msg {
674 Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail, log2str("Unexpected GTP2C msg rx: ", rx_msg));
675 }
676}
677private function f_GTP2C_DeleteBearer_success() runs on EPDG_ConnHdlr {
678 var integer proc_trans_id := 3;
679 GTP2.send(ts_GTP2C_DeleteBearerReq(g_pars.teic_remote, proc_trans_id, g_pars.bearer.ebi, Access_changed_from_Non_3GPP_to_3GPP));
Pau Espin Pedrolcbe6eba2024-02-06 12:53:14 +0100680 as_GSUP_CancelLocation_success();
Pau Espin Pedrold4a20082023-10-23 19:59:24 +0200681 as_GTP2C_DeleteBearer_success();
682}
683
Pau Espin Pedrola9b65f12024-02-29 21:08:15 +0100684private template (value) Gtp1uPeer ts_GtpPeerU(octetstring ip) := {
685 connId := 1,
686 remName := f_inet_ntoa(ip),
687 remPort := GTP1U_PORT
688}
689private function f_GTP1U_send(octetstring payload) runs on EPDG_ConnHdlr {
690 var Gtp1uPeer peer := valueof(ts_GtpPeerU(f_inet_addr(g_pars.bearer.gtpu_addr_remote)));
691 GTP2.send(ts_GTP1U_GPDU(peer, 0 /*seq*/, g_pars.bearer.teid_remote, payload));
692}
693private function f_GTP1U_echo_ping_pong(uint16_t seq_nr := 0) runs on EPDG_ConnHdlr {
694 var Gtp1uPeer peer := valueof(ts_GtpPeerU(f_inet_addr(g_pars.bearer.gtpu_addr_remote)));
695 GTP2.send(ts_GTPU_PING(peer, seq := seq_nr));
696 GTP2.receive(tr_GTPU_PONG(peer));
697}
Pau Espin Pedrolbf03d772024-03-01 16:15:21 +0100698private altstep as_GTPU_rx_icmp4(template (present) PDU_ICMP expected := ?) runs on EPDG_ConnHdlr {
699 var Gtp1uUnitdata rx_msg;
700 var template (value) Gtp1uPeer peer := ts_GtpPeerU(f_inet_addr(g_pars.bearer.gtpu_addr_remote));
701
702 [] GTP2.receive(tr_GTPU_GPDU(peer, g_pars.bearer.teid_local)) -> value rx_msg {
703 /*TODO: verify gtpu txseq:
704 if (f_verify_gtpu_txseq(ud.gtpu, use_gtpu_txseq) == false) {
705 setverdict(fail);
706 stop;
707 }
708 */
709 var octetstring gpdu := rx_msg.gtpu.gtpu_IEs.g_PDU_IEs.data;
710 var IPv4_packet ip4 := f_IPv4_dec(gpdu);
711 if (ip4.header.ver != 4) {
712 repeat;
713 }
714 var PDU_ICMP icmp4 := f_dec_PDU_ICMP(ip4.payload);
715 if (not match(icmp4, expected)) {
716 repeat;
717 }
718 }
719 [] GTP2.receive(Gtp1uUnitdata:?) -> value rx_msg {
720 Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail, log2str("Unexpected GTP msg rx: ", rx_msg));
721 }
722}
Pau Espin Pedrola9b65f12024-02-29 21:08:15 +0100723
Pau Espin Pedrol965ac642023-10-16 18:12:45 +0200724/* GSUP AuthInfo Req + Resp, triggers SWx MAR + MAA. */
725private function f_GSUP_AI_success() runs on EPDG_ConnHdlr {
726 var GSUP_PDU rx_gsup;
Pau Espin Pedrolc2cfd552024-02-07 17:51:55 +0100727 var template (present) GSUP_IE auth_tuple_ie;
728 var template (value) GSUP_IEs pdp_info;
729 auth_tuple_ie := tr_GSUP_IE_AuthTuple3G(g_pars.vec.rand,
730 g_pars.vec.ik,
731 g_pars.vec.ck,
732 g_pars.vec.autn,
733 g_pars.vec.rand & g_pars.vec.auts);
734 pdp_info := { ts_GSUP_IE_PDP_CONTEXT_ID('00'O),
735 ts_GSUP_IE_PDP_ADDRESS(ts_EuaIPv4Dyn),
736 ts_GSUP_IE_APN(f_enc_dns_hostname(g_pars.apn)) };
737 GSUP.send(ts_GSUP_SAI_REQ_PDP_INFO(g_pars.imsi, pdp_info));
Pau Espin Pedrol965ac642023-10-16 18:12:45 +0200738 as_DIA_SWx_MA_success();
739 /* Expect a positive response back to the translator; expect AIA */
740 alt {
741 [] GSUP.receive(tr_GSUP_SAI_RES(g_pars.imsi, auth_tuple_ie));
742 [] GSUP.receive(GSUP_PDU:?) -> value rx_gsup {
743 Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail, log2str("Unexpected GSUP msg rx: ", rx_gsup));
744 }
745 }
746 setverdict(pass);
747}
748
749/* GSUP LU Req + Resp, triggers SWx SAR + SAA (Server Assignment). */
750private function f_GSUP_LU_success() runs on EPDG_ConnHdlr {
751 var GSUP_PDU rx_gsup;
752 var template octetstring destination_name := *;
753 GSUP.send(ts_GSUP_UL_REQ(g_pars.imsi));
Pau Espin Pedrol4944a5c2024-01-24 17:23:01 +0100754 as_DIA_SWx_SA_success(REGISTRATION);
Pau Espin Pedrold19fdf52023-10-19 16:58:24 +0200755 /* Expect a positive response back to the translator */
Pau Espin Pedrol965ac642023-10-16 18:12:45 +0200756 alt {
757 [] GSUP.receive(tr_GSUP_UL_RES(g_pars.imsi, destination_name));
758 [] GSUP.receive(GSUP_PDU:?) -> value rx_gsup {
759 Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail, log2str("Unexpected GSUP msg rx: ", rx_gsup));
760 }
761 }
762 setverdict(pass);
763}
764
Pau Espin Pedrold19fdf52023-10-19 16:58:24 +0200765/* GSUP TunnelEPDG Tunnel Req + Resp, triggers S2b CreateSession Req + Response. */
766private function f_GSUP_EPDGTunnel_success() runs on EPDG_ConnHdlr {
767 var GSUP_PDU rx_gsup;
Pau Espin Pedrola9b65f12024-02-29 21:08:15 +0100768 var template (value) PCO_DATA pco := PCO_Types.ts_PCO({ ts_PCO_P_DNS_IPv4, ts_PCO_P_PCSCF_IPv4 });
Pau Espin Pedrolce1d3cb2024-02-21 17:40:59 +0100769 GSUP.send(ts_GSUP_EPDGTunnel_REQ(g_pars.imsi, pco));
Pau Espin Pedrol4944a5c2024-01-24 17:23:01 +0100770 as_GTP2C_CreateSession_success();
Pau Espin Pedrold19fdf52023-10-19 16:58:24 +0200771 /* Expect a positive response back to the translator; */
Pau Espin Pedrolf2925862024-02-22 20:12:30 +0100772 var template (present) GSUP_IEs exp_pdp_info := {
Pau Espin Pedrola6b0c1c2024-01-22 20:02:06 +0100773 tr_GSUP_IE_PDP_CONTEXT_ID(?),
Pau Espin Pedrol78598b52024-02-14 19:21:42 +0100774 tr_GSUP_IE_PDP_ADDRESS(tr_GSUP_PDP_Address_IPv4(f_inet_addr(g_pars.ue_ip))),
775 tr_GSUP_IE_APN(f_enc_dns_hostname(g_pars.apn)),
Pau Espin Pedrola6b0c1c2024-01-22 20:02:06 +0100776 tr_GSUP_IE_PDP_QOS(?),
777 tr_GSUP_IE_Charging_Characteristics(?)
778 };
Pau Espin Pedrola9b65f12024-02-29 21:08:15 +0100779 var template (present) PCO_DATA exp_pco := PCO_Types.tr_PCO({
Pau Espin Pedrolf2925862024-02-22 20:12:30 +0100780 tr_PCO_P_DNS_IPv4(f_inet_addr(mp_s2b_dns_ipv4)),
781 tr_PCO_P_PCSCF_IPv4(f_inet_addr(mp_s2b_pcscf_ipv4))
782 });
783 /* TODO: check for v6 and v4v6 types ^ */
Pau Espin Pedrold19fdf52023-10-19 16:58:24 +0200784 alt {
Pau Espin Pedrolf2925862024-02-22 20:12:30 +0100785 [] GSUP.receive(tr_GSUP_EPDGTunnel_RES(g_pars.imsi, exp_pdp_info));
Pau Espin Pedrold19fdf52023-10-19 16:58:24 +0200786 [] GSUP.receive(GSUP_PDU:?) -> value rx_gsup {
787 Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail, log2str("Unexpected GSUP msg rx: ", rx_gsup));
788 }
789 }
790 setverdict(pass);
791}
792
Pau Espin Pedrol7b2cc922024-02-28 16:14:15 +0100793/* GSUP TunnelEPDG Tunnel Req + Resp, triggers S2b CreateSession Req + Response (rejected). */
794private function f_GSUP_EPDGTunnel_error() runs on EPDG_ConnHdlr {
795 var GSUP_PDU rx_gsup;
Pau Espin Pedrola9b65f12024-02-29 21:08:15 +0100796 var template (value) PCO_DATA pco := PCO_Types.ts_PCO({ ts_PCO_P_DNS_IPv4, ts_PCO_P_PCSCF_IPv4 });
Pau Espin Pedrol7b2cc922024-02-28 16:14:15 +0100797 GSUP.send(ts_GSUP_EPDGTunnel_REQ(g_pars.imsi, pco));
798 as_GTP2C_CreateSession_error(APN_access_denied__no_subscription);
799 alt {
800 [] GSUP.receive(tr_GSUP_EPDGTunnel_ERR(g_pars.imsi));
801 [] GSUP.receive(GSUP_PDU:?) -> value rx_gsup {
802 Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail, log2str("Unexpected GSUP msg rx: ", rx_gsup));
803 }
804 }
805 setverdict(pass);
806}
807
Pau Espin Pedrol4944a5c2024-01-24 17:23:01 +0100808/* GSUP Purge MS Req + Resp, triggers S2b DeleteSession Req + Response. */
809private function f_GSUP_PurgeMS_success() runs on EPDG_ConnHdlr {
810 var GSUP_PDU rx_gsup;
811 GSUP.send(ts_GSUP_PURGE_MS_REQ(g_pars.imsi, OSMO_GSUP_CN_DOMAIN_PS));
812 as_GTP2C_DeleteSession_success();
813 /* ePDG internally sends STR to its AAA-Server. Since all sessions
814 become inactive, AAA-Server sends SAR(USER_DEREGISTRATION) to HSS: */
815
816 /* Expect a positive response back to the translator; */
817 as_DIA_SWx_SA_success(USER_DEREGISTRATION);
818 alt {
819 [] GSUP.receive(tr_GSUP_PURGE_MS_RES(g_pars.imsi));
820 [] GSUP.receive(GSUP_PDU:?) -> value rx_gsup {
821 Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail, log2str("Unexpected GSUP msg rx: ", rx_gsup));
822 }
823 }
824 setverdict(pass);
825}
826
Pau Espin Pedrolcbe6eba2024-02-06 12:53:14 +0100827/* Expect CancelLocationReq */
828private altstep as_GSUP_CancelLocation_success() runs on EPDG_ConnHdlr {
829 var GSUP_PDU rx_gsup;
830
831 [] GSUP.receive(tr_GSUP_CL_REQ(g_pars.imsi)) -> value rx_gsup {
832 GSUP.send(ts_GSUP_CL_RES(g_pars.imsi));
833 }
834 [] GSUP.receive(GSUP_PDU:?) -> value rx_gsup {
835 Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail, log2str("Unexpected GSUP msg rx: ", rx_gsup));
836 }
837}
838
Pau Espin Pedrolaf8ba582024-02-05 21:05:10 +0100839private function f_initial_attach() runs on EPDG_ConnHdlr {
Pau Espin Pedrol965ac642023-10-16 18:12:45 +0200840 f_GSUP_AI_success();
841 f_GSUP_LU_success();
Pau Espin Pedrold19fdf52023-10-19 16:58:24 +0200842 f_GSUP_EPDGTunnel_success();
Pau Espin Pedrolaf8ba582024-02-05 21:05:10 +0100843}
844
845private function f_TC_authinfo_normal(charstring id) runs on EPDG_ConnHdlr {
846 f_initial_attach();
Pau Espin Pedrol4944a5c2024-01-24 17:23:01 +0100847 f_GSUP_PurgeMS_success();
Pau Espin Pedrol965ac642023-10-16 18:12:45 +0200848}
Pau Espin Pedrol965ac642023-10-16 18:12:45 +0200849testcase TC_authinfo_normal() runs on MTC_CT {
850 var EPDG_ConnHdlrPars pars := f_init_pars();
851 var EPDG_ConnHdlr vc_conn;
852 f_init();
853 vc_conn := f_start_handler(refers(f_TC_authinfo_normal), pars);
854 vc_conn.done;
855 setverdict(pass);
856}
857
Pau Espin Pedrol14abac52024-02-05 21:05:17 +0100858private function f_TC_ho_lte_to_wifi(charstring id) runs on EPDG_ConnHdlr {
859 f_initial_attach();
860 /* Whenever UE comes from 3GPP, PGW may activate a dedicated S2b bearer
861 * and notify ePDG with a Create Bearer Request */
862 f_GTP2C_CreateBearer_success();
863 f_GSUP_PurgeMS_success();
864}
Pau Espin Pedrol14abac52024-02-05 21:05:17 +0100865testcase TC_ho_lte_to_wifi() runs on MTC_CT {
866 var EPDG_ConnHdlrPars pars := f_init_pars();
867 var EPDG_ConnHdlr vc_conn;
868 f_init();
869 vc_conn := f_start_handler(refers(f_TC_ho_lte_to_wifi), pars);
870 vc_conn.done;
871 setverdict(pass);
872}
873
Pau Espin Pedrold4a20082023-10-23 19:59:24 +0200874private function f_TC_ho_wifi_to_lte(charstring id) runs on EPDG_ConnHdlr {
Pau Espin Pedrolaf8ba582024-02-05 21:05:10 +0100875 f_initial_attach();
Pau Espin Pedrold4a20082023-10-23 19:59:24 +0200876 /* Whenever UE goes back to 3GPP, PGW will notify ePDG with a Delete Bearer Request
877 * cause="Access changed from non-3gpp to 3gpp" */
878 f_GTP2C_DeleteBearer_success();
879}
Pau Espin Pedrold4a20082023-10-23 19:59:24 +0200880testcase TC_ho_wifi_to_lte() runs on MTC_CT {
881 var EPDG_ConnHdlrPars pars := f_init_pars();
882 var EPDG_ConnHdlr vc_conn;
883 f_init();
884 vc_conn := f_start_handler(refers(f_TC_ho_wifi_to_lte), pars);
885 vc_conn.done;
886 setverdict(pass);
887}
888
Pau Espin Pedrol7b2cc922024-02-28 16:14:15 +0100889private function f_TC_s2b_CreateSession_rejected(charstring id) runs on EPDG_ConnHdlr {
890 f_GSUP_AI_success();
891 f_GSUP_LU_success();
892 f_GSUP_EPDGTunnel_error();
893}
894testcase TC_s2b_CreateSession_rejected() runs on MTC_CT {
895 var EPDG_ConnHdlrPars pars := f_init_pars();
896 var EPDG_ConnHdlr vc_conn;
897 f_init();
898 vc_conn := f_start_handler(refers(f_TC_s2b_CreateSession_rejected), pars);
899 vc_conn.done;
900 setverdict(pass);
901}
902
Pau Espin Pedrol285a2b62024-02-27 18:25:45 +0100903private function f_TC_concurrent_ues(charstring id) runs on EPDG_ConnHdlr {
904 COORD.send(COORD_CMD_READY);
905 COORD.receive(COORD_CMD_START);
906 f_initial_attach();
907 COORD.send(COORD_CMD_ATTACHED);
908 COORD.receive(COORD_CMD_STOP);
909 f_GSUP_PurgeMS_success();
910}
911private function f_TC_concurrent_ues_MTC(integer num_ues) runs on MTC_CT {
912 var EPDG_ConnHdlrList vc_conn_list := {};
913 var EPDG_ConnHdlr vc_conn;
914 f_init(t_guard := 100.0);
915
916 for (var integer i := 0; i < num_ues; i := i + 1) {
917 var EPDG_ConnHdlrPars pars := f_init_pars(i);
918 vc_conn := f_start_handler(refers(f_TC_concurrent_ues), pars);
919 vc_conn_list := vc_conn_list & { vc_conn };
920 }
921
922 for (var integer i := 0; i < num_ues; i := i + 1) {
923 COORD.receive(COORD_CMD_READY) from vc_conn_list[i];
924 }
925
926 for (var integer i := 0; i < num_ues; i := i + 1) {
927 COORD.send(COORD_CMD_START) to vc_conn_list[i];
928 f_sleep(0.1);
929 }
930
931 for (var integer i := 0; i < num_ues; i := i + 1) {
932 COORD.receive(COORD_CMD_ATTACHED) from vc_conn_list[i];
933 }
934
935 log("All attached!");
936 f_sleep(1.0);
937
938 for (var integer i := 0; i < num_ues; i := i + 1) {
939 COORD.send(COORD_CMD_STOP) to vc_conn_list[i];
940 }
941
942 for (var integer i := 0; i < num_ues; i := i + 1) {
943 vc_conn_list[i].done;
944 }
945
946 setverdict(pass);
947}
948testcase TC_concurrent_ues2() runs on MTC_CT {
949 f_TC_concurrent_ues_MTC(2)
950}
951testcase TC_concurrent_ues100() runs on MTC_CT {
952 f_TC_concurrent_ues_MTC(100)
953}
954
Pau Espin Pedrola9b65f12024-02-29 21:08:15 +0100955private function f_TC_upf_echo_req(charstring id) runs on EPDG_ConnHdlr {
956 f_initial_attach();
957 /* Dispatch Echo Resp to this component: */
958 f_gtp2_register_teid('00000000'O);
959 f_GTP1U_echo_ping_pong(seq_nr := 0);
960 /* Send one again, to validate it works several times: */
961 f_GTP1U_echo_ping_pong(seq_nr := 1);
962 f_GSUP_PurgeMS_success();
963}
964testcase TC_upf_echo_req() runs on MTC_CT {
965 var EPDG_ConnHdlrPars pars := f_init_pars();
966 var EPDG_ConnHdlr vc_conn;
967 f_init();
968 vc_conn := f_start_handler(refers(f_TC_upf_echo_req), pars);
969 vc_conn.done;
970 setverdict(pass);
971}
972
Pau Espin Pedrolbf03d772024-03-01 16:15:21 +0100973private function f_TC_mt_ipv4_echo_req(charstring id) runs on EPDG_ConnHdlr {
974 f_initial_attach();
975 /* Dispatch Echo Resp to this component: */
976 f_gtp2_register_teid('00000000'O);
977 var octetstring echo_req := f_gen_icmpv4_echo(f_inet_addr(mp_upf_gtpu_local_ip), f_inet_addr(g_pars.ue_ip));
978 f_GTP1U_send(echo_req);
979 as_GTPU_rx_icmp4((tr_ICMPv4_ERP, tr_ICMPv4_DU));
980 f_GSUP_PurgeMS_success();
981}
982testcase TC_mt_ipv4_echo_req() runs on MTC_CT {
983 var EPDG_ConnHdlrPars pars := f_init_pars();
984 var EPDG_ConnHdlr vc_conn;
985 f_init();
986 vc_conn := f_start_handler(refers(f_TC_mt_ipv4_echo_req), pars);
987 vc_conn.done;
988 setverdict(pass);
989}
990
Pau Espin Pedrol965ac642023-10-16 18:12:45 +0200991control {
992 execute ( TC_authinfo_normal() );
Pau Espin Pedrol14abac52024-02-05 21:05:17 +0100993 execute ( TC_ho_lte_to_wifi() );
Pau Espin Pedrold4a20082023-10-23 19:59:24 +0200994 execute ( TC_ho_wifi_to_lte() );
Pau Espin Pedrol7b2cc922024-02-28 16:14:15 +0100995 execute ( TC_s2b_CreateSession_rejected() );
Pau Espin Pedrol285a2b62024-02-27 18:25:45 +0100996 execute ( TC_concurrent_ues2() );
997 execute ( TC_concurrent_ues100() );
Pau Espin Pedrola9b65f12024-02-29 21:08:15 +0100998 execute ( TC_upf_echo_req() );
Pau Espin Pedrolbf03d772024-03-01 16:15:21 +0100999 execute ( TC_mt_ipv4_echo_req() );
Pau Espin Pedrol965ac642023-10-16 18:12:45 +02001000}
1001
1002}