Эксклюзив RakLua — RakNet hooks, functions for MoonLoader [UPDATE 2.13 | OPEN-SOURCE]

Представляю вам RakLua.
​

RakLua — это новая библиотека, которая служит заменой событиям и функциям SAMPFUNCS для взаимодействия с RakNet'ом и BitStream — классом, позволяющим SAMPy отправлять/получать данные от сервера. Библиотека использует sol3 для биндинга C++ (самой библиотеки) и самого Lua. Библиотека включает почти все возможности взаимодействия с RakNet'ом и его событиями, а ключевым моментом является одновременная поддержка SAMP 0.3.7-R1, SAMP 0.3.7-R2, SAMP 0.3.7-R3-1, SAMP 0.3.7-R4-2 и SAMP 0.3.7-R5-1, а так же отсутствие зависимости от SAMPFUNCS и CLEO (потому что SAMPFUNCS не используется).

Содержание:

• Список имеющихся функций и событий
• Примеры эмуляции исходящих RPC/пакетов
• Отлавливание и обработка входящих/исходящих RPC и пакетов

GitHub: Northn/RakLua
Версия RakLua: 2.13; состояние: Stable

Установка: файлы RakLuaDll.dll, RakLua.lua из архива RakLua2.1.zip, приложенного к теме, перетащить в папку *Корневая папка с игрой*/moonloader/lib​

Использованные материалы: mod_s0beit_sa; sol3; RakHook
Отдельное спасибо: @FYP ; @RTD ​

---

Список имеющихся функций и событий
Важная заметка: вам может быть неудобно переписывать исходный код в формат RakLua, если это так, то прочтите данный пост.

Описание	Применение в RakLua	Применение в SAMPFUNCS
Создание BitStream; удаление BitStream	local bs = RakLuaBitStream.new() -- Обратите внимание, что это новый класс, а не тот самый BitStream -- Получить сам BitStream можно через bs:getBitStream() -- Удаление недоступно, сборщик мусора сам удалит	local bs = raknetNewBitStream() raknetDeleteBitStream(bs)
Получение оффсета для чтения/записи данных	local offset = bs:getReadOffset() local offset = bs:getWriteOffset()	raknetBitStreamGetReadOffset(bs) raknetBitStreamGetWriteOffset(bs)
Установка оффсета для чтения/записи данных	bs:setReadOffset(offset) bs:setWriteOffset(offset)	raknetBitStreamSetReadOffset(bs, offset) raknetBitStreamSetWriteOffset(bs, offset)
Сброс указателя для чтения/записи данных	bs:resetReadPointer() bs:resetWritePointer()	raknetBitStreamResetReadPointer(bs) raknetBitStreamResetWritePointer(bs)
Игнор битов/байтов для чтения данных	bs:ignoreBits(amount) bs:ignoreBytes(amount) -- Альтернатива (вспоминается проще) bs:skipBits(amount) bs:skipBytes(amount)	raknetBitStreamIgnoreBits(bs, amount) -- Игнор байтов не имеется
Получение количества использованных битов/байтов и количества непрочитанных битов/байтов	local value = bs:getNumberOfBitsUsed() local value = bs:getNumberOfBytesUsed() local value = bs:getNumberOfUnreadBits() local value = bs:getNumberOfUnreadBytes()	local value = raknetBitStreamGetNumberOfBitsUsed(bs) local value = raknetBitStreamGetNumberOfBytesUsed(bs) local value = raknetBitStreamGetNumberOfUnreadBits(bs) -- Получение количества непрочитанных байтов недоступно
Чтение данных	local value = bs:readBool() -- bool local value = bs:readUInt(8/16/32)() -- uint8/16/32; bs:readUInt16() local value = bs:readInt(8/16/32)() -- int8/16/32; bs:readInt16() local value = bs:readFloat() -- float local value = bs:readString(length) -- string local value = bs:readEncoded(size) -- encodedString local result = bs:readBuffer(dest, size)	local value = raknetBitStreamReadBool(bs) -- bool local value = raknetBitStreamReadInt8(bs) -- uint8 local value = raknetBitStreamReadInt16(bs) -- uint16 local value = raknetBitStreamReadInt32(bs) -- int32 local value = raknetBitStreamReadFloat(bs) -- float local value = raknetBitStreamReadString(bs, length) -- string local value = raknetBitStreamDecodeString(bs, size) -- encodedString raknetBitStreamReadBuffer(bs, dest, size)
Запись значений	bs:writeBool(value) bs:writeUInt(8/16/32)(value) -- bs:writeUInt16(value) bs:writeInt(8/16/32)(value) -- bs:writeInt16(value) bs:writeFloat(value) bs:writeString(value) bs:writeEncoded(value) bs:writeBuffer(dest, size) bs:writeBitStream(bitStream)	raknetBitStreamWriteBool(bs, value) raknetBitStreamWriteInt8(bs, value) raknetBitStreamWriteInt16(bs, value) raknetBitStreamWriteInt32(bs, value) raknetBitStreamWriteFloat(bs,value) raknetBitStreamWriteString(bs, value) raknetBitStreamEncodeString(bs, value) raknetBitStreamWriteBuffer(bs, dest, size) raknetBitStreamWriteBitStream(bs, bitStream)
Отправка RPC/пакетов; Эмуляция входящих RPC/пакетов	bs:sendRPC(rpcId) bs:sendPacket() bs:emulIncomingRPC(rpcId) bs:emulIncomingPacket(packetİd)	raknetSendRpc(rpcId, bs) raknetSendBitStream(bs) raknetEmulRpcReceiveBitStream(rpcId, bs) raknetEmulPacketReceiveBitStream(packetId, bs)
Установка обработчиков на входящие/исходящие RPC и пакеты	RakLua.registerHandler(RakLuaEvents.INCOMING_RPC, func) RakLua.registerHandler(RakLuaEvents.INCOMING_PACKET, func) RakLua.registerHandler(RakLuaEvents.OUTGOING_RPC, func) RakLua.registerHandler(RakLuaEvents.OUTGOING_PACKET, func)	addEventHandler("onReceiveRPC", func) addEventHandler("onReceivePacket", func) addEventHandler("onSendRPC", func) addEventHandler("onSendPacket", func)

