searchengines-web/MeiliSearch
searchengines-web/MeiliSearch
1
0
Fork 0
mirror of https://github.com/meilisearch/MeiliSearch synced 2024-12-05 02:55:46 +01:00
Code Issues Releases Wiki Activity

implement the watcher for all kind of operations

Browse Source
This commit is contained in:
Tamo 2023-08-03 10:52:13 +02:00
parent a325ddfe6a
commit 57dc4b148c
1 changed files with 12 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
meilisearch-auth/src/lib.rs
View File

@ -52,20 +52,29 @@ impl AuthController {
// Zookeeper Event listener loop // Zookeeper Event listener loop
let controller_clone = controller.clone(); let controller_clone = controller.clone();
let mut watcher = zk.watch("/auth", zk::AddWatchMode::PersistentRecursive).await?; let mut watcher = zk.watch("/auth", zk::AddWatchMode::PersistentRecursive).await?;
let czk = zk.clone();
tokio::spawn(async move { tokio::spawn(async move {
let zk = czk;
loop { loop {
let zk::WatchedEvent { event_type, session_state, path } = let zk::WatchedEvent { event_type, session_state, path } =
dbg!(watcher.changed().await); dbg!(watcher.changed().await);
match event_type { match event_type {
zk::EventType::Session => panic!("Session error {:?}", session_state),
// a key is deleted from zk // a key is deleted from zk
zk::EventType::NodeDeleted => { zk::EventType::NodeDeleted => {
// TODO: ugly unwraps // TODO: ugly unwraps
let key = path.strip_prefix("/auth/").unwrap(); let uuid = path.strip_prefix("/auth/").unwrap();
let uuid = Uuid::parse_str(&key).unwrap(); let uuid = Uuid::parse_str(&uuid).unwrap();
dbg!(controller_clone.store.delete_api_key(uuid).unwrap()); dbg!(controller_clone.store.delete_api_key(uuid).unwrap());
} }
_ => println!("Not yet implemented"), zk::EventType::NodeCreated | zk::EventType::NodeDataChanged => {
let (key, stat) = zk.get_data(&path).await.unwrap();
dbg!(stat);
let key = serde_json::from_slice(&key).unwrap();
dbg!(controller_clone.store.put_api_key(key).unwrap());
}
zk::EventType::NodeChildrenChanged => panic!("Got the unexpected NodeChildrenChanged event, what is it used for?"),
} }
} }
}); });