From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: from smtp14.mail.ru (smtp14.mail.ru [94.100.181.95]) (using TLSv1.2 with cipher ECDHE-RSA-AES256-GCM-SHA384 (256/256 bits)) (No client certificate requested) by dev.tarantool.org (Postfix) with ESMTPS id D152A4696C4 for ; Sat, 18 Apr 2020 18:29:45 +0300 (MSK) From: Leonid Vasiliev Date: Sat, 18 Apr 2020 18:29:37 +0300 Message-Id: <4b3ee41137cefd5d01a34763d33be897ec5f8c09.1587223627.git.lvasiliev@tarantool.org> In-Reply-To: References: In-Reply-To: References: Subject: [Tarantool-patches] [PATCH V5 2/6] error: send custom type in IProto List-Id: Tarantool development patches List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , To: v.shpilevoy@tarantool.org, alexander.turenko@tarantool.org Cc: tarantool-patches@dev.tarantool.org Error custom type feature was added to the public Lua API in the previous commit. This one makes the new attribute being sent in IProto. Co-authored-by: Vladislav Shpilevoy Needed for #4398 @TarantoolBot document Title: New error object attribute in IProto Error objects in IProto already have 2 fields: `IPROTO_ERROR_CODE = 0x01` and `IPROTO_ERROR_MESSAGE = 0x02`. Now added: `IPROTO_ERROR_CUSTOM_TYPE = 0x03`. It's optional, has MP_STR type, and speaks for itself. Custom error type is error object attribute. This is what a user specifies in `box.error.new({type = })` or `box.error.new()`. --- src/box/iproto_constants.h | 1 + src/box/lua/net_box.lua | 9 ++++++--- src/box/xrow.c | 9 ++++++++- test/box/error.result | 39 +++++++++++++++++++++++++++++++++++++++ test/box/error.test.lua | 16 ++++++++++++++++ 5 files changed, 70 insertions(+), 4 deletions(-) diff --git a/src/box/iproto_constants.h b/src/box/iproto_constants.h index 7ed8296..1fca97b 100644 --- a/src/box/iproto_constants.h +++ b/src/box/iproto_constants.h @@ -154,6 +154,7 @@ enum iproto_ballot_key { enum iproto_error_key { IPROTO_ERROR_CODE = 0x01, IPROTO_ERROR_MESSAGE = 0x02, + IPROTO_ERROR_CUSTOM_TYPE = 0x03, }; #define bit(c) (1ULL<cause) { - mpstream_encode_map(stream, 2); + uint32_t map_size = 2; + const char *custom_type = box_error_custom_type(it); + map_size += (custom_type != NULL); + mpstream_encode_map(stream, map_size); mpstream_encode_uint(stream, IPROTO_ERROR_CODE); mpstream_encode_uint(stream, box_error_code(it)); mpstream_encode_uint(stream, IPROTO_ERROR_MESSAGE); mpstream_encode_str(stream, it->errmsg); + if (custom_type != NULL) { + mpstream_encode_uint(stream, IPROTO_ERROR_CUSTOM_TYPE); + mpstream_encode_str(stream, custom_type); + } } } diff --git a/test/box/error.result b/test/box/error.result index 0192017..9f04c76 100644 --- a/test/box/error.result +++ b/test/box/error.result @@ -888,3 +888,42 @@ e = box.error.new({type = string.rep('a', 128)}) | --- | - 63 | ... + +-- +-- Check how custom error type is passed through IProto. +-- +netbox = require('net.box') + | --- + | ... +box.schema.user.grant('guest', 'super') + | --- + | ... +c = netbox.connect(box.cfg.listen) + | --- + | ... +_, e = pcall(c.call, c, 'box.error', { \ + {code = 123, type = 'TestType', reason = 'Test reason'} \ +}) + | --- + | ... +e = e:unpack() + | --- + | ... +e.trace = nil + | --- + | ... +e + | --- + | - code: 123 + | base_type: CustomError + | type: TestType + | custom_type: TestType + | message: Test reason + | ... + +c:close() + | --- + | ... +box.schema.user.revoke('guest', 'super') + | --- + | ... diff --git a/test/box/error.test.lua b/test/box/error.test.lua index 38f7406..716f2bd 100644 --- a/test/box/error.test.lua +++ b/test/box/error.test.lua @@ -244,3 +244,19 @@ e:unpack() -- Try too long type name. e = box.error.new({type = string.rep('a', 128)}) #e.type + +-- +-- Check how custom error type is passed through IProto. +-- +netbox = require('net.box') +box.schema.user.grant('guest', 'super') +c = netbox.connect(box.cfg.listen) +_, e = pcall(c.call, c, 'box.error', { \ + {code = 123, type = 'TestType', reason = 'Test reason'} \ +}) +e = e:unpack() +e.trace = nil +e + +c:close() +box.schema.user.revoke('guest', 'super') -- 2.7.4