Add container

Dockerfile

@@ -0,0 +1,25 @@
+FROM golang:1.21 AS build-stage
+
+WORKDIR /app
+
+COPY go.mod go.sum .
+RUN go mod download
+
+COPY . .
+
+RUN apt-get update && \
+    apt-get upgrade -y
+
+RUN apt-get install -y build-essential make
+
+RUN make build
+
+FROM gcr.io/distroless/base-debian12 AS build-release-stage
+
+WORKDIR /
+
+COPY --from=build-stage /app/upstream-watch /app/upstream-watch
+
+USER nonroot:nonroot
+
+ENTRYPOINT ["/app/upstream-watch", "/workdir"]

Makefile

@@ -22,3 +22,5 @@ testcoverage:
 	$(GOTEST) -coverprofile coverage.out ./... && go tool cover -html=coverage.out && rm coverage.out
 lint:
 	staticcheck -f stylish github.com/andresterba/upstream-watch/...
+containerize:
+	docker build -t upstream-watch:test .

README.md

@@ -8,7 +8,7 @@ git repository.
 There are two different modes:
 
 - single directory
-- Subdiretorie per service
+- Subdirectories per service
 
 ## Single directory
 

cmd/main.go

@@ -1,8 +1,11 @@
 package main
 
 import (
+	"fmt"
 	"log"
+	"os"
 	"os/exec"
+	"path"
 	"time"
 
 	"github.com/andresterba/upstream-watch/internal/config"
@@ -20,11 +23,11 @@ func pullUpstreamRepository() {
 	log.Print("Successfully pulled upstream repository")
 }
 
-func updateSubdirectories(loadedConfig *config.Config, db updater.Database) {
+func updateSubdirectories(runPath string, loadedConfig *config.Config, db updater.Database) {
 	pullUpstreamRepository()
 
 	ds := files.NewDirectoryScanner(loadedConfig.IgnoreFolders)
-	directories, err := ds.ListDirectories()
+	directories, err := ds.ListDirectories(runPath)
 	if err != nil {
 		log.Fatalf("failed to list directories\n%s\n", err)
 	}
@@ -55,10 +58,10 @@ func updateSubdirectories(loadedConfig *config.Config, db updater.Database) {
 	<-time.After(loadedConfig.RetryInterval * time.Second)
 }
 
-func updateRootRepository(loadedConfig *config.Config, db updater.Database) {
+func updateRootRepository(runPath string, loadedConfig *config.Config, db updater.Database) {
 	pullUpstreamRepository()
 
-	subdirectory := "."
+	subdirectory := path.Join(runPath, "/")
 	updateConfig, err := config.GetUpdateConfig(subdirectory + "/.update-hooks.yaml")
 	if err != nil {
 		log.Printf("Failed to update root: %+v", err)
@@ -81,9 +84,21 @@ func updateRootRepository(loadedConfig *config.Config, db updater.Database) {
 	<-time.After(loadedConfig.RetryInterval * time.Second)
 }
 
+const configName = ".upstream-watch.yaml"
+
 func main() {
+	args := os.Args
+	if len(args) != 2 {
+		fmt.Printf("Please provide specify the directory to run in as arg.\n")
+		os.Exit(0)
+	}
+
+	runPath := os.Args[1]
+
+	pathToConfig := path.Join(runPath, configName)
+
 	for {
-		loadedConfig, err := config.GetConfig(".upstream-watch.yaml")
+		loadedConfig, err := config.GetConfig(pathToConfig)
 		if err != nil {
 			log.Fatal(err)
 		}
@@ -94,10 +109,10 @@ func main() {
 
 		switch rootDirectoryeMode {
 		case true:
-			updateRootRepository(loadedConfig, updateDb)
+			updateRootRepository(runPath, loadedConfig, updateDb)
 
 		case false:
-			updateSubdirectories(loadedConfig, updateDb)
+			updateSubdirectories(runPath, loadedConfig, updateDb)
 		}
 	}
 }

internal/files/files.go

@@ -23,9 +23,9 @@ func NewDirectoryScanner(directoriesToIgnore []string) *DirectoryScanner {
 	}
 }
 
-func (ds *DirectoryScanner) ListDirectories() ([]string, error) {
+func (ds *DirectoryScanner) ListDirectories(runPath string) ([]string, error) {
 	subdirectories := []string{}
-	entries, err := os.ReadDir(".")
+	entries, err := os.ReadDir(runPath)
 	if err != nil {
 		return nil, fmt.Errorf("failed to list directories %v", err)
 	}

internal/files/files_test.go

@@ -74,7 +74,7 @@ func TestDirectoryScanner_ListDirectories(t *testing.T) {
 			ds := &DirectoryScanner{
 				directoriesToIgnore: tt.fields.directoriesToIgnore,
 			}
-			got, err := ds.ListDirectories()
+			got, err := ds.ListDirectories(".")
 			if (err != nil) != tt.wantErr {
 				t.Errorf("DirectoryScanner.ListDirectories() error = %v, wantErr %v", err, tt.wantErr)
 				return