admin/hsp.go
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: remove logs + fallback route

Browse Source
This commit is contained in:
Amir Adal
2025-04-20 13:53:20 +02:00
parent 216b6a2f59
commit 59f7de3d1a
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
hsp/server/router.go
View File

@ -50,8 +50,6 @@ func (r *Router) SetStreamBufferSize(size uint16) {
func (r *Router) Handle(conn net.Conn) error { func (r *Router) Handle(conn net.Conn) error {
defer conn.Close() defer conn.Close()
log.Printf("Got new connection from %s\n", conn.RemoteAddr().String())
dupl := hsp.NewPacketDuplex(conn) dupl := hsp.NewPacketDuplex(conn)
// TODO: Ability to keep connection alive // TODO: Ability to keep connection alive
@ -62,7 +60,6 @@ func (r *Router) Handle(conn net.Conn) error {
} }
if route, ok := packet.Headers["route"]; ok { if route, ok := packet.Headers["route"]; ok {
log.Printf("[ROUTER] New connection to '%s'", route)
req := hsp.NewRequest(conn, packet) req := hsp.NewRequest(conn, packet)
switch req.GetRequestKind() { switch req.GetRequestKind() {
@ -71,6 +68,10 @@ func (r *Router) Handle(conn net.Conn) error {
res := handler(req) res := handler(req)
_, err := dupl.WritePacket(res.ToPacket()) _, err := dupl.WritePacket(res.ToPacket())
return err return err
} else if fallback, ok := r.routes["*"]; ok {
res := fallback(req)
_, err := dupl.WritePacket(res.ToPacket())
return err
} }
case "stream": case "stream":
if handler, ok := r.streamers[route]; ok { if handler, ok := r.streamers[route]; ok {