yazi-actor 26.1.22

Yazi actor model
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56

use anyhow::Result;
use hashbrown::HashMap;
use yazi_macro::{act, render, succ};
use yazi_parser::mgr::UpdateMimesOpt;
use yazi_shared::{data::Data, pool::InternStr, url::{AsUrl, UrlCov}};
use yazi_watcher::local::LINKED;

use crate::{Actor, Ctx};

pub struct UpdateMimes;

impl Actor for UpdateMimes {
	type Options = UpdateMimesOpt;

	const NAME: &str = "update_mimes";

	fn act(cx: &mut Ctx, opt: Self::Options) -> Result<Data> {
		let linked = LINKED.read();
		let updates = opt
			.updates
			.into_iter()
			.flat_map(|(key, value)| key.into_url().zip(value.into_string()))
			.filter(|(url, mime)| cx.mgr.mimetype.get(url) != Some(mime))
			.fold(HashMap::new(), |mut map, (u, m)| {
				for u in linked.from_file(u.as_url()) {
					map.insert(u.into(), m.intern());
				}
				map.insert(u.into(), m.intern());
				map
			});

		drop(linked);
		if updates.is_empty() {
			succ!();
		}

		let affected: Vec<_> = cx
			.current()
			.paginate(cx.current().page)
			.iter()
			.filter(|&f| updates.contains_key(&UrlCov::new(&f.url)))
			.cloned()
			.collect();

		let repeek = cx.hovered().is_some_and(|f| updates.contains_key(&UrlCov::new(&f.url)));
		cx.mgr.mimetype.extend(updates);

		if repeek {
			act!(mgr:peek, cx)?;
		}
		cx.tasks.fetch_paged(&affected, &cx.mgr.mimetype);
		cx.tasks.preload_paged(&affected, &cx.mgr.mimetype);

		succ!(render!());
	}
}