Событие	Индекс
Входящие RPC​	RakLuaEvents.INCOMING_RPC​
Исходящие RPC​	RakLuaEvents.OUTGOING_RPC​
Входящие пакеты​	RakLuaEvents.INCOMING_PACKET​
Исходящие пакеты​	RakLuaEvents.OUTGOING_PACKET​

Дополнительная функция: RakLua.getSampVersion(), возвращает индекс исходя из перечисления:

Описание	Индекс
SAMP не загружен (одиночная игра / SAMP не установлен)​	RakLuaSampVersions.SAMP_NOT_LOADED​
Неизвестная версия SAMP (неподдерживаемая)​	RakLuaSampVersions.SAMP_UNKNOWN​
Версия SAMP 0.3.7-R1​	RakLuaSampVersions.SAMP_037_R1​
Версия SAMP 0.3.7-R3-1​	RakLuaSampVersions.SAMP_037_R3_1​

---

Примеры эмуляции исходящих RPC/пакетов
Для начала, хочу подметить, что работа с BitStream производится через новый класс, предоставляемый этой библиотекой — RakLuaBitStream, однако вы можете получить оригинальный BitStream через local bitStream = bs:getBitStream(), но он, скорее всего, для вас является бесполезным.

Давайте начнём с простого: эмуляция отправки, например, команды.

function send_rpc_command(text)
    local bs = RakLuaBitStream.new()
    bs:writeInt32(text:len())
    bs:writeString(text)
    if bs:sendRPC(50) --[[RPC_ServerCommand в 0.3.7-R3]] then
        print("RPC was sent!")
    else
        print("We couldn't send RPC.")
    end
end

