105 lines
3.3 KiB
Python
105 lines
3.3 KiB
Python
import click
|
|
from tabulate import tabulate
|
|
import utilities_common.cli as clicommon
|
|
|
|
|
|
import ipaddress
|
|
from datetime import datetime
|
|
|
|
|
|
def ts_to_str(ts):
|
|
return datetime.fromtimestamp(int(ts)).strftime("%Y-%m-%d %H:%M:%S")
|
|
|
|
|
|
@click.group(cls=clicommon.AliasedGroup)
|
|
@clicommon.pass_db
|
|
def dhcp_server(db):
|
|
"""Show dhcp_server related info"""
|
|
ctx = click.get_current_context()
|
|
dbconn = db.db
|
|
if dbconn.get("CONFIG_DB", "FEATURE|dhcp_server", "state") != "enabled":
|
|
ctx.fail("Feature dhcp_server is not enabled")
|
|
|
|
|
|
@dhcp_server.group(cls=clicommon.AliasedGroup)
|
|
def ipv4():
|
|
"""Show ipv4 related dhcp_server info"""
|
|
pass
|
|
|
|
|
|
@ipv4.command()
|
|
@click.argument('dhcp_interface', required=False)
|
|
@clicommon.pass_db
|
|
def lease(db, dhcp_interface):
|
|
if not dhcp_interface:
|
|
dhcp_interface = "*"
|
|
headers = ["Interface", "MAC Address", "IP", "Lease Start", "Lease End"]
|
|
table = []
|
|
dbconn = db.db
|
|
for key in dbconn.keys("STATE_DB", "DHCP_SERVER_IPV4_LEASE|" + dhcp_interface + "|*"):
|
|
entry = dbconn.get_all("STATE_DB", key)
|
|
interface, mac = key.split("|")[1:]
|
|
port = dbconn.get("STATE_DB", "FDB_TABLE|" + interface + ":" + mac, "port")
|
|
if not port:
|
|
port = "<Unknown>"
|
|
table.append([interface + "|" + port, mac, entry["ip"], ts_to_str(entry["lease_start"]), ts_to_str(entry["lease_end"])])
|
|
click.echo(tabulate(table, headers=headers))
|
|
|
|
|
|
def count_ipv4(start, end):
|
|
ip1 = int(ipaddress.IPv4Address(start))
|
|
ip2 = int(ipaddress.IPv4Address(end))
|
|
return ip2 - ip1 + 1
|
|
|
|
|
|
@ipv4.command()
|
|
@click.argument('range_name', required=False)
|
|
@clicommon.pass_db
|
|
def range(db, range_name):
|
|
if not range_name:
|
|
range_name = "*"
|
|
headers = ["Range", "IP Start", "IP End", "IP Count"]
|
|
table = []
|
|
dbconn = db.db
|
|
for key in dbconn.keys("CONFIG_DB", "DHCP_SERVER_IPV4_RANGE|" + range_name):
|
|
name = key.split("|")[1]
|
|
entry = dbconn.get_all("CONFIG_DB", key)
|
|
range_ = entry["range"].split(",")
|
|
if len(range_) == 1:
|
|
start, end = range_[0], range_[0]
|
|
elif len(range_) == 2:
|
|
start, end = range_
|
|
else:
|
|
table.append([name, "", "", "range value is illegal"])
|
|
continue
|
|
count = count_ipv4(start, end)
|
|
if count < 1:
|
|
count = "range value is illegal"
|
|
table.append([name, start, end, count])
|
|
click.echo(tabulate(table, headers=headers))
|
|
|
|
|
|
@ipv4.command()
|
|
@click.argument('dhcp_interface', required=False)
|
|
@click.option('--with_customized_options', default=False, is_flag=True)
|
|
@clicommon.pass_db
|
|
def info(db, dhcp_interface, with_customized_options):
|
|
if not dhcp_interface:
|
|
dhcp_interface = "*"
|
|
headers = ["Interface", "Mode", "Gateway", "Netmask", "Lease Time(s)", "State"]
|
|
if with_customized_options:
|
|
headers.append("Customized Options")
|
|
table = []
|
|
dbconn = db.db
|
|
for key in dbconn.keys("CONFIG_DB", "DHCP_SERVER_IPV4|" + dhcp_interface):
|
|
entry = dbconn.get_all("CONFIG_DB", key)
|
|
interface = key.split("|")[1]
|
|
table.append([interface, entry["mode"], entry["gateway"], entry["netmask"], entry["lease_time"], entry["state"]])
|
|
if with_customized_options:
|
|
table[-1].append(entry["customized_options"])
|
|
click.echo(tabulate(table, headers=headers))
|
|
|
|
|
|
def register(cli):
|
|
cli.add_command(dhcp_server)
|