anygatecloud/strom
2
1
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add OnFinishLogin handling to packet inspector

Browse Source
This commit is contained in:
adman
2026-06-16 22:28:01 +02:00
parent d4fe362d9f
commit 4956c1d874
1 changed files with 12 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
cmd/strom/packet_inspector/main.go
+12
View File
@@ -34,6 +34,7 @@ func (p *Proxy) Start() (err error) {
p.Servee.RegisterCritical(p.OnAnything) p.Servee.RegisterCritical(p.OnAnything)
p.Servee.RegisterCriticalUntilLatest(p.OnFinishConfiguration) p.Servee.RegisterCriticalUntilLatest(p.OnFinishConfiguration)
p.Servee.RegisterCriticalUntilLatest(p.OnFinishLogin)
p.Servee.RegisterCriticalUntilLatest(p.OnHandshake) p.Servee.RegisterCriticalUntilLatest(p.OnHandshake)
//p.Servee.RegisterCriticalUntilLatest(p.OnCompress) //p.Servee.RegisterCriticalUntilLatest(p.OnCompress)
p.Client.RegisterCriticalUntilLatest(p.OnCompress) p.Client.RegisterCriticalUntilLatest(p.OnCompress)
@@ -78,6 +79,17 @@ func (p *Proxy) OnFinishConfiguration(packet *v1_21_11.ConfigurationToServerPack
return return
} }
func (p *Proxy) OnFinishLogin(packet *v1_21_11.LoginToServerPacketLoginAcknowledged) (err error) {
err = p.Client.Send(packet)
if err != nil {
return
}
p.Servee.SetState(proto_base.Configuration)
p.Client.SetState(proto_base.Configuration)
err = event.DontForwardErr
return
}
func (p *Proxy) OnHandshake(packet *v1_21_11.HandshakingToServerPacketSetProtocol) (err error) { func (p *Proxy) OnHandshake(packet *v1_21_11.HandshakingToServerPacketSetProtocol) (err error) {
err = p.Client.Send(packet) err = p.Client.Send(packet)
state := proto_base.State(packet.NextState) state := proto_base.State(packet.NextState)