chore(examples): lint examples/mongodb using shared top-level eslint config

examples/mongodb/.eslintrc.js

@@ -0,0 +1,26 @@
+/*
+ * Copyright The OpenTelemetry Authors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+'use strict';
+
+const baseConfig = require('../../eslint.config');
+
+module.exports = {
+  ...baseConfig,
+  env: {
+    node: true,
+  },
+};

examples/mongodb/package.json

@@ -5,6 +5,8 @@
   "description": "Example of mongodb integration with OpenTelemetry",
   "main": "index.js",
   "scripts": {
+    "lint": "eslint . --ext=ts,js,mjs",
+    "lint:fix": "eslint . --ext=ts,js,mjs --fix",
     "docker:start": "docker run -e MONGODB_DB=opentelemetry-tests -e MONGODB_PORT=27017 -e MONGODB_HOST=127.0.0.1 -p 27017:27017 --rm mongo",
     "zipkin:server": "cross-env EXPORTER=zipkin ts-node src/server.ts",
     "zipkin:client": "cross-env EXPORTER=zipkin ts-node src/client.ts",
@@ -35,6 +37,8 @@
     "@opentelemetry/instrumentation": "^0.54.2",
     "@opentelemetry/instrumentation-http": "^0.54.2",
     "@opentelemetry/instrumentation-mongodb": "^0.48.0",
+    "@opentelemetry/exporter-trace-otlp-http": "^0.54.2",
+    "@opentelemetry/resources": "^1.27.0",
     "@opentelemetry/sdk-trace-node": "^1.27.0",
     "@opentelemetry/sdk-trace-base": "^1.27.0",
     "@opentelemetry/semantic-conventions": "^1.27.0",

examples/mongodb/src/client.ts

@@ -1,11 +1,25 @@
-'use strict';
+/*
+ * Copyright The OpenTelemetry Authors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
 
-import * as api  from '@opentelemetry/api';
-import { setupTracing } from './tracer';
-
-const tracer = setupTracing('example-mongodb-http-client')
+import * as api from '@opentelemetry/api';
 import * as http from 'http';
+// eslint-disable-next-line import/extensions
+import { setupTracing } from './tracer';
 
+const tracer = setupTracing('example-mongodb-http-client');
 
 /** A function which makes requests and handles response. */
 function makeRequest() {
@@ -19,58 +33,71 @@ function makeRequest() {
 
   api.context.with(api.trace.setSpan(api.ROOT_CONTEXT, span), () => {
     queries += 1;
-    http.get({
-      host: 'localhost',
-      port: 8080,
-      path: '/collection/',
-    }, (response) => {
-      const body: any = [];
-      response.on('data', (chunk) => body.push(chunk));
-      response.on('end', () => {
-        responses += 1;
-        console.log(body.toString());
-        if (responses === queries) span.end();
-      });
-    });
+    http.get(
+      {
+        host: 'localhost',
+        port: 8080,
+        path: '/collection/',
+      },
+      response => {
+        const body: any = [];
+        response.on('data', chunk => body.push(chunk));
+        response.on('end', () => {
+          responses += 1;
+          console.log(body.toString());
+          if (responses === queries) span.end();
+        });
+      }
+    );
   });
   api.context.with(api.trace.setSpan(api.ROOT_CONTEXT, span), () => {
     queries += 1;
-    http.get({
-      host: 'localhost',
-      port: 8080,
-      path: '/insert/',
-    }, (response) => {
-      const body: any = [];
-      response.on('data', (chunk) => body.push(chunk));
-      response.on('end', () => {
-        responses += 1;
-        console.log(body.toString());
-        if (responses === queries) span.end();
-      });
-    });
+    http.get(
+      {
+        host: 'localhost',
+        port: 8080,
+        path: '/insert/',
+      },
+      response => {
+        const body: any = [];
+        response.on('data', chunk => body.push(chunk));
+        response.on('end', () => {
+          responses += 1;
+          console.log(body.toString());
+          if (responses === queries) span.end();
+        });
+      }
+    );
   });
   api.context.with(api.trace.setSpan(api.ROOT_CONTEXT, span), () => {
     queries += 1;
-    http.get({
-      host: 'localhost',
-      port: 8080,
-      path: '/get/',
-    }, (response) => {
-      const body: any = [];
-      response.on('data', (chunk) => body.push(chunk));
-      response.on('end', () => {
-        responses += 1;
-        console.log(body.toString());
-        if (responses === queries) span.end();
-      });
-    });
+    http.get(
+      {
+        host: 'localhost',
+        port: 8080,
+        path: '/get/',
+      },
+      response => {
+        const body: any = [];
+        response.on('data', chunk => body.push(chunk));
+        response.on('end', () => {
+          responses += 1;
+          console.log(body.toString());
+          if (responses === queries) span.end();
+        });
+      }
+    );
   });
 
   // The process must live for at least the interval past any traces that
   // must be exported, or some risk being lost if they are recorded after the
   // last export.
-  console.log('Sleeping 5 seconds before shutdown to ensure all records are flushed.');
-  setTimeout(() => { console.log('Completed.'); }, 5000);
+  console.log(
+    'Sleeping 5 seconds before shutdown to ensure all records are flushed.'
+  );
+  setTimeout(() => {
+    console.log('Completed.');
+  }, 5000);
 }
 
 makeRequest();

examples/mongodb/src/server.ts

@@ -1,15 +1,30 @@
+/*
+ * Copyright The OpenTelemetry Authors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
 import * as api from '@opentelemetry/api';
 
-import { setupTracing } from './tracer';
-
-setupTracing('example-mongodb-server');
-
-import { accessDB } from './utils';
-
 import * as http from 'http';
 import { IncomingMessage, ServerResponse } from 'http';
 import * as mongodb from 'mongodb';
 import { Collection } from 'mongodb';
+// eslint-disable-next-line import/extensions
+import { setupTracing } from './tracer';
+// eslint-disable-next-line import/extensions
+import { accessDB } from './utils';
+
+setupTracing('example-mongodb-server');
 
 const DB_NAME = 'mydb';
 const COLLECTION_NAME = 'users';
@@ -41,7 +56,7 @@ function handleRequest(request: IncomingMessage, response: ServerResponse) {
   const currentSpan = api.trace.getSpan(api.context.active());
   if (currentSpan) {
     // display traceID in the terminal
-    const { traceId } = currentSpan?.spanContext();
+    const { traceId } = currentSpan.spanContext();
     console.log(`traceid: ${traceId}`);
     console.log(`Jaeger URL: http://localhost:16686/trace/${traceId}`);
     console.log(`Zipkin URL: http://localhost:9411/zipkin/traces/${traceId}`);
@@ -79,9 +94,12 @@ function handleInsertQuery(response: ServerResponse) {
     .then(() => {
       console.log('1 document inserted');
       // find document to test context
-      usersCollection.findOne({}).then(res => {
-        console.log(JSON.stringify(res));
-      });
+      usersCollection
+        .findOne({})
+        .then(res => {
+          console.log(JSON.stringify(res));
+        })
+        .catch(err => console.log(err));
     })
     .catch(err => {
       console.log('Error code:', err.code);

examples/mongodb/src/tracer.ts

@@ -1,3 +1,18 @@
+/*
+ * Copyright The OpenTelemetry Authors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
 import * as api from '@opentelemetry/api';
 
 import { NodeTracerProvider } from '@opentelemetry/sdk-trace-node';
@@ -10,6 +25,7 @@ import { HttpInstrumentation } from '@opentelemetry/instrumentation-http';
 import { MongoDBInstrumentation } from '@opentelemetry/instrumentation-mongodb';
 import { ATTR_SERVICE_NAME } from '@opentelemetry/semantic-conventions';
 
+// eslint-disable-next-line import/prefer-default-export
 export const setupTracing = (serviceName: string): api.Tracer => {
   const provider = new NodeTracerProvider({
     resource: new Resource({

examples/mongodb/src/utils.ts

@@ -22,14 +22,15 @@ import * as mongodb from 'mongodb';
  * @param dbName The mongodb database name.
  * @param options The mongodb client config options.
  */
+// eslint-disable-next-line import/prefer-default-export
 export function accessDB(
   url: string,
   dbName: string,
   options: mongodb.MongoClientOptions = {}
 ): Promise<mongodb.Db> {
   return new Promise((resolve, reject) => {
     mongodb.MongoClient.connect(url, {
-      serverSelectionTimeoutMS: 1000
+      serverSelectionTimeoutMS: 1000,
     })
       .then(client => {
         resolve(client.db(dbName));