Apps/ImageApi
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

001-video-wall #52

Merged
cameron merged 10 commits from 001-video-wall into master 2026-03-02 18:45:05 +00:00
Conversation 0 Commits 10 Files Changed 43 +6 -6
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 7d164bad81 - Show all commits

12
src/main.rs
View File

@@ -176,7 +176,7 @@ fn is_video_file(path: &Path) -> bool {
async fn create_circular_thumbnail( async fn create_circular_thumbnail(
thumb_path: &Path, thumb_path: &Path,
thumbs_dir: &str, thumbs_dir: &str,
) -> Result<PathBuf, Box<dyn std::error::Error>> { ) -> Result<PathBuf, Box<dyn Error>> {
use image::{GenericImageView, ImageBuffer, Rgba}; use image::{GenericImageView, ImageBuffer, Rgba};
// Create circular thumbnails directory // Create circular thumbnails directory
@@ -1091,7 +1091,7 @@ fn main() -> std::io::Result<()> {
let end = end_date; let end = end_date;
tokio::spawn(async move { tokio::spawn(async move {
log::info!("Starting daily summary generation for {}", contact); info!("Starting daily summary generation for {}", contact);
if let Err(e) = generate_daily_summaries( if let Err(e) = generate_daily_summaries(
contact, contact,
start, start,
@@ -1102,9 +1102,9 @@ fn main() -> std::io::Result<()> {
) )
.await .await
{ {
log::error!("Daily summary generation failed for {}: {:?}", contact, e); error!("Daily summary generation failed for {}: {:?}", contact, e);
} else { } else {
log::info!("Daily summary generation completed for {}", contact); info!("Daily summary generation completed for {}", contact);
} }
}); });
} }
@@ -1347,7 +1347,7 @@ fn cleanup_orphaned_playlists() {
fn watch_files( fn watch_files(
playlist_manager: Addr<VideoPlaylistManager>, playlist_manager: Addr<VideoPlaylistManager>,
preview_generator: actix::Addr<crate::video::actors::PreviewClipGenerator>, preview_generator: Addr<video::actors::PreviewClipGenerator>,
) { ) {
std::thread::spawn(move || { std::thread::spawn(move || {
let base_str = dotenv::var("BASE_PATH").unwrap(); let base_str = dotenv::var("BASE_PATH").unwrap();
@@ -1461,7 +1461,7 @@ fn process_new_files(
preview_dao: Arc<Mutex<Box<dyn PreviewDao>>>, preview_dao: Arc<Mutex<Box<dyn PreviewDao>>>,
modified_since: Option<SystemTime>, modified_since: Option<SystemTime>,
playlist_manager: Addr<VideoPlaylistManager>, playlist_manager: Addr<VideoPlaylistManager>,
preview_generator: actix::Addr<crate::video::actors::PreviewClipGenerator>, preview_generator: Addr<video::actors::PreviewClipGenerator>,
) { ) {
let context = opentelemetry::Context::new(); let context = opentelemetry::Context::new();
let thumbs = dotenv::var("THUMBNAILS").expect("THUMBNAILS not defined"); let thumbs = dotenv::var("THUMBNAILS").expect("THUMBNAILS not defined");