Compare commits
5 Commits
Author | SHA1 | Date | |
---|---|---|---|
23288ac043 | |||
e7fe6fbcec | |||
e43ce790cc | |||
5f9a2829f0 | |||
e14795c493 |
@ -1,7 +1,7 @@
|
|||||||
[package]
|
[package]
|
||||||
name = "adept"
|
name = "adept"
|
||||||
description = "Bit Goblin automated video transcoding service."
|
description = "Bit Goblin automated video transcoding service."
|
||||||
version = "0.1.0"
|
version = "0.1.1"
|
||||||
edition = "2021"
|
edition = "2021"
|
||||||
readme = "README.md"
|
readme = "README.md"
|
||||||
license = "BSD 2-Clause"
|
license = "BSD 2-Clause"
|
||||||
@ -15,7 +15,7 @@ shellexpand = "2.1"
|
|||||||
|
|
||||||
[package.metadata.deb]
|
[package.metadata.deb]
|
||||||
license-file = "LICENSE"
|
license-file = "LICENSE"
|
||||||
maintainer-scripts = "build/debian/scripts"
|
maintainer-scripts = "build/scripts"
|
||||||
depends = "ffmpeg (>= 4)"
|
depends = "ffmpeg (>= 4)"
|
||||||
section = "video"
|
section = "video"
|
||||||
assets = [
|
assets = [
|
||||||
@ -35,6 +35,6 @@ assets = [
|
|||||||
{ source = "build/etc/example.toml", dest = "/etc/adept/example.toml", mode = "755"},
|
{ source = "build/etc/example.toml", dest = "/etc/adept/example.toml", mode = "755"},
|
||||||
{ source = "README.md", dest = "/usr/share/doc/adept/README", mode = "644"}
|
{ source = "README.md", dest = "/usr/share/doc/adept/README", mode = "644"}
|
||||||
]
|
]
|
||||||
post_install_script = "build/script/postinst"
|
post_install_script = "build/scripts/postinst"
|
||||||
[package.metadata.generate-rpm.requires]
|
[package.metadata.generate-rpm.requires]
|
||||||
ffmpeg = ">= 4"
|
ffmpeg = ">= 4"
|
||||||
|
@ -20,3 +20,7 @@ fi
|
|||||||
|
|
||||||
# Change the directory ownership of /etc
|
# Change the directory ownership of /etc
|
||||||
chown -R adept:adept /etc/adept
|
chown -R adept:adept /etc/adept
|
||||||
|
|
||||||
|
#DEBHELPER#
|
||||||
|
|
||||||
|
exit 0
|
||||||
|
@ -1,5 +1,6 @@
|
|||||||
use std::path::Path;
|
use std::path::Path;
|
||||||
use std::process;
|
use std::process;
|
||||||
|
use std::{thread, time};
|
||||||
|
|
||||||
use crate::config::Config;
|
use crate::config::Config;
|
||||||
use crate::repository::Repository;
|
use crate::repository::Repository;
|
||||||
@ -20,9 +21,14 @@ impl Transcoder {
|
|||||||
pub fn start(self) {
|
pub fn start(self) {
|
||||||
println!("Starting transcoder...");
|
println!("Starting transcoder...");
|
||||||
|
|
||||||
|
loop {
|
||||||
// search for files in ingest
|
// search for files in ingest
|
||||||
let ingest_files = self.repository.search_ingest();
|
let ingest_files = self.repository.search_ingest();
|
||||||
|
|
||||||
|
// check if we found any files to transcode
|
||||||
|
if ingest_files.len() < 1 {
|
||||||
|
println!("There were no files found in ingest to transcode; skipping run.");
|
||||||
|
} else {
|
||||||
for i in ingest_files {
|
for i in ingest_files {
|
||||||
// copy the file to the archive
|
// copy the file to the archive
|
||||||
self.repository.archive_file(&i);
|
self.repository.archive_file(&i);
|
||||||
@ -35,6 +41,12 @@ impl Transcoder {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// put the loop to sleep for X minutes
|
||||||
|
let sleep_minutes = time::Duration::from_secs((self.config.transcoder.interval * 60).into());
|
||||||
|
thread::sleep(sleep_minutes);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
fn transcode(&self, file: &str) {
|
fn transcode(&self, file: &str) {
|
||||||
let ingest_file = Path::new(&self.repository.ingest_dir).join(file);
|
let ingest_file = Path::new(&self.repository.ingest_dir).join(file);
|
||||||
let output_file = Path::new(&self.repository.output_dir).join(file);
|
let output_file = Path::new(&self.repository.output_dir).join(file);
|
||||||
|
Reference in New Issue
Block a user