Довольно просто, не так ли? Вы также можете убрать проверку на успешность отправки RPC, поскольку если вы всё правильно записали, то оно, вероятнее всего, отправится. Также обратите внимание, что мы не удаляем BitStream, нам этого не нужно делать, этим сам SAMP позаботится.

Можем отправить какое-либо сообщение просто в чат:

function send_text(text)
    local bs = RakLuaBitStream.new()
    bs:writeUInt8(text:len())
    bs:writeString(text)
    if bs:sendRPC(101) --[[RPC_Chat в 0.3.7-R3]] then
        print("RPC was sent!")
    else
        print("We couldn't send RPC.")
    end
end

Или написать целый sampSendChat(text):

function send_rpc_command(text)
    local bs = RakLuaBitStream.new()
    bs:writeInt32(text:len())
    bs:writeString(text)
    return bs:sendRPC(50) --[[RPC_ServerCommand в 0.3.7-R3]]
end

function send_text(text)
    local bs = RakLuaBitStream.new()
    bs:writeUInt8(text:len())
    bs:writeString(text)
    return bs:sendRPC(101) --[[RPC_Chat в 0.3.7-R3]]
end

function sampSendChat(text)
    text = tostring(text)
    return text:sub(1, 1) == "/" and send_rpc_command(text) or send_text(text)
end

Мы также можем отправлять пакеты, достаточно лишь заполнить его и отправить:

local bs = RakLuaBitStream.new()
bs:writeUInt8(id) -- ID пакета
-- И заполняем необходимыми данными
bs:sendPacket()

---

Отлавливание и обработка входящих/исходящих RPC и пакетов
Давайте хукнем, например, всеми известные onServerMessage, onSetPlayerHealth и onSetPlayerPos из входящих RPC:

local RakLua = require 'RakLua'

function main()
    RakLua.registerHandler(RakLuaEvents.INCOMING_RPC,
        function(id, bs)
            if id == 93 then -- RPC_ClientMessage
                local color = bs:readInt32() -- Читаем цвет
                local textLen = bs:readInt32() -- Читаем длину текста
                local text = bs:readString(textLen) -- Читаем сам текст
                local res = onServerMessage(color, text) -- Вызываем свою функцию
                if type(res) == "boolean" then -- Если тип возвращаемого значения bool
                    return res -- Возвращаем значение, сам обработчик уже обработает/не обработает
                    -- исходя из возвращаемого значения
                elseif type(res) == "table" then
                    bs:resetWritePointer() -- Сбросим указатель записи, чтобы перезаписать всё
                    bs:writeInt32(res[1]) -- Запишем цвет
                    bs:writeInt32(res[2]:len()) -- Запишем длину текста
                    bs:writeString(res[2]) -- Запишем сам текст
                end
            elseif id == 14 then -- RPC_SetPlayerHealth
                local health = bs:readFloat() -- Получим количество HP, которое сервер
                -- Хочет нам установить
                if health < 5 then
                    return false
                end
            elseif id == 12 then -- RPC_SetPlayerPos
                local x, y, z = bs:readFloat(), bs:readFloat(), bs:readFloat()
                print(string.format("Server tried to set your position at %.2f; %.2f; %.2f", x, y, z))
                return false -- Проигнорируем телепортацию
            end
        end
    )
end

function onServerMessage(color, text)
    if color == -1 then
        return false
    elseif text == "hello" then
        return true
    end
    return {color, "hello"}
end

Мы написали обработчик, который при получении RPC ClientMessage будет вызывать функцию onServerMessage, при получении RPC SetPlayerHealth, если сервер попытается установить HP ниже пяти, будет игнорировать, и RPC SetPlayerPos, который будет всегда игнорировать попытку сервера телепортировать нас и будет писать в moonloader.log соответствующую информацию.

Давайте напишем обработчик на исходящие RPC:

