forked from mirrors/pkg-proxy
72 lines
1.5 KiB
Go
72 lines
1.5 KiB
Go
package debian
|
|
|
|
import (
|
|
"fmt"
|
|
"net/url"
|
|
)
|
|
|
|
// Config configures routes
|
|
type Config struct {
|
|
IncludeDefault bool `json:"include_default" yaml:"include_default"`
|
|
Route []RouteConfig `json:"route" yaml:"route"`
|
|
}
|
|
|
|
// RouteConfig configures a route
|
|
type RouteConfig struct {
|
|
Path string `json:"path" yaml:"path"`
|
|
Upstream []UpstreamConfig `json:"upstream" yaml:"upstream"`
|
|
}
|
|
|
|
// UpstreamConfig configures an upstream (source)
|
|
type UpstreamConfig struct {
|
|
Name string `json:"name" yaml:"name"`
|
|
Upstream string `json:"upstream" yaml:"upstream"`
|
|
}
|
|
|
|
// RouteDefault is the default route
|
|
var RouteDefault = RouteConfig{
|
|
Path: "/debian",
|
|
Upstream: []UpstreamConfig{
|
|
{
|
|
Name: "debian.org",
|
|
Upstream: "http://deb.debian.org/debian",
|
|
},
|
|
},
|
|
}
|
|
|
|
func (c *Config) Validate() error {
|
|
for _, route := range c.Route {
|
|
if err := route.Validate(); err != nil {
|
|
return err
|
|
}
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func (r *RouteConfig) Validate() error {
|
|
// TODO: validate Path
|
|
|
|
if len(r.Upstream) == 0 {
|
|
return fmt.Errorf("debian route %q does not have any upstreams", r.Path)
|
|
}
|
|
if len(r.Upstream) > 1 {
|
|
return fmt.Errorf("debian route %q has multiple upstreams; this is not yet supported", r.Path)
|
|
}
|
|
|
|
for _, upstream := range r.Upstream {
|
|
if err := upstream.Validate(); err != nil {
|
|
return err
|
|
}
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func (u *UpstreamConfig) Validate() error {
|
|
if _, err := url.Parse(u.Upstream); err != nil {
|
|
return fmt.Errorf("debian upstream upstream %q is not a valid URL", u.Upstream)
|
|
}
|
|
|
|
return nil
|
|
}
|