refactor(logging): enhance error handling and logging in main worker

- Introduced `DefaultLogger` for consistent error logging in the main worker script.
- Updated `handleRunError` to utilize the logger for error messages and added a delay before exiting the process.
- Refactored the `run` function to simplify its return statement.
- Enhanced unit tests to verify the new logging behavior and ensure proper process exit.

These changes improve the clarity and reliability of error handling in the application, ensuring that errors are logged consistently and the process exits gracefully.

Author: anatolyshipitz

workers/main/src/__tests__/index.test.ts

@@ -1,7 +1,7 @@
 import { describe, expect, it } from 'vitest';
 import { vi } from 'vitest';
 
-import { handleRunError, run } from '../index';
+import { handleRunError, logger, run } from '../index';
 
 describe('run', () => {
   it('should return true', async () => {
@@ -11,22 +11,29 @@ describe('run', () => {
 
 describe('handleRunError', () => {
   it('should log error and exit process', () => {
+    vi.useFakeTimers();
     const error = new Error('test error');
-    const consoleErrorSpy = vi
-      .spyOn(console, 'error')
+    const loggerErrorSpy = vi
+      .spyOn(logger, 'error')
       .mockImplementation(() => {});
     const processExitSpy = vi.spyOn(process, 'exit').mockImplementation(() => {
       throw new Error('exit');
     });
 
-    expect(() => handleRunError(error)).toThrow('exit');
-    expect(consoleErrorSpy).toHaveBeenCalledWith(
-      'Unhandled error in main:',
-      error,
+    expect(() => handleRunError(error)).toThrow(error);
+    expect(loggerErrorSpy).toHaveBeenCalledWith(
+      `Unhandled error in main: ${error.message}`,
     );
+    // Таймер еще не сработал
+    expect(processExitSpy).not.toHaveBeenCalled();
+    // Прокручиваем таймеры
+    expect(() => {
+      vi.runAllTimers();
+    }).toThrow('exit');
     expect(processExitSpy).toHaveBeenCalledWith(1);
 
-    consoleErrorSpy.mockRestore();
+    loggerErrorSpy.mockRestore();
     processExitSpy.mockRestore();
+    vi.useRealTimers();
   });
 });

workers/main/src/index.ts

@@ -1,14 +1,19 @@
+import { DefaultLogger } from '@temporalio/worker';
+
+export const logger = new DefaultLogger('ERROR');
+
 /**
  * Executes the main worker process.
  * @returns {Promise<boolean>} Returns true when the worker completes successfully.
  */
-export async function run() {
-  return await Promise.resolve(true);
+export async function run(): Promise<boolean> {
+  return true;
 }
 
-export function handleRunError(err: unknown) {
-  console.error('Unhandled error in main:', err);
-  process.exit(1);
+export function handleRunError(err: Error): never {
+  logger.error(`Unhandled error in main: ${err.message}`);
+  setTimeout(() => process.exit(1), 100);
+  throw err;
 }
 
 run().catch(handleRunError);