RakLua.registerHandler(RakLuaEvents.OUTGOING_RPC,
    function(id, bs, priority, reliability, orderingChannel, shiftTimestamp)
        if id == 101 then -- RPC_Chat
            local textLen = bs:readUInt8()
            local text = bs:readString(textLen)
            local res = onSendChat(text)
            if type(res) == "boolean" then
                return res
            elseif type(res) == "table" then
                bs:resetWritePointer()
                bs:writeUInt8(res[1]:len())
                bs:writeString(res[1])
            end
        elseif id == 50 then -- RPC_ServerCommand
            local cmdLen = bs:readInt32()
            local cmd = bs:readString(cmdLen)
            local res = onSendCommand(cmd)
            if type(res) == "boolean" then
                return res
            elseif type(res) == "table" then
                bs:resetWritePointer()
                bs:writeInt32(res[1]:len())
                bs:writeString(res[1])
            end
        end
    end
)

function onSendChat(text)
    if text == "hello" then
        text = "bye"
    elseif text == "privet" then
        return false
    end
    return {"[Префикс] "..text}
end

function onSendCommand(cmd)
    if cmd == "/help" then
        cmd = "/mm"
    elseif cmd == "/admins" then
        return false
    end
    return {cmd}
end

Обработчик, при получении RPC Chat; ServerCommand, будет вызывать соответствующие функции и исходя из их возвращаемых аргументов действовать.

Обработка исходящих пакетов:

RakLua.registerHandler(RakLuaEvents.OUTGOING_PACKET,
    function(id, bs, priority, reliability, orderingChannel)
        if id == 207 then -- ID_PLAYER_SYNC
            bs:ignoreBytes(35) -- or bs:skipBytes(35); пропускаем 35 байт
            local hp, armor = bs:readUInt8(), bs:readUInt8()
            print(string.format("I sent %d HP; %d armor.", hp, armor))
        end
    end
)

Если отправляем Packet PLAYER_SYNC, то пропускаем первые 35 байт, читаем количество здоровья, брони и выводим в moonloader.log.

---

Вот и всё, мы научились работать с RakLua, возможно даже что и с BitStream, раз ранее не работали.
Также хочу отметить, что поддержка с SAMP.Lua в наличии, но только начиная с версии 2.0. Для совместимости с SAMP.Lua необходимо вызвать функцию RakLua.defineSampLuaCompatibility() до подгрузки SAMP.Lua.

 

[Tema05]

В точку

А чё по R3? можно юзать на этой версии обе либы?

 

[_raz0r]

А чё по R3 можно юзать на этой версии обе либы?

SF.lua только под R1, но вроде должны добавить поддержку R3

 

[imring]

должны

кто они, я тут один

 

[_raz0r]

кто они, я тут один

хомка разве не занимается разработкой вместе с тобой?
(я хотел добавить в сф.луа поддержку R3, R2 и R4 версий)

 

[imring]

хомка разве не занимается разработкой вместе с тобой?
(я хотел добавить в сф.луа поддержку R3, R2 и R4 версий)

ему щас не до этого
(жди, когда обновление войдет в master)

 

[Tema05]

ему щас не до этого
(жди, когда обновление войдет в master)

А как тогда они https://vk.com/scriptpatrol?w=wall-142775990_725 сделали поддержку R3 без SF.lua?

 

[_raz0r]

А как тогда они https://vk.com/scriptpatrol?w=wall-142775990_725 сделали поддержку R3 без SF.lua?

В чем проблема вызывать функции SA-MP самостоятельно из скрипта?

 

