diff --git a/server/src/config/init.go b/server/src/config/init.go index a9e20ac..e724133 100644 --- a/server/src/config/init.go +++ b/server/src/config/init.go @@ -33,4 +33,6 @@ func init() { fmt.Println(`OpenAI base URL is invalid.`) panic(err) } + + os.MkdirAll(StaticDir+`/tmp`, 0777) } diff --git a/server/src/core/fetch.go b/server/src/core/fetch.go index 5335738..ea0cac3 100644 --- a/server/src/core/fetch.go +++ b/server/src/core/fetch.go @@ -8,7 +8,6 @@ import ( "net/url" "project/config" "project/util" - "project/zj" "time" ) @@ -21,7 +20,7 @@ func (pr *row) fetchRemote() (ab []byte, ok bool, err error) { if err != nil { return nil, false, err } - zj.J(`real url`, u.String()) + // zj.J(`real url`, u.String()) req, err := http.NewRequest(r.Method, u.String(), bytes.NewReader(r.Body)) if err != nil { diff --git a/server/src/core/metrics.go b/server/src/core/metrics.go index bb7a9a8..665664d 100644 --- a/server/src/core/metrics.go +++ b/server/src/core/metrics.go @@ -22,7 +22,7 @@ func doMetrics(ab []byte, cached bool, r *http.Request, req *pb.Req) { o := &pb.Rsp{} err := json.Unmarshal(ab, o) if err != nil { - zj.J(`unmarshal fail`, err) + zj.W(`unmarshal fail`, err) util.WriteFile(`metrics-json-fail`, ab) return } diff --git a/server/src/core/pool.go b/server/src/core/pool.go index 919ec29..6c3eaa7 100644 --- a/server/src/core/pool.go +++ b/server/src/core/pool.go @@ -3,7 +3,6 @@ package core import ( "net/http" "project/pb" - "project/zj" "time" ) @@ -13,8 +12,8 @@ func (c *Core) add(req *pb.Req, hr *http.Request) (pr *row, cached bool) { c.mux.Lock() pr, ok := c.pool[hash] - if false && ok { - zj.F(`hit %x`, hash) + if ok { + // zj.F(`hit %x`, hash) c.mux.Unlock() cached = true return diff --git a/server/src/core/req.go b/server/src/core/req.go index 7b672b4..57470a4 100644 --- a/server/src/core/req.go +++ b/server/src/core/req.go @@ -5,7 +5,6 @@ import ( "net/http" "project/pb" "project/util" - "project/zj" ) func (c *Core) getAB(p *pb.Req, r *http.Request) (ab []byte, cached bool, err error) { @@ -67,7 +66,7 @@ func req(w http.ResponseWriter, r *http.Request) (p *pb.Req, err error) { ContentType: contentType, Body: ab, } - zj.F(`%x %s %s %s`, p.Hash(), method, url, contentType) + // zj.F(`%x %s %s %s`, p.Hash(), method, url, contentType) return } diff --git a/server/src/core/web.go b/server/src/core/web.go index c859c17..403ba30 100644 --- a/server/src/core/web.go +++ b/server/src/core/web.go @@ -4,7 +4,6 @@ import ( "errors" "net/http" "project/metrics" - "project/zj" ) var errSkip = errors.New(`skip`) @@ -31,7 +30,7 @@ func (c *Core) ServeHTTP(w http.ResponseWriter, r *http.Request) { err500(w) return } - zj.J(`cached`, cached) + // zj.J(`cached`, cached) w.Header().Add(`Content-Type`, `application/json`) w.Write(ab)