feat: add semconv generator for semantic-conventions-package

packages/opentelemetry-instrumentation-fetch/src/enums/AttributeNames.ts

@@ -18,5 +18,7 @@
  * https://github.com/open-telemetry/opentelemetry-specification/blob/master/specification/trace/semantic_conventions/http.md
  */
 export enum AttributeNames {
-  COMPONENT = 'component',
+  COMPONENT = "component",
+  HTTP_ERROR_NAME = "http.error_name",
+  HTTP_STATUS_TEXT = "http.status_text",
 }

packages/opentelemetry-instrumentation-fetch/src/fetch.ts

@@ -14,18 +14,18 @@
  * limitations under the License.
  */
 
-import * as api from '@opentelemetry/api';
+import * as api from "@opentelemetry/api";
 import {
   isWrapped,
   InstrumentationBase,
   InstrumentationConfig,
-} from '@opentelemetry/instrumentation';
-import * as core from '@opentelemetry/core';
-import * as web from '@opentelemetry/web';
-import { AttributeNames } from './enums/AttributeNames';
-import { HttpAttribute } from '@opentelemetry/semantic-conventions';
-import { FetchError, FetchResponse, SpanData } from './types';
-import { VERSION } from './version';
+} from "@opentelemetry/instrumentation";
+import * as core from "@opentelemetry/core";
+import * as web from "@opentelemetry/web";
+import { AttributeNames } from "./enums/AttributeNames";
+import { SemanticAttributes } from "@opentelemetry/semantic-conventions";
+import { FetchError, FetchResponse, SpanData } from "./types";
+import { VERSION } from "./version";
 
 // how long to wait for observer to collect information about resources
 // this is needed as event "load" is called before observer
