feat: construct new request out of the packet
This commit is contained in:
@ -37,14 +37,14 @@ func (r *Router) Handle(conn net.Conn) error {
|
|||||||
// TODO: Ability to keep connection alive
|
// TODO: Ability to keep connection alive
|
||||||
packet, err := dupl.ReadPacket()
|
packet, err := dupl.ReadPacket()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
dupl.WritePacket(NewErrorResponse(err).ToPacket())
|
_, _ = dupl.WritePacket(hsp.NewErrorResponse(err).ToPacket())
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
if route, ok := packet.Headers["route"]; ok {
|
if route, ok := packet.Headers["route"]; ok {
|
||||||
log.Printf("[ROUTER] New connection to '%s'", route)
|
log.Printf("[ROUTER] New connection to '%s'", route)
|
||||||
if handler, ok := r.Routes[route]; ok {
|
if handler, ok := r.Routes[route]; ok {
|
||||||
req := hsp.NewPacketRequest(conn.RemoteAddr(), packet)
|
req := hsp.NewRequest(conn, packet)
|
||||||
res := handler(req)
|
res := handler(req)
|
||||||
_, err := dupl.WritePacket(res.ToPacket())
|
_, err := dupl.WritePacket(res.ToPacket())
|
||||||
return err
|
return err
|
||||||
|
Reference in New Issue
Block a user