crash relay with Error: Checksum mismatch

[kulpinaolga1979-sudo]

Hello, I'm using relay to modify traffic from a server, and after 5 minutes of use, this error occurs:
Error: Checksum mismatch bd933834d2da0b1c != 20a902729262346e
at Decipheriv.verify (/data/data/com.termux/files/home/node_modules/bedrock-protocol/src/transforms/encryption.js:71:28)
at Decipheriv.emit (node:events:518:28)
at addChunk (node:internal/streams/readable:561:12)
at readableAddChunkPushByteMode (node:internal/streams/readable:512:3)
at Readable.push (node:internal/streams/readable:392:5)
at Decipheriv._transform (node:internal/crypto/cipher:150:8)
at Transform._write (node:internal/streams/transform:171:8)
at writeOrBuffer (node:internal/streams/writable:572:12)
at _write (node:internal/streams/writable:501:10)
at Writable.write (node:internal/streams/writable:510:10)
Error: Checksum mismatch ad0336cec4a2a200 != 02d31392024c2369
at Decipheriv.verify (/data/data/com.termux/files/home/node_modules/bedrock-protocol/src/transforms/encryption.js:71:28)
at Decipheriv.emit (node:events:518:28)
at addChunk (node:internal/streams/readable:561:12)
at readableAddChunkPushByteMode (node:internal/streams/readable:512:3)
at Readable.push (node:internal/streams/readable:392:5)
at Decipheriv._transform (node:internal/crypto/cipher:150:8)
at Transform._write (node:internal/streams/transform:171:8)
at writeOrBuffer (node:internal/streams/writable:572:12)
at _write (node:internal/streams/writable:501:10)
at Writable.write (node:internal/streams/writable:510:10)
I'm using the offline connection version, but recompiling didn't help

[extremeheat]

This seems like a user or server error. Can you provide the code to replicate the issue?

[kulpinaolga1979-sudo]

yea
const { Relay } = require('bedrock-protocol')
const fs = require("fs")
const util = require('util')

function delay(ms) {
return new Promise(resolve => setTimeout(resolve, ms));
}
const now = new Date()
const file = log/${now.getHours()}-${now.getMinutes()}-${now.getSeconds()}
console.log(file)
const playerMap = new Map()

var filter = [
{
chat: "",
message: "",
ignored: []
}
]
function Funcevent(params) {
if (data.count !== -1) {
if (data.count == 0) {
event = ""
data.count+= -1
}
}
if (mode == "redacted") {
//постоянная модификация пакета
for (let i = 0;i<data.redactive.length;i++) {
switch (data.redactive[i].operation) {
case "+":
params[data.redactive[i].name]+= params[data.redactive[i].value]
break
case "=":
params[data.redactive[i].name]= params[data.redactive[i].value]
break
case "@=":
params[data.redactive[i].name]= ${params[data.redactive[i].value]}
break
case "@+":
params[data.redactive[i].name]+= ${params[data.redactive[i].value]}
break
default:
break
}
}
}
return params
}
const relay = new Relay({
version: '1.21.100', // The version
/ host and port to listen for clients on /
host: '0.0.0.0',
port: 19132,
offline: true,
/ Where to send upstream packets to /
destination: {
host: '4mine.ru',
port: 19132
}
})
relay.listen() // Tell the server to start listening.
relay.on("disconnect",player => {
player.disconnect()
console.log("disconnect",player.connection.address,"\n",player)
})
relay.on('connect', player => {
console.log('New connection', player.connection.address,"\n",player)
player.on("error", (error) => {
console.log(error)
})
// Server is sending a message to the client.
player.on('clientbound', ({ name, params }, des) => {
fs.appendFile(file+" - log.txt"," "+name+"\n",(err) => { })
fs.appendFile(file+" - mod.txt","**\nname: "+ name +"\nparams: " + util.inspect(params, {
depth: null,
showHidden: false,
compact: false,
numericSeparator: false,
breakLength: 80,
maxStringLength: 10000,
maxArrayLength: 100,
showProxy: false,
sorted: false,
getters: false,
bigint: true // Это ключевая опция!
})+"\n",(err) => { })
switch (name) {
case "text":
var message = params.message
for (let i = 0;i<message.length;i++) {
if (message.length <= i) {
break
}
if (message[i] == "§") {
message = message.split("")
message.splice(i,2)
message = message.join("")
i-=2
}
}
console.log(message)
//params.message = message
for (let i=0;i<filter.length;i++) {
if (message[0] == filter[i].chat) {
if (filter[i].message == "*") {
des.canceled = true
}
}
}
break
case "start_game":
playerMap.set(player.connection.address,{
entity_id: params.entity_id,
runtime_entity_id: params.runtime_entity_id,
player_unique_id: params.entity_id,
tick: 0n,
})
}
})
// Client is sending a message to the server
player.on('serverbound', ({ name, params }, des) => {
fs.appendFile(file+" - log.txt",name+"\n",(err) => { })
if (name === 'text') { // Intercept chat message to server and append time.
const t = new Date()
params.message += ${t.getHours()}-${t.getMinutes()}-${t.getSeconds()}
}
if (name !== 'player_auth_input' && name !== "serverbound_diagnostics") {
console.log(name)
}
fs.appendFile(file+" - mod.txt","name: " + name + "\nparams: " + util.inspect(params,{
depth: null,
showHidden: false,
compact: false,
numericSeparator: false,
breakLength: 80,
maxStringLength: 10000,
maxArrayLength: 100,
showProxy: false,
sorted: false,
getters: false,
bigint: true // Это ключевая опция!
})+"\n",(err) => { })
switch (name) {
case "command_request":
console.log(params)
let arg = params.command.split(" ")
if (arg[0] == "/anims") {
arg.shift()
des.canceled = true
const nm = arg[0]
const data = fs.readFileSync("data/"+nm, 'utf8').split("\n")
arg.shift()
let com = ""
for (let i =0;i<arg.length;i++) {
com += arg[i]+" "
}
async function runAsyncLoop() {
console.log("its work now",data)
for (let i = 0;i<data.length;i++) {
let uu = params.origin.uuid
console.log(com+data[i])
player.upstream.queue("command_request",{
command: com+data[i]+"ь",
origin: {
type: "player",
uuid: uu,
request_id: '',
player_entity_id: undefined
}
})
await delay(50)
}
}
runAsyncLoop().catch(console.error);
} else if (arg[0] == "/test") {
const pl = playerMap.get(player.connection.address)
console.log(pl.tick)
player.queue("update_player_game_type",{
gamemode: 3,
player_unique_id: pl.player_unique_id,
tick: pl.tick
})
des.canceled = true
}
break
case "player_auth_input":
if (playerMap.has(player.connection.address)) {
const pl = playerMap.get(player.connection.address)
playerMap.set(player.connection.address,{
entity_id: pl.entity_id,
runtime_entity_id: pl.runtime_entity_id,
player_unique_id: pl.player_unique_id,
tick: params.tick
})
}
}
})
})
I'm connecting through an account, so it might have an effect.

