Skip to content

Commit

Permalink
chore: clean up redundant proj_name
Browse files Browse the repository at this point in the history
chore: remove dead unutilized proj_name parameter from volume_ls

Signed-off-by: legobt <[email protected]>
  • Loading branch information
legobeat committed Jul 31, 2024
1 parent 348461c commit 9d6b48d
Showing 1 changed file with 20 additions and 28 deletions.
48 changes: 20 additions & 28 deletions podman_compose.py
Original file line number Diff line number Diff line change
Expand Up @@ -194,7 +194,7 @@ def parse_short_mount(mount_str, basedir):
# unless it's anonymous-volume


def fix_mount_dict(compose, mount_dict, proj_name, srv_name):
def fix_mount_dict(compose, mount_dict, srv_name):
"""
in-place fix mount dictionary to:
- define _vol to be the corresponding top-level volume
Expand All @@ -214,7 +214,7 @@ def fix_mount_dict(compose, mount_dict, proj_name, srv_name):
if not source:
# missing source
vol["name"] = "_".join([
proj_name,
compose.project_name,
srv_name,
hashlib.sha256(mount_dict["target"].encode("utf-8")).hexdigest(),
])
Expand All @@ -225,7 +225,7 @@ def fix_mount_dict(compose, mount_dict, proj_name, srv_name):
elif external:
vol["name"] = f"{source}"
else:
vol["name"] = f"{proj_name}_{source}"
vol["name"] = f"{compose.project_name}_{source}"
return mount_dict


Expand Down Expand Up @@ -346,14 +346,14 @@ def norm_ulimit(inner_value):
return inner_value


def default_network_name_for_project(compose, proj_name, net, is_ext):
def default_network_name_for_project(compose, net, is_ext):
if is_ext:
return net

default_net_name_compat = compose.x_podman.get("default_net_name_compat", False)
if default_net_name_compat is True:
return f"{proj_name.replace('-', '')}_{net}"
return f"{proj_name}_{net}"
return f"{compose.project_name.replace('-', '')}_{net}"
return f"{compose.project_name}_{net}"


# def tr_identity(project_name, given_containers):
Expand Down Expand Up @@ -397,7 +397,6 @@ async def assert_volume(compose, mount_dict):
return
if mount_dict["type"] != "volume" or not vol or not vol.get("name", None):
return
proj_name = compose.project_name
vol_name = vol["name"]
is_ext = vol.get("external", None)
log.debug("podman volume inspect %s || podman volume create %s", vol_name, vol_name)
Expand All @@ -413,9 +412,9 @@ async def assert_volume(compose, mount_dict):
args = [
"create",
"--label",
f"io.podman.compose.project={proj_name}",
f"io.podman.compose.project={compose.project_name}",
"--label",
f"com.docker.compose.project={proj_name}",
f"com.docker.compose.project={compose.project_name}",
]
for item in norm_as_list(labels):
args.extend(["--label", item])
Expand Down Expand Up @@ -534,17 +533,15 @@ def mount_desc_to_volume_args(compose, mount_desc, srv_name, cnt_name): # pylin


def get_mnt_dict(compose, cnt, volume):
proj_name = compose.project_name
srv_name = cnt["_service"]
basedir = compose.dirname
if is_str(volume):
volume = parse_short_mount(volume, basedir)
return fix_mount_dict(compose, volume, proj_name, srv_name)
return fix_mount_dict(compose, volume, srv_name)


async def get_mount_args(compose, cnt, volume):
volume = get_mnt_dict(compose, cnt, volume)
# proj_name = compose.project_name
srv_name = cnt["_service"]
mount_type = volume["type"]
await assert_volume(compose, volume)
Expand Down Expand Up @@ -854,7 +851,6 @@ async def assert_cnt_nets(compose, cnt):
net = cnt.get("network_mode", None)
if net and not net.startswith("bridge"):
return
proj_name = compose.project_name
nets = compose.networks
default_net = compose.default_net
cnt_nets = cnt.get("networks", None)
Expand All @@ -865,14 +861,14 @@ async def assert_cnt_nets(compose, cnt):
net_desc = nets[net] or {}
is_ext = net_desc.get("external", None)
ext_desc = is_ext if is_dict(is_ext) else {}
default_net_name = default_network_name_for_project(compose, proj_name, net, is_ext)
default_net_name = default_network_name_for_project(compose, net, is_ext)
net_name = ext_desc.get("name", None) or net_desc.get("name", None) or default_net_name
try:
await compose.podman.output([], "network", ["exists", net_name])
except subprocess.CalledProcessError as e:
if is_ext:
raise RuntimeError(f"External network [{net_name}] does not exists") from e
args = get_network_create_args(net_desc, proj_name, net_name)
args = get_network_create_args(net_desc, compose.project_name, net_name)
await compose.podman.output([], "network", args)
await compose.podman.output([], "network", ["exists", net_name])

Expand Down Expand Up @@ -911,7 +907,6 @@ def get_net_args(compose, cnt):
sys.exit(1)
else:
is_bridge = True
proj_name = compose.project_name
default_net = compose.default_net
nets = compose.networks
cnt_nets = cnt.get("networks", None)
Expand Down Expand Up @@ -955,7 +950,7 @@ def get_net_args(compose, cnt):
net_desc = nets[net] or {}
is_ext = net_desc.get("external", None)
ext_desc = is_ext if is_dict(is_ext) else {}
default_net_name = default_network_name_for_project(compose, proj_name, net, is_ext)
default_net_name = default_network_name_for_project(compose, net, is_ext)
net_name = ext_desc.get("name", None) or net_desc.get("name", None) or default_net_name
net_names.append(net_name)
net_names_str = ",".join(net_names)
Expand Down Expand Up @@ -991,7 +986,7 @@ def get_net_args(compose, cnt):
net_desc = nets[net_] or {}
is_ext = net_desc.get("external", None)
ext_desc = is_ext if is_dict(is_ext) else {}
default_net_name = default_network_name_for_project(compose, proj_name, net_, is_ext)
default_net_name = default_network_name_for_project(compose, net_, is_ext)
net_name = ext_desc.get("name", None) or net_desc.get("name", None) or default_net_name

ipv4 = net_config_.get("ipv4_address", None)
Expand Down Expand Up @@ -1454,9 +1449,9 @@ async def format_out(stdout):
log.info("exit code: %s", exit_code)
return exit_code

async def volume_ls(self, proj=None):
if not proj:
proj = self.compose.project_name
async def volume_ls(self, proj_name=None):
if not proj_name:
proj_name = self.compose.project_name
output = (
await self.output(
[],
Expand All @@ -1465,7 +1460,7 @@ async def volume_ls(self, proj=None):
"ls",
"--noheading",
"--filter",
f"label=io.podman.compose.project={proj}",
f"label=io.podman.compose.project={proj_name}",
"--format",
"{{.Name}}",
],
Expand Down Expand Up @@ -2490,7 +2485,6 @@ def get_excluded(compose, args):

@cmd_run(podman_compose, "up", "Create and start the entire stack or some of its services")
async def compose_up(compose: PodmanCompose, args):
proj_name = compose.project_name
excluded = get_excluded(compose, args)
if not args.no_build:
# `podman build` does not cache, so don't always build
Expand All @@ -2505,7 +2499,7 @@ async def compose_up(compose: PodmanCompose, args):
"ps",
[
"--filter",
f"label=io.podman.compose.project={proj_name}",
f"label=io.podman.compose.project={compose.project_name}",
"-a",
"--format",
'{{ index .Labels "io.podman.compose.config-hash"}}',
Expand Down Expand Up @@ -2601,14 +2595,13 @@ def _task_cancelled(task: Task) -> bool:


def get_volume_names(compose, cnt):
proj_name = compose.project_name
basedir = compose.dirname
srv_name = cnt["_service"]
ls = []
for volume in cnt.get("volumes", []):
if is_str(volume):
volume = parse_short_mount(volume, basedir)
volume = fix_mount_dict(compose, volume, proj_name, srv_name)
volume = fix_mount_dict(compose, volume, srv_name)
mount_type = volume["type"]
if mount_type != "volume":
continue
Expand Down Expand Up @@ -2688,8 +2681,7 @@ async def compose_down(compose, args):

@cmd_run(podman_compose, "ps", "show status of containers")
async def compose_ps(compose, args):
proj_name = compose.project_name
ps_args = ["-a", "--filter", f"label=io.podman.compose.project={proj_name}"]
ps_args = ["-a", "--filter", f"label=io.podman.compose.project={compose.project_name}"]
if args.quiet is True:
ps_args.extend(["--format", "{{.ID}}"])
elif args.format:
Expand Down

0 comments on commit 9d6b48d

Please sign in to comment.