playa 0.1.142

Image sequence player (EXR, PNG, JPEG, TIFF, .MP4). Pure Rust with optional OpenEXR/FFmpeg support.
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
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109

//! Abstract traits for dependency inversion.
//!
//! These traits define interfaces that `entities` needs from infrastructure,
//! allowing `core` to depend on `entities` (not vice versa).
//!
//! Implementations live in `core/` module.

use std::sync::Arc;
use uuid::Uuid;

use super::frame::{Frame, FrameStatus};

/// Cache strategy for frame retention (moved here for dependency inversion)
#[derive(Debug, Clone, Copy, PartialEq, Eq, serde::Serialize, serde::Deserialize, Default)]
pub enum CacheStrategy {
    /// Cache only the last accessed frame per comp (minimal memory)
    LastOnly,
    /// Cache all frames within work area (maximum performance)
    #[default]
    All,
}

/// Simple cache statistics (subset exposed via trait)
#[derive(Debug, Clone, Copy, Default)]
pub struct CacheStatsSnapshot {
    pub hits: u64,
    pub misses: u64,
    pub size: usize,
}

impl CacheStatsSnapshot {
    pub fn hit_rate(&self) -> f64 {
        let total = self.hits + self.misses;
        if total == 0 { 0.0 } else { self.hits as f64 / total as f64 }
    }
}

/// Abstract frame cache interface.
///
/// Allows nodes to cache computed frames without knowing
/// the concrete cache implementation.
pub trait FrameCache: Send + Sync {
    /// Get cached frame by (node_uuid, frame_index).
    /// Returns None if not cached.
    fn get(&self, node_uuid: Uuid, frame_idx: i32) -> Option<Frame>;

    /// Insert frame into cache.
    fn insert(&self, node_uuid: Uuid, frame_idx: i32, frame: Frame);

    /// Get frame status without cloning the frame (lightweight query).
    fn get_status(&self, node_uuid: Uuid, frame_idx: i32) -> Option<FrameStatus>;

    /// Get current cache size (number of cached frames).
    fn len(&self) -> usize;

    /// Check if cache is empty.
    fn is_empty(&self) -> bool { self.len() == 0 }

    /// Set caching strategy.
    fn set_strategy(&self, strategy: CacheStrategy);

    /// Get cache statistics snapshot.
    fn stats_snapshot(&self) -> CacheStatsSnapshot;
}

/// Abstract worker pool interface.
///
/// Allows nodes to schedule background work without knowing
/// the concrete thread pool implementation.
pub trait WorkerPool: Send + Sync {
    /// Execute closure on worker thread with epoch-based cancellation.
    ///
    /// If epoch changed before execution, the closure is skipped.
    /// This allows fast timeline scrubbing without wasted work.
    fn execute_with_epoch(&self, epoch: u64, f: Box<dyn FnOnce() + Send + 'static>);
}

/// Blanket impl: Arc<T> implements traits if T does
impl<T: FrameCache + ?Sized> FrameCache for Arc<T> {
    fn get(&self, node_uuid: Uuid, frame_idx: i32) -> Option<Frame> {
        (**self).get(node_uuid, frame_idx)
    }

    fn insert(&self, node_uuid: Uuid, frame_idx: i32, frame: Frame) {
        (**self).insert(node_uuid, frame_idx, frame)
    }

    fn get_status(&self, node_uuid: Uuid, frame_idx: i32) -> Option<FrameStatus> {
        (**self).get_status(node_uuid, frame_idx)
    }

    fn len(&self) -> usize {
        (**self).len()
    }

    fn set_strategy(&self, strategy: CacheStrategy) {
        (**self).set_strategy(strategy)
    }

    fn stats_snapshot(&self) -> CacheStatsSnapshot {
        (**self).stats_snapshot()
    }
}

impl<T: WorkerPool + ?Sized> WorkerPool for Arc<T> {
    fn execute_with_epoch(&self, epoch: u64, f: Box<dyn FnOnce() + Send + 'static>) {
        (**self).execute_with_epoch(epoch, f)
    }
}