Merge branch 'main' into optimize-utcp

Raezil · web-flow · commit dc6ea9a069ff · 2025-08-09T11:20:17.000+02:00
diff --git a/go.sum b/go.sum
@@ -17,10 +17,6 @@ github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
 github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
 github.com/gorilla/websocket v1.5.3 h1:saDtZ6Pbx/0u+bgYQ3q96pZgCzfhKXGPqt7kZ72aNNg=
 github.com/gorilla/websocket v1.5.3/go.mod h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/adAjf1fMHhE=
-github.com/graphql-go/graphql v0.8.1 h1:p7/Ou/WpmulocJeEx7wjQy611rtXGQaAcXGqanuMMgc=
-github.com/graphql-go/graphql v0.8.1/go.mod h1:nKiHzRM0qopJEwCITUuIsxk9PlVlwIiiI8pnJEhordQ=
-github.com/graphql-go/handler v0.2.4 h1:gz9q11TUHPNUpqzV8LMa+rkqM5NUuH/nkE3oF2LS3rI=
-github.com/graphql-go/handler v0.2.4/go.mod h1:gsQlb4gDvURR0bgN8vWQEh+s5vJALM2lYL3n3cf6OxQ=
 github.com/joho/godotenv v1.5.1 h1:7eLL/+HRGLY0ldzfGMeQkb7vMd0as4CfYvUVzLqw0N0=
 github.com/joho/godotenv v1.5.1/go.mod h1:f4LDr5Voq0i2e/R5DDNOoa2zzDfwtkZa6DnEwAbqwq4=
 github.com/json-iterator/go v1.1.12 h1:PV8peI4a0ysnczrg+LtxykD8LfKY9ML6u2jnxaEnrnM=
diff --git a/go.work.sum b/go.work.sum
@@ -1,35 +1,62 @@
+cel.dev/expr v0.23.0 h1:wUb94w6OYQS4uXraxo9U+wUAs9jT47Xvl4iPgAwM2ss=
 cel.dev/expr v0.23.0/go.mod h1:hLPLo1W4QUmuYdA72RBX06QTs6MXw941piREPl3Yfiw=
 cel.dev/expr v0.24.0/go.mod h1:hLPLo1W4QUmuYdA72RBX06QTs6MXw941piREPl3Yfiw=
+cloud.google.com/go/compute/metadata v0.6.0 h1:A6hENjEsCDtC1k8byVsgwvVcioamEHvZ4j01OwKxG9I=
 cloud.google.com/go/compute/metadata v0.6.0/go.mod h1:FjyFAW1MW0C203CEOMDTu3Dk1FlqW3Rga40jzHL4hfg=
 cloud.google.com/go/compute/metadata v0.7.0/go.mod h1:j5MvL9PprKL39t166CoB1uVHfQMs4tFQZZcKwksXUjo=
+github.com/GoogleCloudPlatform/opentelemetry-operations-go/detectors/gcp v1.27.0 h1:ErKg/3iS1AKcTkf3yixlZ54f9U1rljCkQyEXWUnIUxc=
 github.com/GoogleCloudPlatform/opentelemetry-operations-go/detectors/gcp v1.27.0/go.mod h1:yAZHSGnqScoU556rBOVkwLze6WP5N+U11RHuWaGVxwY=
 github.com/Raezil/UTCP v1.1.9 h1:CYJigZtIM0r6MN8YdkXq2vBuoXah+j1+Kc9+hcqoH5c=
+github.com/cespare/xxhash/v2 v2.3.0 h1:UL815xU9SqsFlibzuggzjXhog7bL6oX9BbNZnL2UFvs=
 github.com/cespare/xxhash/v2 v2.3.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
+github.com/cncf/xds/go v0.0.0-20250326154945-ae57f3c0d45f h1:C5bqEmzEPLsHm9Mv73lSE9e9bKV23aB1vxOsmZrkl3k=
 github.com/cncf/xds/go v0.0.0-20250326154945-ae57f3c0d45f/go.mod h1:W+zGtBO5Y1IgJhy4+A9GOqVhqLpfZi+vwmdNXUehLA8=
 github.com/cncf/xds/go v0.0.0-20250501225837-2ac532fd4443/go.mod h1:W+zGtBO5Y1IgJhy4+A9GOqVhqLpfZi+vwmdNXUehLA8=
