Method InvalidateCDNCache

lib/cloudfront.go:57–114

(ctx context.Context, paths ...string)

}

func (c *cloudFrontClient) InvalidateCDNCache(ctx context.Context, paths ...string) error {
	if len(paths) == 0 {
		return nil
	}

	invalidateForID := func(id string) error {
		dcfg, err := c.cf.GetDistribution(ctx, &cloudfront.GetDistributionInput{
			Id: &id,
		})
		if err != nil {
			return err
		}

		originPath := *dcfg.Distribution.DistributionConfig.Origins.Items[0].OriginPath
		var root string
		if originPath != "" || c.bucketPath != "" {
			var subPath string
			root, subPath = c.determineRootAndSubPath(c.bucketPath, originPath)
			if subPath != "" {
				for i, p := range paths {
					paths[i] = strings.TrimPrefix(p, subPath)
				}
			}
		}

		// This will try to reduce the number of invaldation paths to maximum 8.
		// If that isn't possible it will fall back to a full invalidation, e.g. "/*".
		// CloudFront allows 1000 free invalidations per month. After that they
		// cost money, so we want to keep this down.
		paths = c.normalizeInvalidationPaths(root, 8, c.force, paths...)

		if len(paths) > 10 {
			c.logger.Printf("Create CloudFront invalidation request for %d paths", len(paths))
		} else {
			c.logger.Printf("Create CloudFront invalidation request for %v", paths)
		}

		in := &cloudfront.CreateInvalidationInput{
			DistributionId:    &id,
			InvalidationBatch: c.pathsToInvalidationBatch(time.Now().Format("20060102150405"), paths...),
		}

		_, err = c.cf.CreateInvalidation(
			ctx,
			in,
		)

		return err
	}

	for _, id := range c.distributionIDs {
		if err := invalidateForID(id); err != nil {
			return err
		}
	}

	return nil
}