Added a quick and dirty file open check

.woodpecker.yml

@@ -6,6 +6,11 @@ pipeline:
       - GOOS=linux GOARCH=amd64 go build -o "dist/adept-linux-amd64-${CI_COMMIT_TAG}"
       - GOOS=windows GOARCH=amd64 go build -o "dist/adept-windows-amd64-${CI_COMMIT_TAG}.exe"
 
+  test:
+    image: golang:1.16
+    commands:
+      - go test -v ./...
+
   gitea_release:
     image: plugins/gitea-release
     settings:

Makefile

@@ -0,0 +1,17 @@
+BINARY_NAME=adept
+
+all: build test
+
+build:
+	go build -o ${BINARY_NAME} adept.go
+
+test:
+	go test -v ./...
+
+run:
+	go build -o ${BINARY_NAME} adept.go
+	./${BINARY_NAME}
+ 
+clean:
+	go clean
+	rm ${BINARY_NAME}

adept.go

@@ -1,12 +1,15 @@
 package main
 
 import (
+  "log"
+  "path/filepath"
   "time"
 
   "github.com/spf13/viper"
 
   "git.metaunix.net/BitGoblin/adept/config"
   "git.metaunix.net/BitGoblin/adept/transcoder"
+  "git.metaunix.net/BitGoblin/adept/util"
 )
 
 func main() {
@@ -18,7 +21,16 @@ func main() {
   for {
     ingestFiles := r.SearchIngest()
 
+    if len(ingestFiles) < 1 {
+      log.Println("There were no files found in ingest to transcode; skipping run.")
+    } else {
       for _, i := range ingestFiles {
+        // check if the file is open in another program (e.g. still being written to)
+        if util.IsFileLocked(filepath.Join(viper.GetString("transcoder.repository"), "ingest", i.Name())) {
+          log.Printf("%s appears to be open in another program; skipping it for this run.", i.Name())
+          continue
+        }
+
         // archive file
         r.ArchiveFile(i.Name())
         // transcode file
@@ -26,6 +38,7 @@ func main() {
         // clean up source file
         r.CleanupFile(i.Name())
       }
+    }
 
     // sleep for X minutes - specified in the adept.toml config file
     interval := viper.GetInt("transcoder.interval")

util/env_test.go

@@ -0,0 +1,19 @@
+package util
+
+import "testing"
+
+func TestResolveTilde(t *testing.T) {
+	resolvedPath := ResolveTilde("~")
+
+	if resolvedPath == "~" {
+		t.Logf("ResolveTilde returned '%s'; it should have expanded to an absolute path.", resolvedPath)
+	}
+}
+
+func TestResolveTildePath(t *testing.T) {
+	resolvedPath := ResolveTilde("~/test")
+
+	if resolvedPath == "~/test" {
+		t.Logf("ResolveTilde returned '%s'; it should have expanded to an absolute path.", resolvedPath)
+	}
+}

util/file.go

@@ -1,6 +1,7 @@
 package util
 
 import (
+  "os/exec"
   "path"
   "strings"
 )
@@ -8,3 +9,14 @@ import (
 func FilenameWithoutExtension(filename string) string {
   return strings.TrimSuffix(filename, path.Ext(filename))
 }
+
+func IsFileLocked(filepath string) bool {
+  cmd := exec.Command("/usr/bin/lsof", filepath)
+  stdout, _ := cmd.Output()
+
+  if strings.Contains(string(stdout), filepath) {
+    return true
+  }
+
+  return false
+}

util/file_test.go

@@ -0,0 +1,11 @@
+package util
+
+import "testing"
+
+func TestFilenameWithoutExtension(t *testing.T) {
+	filename := FilenameWithoutExtension("testfile.txt")
+
+	if filename != "testfile" {
+		t.Logf("FilenameWithoutExtension returned '%s'; it should be 'testfile'.", filename)
+	}
+}