+github.com/envoyproxy/go-control-plane v0.13.4 h1:zEqyPVyku6IvWCFwux4x9RxkLOMUL+1vC9xUFv5l2/M=
 github.com/envoyproxy/go-control-plane v0.13.4/go.mod h1:kDfuBlDVsSj2MjrLEtRWtHlsWIFcGyB2RMO44Dc5GZA=
+github.com/envoyproxy/go-control-plane/envoy v1.32.4 h1:jb83lalDRZSpPWW2Z7Mck/8kXZ5CQAFYVjQcdVIr83A=
 github.com/envoyproxy/go-control-plane/envoy v1.32.4/go.mod h1:Gzjc5k8JcJswLjAx1Zm+wSYE20UrLtt7JZMWiWQXQEw=
+github.com/envoyproxy/go-control-plane/ratelimit v0.1.0 h1:/G9QYbddjL25KvtKTv3an9lx6VBE2cnb8wp1vEGNYGI=
 github.com/envoyproxy/go-control-plane/ratelimit v0.1.0/go.mod h1:Wk+tMFAFbCXaJPzVVHnPgRKdUdwW/KdbRt94AzgRee4=
+github.com/envoyproxy/protoc-gen-validate v1.2.1 h1:DEo3O99U8j4hBFwbJfrz9VtgcDfUKS7KJ7spH3d86P8=
 github.com/envoyproxy/protoc-gen-validate v1.2.1/go.mod h1:d/C80l/jxXLdfEIhX1W2TmLfsJ31lvEjwamM4DxlWXU=
+github.com/go-jose/go-jose/v4 v4.0.5 h1:M6T8+mKZl/+fNNuFHvGIzDz7BTLQPIounk/b9dw3AaE=
 github.com/go-jose/go-jose/v4 v4.0.5/go.mod h1:s3P1lRrkT8igV8D9OjyL4WRyHvjB6a4JSllnOrmmBOA=
+github.com/golang/glog v1.2.4 h1:CNNw5U8lSiiBk7druxtSHHTsRWcxKoac6kZKm2peBBc=
 github.com/golang/glog v1.2.4/go.mod h1:6AhwSGph0fcJtXVM/PEHPqZlFeoLxhs7/t5UDAwmO+w=
 github.com/golang/glog v1.2.5/go.mod h1:6AhwSGph0fcJtXVM/PEHPqZlFeoLxhs7/t5UDAwmO+w=
+github.com/kr/pty v1.1.1 h1:VkoXIwSboBpnk99O/KFauAEILuNHv5DVFKZMBN/gUgw=
+github.com/onsi/ginkgo v1.16.5 h1:8xi0RTUf59SOSfEtZMvwTvXYMzG4gV23XVHOZiXNtnE=
 github.com/onsi/ginkgo v1.16.5/go.mod h1:+E8gABHa3K6zRBolWtd+ROzc/U5bkGt0FwiG042wbpU=
+github.com/onsi/gomega v1.17.0 h1:9Luw4uT5HTjHTN8+aNcSThgH1vdXnmdJ8xIfZ4wyTRE=
 github.com/onsi/gomega v1.17.0/go.mod h1:HnhC7FXeEQY45zxNK3PPoIUhzk/80Xly9PcubAlGdZY=
+github.com/planetscale/vtprotobuf v0.6.1-0.20240319094008-0393e58bdf10 h1:GFCKgmp0tecUJ0sJuv4pzYCqS9+RGSn52M3FUwPs+uo=
 github.com/planetscale/vtprotobuf v0.6.1-0.20240319094008-0393e58bdf10/go.mod h1:t/avpk3KcrXxUnYOhZhMXJlSEyie6gQbtLq5NM3loB8=
+github.com/sclevine/agouti v3.0.0+incompatible h1:8IBJS6PWz3uTlMP3YBIR5f+KAldcGuOeFkFbUWfBgK4=
 github.com/sclevine/agouti v3.0.0+incompatible/go.mod h1:b4WX9W9L1sfQKXeJf1mUTLZKJ48R1S7H23Ji7oFO5Bw=
