Merge pull request #34 from MediaJel/staging

Staging

Author: johnjoseph28

chart/stages/production.yaml

@@ -12,3 +12,4 @@ global:
   environment: PRODUCTION
 salesForceChannel: "live" # Must either be "live" or "test", production must use "live"
 intuitEnvironment: production
+service_name: "Salesforce Automation"

chart/stages/staging.yaml

@@ -13,3 +13,4 @@ global:
   environment: STAGE
 salesForceChannel: "live" # Must either be "live" or "test", production must use "live"
 intuitEnvironment: sandbox
+service_name: "Salesforce Automation"

chart/templates/salesforce.yaml

@@ -82,6 +82,9 @@ spec:
             memory: |-
               {{ .Values.memoryRequest }}
         env:  
+        - name: SERVICE_NAME
+          value:  |-
+            {{ .Values.service_name }}
         - name: GRAPHQL_ENDPOINT
           value: |-
             {{ .Values.gqlEndpoint }}

package.json

@@ -16,6 +16,15 @@
     "@graphql-codegen/client-preset": "^1.1.4",
     "@types/jsforce": "^1.11.0",
     "@types/node": "^18.11.9",
+    "@opentelemetry/api": "1.7.0",
+    "@opentelemetry/auto-instrumentations-node": "^0.48.0",
+    "@opentelemetry/exporter-trace-otlp-http": "^0.45.0",
+    "@opentelemetry/instrumentation-express": "^0.41.1",
+    "@opentelemetry/instrumentation-http": "^0.57.0",
+    "@opentelemetry/instrumentation-nestjs-core": "^0.39.0",
+    "@opentelemetry/instrumentation-pino": "^0.41.0",
+    "@opentelemetry/sdk-node": "^0.45.0",
+    "pino-opentelemetry-transport": "^1.0.1",
     "nodemon": "^2.0.20",
     "rimraf": "^3.0.2",
     "ts-node": "^10.9.1"

src/index.ts

@@ -1,11 +1,13 @@
 import createApp from '@/app';
 import config from '@/config';
 import createLogger from '@/utils/logger';
+import tracer from "./tracer";
 
 const logger = createLogger("Index");
 logger.info(`Logging set to ${config.logLevel} mode`);
 
 const startApp = async () => {
+  await tracer.start();
   const app = await createApp(config);
 
   await app.start();

src/tracer.ts

@@ -0,0 +1,49 @@
+'use strict';
+
+import { getNodeAutoInstrumentations } from '@opentelemetry/auto-instrumentations-node';
+import { OTLPTraceExporter } from '@opentelemetry/exporter-trace-otlp-http';
+import { ExpressInstrumentation } from '@opentelemetry/instrumentation-express';
+import { HttpInstrumentation } from '@opentelemetry/instrumentation-http';
+import { NestInstrumentation } from '@opentelemetry/instrumentation-nestjs-core';
+import { PinoInstrumentation } from '@opentelemetry/instrumentation-pino';
+import { Resource } from '@opentelemetry/resources';
+import * as opentelemetry from '@opentelemetry/sdk-node';
+import { SemanticResourceAttributes } from '@opentelemetry/semantic-conventions';
+
+// Configure the SDK to export telemetry data to the console
+// Enable all auto-instrumentations from the meta package
+const exporterOptions = {
+  url: 'http://otelcollector.dmp.cnna.io/v1/traces',
+};
+// http://localhost:4318/v1/traces
+
+const traceExporter = new OTLPTraceExporter(exporterOptions);
+const sdk = new opentelemetry.NodeSDK({
+  traceExporter,
+  instrumentations: [
+    getNodeAutoInstrumentations(),
+    new NestInstrumentation(),
+    new PinoInstrumentation(),
+    new HttpInstrumentation(),
+    new ExpressInstrumentation(),
+  ],
+  resource: new Resource({
+    [SemanticResourceAttributes.SERVICE_NAME]: 'salesforce-automation',
+    [SemanticResourceAttributes.DEPLOYMENT_ENVIRONMENT]: process.env.NODE_ENV || 'local',
+  }),
+});
+
+// initialize the SDK and register with the OpenTelemetry API
+// this enables the API to record telemetry
+sdk.start();
+
+// gracefully shut down the SDK on process exit
+process.on("SIGTERM", () => {
+  sdk
+    .shutdown()
+    .then(() => console.log("Tracing terminated"))
+    .catch((error) => console.log("Error terminating tracing", error))
+    .finally(() => process.exit(0));
+});
+
+export default sdk;