diff options
| -rw-r--r-- | src/msgpack_rpc.c | 156 | ||||
| -rw-r--r-- | src/msgpack_rpc.h | 30 |
2 files changed, 186 insertions, 0 deletions
diff --git a/src/msgpack_rpc.c b/src/msgpack_rpc.c new file mode 100644 index 0000000000..5e36830132 --- /dev/null +++ b/src/msgpack_rpc.c @@ -0,0 +1,156 @@ +#include <msgpack.h> + +#include "msgpack_rpc.h" +#include "vim.h" +#include "memory.h" + + +bool msgpack_rpc_call(msgpack_object *req, msgpack_packer *res) +{ + // Validate the basic structure of the msgpack-rpc payload + if (req->type != MSGPACK_OBJECT_ARRAY) { + return msgpack_rpc_error(req, res, "Request is not an array"); + } + + if (req->via.array.size != 4) { + char error_msg[256]; + snprintf(error_msg, + sizeof(error_msg), + "Request array size is %u, it should be 4", + req->via.array.size); + return msgpack_rpc_error(req, res, error_msg); + } + + if (req->via.array.ptr[0].type != MSGPACK_OBJECT_POSITIVE_INTEGER) { + return msgpack_rpc_error(req, res, "Message type must be an integer"); + } + + if (req->via.array.ptr[0].via.u64 != 0) { + return msgpack_rpc_error(req, res, "Message type must be 0"); + } + + if (req->via.array.ptr[1].type != MSGPACK_OBJECT_POSITIVE_INTEGER) { + return msgpack_rpc_error(req, res, "Id must be a positive integer"); + } + + if (req->via.array.ptr[2].type != MSGPACK_OBJECT_POSITIVE_INTEGER) { + return msgpack_rpc_error(req, res, "Method id must be a positive integer"); + } + + if (req->via.array.ptr[3].type != MSGPACK_OBJECT_ARRAY) { + return msgpack_rpc_error(req, res, "Paremeters must be an array"); + } + + // dispatch the message + return msgpack_rpc_dispatch(req, res); +} + +void msgpack_rpc_response(msgpack_object *req, msgpack_packer *res) +{ + // Array of size 4 + msgpack_pack_array(res, 4); + // Response type is 1 + msgpack_pack_int(res, 1); + // Msgid is the same as the request + msgpack_pack_int(res, req->via.array.ptr[1].via.u64); +} + +void msgpack_rpc_success(msgpack_object *req, msgpack_packer *res) +{ + msgpack_rpc_response(req, res); + // Nil error + msgpack_pack_nil(res); +} + +bool msgpack_rpc_error(msgpack_object *req, msgpack_packer *res, char *msg) +{ + size_t len = strlen(msg); + + msgpack_rpc_response(req, res); + msgpack_pack_raw(res, len); + msgpack_pack_raw_body(res, msg, len); + // Nil result + msgpack_pack_nil(res); + + return false; +} + +char **msgpack_rpc_array_argument(msgpack_object *obj) +{ + uint32_t i; + char **rv = xmalloc(obj->via.array.size + 1); + + for (i = 0; i < obj->via.array.size; i++) { + rv[i] = msgpack_rpc_raw_argument(obj->via.array.ptr + i); + } + + rv[i] = NULL; + + return rv; +} + +char *msgpack_rpc_raw_argument(msgpack_object *obj) +{ + char *rv = xmalloc(obj->via.raw.size + 1); + memcpy(rv, obj->via.raw.ptr, obj->via.raw.size); + rv[obj->via.raw.size] = NUL; + + return rv; +} + +uint32_t msgpack_rpc_integer_argument(msgpack_object *obj) +{ + return obj->via.u64; +} + +bool msgpack_rpc_array_result(char **result, + msgpack_object *req, + msgpack_packer *res) +{ + char **ptr; + uint32_t array_size; + + // Count number of items in the array + for (ptr = result; *ptr != NULL; ptr++) continue; + + msgpack_rpc_success(req, res); + // Subtract 1 to exclude the NULL slot + array_size = ptr - result - 1; + msgpack_pack_array(res, array_size); + + // push each string to the array + for (ptr = result; *ptr != NULL; ptr++) { + size_t raw_size = strlen(*ptr); + msgpack_pack_raw(res, raw_size); + msgpack_pack_raw_body(res, *ptr, raw_size); + } + + return true; +} + +bool msgpack_rpc_raw_result(char *result, + msgpack_object *req, + msgpack_packer *res) +{ + size_t raw_size = strlen(result); + msgpack_rpc_success(req, res); + msgpack_pack_raw(res, raw_size); + msgpack_pack_raw_body(res, result, raw_size); + return true; +} + +bool msgpack_rpc_integer_result(uint32_t result, + msgpack_object *req, + msgpack_packer *res) +{ + msgpack_rpc_success(req, res); + msgpack_pack_int(res, result); + return true; +} + +bool msgpack_rpc_void_result(msgpack_object *req, msgpack_packer *res) +{ + msgpack_rpc_success(req, res); + msgpack_pack_nil(res); + return true; +} diff --git a/src/msgpack_rpc.h b/src/msgpack_rpc.h new file mode 100644 index 0000000000..f713e5eeb5 --- /dev/null +++ b/src/msgpack_rpc.h @@ -0,0 +1,30 @@ +#ifndef NEOVIM_MSGPACK_RPC_H +#define NEOVIM_MSGPACK_RPC_H + +#include <stdint.h> +#include <stdbool.h> + +#include <msgpack.h> + +bool msgpack_rpc_call(msgpack_object *req, msgpack_packer *res); +bool msgpack_rpc_dispatch(msgpack_object *req, msgpack_packer *res); +void msgpack_rpc_response(msgpack_object *req, msgpack_packer *res); +void msgpack_rpc_success(msgpack_object *req, msgpack_packer *res); +bool msgpack_rpc_error(msgpack_object *req, msgpack_packer *res, char *msg); +char **msgpack_rpc_array_argument(msgpack_object *obj); +char *msgpack_rpc_raw_argument(msgpack_object *obj); +uint32_t msgpack_rpc_integer_argument(msgpack_object *obj); +bool msgpack_rpc_array_result(char **result, + msgpack_object *req, + msgpack_packer *res); +bool msgpack_rpc_raw_result(char *result, + msgpack_object *req, + msgpack_packer *res); +bool msgpack_rpc_integer_result(uint32_t result, + msgpack_object *req, + msgpack_packer *res); +bool msgpack_rpc_void_result(msgpack_object *req, msgpack_packer *res); + + +#endif // NEOVIM_MSGPACK_RPC_H + |