cha0s/avocado
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor: socket API

Browse Source
This commit is contained in:
cha0s 2021-01-18 15:49:24 -06:00
parent 86cfe1fb8a
commit 900470ee2c
8 changed files with 24 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
packages/entity/src/packets/entity-list-update-entity.js
View File

@ -2,11 +2,11 @@ import {packets, Packet} from '@latus/socket';
export default (latus) => class EntityListUpdateEntityPacket extends Packet {
static packData(data) {
static pack(data) {
const {fromType: {Bundle}} = packets(latus);
for (let i = 0; i < data.length; i++) {
// eslint-disable-next-line no-param-reassign
data[i].packets = Bundle.bundle(data[i].packets);
data[i].packets = Bundle.encode(data[i].packets);
}
return data;
}
@ -20,11 +20,11 @@ export default (latus) => class EntityListUpdateEntityPacket extends Packet {
];
}
static unpackData(data) {
static unpack(data) {
const {fromType: {Bundle}} = packets(latus);
for (let i = 0; i < data.length; i++) {
// eslint-disable-next-line no-param-reassign
data[i].packets = Bundle.unbundle(data[i].packets);
data[i].packets = Bundle.decode(data[i].packets);
}
return data;
}

8
packages/entity/src/packets/entity-update-trait.js
View File

@ -4,7 +4,7 @@ import {packets} from '@latus/socket';
export default (latus) => class EntityUpdateTraitPacket extends SynchronizedUpdatePacket {
static packData(data) {
static pack(data) {
const {fromType: {Bundle}} = packets(latus);
const {fromType} = traits(latus);
for (let i = 0; i < data.traits.length; i++) {
@ -12,7 +12,7 @@ export default (latus) => class EntityUpdateTraitPacket extends SynchronizedUpda
// eslint-disable-next-line no-param-reassign
data.traits[i] = {
type: Trait.id,
packets: Bundle.bundle(data.traits[i].packets),
packets: Bundle.encode(data.traits[i].packets),
};
}
return data;
@ -29,7 +29,7 @@ export default (latus) => class EntityUpdateTraitPacket extends SynchronizedUpda
};
}
static unpackData(data) {
static unpack(data) {
const {fromType: {Bundle}} = packets(latus);
const {fromId} = traits(latus);
for (let i = 0; i < data.traits.length; i++) {
@ -37,7 +37,7 @@ export default (latus) => class EntityUpdateTraitPacket extends SynchronizedUpda
// eslint-disable-next-line no-param-reassign
data.traits[i] = {
type: Trait.type,
packets: Bundle.unbundle(data.traits[i].packets),
packets: Bundle.decode(data.traits[i].packets),
};
}
return data;

4
packages/graphics/src/packets/trait-update-visible.js
View File

@ -2,7 +2,7 @@ import {Packet} from '@latus/socket';
export default () => class TraitUpdateVisiblePacket extends Packet {
static packData(data) {
static pack(data) {
return {
isVisibile: data.isVisible,
opacity: Math.floor(data.opacity * 255),
@ -16,7 +16,7 @@ export default () => class TraitUpdateVisiblePacket extends Packet {
};
}
static unpackData(data) {
static unpack(data) {
return {
isVisibile: data.isVisible,
opacity: data.opacity / 255,

4
packages/input/src/packets/input.js
View File

@ -12,7 +12,7 @@ export default class InputPacket extends Packet {
}
}
static packData(data) {
static pack(data) {
for (let i = 0; i < data.length; i++) {
const {action, value} = data[i];
const actionId = this.actionIds[action];
@ -26,7 +26,7 @@ export default class InputPacket extends Packet {
return ['uint32'];
}
static unpackData(data) {
static unpack(data) {
for (let i = 0; i < data.length; i++) {
// eslint-disable-next-line no-bitwise
const [actionId, value] = [data[i] >> 24, data[i] & 0xFFFFFF];

4
packages/math/src/vector/packer.js
View File

@ -33,14 +33,14 @@ export default (key) => (Superclass) => {
},
},
);
PackedVectorPacket.packData = key
PackedVectorPacket.pack = key
? (data) => {
// eslint-disable-next-line no-param-reassign
data[key] = packToUint32(data[key]);
return data;
}
: (data) => packToUint32(data);
PackedVectorPacket.unpackData = key
PackedVectorPacket.unpack = key
? (data) => {
// eslint-disable-next-line no-param-reassign
data[key] = unpackFromUint32(data[key]);

4
packages/s13n/src/packets/synchronized-create.js
View File

@ -4,7 +4,7 @@ import SynchronizedPacket from './synchronized';
export default class SynchronizedCreatePacket extends SynchronizedPacket {
static packData(data) {
static pack(data) {
// eslint-disable-next-line no-param-reassign
data.spec = msgpack.encode(data.spec);
return data;
@ -20,7 +20,7 @@ export default class SynchronizedCreatePacket extends SynchronizedPacket {
return 'create';
}
static unpackData(data) {
static unpack(data) {
// eslint-disable-next-line no-param-reassign
data.spec = msgpack.decode(data.spec);
return data;

8
packages/topdown/src/packets/layers-update-layer.js
View File

@ -2,11 +2,11 @@ import {packets, Packet} from '@latus/socket';
export default (latus) => class LayersUpdateLayerPacket extends Packet {
static packData(data) {
static pack(data) {
const {fromType: {Bundle}} = packets(latus);
for (let i = 0; i < data.length; i++) {
// eslint-disable-next-line no-param-reassign
data[i].layerPackets = Bundle.bundle(data[i].layerPackets);
data[i].layerPackets = Bundle.encode(data[i].layerPackets);
}
return data;
}
@ -20,11 +20,11 @@ export default (latus) => class LayersUpdateLayerPacket extends Packet {
];
}
static unpackData(data) {
static unpack(data) {
const {fromType: {Bundle}} = packets(latus);
for (let i = 0; i < data.length; i++) {
// eslint-disable-next-line no-param-reassign
data[i].layerPackets = Bundle.unbundle(data[i].layerPackets);
data[i].layerPackets = Bundle.decode(data[i].layerPackets);
}
return data;
}

8
packages/topdown/src/packets/room-update-layers.js
View File

@ -3,10 +3,10 @@ import {SynchronizedUpdatePacket} from '@avocado/s13n';
export default (latus) => class RoomUpdateLayers extends SynchronizedUpdatePacket {
static packData(data) {
static pack(data) {
const {fromType: {Bundle}} = packets(latus);
// eslint-disable-next-line no-param-reassign
data.layersPackets = Bundle.bundle(data.layersPackets);
data.layersPackets = Bundle.encode(data.layersPackets);
return data;
}
@ -16,10 +16,10 @@ export default (latus) => class RoomUpdateLayers extends SynchronizedUpdatePacke
};
}
static unpackData(data) {
static unpack(data) {
const {fromType: {Bundle}} = packets(latus);
// eslint-disable-next-line no-param-reassign
data.layersPackets = Bundle.unbundle(data.layersPackets);
data.layersPackets = Bundle.decode(data.layersPackets);
return data;
}