Context building slog sender

packages/telemetry/src/context-aware-slog-file.js

@@ -28,8 +28,12 @@ export const makeSlogSender = async options => {
   /**
    * @param {import('./context-aware-slog.js').Slog} slog
    */
-  const slogSender = slog =>
-    stream.write(`${serializeSlogObj(contextualSlogProcessor(slog))}\n`);
+  const slogSender = slog => {
+    const contextualizedSlog = contextualSlogProcessor(slog);
+
+    // eslint-disable-next-line prefer-template
+    stream.write(serializeSlogObj(contextualizedSlog) + '\n').catch(() => {});
+  };
 
   return Object.assign(slogSender, {
     forceFlush: () => stream.flush(),

packages/telemetry/src/otel-context-aware-slog.js

@@ -59,9 +59,9 @@ export const makeSlogSender = async options => {
   const loggerProvider = new LoggerProvider({
     resource: new Resource(getResourceAttributes(options)),
   });
-  const logRecordProcessor = new SimpleLogRecordProcessor(
-    new OTLPLogExporter({ keepAlive: true }),
-  );
+
+  const otelLogExporter = new OTLPLogExporter({ keepAlive: true });
+  const logRecordProcessor = new SimpleLogRecordProcessor(otelLogExporter);
 
   loggerProvider.addLogRecordProcessor(logRecordProcessor);
 
@@ -91,16 +91,28 @@ export const makeSlogSender = async options => {
       10,
     );
 
-    return logger.emit({
+    logger.emit({
       ...JSON.parse(serializeSlogObj(logRecord)),
       severityNumber: SeverityNumber.INFO,
       timestamp: [seconds, nanoSeconds],
     });
   };
 
   return Object.assign(slogSender, {
-    forceFlush: () => logRecordProcessor.forceFlush(),
+    forceFlush: otelLogExporter.forceFlush,
     shutdown: () =>
-      logRecordProcessor.forceFlush().then(logRecordProcessor.shutdown),
+      logRecordProcessor
+        .shutdown()
+        .then(otelLogExporter.forceFlush, shutdownError =>
+          otelLogExporter.forceFlush().then(
+            () => Promise.reject(shutdownError),
+            flushError =>
+              Promise.reject(AggregateError([shutdownError, flushError])),
+          ),
+        )
+        .then(
+          () => {},
+          flushError => Promise.reject(flushError),
+        ),
   });
 };