blob: 30bb6f122b94fdc5d7adec0ab2661e89e9a421dd [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,
Pau Espin Pedrol9b2ebc02024-03-05 13:25:19 +0100420 IPv4,
421 g_pars.apn,
Pau Espin Pedrol965ac642023-10-16 18:12:45 +0200422 sess_id := sess_id,
423 hbh_id := rx_dia.hop_by_hop_id,
424 ete_id := rx_dia.end_to_end_id));
425 setverdict(pass);
426 }
427 [] SWx.receive(PDU_DIAMETER:?) -> value rx_dia {
428 Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail, log2str("Unexpected Diameter msg rx: ", rx_dia));
429 }
430}
431
Pau Espin Pedrolcdd41622023-10-23 14:38:20 +0200432/* Send AAR as PGW to AAA server, expect back AAA */
433private function f_S6b_AA_success() runs on EPDG_ConnHdlr {
434 var PDU_DIAMETER rx_dia;
435 var UINT32 hbh_id := f_rnd_octstring(4);
436 var UINT32 ete_id := f_rnd_octstring(4);
437
438 /* Unlike AAR, AAA contains no IMSI. Register ete_id in DIAMETER_Emulation,
439 * so AIA is forwarded back to us in DIAMETER port instead of MTC_CT.DIAMETER_UNIT.
440 */
441 f_epdg_connhldr_S6b_expect_eteid(ete_id);
442
Pau Espin Pedrol8586b262024-02-09 18:12:21 +0100443 S6b.send(ts_DIA_S6b_AAR(f_nai(),
Pau Espin Pedrol2c2e1872023-10-23 18:31:03 +0200444 int2oct(DIA_TS29_373_MIP6_Feature_Vector_GTPv2_SUPPORTED, 8),
445 g_pars.apn, hbh_id := hbh_id, ete_id := ete_id));
Pau Espin Pedrolc119ba02024-01-29 11:55:39 +0100446
447 /* AAR in S6b in AAA-Server triggers Service-Assignment Request/Answer towards HSS: */
448 as_DIA_SWx_SA_success();
449
Pau Espin Pedrolcdd41622023-10-23 14:38:20 +0200450 alt {
451 [] S6b.receive(tr_DIA_S6b_AAA) -> value rx_dia {}
452 [] S6b.receive(PDU_DIAMETER:?) -> value rx_dia {
453 Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail, log2str("Unexpected Diameter S6b msg rx: ", rx_dia));
454 }
455 }
456}
457
Pau Espin Pedrol4944a5c2024-01-24 17:23:01 +0100458/* Send STR as PGW to AAA server, expect back STA */
459private function f_S6b_ST_success() runs on EPDG_ConnHdlr {
460 var PDU_DIAMETER rx_dia;
461 var UINT32 hbh_id := f_rnd_octstring(4);
462 var UINT32 ete_id := f_rnd_octstring(4);
463
464 /* Unlike STR, STA contains no IMSI. Register ete_id in DIAMETER_Emulation,
465 * so AIA is forwarded back to us in DIAMETER port instead of MTC_CT.DIAMETER_UNIT.
466 */
467 f_epdg_connhldr_S6b_expect_eteid(ete_id);
468
469 S6b.send(ts_DIA_S6b_STR(g_pars.imsi, DIAMETER_LOGOUT,
470 hbh_id := hbh_id, ete_id := ete_id));
471 alt {
472 [] S6b.receive(tr_DIA_S6b_STA(DIAMETER_SUCCESS)) -> value rx_dia {}
473 [] S6b.receive(PDU_DIAMETER:?) -> value rx_dia {
474 Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail, log2str("Unexpected Diameter S6b msg rx: ", rx_dia));
475 }
476 }
477}
478
Pau Espin Pedrolf2925862024-02-22 20:12:30 +0100479private function f_exp_tr_GTP2C_APCO_in_CreateSessionReq()
480 runs on EPDG_ConnHdlr return template (present) APCO {
481 var template ProtocolIDs_and_ContainerIDs protos, protosV4, protosV6, protosV46;
482 protosV4 := {tr_GTP2C_PCO_P_DNS_IPv4(''O), tr_GTP2C_PCO_P_PCSCF_IPv4(''O)};
483 protosV6 := {tr_GTP2C_PCO_P_DNS_IPv6(''O), tr_GTP2C_PCO_P_PCSCF_IPv6(''O)};
484 protosV46 := {tr_GTP2C_PCO_P_DNS_IPv4(''O), tr_GTP2C_PCO_P_PCSCF_IPv4(''O),
485 tr_GTP2C_PCO_P_DNS_IPv6(''O), tr_GTP2C_PCO_P_PCSCF_IPv6(''O)}
486 /* TODO: pick proto based on req_type v4, v6 or v4v6 */
487 protos := protosV4;
488 return tr_GTP2C_APCO('0000'B, protos);
489}
490
491private function f_GTPv2C_gen_APCO_response(APCO apco_req) runs on EPDG_ConnHdlr return template (value) APCO {
492 var ProtocolIDs_and_ContainerIDs proto_list_resp := {};
493
494 for (var integer i := 0; i < lengthof(apco_req.protocolIDs_and_ContainerIDs); i := i + 1) {
495 var ProtocolID_or_ContainerID proto_req := apco_req.protocolIDs_and_ContainerIDs[i];
496 select (proto_req.protocolID_or_ContainerID) {
497 case (PCO_P_to_OCT2(PCO_P_DNS_IPv4_ADDR)) {
498 proto_list_resp := proto_list_resp & { valueof(ts_GTP2C_PCO_P_DNS_IPv4(f_inet_addr(mp_s2b_dns_ipv4))) };
499 }
500 case (PCO_P_to_OCT2(PCO_P_DNS_IPv6_ADDR)) {
501 proto_list_resp := proto_list_resp & { valueof(ts_GTP2C_PCO_P_DNS_IPv6(f_inet_addr(mp_s2b_dns_ipv6))) };
502 }
503 case (PCO_P_to_OCT2(PCO_P_PCSCF_IPv4_ADDR)) {
504 proto_list_resp := proto_list_resp & { valueof(ts_GTP2C_PCO_P_PCSCF_IPv4(f_inet_addr(mp_s2b_pcscf_ipv4))) };
505 }
506 case (PCO_P_to_OCT2(PCO_P_PCSCF_ADDR)) {
507 proto_list_resp := proto_list_resp & { valueof(ts_GTP2C_PCO_P_PCSCF_IPv6(f_inet_addr(mp_s2b_pcscf_ipv6))) };
508 }
509 case else {
510 log("Ignoring unknown PCO Protocol ID: ", proto_req);
511 }
512 }
513 }
514
515 return ts_GTP2C_APCO(apco_req.instance, proto_list_resp);
516}
517
Pau Espin Pedrol7b2cc922024-02-28 16:14:15 +0100518private function f_EPDG_ConnHdlr_parse_CreateSessionReq(PDU_GTPCv2 rx_msg) runs on EPDG_ConnHdlr {
519 var BearerContextIEs rx_bctx_ies;
Pau Espin Pedrola9b65f12024-02-29 21:08:15 +0100520 var FullyQualifiedTEID rx_fteid_gtpu;
Pau Espin Pedrol7b2cc922024-02-28 16:14:15 +0100521
522 /* Parse TEIC and Bearer EBI and TEID and store it in g_pars */
523 g_pars.teic_remote := rx_msg.gtpcv2_pdu.createSessionRequest.fullyQualifiedTEID[0].tEID_GRE_Key;
524 rx_bctx_ies := rx_msg.gtpcv2_pdu.createSessionRequest.bearerContextGrouped[0].bearerContextIEs;
525 g_pars.bearer.ebi := rx_bctx_ies.ePS_Bearer_ID.ePS_Bearer_ID_Value;
Pau Espin Pedrola9b65f12024-02-29 21:08:15 +0100526
527 rx_fteid_gtpu := rx_bctx_ies.fullyQualifiedTEID[0];
528 g_pars.bearer.teid_remote := rx_fteid_gtpu.tEID_GRE_Key;
529 if (rx_fteid_gtpu.v4_Flag == '1'B) {
530 g_pars.bearer.gtpu_addr_remote := f_inet_ntoa(rx_fteid_gtpu.iPv4_Address);
531 }
532 /*if (rx_fteid_gtpu.v6_Flag == '1'B) {
533 g_gtpu6_remote := rx_fteid_gtpu.iPv6_Address;
534 }*/
Pau Espin Pedrol7b2cc922024-02-28 16:14:15 +0100535
536 /* allocate + register TEID-C on local side */
537 g_pars.teic_local := f_gtp2_allocate_teid();
538 g_pars.bearer.teid_local := g_pars.teic_local;
539}
540
Pau Espin Pedrol4944a5c2024-01-24 17:23:01 +0100541/* ePDG Creates session at the PGW. PGW sends Diameter s6b AAR + AAA. */
Pau Espin Pedrold19fdf52023-10-19 16:58:24 +0200542private altstep as_GTP2C_CreateSession_success() runs on EPDG_ConnHdlr {
543 var PDU_GTPCv2 rx_msg;
544 var template (value) FullyQualifiedTEID fteid_c_ie, fteid_u_ie;
545 var template (value) PDN_AddressAllocation paa;
Pau Espin Pedrol8c746492023-10-23 20:56:09 +0200546 var template (value) BearerContextIEs bctx_ies;
Pau Espin Pedrold19fdf52023-10-19 16:58:24 +0200547
Pau Espin Pedrolf2925862024-02-22 20:12:30 +0100548 [] 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 +0100549 f_EPDG_ConnHdlr_parse_CreateSessionReq(rx_msg);
Pau Espin Pedrold19fdf52023-10-19 16:58:24 +0200550
Pau Espin Pedrolcdd41622023-10-23 14:38:20 +0200551 /* Upon rx of CreateSession, emulate PGW asking the AAA server. */
552 f_S6b_AA_success();
553
Pau Espin Pedrol24b08592024-02-09 18:48:53 +0100554 fteid_c_ie := ts_GTP2C_FTEID(FTEID_IF_S2b_PGW_GTPC, g_pars.teic_local, 1,
Pau Espin Pedrold19fdf52023-10-19 16:58:24 +0200555 f_inet_addr(mp_s2b_local_ip), omit);
Pau Espin Pedrol24b08592024-02-09 18:48:53 +0100556 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 +0200557 f_inet_addr(mp_s2b_local_ip), omit);
558 paa := ts_GTP2C_PdnAddrAlloc_v4(f_inet_addr(g_pars.ue_ip));
Pau Espin Pedrold4a20082023-10-23 19:59:24 +0200559 bctx_ies := ts_GTP2C_BcContextIE(ebi := g_pars.bearer.ebi,
Pau Espin Pedrol8c746492023-10-23 20:56:09 +0200560 teid_list := { fteid_u_ie },
561 qos := ts_GTP2C_BearerQos('09'O, 0,0,0,0),
Pau Espin Pedrold4a20082023-10-23 19:59:24 +0200562 charging_id := ts_GTP2C_ChargingID(g_pars.teic_local));
Pau Espin Pedrolfa2b3842023-12-13 18:49:19 +0100563 GTP2.send(ts_GTP2C_CreateSessionResp(g_pars.teic_remote, rx_msg.sequenceNumber,
Pau Espin Pedrol7b2cc922024-02-28 16:14:15 +0100564 Request_accepted,
Pau Espin Pedrolfa2b3842023-12-13 18:49:19 +0100565 { fteid_c_ie }, paa,
Pau Espin Pedrolf2925862024-02-22 20:12:30 +0100566 { ts_GTP2C_BcGrouped(bctx_ies) },
567 f_GTPv2C_gen_APCO_response(rx_msg.gtpcv2_pdu.createSessionRequest.aPCO) ));
Pau Espin Pedrold19fdf52023-10-19 16:58:24 +0200568 setverdict(pass);
569 }
570 [] GTP2.receive(PDU_GTPCv2:?) -> value rx_msg {
571 Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail, log2str("Unexpected GTP2C msg rx: ", rx_msg));
572 }
573}
Pau Espin Pedrol4944a5c2024-01-24 17:23:01 +0100574
Pau Espin Pedrol7b2cc922024-02-28 16:14:15 +0100575/* ePDG Creates session at the PGW. PGW sends Diameter s6b AAR + AAA. */
576private altstep as_GTP2C_CreateSession_error(GTP2C_Cause resp_cause, boolean do_s6b_aar := false) runs on EPDG_ConnHdlr {
577 var PDU_GTPCv2 rx_msg;
578 var template (value) FullyQualifiedTEID fteid_c_ie, fteid_u_ie;
579 var template (value) PDN_AddressAllocation paa;
580 var template (value) BearerContextIEs bctx_ies;
581
582 [] GTP2.receive(tr_GTP2C_CreateSessionReq(g_pars.imsi, apco := f_exp_tr_GTP2C_APCO_in_CreateSessionReq())) -> value rx_msg {
583 f_EPDG_ConnHdlr_parse_CreateSessionReq(rx_msg);
584
585 /* Upon rx of CreateSession, emulate PGW asking the AAA server. */
586 if (do_s6b_aar) {
587 f_S6b_AA_success();
588 }
589
590 fteid_c_ie := ts_GTP2C_FTEID(FTEID_IF_S2b_PGW_GTPC, g_pars.teic_local, 1,
591 f_inet_addr(mp_s2b_local_ip), omit);
592 fteid_u_ie := ts_GTP2C_FTEID(FTEID_IF_S2bU_PGW_GTPU, g_pars.bearer.teid_local, 4,
593 f_inet_addr(mp_s2b_local_ip), omit);
594 GTP2.send(ts_GTP2C_CreateSessionResp(g_pars.teic_remote, rx_msg.sequenceNumber,
595 resp_cause));
596 setverdict(pass);
597 }
598 [] GTP2.receive(PDU_GTPCv2:?) -> value rx_msg {
599 Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail, log2str("Unexpected GTP2C msg rx: ", rx_msg));
600 }
601}
602
Pau Espin Pedrol4944a5c2024-01-24 17:23:01 +0100603/* ePDG Deletes session at the PGW. PGW sends Diameter s6b AAR + AAA. */
604private altstep as_GTP2C_DeleteSession_success() runs on EPDG_ConnHdlr {
605 var PDU_GTPCv2 rx_msg;
606 var BearerContextIEs rx_bctx_ies;
607 var template (value) FullyQualifiedTEID fteid_c_ie, fteid_u_ie;
608 var template (value) PDN_AddressAllocation paa;
609 var template (value) BearerContextIEs bctx_ies;
610
611 [] GTP2.receive(tr_GTP2C_DeleteSessionReq(g_pars.teic_local)) -> value rx_msg {
612 /* Upon rx of DeleteSession, emulate PGW requesting the AAA server for Sesssion Termination. */
613 f_S6b_ST_success();
614
615 GTP2.send(ts_GTP2C_DeleteSessionResp(g_pars.teic_remote,
616 rx_msg.sequenceNumber,
617 Request_accepted));
618 setverdict(pass);
619 }
620 [] GTP2.receive(PDU_GTPCv2:?) -> value rx_msg {
621 Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail, log2str("Unexpected GTP2C msg rx: ", rx_msg));
622 }
Pau Espin Pedrold19fdf52023-10-19 16:58:24 +0200623}
624
Pau Espin Pedrol14abac52024-02-05 21:05:17 +0100625/* Expect CreateBearerResponse */
626private altstep as_GTP2C_CreateBearer_success() runs on EPDG_ConnHdlr {
627 var PDU_GTPCv2 rx_msg;
628
629 [] GTP2.receive(tr_GTP2C_CreateBearerResp(g_pars.teic_local)) -> value rx_msg {
630 setverdict(pass);
631 }
632 [] GTP2.receive(PDU_GTPCv2:?) -> value rx_msg {
633 Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail, log2str("Unexpected GTP2C msg rx: ", rx_msg));
634 }
635}
636private function f_GTP2C_CreateBearer_success(uint4_t dedicated_bearer_id := 6) runs on EPDG_ConnHdlr {
637
638 var template (value) FullyQualifiedTEID fteid_u_ie := ts_GTP2C_FTEID(FTEID_IF_S2bU_ePDG_GTPU, g_pars.bearer.teid_local, dedicated_bearer_id,
639 f_inet_addr(mp_s2b_local_ip), omit);
640 var template (value) FullyQualifiedTEID_List teid_list := { fteid_u_ie };
641
642 var template (value) FullyQualifiedPDN_ConnectionSetID pgw_fq_csid := ts_GTP2C_FQCSID_IPv4(f_inet_addr(mp_s2b_local_ip), int2oct(dedicated_bearer_id, 2));
643 var template (value) FullyQualifiedPDN_ConnectionSetID_List csid_list := { pgw_fq_csid };
644
645 var template (value) BearerContextGrouped_List bcg_list := {
646 ts_GTP2C_BcGrouped({
647 ePS_Bearer_ID := ts_GTP2C_EpsBearerId(dedicated_bearer_id),
648 cause := omit,
649 ePS_Bearer_TFT := omit,
650 fullyQualifiedTEID := teid_list,
651 bearerLevel_QoS := ts_GTP2C_BearerQos('09'O, 0,0,0,0),
652 chargingID := ts_GTP2C_ChargingID(f_rnd_octstring(4)),
653 bearerFlags := omit,
654 transactionIdentifier := omit,
655 protocolConfigOptions := omit,
656 rAN_NASCause := omit,
657 additionalProtocolConfigOptions := omit,
658 extendedProtocolConfigOptions := omit
659 })
660 };
661 GTP2.send(ts_GTP2C_CreateBearerReq(g_pars.teic_remote, omit, g_pars.bearer.ebi,
662 dedicated_bearer_id, bcg_list, csid_list));
663 as_GTP2C_CreateBearer_success();
664}
665
Pau Espin Pedrold4a20082023-10-23 19:59:24 +0200666/* Expect DeleteBearerResponse */
667private altstep as_GTP2C_DeleteBearer_success() runs on EPDG_ConnHdlr {
668 var PDU_GTPCv2 rx_msg;
669 var template (value) FullyQualifiedTEID fteid_c_ie, fteid_u_ie;
670 var template (value) PDN_AddressAllocation paa;
671
672 [] GTP2.receive(tr_GTP2C_DeleteBearerResp(g_pars.teic_local)) -> value rx_msg {
673 setverdict(pass);
674 }
675 [] GTP2.receive(PDU_GTPCv2:?) -> value rx_msg {
676 Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail, log2str("Unexpected GTP2C msg rx: ", rx_msg));
677 }
678}
679private function f_GTP2C_DeleteBearer_success() runs on EPDG_ConnHdlr {
680 var integer proc_trans_id := 3;
681 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 +0100682 as_GSUP_CancelLocation_success();
Pau Espin Pedrold4a20082023-10-23 19:59:24 +0200683 as_GTP2C_DeleteBearer_success();
684}
685
Pau Espin Pedrola9b65f12024-02-29 21:08:15 +0100686private template (value) Gtp1uPeer ts_GtpPeerU(octetstring ip) := {
687 connId := 1,
688 remName := f_inet_ntoa(ip),
689 remPort := GTP1U_PORT
690}
691private function f_GTP1U_send(octetstring payload) runs on EPDG_ConnHdlr {
692 var Gtp1uPeer peer := valueof(ts_GtpPeerU(f_inet_addr(g_pars.bearer.gtpu_addr_remote)));
693 GTP2.send(ts_GTP1U_GPDU(peer, 0 /*seq*/, g_pars.bearer.teid_remote, payload));
694}
695private function f_GTP1U_echo_ping_pong(uint16_t seq_nr := 0) runs on EPDG_ConnHdlr {
696 var Gtp1uPeer peer := valueof(ts_GtpPeerU(f_inet_addr(g_pars.bearer.gtpu_addr_remote)));
697 GTP2.send(ts_GTPU_PING(peer, seq := seq_nr));
698 GTP2.receive(tr_GTPU_PONG(peer));
699}
Pau Espin Pedrolbf03d772024-03-01 16:15:21 +0100700private altstep as_GTPU_rx_icmp4(template (present) PDU_ICMP expected := ?) runs on EPDG_ConnHdlr {
701 var Gtp1uUnitdata rx_msg;
702 var template (value) Gtp1uPeer peer := ts_GtpPeerU(f_inet_addr(g_pars.bearer.gtpu_addr_remote));
703
704 [] GTP2.receive(tr_GTPU_GPDU(peer, g_pars.bearer.teid_local)) -> value rx_msg {
705 /*TODO: verify gtpu txseq:
706 if (f_verify_gtpu_txseq(ud.gtpu, use_gtpu_txseq) == false) {
707 setverdict(fail);
708 stop;
709 }
710 */
711 var octetstring gpdu := rx_msg.gtpu.gtpu_IEs.g_PDU_IEs.data;
712 var IPv4_packet ip4 := f_IPv4_dec(gpdu);
713 if (ip4.header.ver != 4) {
714 repeat;
715 }
716 var PDU_ICMP icmp4 := f_dec_PDU_ICMP(ip4.payload);
717 if (not match(icmp4, expected)) {
718 repeat;
719 }
720 }
721 [] GTP2.receive(Gtp1uUnitdata:?) -> value rx_msg {
722 Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail, log2str("Unexpected GTP msg rx: ", rx_msg));
723 }
724}
Pau Espin Pedrola9b65f12024-02-29 21:08:15 +0100725
Pau Espin Pedrol965ac642023-10-16 18:12:45 +0200726/* GSUP AuthInfo Req + Resp, triggers SWx MAR + MAA. */
727private function f_GSUP_AI_success() runs on EPDG_ConnHdlr {
728 var GSUP_PDU rx_gsup;
Pau Espin Pedrolc2cfd552024-02-07 17:51:55 +0100729 var template (present) GSUP_IE auth_tuple_ie;
730 var template (value) GSUP_IEs pdp_info;
731 auth_tuple_ie := tr_GSUP_IE_AuthTuple3G(g_pars.vec.rand,
732 g_pars.vec.ik,
733 g_pars.vec.ck,
734 g_pars.vec.autn,
735 g_pars.vec.rand & g_pars.vec.auts);
736 pdp_info := { ts_GSUP_IE_PDP_CONTEXT_ID('00'O),
737 ts_GSUP_IE_PDP_ADDRESS(ts_EuaIPv4Dyn),
738 ts_GSUP_IE_APN(f_enc_dns_hostname(g_pars.apn)) };
739 GSUP.send(ts_GSUP_SAI_REQ_PDP_INFO(g_pars.imsi, pdp_info));
Pau Espin Pedrol965ac642023-10-16 18:12:45 +0200740 as_DIA_SWx_MA_success();
741 /* Expect a positive response back to the translator; expect AIA */
742 alt {
743 [] GSUP.receive(tr_GSUP_SAI_RES(g_pars.imsi, auth_tuple_ie));
744 [] GSUP.receive(GSUP_PDU:?) -> value rx_gsup {
745 Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail, log2str("Unexpected GSUP msg rx: ", rx_gsup));
746 }
747 }
748 setverdict(pass);
749}
750
751/* GSUP LU Req + Resp, triggers SWx SAR + SAA (Server Assignment). */
752private function f_GSUP_LU_success() runs on EPDG_ConnHdlr {
753 var GSUP_PDU rx_gsup;
754 var template octetstring destination_name := *;
755 GSUP.send(ts_GSUP_UL_REQ(g_pars.imsi));
Pau Espin Pedrol4944a5c2024-01-24 17:23:01 +0100756 as_DIA_SWx_SA_success(REGISTRATION);
Pau Espin Pedrold19fdf52023-10-19 16:58:24 +0200757 /* Expect a positive response back to the translator */
Pau Espin Pedrol965ac642023-10-16 18:12:45 +0200758 alt {
759 [] GSUP.receive(tr_GSUP_UL_RES(g_pars.imsi, destination_name));
760 [] GSUP.receive(GSUP_PDU:?) -> value rx_gsup {
761 Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail, log2str("Unexpected GSUP msg rx: ", rx_gsup));
762 }
763 }
764 setverdict(pass);
765}
766
Pau Espin Pedrold19fdf52023-10-19 16:58:24 +0200767/* GSUP TunnelEPDG Tunnel Req + Resp, triggers S2b CreateSession Req + Response. */
768private function f_GSUP_EPDGTunnel_success() runs on EPDG_ConnHdlr {
769 var GSUP_PDU rx_gsup;
Pau Espin Pedrola9b65f12024-02-29 21:08:15 +0100770 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 +0100771 GSUP.send(ts_GSUP_EPDGTunnel_REQ(g_pars.imsi, pco));
Pau Espin Pedrol4944a5c2024-01-24 17:23:01 +0100772 as_GTP2C_CreateSession_success();
Pau Espin Pedrold19fdf52023-10-19 16:58:24 +0200773 /* Expect a positive response back to the translator; */
Pau Espin Pedrolf2925862024-02-22 20:12:30 +0100774 var template (present) GSUP_IEs exp_pdp_info := {
Pau Espin Pedrola6b0c1c2024-01-22 20:02:06 +0100775 tr_GSUP_IE_PDP_CONTEXT_ID(?),
Pau Espin Pedrol78598b52024-02-14 19:21:42 +0100776 tr_GSUP_IE_PDP_ADDRESS(tr_GSUP_PDP_Address_IPv4(f_inet_addr(g_pars.ue_ip))),
777 tr_GSUP_IE_APN(f_enc_dns_hostname(g_pars.apn)),
Pau Espin Pedrola6b0c1c2024-01-22 20:02:06 +0100778 tr_GSUP_IE_PDP_QOS(?),
779 tr_GSUP_IE_Charging_Characteristics(?)
780 };
Pau Espin Pedrola9b65f12024-02-29 21:08:15 +0100781 var template (present) PCO_DATA exp_pco := PCO_Types.tr_PCO({
Pau Espin Pedrolf2925862024-02-22 20:12:30 +0100782 tr_PCO_P_DNS_IPv4(f_inet_addr(mp_s2b_dns_ipv4)),
783 tr_PCO_P_PCSCF_IPv4(f_inet_addr(mp_s2b_pcscf_ipv4))
784 });
785 /* TODO: check for v6 and v4v6 types ^ */
Pau Espin Pedrold19fdf52023-10-19 16:58:24 +0200786 alt {
Pau Espin Pedrolf2925862024-02-22 20:12:30 +0100787 [] GSUP.receive(tr_GSUP_EPDGTunnel_RES(g_pars.imsi, exp_pdp_info));
Pau Espin Pedrold19fdf52023-10-19 16:58:24 +0200788 [] GSUP.receive(GSUP_PDU:?) -> value rx_gsup {
789 Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail, log2str("Unexpected GSUP msg rx: ", rx_gsup));
790 }
791 }
792 setverdict(pass);
793}
794
Pau Espin Pedrol7b2cc922024-02-28 16:14:15 +0100795/* GSUP TunnelEPDG Tunnel Req + Resp, triggers S2b CreateSession Req + Response (rejected). */
796private function f_GSUP_EPDGTunnel_error() runs on EPDG_ConnHdlr {
797 var GSUP_PDU rx_gsup;
Pau Espin Pedrola9b65f12024-02-29 21:08:15 +0100798 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 +0100799 GSUP.send(ts_GSUP_EPDGTunnel_REQ(g_pars.imsi, pco));
800 as_GTP2C_CreateSession_error(APN_access_denied__no_subscription);
801 alt {
802 [] GSUP.receive(tr_GSUP_EPDGTunnel_ERR(g_pars.imsi));
803 [] GSUP.receive(GSUP_PDU:?) -> value rx_gsup {
804 Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail, log2str("Unexpected GSUP msg rx: ", rx_gsup));
805 }
806 }
807 setverdict(pass);
808}
809
Pau Espin Pedrol4944a5c2024-01-24 17:23:01 +0100810/* GSUP Purge MS Req + Resp, triggers S2b DeleteSession Req + Response. */
811private function f_GSUP_PurgeMS_success() runs on EPDG_ConnHdlr {
812 var GSUP_PDU rx_gsup;
813 GSUP.send(ts_GSUP_PURGE_MS_REQ(g_pars.imsi, OSMO_GSUP_CN_DOMAIN_PS));
814 as_GTP2C_DeleteSession_success();
815 /* ePDG internally sends STR to its AAA-Server. Since all sessions
816 become inactive, AAA-Server sends SAR(USER_DEREGISTRATION) to HSS: */
817
818 /* Expect a positive response back to the translator; */
819 as_DIA_SWx_SA_success(USER_DEREGISTRATION);
820 alt {
821 [] GSUP.receive(tr_GSUP_PURGE_MS_RES(g_pars.imsi));
822 [] GSUP.receive(GSUP_PDU:?) -> value rx_gsup {
823 Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail, log2str("Unexpected GSUP msg rx: ", rx_gsup));
824 }
825 }
826 setverdict(pass);
827}
828
Pau Espin Pedrolcbe6eba2024-02-06 12:53:14 +0100829/* Expect CancelLocationReq */
830private altstep as_GSUP_CancelLocation_success() runs on EPDG_ConnHdlr {
831 var GSUP_PDU rx_gsup;
832
833 [] GSUP.receive(tr_GSUP_CL_REQ(g_pars.imsi)) -> value rx_gsup {
834 GSUP.send(ts_GSUP_CL_RES(g_pars.imsi));
835 }
836 [] GSUP.receive(GSUP_PDU:?) -> value rx_gsup {
837 Misc_Helpers.f_shutdown(__BFILE__, __LINE__, fail, log2str("Unexpected GSUP msg rx: ", rx_gsup));
838 }
839}
840
Pau Espin Pedrolaf8ba582024-02-05 21:05:10 +0100841private function f_initial_attach() runs on EPDG_ConnHdlr {
Pau Espin Pedrol965ac642023-10-16 18:12:45 +0200842 f_GSUP_AI_success();
843 f_GSUP_LU_success();
Pau Espin Pedrold19fdf52023-10-19 16:58:24 +0200844 f_GSUP_EPDGTunnel_success();
Pau Espin Pedrolaf8ba582024-02-05 21:05:10 +0100845}
846
847private function f_TC_authinfo_normal(charstring id) runs on EPDG_ConnHdlr {
848 f_initial_attach();
Pau Espin Pedrol4944a5c2024-01-24 17:23:01 +0100849 f_GSUP_PurgeMS_success();
Pau Espin Pedrol965ac642023-10-16 18:12:45 +0200850}
Pau Espin Pedrol965ac642023-10-16 18:12:45 +0200851testcase TC_authinfo_normal() runs on MTC_CT {
852 var EPDG_ConnHdlrPars pars := f_init_pars();
853 var EPDG_ConnHdlr vc_conn;
854 f_init();
855 vc_conn := f_start_handler(refers(f_TC_authinfo_normal), pars);
856 vc_conn.done;
857 setverdict(pass);
858}
859
Pau Espin Pedrol14abac52024-02-05 21:05:17 +0100860private function f_TC_ho_lte_to_wifi(charstring id) runs on EPDG_ConnHdlr {
861 f_initial_attach();
862 /* Whenever UE comes from 3GPP, PGW may activate a dedicated S2b bearer
863 * and notify ePDG with a Create Bearer Request */
864 f_GTP2C_CreateBearer_success();
865 f_GSUP_PurgeMS_success();
866}
Pau Espin Pedrol14abac52024-02-05 21:05:17 +0100867testcase TC_ho_lte_to_wifi() runs on MTC_CT {
868 var EPDG_ConnHdlrPars pars := f_init_pars();
869 var EPDG_ConnHdlr vc_conn;
870 f_init();
871 vc_conn := f_start_handler(refers(f_TC_ho_lte_to_wifi), pars);
872 vc_conn.done;
873 setverdict(pass);
874}
875
Pau Espin Pedrold4a20082023-10-23 19:59:24 +0200876private function f_TC_ho_wifi_to_lte(charstring id) runs on EPDG_ConnHdlr {
Pau Espin Pedrolaf8ba582024-02-05 21:05:10 +0100877 f_initial_attach();
Pau Espin Pedrold4a20082023-10-23 19:59:24 +0200878 /* Whenever UE goes back to 3GPP, PGW will notify ePDG with a Delete Bearer Request
879 * cause="Access changed from non-3gpp to 3gpp" */
880 f_GTP2C_DeleteBearer_success();
881}
Pau Espin Pedrold4a20082023-10-23 19:59:24 +0200882testcase TC_ho_wifi_to_lte() runs on MTC_CT {
883 var EPDG_ConnHdlrPars pars := f_init_pars();
884 var EPDG_ConnHdlr vc_conn;
885 f_init();
886 vc_conn := f_start_handler(refers(f_TC_ho_wifi_to_lte), pars);
887 vc_conn.done;
888 setverdict(pass);
889}
890
Pau Espin Pedrol7b2cc922024-02-28 16:14:15 +0100891private function f_TC_s2b_CreateSession_rejected(charstring id) runs on EPDG_ConnHdlr {
892 f_GSUP_AI_success();
893 f_GSUP_LU_success();
894 f_GSUP_EPDGTunnel_error();
895}
896testcase TC_s2b_CreateSession_rejected() runs on MTC_CT {
897 var EPDG_ConnHdlrPars pars := f_init_pars();
898 var EPDG_ConnHdlr vc_conn;
899 f_init();
900 vc_conn := f_start_handler(refers(f_TC_s2b_CreateSession_rejected), pars);
901 vc_conn.done;
902 setverdict(pass);
903}
904
Pau Espin Pedrol285a2b62024-02-27 18:25:45 +0100905private function f_TC_concurrent_ues(charstring id) runs on EPDG_ConnHdlr {
906 COORD.send(COORD_CMD_READY);
907 COORD.receive(COORD_CMD_START);
908 f_initial_attach();
909 COORD.send(COORD_CMD_ATTACHED);
910 COORD.receive(COORD_CMD_STOP);
911 f_GSUP_PurgeMS_success();
912}
913private function f_TC_concurrent_ues_MTC(integer num_ues) runs on MTC_CT {
914 var EPDG_ConnHdlrList vc_conn_list := {};
915 var EPDG_ConnHdlr vc_conn;
916 f_init(t_guard := 100.0);
917
918 for (var integer i := 0; i < num_ues; i := i + 1) {
919 var EPDG_ConnHdlrPars pars := f_init_pars(i);
920 vc_conn := f_start_handler(refers(f_TC_concurrent_ues), pars);
921 vc_conn_list := vc_conn_list & { vc_conn };
922 }
923
924 for (var integer i := 0; i < num_ues; i := i + 1) {
925 COORD.receive(COORD_CMD_READY) from vc_conn_list[i];
926 }
927
928 for (var integer i := 0; i < num_ues; i := i + 1) {
929 COORD.send(COORD_CMD_START) to vc_conn_list[i];
930 f_sleep(0.1);
931 }
932
933 for (var integer i := 0; i < num_ues; i := i + 1) {
934 COORD.receive(COORD_CMD_ATTACHED) from vc_conn_list[i];
935 }
936
937 log("All attached!");
938 f_sleep(1.0);
939
940 for (var integer i := 0; i < num_ues; i := i + 1) {
941 COORD.send(COORD_CMD_STOP) to vc_conn_list[i];
942 }
943
944 for (var integer i := 0; i < num_ues; i := i + 1) {
945 vc_conn_list[i].done;
946 }
947
948 setverdict(pass);
949}
950testcase TC_concurrent_ues2() runs on MTC_CT {
951 f_TC_concurrent_ues_MTC(2)
952}
953testcase TC_concurrent_ues100() runs on MTC_CT {
954 f_TC_concurrent_ues_MTC(100)
955}
956
Pau Espin Pedrola9b65f12024-02-29 21:08:15 +0100957private function f_TC_upf_echo_req(charstring id) runs on EPDG_ConnHdlr {
958 f_initial_attach();
959 /* Dispatch Echo Resp to this component: */
960 f_gtp2_register_teid('00000000'O);
961 f_GTP1U_echo_ping_pong(seq_nr := 0);
962 /* Send one again, to validate it works several times: */
963 f_GTP1U_echo_ping_pong(seq_nr := 1);
964 f_GSUP_PurgeMS_success();
965}
966testcase TC_upf_echo_req() runs on MTC_CT {
967 var EPDG_ConnHdlrPars pars := f_init_pars();
968 var EPDG_ConnHdlr vc_conn;
969 f_init();
970 vc_conn := f_start_handler(refers(f_TC_upf_echo_req), pars);
971 vc_conn.done;
972 setverdict(pass);
973}
974
Pau Espin Pedrolbf03d772024-03-01 16:15:21 +0100975private function f_TC_mt_ipv4_echo_req(charstring id) runs on EPDG_ConnHdlr {
976 f_initial_attach();
977 /* Dispatch Echo Resp to this component: */
978 f_gtp2_register_teid('00000000'O);
979 var octetstring echo_req := f_gen_icmpv4_echo(f_inet_addr(mp_upf_gtpu_local_ip), f_inet_addr(g_pars.ue_ip));
980 f_GTP1U_send(echo_req);
981 as_GTPU_rx_icmp4((tr_ICMPv4_ERP, tr_ICMPv4_DU));
982 f_GSUP_PurgeMS_success();
983}
984testcase TC_mt_ipv4_echo_req() runs on MTC_CT {
985 var EPDG_ConnHdlrPars pars := f_init_pars();
986 var EPDG_ConnHdlr vc_conn;
987 f_init();
988 vc_conn := f_start_handler(refers(f_TC_mt_ipv4_echo_req), pars);
989 vc_conn.done;
990 setverdict(pass);
991}
992
Pau Espin Pedrol965ac642023-10-16 18:12:45 +0200993control {
994 execute ( TC_authinfo_normal() );
Pau Espin Pedrol14abac52024-02-05 21:05:17 +0100995 execute ( TC_ho_lte_to_wifi() );
Pau Espin Pedrold4a20082023-10-23 19:59:24 +0200996 execute ( TC_ho_wifi_to_lte() );
Pau Espin Pedrol7b2cc922024-02-28 16:14:15 +0100997 execute ( TC_s2b_CreateSession_rejected() );
Pau Espin Pedrol285a2b62024-02-27 18:25:45 +0100998 execute ( TC_concurrent_ues2() );
999 execute ( TC_concurrent_ues100() );
Pau Espin Pedrola9b65f12024-02-29 21:08:15 +01001000 execute ( TC_upf_echo_req() );
Pau Espin Pedrolbf03d772024-03-01 16:15:21 +01001001 execute ( TC_mt_ipv4_echo_req() );
Pau Espin Pedrol965ac642023-10-16 18:12:45 +02001002}
1003
1004}