#!/usr/bin/env python3

import jamulus

import argparse

import signal

import sys

from time import time

def format_server(server):

age_seconds = int(time() - server["time_updated"]) if "time_updated" in server.keys() else "?"

return "{:>15}:{:<5} {} {:<20} {:>3}/{:>3} {}/{} ({}/{}) {}s {}".format(

server.get("ip", 0),

server.get("port", 0),

"*" if server.get("permanent", 0) == 1 else " ",

server.get("name", "?"),

server.get("clients", "?"),

server.get("max_clients", "?"),

server.get("city", "?"),

jamulus.COUNTRY_KEYS.get(server.get("country_id"), "?"),

jamulus.OS_KEYS.get(server.get("os"), "?"),

server.get("version", "?"),

age_seconds,

server.get("internal_address", ""),

)

def argument_parser():

parser = argparse.ArgumentParser()

parser.add_argument("--port", type=int, default=jamulus.DEFAULT_PORT, help="local port number")

parser.add_argument(

"--directory",

type=jamulus.server_argument,

required=True,

action="extend",

nargs="+",

default=[],

help="central servers for collecting server lists",

)

parser.add_argument(

"--log-data",

action="store_true",

help="log protocol data",

)

return parser.parse_args()

################################################################################

def main():

# get arguments

args = argument_parser()

timeout = 3

# create jamulus connector

jc = jamulus.JamulusConnector(port=args.port, log_data=args.log_data)

for addr in args.directory:

jc.sendto(addr, "CLM_REQ_SERVER_LIST")

# receive messages indefinitely

while True:

try:

addr, key, count, values = jc.recvfrom(timeout)

except TimeoutError:

break

#continue

if key == "AUDIO":

# stop clients from connecting

jc.sendto(addr, "CLM_DISCONNECTION")

elif key == "CLM_SERVER_LIST":

# add servers to list

print("add/update {} servers".format(len(values)))

#server_list.add_list(addr, values)

#break

def signal_handler(sig, frame):

print()

sys.exit(0)

if __name__ == "__main__":

signal.signal(signal.SIGINT, signal_handler)

main()