Compare commits
3 Commits
Author | SHA1 | Date | |
---|---|---|---|
e479959ca8 | |||
ef492f6008 | |||
6371417234 |
@ -1,11 +1,12 @@
|
|||||||
[package]
|
[package]
|
||||||
name = "zealot"
|
name = "zealot"
|
||||||
description = "Bit Goblin automated video transcoding service."
|
description = "Bit Goblin automated video transcoding service."
|
||||||
version = "0.2.5"
|
version = "0.2.6"
|
||||||
edition = "2021"
|
edition = "2021"
|
||||||
readme = "README.md"
|
readme = "README.md"
|
||||||
license = "BSD 2-Clause"
|
license = "BSD 2-Clause"
|
||||||
authors = ["Gregory Ballantine <gballantine@bitgoblin.tech>"]
|
authors = ["Gregory Ballantine <gballantine@bitgoblin.tech>"]
|
||||||
|
repository = "https://git.metaunix.net/BitGoblin/zealot"
|
||||||
|
|
||||||
[dependencies]
|
[dependencies]
|
||||||
clap = { version = "3.2", features = ['derive'] }
|
clap = { version = "3.2", features = ['derive'] }
|
||||||
|
@ -18,3 +18,21 @@ pub fn setup_command() {
|
|||||||
// initialize the video repository
|
// initialize the video repository
|
||||||
r.initialize();
|
r.initialize();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
pub fn version_command() {
|
||||||
|
println!("===================================================================================");
|
||||||
|
|
||||||
|
// output the program and version
|
||||||
|
println!("Zealot version v{}", env!("CARGO_PKG_VERSION"));
|
||||||
|
|
||||||
|
// output project description
|
||||||
|
println!("{}", env!("CARGO_PKG_DESCRIPTION"));
|
||||||
|
|
||||||
|
// display license info
|
||||||
|
println!("\nThis code is licensed under the {} license.", env!("CARGO_PKG_LICENSE"));
|
||||||
|
|
||||||
|
// output the project source URL
|
||||||
|
println!("View the source code or file issues at {}.", env!("CARGO_PKG_REPOSITORY"));
|
||||||
|
|
||||||
|
println!("===================================================================================");
|
||||||
|
}
|
||||||
|
@ -22,8 +22,11 @@ struct Cli {
|
|||||||
|
|
||||||
#[derive(Subcommand)]
|
#[derive(Subcommand)]
|
||||||
enum Commands {
|
enum Commands {
|
||||||
/// displays version info about this program
|
// Runs the setup command
|
||||||
Setup {},
|
Setup {},
|
||||||
|
|
||||||
|
// Displays version info about the program
|
||||||
|
Version {},
|
||||||
}
|
}
|
||||||
|
|
||||||
fn main() {
|
fn main() {
|
||||||
@ -37,6 +40,7 @@ fn main() {
|
|||||||
match &cli.command {
|
match &cli.command {
|
||||||
// sub-commands will be handled here
|
// sub-commands will be handled here
|
||||||
Some(Commands::Setup {}) => cmd::core::setup_command(),
|
Some(Commands::Setup {}) => cmd::core::setup_command(),
|
||||||
|
Some(Commands::Version {}) => cmd::core::version_command(),
|
||||||
|
|
||||||
// run the main program without any commands
|
// run the main program without any commands
|
||||||
None => {
|
None => {
|
||||||
|
@ -31,6 +31,10 @@ impl Transcoder {
|
|||||||
if ingest_files.len() < 1 {
|
if ingest_files.len() < 1 {
|
||||||
info!("There were no files found in ingest to transcode; skipping run.");
|
info!("There were no files found in ingest to transcode; skipping run.");
|
||||||
} else {
|
} else {
|
||||||
|
// log that the transcoder is starting up
|
||||||
|
info!("Found {} files in ingest to transcode. Standby...", ingest_files.len());
|
||||||
|
|
||||||
|
// loop through each file found in ingest
|
||||||
for i in ingest_files {
|
for i in ingest_files {
|
||||||
let ingest_path = Path::new(&self.repository.ingest_dir).join(&i);
|
let ingest_path = Path::new(&self.repository.ingest_dir).join(&i);
|
||||||
if io::is_file_locked(&ingest_path.to_str().unwrap()) {
|
if io::is_file_locked(&ingest_path.to_str().unwrap()) {
|
||||||
@ -47,6 +51,9 @@ impl Transcoder {
|
|||||||
// remove the source file
|
// remove the source file
|
||||||
self.repository.cleanup_file(&i);
|
self.repository.cleanup_file(&i);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// let the user know the transcode has finished
|
||||||
|
info!("Finished transcoding. Sleeping...");
|
||||||
}
|
}
|
||||||
|
|
||||||
// put the loop to sleep for X minutes
|
// put the loop to sleep for X minutes
|
||||||
|
Reference in New Issue
Block a user