@@ -37,7 +37,7 @@ const OBSERVER_WAIT_TIME_MS = 300;
 let a: HTMLAnchorElement | undefined;
 const getUrlNormalizingAnchor = () => {
   if (!a) {
-    a = document.createElement('a');
+    a = document.createElement("a");
   }
 
   return a;
@@ -69,15 +69,15 @@ export interface FetchInstrumentationConfig extends InstrumentationConfig {
 export class FetchInstrumentation extends InstrumentationBase<
   Promise<Response>
 > {
-  readonly component: string = 'fetch';
+  readonly component: string = "fetch";
   readonly version: string = VERSION;
   moduleName = this.component;
   private _usedResources = new WeakSet<PerformanceResourceTiming>();
   private _tasksCount = 0;
 
   constructor(config: FetchInstrumentationConfig = {}) {
     super(
-      '@opentelemetry/instrumentation-fetch',
+      "@opentelemetry/instrumentation-fetch",
       VERSION,
       Object.assign({}, config)
     );
@@ -99,7 +99,7 @@ export class FetchInstrumentation extends InstrumentationBase<
     corsPreFlightRequest: PerformanceResourceTiming
   ): void {
     const childSpan = this.tracer.startSpan(
-      'CORS Preflight',
+      "CORS Preflight",
       {
         startTime: corsPreFlightRequest[web.PerformanceTimingNames.FETCH_START],
       },
@@ -121,16 +121,16 @@ export class FetchInstrumentation extends InstrumentationBase<
     response: FetchResponse
   ): void {
     const parsedUrl = web.parseUrl(response.url);
-    span.setAttribute(HttpAttribute.HTTP_STATUS_CODE, response.status);
+    span.setAttribute(SemanticAttributes.HTTP_STATUS_CODE, response.status);
     if (response.statusText != null) {
-      span.setAttribute(HttpAttribute.HTTP_STATUS_TEXT, response.statusText);
+      span.setAttribute(AttributeNames.HTTP_STATUS_TEXT, response.statusText);
     }
-    span.setAttribute(HttpAttribute.HTTP_HOST, parsedUrl.host);
+    span.setAttribute(SemanticAttributes.HTTP_HOST, parsedUrl.host);
     span.setAttribute(
-      HttpAttribute.HTTP_SCHEME,
-      parsedUrl.protocol.replace(':', '')
+      SemanticAttributes.HTTP_SCHEME,
+      parsedUrl.protocol.replace(":", "")
     );
-    span.setAttribute(HttpAttribute.HTTP_USER_AGENT, navigator.userAgent);
+    span.setAttribute(SemanticAttributes.HTTP_USER_AGENT, navigator.userAgent);
   }
 
   /**
@@ -150,7 +150,7 @@ export class FetchInstrumentation extends InstrumentationBase<
 
     if (options instanceof Request) {
       api.propagation.inject(api.context.active(), options.headers, {
-        set: (h, k, v) => h.set(k, typeof v === 'string' ? v : String(v)),
+        set: (h, k, v) => h.set(k, typeof v === "string" ? v : String(v)),
       });
     } else {
       const headers: Partial<Record<string, unknown>> = {};
@@ -182,17 +182,17 @@ export class FetchInstrumentation extends InstrumentationBase<
     options: Partial<Request | RequestInit> = {}
   ): api.Span | undefined {
     if (core.isUrlIgnored(url, this._getConfig().ignoreUrls)) {
-      api.diag.debug('ignoring span as url matches ignored url');
+      api.diag.debug("ignoring span as url matches ignored url");
       return;
     }
-    const method = (options.method || 'GET').toUpperCase();
+    const method = (options.method || "GET").toUpperCase();
     const spanName = `HTTP ${method}`;
     return this.tracer.startSpan(spanName, {
       kind: api.SpanKind.CLIENT,
       attributes: {
         [AttributeNames.COMPONENT]: this.moduleName,
-        [HttpAttribute.HTTP_METHOD]: method,
-        [HttpAttribute.HTTP_URL]: url,
+        [SemanticAttributes.HTTP_METHOD]: method,
+        [SemanticAttributes.HTTP_URL]: url,
       },
     });
   }
@@ -217,7 +217,7 @@ export class FetchInstrumentation extends InstrumentationBase<
       // then OBSERVER_WAIT_TIME_MS and observer didn't collect enough
       // information
       resources = performance.getEntriesByType(
-        'resource'
+        "resource"
       ) as PerformanceResourceTiming[];
     }
     const resource = web.getResource(
@@ -226,7 +226,7 @@ export class FetchInstrumentation extends InstrumentationBase<
       endTime,
       resources,
       this._usedResources,
-      'fetch'
+      "fetch"
     );
 
     if (resource.mainRequest) {
@@ -363,25 +363,25 @@ export class FetchInstrumentation extends InstrumentationBase<
   private _prepareSpanData(spanUrl: string): SpanData {
     const startTime = core.hrTime();
     const entries: PerformanceResourceTiming[] = [];
-    if (typeof window.PerformanceObserver === 'undefined') {
+    if (typeof window.PerformanceObserver === "undefined") {
       return { entries, startTime, spanUrl };
     }
 
-    const observer: PerformanceObserver = new PerformanceObserver(list => {
+    const observer: PerformanceObserver = new PerformanceObserver((list) => {
       const perfObsEntries = list.getEntries() as PerformanceResourceTiming[];
       const urlNormalizingAnchor = getUrlNormalizingAnchor();
       urlNormalizingAnchor.href = spanUrl;
-      perfObsEntries.forEach(entry => {
+      perfObsEntries.forEach((entry) => {
         if (
-          entry.initiatorType === 'fetch' &&
+          entry.initiatorType === "fetch" &&
           entry.name === urlNormalizingAnchor.href
         ) {
           entries.push(entry);
         }
       });
     });
     observer.observe({
-      entryTypes: ['resource'],
+      entryTypes: ["resource"],
     });
     return { entries, observer, startTime, spanUrl };
   }
@@ -391,17 +391,17 @@ export class FetchInstrumentation extends InstrumentationBase<
    */
   enable() {
     if (isWrapped(window.fetch)) {
-      this._unwrap(window, 'fetch');
-      api.diag.debug('removing previous patch for constructor');
+      this._unwrap(window, "fetch");
+      api.diag.debug("removing previous patch for constructor");
     }
-    this._wrap(window, 'fetch', this._patchConstructor());
+    this._wrap(window, "fetch", this._patchConstructor());
   }
 
   /**
    * implements unpatch function
    */
   disable() {
-    this._unwrap(window, 'fetch');
+    this._unwrap(window, "fetch");
     this._usedResources = new WeakSet<PerformanceResourceTiming>();
   }
 }