81 lines
2.1 KiB
Go
81 lines
2.1 KiB
Go
package server
|
|
|
|
import (
|
|
"fmt"
|
|
"log/slog"
|
|
|
|
"github.com/admin-else/strom/data"
|
|
"github.com/admin-else/strom/event"
|
|
"github.com/admin-else/strom/nbt"
|
|
"github.com/admin-else/strom/proto"
|
|
"github.com/admin-else/strom/proto_base"
|
|
"github.com/admin-else/strom/proto_generated/v1_21_8"
|
|
)
|
|
|
|
type ConfigServer struct {
|
|
*proto.Conn
|
|
}
|
|
|
|
func (c *ConfigServer) Default(event event.Anything) (err error) {
|
|
slog.Debug("Config server", "packet", fmt.Sprintf("%#v", event.Val))
|
|
return
|
|
}
|
|
|
|
func ServeConfig(c *proto.Conn) (err error) {
|
|
n, err := data.LoadRegistry(c.Version)
|
|
if err != nil {
|
|
return
|
|
}
|
|
for _, p := range n.Value.(map[string]any)["Registries"].([]any) {
|
|
packet := &v1_21_8.ConfigurationToClientPacketRegistryData{Id: p.(map[string]any)["Id"].(string)}
|
|
for _, entry := range p.(map[string]any)["Entries"].([]any) {
|
|
entryTyped := entry.(map[string]any)
|
|
valAny, ok := entryTyped["Value"]
|
|
var val *nbt.Anon
|
|
if ok {
|
|
val = &nbt.Anon{Value: valAny}
|
|
}
|
|
packet.Entries = append(packet.Entries, struct {
|
|
Key string
|
|
Value *nbt.Anon
|
|
}{entryTyped["TagType"].(string), val})
|
|
}
|
|
err = c.Send(packet)
|
|
if err != nil {
|
|
return
|
|
}
|
|
}
|
|
tagsPacket := &v1_21_8.ConfigurationToClientPacketTags{}
|
|
for _, p := range n.Value.(map[string]any)["Tags"].([]any) {
|
|
p := p.(map[string]any)
|
|
tags := v1_21_8.Tags{}
|
|
for _, entry := range p["Entries"].([]any) {
|
|
entry := entry.(map[string]any)
|
|
tags.Val = append(tags.Val, struct {
|
|
TagName string
|
|
Entries []int32
|
|
}{
|
|
TagName: entry["TagName"].(string),
|
|
Entries: entry["Entries"].([]int32),
|
|
})
|
|
}
|
|
tagsPacket.Tags = append(tagsPacket.Tags, struct {
|
|
TagType string
|
|
Tags v1_21_8.Tags
|
|
}{TagType: p["TagType"].(string), Tags: tags})
|
|
}
|
|
err = c.Send(tagsPacket)
|
|
if err != nil {
|
|
return
|
|
}
|
|
err = c.Send(&v1_21_8.ConfigurationToClientPacketFinishConfiguration{})
|
|
cs := &ConfigServer{c}
|
|
return cs.StartLoop()
|
|
}
|
|
|
|
func (c *ConfigServer) OnFinishConfiguration(_ *v1_21_8.ConfigurationToServerPacketFinishConfiguration) (err error) {
|
|
c.SetState(proto_base.Play)
|
|
err = event.HandlerDoneErr{}
|
|
return
|
|
}
|