diff --git a/src-async/BitLoggerAsync_test.mbt b/src-async/BitLoggerAsync_test.mbt index 560a9b6..af321ce 100644 --- a/src-async/BitLoggerAsync_test.mbt +++ b/src-async/BitLoggerAsync_test.mbt @@ -2604,6 +2604,129 @@ async test "application async logger keeps broader async composition surface" { inspect(logger.last_error(), content="") } +async test "application async logger log supports per-call target override" { + let written_target : Ref[String] = Ref("") + let written_message : Ref[String] = Ref("") + let written_fields : Ref[Array[@bitlogger.Field]] = Ref([]) + let logger : ApplicationAsyncLogger = build_application_async_logger( + AsyncLoggerBuildConfig::new( + logger=@bitlogger.LoggerConfig::new( + min_level=@bitlogger.Level::Warn, + target="async.app.default", + sink=@bitlogger.SinkConfig::new(kind=@bitlogger.SinkKind::Console), + ), + async_config=AsyncLoggerConfig::new(max_pending=4), + ), + ) + .with_context_fields([@bitlogger.field("service", "bitlogger")]) + .with_patch(fn(rec) { + written_target.val = rec.target + written_message.val = rec.message + written_fields.val = rec.fields + rec + }) + + @async.with_task_group(group => { + group.spawn_bg(() => logger.run()) + logger.log( + @bitlogger.Level::Error, + "override", + fields=[@bitlogger.field("mode", "test")], + target="async.app.override", + ) + logger.shutdown() + }) + + inspect(written_target.val, content="async.app.override") + inspect(written_message.val, content="override") + inspect(written_fields.val.length(), content="2") + inspect(written_fields.val[0].key, content="service") + inspect(written_fields.val[0].value, content="bitlogger") + inspect(written_fields.val[1].key, content="mode") + inspect(written_fields.val[1].value, content="test") + + let second_target : Ref[String] = Ref("") + let second_message : Ref[String] = Ref("") + let second_fields : Ref[Array[@bitlogger.Field]] = Ref([]) + let second : ApplicationAsyncLogger = build_application_async_logger( + AsyncLoggerBuildConfig::new( + logger=@bitlogger.LoggerConfig::new( + min_level=@bitlogger.Level::Warn, + target="async.app.default", + sink=@bitlogger.SinkConfig::new(kind=@bitlogger.SinkKind::Console), + ), + async_config=AsyncLoggerConfig::new(max_pending=4), + ), + ) + .with_context_fields([@bitlogger.field("service", "bitlogger")]) + .with_patch(fn(rec) { + second_target.val = rec.target + second_message.val = rec.message + second_fields.val = rec.fields + rec + }) + + @async.with_task_group(group => { + group.spawn_bg(() => second.run()) + second.log(@bitlogger.Level::Error, "default") + second.shutdown() + }) + + inspect(second_target.val, content="async.app.default") + inspect(second_message.val, content="default") + inspect(second_fields.val.length(), content="1") + inspect(second_fields.val[0].key, content="service") +} + +async test "application async logger severity helpers use stored target without override" { + let written_levels : Ref[Array[String]] = Ref([]) + let written_targets : Ref[Array[String]] = Ref([]) + let written_fields : Ref[Array[Array[@bitlogger.Field]]] = Ref([]) + let logger : ApplicationAsyncLogger = build_application_async_logger( + AsyncLoggerBuildConfig::new( + logger=@bitlogger.LoggerConfig::new( + min_level=@bitlogger.Level::Info, + target="async.app.helpers", + sink=@bitlogger.SinkConfig::new(kind=@bitlogger.SinkKind::Console), + ), + async_config=AsyncLoggerConfig::new(max_pending=4), + ), + ) + .with_context_fields([@bitlogger.field("service", "bitlogger")]) + .with_patch(fn(rec) { + written_levels.val.push(rec.level.label()) + written_targets.val.push(rec.target) + written_fields.val.push(rec.fields) + rec + }) + + @async.with_task_group(group => { + group.spawn_bg(() => logger.run()) + logger.info("info", fields=[@bitlogger.field("mode", "info")]) + logger.warn("warn", fields=[@bitlogger.field("mode", "warn")]) + logger.error("error", fields=[@bitlogger.field("mode", "error")]) + logger.shutdown() + }) + + inspect(written_levels.val.length(), content="3") + inspect(written_levels.val[0], content="INFO") + inspect(written_levels.val[1], content="WARN") + inspect(written_levels.val[2], content="ERROR") + inspect(written_targets.val.length(), content="3") + inspect(written_targets.val[0], content="async.app.helpers") + inspect(written_targets.val[1], content="async.app.helpers") + inspect(written_targets.val[2], content="async.app.helpers") + inspect(written_fields.val[0].length(), content="2") + inspect(written_fields.val[1].length(), content="2") + inspect(written_fields.val[2].length(), content="2") + inspect(written_fields.val[0][0].key, content="service") + inspect(written_fields.val[0][1].value, content="info") + inspect(written_fields.val[1][0].key, content="service") + inspect(written_fields.val[1][1].value, content="warn") + inspect(written_fields.val[2][0].key, content="service") + inspect(written_fields.val[2][1].value, content="error") +} + test "application async logger builder preserves sync queue-backed runtime sink" { let logger = build_application_async_logger( AsyncLoggerBuildConfig::new( @@ -2829,6 +2952,129 @@ async test "application text async logger keeps broader async composition surfac inspect(logger.last_error(), content="") } +async test "application text async logger log supports per-call target override" { + let written_target : Ref[String] = Ref("") + let written_message : Ref[String] = Ref("") + let written_fields : Ref[Array[@bitlogger.Field]] = Ref([]) + let logger : ApplicationTextAsyncLogger = build_application_text_async_logger( + AsyncLoggerBuildConfig::new( + logger=@bitlogger.text_console( + min_level=@bitlogger.Level::Warn, + target="async.app.text.default", + text_formatter=@bitlogger.TextFormatterConfig::new(show_timestamp=false, separator=" | "), + ), + async_config=AsyncLoggerConfig::new(max_pending=4), + ), + ) + .with_context_fields([@bitlogger.field("service", "bitlogger")]) + .with_patch(fn(rec) { + written_target.val = rec.target + written_message.val = rec.message + written_fields.val = rec.fields + rec + }) + + @async.with_task_group(group => { + group.spawn_bg(() => logger.run()) + logger.log( + @bitlogger.Level::Error, + "override", + fields=[@bitlogger.field("mode", "test")], + target="async.app.text.override", + ) + logger.shutdown() + }) + + inspect(written_target.val, content="async.app.text.override") + inspect(written_message.val, content="override") + inspect(written_fields.val.length(), content="2") + inspect(written_fields.val[0].key, content="service") + inspect(written_fields.val[0].value, content="bitlogger") + inspect(written_fields.val[1].key, content="mode") + inspect(written_fields.val[1].value, content="test") + + let second_target : Ref[String] = Ref("") + let second_message : Ref[String] = Ref("") + let second_fields : Ref[Array[@bitlogger.Field]] = Ref([]) + let second : ApplicationTextAsyncLogger = build_application_text_async_logger( + AsyncLoggerBuildConfig::new( + logger=@bitlogger.text_console( + min_level=@bitlogger.Level::Warn, + target="async.app.text.default", + text_formatter=@bitlogger.TextFormatterConfig::new(show_timestamp=false, separator=" | "), + ), + async_config=AsyncLoggerConfig::new(max_pending=4), + ), + ) + .with_context_fields([@bitlogger.field("service", "bitlogger")]) + .with_patch(fn(rec) { + second_target.val = rec.target + second_message.val = rec.message + second_fields.val = rec.fields + rec + }) + + @async.with_task_group(group => { + group.spawn_bg(() => second.run()) + second.log(@bitlogger.Level::Error, "default") + second.shutdown() + }) + + inspect(second_target.val, content="async.app.text.default") + inspect(second_message.val, content="default") + inspect(second_fields.val.length(), content="1") + inspect(second_fields.val[0].key, content="service") +} + +async test "application text async logger severity helpers use stored target without override" { + let written_levels : Ref[Array[String]] = Ref([]) + let written_targets : Ref[Array[String]] = Ref([]) + let written_fields : Ref[Array[Array[@bitlogger.Field]]] = Ref([]) + let logger : ApplicationTextAsyncLogger = build_application_text_async_logger( + AsyncLoggerBuildConfig::new( + logger=@bitlogger.text_console( + min_level=@bitlogger.Level::Info, + target="async.app.text.helpers", + text_formatter=@bitlogger.TextFormatterConfig::new(show_timestamp=false, separator=" | "), + ), + async_config=AsyncLoggerConfig::new(max_pending=4), + ), + ) + .with_context_fields([@bitlogger.field("service", "bitlogger")]) + .with_patch(fn(rec) { + written_levels.val.push(rec.level.label()) + written_targets.val.push(rec.target) + written_fields.val.push(rec.fields) + rec + }) + + @async.with_task_group(group => { + group.spawn_bg(() => logger.run()) + logger.info("info", fields=[@bitlogger.field("mode", "info")]) + logger.warn("warn", fields=[@bitlogger.field("mode", "warn")]) + logger.error("error", fields=[@bitlogger.field("mode", "error")]) + logger.shutdown() + }) + + inspect(written_levels.val.length(), content="3") + inspect(written_levels.val[0], content="INFO") + inspect(written_levels.val[1], content="WARN") + inspect(written_levels.val[2], content="ERROR") + inspect(written_targets.val.length(), content="3") + inspect(written_targets.val[0], content="async.app.text.helpers") + inspect(written_targets.val[1], content="async.app.text.helpers") + inspect(written_targets.val[2], content="async.app.text.helpers") + inspect(written_fields.val[0].length(), content="2") + inspect(written_fields.val[1].length(), content="2") + inspect(written_fields.val[2].length(), content="2") + inspect(written_fields.val[0][0].key, content="service") + inspect(written_fields.val[0][1].value, content="info") + inspect(written_fields.val[1][0].key, content="service") + inspect(written_fields.val[1][1].value, content="warn") + inspect(written_fields.val[2][0].key, content="service") + inspect(written_fields.val[2][1].value, content="error") +} + test "application text async logger builder ignores sync queue layer" { let logger = build_application_text_async_logger( AsyncLoggerBuildConfig::new(