Function DecodeAllResources

internal/pulumi/mapper.go:41–86

DecodeAllResources decodes collected Pulumi resources using the metadata-driven mapping. It replaces the old per-resource decoder approach — no Go code changes are needed to support new resource types; just update pulumi_resource_map.json in the pipeline and refresh metadata.

(records []resources.ResourceRecord, meta *api.MetadataResponse)

// are needed to support new resource types; just update pulumi_resource_map.json
// in the pipeline and refresh metadata.
func DecodeAllResources(records []resources.ResourceRecord, meta *api.MetadataResponse) []resources.DecodedResource {
	// Build free-type lookup set from metadata.
	freeSet := make(map[string]bool, len(meta.FreeTypes))
	for _, ft := range meta.FreeTypes {
		freeSet[ft] = true
	}

	var results []resources.DecodedResource

	for _, record := range records {
		if skipTypes[record.Type] {
			continue
		}

		normalizedType := normalizeType(record.Type)

		// Check free types first.
		if freeSet[record.Type] || freeSet[normalizedType] {
			results = append(results, awsdecode.DecodeFreeResource(record))
			continue
		}

		// Look up in pulumi_resources mapping.
		mapping, ok := meta.PulumiResources[normalizedType]
		if !ok {
			// Also try the original type (in case normalizeType changed it).
			mapping, ok = meta.PulumiResources[record.Type]
		}
		if !ok {
			// Unknown type — include as no-pricing so it still shows in output.
			results = append(results, resources.DecodedResource{
				Name:       record.Name,
				RawType:    record.Type,
				NoPricing:  true,
				Props:      awsdecode.InputsToProps(record),
				InputsJSON: awsdecode.FormatInputProperties(record.Inputs),
			})
			continue
		}

		decoded := decodeFromMapping(record, mapping)
		results = append(results, decoded...)
	}

	return consolidateS3Objects(results)
}

// s3ObjectTypes are the Pulumi resource types for individual S3 objects.
var s3ObjectTypes = map[string]bool{