mirror of
				https://github.com/caddyserver/caddy.git
				synced 2025-11-03 19:17:29 -05:00 
			
		
		
		
	
		
			
				
	
	
		
			96 lines
		
	
	
		
			2.2 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
			
		
		
	
	
			96 lines
		
	
	
		
			2.2 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
package setup
 | 
						|
 | 
						|
import (
 | 
						|
	"fmt"
 | 
						|
	"strconv"
 | 
						|
	"strings"
 | 
						|
 | 
						|
	"github.com/mholt/caddy/middleware"
 | 
						|
	"github.com/mholt/caddy/middleware/gzip"
 | 
						|
)
 | 
						|
 | 
						|
// Gzip configures a new gzip middleware instance.
 | 
						|
func Gzip(c *Controller) (middleware.Middleware, error) {
 | 
						|
	configs, err := gzipParse(c)
 | 
						|
	if err != nil {
 | 
						|
		return nil, err
 | 
						|
	}
 | 
						|
 | 
						|
	return func(next middleware.Handler) middleware.Handler {
 | 
						|
		return gzip.Gzip{Next: next, Configs: configs}
 | 
						|
	}, nil
 | 
						|
}
 | 
						|
 | 
						|
func gzipParse(c *Controller) ([]gzip.Config, error) {
 | 
						|
	var configs []gzip.Config
 | 
						|
 | 
						|
	for c.Next() {
 | 
						|
		config := gzip.Config{}
 | 
						|
 | 
						|
		pathFilter := gzip.PathFilter{make(gzip.Set)}
 | 
						|
		extFilter := gzip.ExtFilter{make(gzip.Set)}
 | 
						|
 | 
						|
		// No extra args expected
 | 
						|
		if len(c.RemainingArgs()) > 0 {
 | 
						|
			return configs, c.ArgErr()
 | 
						|
		}
 | 
						|
 | 
						|
		for c.NextBlock() {
 | 
						|
			switch c.Val() {
 | 
						|
			case "ext":
 | 
						|
				exts := c.RemainingArgs()
 | 
						|
				if len(exts) == 0 {
 | 
						|
					return configs, c.ArgErr()
 | 
						|
				}
 | 
						|
				for _, e := range exts {
 | 
						|
					if !strings.HasPrefix(e, ".") && e != gzip.ExtWildCard {
 | 
						|
						return configs, fmt.Errorf(`gzip: invalid extension "%v" (must start with dot)`, e)
 | 
						|
					}
 | 
						|
					extFilter.Exts.Add(e)
 | 
						|
				}
 | 
						|
			case "not":
 | 
						|
				paths := c.RemainingArgs()
 | 
						|
				if len(paths) == 0 {
 | 
						|
					return configs, c.ArgErr()
 | 
						|
				}
 | 
						|
				for _, p := range paths {
 | 
						|
					if p == "/" {
 | 
						|
						return configs, fmt.Errorf(`gzip: cannot exclude path "/" - remove directive entirely instead`)
 | 
						|
					}
 | 
						|
					if !strings.HasPrefix(p, "/") {
 | 
						|
						return configs, fmt.Errorf(`gzip: invalid path "%v" (must start with /)`, p)
 | 
						|
					}
 | 
						|
					pathFilter.IgnoredPaths.Add(p)
 | 
						|
				}
 | 
						|
			case "level":
 | 
						|
				if !c.NextArg() {
 | 
						|
					return configs, c.ArgErr()
 | 
						|
				}
 | 
						|
				level, _ := strconv.Atoi(c.Val())
 | 
						|
				config.Level = level
 | 
						|
			default:
 | 
						|
				return configs, c.ArgErr()
 | 
						|
			}
 | 
						|
		}
 | 
						|
 | 
						|
		config.Filters = []gzip.Filter{}
 | 
						|
 | 
						|
		// If ignored paths are specified, put in front to filter with path first
 | 
						|
		if len(pathFilter.IgnoredPaths) > 0 {
 | 
						|
			config.Filters = []gzip.Filter{pathFilter}
 | 
						|
		}
 | 
						|
 | 
						|
		// Then, if extensions are specified, use those to filter.
 | 
						|
		// Otherwise, use default extensions filter.
 | 
						|
		if len(extFilter.Exts) > 0 {
 | 
						|
			config.Filters = append(config.Filters, extFilter)
 | 
						|
		} else {
 | 
						|
			config.Filters = append(config.Filters, gzip.DefaultExtFilter())
 | 
						|
		}
 | 
						|
 | 
						|
		configs = append(configs, config)
 | 
						|
	}
 | 
						|
 | 
						|
	return configs, nil
 | 
						|
}
 |