Function createRecords

commands.go:603–660

(ctx context.Context, args createArgs)

}

func createRecords(ctx context.Context, args createArgs) {
	zone := lookupZone(ctx, args.name)
	records := parseRecordList(args.records, zone)
	expandSelfAliases(records, zone)

	grouped := groupRecords(records)

	var existing []*route53types.ResourceRecordSet
	if args.replace || args.append {
		var err error
		existing, err = ListAllRecordSets(ctx, r53, *zone.Id)
		fatalIfErr(err)
	}

	additions := []route53types.Change{}
	deletions := []route53types.Change{}
	for _, values := range grouped {
		rrset := ConvertBindToRRSet(values)
		args.applyRRSetParams(rrset)

		addChange := route53types.Change{
			Action:            route53types.ChangeActionCreate,
			ResourceRecordSet: rrset,
		}
		additions = append(additions, addChange)

		if args.replace || args.append {
			// add DELETE if there is an existing record
			for _, candidate := range existing {
				if equalCaseInsensitiveStringPtrs(rrset.Name, candidate.Name) &&
					rrset.Type == candidate.Type &&
					equalStringPtrs(rrset.SetIdentifier, candidate.SetIdentifier) {
					change := route53types.Change{
						Action:            route53types.ChangeActionDelete,
						ResourceRecordSet: candidate,
					}
					deletions = append(deletions, change)

					if args.append {
						additions[len(additions)-1].ResourceRecordSet.ResourceRecords = append(additions[len(additions)-1].ResourceRecordSet.ResourceRecords, candidate.ResourceRecords...)
					}
					break
				}
			}
		}
	}

	resp := batchChanges(ctx, additions, deletions, zone)

	for _, record := range records {
		txt := strings.Replace(record.String(), "\t", " ", -1)
		fmt.Printf("Created record: '%s'\n", txt)
	}

	if args.wait {
		waitForChange(ctx, resp.ChangeInfo)
	}
}