internal: remove sentry proxy
Signed-off-by: Jens Langhammer <jens.langhammer@beryju.org>
This commit is contained in:
parent
67b45fc4e3
commit
bacf2afed1
|
@ -1,78 +0,0 @@
|
||||||
package web
|
|
||||||
|
|
||||||
import (
|
|
||||||
"bytes"
|
|
||||||
"encoding/json"
|
|
||||||
"fmt"
|
|
||||||
"io"
|
|
||||||
"net/http"
|
|
||||||
"net/url"
|
|
||||||
"strconv"
|
|
||||||
"strings"
|
|
||||||
|
|
||||||
"goauthentik.io/internal/config"
|
|
||||||
)
|
|
||||||
|
|
||||||
type SentryRequest struct {
|
|
||||||
DSN string `json:"dsn"`
|
|
||||||
}
|
|
||||||
|
|
||||||
func (ws *WebServer) APISentryProxy() http.HandlerFunc {
|
|
||||||
fallbackHandler := func(w http.ResponseWriter, r *http.Request) {
|
|
||||||
w.WriteHeader(http.StatusBadRequest)
|
|
||||||
}
|
|
||||||
if !config.Get().ErrorReporting.Enabled {
|
|
||||||
ws.log.Debug("error reporting disabled")
|
|
||||||
return fallbackHandler
|
|
||||||
}
|
|
||||||
dsn, err := url.Parse(config.Get().ErrorReporting.SentryDSN)
|
|
||||||
if err != nil {
|
|
||||||
ws.log.WithError(err).Warning("invalid sentry DSN")
|
|
||||||
return fallbackHandler
|
|
||||||
}
|
|
||||||
projectId, err := strconv.Atoi(strings.TrimPrefix(dsn.Path, "/"))
|
|
||||||
if err != nil {
|
|
||||||
ws.log.WithError(err).Warning("failed to get sentry project id")
|
|
||||||
return fallbackHandler
|
|
||||||
}
|
|
||||||
return func(rw http.ResponseWriter, r *http.Request) {
|
|
||||||
fb := &bytes.Buffer{}
|
|
||||||
_, err := io.Copy(fb, r.Body)
|
|
||||||
if err != nil {
|
|
||||||
ws.log.Debug("failed to read body")
|
|
||||||
rw.WriteHeader(http.StatusBadRequest)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
lines := strings.Split(fb.String(), "\n")
|
|
||||||
if len(lines) < 1 {
|
|
||||||
rw.WriteHeader(http.StatusBadRequest)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
sd := SentryRequest{}
|
|
||||||
err = json.Unmarshal([]byte(lines[0]), &sd)
|
|
||||||
if err != nil {
|
|
||||||
ws.log.WithError(err).Warning("failed to parse sentry request")
|
|
||||||
rw.WriteHeader(http.StatusBadRequest)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
if sd.DSN != config.Get().ErrorReporting.SentryDSN {
|
|
||||||
rw.WriteHeader(http.StatusBadRequest)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
res, err := http.DefaultClient.Post(
|
|
||||||
fmt.Sprintf(
|
|
||||||
"https://%s/api/%d/envelope/",
|
|
||||||
dsn.Host,
|
|
||||||
projectId,
|
|
||||||
),
|
|
||||||
"application/x-sentry-envelope",
|
|
||||||
fb,
|
|
||||||
)
|
|
||||||
if err != nil {
|
|
||||||
ws.log.WithError(err).Warning("failed to proxy sentry")
|
|
||||||
rw.WriteHeader(http.StatusBadRequest)
|
|
||||||
return
|
|
||||||
}
|
|
||||||
rw.WriteHeader(res.StatusCode)
|
|
||||||
}
|
|
||||||
}
|
|
|
@ -47,15 +47,10 @@ func NewWebServer(g *gounicorn.GoUnicorn) *WebServer {
|
||||||
p: g,
|
p: g,
|
||||||
}
|
}
|
||||||
ws.configureStatic()
|
ws.configureStatic()
|
||||||
ws.configureRoutes()
|
|
||||||
ws.configureProxy()
|
ws.configureProxy()
|
||||||
return ws
|
return ws
|
||||||
}
|
}
|
||||||
|
|
||||||
func (ws *WebServer) configureRoutes() {
|
|
||||||
ws.m.Path("/api/v3/sentry/").HandlerFunc(ws.APISentryProxy())
|
|
||||||
}
|
|
||||||
|
|
||||||
func (ws *WebServer) Start() {
|
func (ws *WebServer) Start() {
|
||||||
go ws.listenPlain()
|
go ws.listenPlain()
|
||||||
go ws.listenTLS()
|
go ws.listenTLS()
|
||||||
|
|
|
@ -27,7 +27,6 @@ export async function configureSentry(canDoPpi = false): Promise<Config> {
|
||||||
/NS_ERROR_FAILURE/gi,
|
/NS_ERROR_FAILURE/gi,
|
||||||
],
|
],
|
||||||
release: `authentik@${VERSION}`,
|
release: `authentik@${VERSION}`,
|
||||||
tunnel: "/api/v3/sentry/",
|
|
||||||
integrations: [
|
integrations: [
|
||||||
new Integrations.BrowserTracing({
|
new Integrations.BrowserTracing({
|
||||||
tracingOrigins: [window.location.host, "localhost"],
|
tracingOrigins: [window.location.host, "localhost"],
|
||||||
|
|
Reference in New Issue