Function consolidateS3Objects

internal/pulumi/mapper.go:99–171

consolidateS3Objects merges multiple S3 BucketObject/BucketObjectv2 DecodedResources that share the same region, bucket, and storage volume type into a single "S3 Objects (xN)" entry. Each object otherwise produces its own "Storage" line with the same 25 GB-Mo default usage, duplicating the bucket's

(results []resources.DecodedResource)

// its own "Storage" line with the same 25 GB-Mo default usage, duplicating
// the bucket's own Storage line and overstating the estimate.
func consolidateS3Objects(results []resources.DecodedResource) []resources.DecodedResource {
	type group struct {
		indices []int
		names   []string
	}
	groups := make(map[string]*group)
	var order []string

	for i, d := range results {
		if !s3ObjectTypes[d.RawType] {
			continue
		}
		key := d.Region + "|" + d.Props["bucket"] + "|" + d.Props["volumeType"]
		g, ok := groups[key]
		if !ok {
			g = &group{}
			groups[key] = g
			order = append(order, key)
		}
		g.indices = append(g.indices, i)
		g.names = append(g.names, d.Name)
	}

	const maxNames = 5
	replace := make(map[int]resources.DecodedResource)
	remove := make(map[int]bool)

	for _, key := range order {
		g := groups[key]
		if len(g.indices) < 2 {
			continue
		}

		nameList := strings.Join(g.names[:min(len(g.names), maxNames)], ", ")
		if len(g.names) > maxNames {
			nameList += fmt.Sprintf(", ...and %d more", len(g.names)-maxNames)
		}

		first := g.indices[0]
		consolidated := results[first]
		consolidated.Name = fmt.Sprintf("S3 Objects (x%d)", len(g.indices))

		props := make(map[string]string, len(consolidated.Props)+2)
		for k, v := range consolidated.Props {
			props[k] = v
		}
		props["objectCount"] = strconv.Itoa(len(g.indices))
		props["objects"] = nameList
		consolidated.Props = props

		replace[first] = consolidated
		for _, idx := range g.indices[1:] {
			remove[idx] = true
		}
	}

	if len(replace) == 0 {
		return results