mirrors/riiablo
1
0
Fork 0
mirror of https://github.com/collinsmith/riiablo.git synced 2025-03-05 23:20:32 +07:00
Code Issues Actions Packages Projects Releases Wiki Activity

Implemented ItemReader and ItemWriter into Item component serializer

Browse Source
This commit is contained in:
Collin Smith 2020-08-19 21:16:52 -07:00
parent 1bd32e777d
commit 2beecb35a8
1 changed files with 17 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
core/src/com/riiablo/engine/server/component/serializer/ItemSerializer.java
View File

@ -1,17 +1,25 @@
package com.riiablo.engine.server.component.serializer;
import com.google.flatbuffers.FlatBufferBuilder;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.ByteBufUtil;
import io.netty.buffer.Unpooled;
import com.riiablo.codec.util.BitStream;
import com.riiablo.engine.server.component.Item;
import com.riiablo.io.ByteInput;
import com.riiablo.io.ByteOutput;
import com.riiablo.item.ItemReader;
import com.riiablo.item.ItemWriter;
import com.riiablo.net.packet.d2gs.ComponentP;
import com.riiablo.net.packet.d2gs.EntitySync;
import com.riiablo.net.packet.d2gs.ItemP;
import com.riiablo.util.BufferUtils;
public class ItemSerializer implements FlatBuffersSerializer<Item, ItemP> {
public static final ItemP table = new ItemP();
protected static final ItemReader itemReader = new ItemReader();
protected static final ItemWriter itemWriter = new ItemWriter();
@Override
public byte getDataType() {
return ComponentP.ItemP;
@ -19,7 +27,11 @@ public class ItemSerializer implements FlatBuffersSerializer<Item, ItemP> {
@Override
public int putData(FlatBufferBuilder builder, Item c) {
int dataOffset = ItemP.createDataVector(builder, c.item.data());
ByteBuf buffer = Unpooled.buffer();
ByteOutput out = ByteOutput.wrap(buffer);
itemWriter.writeItem(c.item, out);
byte[] itemBytes = ByteBufUtil.getBytes(buffer);
int dataOffset = ItemP.createDataVector(builder, itemBytes);
return ItemP.createItemP(builder, dataOffset);
}
@ -32,10 +44,8 @@ public class ItemSerializer implements FlatBuffersSerializer<Item, ItemP> {
@Override
public Item getData(EntitySync sync, int j, Item c) {
getTable(sync, j);
byte[] bytes = BufferUtils.readRemaining(table.dataAsByteBuffer());
BitStream bitStream = new BitStream(bytes);
// bitStream.skip(D2S.ItemData.SECTION_HEADER_BITS);
c.item = com.riiablo.item.Item.loadFromStream(bitStream);
ByteBuf buffer = Unpooled.wrappedBuffer(table.dataAsByteBuffer());
c.item = itemReader.readItem(ByteInput.wrap(buffer));
return c;
}
}