holm/podman-compose
1
0
Fork 0
forked from extern/podman-compose
Code Issues Pull Requests Packages Projects Releases Wiki Activity

reformat

Browse Source
This commit is contained in:
Muayyad alsadi 2022-05-10 01:30:03 +03:00
parent d479001454
commit c175fd1b10
1 changed files with 24 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

46
podman_compose.py
View File

@ -347,11 +347,7 @@ def assert_volume(compose, mount_dict):
except OSError: except OSError:
pass pass
return return
if ( if mount_dict["type"] != "volume" or not vol or not vol.get("name", None):
mount_dict["type"] != "volume"
or not vol
or not vol.get("name", None)
):
return return
proj_name = compose.project_name proj_name = compose.project_name
vol_name = vol["name"] vol_name = vol["name"]
@ -363,9 +359,7 @@ def assert_volume(compose, mount_dict):
_ = compose.podman.output([], "volume", ["inspect", vol_name]).decode("utf-8") _ = compose.podman.output([], "volume", ["inspect", vol_name]).decode("utf-8")
except subprocess.CalledProcessError as e: except subprocess.CalledProcessError as e:
if is_ext: if is_ext:
raise RuntimeError( raise RuntimeError(f"External volume [{vol_name}] does not exists") from e
f"External volume [{vol_name}] does not exists"
) from e
labels = vol.get("labels", None) or [] labels = vol.get("labels", None) or []
args = [ args = [
"create", "create",
@ -2296,28 +2290,30 @@ def compose_logs(compose, args):
@cmd_run(podman_compose, "config", "displays the compose file") @cmd_run(podman_compose, "config", "displays the compose file")
def compose_config(compose, args): def compose_config(compose, args):
if args.services: if args.services:
for service in compose.services: print(service) for service in compose.services:
print(service)
return return
print(compose.merged_yaml) print(compose.merged_yaml)
@cmd_run(
podman_compose, "port", "Prints the public port for a port binding." @cmd_run(podman_compose, "port", "Prints the public port for a port binding.")
)
def compose_port(compose, args): def compose_port(compose, args):
#TODO - deal with pod index # TODO - deal with pod index
compose.assert_services(args.service) compose.assert_services(args.service)
containers = compose.container_names_by_service[args.service] containers = compose.container_names_by_service[args.service]
container_ports = list(itertools.chain(*(compose.container_by_name[c]["ports"] for c in containers))) container_ports = list(
itertools.chain(*(compose.container_by_name[c]["ports"] for c in containers))
)
def _published_target(port_string): def _published_target(port_string):
published, target = port_string.split(':')[-2:] published, target = port_string.split(":")[-2:]
return int(published), int(target) return int(published), int(target)
select_udp = (args.protocol == "udp") select_udp = args.protocol == "udp"
published, target = None, None published, target = None, None
for p in container_ports: for p in container_ports:
is_udp = (p[-4:] == "/udp") is_udp = p[-4:] == "/udp"
if select_udp and is_udp: if select_udp and is_udp:
published, target = _published_target(p[-4:]) published, target = _published_target(p[-4:])
if not select_udp and not is_udp: if not select_udp and not is_udp:
@ -2708,11 +2704,10 @@ def compose_build_parse(parser):
@cmd_parse(podman_compose, "config") @cmd_parse(podman_compose, "config")
def compose_config_parse(parser): def compose_config_parse(parser):
parser.add_argument( parser.add_argument(
"--services", "--services", help="Print the service names, one per line.", action="store_true"
help="Print the service names, one per line.",
action="store_true"
) )
@cmd_parse(podman_compose, "port") @cmd_parse(podman_compose, "port")
def compose_port_parse(parser): def compose_port_parse(parser):
parser.add_argument( parser.add_argument(
@ -2728,7 +2723,14 @@ def compose_port_parse(parser):
help="tcp or udp", help="tcp or udp",
) )
parser.add_argument("service", metavar="service", nargs=None, help="service name") parser.add_argument("service", metavar="service", nargs=None, help="service name")
parser.add_argument("private_port", metavar="private_port", nargs=None, type=int, help="private port") parser.add_argument(
"private_port",
metavar="private_port",
nargs=None,
type=int,
help="private port",
)
def main(): def main():
podman_compose.run() podman_compose.run()