chore: Export LoggerSinks from @temporalio/workflow (#889)

Author: lorensr

packages/common/src/failure.ts

@@ -1,5 +1,4 @@
 import type { temporal } from '@temporalio/proto';
-import { PayloadConverter } from './converter/payload-converter';
 import { checkExtends, isRecord } from './type-helpers';
 
 export const FAILURE_SOURCE = 'TypeScriptSDK';

packages/worker/src/index.ts

@@ -18,6 +18,7 @@ export {
   TelemetryOptions,
   TraceExporter,
 } from '@temporalio/core-bridge';
+export { LoggerSinks } from '@temporalio/workflow';
 export { ActivityInboundLogInterceptor, activityLogAttributes } from './activity-log-interceptor';
 export { NativeConnection as NativeConnection } from './connection';
 export { NativeConnectionOptions, RequiredNativeConnectionOptions, TLSConfig } from './connection-options';
@@ -39,5 +40,5 @@ export {
   WorkflowBundlePath,
   WorkflowBundlePathWithSourceMap, // eslint-disable-line deprecation/deprecation
 } from './worker-options';
-export { LoggerSinks, WorkflowInboundLogInterceptor, workflowLogAttributes } from './workflow-log-interceptor';
+export { WorkflowInboundLogInterceptor, workflowLogAttributes } from './workflow-log-interceptor';
 export { BundleOptions, bundleWorkflowCode, WorkflowBundleWithSourceMap } from './workflow/bundler';

packages/worker/src/worker-options.ts

@@ -1,17 +1,16 @@
-import { DataConverter, LoadedDataConverter } from '@temporalio/common';
+import { DataConverter, LoadedDataConverter, msToNumber } from '@temporalio/common';
 import { loadDataConverter } from '@temporalio/common/lib/internal-non-workflow';
-import { msToNumber } from '@temporalio/common';
+import { LoggerSinks } from '@temporalio/workflow';
+import * as os from 'os';
+import * as v8 from 'v8';
 import type { Configuration as WebpackConfiguration } from 'webpack';
 import { ActivityInboundLogInterceptor } from './activity-log-interceptor';
 import { NativeConnection } from './connection';
 import { WorkerInterceptors } from './interceptors';
 import { Runtime } from './runtime';
 import { InjectedSinks } from './sinks';
 import { GiB } from './utils';
-import { LoggerSinks } from './workflow-log-interceptor';
 import { WorkflowBundleWithSourceMap } from './workflow/bundler';
-import * as v8 from 'v8';
-import * as os from 'os';
 
 export type { WebpackConfiguration };
 

packages/worker/src/workflow-log-interceptor.ts

@@ -1,29 +1,16 @@
 import {
-  WorkflowInboundCallsInterceptor,
-  WorkflowExecuteInput,
+  isCancellation,
+  LoggerSinks,
   Next,
+  proxySinks,
+  WorkflowExecuteInput,
+  WorkflowInboundCallsInterceptor,
   workflowInfo,
   WorkflowInfo,
-  isCancellation,
-  proxySinks,
-  Sinks,
   WorkflowInterceptorsFactory,
 } from '@temporalio/workflow';
 import { untrackPromise } from '@temporalio/workflow/lib/stack-helpers';
 
-/**
- * Sink interface for forwarding logs from the Workflow sandbox to the Worker
- */
-export interface LoggerSinks extends Sinks {
-  defaultWorkerLogger: {
-    trace(message: string, attrs: Record<string, unknown>): void;
-    debug(message: string, attrs: Record<string, unknown>): void;
-    info(message: string, attrs: Record<string, unknown>): void;
-    warn(message: string, attrs: Record<string, unknown>): void;
-    error(message: string, attrs: Record<string, unknown>): void;
-  };
-}
-
 /**
  * Returns a map of attributes to be set on log messages for a given Workflow
  */

packages/workflow/src/index.ts

@@ -86,7 +86,7 @@ export {
   EnhancedStackTrace,
   SDKInfo,
 } from './interfaces';
-export { Sink, SinkCall, SinkFunction, Sinks } from './sinks';
+export { LoggerSinks, Sink, SinkCall, SinkFunction, Sinks } from './sinks';
 export { Trigger } from './trigger';
 export * from './workflow';
 export { ChildWorkflowHandle, ExternalWorkflowHandle } from './workflow-handle';

packages/workflow/src/sinks.ts

@@ -39,3 +39,16 @@ export interface SinkCall {
   fnName: string;
   args: any[];
 }
+
+/**
+ * Sink interface for forwarding logs from the Workflow sandbox to the Worker
+ */
+export interface LoggerSinks extends Sinks {
+  defaultWorkerLogger: {
+    trace(message: string, attrs: Record<string, unknown>): void;
+    debug(message: string, attrs: Record<string, unknown>): void;
+    info(message: string, attrs: Record<string, unknown>): void;
+    warn(message: string, attrs: Record<string, unknown>): void;
+    error(message: string, attrs: Record<string, unknown>): void;
+  };
+}