/*
GoCheese -- Python private package repository and caching proxy
-Copyright (C) 2019 Sergey Matveev <stargrave@stargrave.org>
- 2019 Elena Balakhonova <balakhonova_e@riseup.net>
+Copyright (C) 2019-2020 Sergey Matveev <stargrave@stargrave.org>
+ 2019-2020 Elena Balakhonova <balakhonova_e@riseup.net>
This program is free software: you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
)
const (
+ Version = "2.4.1"
HTMLBegin = `<!DOCTYPE html>
<html>
<head>
pypiURL = flag.String("pypi", "https://pypi.org/simple/", "Upstream PyPI URL")
passwdPath = flag.String("passwd", "passwd", "Path to file with authenticators")
passwdCheck = flag.Bool("passwd-check", false, "Test the -passwd file for syntax errors and exit")
- fsck = flag.Bool("fsck", false, "Check integrity of all packages")
+ fsck = flag.Bool("fsck", false, "Check integrity of all packages (errors are in stderr)")
maxClients = flag.Int("maxclients", 128, "Maximal amount of simultaneous clients")
version = flag.Bool("version", false, "Print version information")
warranty = flag.Bool("warranty", false, "Print warranty information")
- Version string = "UNKNOWN"
killed bool
pypiURLParsed *url.URL
)
-func mkdirForPkg(w http.ResponseWriter, r *http.Request, dir string) bool {
- path := filepath.Join(*root, dir)
+func mkdirForPkg(w http.ResponseWriter, r *http.Request, pkgName string) bool {
+ path := filepath.Join(*root, pkgName)
if _, err := os.Stat(path); os.IsNotExist(err) {
if err = os.Mkdir(path, os.FileMode(0777)); err != nil {
+ log.Println("error", r.RemoteAddr, "mkdir", pkgName, err)
http.Error(w, err.Error(), http.StatusInternalServerError)
return false
}
- log.Println(r.RemoteAddr, "mkdir", dir)
+ log.Println(r.RemoteAddr, "mkdir", pkgName)
}
return true
}
func listRoot(w http.ResponseWriter, r *http.Request) {
files, err := ioutil.ReadDir(*root)
if err != nil {
+ log.Println("error", r.RemoteAddr, "root", err)
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}
func listDir(
w http.ResponseWriter,
r *http.Request,
- dir string,
- autorefresh,
- gpgUpdate bool,
+ pkgName string,
+ autorefresh, gpgUpdate bool,
) {
- dirPath := filepath.Join(*root, dir)
+ dirPath := filepath.Join(*root, pkgName)
if autorefresh {
- if !refreshDir(w, r, dir, "", gpgUpdate) {
+ if !refreshDir(w, r, pkgName, "", gpgUpdate) {
return
}
- } else if _, err := os.Stat(dirPath); os.IsNotExist(err) && !refreshDir(w, r, dir, "", false) {
+ } else if _, err := os.Stat(dirPath); os.IsNotExist(err) && !refreshDir(w, r, pkgName, "", false) {
return
}
fis, err := ioutil.ReadDir(dirPath)
if err != nil {
+ log.Println("error", r.RemoteAddr, "list", pkgName, err)
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}
files[fi.Name()] = struct{}{}
}
var result bytes.Buffer
- result.WriteString(fmt.Sprintf(HTMLBegin, dir))
+ result.WriteString(fmt.Sprintf(HTMLBegin, pkgName))
for _, algo := range knownHashAlgos {
for fn, _ := range files {
if killed {
delete(files, fn)
digest, err := ioutil.ReadFile(filepath.Join(dirPath, fn))
if err != nil {
+ log.Println("error", r.RemoteAddr, "list", fn, err)
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}
result.WriteString(fmt.Sprintf(
HTMLElement,
strings.Join([]string{
- *refreshURLPath, dir, "/", fnClean,
+ *refreshURLPath, pkgName, "/", fnClean,
"#", algo, "=", hex.EncodeToString(digest),
}, ""),
gpgSigAttr,
w.Write(result.Bytes())
}
-func servePkg(w http.ResponseWriter, r *http.Request, dir, filename string) {
+func servePkg(w http.ResponseWriter, r *http.Request, pkgName, filename string) {
log.Println(r.RemoteAddr, "get", filename)
- path := filepath.Join(*root, dir, filename)
+ path := filepath.Join(*root, pkgName, filename)
if _, err := os.Stat(path); os.IsNotExist(err) {
- if !refreshDir(w, r, dir, filename, false) {
+ if !refreshDir(w, r, pkgName, filename, false) {
return
}
}
log.Fatalln(err)
}
refreshPasswd()
- log.Println("root:", *root, "bind:", *bind)
+ log.Println("root:", *root)
+ log.Println("bind:", *bind)
+ log.Println("pypi:", *pypiURL)
ln, err := net.Listen("tcp", *bind)
if err != nil {
signal.Notify(needsShutdown, syscall.SIGTERM, syscall.SIGINT)
go func() {
for range needsRefreshPasswd {
- log.Println("Refreshing passwords")
+ log.Println("refreshing passwords")
refreshPasswd()
}
}()
go func(s *http.Server) {
<-needsShutdown
killed = true
- log.Println("Shutting down")
+ log.Println("shutting down")
ctx, cancel := context.WithTimeout(context.TODO(), time.Minute)
exitErr <- s.Shutdown(ctx)
cancel()