Function write_logs

crates/core/src/database_logger.rs:694–712

(logger: Arc<DatabaseLogger>, r: Range<usize>)

    use super::{DatabaseLogger, LogLevel, Record};

    async fn write_logs(logger: Arc<DatabaseLogger>, r: Range<usize>) {
        asyncify(move || {
            for i in r {
                logger.write(
                    LogLevel::Info,
                    &Record {
                        ts: chrono::Utc::now(),
                        target: None,
                        filename: None,
                        line_number: None,
                        function: None,
                        message: &format!("log line {i}"),
                    },
                    &(),
                );
            }
        })
        .await
    }

    fn deserialize_logs<'a>(raw: &'a [u8]) -> Result<Vec<Record<'a>>, serde_json::Error> {
        serde_json::StreamDeserializer::new(serde_json::de::SliceRead::new(raw)).collect()