Method ensureNetworks

internal/deploy/deployer.go:251–337

(ctx context.Context, project *composetypes.Project)

}

func (d *Deployer) ensureNetworks(ctx context.Context, project *composetypes.Project) (map[string]string, error) {
	ids := make(map[string]string)

	// Two listings: project-owned (for idempotent reuse) and external references.
	// Project filter keeps the response small on hosts with many stacks.
	ownedList, err := d.cli.NetworkList(ctx, client.NetworkListOptions{
		Filters: make(client.Filters).Add("label", labelComposeProject+"="+project.Name),
	})
	if err != nil {
		return nil, fmt.Errorf("listing networks: %w", err)
	}
	ownedByName := make(map[string]string, len(ownedList.Items))
	for _, n := range ownedList.Items {
		ownedByName[n.Name] = n.ID
	}

	// External networks are looked up unfiltered, on demand (they are not project-labeled).
	var externalByName map[string]string
	lookupExternalNet := func() error {
		if externalByName != nil {
			return nil
		}
		all, err := d.cli.NetworkList(ctx, client.NetworkListOptions{})
		if err != nil {
			return fmt.Errorf("listing external networks: %w", err)
		}
		externalByName = make(map[string]string, len(all.Items))
		for _, n := range all.Items {
			externalByName[n.Name] = n.ID
		}
		return nil
	}

	for name, netCfg := range project.Networks {
		if bool(netCfg.External) {
			extName := netCfg.Name
			if extName == "" {
				extName = name
			}
			if err := lookupExternalNet(); err != nil {
				return nil, err
			}
			id, ok := externalByName[extName]
			if !ok {
				return nil, fmt.Errorf("external network %q not found", extName)
			}
			ids[name] = id
			continue
		}

		fullName := netCfg.Name
		if fullName == "" {
			fullName = project.Name + "_" + name
		}

		if id, ok := ownedByName[fullName]; ok {
			ids[name] = id
			log.Info().Str("network", fullName).Msg("Network already exists, skipping")