+github.com/spiffe/go-spiffe/v2 v2.5.0 h1:N2I01KCUkv1FAjZXJMwh95KK1ZIQLYbPfhaxw8WS0hE=
 github.com/spiffe/go-spiffe/v2 v2.5.0/go.mod h1:P+NxobPc6wXhVtINNtFjNWGBTreew1GBUCwT2wPmb7g=
+github.com/stretchr/objx v0.5.2 h1:xuMeJ0Sdp5ZMRXx/aWO6RZxdr3beISkG5/G/aIRr3pY=
+github.com/yuin/goldmark v1.4.13 h1:fVcFKWvrslecOb/tg+Cc05dkeYx540o0FuFt3nUVDoE=
+github.com/zeebo/errs v1.4.0 h1:XNdoD/RRMKP7HD0UhJnIzUy74ISdGGxURlYG8HSWSfM=
 github.com/zeebo/errs v1.4.0/go.mod h1:sgbWHsvVuTPHcqJJGQ1WhI5KbWlHYz+2+2C/LSEtCw4=
+go.opentelemetry.io/contrib/detectors/gcp v1.35.0 h1:bGvFt68+KTiAKFlacHW6AhA56GF2rS0bdD3aJYEnmzA=
 go.opentelemetry.io/contrib/detectors/gcp v1.35.0/go.mod h1:qGWP8/+ILwMRIUf9uIVLloR1uo5ZYAslM4O6OqUi1DA=
 go.opentelemetry.io/contrib/detectors/gcp v1.36.0/go.mod h1:IbBN8uAIIx734PTonTPxAxnjc2pQTxWNkwfstZ+6H2k=
+golang.org/x/mod v0.17.0 h1:zY54UmvipHiNd+pm+m0x9KhZ9hl1/7QNMyxXbc6ICqA=
 golang.org/x/mod v0.17.0/go.mod h1:hTbmBsO62+eylJbnUtE2MGJUyE7QWk4xUqPFrRgJ+7c=
+golang.org/x/oauth2 v0.28.0 h1:CrgCKl8PPAVtLnU3c+EDw6x11699EWlsDeWNWKdIOkc=
 golang.org/x/oauth2 v0.28.0/go.mod h1:onh5ek6nERTohokkhCD/y2cV4Do3fxFHFuAejCkRWT8=
 golang.org/x/oauth2 v0.30.0/go.mod h1:B++QgG3ZKulg6sRPGD/mqlHQs5rB3Ml9erfeDY7xKlU=
 golang.org/x/sync v0.14.0 h1:woo0S4Yywslg6hp4eUFjTVOyKt0RookbpAHG4c1HmhQ=
 golang.org/x/sync v0.14.0/go.mod h1:1dzgHSNfp02xaA81J2MS99Qcpr2w7fw1gpm99rleRqA=
 golang.org/x/term v0.18.0/go.mod h1:ILwASektA3OnRv7amZ1xhE/KTR+u50pbXfZ03+6Nx58=
+golang.org/x/term v0.32.0 h1:DR4lr0TjUs3epypdhTOkMmuF5CDFJ/8pOnbzMZPQ7bg=
 golang.org/x/term v0.32.0/go.mod h1:uZG1FhGx848Sqfsq4/DlJr3xGGsYMu/L5GW4abiaEPQ=
+golang.org/x/tools v0.21.1-0.20240508182429-e35e4ccd0d2d h1:vU5i/LfpvrRCpgM/VPfJLg5KjxD3E+hfT1SH+d9zLwg=
 golang.org/x/tools v0.21.1-0.20240508182429-e35e4ccd0d2d/go.mod h1:aiJjzUbINMkxbQROHiO6hDPo2LHcIPhhQsa9DLh0yGk=
+golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543 h1:E7g+9GITq07hpfrRu66IVDexMakfv52eLZ2CXBWiKr4=
 golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
+google.golang.org/genproto/googleapis/api v0.0.0-20250324211829-b45e905df463 h1:hE3bRWtU6uceqlh4fhrSnUyjKHMKB9KrTLLG+bc0ddM=
 google.golang.org/genproto/googleapis/api v0.0.0-20250324211829-b45e905df463/go.mod h1:U90ffi8eUL9MwPcrJylN5+Mk2v3vuPDptd5yyNUiRR8=
 google.golang.org/genproto/googleapis/api v0.0.0-20250528174236-200df99c418a/go.mod h1:a77HrdMjoeKbnd2jmgcWdaS++ZLZAEq3orIOAEIKiVw=
