From 081db23438ef6059b16dd12b4e3b926a522f2125 Mon Sep 17 00:00:00 2001
From: Tglman <tglman@tglman.com>
Date: Fri, 30 Jul 2021 22:24:56 +0100
Subject: [PATCH] updated persy implementation for use tracing

---
 Cargo.lock                        | 11 +++++++++++
 src/database/abstraction/persy.rs |  8 +++++---
 2 files changed, 16 insertions(+), 3 deletions(-)

diff --git a/Cargo.lock b/Cargo.lock
index 9118d1a..43d9857 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -246,6 +246,7 @@ version = "0.1.0"
 dependencies = [
  "base64 0.13.0",
  "bytes",
+ "chrono",
  "crossbeam",
  "directories",
  "heed",
@@ -275,6 +276,7 @@ dependencies = [
  "sled",
  "thiserror",
  "threadpool",
+ "timer",
  "tokio",
  "tracing",
  "tracing-flame",
@@ -2934,6 +2936,15 @@ dependencies = [
  "syn",
 ]
 
+[[package]]
+name = "timer"
+version = "0.2.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "31d42176308937165701f50638db1c31586f183f1aab416268216577aec7306b"
+dependencies = [
+ "chrono",
+]
+
 [[package]]
 name = "tinyvec"
 version = "1.3.1"
diff --git a/src/database/abstraction/persy.rs b/src/database/abstraction/persy.rs
index 5a7c181..ba1a1ab 100644
--- a/src/database/abstraction/persy.rs
+++ b/src/database/abstraction/persy.rs
@@ -17,6 +17,8 @@ use std::{
     time::{Duration, Instant},
 };
 
+use tracing::warn;
+
 pub struct PersyEngine {
     persy: Persy,
     write_cache: Arc<RwLock<WriteCache>>,
@@ -415,7 +417,7 @@ impl Tree for PersyTree {
                 self.write_cache.read().unwrap().iter(&self.name, result)
             }
             Err(e) => {
-                log::warn!("error iterating {:?}", e);
+                warn!("error iterating {:?}", e);
                 Box::new(std::iter::empty())
             }
         }
@@ -453,7 +455,7 @@ impl Tree for PersyTree {
                     .iter_from(&self.name, from, backwards, result)
             }
             Err(e) => {
-                log::warn!("error iterating with prefix {:?}", e);
+                warn!("error iterating with prefix {:?}", e);
                 Box::new(std::iter::empty())
             }
         }
@@ -493,7 +495,7 @@ impl Tree for PersyTree {
                     .scan_prefix(&self.name, prefix, result)
             }
             Err(e) => {
-                log::warn!("error scanning prefix {:?}", e);
+                warn!("error scanning prefix {:?}", e);
                 Box::new(std::iter::empty())
             }
         }