Merge pull request #1 from juliusmarminge/trpc-11

feat: support trpc11

package.json

@@ -44,7 +44,12 @@
   },
   "homepage": "https://github.com/baselime/node-opentelemetry#readme",
   "peerDependencies": {
-    "@trpc/server": "^10.0.0"
+    "@trpc/server": "^10.0.0 || ^11.0.0"
+  },
+  "peerDependenciesMeta": {
+    "@trpc/server": {
+      "optional": true
+    }
   },
   "dependencies": {
     "@opentelemetry/api": "^1.7.0",

src/trpc.ts

@@ -23,8 +23,11 @@ export function tracing(options?: TracingOptions) {
         return tracer.startActiveSpan(`TRPC ${opts.type}`, async (span: Span) => {
             const result = await opts.next();
 
-            if (options.collectInput && typeof opts.rawInput === "object") {
-                span.setAttributes(flatten({ input: opts.rawInput }))
+            // opts.rawInput is for v10, `opts.getRawInput` is for v11
+            const rawInput =
+                "rawInput" in opts ? opts.rawInput : await opts.getRawInput();
+            if (options.collectInput && typeof rawInput === "object") {
+                span.setAttributes(flatten({ input: rawInput }))
             }
             const meta = { path: opts.path, type: opts.type, ok: result.ok };
             span.setAttributes(meta)