Skip to content
Snippets Groups Projects
Commit 830f7e4b authored by David Huss's avatar David Huss :speech_balloon:
Browse files

Add Request timeout, handle unreachable endpoints

parent 3e2c0e71
Branches
No related tags found
No related merge requests found
...@@ -41,14 +41,13 @@ def request_meetings(secret: Secret, bbb_url: Url, user_config_path: str) -> Xml ...@@ -41,14 +41,13 @@ def request_meetings(secret: Secret, bbb_url: Url, user_config_path: str) -> Xml
url = "{}/api/{}?checksum={}".format(bbb_url, call_name, checksum) url = "{}/api/{}?checksum={}".format(bbb_url, call_name, checksum)
try: try:
r = requests.get(url) r = requests.get(url, timeout=3)
except requests.exceptions.Timeout as e:
# Offline Server!
return XmlDictConfig({"meetings":None})
except: except:
click.echo("{} The URL \"{}\" is unreachable.\n Check your network connection, and the URL and Secret of the endpoint.".format(click.style('Error:', fg='red', bold=True), url)) # Offline Server!
print() return XmlDictConfig({"meetings":None})
time.sleep(1)
if click.confirm(click.style('Do you want to open the config file at {} with your default editor?'.format(user_config_path), fg="yellow"), abort=True):
click.edit(filename=user_config_path)
exit()
try: try:
root = ElementTree.XML(r.text) root = ElementTree.XML(r.text)
...@@ -68,12 +67,16 @@ def request_meetings(secret: Secret, bbb_url: Url, user_config_path: str) -> Xml ...@@ -68,12 +67,16 @@ def request_meetings(secret: Secret, bbb_url: Url, user_config_path: str) -> Xml
return xmldict return xmldict
def get_meetings(secret: Secret, bbb_url: Url, user_config_path: str) -> Iterable[XmlDictConfig]: def get_meetings(secret: Secret, bbb_url: Url, user_config_path: str) -> Iterable[XmlDictConfig]:
""" """
Request meetings and return a list of them. Sorted by biggest first Request meetings and return a list of them. Sorted by biggest first
""" """
meetings = [] meetings = []
try:
d = request_meetings(secret, bbb_url, user_config_path) d = request_meetings(secret, bbb_url, user_config_path)
except:
return ["unreachable"]
if d["meetings"] is None: if d["meetings"] is None:
return [] return []
...@@ -137,6 +140,10 @@ def list_meetings(config: Config, leaderboards: bool, n: int, participants: bool ...@@ -137,6 +140,10 @@ def list_meetings(config: Config, leaderboards: bool, n: int, participants: bool
print("="*click.get_terminal_size()[0]) print("="*click.get_terminal_size()[0])
print() print()
if meeting[0] == "unreachable":
printing.print_header(endpoint.name, "No connection..", fancy)
continue
# If there are no meetings, skip to next endpoint # If there are no meetings, skip to next endpoint
if len(meeting) == 0: if len(meeting) == 0:
if show_meetings: if show_meetings:
...@@ -226,6 +233,10 @@ def meetings_twolines(config: Config, watch: int, fancy: bool): ...@@ -226,6 +233,10 @@ def meetings_twolines(config: Config, watch: int, fancy: bool):
print(lines) print(lines)
continue continue
if meeting[0] == "unreachable":
printing.print_header(endpoint.name, "No connection..", fancy)
continue
n_running = len(meeting) n_running = len(meeting)
n_recording = len([m for m in meeting if m["recording"] == "true"]) n_recording = len([m for m in meeting if m["recording"] == "true"])
n_participants = sum([int(m["participantCount"]) for m in meeting]) n_participants = sum([int(m["participantCount"]) for m in meeting])
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment