deno.land / x / esm@v135_2 / server / config / config.go
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268package config
import ( "encoding/json" "fmt" "net/url" "os" "path" "path/filepath" "runtime" "strings"
"github.com/ije/gox/utils")
type Config struct { Port uint16 `json:"port,omitempty"` TlsPort uint16 `json:"tlsPort,omitempty"` BuildConcurrency uint16 `json:"buildConcurrency,omitempty"` BanList BanList `json:"banList,omitempty"` AllowList AllowList `json:"allowList,omitempty"` AuthSecret string `json:"authSecret,omitempty"` WorkDir string `json:"workDir,omitempty"` Cache string `json:"cache,omitempty"` Database string `json:"database,omitempty"` Storage string `json:"storage,omitempty"` LogLevel string `json:"logLevel,omitempty"` LogDir string `json:"logDir,omitempty"` CdnOrigin string `json:"cdnOrigin,omitempty"` CdnBasePath string `json:"cdnBasePath,omitempty"` NpmRegistry string `json:"npmRegistry,omitempty"` NpmToken string `json:"npmToken,omitempty"` NpmRegistryScope string `json:"npmRegistryScope,omitempty"` NpmUser string `json:"npmUser,omitempty"` NpmPassword string `json:"npmPassword,omitempty"` NoCompress bool `json:"noCompress,omitempty"`}
type BanList struct { Packages []string `json:"packages"` Scopes []BanScope `json:"scopes"`}
type BanScope struct { Name string `json:"name"` Excludes []string `json:"excludes"`}
type AllowList struct { Packages []string `json:"packages"` Scopes []AllowScope `json:"scopes"`}
type AllowScope struct { Name string `json:"name"`}
// Load loads config from the given file. Panic if failed to load.func Load(filename string) (*Config, error) { var ( cfg *Config cfgFile *os.File err error )
cfgFile, err = os.Open(filename) if err != nil { return nil, fmt.Errorf("fail to read config file: %w", err) } defer cfgFile.Close()
err = json.NewDecoder(cfgFile).Decode(&cfg) if err != nil { return nil, fmt.Errorf("fail to parse config: %w", err) }
// fix config if cfg.WorkDir == "" { homeDir, err := os.UserHomeDir() if err != nil { return nil, fmt.Errorf("fail to get current user home directory: %w", err) } cfg.WorkDir = path.Join(homeDir, ".esmd") } else { cfg.WorkDir, err = filepath.Abs(cfg.WorkDir) if err != nil { return nil, fmt.Errorf("fail to get absolute path of the work directory: %w", err) } } return fixConfig(cfg), nil}
func Default() *Config { homeDir, err := os.UserHomeDir() if err != nil { panic(err) } return fixConfig(&Config{ WorkDir: path.Join(homeDir, ".esmd"), })}
func fixConfig(c *Config) *Config { if c.Port == 0 { c.Port = 8080 } if c.CdnOrigin != "" { _, e := url.Parse(c.CdnOrigin) if e != nil { panic("invalid Cdnorigin url: " + e.Error()) } c.CdnOrigin = strings.TrimRight(c.CdnOrigin, "/") } else { v := os.Getenv("CDN_ORIGIN") if v != "" { if _, e := url.Parse(v); e == nil { c.CdnOrigin = strings.TrimRight(v, "/") } } } if c.CdnBasePath != "" { a := strings.Split(c.CdnBasePath, "/") path := make([]string, len(a)) n := 0 for _, p := range a { if p != "" && p != "." { path[n] = p n++ } } if n > 0 { c.CdnBasePath = "/" + strings.Join(path[:n], "/") } else { c.CdnBasePath = "" } } else { v := os.Getenv("CDN_BASE_PATH") if v != "" { c.CdnBasePath = utils.CleanPath(v) } } if c.BuildConcurrency == 0 { c.BuildConcurrency = uint16(runtime.NumCPU()) } if c.Cache == "" { c.Cache = "memory:default" } if c.Database == "" { c.Database = fmt.Sprintf("bolt:%s", path.Join(c.WorkDir, "esm.db")) } if c.Storage == "" { c.Storage = fmt.Sprintf("local:%s", path.Join(c.WorkDir, "storage")) } if c.LogDir == "" { c.LogDir = path.Join(c.WorkDir, "log") } if c.LogLevel == "" { c.LogLevel = "info" } if c.NpmRegistry != "" { _, e := url.Parse(c.NpmRegistry) if e != nil { panic("invalid npm registry url: " + e.Error()) } c.NpmRegistry = strings.TrimRight(c.NpmRegistry, "/") + "/" } else { v := os.Getenv("NPM_REGISTRY") if v != "" { if _, e := url.Parse(v); e == nil { c.NpmRegistry = strings.TrimRight(v, "/") + "/" } } } if c.NpmToken == "" { c.NpmToken = os.Getenv("NPM_TOKEN") } if c.NpmRegistryScope == "" { c.NpmRegistryScope = os.Getenv("NPM_REGISTRY_SCOPE") } if c.NpmUser == "" { c.NpmUser = os.Getenv("NPM_USER") } if c.NpmPassword == "" { c.NpmPassword = os.Getenv("NPM_PASSWORD") } if c.AuthSecret == "" { c.AuthSecret = os.Getenv("SERVER_AUTH_SECRET") } return c}
// extractPackageName Will take a packageName as input extract key// parts and return them//// fullNameWithoutVersion e.g. @github/faker// scope e.g. @github// nameWithoutVersionScope e.g. fakerfunc extractPackageName(packageName string) (fullNameWithoutVersion string, scope string, nameWithoutVersionScope string) { paths := strings.Split(packageName, "/") if strings.HasPrefix(packageName, "@") { scope = paths[0] nameWithoutVersionScope = strings.Split(paths[1], "@")[0] fullNameWithoutVersion = fmt.Sprintf("%s/%s", scope, nameWithoutVersionScope) } else { // the package has no scope prefix nameWithoutVersionScope = strings.Split(paths[0], "@")[0] fullNameWithoutVersion = nameWithoutVersionScope }
return fullNameWithoutVersion, scope, nameWithoutVersionScope}
// IsPackageBanned Checking if the package is banned.// The `packages` list is the highest priority ban rule to match,// so the `excludes` list in the `scopes` list won't take effect if the package is banned in `packages` listfunc (banList *BanList) IsPackageBanned(fullName string) bool { fullNameWithoutVersion, scope, nameWithoutVersionScope := extractPackageName(fullName)
for _, p := range banList.Packages { if fullNameWithoutVersion == p { return true } }
for _, s := range banList.Scopes { if scope == s.Name { return !isPackageExcluded(nameWithoutVersionScope, s.Excludes) } }
return false}
// IsPackageAllowed Checking if the package is allowed.// The `packages` list is the highest priority allow rule to match,// so the `includes` list in the `scopes` list won't take effect if the package is allowed in `packages` listfunc (allowList *AllowList) IsPackageAllowed(fullName string) bool { if len(allowList.Packages) == 0 && len(allowList.Scopes) == 0 { return true }
fullNameWithoutVersion, scope, _ := extractPackageName(fullName)
for _, p := range allowList.Packages { if fullNameWithoutVersion == p { return true } }
for _, s := range allowList.Scopes { if scope == s.Name { return true } }
return false}
func isPackageExcluded(name string, excludes []string) bool { for _, exclude := range excludes { if name == exclude { return true } }
return false}
esm
Version Info
a year ago
