Update Envelop Prom plugin

Author: ardatan

.changeset/shiny-coats-smile.md

@@ -0,0 +1,5 @@
+---
+'@graphql-yoga/plugin-prometheus': patch
+---
+
+Update Envelop plugin

packages/plugins/prometheus/package.json

@@ -42,7 +42,7 @@
     "prom-client": "^15.0.0"
   },
   "dependencies": {
-    "@envelop/prometheus": "9.0.0"
+    "@envelop/prometheus": "^9.2.0"
   },
   "devDependencies": {
     "prom-client": "15.0.0"

packages/plugins/prometheus/src/index.ts

@@ -29,15 +29,21 @@ export function usePrometheus(options: PrometheusTracingPluginConfig): Plugin {
 
   let httpHistogram: ReturnType<typeof createHistogram> | undefined;
 
+  function labelExists(label: string) {
+    if ((options.labels as Record<string, boolean>)?.[label] == null) {
+      return true;
+    }
+    return (options.labels as Record<string, boolean>)[label];
+  }
+
   if (options.http) {
-    const labelNames = [
-      'url',
-      'method',
-      'statusCode',
-      'statusText',
-      'operationName',
-      'operationType',
-    ];
+    const labelNames = ['url', 'method', 'statusCode', 'statusText'];
+    if (labelExists('operationName')) {
+      labelNames.push('operationName');
+    }
+    if (labelExists('operationType')) {
+      labelNames.push('operationType');
+    }
     if (options.httpRequestHeaders) {
       labelNames.push('requestHeaders');
     }
@@ -62,9 +68,12 @@ export function usePrometheus(options: PrometheusTracingPluginConfig): Plugin {
                 statusCode: response.status,
                 statusText: response.statusText,
               };
-              if (params?.operationType) {
+              if (labelExists('operationType') && params.operationType) {
                 labels.operationType = params.operationType;
               }
+              if (labelExists('operationName')) {
+                labels.operationName = params.operationName || 'Anonymous';
+              }
               if (options.httpRequestHeaders) {
                 labels.requestHeaders = JSON.stringify(
                   Object.fromEntries(request.headers.entries()),