diff --git a/src/BitLogger_test.mbt b/src/BitLogger_test.mbt index 80719bd..951e4f8 100644 --- a/src/BitLogger_test.mbt +++ b/src/BitLogger_test.mbt @@ -1647,6 +1647,118 @@ test "configured logger file flush and close stay aligned with runtime sink help inspect(console_logger.file_close() == console_sink.file_close(), content="true") } +test "configured logger file state helpers stay aligned with runtime sink helpers" { + let file_logger = build_logger( + LoggerConfig::new( + target="config.file.state.delegate", + sink=SinkConfig::new(kind=SinkKind::File, path="config-file-state-delegate.log"), + ), + ) + let file_sink = file_logger.sink + let file_state = file_logger.file_state() + let file_sink_state = file_sink.file_state() + + inspect(file_state.path == file_sink_state.path, content="true") + inspect(file_state.available == file_sink_state.available, content="true") + inspect(file_state.append == file_sink_state.append, content="true") + inspect(file_state.auto_flush == file_sink_state.auto_flush, content="true") + inspect(file_state.open_failures == file_sink_state.open_failures, content="true") + inspect(file_state.write_failures == file_sink_state.write_failures, content="true") + inspect(file_state.flush_failures == file_sink_state.flush_failures, content="true") + inspect(file_state.rotation_failures == file_sink_state.rotation_failures, content="true") + inspect(match file_state.rotation { + Some(rotation) => match file_sink_state.rotation { + Some(other) => rotation.max_bytes == other.max_bytes && rotation.max_backups == other.max_backups + None => false + } + None => file_sink_state.rotation is None + }, content="true") + inspect( + (file_logger.file_runtime_state() is None) == (file_sink.file_runtime_state() is None), + content="true", + ) + + let queued_logger = build_logger( + LoggerConfig::new( + target="config.file.runtime.delegate", + sink=SinkConfig::new(kind=SinkKind::File, path="config-file-runtime-delegate.log"), + queue=Some(QueueConfig::new(4, overflow=QueueOverflowPolicy::DropNewest)), + ), + ) + let queued_sink = queued_logger.sink + queued_logger.info("one") + queued_logger.info("two") + let queued_state = queued_logger.file_state() + let queued_sink_state = queued_sink.file_state() + + inspect(queued_state.path == queued_sink_state.path, content="true") + inspect(queued_state.available == queued_sink_state.available, content="true") + inspect(queued_state.append == queued_sink_state.append, content="true") + inspect(queued_state.auto_flush == queued_sink_state.auto_flush, content="true") + inspect(queued_state.open_failures == queued_sink_state.open_failures, content="true") + inspect(queued_state.write_failures == queued_sink_state.write_failures, content="true") + inspect(queued_state.flush_failures == queued_sink_state.flush_failures, content="true") + inspect(queued_state.rotation_failures == queued_sink_state.rotation_failures, content="true") + inspect(match queued_state.rotation { + Some(rotation) => match queued_sink_state.rotation { + Some(other) => rotation.max_bytes == other.max_bytes && rotation.max_backups == other.max_backups + None => false + } + None => queued_sink_state.rotation is None + }, content="true") + + match (queued_logger.file_runtime_state(), queued_sink.file_runtime_state()) { + (Some(snapshot), Some(sink_snapshot)) => { + inspect(snapshot.file.path == sink_snapshot.file.path, content="true") + inspect(snapshot.file.available == sink_snapshot.file.available, content="true") + inspect(snapshot.file.append == sink_snapshot.file.append, content="true") + inspect(snapshot.file.auto_flush == sink_snapshot.file.auto_flush, content="true") + inspect(snapshot.file.open_failures == sink_snapshot.file.open_failures, content="true") + inspect(snapshot.file.write_failures == sink_snapshot.file.write_failures, content="true") + inspect(snapshot.file.flush_failures == sink_snapshot.file.flush_failures, content="true") + inspect(snapshot.file.rotation_failures == sink_snapshot.file.rotation_failures, content="true") + inspect(snapshot.queued == sink_snapshot.queued, content="true") + inspect(snapshot.pending_count == sink_snapshot.pending_count, content="true") + inspect(snapshot.dropped_count == sink_snapshot.dropped_count, content="true") + inspect(match snapshot.file.rotation { + Some(rotation) => match sink_snapshot.file.rotation { + Some(other) => rotation.max_bytes == other.max_bytes && rotation.max_backups == other.max_backups + None => false + } + None => sink_snapshot.file.rotation is None + }, content="true") + } + _ => inspect(false, content="true") + } + + let console_logger = build_logger( + LoggerConfig::new( + target="config.file.state.console", + sink=SinkConfig::new(kind=SinkKind::Console), + ), + ) + let console_sink = console_logger.sink + let console_state = console_logger.file_state() + let console_sink_state = console_sink.file_state() + + inspect(console_state.path == console_sink_state.path, content="true") + inspect(console_state.available == console_sink_state.available, content="true") + inspect(console_state.append == console_sink_state.append, content="true") + inspect(console_state.auto_flush == console_sink_state.auto_flush, content="true") + inspect(console_state.open_failures == console_sink_state.open_failures, content="true") + inspect(console_state.write_failures == console_sink_state.write_failures, content="true") + inspect(console_state.flush_failures == console_sink_state.flush_failures, content="true") + inspect(console_state.rotation_failures == console_sink_state.rotation_failures, content="true") + inspect((console_state.rotation is None) == (console_sink_state.rotation is None), content="true") + inspect( + (console_logger.file_runtime_state() is None) == (console_sink.file_runtime_state() is None), + content="true", + ) + + ignore(file_logger.close()) + ignore(queued_logger.close()) +} + test "configured queued file logger flushes queue through file helper" { let logger = build_logger( LoggerConfig::new(