-
Notifications
You must be signed in to change notification settings - Fork 72
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
8758bce
commit f3b0b76
Showing
12 changed files
with
257 additions
and
33 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,115 @@ | ||
| # coding: utf-8 | ||
| require "sam" | ||
| require "file_utils" | ||
| require "colorize" | ||
| require "totem" | ||
| require "../utils/utils.cr" | ||
|
|
||
| desc "Test if a 5G core has SMF/UPF heartbeat" | ||
| task "smf_upf_heartbeat" do |t, args| | ||
| CNFManager::Task.task_runner(args) do |args, config| | ||
| task_start_time = Time.utc | ||
| testsuite_task = "suci_enabled" | ||
| Log.for(testsuite_task).info { "Starting test" } | ||
|
|
||
| Log.debug { "cnf_config: #{config}" } | ||
| suci_found : Bool | Nil | ||
| smf = config.cnf_config[:smf_label]? | ||
| upf = config.cnf_config[:upf_label]? | ||
| Log.info { "smf: #{smf}" } | ||
| Log.info { "upf: #{upf}" } | ||
| smf_key : String = "" | ||
| smf_value : String = "" | ||
| smf_key = config.cnf_config[:smf_label].split("=").first if smf | ||
| smf_value = config.cnf_config[:smf_label].split("=").last if upf | ||
|
|
||
| if smf && upf | ||
|
|
||
| args.named["pod_labels"]="#{smf},#{upf}" | ||
| command = "-ni any -Y 'pfcp.msg_type == 1 or pfcp.msg_type == 2' -T json" | ||
| #todo in pod_nework_latency do labels = args.named["pod_labels"].as(String).split(",") | ||
| # todo t.invoke("pod_network_latency", args) | ||
|
|
||
| #Baseline | ||
| tshark_log_name = K8sTshark.log_of_tshark_by_label(command, smf_key, smf_value, duration="120") | ||
| if tshark_log_name && | ||
| !tshark_log_name.empty? && | ||
| (tshark_log_name =~ /not found/) == nil | ||
| scan = K8sTshark.regex_tshark_log_scan(/"pfcp\.msg_type": "(1|2)"/, tshark_log_name) | ||
| if scan | ||
| baseline_count = scan.size | ||
| Log.info { "Baseline matches: #{baseline_count}" } | ||
| end | ||
| end | ||
|
|
||
| #Chaos Matches | ||
| sync_channel = Channel(Nil).new | ||
| spawn do | ||
| t.invoke("pod_network_latency", args) | ||
| sync_channel.send(nil) | ||
| end | ||
| Log.info { "Main thread continuing" } | ||
|
|
||
| tshark_log_name = K8sTshark.log_of_tshark_by_label(command, smf_key, smf_value, duration="120") | ||
| if tshark_log_name && | ||
| !tshark_log_name.empty? && | ||
| (tshark_log_name =~ /not found/) == nil | ||
|
|
||
| #todo put in prereq | ||
| #todo call test suite chaos tasks | ||
| #hi = t.invoke("node_drain") | ||
| #todo hi should have a string e.g. "PASSED: nodes are drained etc" | ||
|
|
||
| # UERANSIM.install(config) #todo remove | ||
| Log.info { "TShark Log File: #{tshark_log_name}" } | ||
| #TODO 5g RAN (only) mobile traffic check ???? | ||
| # use suci encyption but don't use a null encryption key | ||
| scan = K8sTshark.regex_tshark_log_scan(/"pfcp\.msg_type": "(1|2)"/, tshark_log_name) | ||
| if scan | ||
| chaos_count = scan.size | ||
| Log.info { "Chaos Matches: #{chaos_count}" } | ||
| end | ||
| # !K8sTshark.regex_tshark_log(/"nas_5gs.mm.suci.scheme_id": "0"/, tshark_log_name) && | ||
| # !K8sTshark.regex_tshark_log(/"nas_5gs.mm.suci.pki": "0"/, tshark_log_name) | ||
| suci_found = true | ||
| else | ||
| suci_found = false | ||
| end | ||
| sync_channel.receive | ||
|
|
||
| Log.info { "Chaos Matches: #{chaos_count}" } | ||
| Log.info { "Baseline matches: #{baseline_count}" } | ||
|
|
||
| if chaos_count && baseline_count | ||
| difference = (chaos_count.to_i - baseline_count.to_i).abs | ||
| if difference <= 5 | ||
| puts "The integers are within a value of 5. Passing" | ||
| else | ||
| puts "The integers are not within a value of 5. Failing" | ||
| end | ||
| end | ||
|
|
||
| #todo delete log file | ||
| else | ||
| suci_found = false | ||
| puts "no 5g labels".colorize(:red) | ||
| end | ||
|
|
||
| # else | ||
| # suci_found = false | ||
| # puts "You must set the core label for you AMF node".colorize(:red) | ||
| # end | ||
|
|
||
|
|
||
| if suci_found | ||
| resp = upsert_passed_task(testsuite_task,"✔️ PASSED: Core uses SUCI 5g authentication", task_start_time) | ||
| else | ||
| resp = upsert_failed_task(testsuite_task, "✖️ FAILED: Core does not use SUCI 5g authentication", task_start_time) | ||
| end | ||
| resp | ||
| ensure | ||
| Helm.delete("ueransim") | ||
| ClusterTools.uninstall | ||
| ClusterTools.install | ||
| end | ||
| end |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.