ussd/internal/http/server.go

123 lines
2.3 KiB
Go
Raw Normal View History

package http
import (
2024-09-11 18:32:55 +02:00
"io/ioutil"
"net/http"
2024-09-12 04:30:23 +02:00
"strconv"
"git.defalsify.org/vise.git/logging"
2024-09-12 04:30:23 +02:00
"git.grassecon.net/urdt/ussd/internal/handlers"
)
var (
logg = logging.NewVanilla().WithDomain("httpserver")
)
type DefaultRequestParser struct {
}
2024-09-12 04:30:23 +02:00
func(rp *DefaultRequestParser) GetSessionId(rq any) (string, error) {
rqv, ok := rq.(*http.Request)
if !ok {
return "", handlers.ErrInvalidRequest
}
v := rqv.Header.Get("X-Vise-Session")
2024-09-11 18:32:55 +02:00
if v == "" {
2024-09-12 04:30:23 +02:00
return "", handlers.ErrSessionMissing
}
2024-09-11 18:32:55 +02:00
return v, nil
}
2024-09-12 04:30:23 +02:00
func(rp *DefaultRequestParser) GetInput(rq any) ([]byte, error) {
rqv, ok := rq.(*http.Request)
if !ok {
return nil, handlers.ErrInvalidRequest
}
defer rqv.Body.Close()
v, err := ioutil.ReadAll(rqv.Body)
2024-09-11 18:32:55 +02:00
if err != nil {
return nil, err
}
2024-09-11 18:32:55 +02:00
return v, nil
}
type SessionHandler struct {
handlers.RequestHandler
}
func ToSessionHandler(h handlers.RequestHandler) *SessionHandler {
return &SessionHandler{
RequestHandler: h,
}
}
2024-09-12 04:30:23 +02:00
func(f *SessionHandler) writeError(w http.ResponseWriter, code int, err error) {
s := err.Error()
w.Header().Set("Content-Length", strconv.Itoa(len(s)))
w.WriteHeader(code)
_, err = w.Write([]byte{})
if err != nil {
2024-09-12 04:30:23 +02:00
logg.Errorf("error writing error!!", "err", err, "olderr", s)
w.WriteHeader(500)
}
return
}
2024-09-12 04:30:23 +02:00
func(f *SessionHandler) ServeHTTP(w http.ResponseWriter, req *http.Request) {
var code int
var err error
var perr error
2024-09-12 04:30:23 +02:00
rqs := handlers.RequestSession{
Ctx: req.Context(),
Writer: w,
}
rp := f.GetRequestParser()
cfg := f.GetConfig()
cfg.SessionId, err = rp.GetSessionId(req)
if err != nil {
2024-09-12 04:30:23 +02:00
logg.ErrorCtxf(rqs.Ctx, "", "header processing error", err)
f.writeError(w, 400, err)
}
rqs.Config = cfg
rqs.Input, err = rp.GetInput(req)
2024-09-12 04:30:23 +02:00
if err != nil {
logg.ErrorCtxf(rqs.Ctx, "", "header processing error", err)
f.writeError(w, 400, err)
return
}
2024-09-12 04:30:23 +02:00
rqs, err = f.Process(rqs)
switch err {
case handlers.ErrStorage:
code = 500
case handlers.ErrEngineInit:
code = 500
case handlers.ErrEngineExec:
code = 500
default:
code = 200
}
2024-09-12 04:30:23 +02:00
if code != 200 {
f.writeError(w, 500, err)
return
}
w.WriteHeader(200)
w.Header().Set("Content-Type", "text/plain")
rqs, err = f.Output(rqs)
rqs, perr = f.Reset(rqs)
if err != nil {
2024-09-12 04:30:23 +02:00
f.writeError(w, 500, err)
return
}
if perr != nil {
f.writeError(w, 500, perr)
return
}
}