scottk/wlan-lanforge-scripts
1
0
Fork 0
mirror of https://github.com/Telecominfraproject/wlan-lanforge-scripts.git synced 2025-11-01 03:07:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

station info table added to allure

Browse Source 
Signed-off-by: anil-tegala <anil.tegala@candelatech.com>
This commit is contained in:
anil-tegala
2022-05-19 17:25:04 +05:30
parent fba070d872
commit aea9a0162d
1 changed files with 32 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
py-scripts/lf_multipsk.py
View File

@@ -27,12 +27,13 @@ import os
import importlib import importlib
import argparse import argparse
import time import time
import allure
from tabulate import tabulate
if sys.version_info[0] != 3: if sys.version_info[0] != 3:
print("This script requires Python 3") print("This script requires Python 3")
exit(1) exit(1)
sys.path.append(os.path.join(os.path.abspath(__file__ + "../../../"))) sys.path.append(os.path.join(os.path.abspath(__file__ + "../../../")))
lfcli_base = importlib.import_module("py-json.LANforge.lfcli_base") lfcli_base = importlib.import_module("py-json.LANforge.lfcli_base")
@@ -75,6 +76,8 @@ class MultiPsk(Realm):
def build(self): def build(self):
station_list = [] station_list = []
data_table = ""
dict_table = {}
for idex, input in enumerate(self.input): for idex, input in enumerate(self.input):
# print(input) # print(input)
if "." in input['upstream']: if "." in input['upstream']:
@@ -94,12 +97,37 @@ class MultiPsk(Realm):
self.station_profile.set_command_flag("set_port", "rpt_timer", 1) self.station_profile.set_command_flag("set_port", "rpt_timer", 1)
self.station_profile.create(radio=input['radio'], sta_names_=station_list, debug=self.debug) self.station_profile.create(radio=input['radio'], sta_names_=station_list, debug=self.debug)
self.wait_until_ports_appear(sta_list=station_list) self.wait_until_ports_appear(sta_list=station_list)
for sta_name in station_list:
if '1.1.' in sta_name:
sta_name = sta_name.strip('1.1.')
try:
cli_base = LFCliBase(_lfjson_host=self.lfclient_host, _lfjson_port=self.lfclient_port)
resp = cli_base.json_get(_req_url=f'port/1/1/{sta_name}')
dict_data = resp['interface']
dict_table[""] = list(dict_data.keys())
dict_table["Before"] = list(dict_data.values())
except Exception as e:
print(e)
self.station_profile.admin_up() self.station_profile.admin_up()
if self.wait_for_ip(station_list, timeout_sec=120): if self.wait_for_ip(station_list, timeout_sec=120):
print("All stations got IPs") print("All stations got IPs")
else: else:
print("Stations failed to get IPs") print("Stations failed to get IPs")
for sta_name2 in station_list:
if '1.1.' in sta_name2:
sta_name2 = sta_name2.strip('1.1.')
try:
cli_base = LFCliBase(_lfjson_host=self.lfclient_host, _lfjson_port=self.lfclient_port)
resp = cli_base.json_get(_req_url=f'port/1/1/{sta_name2}')
dict_data = resp['interface']
dict_table["After"] = list(dict_data.values())
try:
data_table = tabulate(dict_table, headers='keys', tablefmt='fancy_grid')
except Exception as e:
print(e)
allure.attach(name=f'{sta_name2} info', body=data_table)
except Exception as e:
print(e)
print("create udp endp") print("create udp endp")
self.cx_profile_udp = self.new_l3_cx_profile() self.cx_profile_udp = self.new_l3_cx_profile()
self.cx_profile_udp.side_a_min_bps = 128000 self.cx_profile_udp.side_a_min_bps = 128000
@@ -329,7 +357,7 @@ def main():
"mac": "", "mac": "",
"num_station": 1, "num_station": 1,
"radio": "wiphy4" "radio": "wiphy4"
}, },
{ {
"password": "lanforge2", "password": "lanforge2",
"upstream": "eth2.200", "upstream": "eth2.200",
@@ -352,7 +380,7 @@ def main():
"radio": "wiphy0" "radio": "wiphy0"
}, },
] ]
multi_obj = MultiPsk(host=args.mgr, multi_obj = MultiPsk(host=args.mgr,
port=args.mgr_port, port=args.mgr_port,
ssid=args.ssid, ssid=args.ssid,