format

Author: andrewbrook

packages/telemetry/src/logging/fetch-transport.edge.test.ts

@@ -1,7 +1,8 @@
 /*
+* @license
  * Copyright The OpenTelemetry Authors
  * Copyright 2025 Google LLC
- * 
+ *
  * This file has been modified by Google LLC
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
@@ -20,15 +21,19 @@
 import * as sinon from 'sinon';
 import * as assert from 'assert';
 import { FetchTransportEdge } from './fetch-transport.edge';
-import { ExportResponseRetryable, ExportResponseFailure, ExportResponseSuccess } from '@opentelemetry/otlp-exporter-base';
+import {
+  ExportResponseRetryable,
+  ExportResponseFailure,
+  ExportResponseSuccess
+} from '@opentelemetry/otlp-exporter-base';
 
 const testTransportParameters = {
   url: 'http://example.test',
   headers: () => ({
     foo: 'foo-value',
     bar: 'bar-value',
-    'Content-Type': 'application/json',
-  }),
+    'Content-Type': 'application/json'
+  })
 };
 
 const requestTimeout = 1000;
@@ -40,7 +45,7 @@ describe('FetchTransportEdge', () => {
   });
 
   describe('send', () => {
-    it('returns success when request succeeds', (done) => {
+    it('returns success when request succeeds', done => {
       // arrange
       const fetchStub = sinon
         .stub(globalThis, 'fetch')
@@ -65,9 +70,9 @@ describe('FetchTransportEdge', () => {
               headers: {
                 foo: 'foo-value',
                 bar: 'bar-value',
-                'Content-Type': 'application/json',
+                'Content-Type': 'application/json'
               },
-              body: testPayload,
+              body: testPayload
             }
           );
           done();
@@ -77,7 +82,7 @@ describe('FetchTransportEdge', () => {
       }, done /* catch any rejections */);
     });
 
-    it('returns failure when request fails', (done) => {
+    it('returns failure when request fails', done => {
       // arrange
       sinon
         .stub(globalThis, 'fetch')
@@ -96,7 +101,7 @@ describe('FetchTransportEdge', () => {
       }, done /* catch any rejections */);
     });
 
-    it('returns retryable when request is retryable', (done) => {
+    it('returns retryable when request is retryable', done => {
       // arrange
       sinon
         .stub(globalThis, 'fetch')
@@ -121,7 +126,7 @@ describe('FetchTransportEdge', () => {
       }, done /* catch any rejections */);
     });
 
-    it('returns failure when request times out', (done) => {
+    it('returns failure when request times out', done => {
       // arrange
       const abortError = new Error('aborted request');
       abortError.name = 'AbortError';
@@ -146,7 +151,7 @@ describe('FetchTransportEdge', () => {
       clock.tick(requestTimeout + 100);
     });
 
-    it('returns failure when no server exists', (done) => {
+    it('returns failure when no server exists', done => {
       // arrange
       sinon.stub(globalThis, 'fetch').throws(new Error('fetch failed'));
       const clock = sinon.useFakeTimers();
@@ -169,4 +174,4 @@ describe('FetchTransportEdge', () => {
       clock.tick(requestTimeout + 100);
     });
   });
-});
+});

packages/telemetry/src/logging/fetch-transport.edge.ts

@@ -1,7 +1,8 @@
 /*
+* @license
  * Copyright The OpenTelemetry Authors
  * Copyright 2025 Google LLC
- * 
+ *
  * This file has been modified by Google LLC
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
@@ -17,7 +18,10 @@
  * limitations under the License.
  */
 
-import { IExporterTransport, ExportResponse } from '@opentelemetry/otlp-exporter-base';
+import {
+  IExporterTransport,
+  ExportResponse
+} from '@opentelemetry/otlp-exporter-base';
 import { diag } from '@opentelemetry/api';
 
 function isExportRetryable(statusCode: number): boolean {
@@ -53,7 +57,7 @@ export interface FetchTransportParameters {
 
 /**
  * An implementation of IExporterTransport that can be used in the Edge Runtime.
- * 
+ *
  * @internal
  */
 export class FetchTransportEdge implements IExporterTransport {
@@ -84,15 +88,15 @@ export class FetchTransportEdge implements IExporterTransport {
       }
       return {
         status: 'failure',
-        error: new Error('Fetch request failed with non-retryable status'),
+        error: new Error('Fetch request failed with non-retryable status')
       };
     } catch (error) {
       if (error instanceof Error) {
-        return {status: 'failure', error,};
+        return { status: 'failure', error };
       }
       return {
         status: 'failure',
-        error: new Error(`Fetch request errored: ${error}`),
+        error: new Error(`Fetch request errored: ${error}`)
       };
     } finally {
       clearTimeout(timeout);
@@ -102,4 +106,4 @@ export class FetchTransportEdge implements IExporterTransport {
   shutdown(): void {
     // Intentionally left empty, nothing to do.
   }
-}
+}

packages/telemetry/src/logging/logger-provider.ts

@@ -19,14 +19,17 @@ import {
   LoggerProvider,
   BatchLogRecordProcessor,
   ReadableLogRecord,
-  LogRecordExporter,
+  LogRecordExporter
 } from '@opentelemetry/sdk-logs';
 import { ATTR_SERVICE_NAME } from '@opentelemetry/semantic-conventions';
 import { resourceFromAttributes } from '@opentelemetry/resources';
 import { OTLPLogExporter } from '@opentelemetry/exporter-logs-otlp-http';
 import { JsonLogsSerializer } from '@opentelemetry/otlp-transformer';
 import type { OTLPExporterConfigBase } from '@opentelemetry/otlp-exporter-base';
-import { OTLPExporterBase, createOtlpNetworkExportDelegate } from '@opentelemetry/otlp-exporter-base';
+import {
+  OTLPExporterBase,
+  createOtlpNetworkExportDelegate
+} from '@opentelemetry/otlp-exporter-base';
 import { FetchTransportEdge } from './fetch-transport.edge';
 
 /**
@@ -44,18 +47,18 @@ export function createLoggerProvider(): LoggerProvider {
     // We need a slightly custom implementation for the Edge Runtime, because it doesn't have access
     // to many features available in Node.
     const logExporter = new OTLPLogExporterEdge({ url: otlpEndpoint });
-    const provider =  new LoggerProvider({
+    const provider = new LoggerProvider({
       resource,
       processors: [new BatchLogRecordProcessor(logExporter)],
       logRecordLimits: {}
     });
     return provider;
   } else {
-      const logExporter = new OTLPLogExporter({ url: otlpEndpoint });
-      return new LoggerProvider({
-        resource,
-        processors: [new BatchLogRecordProcessor(logExporter)]
-      });
+    const logExporter = new OTLPLogExporter({ url: otlpEndpoint });
+    return new LoggerProvider({
+      resource,
+      processors: [new BatchLogRecordProcessor(logExporter)]
+    });
   }
 }
 
@@ -78,7 +81,7 @@ class OTLPLogExporterEdge
           headers: () => ({
             'Content-Type': 'application/json'
           })
-        }),
+        })
       )
     );
   }