/*
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
log.Println(r.RemoteAddr, "put", filename, "by", username)
path := filepath.Join(dirPath, filename)
if _, err = os.Stat(path); err == nil {
- log.Println(r.RemoteAddr, "already exists", filename)
+ log.Println(r.RemoteAddr, filename, "already exists")
http.Error(w, "already exists", http.StatusBadRequest)
return
}
src, err := file.Open()
defer src.Close()
if err != nil {
+ log.Println("error", r.RemoteAddr, filename, err)
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}
dst, err := TempFile(dirPath)
if err != nil {
+ log.Println("error", r.RemoteAddr, filename, err)
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}
hasher := sha256.New()
wr := io.MultiWriter(hasher, dst)
if _, err = io.Copy(wr, src); err != nil {
+ log.Println("error", r.RemoteAddr, filename, err)
os.Remove(dst.Name())
dst.Close()
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}
if err = dstBuf.Flush(); err != nil {
+ log.Println("error", r.RemoteAddr, filename, err)
os.Remove(dst.Name())
dst.Close()
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}
if err = dst.Sync(); err != nil {
+ log.Println("error", r.RemoteAddr, filename, err)
os.Remove(dst.Name())
dst.Close()
http.Error(w, err.Error(), http.StatusInternalServerError)
}
}
if err = os.Rename(dst.Name(), path); err != nil {
+ log.Println("error", r.RemoteAddr, path, err)
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}
if err = DirSync(dirPath); err != nil {
+ log.Println("error", r.RemoteAddr, dirPath, err)
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}
if err = WriteFileSync(dirPath, path+"."+HashAlgoSHA256, digest); err != nil {
+ log.Println("error", r.RemoteAddr, path+"."+HashAlgoSHA256, err)
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}
for _, file := range r.MultipartForm.File["gpg_signature"] {
filename := file.Filename
if _, exists := gpgSigsExpected[filename]; !exists {
+ log.Println(r.RemoteAddr, filename, "unexpected GPG signature filename")
http.Error(w, "unexpected GPG signature filename", http.StatusBadRequest)
return
}
log.Println(r.RemoteAddr, "put", filename, "by", username)
path := filepath.Join(dirPath, filename)
if _, err = os.Stat(path); err == nil {
- log.Println(r.RemoteAddr, "already exists", filename)
+ log.Println(r.RemoteAddr, filename, "already exists")
http.Error(w, "already exists", http.StatusBadRequest)
return
}
src, err := file.Open()
if err != nil {
+ log.Println("error", r.RemoteAddr, filename, err)
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}
sig, err := ioutil.ReadAll(src)
src.Close()
if err != nil {
+ log.Println("error", r.RemoteAddr, filename, err)
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}
if err = WriteFileSync(dirPath, path, sig); err != nil {
+ log.Println("error", r.RemoteAddr, path, err)
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}