cloudflare

var Manager = schema.ResourceManager{
	Name:              "cloudflare",
	ResourcePrototype: &DNS{},
	GroupPrototype:    &Cloudflare{},
	Provision: func(group interface{}, resource interface{}, l schema.Logger) error {
		ctx := context.Background()
		g := group.(*Cloudflare)
		d := resource.(*DNS)

		typeID, err := d.Type.Render(nil)
		if err != nil {
			return err
		}
		name, err := d.Name.Render(nil)
		if err != nil {
			return err
		}
		content, err := d.Content.Render(nil)
		if err != nil {
			return err
		}
		ttl, err := d.TTL.Render(nil)
		if err != nil {
			return err
		}
		ttlInt, err := strconv.ParseInt(ttl, 10, 64)
		if err != nil {
			return fmt.Errorf("could not parse '%v' to integer TTL", ttl)
		}

		names := make([]string, 0)
		for _, n := range strings.Split(name, ",") {
			n = strings.TrimSpace(n)
			if n != "" {
				match := numberRegex.FindAllStringSubmatch(n, -1)
				if len(match) == 1 {
					start, err := strconv.ParseInt(match[0][1], 10, 64)
					if err != nil {
						return err
					}
					end, err := strconv.ParseInt(match[0][2], 10, 64)
					if err != nil {
						return err
					}
					if start >= end {
						return fmt.Errorf("Cloudflare name '%v', the start numeric generator must be less than the end. E.g; '[0-100]'", n)
					}

					for i := start; i < end; i++ {
						names = append(names, numberRegex.ReplaceAllString(n, fmt.Sprintf("%v", i)))
					}
				} else {
					names = append(names, n)
				}
			}
		}

		contents := make([]string, 0)
		for _, c := range strings.Split(content, ",") {
			c = strings.TrimSpace(c)
			if c != "" {
				contents = append(contents, c)
			}
		}

		targetRecords := make(map[string][]string)
		cptr := 0
		for _, name := range names {
			content := contents[cptr%len(contents)]
			cptr += 1

			arr, found := targetRecords[name]
			if !found {
				arr = make([]string, 0)
			}
			targetRecords[name] = append(arr, content)
		}

		nameptr := 0
		for i := cptr; i < len(contents); i++ {
			content := contents[i]
			name := names[nameptr%len(names)]
			nameptr += 1

			arr, found := targetRecords[name]
			if !found {
				arr = make([]string, 0)
			}
			targetRecords[name] = append(arr, content)
		}

		api, zoneID, records, err := getApiAndRecords(ctx, g)
		if err != nil {
			return err
		}

		for targetName, targets := range targetRecords {
			sourceRecords := records[targetName]
			for _, targetContent := range targets {
				var foundRecord *cloudflarego.DNSRecord
				for i, record := range sourceRecords {
					if record.Content == targetContent && record.Type == typeID {
						foundRecord = &record
						sourceRecords = append(sourceRecords[:i], sourceRecords[i+1:]...)
						break
					}
				}
				if foundRecord != nil {
					if (foundRecord.Proxied != nil && *foundRecord.Proxied != d.Proxy) || foundRecord.TTL != int(ttlInt) {
						l.Logf("Updating record: %v (%v/%v) with type:%v, proxied:%v, ttl: %v", foundRecord.ID, foundRecord.Name, foundRecord.Content, typeID, d.Proxy, ttlInt)

						err := api.UpdateDNSRecord(ctx, zoneID, foundRecord.ID, cloudflarego.DNSRecord{
							Type:    typeID,
							Proxied: &d.Proxy,
							TTL:     int(ttlInt),
						})
						if err != nil {
							return fmt.Errorf("Could not update record#%v with type:%v, proxied:%v, ttl: %v. Error: %v", foundRecord.ID, typeID, d.Proxy, ttlInt, err)
						}
					}
				} else {

					l.Logf("Creating record with type:%v, name:%v, content:%v, proxied:%v, ttl:%v", typeID, targetName, targetContent, d.Proxy, ttlInt)
					_, err := api.CreateDNSRecord(ctx, zoneID, cloudflarego.DNSRecord{
						Type:    typeID,
						Name:    targetName,
						Content: targetContent,
						Proxied: &d.Proxy,
						TTL:     int(ttlInt),
					})
					if err != nil {
						return fmt.Errorf("Could not create record with type:%v, name:%v, content:%v, proxied:%v, ttl:%v. Error: %v", typeID, targetName, targetContent, d.Proxy, ttlInt, err)
					}
				}
			}
			for _, record := range sourceRecords {
				if record.Type == typeID {
					l.Logf("Deleting old record with type:%v, name:%v, content:%v, proxied:%v, ttl:%v", record.Type, record.Name, record.Content, record.Proxied, record.TTL)
					err := api.DeleteDNSRecord(ctx, zoneID, record.ID)
					if err != nil {
						return fmt.Errorf("Could not delete old record with type:%v, name:%v, content:%v, proxied:%v, ttl:%v", record.Type, record.Name, record.Content, record.Proxied, record.TTL)
					}
				}
			}
		}

		return nil
	},
}