diff --git a/src/json/json.go b/src/json/json.go
@@ -0,0 +1,20 @@
+package json
+
+import (
+	jsoniter "github.com/json-iterator/go"
+)
+
+var json = jsoniter.ConfigCompatibleWithStandardLibrary
+
+var (
+	Marshal    = json.Marshal
+	Unmarshal  = json.Unmarshal
+	NewDecoder = json.NewDecoder
+	NewEncoder = json.NewEncoder
+)
+
+type RawMessage = jsoniter.RawMessage
+
+type Decoder = jsoniter.Decoder
+
+type Encoder = jsoniter.Encoder
diff --git a/src/transports/cli/cli_transport.go b/src/transports/cli/cli_transport.go
@@ -3,9 +3,9 @@ package cli
 import (
 	"bytes"
 	"context"
-	"encoding/json"
 	"errors"
 	"fmt"
+	json "github.com/universal-tool-calling-protocol/go-utcp/src/json"
 	"os"
 	"os/exec"
 	"sort"
diff --git a/src/transports/graphql/graphql_transport.go b/src/transports/graphql/graphql_transport.go
@@ -3,9 +3,9 @@ package graphql
 import (
 	"context"
 	"encoding/base64"
-	"encoding/json"
 	"errors"
 	"fmt"
+	json "github.com/universal-tool-calling-protocol/go-utcp/src/json"
 	"io"
 	"io/ioutil"
 	"net/http"
diff --git a/src/transports/graphql/graphql_transport_additional_test.go b/src/transports/graphql/graphql_transport_additional_test.go
@@ -2,7 +2,7 @@ package graphql
 
 import (
 	"context"
-	"encoding/json"
+	json "github.com/universal-tool-calling-protocol/go-utcp/src/json"
 	"net/http"
 	"net/http/httptest"
 	"testing"
diff --git a/src/transports/graphql/graphql_transport_subscription_test.go b/src/transports/graphql/graphql_transport_subscription_test.go
@@ -2,7 +2,7 @@ package graphql
 
 import (
 	"context"
-	"encoding/json"
+	json "github.com/universal-tool-calling-protocol/go-utcp/src/json"
 	"net/http"
 	"net/http/httptest"
 	"strings"
diff --git a/src/transports/graphql/graphql_transport_test.go b/src/transports/graphql/graphql_transport_test.go
@@ -2,7 +2,7 @@ package graphql
 
 import (
 	"context"
-	"encoding/json"
+	json "github.com/universal-tool-calling-protocol/go-utcp/src/json"
 	"net/http"
 	"net/http/httptest"
 	"strings"
diff --git a/src/transports/grpc/grpc_transport.go b/src/transports/grpc/grpc_transport.go
@@ -2,9 +2,9 @@ package grpc
 
 import (
 	"context"
-	"encoding/json"
 	"errors"
 	"fmt"
+	json "github.com/universal-tool-calling-protocol/go-utcp/src/json"
 
 	"google.golang.org/grpc"
 	"google.golang.org/grpc/credentials/insecure"
diff --git a/src/transports/grpc/grpc_transport_test.go b/src/transports/grpc/grpc_transport_test.go
@@ -2,7 +2,7 @@ package grpc
 
 import (
 	"context"
-	"encoding/json"
+	json "github.com/universal-tool-calling-protocol/go-utcp/src/json"
 	"net"
 	"testing"
 
diff --git a/src/transports/http/http_transport.go b/src/transports/http/http_transport.go
@@ -2,9 +2,9 @@ package http
 
 import (
 	"context"
-	"encoding/json"
 	"errors"
 	"fmt"
+	json "github.com/universal-tool-calling-protocol/go-utcp/src/json"
 	"io/ioutil"
 	"net/http"
 	"net/url"
diff --git a/src/transports/mcp/mcp_transport.go b/src/transports/mcp/mcp_transport.go
@@ -3,9 +3,9 @@ package mcp
 import (
 	"bufio"
 	"context"
-	"encoding/json"
 	"errors"
 	"fmt"
+	json "github.com/universal-tool-calling-protocol/go-utcp/src/json"
 	"io"
 	"os"
 	"os/exec"
diff --git a/src/transports/sse/sse_client_transport.go b/src/transports/sse/sse_client_transport.go
@@ -5,9 +5,9 @@ import (
 	"bufio"
 	"bytes"
 	"context"
-	"encoding/json"
 	"errors"
 	"fmt"
+	json "github.com/universal-tool-calling-protocol/go-utcp/src/json"
 	"io"
 	"net/http"
 	"strings"
diff --git a/src/transports/sse/sse_client_transport_test.go b/src/transports/sse/sse_client_transport_test.go
@@ -2,7 +2,7 @@ package sse
 
 import (
 	"context"
-	"encoding/json"
+	json "github.com/universal-tool-calling-protocol/go-utcp/src/json"
 	"net/http"
 	"net/http/httptest"
 	"testing"
diff --git a/src/transports/streamable/streamable_transport.go b/src/transports/streamable/streamable_transport.go
@@ -4,9 +4,9 @@ import (
 	"bufio"
 	"bytes"
 	"context"
-	"encoding/json"
 	"errors"
 	"fmt"
+	json "github.com/universal-tool-calling-protocol/go-utcp/src/json"
 	"io"
 	"net/http"
 	"time"
diff --git a/src/transports/streamable/streamable_transport_test.go b/src/transports/streamable/streamable_transport_test.go
@@ -2,7 +2,7 @@ package streamable
 
 import (
 	"context"
-	"encoding/json"
+	json "github.com/universal-tool-calling-protocol/go-utcp/src/json"
 	"io"
 	"net/http"
 	"net/http/httptest"
diff --git a/src/transports/tcp/tcp_transport.go b/src/transports/tcp/tcp_transport.go
@@ -3,9 +3,9 @@ package tcp
 import (
 	"bufio"
 	"context"
-	"encoding/json"
 	"errors"
 	"fmt"
+	json "github.com/universal-tool-calling-protocol/go-utcp/src/json"
 	"io"
 	"net"
 	"time"
diff --git a/src/transports/tcp/tcp_transport_test.go b/src/transports/tcp/tcp_transport_test.go
@@ -2,7 +2,7 @@ package tcp
 
 import (
 	"context"
-	"encoding/json"
+	json "github.com/universal-tool-calling-protocol/go-utcp/src/json"
 	"net"
 
 	. "github.com/universal-tool-calling-protocol/go-utcp/src/providers/base"
diff --git a/src/transports/udp/udp_transport.go b/src/transports/udp/udp_transport.go
@@ -2,9 +2,9 @@ package udp
 
 import (
 	"context"
-	"encoding/json"
 	"errors"
 	"fmt"
+	json "github.com/universal-tool-calling-protocol/go-utcp/src/json"
 	"net"
 
 	. "github.com/universal-tool-calling-protocol/go-utcp/src/manual"
diff --git a/src/transports/udp/udp_transport_test.go b/src/transports/udp/udp_transport_test.go
@@ -2,7 +2,7 @@ package udp
 
 import (
 	"context"
-	"encoding/json"
+	json "github.com/universal-tool-calling-protocol/go-utcp/src/json"
 	"net"
 	"strconv"
 	"testing"
diff --git a/src/transports/webrtc/webrtc_transport.go b/src/transports/webrtc/webrtc_transport.go
@@ -3,8 +3,8 @@ package webrtc
 import (
 	"bytes"
 	"context"
-	"encoding/json"
 	"errors"
+	json "github.com/universal-tool-calling-protocol/go-utcp/src/json"
 	"net/http"
 	"sync"
 	"time"
diff --git a/src/transports/webrtc/webrtc_transport_integration_test.go b/src/transports/webrtc/webrtc_transport_integration_test.go
@@ -2,7 +2,7 @@ package webrtc
 
 import (
 	"context"
-	"encoding/json"
+	json "github.com/universal-tool-calling-protocol/go-utcp/src/json"
 	"net/http"
 
 	"net/http/httptest"
diff --git a/src/transports/websocket/websocket_transport.go b/src/transports/websocket/websocket_transport.go
@@ -3,8 +3,8 @@ package websocket
 import (
 	"context"
 	"encoding/base64"
-	"encoding/json"
 	"errors"
+	json "github.com/universal-tool-calling-protocol/go-utcp/src/json"
 	"net/http"
 	"strings"
 
