Compare commits
13 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 9a567b7178 | |||
| 88f63e040e | |||
| aabf1d49a7 | |||
| 3b789eb623 | |||
| ad0115e5f2 | |||
| 3c6079807e | |||
| b21d98ef73 | |||
| 2e55876076 | |||
| dad3e6c1cf | |||
| 8c36855593 | |||
| 6bce649458 | |||
| d017cb19f3 | |||
| 5bc2acac1d |
@ -1,14 +1,23 @@
|
|||||||
pipeline:
|
pipeline:
|
||||||
test:
|
test:
|
||||||
image: maven:3-jdk-11
|
image: maven:3-openjdk-18
|
||||||
commands:
|
commands:
|
||||||
|
- microdnf install -y lsof
|
||||||
- mvn test
|
- mvn test
|
||||||
|
|
||||||
build:
|
build:
|
||||||
image: maven:3-jdk-11
|
image: maven:3-openjdk-18
|
||||||
commands:
|
commands:
|
||||||
- mvn clean compile assembly:single
|
- mvn clean compile assembly:single
|
||||||
|
|
||||||
|
package:
|
||||||
|
image: maven:3-openjdk-18
|
||||||
|
commands:
|
||||||
|
- microdnf install -y rpm-build
|
||||||
|
- mvn clean compile package -Dmaven.test.skip
|
||||||
|
when:
|
||||||
|
event: tag
|
||||||
|
|
||||||
gitea_release:
|
gitea_release:
|
||||||
image: plugins/gitea-release
|
image: plugins/gitea-release
|
||||||
settings:
|
settings:
|
||||||
@ -17,6 +26,8 @@ pipeline:
|
|||||||
base_url: https://git.metaunix.net
|
base_url: https://git.metaunix.net
|
||||||
title: "${CI_COMMIT_TAG}"
|
title: "${CI_COMMIT_TAG}"
|
||||||
files:
|
files:
|
||||||
- target/Dragoon-*.jar
|
- target/dragoon-*.jar
|
||||||
|
- target/dragoon-*.deb
|
||||||
|
- target/rpm/dragoon/RPMS/noarch/dragoon-*.rpm
|
||||||
when:
|
when:
|
||||||
event: tag
|
event: tag
|
||||||
|
|||||||
299
pom.xml
299
pom.xml
@ -5,19 +5,48 @@
|
|||||||
<modelVersion>4.0.0</modelVersion>
|
<modelVersion>4.0.0</modelVersion>
|
||||||
|
|
||||||
<groupId>tech.bitgoblin</groupId>
|
<groupId>tech.bitgoblin</groupId>
|
||||||
<artifactId>Dragoon</artifactId>
|
<artifactId>dragoon</artifactId>
|
||||||
<version>0.3.0</version>
|
<version>0.3.3</version>
|
||||||
|
|
||||||
<name>Dragoon</name>
|
<name>Dragoon</name>
|
||||||
<url>https://www.bitgoblin.tech</url>
|
<url>https://www.bitgoblin.tech</url>
|
||||||
|
<description>Automated video transcoder service.</description>
|
||||||
|
<inceptionYear>2022</inceptionYear>
|
||||||
|
|
||||||
|
<organization>
|
||||||
|
<name>Bit Goblin</name>
|
||||||
|
<url>https://www.bitgoblin.tech</url>
|
||||||
|
</organization>
|
||||||
|
|
||||||
|
<developers>
|
||||||
|
<developer>
|
||||||
|
<id>gballantine</id>
|
||||||
|
<name>Gregory Ballantine</name>
|
||||||
|
<email>gballantine@bitgoblin.tech</email>
|
||||||
|
</developer>
|
||||||
|
</developers>
|
||||||
|
|
||||||
|
<licenses>
|
||||||
|
<license>
|
||||||
|
<name>BSD</name>
|
||||||
|
<url>https://opensource.org/licenses/BSD-2-Clause</url>
|
||||||
|
<distribution>repo</distribution>
|
||||||
|
<comments>Simplified BSD license.</comments>
|
||||||
|
</license>
|
||||||
|
</licenses>
|
||||||
|
|
||||||
<properties>
|
<properties>
|
||||||
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
|
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
|
||||||
<maven.compiler.source>11</maven.compiler.source>
|
<maven.compiler.source>17</maven.compiler.source>
|
||||||
<maven.compiler.target>11</maven.compiler.target>
|
<maven.compiler.target>17</maven.compiler.target>
|
||||||
</properties>
|
</properties>
|
||||||
|
|
||||||
<dependencies>
|
<dependencies>
|
||||||
|
<dependency>
|
||||||
|
<groupId>commons-cli</groupId>
|
||||||
|
<artifactId>commons-cli</artifactId>
|
||||||
|
<version>1.3.1</version>
|
||||||
|
</dependency>
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>org.tomlj</groupId>
|
<groupId>org.tomlj</groupId>
|
||||||
<artifactId>tomlj</artifactId>
|
<artifactId>tomlj</artifactId>
|
||||||
@ -42,81 +71,191 @@
|
|||||||
</dependencies>
|
</dependencies>
|
||||||
|
|
||||||
<build>
|
<build>
|
||||||
<pluginManagement><!-- lock down plugins versions to avoid using Maven defaults (may be moved to parent pom) -->
|
<plugins>
|
||||||
<plugins>
|
<!-- clean lifecycle, see https://maven.apache.org/ref/current/maven-core/lifecycles.html#clean_Lifecycle -->
|
||||||
<!-- clean lifecycle, see https://maven.apache.org/ref/current/maven-core/lifecycles.html#clean_Lifecycle -->
|
<plugin>
|
||||||
<plugin>
|
<artifactId>maven-clean-plugin</artifactId>
|
||||||
<artifactId>maven-clean-plugin</artifactId>
|
<version>3.1.0</version>
|
||||||
<version>3.1.0</version>
|
</plugin>
|
||||||
</plugin>
|
<!-- default lifecycle, jar packaging: see https://maven.apache.org/ref/current/maven-core/default-bindings.html#Plugin_bindings_for_jar_packaging -->
|
||||||
<!-- default lifecycle, jar packaging: see https://maven.apache.org/ref/current/maven-core/default-bindings.html#Plugin_bindings_for_jar_packaging -->
|
<plugin>
|
||||||
<plugin>
|
<artifactId>maven-resources-plugin</artifactId>
|
||||||
<artifactId>maven-resources-plugin</artifactId>
|
<version>3.0.2</version>
|
||||||
<version>3.0.2</version>
|
</plugin>
|
||||||
</plugin>
|
<plugin>
|
||||||
<plugin>
|
<artifactId>maven-compiler-plugin</artifactId>
|
||||||
<artifactId>maven-compiler-plugin</artifactId>
|
<version>3.8.0</version>
|
||||||
<version>3.8.0</version>
|
</plugin>
|
||||||
</plugin>
|
<plugin>
|
||||||
<plugin>
|
<artifactId>maven-surefire-plugin</artifactId>
|
||||||
<artifactId>maven-surefire-plugin</artifactId>
|
<version>2.22.1</version>
|
||||||
<version>2.22.1</version>
|
</plugin>
|
||||||
</plugin>
|
<plugin>
|
||||||
<plugin>
|
<artifactId>maven-jar-plugin</artifactId>
|
||||||
<artifactId>maven-jar-plugin</artifactId>
|
<version>3.0.2</version>
|
||||||
<version>3.0.2</version>
|
<configuration>
|
||||||
<configuration>
|
<!-- DO NOT include log4j.properties file in your Jar -->
|
||||||
<!-- DO NOT include log4j.properties file in your Jar -->
|
<excludes>
|
||||||
<excludes>
|
<exclude>**/log4j.properties</exclude>
|
||||||
<exclude>**/log4j.properties</exclude>
|
</excludes>
|
||||||
</excludes>
|
<archive>
|
||||||
<archive>
|
<manifest>
|
||||||
<manifest>
|
<!-- Jar file entry point -->
|
||||||
<!-- Jar file entry point -->
|
<mainClass>tech.bitgoblin.App</mainClass>
|
||||||
<mainClass>tech.bitgoblin.App</mainClass>
|
</manifest>
|
||||||
</manifest>
|
</archive>
|
||||||
</archive>
|
</configuration>
|
||||||
</configuration>
|
</plugin>
|
||||||
</plugin>
|
<plugin>
|
||||||
<plugin>
|
<artifactId>maven-assembly-plugin</artifactId>
|
||||||
<artifactId>maven-assembly-plugin</artifactId>
|
<executions>
|
||||||
<executions>
|
<execution>
|
||||||
<execution>
|
<phase>package</phase>
|
||||||
<phase>package</phase>
|
<goals>
|
||||||
<goals>
|
<goal>single</goal>
|
||||||
<goal>single</goal>
|
</goals>
|
||||||
</goals>
|
</execution>
|
||||||
</execution>
|
</executions>
|
||||||
</executions>
|
<configuration>
|
||||||
<configuration>
|
<archive>
|
||||||
<archive>
|
<manifest>
|
||||||
<manifest>
|
<mainClass>tech.bitgoblin.App</mainClass>
|
||||||
<mainClass>tech.bitgoblin.App</mainClass>
|
</manifest>
|
||||||
</manifest>
|
</archive>
|
||||||
</archive>
|
<descriptorRefs>
|
||||||
<descriptorRefs>
|
<descriptorRef>jar-with-dependencies</descriptorRef>
|
||||||
<descriptorRef>jar-with-dependencies</descriptorRef>
|
</descriptorRefs>
|
||||||
</descriptorRefs>
|
</configuration>
|
||||||
</configuration>
|
</plugin>
|
||||||
</plugin>
|
<plugin>
|
||||||
<plugin>
|
<groupId>com.aerse.maven</groupId>
|
||||||
<artifactId>maven-install-plugin</artifactId>
|
<artifactId>deb-maven-plugin</artifactId>
|
||||||
<version>2.5.2</version>
|
<version>1.16</version>
|
||||||
</plugin>
|
<executions>
|
||||||
<plugin>
|
<execution>
|
||||||
<artifactId>maven-deploy-plugin</artifactId>
|
<id>package</id>
|
||||||
<version>2.8.2</version>
|
<phase>package</phase>
|
||||||
</plugin>
|
<goals>
|
||||||
<!-- site lifecycle, see https://maven.apache.org/ref/current/maven-core/lifecycles.html#site_Lifecycle -->
|
<goal>package</goal>
|
||||||
<plugin>
|
</goals>
|
||||||
<artifactId>maven-site-plugin</artifactId>
|
</execution>
|
||||||
<version>3.7.1</version>
|
</executions>
|
||||||
</plugin>
|
<configuration>
|
||||||
<plugin>
|
<unixUserId>dragoon</unixUserId>
|
||||||
<artifactId>maven-project-info-reports-plugin</artifactId>
|
<unixGroupId>dragoon</unixGroupId>
|
||||||
<version>3.0.0</version>
|
<debBaseDir>${project.basedir}/src/build/deb</debBaseDir>
|
||||||
</plugin>
|
<installDir>/opt</installDir>
|
||||||
</plugins>
|
<osDependencies>
|
||||||
</pluginManagement>
|
<openjdk-17-jre></openjdk-17-jre>
|
||||||
|
<ffmpeg></ffmpeg>
|
||||||
|
</osDependencies>
|
||||||
|
<javaServiceWrapper>false</javaServiceWrapper>
|
||||||
|
<generateVersion>false</generateVersion>
|
||||||
|
<fileSets>
|
||||||
|
<fileSet>
|
||||||
|
<source>${basedir}/src/build/deb</source>
|
||||||
|
<target>/</target>
|
||||||
|
</fileSet>
|
||||||
|
<fileSet>
|
||||||
|
<source>${basedir}/target/dragoon-${project.version}-jar-with-dependencies.jar</source>
|
||||||
|
<target>/opt/dragoon/dragoon.jar</target>
|
||||||
|
</fileSet>
|
||||||
|
</fileSets>
|
||||||
|
</configuration>
|
||||||
|
</plugin>
|
||||||
|
<plugin>
|
||||||
|
<groupId>org.codehaus.mojo</groupId>
|
||||||
|
<artifactId>rpm-maven-plugin</artifactId>
|
||||||
|
<version>2.2.0</version>
|
||||||
|
<executions>
|
||||||
|
<execution>
|
||||||
|
<id>generate-rpm</id>
|
||||||
|
<goals>
|
||||||
|
<goal>rpm</goal>
|
||||||
|
</goals>
|
||||||
|
</execution>
|
||||||
|
</executions>
|
||||||
|
<configuration>
|
||||||
|
<license>BSD 2-Clause</license>
|
||||||
|
<group>Applications/Multimedia</group>
|
||||||
|
<icon>src/main/resources/icon.gif</icon>
|
||||||
|
<packager>Bit Goblin</packager>
|
||||||
|
<prefix>/opt</prefix>
|
||||||
|
<changelogFile>${project.basedir}/src/build/changelog.txt</changelogFile>
|
||||||
|
<targetOs>linux</targetOs>
|
||||||
|
<mappings>
|
||||||
|
<mapping>
|
||||||
|
<directory>/opt/dragoon</directory>
|
||||||
|
<filemode>755</filemode>
|
||||||
|
<username>dragoon</username>
|
||||||
|
<groupname>dragoon</groupname>
|
||||||
|
</mapping>
|
||||||
|
<mapping>
|
||||||
|
<directory>/opt/dragoon/dragoon.jar</directory>
|
||||||
|
<filemode>755</filemode>
|
||||||
|
<username>dragoon</username>
|
||||||
|
<groupname>dragoon</groupname>
|
||||||
|
<sources>
|
||||||
|
<source>
|
||||||
|
<location>${basedir}/target/dragoon-${project.version}-jar-with-dependencies.jar</location>
|
||||||
|
</source>
|
||||||
|
</sources>
|
||||||
|
</mapping>
|
||||||
|
<mapping>
|
||||||
|
<directory>/etc/dragoon</directory>
|
||||||
|
<configuration>true</configuration>
|
||||||
|
<filemode>755</filemode>
|
||||||
|
<username>dragoon</username>
|
||||||
|
<groupname>dragoon</groupname>
|
||||||
|
<sources>
|
||||||
|
<source>
|
||||||
|
<location>${project.basedir}/src/build/deb/etc/dragoon</location>
|
||||||
|
</source>
|
||||||
|
</sources>
|
||||||
|
</mapping>
|
||||||
|
<mapping>
|
||||||
|
<directory>/etc/systemd/system/dragoon.service</directory>
|
||||||
|
<filemode>644</filemode>
|
||||||
|
<username>root</username>
|
||||||
|
<groupname>root</groupname>
|
||||||
|
<sources>
|
||||||
|
<source>
|
||||||
|
<location>${project.basedir}/src/build/deb/etc/systemd/system/dragoon.service</location>
|
||||||
|
</source>
|
||||||
|
</sources>
|
||||||
|
</mapping>
|
||||||
|
</mappings>
|
||||||
|
<requires>
|
||||||
|
<require>java-17-openjdk</require>
|
||||||
|
<require>ffmpeg</require>
|
||||||
|
</requires>
|
||||||
|
<preinstallScriptlet>
|
||||||
|
<script>echo "installing ${project.name} now"</script>
|
||||||
|
</preinstallScriptlet>
|
||||||
|
<postinstallScriptlet>
|
||||||
|
<scriptFile>src/build/scripts/postinstall.sh</scriptFile>
|
||||||
|
<fileEncoding>utf-8</fileEncoding>
|
||||||
|
<filter>true</filter>
|
||||||
|
</postinstallScriptlet>
|
||||||
|
</configuration>
|
||||||
|
</plugin>
|
||||||
|
<plugin>
|
||||||
|
<artifactId>maven-install-plugin</artifactId>
|
||||||
|
<version>2.5.2</version>
|
||||||
|
</plugin>
|
||||||
|
<plugin>
|
||||||
|
<artifactId>maven-deploy-plugin</artifactId>
|
||||||
|
<version>2.8.2</version>
|
||||||
|
</plugin>
|
||||||
|
<!-- site lifecycle, see https://maven.apache.org/ref/current/maven-core/lifecycles.html#site_Lifecycle -->
|
||||||
|
<plugin>
|
||||||
|
<artifactId>maven-site-plugin</artifactId>
|
||||||
|
<version>3.7.1</version>
|
||||||
|
</plugin>
|
||||||
|
<plugin>
|
||||||
|
<artifactId>maven-project-info-reports-plugin</artifactId>
|
||||||
|
<version>3.0.0</version>
|
||||||
|
</plugin>
|
||||||
|
</plugins>
|
||||||
</build>
|
</build>
|
||||||
</project>
|
</project>
|
||||||
|
|||||||
1
src/build/changelog.txt
Normal file
1
src/build/changelog.txt
Normal file
@ -0,0 +1 @@
|
|||||||
|
# Check https://git.metaunix.net/bitgoblin/dragoon/releases for the current changelog
|
||||||
8
src/build/deb/etc/dragoon/config.example.toml
Normal file
8
src/build/deb/etc/dragoon/config.example.toml
Normal file
@ -0,0 +1,8 @@
|
|||||||
|
# This example transcodes footage to DNxHD 1080p60 for use in video editors like DaVinci Resolve.
|
||||||
|
[transcoder]
|
||||||
|
repo_path = '~/videos' # location of the videos to transcode
|
||||||
|
video_format = 'mov' # video container format
|
||||||
|
video_codec = 'dnxhd' # video codec to use
|
||||||
|
video_parameters = 'scale=1920x1080,fps=60,format=yuv422p' # video extra format parameters flag - this will be broken later into separate attributes
|
||||||
|
video_profile = 'dnxhr_hq' # DNxHD has multiple presets for various video qualities
|
||||||
|
audio_codec = 'pcm_s16le' # audio codec to use
|
||||||
11
src/build/deb/etc/systemd/system/dragoon.service
Normal file
11
src/build/deb/etc/systemd/system/dragoon.service
Normal file
@ -0,0 +1,11 @@
|
|||||||
|
[Unit]
|
||||||
|
Description=Dragoon video transcoder service
|
||||||
|
|
||||||
|
[Service]
|
||||||
|
User=dragoon
|
||||||
|
Group=dragoon
|
||||||
|
ExecStart=/usr/bin/java -jar '/opt/dragoon/dragoon.jar'
|
||||||
|
SuccessExitStatus=143
|
||||||
|
|
||||||
|
[Install]
|
||||||
|
WantedBy=multi-user.target
|
||||||
23
src/build/scripts/postinstall.sh
Normal file
23
src/build/scripts/postinstall.sh
Normal file
@ -0,0 +1,23 @@
|
|||||||
|
#!/bin/sh
|
||||||
|
|
||||||
|
GETENT_USER=$(getent passwd dragoon)
|
||||||
|
GETENT_GROUP=$(getent group dragoon)
|
||||||
|
|
||||||
|
# Create the dragoon user if it doesn't already exist
|
||||||
|
if [ "$GETENT_USER" = "" ]; then
|
||||||
|
useradd -r dragoon
|
||||||
|
else
|
||||||
|
echo "The 'dragoon' user already exists, skipping creation."
|
||||||
|
fi
|
||||||
|
|
||||||
|
# Create the dragoon group if it doesn't already exist
|
||||||
|
if [ "$GETENT_GROUP" = "" ]; then
|
||||||
|
groupadd dragoon
|
||||||
|
usermod -aG dragoon dragoon
|
||||||
|
else
|
||||||
|
echo "The 'dragoon' group already exists, skipping creation."
|
||||||
|
fi
|
||||||
|
|
||||||
|
# Change the directory ownership of /opt and /etc
|
||||||
|
chown -R dragoon:dragoon /etc/dragoon
|
||||||
|
chown -R dragoon:dragoon /opt/dragoon
|
||||||
@ -1,5 +1,7 @@
|
|||||||
package tech.bitgoblin;
|
package tech.bitgoblin;
|
||||||
|
|
||||||
|
import org.apache.commons.cli.ParseException;
|
||||||
|
import tech.bitgoblin.config.Cmd;
|
||||||
import tech.bitgoblin.config.Config;
|
import tech.bitgoblin.config.Config;
|
||||||
import tech.bitgoblin.transcoder.RunTranscoderTask;
|
import tech.bitgoblin.transcoder.RunTranscoderTask;
|
||||||
import tech.bitgoblin.transcoder.Transcoder;
|
import tech.bitgoblin.transcoder.Transcoder;
|
||||||
@ -12,13 +14,15 @@ import java.util.Timer;
|
|||||||
*/
|
*/
|
||||||
public class App {
|
public class App {
|
||||||
|
|
||||||
private static final String configFile = "~/.config/dragoon.toml";
|
|
||||||
|
|
||||||
private static final int msToMinutes = 60 * 1000;
|
private static final int msToMinutes = 60 * 1000;
|
||||||
|
|
||||||
public static void main(String[] args) {
|
public static void main(String[] args) throws ParseException {
|
||||||
|
// parse command-line options
|
||||||
|
Cmd cmd = new Cmd(args);
|
||||||
|
|
||||||
// read our config file
|
// read our config file
|
||||||
Config c = new Config(configFile);
|
Config c = new Config(cmd.getConfigPath());
|
||||||
|
|
||||||
// create new Transcoder object and start the service
|
// create new Transcoder object and start the service
|
||||||
Transcoder t = new Transcoder(c);
|
Transcoder t = new Transcoder(c);
|
||||||
Timer timer = new Timer();
|
Timer timer = new Timer();
|
||||||
|
|||||||
30
src/main/java/tech/bitgoblin/config/Cmd.java
Normal file
30
src/main/java/tech/bitgoblin/config/Cmd.java
Normal file
@ -0,0 +1,30 @@
|
|||||||
|
package tech.bitgoblin.config;
|
||||||
|
|
||||||
|
import org.apache.commons.cli.*;
|
||||||
|
|
||||||
|
public class Cmd {
|
||||||
|
|
||||||
|
private String configPath = "/etc/dragoon/config.toml";
|
||||||
|
|
||||||
|
public Cmd(String[] args) throws ParseException {
|
||||||
|
Options options = new Options();
|
||||||
|
|
||||||
|
Option configPath = new Option("c", "configPath", true, "configuration file path (defaults to /etc/dragoon/config.toml)");
|
||||||
|
configPath.setRequired(false);
|
||||||
|
options.addOption(configPath);
|
||||||
|
|
||||||
|
CommandLineParser parser = new DefaultParser();
|
||||||
|
HelpFormatter formatter = new HelpFormatter();
|
||||||
|
CommandLine cmd = parser.parse(options, args);
|
||||||
|
|
||||||
|
// set the configPath variable if the option was passed to the program
|
||||||
|
if (cmd.hasOption("configPath")) {
|
||||||
|
this.configPath = cmd.getOptionValue("configPath");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getConfigPath() {
|
||||||
|
return this.configPath;
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
@ -1,6 +1,5 @@
|
|||||||
package tech.bitgoblin.config;
|
package tech.bitgoblin.config;
|
||||||
|
|
||||||
import java.io.File;
|
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.nio.file.Path;
|
import java.nio.file.Path;
|
||||||
import java.nio.file.Paths;
|
import java.nio.file.Paths;
|
||||||
|
|||||||
@ -1,6 +1,6 @@
|
|||||||
package tech.bitgoblin.io;
|
package tech.bitgoblin.io;
|
||||||
|
|
||||||
import java.io.File;
|
import java.io.*;
|
||||||
|
|
||||||
public class IOUtils {
|
public class IOUtils {
|
||||||
|
|
||||||
@ -24,4 +24,23 @@ public class IOUtils {
|
|||||||
return path;
|
return path;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// checks to see if a file is currently locked/being written to.
|
||||||
|
public static boolean isFileLocked(File file) throws IOException {
|
||||||
|
String[] cmd = {"lsof", file.toString()};
|
||||||
|
Process process = Runtime.getRuntime().exec(cmd);
|
||||||
|
BufferedReader reader = new BufferedReader(new InputStreamReader(
|
||||||
|
process.getInputStream()));
|
||||||
|
|
||||||
|
boolean isOpen = false; // we'll change this if lsof returns that the file is open
|
||||||
|
|
||||||
|
String s;
|
||||||
|
while ((s = reader.readLine()) != null) {
|
||||||
|
if (s.endsWith(file.toString())) {
|
||||||
|
isOpen = true;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return isOpen;
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
@ -40,25 +40,21 @@ public class Repository {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// archives files in the ingest directory
|
// archives files in the ingest directory
|
||||||
public void archiveIngest(File[] sourceFiles) {
|
public void archiveFile(File sourceFile) {
|
||||||
for (File f : sourceFiles) {
|
Path filePath = Path.of(sourceFile.toString());
|
||||||
Path filePath = Path.of(f.toString());
|
String filename = filePath.getFileName().toString();
|
||||||
String filename = filePath.getFileName().toString();
|
String archivePath = Paths.get(this.archivePath, filename).toString();
|
||||||
String archivePath = Paths.get(this.archivePath, filename).toString();
|
|
||||||
|
|
||||||
try {
|
try {
|
||||||
Files.copy(filePath, Paths.get(archivePath), StandardCopyOption.COPY_ATTRIBUTES, StandardCopyOption.REPLACE_EXISTING);
|
Files.copy(filePath, Paths.get(archivePath), StandardCopyOption.COPY_ATTRIBUTES, StandardCopyOption.REPLACE_EXISTING);
|
||||||
} catch (IOException e) {
|
} catch (IOException e) {
|
||||||
throw new RuntimeException(e);
|
throw new RuntimeException(e);
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// clean up the ingest directory once we're done
|
// clean up the ingest directory once we're done
|
||||||
public void cleanupIngest(File[] sourceFiles) {
|
public void cleanupFile(File sourceFile) {
|
||||||
for (File f : sourceFiles) {
|
sourceFile.delete();
|
||||||
f.delete();
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// returns the repository's path
|
// returns the repository's path
|
||||||
|
|||||||
@ -1,5 +1,6 @@
|
|||||||
package tech.bitgoblin.transcoder;
|
package tech.bitgoblin.transcoder;
|
||||||
|
|
||||||
|
import java.io.IOException;
|
||||||
import java.util.TimerTask;
|
import java.util.TimerTask;
|
||||||
|
|
||||||
public class RunTranscoderTask extends TimerTask {
|
public class RunTranscoderTask extends TimerTask {
|
||||||
@ -13,7 +14,11 @@ public class RunTranscoderTask extends TimerTask {
|
|||||||
@Override
|
@Override
|
||||||
public void run() {
|
public void run() {
|
||||||
// archive the files
|
// archive the files
|
||||||
transcoder.run();
|
try {
|
||||||
|
transcoder.run();
|
||||||
|
} catch (IOException e) {
|
||||||
|
throw new RuntimeException(e);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
@ -4,11 +4,7 @@ import java.io.File;
|
|||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.lang.InterruptedException;
|
import java.lang.InterruptedException;
|
||||||
import java.lang.Process;
|
import java.lang.Process;
|
||||||
import java.nio.file.Files;
|
|
||||||
import java.nio.file.Path;
|
|
||||||
import java.nio.file.Paths;
|
import java.nio.file.Paths;
|
||||||
import java.nio.file.StandardCopyOption;
|
|
||||||
import java.util.Timer;
|
|
||||||
|
|
||||||
import tech.bitgoblin.Logger;
|
import tech.bitgoblin.Logger;
|
||||||
import tech.bitgoblin.config.Config;
|
import tech.bitgoblin.config.Config;
|
||||||
@ -31,54 +27,29 @@ public class Transcoder {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// create a periodic timer task and start it
|
// create a periodic timer task and start it
|
||||||
public void run() {
|
public void run() throws IOException {
|
||||||
// pull list of files to transcode
|
// pull list of files to transcode
|
||||||
File[] sourceFiles = this.repo.searchIngest();
|
File[] sourceFiles = this.repo.searchIngest();
|
||||||
|
|
||||||
// archive files
|
// check if we have anything to process
|
||||||
this.repo.archiveIngest(sourceFiles);
|
|
||||||
// transcode files
|
|
||||||
this.transcode(sourceFiles);
|
|
||||||
// cleanup old files
|
|
||||||
this.repo.cleanupIngest(sourceFiles);
|
|
||||||
}
|
|
||||||
|
|
||||||
// transcode files in the working directory
|
|
||||||
public void transcode(File[] sourceFiles) {
|
|
||||||
// check if the ingest directory is empty
|
|
||||||
if (sourceFiles.length == 0) {
|
if (sourceFiles.length == 0) {
|
||||||
Logger.logger.info("There is nothing to transcode in ingest.");
|
Logger.logger.info("There is nothing in ingest, skipping transcode run.");
|
||||||
return;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// transcode
|
// loop through each file
|
||||||
Logger.logger.info("Transcoding video files ingest...");
|
for (File sf : sourceFiles) {
|
||||||
for (File f : sourceFiles) {
|
// check if the file is open before attempting to transcode it
|
||||||
String filePath = f.toString().substring(0, f.toString().lastIndexOf("."));
|
if (IOUtils.isFileLocked(sf)) {
|
||||||
String filename = Paths.get(filePath).getFileName().toString();
|
Logger.logger.info(String.format("Skipping %s because it is open in another program.", sf.toString()));
|
||||||
String outputPath = Paths.get(this.repo.getOutputPath(), String.format("%s.mov", filename)).toString();
|
continue;
|
||||||
|
|
||||||
String cmd = String.format("%s -i %s -y -f %s -c:v %s -vf %s -profile:v %s -c:a %s %s",
|
|
||||||
this.ffmpeg_path, // FFMPEG binary path
|
|
||||||
f.toString(), // input file
|
|
||||||
this.config.getString("transcoder.video_format"), // video container format
|
|
||||||
this.config.getString("transcoder.video_codec"), // video codec
|
|
||||||
this.config.getString("transcoder.video_parameters"), // video format
|
|
||||||
this.config.getString("transcoder.video_profile"), // video profile
|
|
||||||
this.config.getString("transcoder.audio_codec"), // audio codec
|
|
||||||
outputPath // output file path
|
|
||||||
);
|
|
||||||
|
|
||||||
ProcessBuilder pb = new ProcessBuilder(cmd.split("\\s+"));
|
|
||||||
pb.inheritIO(); // use the java processes' input and output streams
|
|
||||||
try {
|
|
||||||
Process process = pb.start();
|
|
||||||
int ret = process.waitFor();
|
|
||||||
Logger.logger.info("Program exited with code: %d", ret);
|
|
||||||
Logger.logger.info("");
|
|
||||||
} catch (IOException | InterruptedException e) {
|
|
||||||
throw new RuntimeException(e);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// archive files
|
||||||
|
this.repo.archiveFile(sf);
|
||||||
|
// transcode files
|
||||||
|
this.transcodeFile(sf);
|
||||||
|
// cleanup old files
|
||||||
|
this.repo.cleanupFile(sf);
|
||||||
}
|
}
|
||||||
|
|
||||||
// end output
|
// end output
|
||||||
@ -86,4 +57,33 @@ public class Transcoder {
|
|||||||
Logger.logger.info("");
|
Logger.logger.info("");
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// transcode files in the working directory
|
||||||
|
public void transcodeFile(File sourceFile) throws IOException {
|
||||||
|
String filePath = sourceFile.toString().substring(0, sourceFile.toString().lastIndexOf("."));
|
||||||
|
String filename = Paths.get(filePath).getFileName().toString();
|
||||||
|
String outputPath = Paths.get(this.repo.getOutputPath(), String.format("%s.mov", filename)).toString();
|
||||||
|
|
||||||
|
String cmd = String.format("%s -i %s -y -f %s -c:v %s -vf %s -profile:v %s -c:a %s %s",
|
||||||
|
this.ffmpeg_path, // FFMPEG binary path
|
||||||
|
sourceFile.toString(), // input file
|
||||||
|
this.config.getString("transcoder.video_format"), // video container format
|
||||||
|
this.config.getString("transcoder.video_codec"), // video codec
|
||||||
|
this.config.getString("transcoder.video_parameters"), // video format
|
||||||
|
this.config.getString("transcoder.video_profile"), // video profile
|
||||||
|
this.config.getString("transcoder.audio_codec"), // audio codec
|
||||||
|
outputPath // output file path
|
||||||
|
);
|
||||||
|
|
||||||
|
ProcessBuilder pb = new ProcessBuilder(cmd.split("\\s+"));
|
||||||
|
pb.inheritIO(); // use the java processes' input and output streams
|
||||||
|
try {
|
||||||
|
Process process = pb.start();
|
||||||
|
int ret = process.waitFor();
|
||||||
|
Logger.logger.info(String.format("Program exited with code: %d", ret));
|
||||||
|
Logger.logger.info("");
|
||||||
|
} catch (IOException | InterruptedException e) {
|
||||||
|
throw new RuntimeException(e);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
BIN
src/main/resources/icon.gif
Normal file
BIN
src/main/resources/icon.gif
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 52 KiB |
17
src/test/java/tech/bitgoblin/config/CmdTest.java
Normal file
17
src/test/java/tech/bitgoblin/config/CmdTest.java
Normal file
@ -0,0 +1,17 @@
|
|||||||
|
package tech.bitgoblin.config;
|
||||||
|
|
||||||
|
import static org.junit.Assert.assertTrue;
|
||||||
|
|
||||||
|
import org.junit.Test;
|
||||||
|
|
||||||
|
import org.apache.commons.cli.ParseException;
|
||||||
|
|
||||||
|
public class CmdTest {
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void shouldDefaultToEtc() throws ParseException {
|
||||||
|
Cmd cmd = new Cmd(new String[]{});
|
||||||
|
assertTrue(cmd.getConfigPath().equals("/etc/dragoon/config.toml"));
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
@ -1,15 +1,20 @@
|
|||||||
package tech.bitgoblin.io;
|
package tech.bitgoblin.io;
|
||||||
|
|
||||||
|
import static org.junit.Assert.assertFalse;
|
||||||
import static org.junit.Assert.assertTrue;
|
import static org.junit.Assert.assertTrue;
|
||||||
|
|
||||||
import org.junit.AfterClass;
|
import org.junit.AfterClass;
|
||||||
|
import org.junit.BeforeClass;
|
||||||
import org.junit.Test;
|
import org.junit.Test;
|
||||||
|
|
||||||
import java.io.File;
|
import java.io.File;
|
||||||
|
import java.io.IOException;
|
||||||
|
import java.io.RandomAccessFile;
|
||||||
|
|
||||||
public class IOUtilsTest {
|
public class IOUtilsTest {
|
||||||
|
|
||||||
private static String testDir = "test-temp";
|
private static String testDir = "test-temp";
|
||||||
|
private static String testFile = "test.txt";
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
public void shouldCreateDirectory() {
|
public void shouldCreateDirectory() {
|
||||||
@ -28,9 +33,31 @@ public class IOUtilsTest {
|
|||||||
IOUtils.resolveTilda("~test");
|
IOUtils.resolveTilda("~test");
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void fileShouldBeLocked() throws IOException {
|
||||||
|
RandomAccessFile raf = new RandomAccessFile(testFile, "rw");
|
||||||
|
assertTrue(IOUtils.isFileLocked(new File(testFile)));
|
||||||
|
raf.close();
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void fileShouldNotBeLocked() throws IOException {
|
||||||
|
RandomAccessFile raf = new RandomAccessFile("test.txt", "rw");
|
||||||
|
raf.close();
|
||||||
|
assertFalse(IOUtils.isFileLocked(new File(testFile)));
|
||||||
|
}
|
||||||
|
|
||||||
|
@BeforeClass
|
||||||
|
// ensure that test files are created before running tests
|
||||||
|
public static void setup() throws IOException {
|
||||||
|
new File(testFile).createNewFile();
|
||||||
|
}
|
||||||
|
|
||||||
@AfterClass
|
@AfterClass
|
||||||
|
// ensure test files are cleaned up from the environment
|
||||||
public static void cleanup() {
|
public static void cleanup() {
|
||||||
new File(testDir).delete();
|
new File(testDir).delete();
|
||||||
|
new File(testFile).delete();
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user