mirror of
https://github.com/Nanaloveyuki/BitLogger.git
synced 2026-07-24 00:42:18 +00:00
✅ cover application async target behavior
This commit is contained in:
Nanaloveyuki
@@ -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(
|
||||
|
||||
Reference in New Issue
Block a user