5 Commits
9 changed files with 114 additions and 18 deletions
+3 -3
View File
@@ -125,7 +125,7 @@ func (s *LoginClient) OnStart() (err error) {
return
}
func LoginRaw(c *proto.Conn, account *api.Account, addr string) (err error) {
func LoginRaw(c *proto.Conn, account *api.Account) (err error) {
lc := &LoginClient{
Conn: c,
Account: account,
@@ -161,7 +161,7 @@ func LoginNoSrv(connectTo string, account *api.Account) (c *proto.Conn, err erro
if err != nil {
return
}
err = LoginRaw(c, account, connectTo)
err = LoginRaw(c, account)
return
}
@@ -174,6 +174,6 @@ func Login(connectTo string, account *api.Account) (c *proto.Conn, err error) {
if err != nil {
return
}
err = LoginRaw(c, account, connectTo)
err = LoginRaw(c, account)
return
}
+1 -1
View File
@@ -39,7 +39,7 @@ func mainE() (err error) {
// Debug stuff
slog.SetLogLoggerLevel(slog.LevelDebug)
//args = []string{"TEST", "api", "-name", "Admin_Else"}
//args = []string{"TEST", "packet-spy"}
if len(args) < 2 {
err = ExpectedASubcommandErr
+1 -1
View File
@@ -116,7 +116,7 @@ func Run(args []string) (err error) {
return
}
c.DebugPrintPackets = []string{""}
err = client.LoginRaw(c, acc, *TargetAddr)
err = client.LoginRaw(c, acc)
if err != nil {
return
}
+6 -1
View File
@@ -99,7 +99,12 @@ func StateIdFromBlocKAndStateMap(version string, name string, stateMap map[strin
err = BlockNotFoundErr
return
}
stateId, err = b.IdFromStateMap(stateMap)
if stateMap == nil {
stateId = b.DefaultState
} else {
stateId, err = b.IdFromStateMap(stateMap)
}
return
}
+59 -3
View File
@@ -1,5 +1,14 @@
package anvil
import (
"strings"
"unsafe"
"github.com/admin-else/strom/data"
"github.com/admin-else/strom/level"
"github.com/admin-else/strom/util"
)
type Chunk struct {
DataVersion int32
Heightmaps map[string][]int64
@@ -8,17 +17,64 @@ type Chunk struct {
Sections []Section
}
const McPrefix = "minecraft:"
func (c Chunk) ToStorage(version string) (toChunk *level.Chunk, err error) {
f := level.MakeBlockFormat(version)
toChunk = new(level.Chunk)
toChunk.Sections = make([]level.Section, len(c.Sections))
for i, s := range c.Sections {
pallete := make([]int32, len(s.BlockStates.Palette))
for j, p := range s.BlockStates.Palette {
pallete[j], err = data.StateIdFromBlocKAndStateMap(version, strings.TrimPrefix(p.Name, McPrefix), p.Properties)
if err != nil {
return
}
}
// this is probably fine
uintSlice := unsafe.Slice((*uint64)(unsafe.Pointer(unsafe.SliceData(s.BlockStates.Data))), len(s.BlockStates.Data))
toChunk.Sections[i].Blocks, err = f.Import(uintSlice, util.BpeByNum(float64(len(s.BlockStates.Palette))), pallete)
if err != nil {
return
}
toChunk.Sections[i].BlockCount = int16(level.CountStorage(toChunk.Sections[i].Blocks, 0))
}
for i, s := range c.Sections {
pallete := make([]int32, len(s.Biomes.Palette))
for j, p := range s.Biomes.Palette {
var b *data.Biome
b, ok := data.LookupBiomeByName(version, strings.TrimPrefix(p, McPrefix))
if !ok {
err = data.UnknownBiomeNameErr
return
}
pallete[j] = b.Id
}
// this is probably fine
uintSlice := unsafe.Slice((*uint64)(unsafe.Pointer(unsafe.SliceData(s.Biomes.Data))), len(s.Biomes.Data))
toChunk.Sections[i].Biomes, err = f.Import(uintSlice, util.BpeByNum(float64(len(pallete))), pallete)
if err != nil {
return
}
}
return
}
type Section struct {
Y int8
BlockStates struct {
Data []int64
Data []int64 `nbt:"data,omitempty"`
Palette []struct {
Name string
Properties map[string]string `nbt:"properties,omitempty"`
}
}
Biomes []struct {
Data []int64
Biomes struct {
Data []int64 `nbt:"data,omitempty"`
Palette []string
}
}
+30 -4
View File
@@ -29,13 +29,30 @@ func (r StorageFormat) Import(data []uint64, bpe uint8, palette []int32) (s *Sto
return
}
if !slices.Contains(r.AvailableBpes, bpe) {
err = BpeNotAvailableErr
return
}
s = new(Storage)
s.format = r
s.resize(bpe)
if !slices.Contains(r.AvailableBpes, bpe) {
var newBpe uint8
for _, newBpe = range r.AvailableBpes {
if bpe < newBpe {
continue
}
}
var tmps *Storage
tmps, err = StorageFormat{
AvailableBpes: []uint8{bpe},
BiggestDirect: false,
Len: r.Len,
}.ImportDataDirect(data)
if err != nil {
return
}
tmps.resize(newBpe)
data = tmps.data
bpe = newBpe
}
if bpe == 0 && len(palette) != 1 {
err = Bpe0PalletMustBeLenOneErr
return
@@ -238,3 +255,12 @@ func CompareStorage(a, b *Storage) bool {
}
return true
}
func CountStorage(s *Storage, v int32) (a int) {
for i := range s.format.Len {
if w, _ := s.Get(i); w == v {
a++
}
}
return
}
+11 -5
View File
@@ -163,15 +163,18 @@ func (l *LoginServer) OnEncryptionResponse(packet *v1_21_8.LoginToServerPacketEn
return
}
serverId := crypto.AuthDigest([]byte(l.ServerId), sharedSecret, l.PublicKeyBytes)
_, err = api.HasJoined(l.Requested.Name, serverId, "")
if err != nil {
return
}
err = l.SetSecret(sharedSecret)
if err != nil {
return
}
serverId := crypto.AuthDigest([]byte(l.ServerId), sharedSecret, l.PublicKeyBytes)
if l.OnlineMode {
_, err = api.HasJoined(l.Requested.Name, serverId, "")
if err != nil {
return
}
}
err = l.FinishLogin()
return
}
@@ -234,12 +237,15 @@ func WithCompatibleVersions(versions ...int32) LoginServerSetting {
func ServeLogin(c *proto.Conn, settings ...LoginServerSetting) (ret *LoginServer, err error) {
ret = &LoginServer{Conn: c}
ret.OnlineMode = true
ret.RegisterCritical(ret.OnDefault)
ret.RegisterCriticalUntilLatest(ret.OnHandshake)
ret.RegisterCriticalUntilLatest(ret.OnLoginStart)
ret.RegisterCriticalUntilLatest(ret.OnLoginAcknowledged)
ret.RegisterCriticalUntilLatest(ret.OnStatusRequest)
ret.RegisterCriticalUntilLatest(ret.OnStatusPing)
ret.RegisterCriticalUntilLatest(ret.OnEncryptionResponse)
for _, s := range settings {
s(ret)
}
+1
View File
@@ -78,6 +78,7 @@ func StartServerWithOnConn(listenAddr string, onConn func(c *proto.Conn) (err er
if errors.Is(connErr, ShutDownServerErr) {
running = false
}
c.Log.Error("closing connection", "err", connErr)
if connErr != nil {
connErr = Kick(c, text.Pretty(connErr.Error()), "")
}
+2
View File
@@ -25,6 +25,8 @@ func wontFail[T any](v T, err error) T {
return v
}
// THIS IS REDUNDANT USE LOGIN PACKET IN MINECRAFT DATA
var (
// Edit these two
Version = "1.21.11"