Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
1a5f4f4f8e | ||
|
|
d0844dd6b5 | ||
|
|
d8e36aa6fa | ||
|
|
6781e4c16d | ||
|
|
fccba0248a |
+3
-3
@@ -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
@@ -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
|
||||
|
||||
@@ -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
@@ -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
@@ -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
@@ -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
@@ -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)
|
||||
}
|
||||
|
||||
@@ -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()), "")
|
||||
}
|
||||
|
||||
@@ -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"
|
||||
|
||||
Reference in New Issue
Block a user