[kulpinaolga1979-sudo]

A small update: I have implemented the object rejection function and obtained the following output
Error: Checksum mismatch 81484854c0ffd0b0 != d197eec814a2766f 105 - packet.length 16907 - client.receiveCounter.toString() d122b39ec6f6191a - client.secretKeyBytes.slice(0, 8).toString('hex') at Decipheriv.verify (/data/data/com.termux/files/home/node_modules/bedrock-protocol/src/transforms/encryption.js:71:28) at Decipheriv.emit (node:events:518:28) at addChunk (node:internal/streams/readable:561:12) at readableAddChunkPushByteMode (node:internal/streams/readable:512:3) at Readable.push (node:internal/streams/readable:392:5) at Decipheriv._transform (node:internal/crypto/cipher:150:8) at Transform._write (node:internal/streams/transform:171:8) at writeOrBuffer (node:internal/streams/writable:572:12) at _write (node:internal/streams/writable:501:10) at Writable.write (node:internal/streams/writable:510:10) Error: Unsupported compressor: 206 at Decipheriv.verify (/data/data/com.termux/files/home/node_modules/bedrock-protocol/src/transforms/encryption.js:86:32) at Decipheriv.emit (node:events:518:28) at addChunk (node:internal/streams/readable:561:12) at readableAddChunkPushByteMode (node:internal/streams/readable:512:3) at Readable.push (node:internal/streams/readable:392:5) at Decipheriv._transform (node:internal/crypto/cipher:150:8) at Transform._write (node:internal/streams/transform:171:8) at writeOrBuffer (node:internal/streams/writable:572:12) at _write (node:internal/streams/writable:501:10) at Writable.write (node:internal/streams/writable:510:10) /data/data/com.termux/files/home/node_modules/bedrock-protocol/src/transforms/framer.js:100 while (offset < buffer.byteLength) { ^
TypeError: Cannot read properties of undefined (reading 'byteLength') at Framer.getPackets (/data/data/com.termux/files/home/node_modules/bedrock-protocol/src/transforms/framer.js:100:28) at RelayPlayer.onDecryptedPacket (/data/data/com.termux/files/home/node_modules/bedrock-protocol/src/connection.js:173:28) at Decipheriv.verify (/data/data/com.termux/files/home/node_modules/bedrock-protocol/src/transforms/encryption.js:92:12) at Decipheriv.emit (node:events:518:28) at addChunk (node:internal/streams/readable:561:12) at readableAddChunkPushByteMode (node:internal/streams/readable:512:3) at Readable.push (node:internal/streams/readable:392:5) at Decipheriv._transform (node:internal/crypto/cipher:150:8) at Transform._write (node:internal/streams/transform:171:8) at writeOrBuffer (node:internal/streams/writable:572:12)