Compare commits
	
		
			3 Commits
		
	
	
		
			v0.2.5
			...
			e479959ca8
		
	
	| 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