fix: MCPCをvendored fork化しMCP準拠と接続安定性を改善

- Git submoduleを廃止してMCPCを直接管理
- Windowsで254リクエスト付近に発生する切断を修正
- JSON-RPC 2.0エラー応答を標準化
- tool schemaとruntimeの必須・任意引数を一致
- 1000回連続呼び出しの回帰テストを追加

1 files changed, 296 insertions, 0 deletions

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 <stdarg.h>
+#include <stdlib.h>
+#include <string.h>
+
+#include <mcpc/_c23_uchar.h>
+#include <mcpc/_c23_keywords.h>
+#include <stdint.h>
+
+#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