mleku
110223fc4e
Replaced legacy `*.orly` module imports with `next.orly.dev/pkg` paths across the codebase for consistency. Removed legacy `go.mod` files from sub-packages, consolidating dependency management. Added Dockerfiles and configurations for benchmarking environments.
52 lines
1.3 KiB
Go
52 lines
1.3 KiB
Go
package app
|
|
|
|
import (
|
|
"lol.mleku.dev/chk"
|
|
"lol.mleku.dev/errorf"
|
|
"lol.mleku.dev/log"
|
|
"next.orly.dev/pkg/encoders/envelopes"
|
|
"next.orly.dev/pkg/encoders/envelopes/authenvelope"
|
|
"next.orly.dev/pkg/encoders/envelopes/closeenvelope"
|
|
"next.orly.dev/pkg/encoders/envelopes/eventenvelope"
|
|
"next.orly.dev/pkg/encoders/envelopes/noticeenvelope"
|
|
"next.orly.dev/pkg/encoders/envelopes/reqenvelope"
|
|
)
|
|
|
|
func (l *Listener) HandleMessage(msg []byte, remote string) {
|
|
log.D.F("%s received message:\n%s", remote, msg)
|
|
var err error
|
|
var t string
|
|
var rem []byte
|
|
if t, rem, err = envelopes.Identify(msg); !chk.E(err) {
|
|
switch t {
|
|
case eventenvelope.L:
|
|
// log.D.F("eventenvelope: %s %s", remote, rem)
|
|
err = l.HandleEvent(rem)
|
|
case reqenvelope.L:
|
|
// log.D.F("reqenvelope: %s %s", remote, rem)
|
|
err = l.HandleReq(rem)
|
|
case closeenvelope.L:
|
|
// log.D.F("closeenvelope: %s %s", remote, rem)
|
|
err = l.HandleClose(rem)
|
|
case authenvelope.L:
|
|
// log.D.F("authenvelope: %s %s", remote, rem)
|
|
err = l.HandleAuth(rem)
|
|
default:
|
|
err = errorf.E("unknown envelope type %s\n%s", t, rem)
|
|
}
|
|
}
|
|
if err != nil {
|
|
// log.D.C(
|
|
// func() string {
|
|
// return fmt.Sprintf(
|
|
// "notice->%s %s", remote, err,
|
|
// )
|
|
// },
|
|
// )
|
|
if err = noticeenvelope.NewFrom(err.Error()).Write(l); chk.E(err) {
|
|
return
|
|
}
|
|
}
|
|
|
|
}
|