[#Northn]

Я чёт недопёр как это можно написать под эту либу?

function sampev.onShowDialog(id, style, title, button1, button2, text)
   if id == 1000 and title == "{BFBBBA}{FFFFFF}Телефоны | {ae433d}Телефоны" then
      sampSendDialogResponse(1000, 0, 0, -1)
      return false
   end
end

Сейчас хотел ответить тебе и понял, что нет чтения/записи зашифрованного текста, занимаюсь добавлением, но вот тебе sampSendDialogResponse:

function sampSendDialogResponse(id, button, listItem, input)
    local bs = RakLuaBitStream.new()
    bs:writeUInt16(id)
    bs:writeUInt8(button)
    bs:writeInt16(listItem)
    bs:writeUInt8(input:len())
    bs:writeString(input)
    return bs:sendRPC(62)
end

А в чем проблема сделать ее на данный момент?

Хотел сделать, но на этапе получения RPCMap не выходило получить RPCNode* и забил пока что
Но я посмотрел, в бх нигде, никто не пользуется эмуляцией входящих пакетов/рпц, ну и я решил не тратить время на это

 

[Tema05]

чтения/записи зашифрованного текста

А разве samp шифрует диалоги?
И откуда ты вот это берёшь?

bs:writeUInt16(id)
bs:writeUInt8(button)
bs:writeInt16(listItem)
bs:writeUInt8(input:len())
bs:writeString(input)

Где можно узнать какие типы данных и в каком порядке нужно прописывать?

 

[_raz0r]

А разве samp шифрует диалоги?
И откуда ты вот это берёшь?

bs:writeUInt16(id)
bs:writeUInt8(button)
bs:writeInt16(listItem)
bs:writeUInt8(input:len())
bs:writeString(input)

Где можно узнать какие типы данных и в каком порядке нужно прописывать?

GitHub - Brunoo16/samp-packet-list: A list with SA-MP's packets documented.

A list with SA-MP's packets documented. Contribute to Brunoo16/samp-packet-list development by creating an account on GitHub.

github.com

 

[trefa]

GitHub - Brunoo16/samp-packet-list: A list with SA-MP's packets documented.

A list with SA-MP's packets documented. Contribute to Brunoo16/samp-packet-list development by creating an account on GitHub.

github.com

Там не все RPC расписаны, лучше ковырять SAMP.lua

 

[Tema05]

Там не все RPC расписаны, лучше ковырять SAMP.lua

SAMP.lua ведь не нужен с этими 2 либами?

 

[_raz0r]

SAMP.lua ведь не нужен с этими 2 либами?

просто смотри в файлах samp.lua типы данных
не нужен

 

[Tema05]

Сейчас хотел ответить тебе и понял, что нет чтения/записи зашифрованного текста, занимаюсь добавлением, но вот тебе sampSendDialogResponse:

function sampSendDialogResponse(id, button, listItem, input)
    local bs = RakLuaBitStream.new()
    bs:writeUInt16(id)
    bs:writeUInt8(button)
    bs:writeInt16(listItem)
    bs:writeUInt8(input:len())
    bs:writeString(input)
    return bs:sendRPC(62)
end

Хотел сделать, но на этапе получения RPCMap не выходило получить RPCNode* и забил пока что
Но я посмотрел, в бх нигде, никто не пользуется эмуляцией входящих пакетов/рпц, ну и я решил не тратить время на это

Планируешь добавить уже готовые функции для хуков как в SAMP.lua?
Как я думаю большинству людей проще скачать SAMP.lua и юзать

function sampev.onSendChat(text)
end

чем добавлять в свой код вот это

RakLua.registerHandler(RakLuaEvents.OUTGOING_RPC,
    function(id, bs, priority, reliability, orderingChannel, shiftTimestamp)
        if id == 101 then -- RPC_Chat
            local textLen = bs:readUInt8()
            local text = bs:readString(textLen)
            local res = onSendChat(text)
            if type(res) == "bool" then
                return res
            elseif type(res) == "table" then
                bs:resetWritePointer()
                bs:writeUInt8(res[1]:len())
                bs:writeString(res[1])
            end
        end
    end
)

function onSendChat(text)
end

 

[Azller Lollison]

GitHub - Brunoo16/samp-packet-list: A list with SA-MP's packets documented.

A list with SA-MP's packets documented. Contribute to Brunoo16/samp-packet-list development by creating an account on GitHub.

github.com

хуета репо как минимум одна ошибка с пакетами есть, указан неверный ид