From 05c8e0a31a0d4192c590e833b24393208e1c751f Mon Sep 17 00:00:00 2001 From: tanaka takashi Date: Tue, 30 Jun 2026 19:03:25 +0900 Subject: fix: MCPCをvendored fork化しMCP準拠と接続安定性を改善 MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - Git submoduleを廃止してMCPCを直接管理 - Windowsで254リクエスト付近に発生する切断を修正 - JSON-RPC 2.0エラー応答を標準化 - tool schemaとruntimeの必須・任意引数を一致 - 1000回連続呼び出しの回帰テストを追加 --- third_party/mcpc/src/mjson.h | 296 +++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 296 insertions(+) create mode 100644 third_party/mcpc/src/mjson.h (limited to 'third_party/mcpc/src/mjson.h') diff --git a/third_party/mcpc/src/mjson.h b/third_party/mcpc/src/mjson.h new file mode 100644 index 0000000..7a562f0 --- /dev/null +++ b/third_party/mcpc/src/mjson.h @@ -0,0 +1,296 @@ +// Copyright (c) 2018-2020 Cesanta Software Limited +// All rights reserved +// +// Permission is hereby granted, free of charge, to any person obtaining a copy +// of this software and associated documentation files (the "Software"), to deal +// in the Software without restriction, including without limitation the rights +// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell +// copies of the Software, and to permit persons to whom the Software is +// furnished to do so, subject to the following conditions: +// +// The above copyright notice and this permission notice shall be included in +// all copies or substantial portions of the Software. +// +// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR +// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, +// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE +// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER +// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, +// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE +// SOFTWARE. + +#ifndef MJSON_H +#define MJSON_H + +#include +#include +#include + +#include +#include +#include + +#ifndef MJSON_ENABLE_PRINT +#define MJSON_ENABLE_PRINT 1 +#endif + +#ifndef MJSON_ENABLE_RPC +#define MJSON_ENABLE_RPC 1 +#endif + +#ifndef MJSON_ENABLE_BASE64 +#define MJSON_ENABLE_BASE64 1 +#endif + +#ifndef MJSON_ENABLE_MERGE +#define MJSON_ENABLE_MERGE 1 +#endif + +#ifndef MJSON_ENABLE_PRETTY +#define MJSON_ENABLE_PRETTY 1 +#endif + +#ifndef MJSON_ENABLE_NEXT +#define MJSON_ENABLE_NEXT 1 +#endif + +#ifndef MJSON_RPC_LIST_NAME +#define MJSON_RPC_LIST_NAME "rpc.list" +#endif + +#ifndef MJSON_DYNBUF_CHUNK +#define MJSON_DYNBUF_CHUNK 256 // Allocation granularity for print_dynamic_buf +#endif + +#ifndef MJSON_REALLOC +#define MJSON_REALLOC realloc +#endif + +#ifdef __cplusplus +extern "C" +{ +#endif + +#define MJSON_ERROR_INVALID_INPUT (-1) +#define MJSON_ERROR_TOO_DEEP (-2) +#define MJSON_TOK_INVALID 0 +#define MJSON_TOK_KEY 1 +#define MJSON_TOK_STRING 11 +#define MJSON_TOK_NUMBER 12 +#define MJSON_TOK_TRUE 13 +#define MJSON_TOK_FALSE 14 +#define MJSON_TOK_NULL 15 +#define MJSON_TOK_ARRAY 91 +#define MJSON_TOK_OBJECT 123 +#define MJSON_TOK_IS_VALUE(t) ((t) > 10 && (t) < 20) + + typedef int (*mjson_cb_t)(int event, + const char* buf, + int offset, + int len, + void* fn_data); + +#ifndef MJSON_MAX_DEPTH +#define MJSON_MAX_DEPTH 20 +#endif + + int mjson(const char* buf, int len, mjson_cb_t cb, void* ud); + int mjson_find(const char* buf, + int len, + const char* jp, + const char** tp, + int* tl); + int32_t mjson_find8(const char8_t* buf, + int32_t len, + const char8_t* jp, + const char8_t** tp, + int32_t* tl); + int32_t mjson_find88(const char* buf, + int32_t len, + const char8_t* jp, + const char8_t** tp, + int32_t* tl); + int32_t mjson_find88(const char* buf, + int32_t len, + const char8_t* jp, + const char8_t** tp, + int32_t* tl); + int mjson_get_number(const char* buf, int len, const char* path, double* v); + int mjson_get_bool(const char* buf, int len, const char* path, int* v); + int mjson_get_string(const char* buf, + int len, + const char* path, + char* to, + int n); + int mjson_get_hex(const char* buf, + int len, + const char* path, + char* to, + int n); + +#if MJSON_ENABLE_NEXT + int mjson_next(const char* buf, + int len, + int offset, + int* key_offset, + int* key_len, + int* val_offset, + int* val_len, + int* vale_type); +#endif + +#if MJSON_ENABLE_BASE64 + int mjson_get_base64(const char* buf, + int len, + const char* path, + char* dst, + int dst_len); + int mjson_base64_dec(const char* src, int src_len, char* dst, int dst_len); +#endif + +#if MJSON_ENABLE_PRINT + typedef int (*mjson_print_fn_t)(const char* buf, int len, void* fn_data); + typedef int (*mjson_vprint_fn_t)(mjson_print_fn_t fn, void*, va_list*); + + struct mjson_fixedbuf + { + char* ptr; + int size, len; + }; + + int mjson_printf(mjson_print_fn_t fn, void* fn_data, const char* fmt, ...); + int mjson_vprintf(mjson_print_fn_t fn, + void* fn_data, + const char* fmt, + va_list* ap); + int mjson_print_str(mjson_print_fn_t fn, + void* fn_data, + const char* buf, + int len); + int mjson_print_int(mjson_print_fn_t fn, + void* fn_data, + int value, + int is_signed); + int mjson_print_long(mjson_print_fn_t fn, + void* fn_data, + long value, + int is_signed); + int mjson_print_buf(mjson_print_fn_t fn, + void* fn_data, + const char* buf, + int len); + int mjson_print_dbl(mjson_print_fn_t fn, void* fn_data, double d, int width); + + int mjson_print_null(const char* ptr, int len, void* fn_data); + int mjson_print_fixed_buf(const char* ptr, int len, void* fn_data); + int mjson_print_dynamic_buf(const char* ptr, int len, void* fn_data); + + int mjson_snprintf(char* buf, size_t len, const char* fmt, ...); + char* mjson_aprintf(const char* fmt, ...); + +#if MJSON_ENABLE_PRETTY + int mjson_pretty(const char* s, + int n, + const char* pad, + mjson_print_fn_t fn, + void* fn_data); +#endif + +#if MJSON_ENABLE_MERGE + int mjson_merge(const char* s, + int n, + const char* s2, + int n2, + mjson_print_fn_t fn, + void* fn_data); +#endif + +#endif // MJSON_ENABLE_PRINT + +#if MJSON_ENABLE_RPC + + void jsonrpc_init(mjson_print_fn_t response_cb, void* fn_data); + int mjson_globmatch(const char* s1, int n1, const char* s2, int n2); + + struct jsonrpc_request + { + struct jsonrpc_ctx* ctx; + const char* frame; // Points to the whole frame + int frame_len; // Frame length + const char* params; // Points to the "params" in the request frame + int params_len; // Length of the "params" + const char* id; // Points to the "id" in the request frame + int id_len; // Length of the "id" + const char* method; // Points to the "method" in the request frame + int method_len; // Length of the "method" + mjson_print_fn_t fn; // Printer function + void* fn_data; // Printer function data + void* userdata; // Callback's user data as specified at export time + }; + + struct jsonrpc_method + { + const char* method; + int method_sz; + void (*cb)(struct jsonrpc_request*); + struct jsonrpc_method* next; + }; + + // Main RPC context, stores current request information and a list of + // exported RPC methods. + struct jsonrpc_ctx + { + struct jsonrpc_method* methods; + mjson_print_fn_t response_cb; + void* response_cb_data; + }; + +// Registers function fn under the given name within the given RPC context +#define jsonrpc_ctx_export(ctx, name, fn) \ + do { \ + static struct jsonrpc_method m = { (name), sizeof(name) - 1, (fn), 0 }; \ + m.next = (ctx)->methods; \ + (ctx)->methods = &m; \ + } while (0) + + void jsonrpc_ctx_init(struct jsonrpc_ctx* ctx, + mjson_print_fn_t response_cb, + void* response_cb_data); + void jsonrpc_return_error(struct jsonrpc_request* r, + int code, + const char* message, + const char* data_fmt, + ...); + void jsonrpc_return_success(struct jsonrpc_request* r, + const char* result_fmt, + ...); + void jsonrpc_return_success2(struct jsonrpc_request* r, bool add_endl, + const char* result_fmt, + ...); + void jsonrpc_ctx_process(struct jsonrpc_ctx* ctx, + const char* req, + int req_sz, + mjson_print_fn_t fn, + void* fn_data, + void* userdata); + + extern struct jsonrpc_ctx jsonrpc_default_context; + extern void jsonrpc_list(struct jsonrpc_request* r); + +#define jsonrpc_export(name, fn) \ + jsonrpc_ctx_export(&jsonrpc_default_context, (name), (fn)) + +#define jsonrpc_process(buf, len, fn, fnd, ud) \ + jsonrpc_ctx_process(&jsonrpc_default_context, (buf), (len), (fn), (fnd), (ud)) + +#define JSONRPC_ERROR_INVALID -32700 /* Invalid JSON was received */ +#define JSONRPC_ERROR_INVALID_REQUEST -32600 /* The JSON-RPC request is invalid */ +#define JSONRPC_ERROR_NOT_FOUND -32601 /* The method does not exist */ +#define JSONRPC_ERROR_BAD_PARAMS -32602 /* Invalid params passed */ +#define JSONRPC_ERROR_INTERNAL -32603 /* Internal JSON-RPC error */ + +#endif // MJSON_ENABLE_RPC +#ifdef __cplusplus +} +#endif +#endif // MJSON_H -- cgit v1.2.3