Log streams (#123)

eslint.config.mjs

@@ -82,21 +82,7 @@ export default [
       "@typescript-eslint/unbound-method": "error",
       "import/no-extraneous-dependencies": ["error", { packageDir: "./" }],
       "sonarjs/prefer-immediate-return": "off",
-      "unicorn/prevent-abbreviations": [
-        "error",
-        {
-          replacements: {
-            docs: false,
-            e: false,
-            dir: false,
-            i: false,
-            params: false,
-            props: false,
-            ref: false,
-            temp: false,
-          },
-        },
-      ],
+      "unicorn/prevent-abbreviations": "off",
       "no-case-declarations": "off",
       "no-async-promise-executor": "off",
       "unicorn/prefer-node-protocol": "off",

package.json

@@ -5,7 +5,7 @@
   "repository": {
     "url": "git+https://github.com/Digital-Alchemy-TS/core"
   },
-  "version": "24.11.3",
+  "version": "24.11.4",
   "author": {
     "url": "https://github.com/zoe-codez",
     "name": "Zoe Codez"
@@ -66,7 +66,7 @@
     "@types/ini": "^4.1.1",
     "@types/js-yaml": "^4.0.9",
     "@types/minimist": "^1.2.5",
-    "@types/node": "^22.9.1",
+    "@types/node": "^22.9.3",
     "@types/node-cron": "^3.0.11",
     "@types/sinonjs__fake-timers": "^8.1.5",
     "@typescript-eslint/eslint-plugin": "8.15.0",
@@ -92,8 +92,8 @@
     "prettier": "^3.3.3",
     "tslib": "^2.8.1",
     "tsx": "^4.19.2",
-    "type-fest": "^4.27.0",
-    "typescript": "^5.7.0-beta",
+    "type-fest": "^4.28.0",
+    "typescript": "^5.7.2",
     "uuid": "^11.0.3",
     "vitest": "^2.1.5"
   },

src/helpers/logger.mts

@@ -1,6 +1,21 @@
+import { Get } from "type-fest";
+
 import { TContext } from "./context.mts";
+import { TBlackHole } from "./utilities.mts";
+
+// eslint-disable-next-line @typescript-eslint/no-empty-object-type
+export interface ReplacementLogger {
+  // intentionally left empty
+  // for use with declaration merging
+}
+
+export type GetLogger =
+  Get<ReplacementLogger, "logger"> extends object ? Get<ReplacementLogger, "logger"> : ILogger;
+
+export type LogStreamTarget = (message: string, data: object) => TBlackHole;
 
 export type DigitalAlchemyLogger = {
+  addTarget: (logger: GetLogger | LogStreamTarget) => void;
   /**
    * Create a new logger instance for a given context
    */
@@ -9,7 +24,7 @@ export type DigitalAlchemyLogger = {
    * Retrieve a reference to the base logger used to emit from
    */
   getBaseLogger: () => Record<
-    keyof ILogger,
+    keyof GetLogger,
     (context: TContext, ...data: Parameters<TLoggerFunction>) => void
   >;
   getPrettyFormat: () => boolean;
@@ -22,23 +37,19 @@ export type DigitalAlchemyLogger = {
    *
    * Note: Extension still handles LOG_LEVEL logic
    */
-  setBaseLogger: (base: ILogger) => ILogger;
+  setBaseLogger: (base: GetLogger) => GetLogger;
   /**
    * Set the enabled/disabled state of the message pretty formatting logic
    */
   setPrettyFormat: (state: boolean) => boolean;
   /**
    * Logger instance of last resort
    */
-  systemLogger: ILogger;
+  systemLogger: GetLogger;
   /**
    * exposed for testing
    */
   updateShouldLog: () => void;
-  /**
-   * If set, logs will be converted to json & sent to target
-   */
-  setHttpLogs: (url: string) => void;
 };
 
 export type TLoggerFunction =

src/helpers/wiring.mts

@@ -18,7 +18,7 @@ import { TContext } from "./context.mts";
 import { CronExpression, ScheduleRemove } from "./cron.mts";
 import { BootstrapException } from "./errors.mts";
 import { TLifecycleBase } from "./lifecycle.mts";
-import { ILogger, TConfigLogLevel } from "./logger.mts";
+import { GetLogger, TConfigLogLevel } from "./logger.mts";
 import { TBlackHole } from "./utilities.mts";
 
 export type TServiceReturn<OBJECT extends object = object> = void | OBJECT;
@@ -142,7 +142,14 @@ export type TInjectedConfig = {
 // #region Special
 // SEE DOCS http://docs.digital-alchemy.app/docs/core/declaration-merging
 export interface AsyncLogData {
-  logger?: ILogger;
+  /**
+   * return ms since entry, precision is on you
+   */
+  duration?: () => number;
+  /**
+   * thread local child logger
+   */
+  logger?: GetLogger;
 }
 
 export interface AsyncLocalData {
@@ -188,7 +195,7 @@ export type TServiceParams = {
   /**
    * context aware logger instance
    */
-  logger: ILogger;
+  logger: GetLogger;
   /**
    * run commands on intervals & schedules
    *
@@ -355,7 +362,7 @@ export type BootstrapOptions = {
   /**
    * use this logger, instead of the baked in one. Maybe you want some custom transports or something? Put your customized thing here
    */
-  customLogger?: ILogger;
+  customLogger?: GetLogger;
 
   /**
    * fine tine the built in logger
@@ -429,6 +436,13 @@ export type LoggerOptions = {
    * Override the `LOG_LEVEL` per service or module
    */
   levelOverrides?: Partial<Record<LoadedModuleNames | FlatServiceNames, TConfigLogLevel>>;
+
+  /**
+   * default: true (unless a replacement logger is provided)
+   *
+   * emit logs to stdout
+   */
+  stdOut?: boolean;
 };
 
 export const WIRE_PROJECT = Symbol.for("wire-project");
@@ -467,7 +481,7 @@ export type ApplicationDefinition<
   C extends OptionalModuleConfiguration,
 > = ApplicationConfigurationOptions<S, C> &
   Wire & {
-    logger: ILogger;
+    logger: GetLogger;
     type: "application";
     booted: boolean;
     bootstrap: (options?: BootstrapOptions) => Promise<TServiceParams>;
@@ -478,7 +492,7 @@ export type TLibrary = LibraryDefinition<ServiceMap, OptionalModuleConfiguration
 // #MARK: buildSortOrder
 export function buildSortOrder<S extends ServiceMap, C extends OptionalModuleConfiguration>(
   app: ApplicationDefinition<S, C>,
-  logger: ILogger,
+  logger: GetLogger,
 ) {
   if (is.empty(app.libraries)) {
     return [];