eco2d/code/common/packets/packet.c

90 lines
2.9 KiB
C
Raw Normal View History

2021-01-26 19:16:08 +00:00
#include "packet.h"
2021-05-03 22:44:39 +00:00
#include "packet_utils.h"
2021-05-03 19:53:28 +00:00
#include "cwpack/cwpack.h"
2021-01-26 19:16:08 +00:00
#define PKT_HEADER_ELEMENTS 2
pkt_handler pkt_handlers[] = {
2021-05-04 00:01:31 +00:00
#ifdef SERVER
#else
2021-05-03 22:44:39 +00:00
{.id = MSG_ID_01_WELCOME, .handler = pkt_01_welcome_handler},
2021-05-04 00:01:31 +00:00
#endif
2021-01-26 19:16:08 +00:00
};
2021-05-03 22:44:39 +00:00
uint8_t pkt_buffer[PKT_BUFSIZ];
2021-05-04 11:04:15 +00:00
uint8_t pkt_pack_buffer[PKT_BUFSIZ];
2021-05-03 22:44:39 +00:00
2021-01-26 19:16:08 +00:00
int32_t pkt_header_encode(pkt_header *table) {
return 0;
}
int32_t pkt_header_decode(pkt_header *table, void *data, size_t datalen) {
cw_unpack_context uc = {0};
2021-05-03 22:44:39 +00:00
pkt_unpack_msg_raw(&uc, data, datalen, PKT_HEADER_ELEMENTS);
2021-01-26 19:16:08 +00:00
cw_unpack_next(&uc);
if (uc.item.type != CWP_ITEM_POSITIVE_INTEGER || uc.item.as.u64 > UINT16_MAX) {
2021-05-03 22:44:39 +00:00
return -1; // invalid packet id
2021-01-26 19:16:08 +00:00
}
uint16_t pkt_id = (uint16_t)uc.item.as.u64;
cw_unpack_next(&uc);
const void *packed_blob = uc.item.as.bin.start;
2021-05-03 19:53:28 +00:00
uint32_t packed_size = uc.item.as.bin.length;
2021-01-26 19:16:08 +00:00
table->id = pkt_id;
table->data = packed_blob;
table->datalen = packed_size;
table->ok = 1;
2021-05-03 22:44:39 +00:00
return pkt_validate_eof_msg(&uc);
2021-01-26 19:16:08 +00:00
}
2021-05-03 23:38:47 +00:00
int32_t pkt_unpack_struct(cw_unpack_context *uc, pkt_desc *desc, void *raw_blob, uint32_t blob_size) {
uint8_t *blob = (uint8_t*)raw_blob;
2021-05-04 08:08:00 +00:00
for (pkt_desc *field = desc; field->type != CWP_NOT_AN_ITEM; ++field) {
2021-05-03 23:38:47 +00:00
cw_unpack_next(uc);
if (uc->item.type != field->type) return -1; // unexpected field
2021-05-04 11:04:15 +00:00
if (blob + field->offset + field->size > blob + blob_size) return -1; // field does not fit
2021-05-03 23:38:47 +00:00
switch (field->type) {
case CWP_ITEM_POSITIVE_INTEGER: {
2021-05-04 08:08:00 +00:00
zpl_memcopy(blob + field->offset, (uint8_t*)&uc->item.as.u64, field->size);
2021-05-03 23:38:47 +00:00
}break;
2021-05-04 11:04:15 +00:00
case CWP_ITEM_BIN: {
if (uc->item.as.bin.length != field->size) return -1; // bin size mismatch
zpl_memcopy(blob + field->offset, (uint8_t*)uc->item.as.bin.start, uc->item.as.bin.length);
}break;
2021-05-03 23:38:47 +00:00
default: {
zpl_printf("[WARN] unsupported pkt field type %lld !\n", field->type);
return -1; // unsupported field
}break;
}
}
return 0;
}
2021-05-03 23:57:19 +00:00
2021-05-04 11:04:15 +00:00
int32_t pkt_pack_struct(cw_pack_context *pc, pkt_desc *desc, void *raw_blob, uint32_t blob_size) {
uint8_t *blob = (uint8_t*)raw_blob;
zpl_zero_item(pkt_pack_buffer);
for (pkt_desc *field = desc; field->type != CWP_NOT_AN_ITEM; ++field) {
switch (field->type) {
case CWP_ITEM_BIN: {
cw_pack_bin(pc, blob + field->offset, field->size);
}break;
case CWP_ITEM_POSITIVE_INTEGER: {
uint64_t num;
zpl_memcopy(&num, blob + field->offset, field->size);
cw_pack_unsigned(pc, num);
}break;
default: {
zpl_printf("[WARN] unsupported pkt field type %lld !\n", field->type);
return -1; // unsupported field
}break;
}
}
return 0;
}