log-sink-tester.ts

/**
 * Workflow used in test-sinks.ts to verify sink replay behavior
 *
 * Also tests workflow.taskInfo()
 * @module
 */

import * as wf from '@temporalio/workflow';
// @@@SNIPSTART typescript-logger-sink-interface
import type { Sinks } from '@temporalio/workflow';

export interface CustomLoggerSinks extends Sinks {
  customLogger: {
    info(message: string): void;
  };
}
// @@@SNIPEND

const { customLogger } = wf.proxySinks<CustomLoggerSinks>();

export async function logSinkTester(): Promise<void> {
  customLogger.info(
    `Workflow execution started, replaying: ${wf.workflowInfo().unsafe.isReplaying}, hl: ${
      wf.workflowInfo().historyLength
    }`
  );
  // We rely on this test to run with workflow cache disabled. This sleep()
  // therefore ends the current WFT, evicting the workflow from cache, and thus
  // causing replay of the first sink call.
  await wf.sleep(1);
  customLogger.info(
    `Workflow execution completed, replaying: ${wf.workflowInfo().unsafe.isReplaying}, hl: ${
      wf.workflowInfo().historyLength
    }`
  );
}

// eslint-disable-next-line deprecation/deprecation
const { defaultWorkerLogger } = wf.proxySinks<wf.LoggerSinks>();

export async function useDepreatedLoggerSinkWorkflow(): Promise<void> {
  defaultWorkerLogger.info('Log message from workflow', { workflowId: wf.workflowInfo().workflowId });
}