feat: adding opentelemetry (#257)

* feat: adding opentelemetry

* test: fix test

---------

Co-authored-by: Nicolas Burtey <[email protected]>

README.md

@@ -10,7 +10,7 @@ With a default installation, Admin Panel can be accessed with `admin.domain.com`
 
 ## How to run this repo locally?
 
-copy `.env` to `.env.local`. and edit environement variable accordingly.
+copy `.env` to `.env.local`. and edit environment variable accordingly.
 
 ```
 yarn install

app/graphql-rsc.tsx

@@ -6,6 +6,7 @@ import {
 } from "@apollo/experimental-nextjs-app-support/ssr"
 import { cookies } from "next/headers"
 import { env } from "./env"
+import { propagation, context } from '@opentelemetry/api';
 
 export const { getClient } = registerApolloClient(() => {
   const cookieStore = cookies()
@@ -19,6 +20,14 @@ export const { getClient } = registerApolloClient(() => {
       headers: {
         cookie: cookieStore.toString(),
       },
+      fetch: (uri, options) => {
+        const headersWithTrace = options?.headers || {}
+        propagation.inject(context.active(), headersWithTrace)
+        return fetch(uri, {
+          ...options,
+          headers: headersWithTrace,
+        })
+      },
     }),
   })
 })

instrumentation.node.ts

@@ -0,0 +1,35 @@
+import { NodeSDK } from "@opentelemetry/sdk-node";
+import { OTLPTraceExporter } from "@opentelemetry/exporter-trace-otlp-http";
+import { Resource } from "@opentelemetry/resources";
+import { SemanticResourceAttributes } from "@opentelemetry/semantic-conventions";
+import { SimpleSpanProcessor } from "@opentelemetry/sdk-trace-node";
+import { NetInstrumentation } from "@opentelemetry/instrumentation-net";
+import { HttpInstrumentation } from "@opentelemetry/instrumentation-http";
+import { GraphQLInstrumentation } from "@opentelemetry/instrumentation-graphql";
+import { propagation } from "@opentelemetry/api"
+import { W3CTraceContextPropagator } from "@opentelemetry/core"
+
+const sdk = new NodeSDK({
+  textMapPropagator: new W3CTraceContextPropagator(),
+  resource: new Resource({
+    [SemanticResourceAttributes.SERVICE_NAME]: process.env.TRACING_SERVICE_NAME || "blink-fiat",
+  }),
+  spanProcessor: new SimpleSpanProcessor(new OTLPTraceExporter()),
+  instrumentations: [
+    new NetInstrumentation(),
+    new HttpInstrumentation(),
+    new GraphQLInstrumentation({
+      mergeItems: true,
+      allowValues: true,
+    }),
+  ],
+});
+sdk.start();
+
+process.on("SIGTERM", () => {
+  sdk
+    .shutdown()
+    .then(() => console.log("Tracing terminated"))
+    .catch((error) => console.log("Error terminating tracing", error))
+    .finally(() => process.exit(0));
+});

instrumentation.ts

@@ -0,0 +1,7 @@
+export async function register() {
+  console.log("register", process.env.NEXT_RUNTIME)
+
+  if (process.env.NEXT_RUNTIME === "nodejs") {
+    await import("./instrumentation.node")
+  }
+}

next.config.js

@@ -3,5 +3,6 @@
 module.exports = {
   experimental: {
     serverActions: true,
+    instrumentationHook: true,
   },
 }

package.json

@@ -19,6 +19,15 @@
   "dependencies": {
     "@apollo/client": "^3.7.17",
     "@apollo/experimental-nextjs-app-support": "^0.4.3",
+    "@opentelemetry/api": "^1.6.0",
+    "@opentelemetry/exporter-trace-otlp-http": "^0.43.0",
+    "@opentelemetry/instrumentation-graphql": "^0.35.1",
+    "@opentelemetry/instrumentation-http": "^0.43.0",
+    "@opentelemetry/instrumentation-net": "^0.32.1",
+    "@opentelemetry/resources": "^1.17.0",
+    "@opentelemetry/sdk-node": "^0.43.0",
+    "@opentelemetry/sdk-trace-node": "^1.17.0",
+    "@opentelemetry/semantic-conventions": "^1.17.0",
     "@svgr/webpack": "^8.0.1",
     "@t3-oss/env-nextjs": "^0.6.1",
     "graphql": "^16.7.1",