Cutlery/Kyoo
1
0
Fork 0
mirror of https://github.com/zoriya/Kyoo.git synced 2025-07-31 14:33:50 -04:00
Code Issues Packages Projects Releases Wiki Activity

Automatically clear the transcoder cache

Browse Source
This commit is contained in:
Zoe Roux 2023-06-20 14:09:21 +09:00
parent bbe8a19189
commit 8ebc767b76
2 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
transcoder/src/main.rs
View File

@ -130,6 +130,11 @@ async fn get_swagger() -> String {
async fn main() -> std::io::Result<()> { async fn main() -> std::io::Result<()> {
let state = web::Data::new(Transcoder::new()); let state = web::Data::new(Transcoder::new());
// Clear the cache
for entry in std::fs::read_dir("/cache")? {
_ = std::fs::remove_dir_all(entry?.path());
}
HttpServer::new(move || { HttpServer::new(move || {
App::new() App::new()
.app_data(state.clone()) .app_data(state.clone())

2
transcoder/src/state.rs
View File

@ -98,7 +98,6 @@ impl Transcoder {
start_time: u32, start_time: u32,
) -> Result<String, std::io::Error> { ) -> Result<String, std::io::Error> {
// TODO: If the stream is not yet up to start_time (and is far), kill it and restart one at the right time. // TODO: If the stream is not yet up to start_time (and is far), kill it and restart one at the right time.
// TODO: Clear cache at startup/every X time without use.
// TODO: cache transcoded output for a show/quality and reuse it for every future requests. // TODO: cache transcoded output for a show/quality and reuse it for every future requests.
if let Some(TranscodeInfo { if let Some(TranscodeInfo {
show: (old_path, old_qual), show: (old_path, old_qual),
@ -110,6 +109,7 @@ impl Transcoder {
if path != *old_path || quality != *old_qual { if path != *old_path || quality != *old_qual {
// If the job has already ended, interrupt returns an error but we don't care. // If the job has already ended, interrupt returns an error but we don't care.
_ = job.interrupt(); _ = job.interrupt();
_ = std::fs::remove_dir_all(get_cache_path_from_uuid(uuid));
} else { } else {
let mut path = get_cache_path_from_uuid(uuid); let mut path = get_cache_path_from_uuid(uuid);
path.push("stream.m3u8"); path.push("stream.m3u8");