use configcat::*;
use log::kv::Key;
use log::{Level, LevelFilter, Log, Metadata, Record};
use std::time::Duration;
#[tokio::main]
async fn main() {
log::set_max_level(LevelFilter::Info);
log::set_logger(&PrintLog {}).unwrap();
let client = Client::builder("PKDVCLf-Hq-h-kCzMp-L7Q/HhOWfwVtZ0mb30i9wi17GQ")
.polling_mode(PollingMode::AutoPoll(Duration::from_secs(5)))
.build()
.unwrap();
let is_awesome_enabled = client
.get_value("isAwesomeFeatureEnabled", false, None)
.await;
println!("isAwesomeFeatureEnabled: {is_awesome_enabled}");
let user = User::new("#SOME-USER-ID#").email("configcat@example.com");
let is_poc_enabled = client
.get_value("isPOCFeatureEnabled", false, Some(user))
.await;
println!("isPOCFeatureEnabled: {is_poc_enabled}");
}
pub struct PrintLog {}
impl Log for PrintLog {
fn enabled(&self, metadata: &Metadata) -> bool {
metadata.level() <= log::max_level() && metadata.target().contains("configcat")
}
fn log(&self, record: &Record) {
if !self.enabled(record.metadata()) {
return;
}
let level = match record.level() {
Level::Error => "ERROR",
Level::Warn => "WARN",
Level::Info => "INFO",
Level::Debug => "DEBUG",
Level::Trace => "TRACE",
};
let event_id = record.key_values().get(Key::from("event_id")).unwrap();
println!("{level} [{event_id}] {}", record.args());
}
fn flush(&self) {}
}