Add a filesystem monitoring option for the snapshot paths command

bin/flyio_env_report.sh

@@ -5,6 +5,8 @@ SCRIPT_NAME=flyio_env_report.sh
 USAGE="$SCRIPT_NAME [options] <protocol://hostname> <owner> <environment-name>"
 
 
+
+
 die()
 {
     echo "Error: $1" >&2

cmd/kosli/root.go

@@ -207,6 +207,7 @@ The service principal needs to have the following permissions:
 	setTagsFlag                          = "[optional] The key-value pairs to tag the resource with. The format is: key=value"
 	unsetTagsFlag                        = "[optional] The list of tag keys to remove from the resource."
 	pathsSpecFileFlag                    = "The path to a paths file in YAML/JSON/TOML format. Cannot be used together with --path ."
+	pathsWatchFlag                       = "[optional] Watch the filesystem for changes and report snapshots of artifacts running in specific filesystem paths to Kosli."
 	snapshotPathPathFlag                 = "The base path for the artifact to snapshot."
 	snapshotPathExcludeFlag              = "[optional] The comma-separated list of literal paths or glob patterns to exclude when fingerprinting the artifact."
 	snapshotPathArtifactNameFlag         = "The reported name of the artifact."

cmd/kosli/snapshotPaths.go

@@ -3,10 +3,12 @@ package main
 import (
 	"fmt"
 	"io"
+	"log"
 	"net/http"
 	"path/filepath"
 	"strings"
 
+	"github.com/fsnotify/fsnotify"
 	"github.com/go-playground/validator/v10"
 	"github.com/kosli-dev/cli/internal/requests"
 	"github.com/kosli-dev/cli/internal/server"
@@ -52,6 +54,7 @@ kosli snapshot paths yourEnvironmentName \
 
 type snapshotPathsOptions struct {
 	pathSpecFile string
+	watch        bool
 }
 
 func newSnapshotPathsCmd(out io.Writer) *cobra.Command {
@@ -76,6 +79,8 @@ func newSnapshotPathsCmd(out io.Writer) *cobra.Command {
 	}
 
 	cmd.Flags().StringVar(&o.pathSpecFile, "paths-file", "", pathsSpecFileFlag)
+	cmd.Flags().BoolVar(&o.watch, "watch", false, pathsWatchFlag)
+
 	addDryRunFlag(cmd)
 
 	if err := RequireFlags(cmd, []string{"paths-file"}); err != nil {
@@ -96,10 +101,26 @@ func (o *snapshotPathsOptions) run(args []string) error {
 		return err
 	}
 
+	// snapshot the paths
+	if o.watch {
+		err := reportArtifacts(ps, url, envName)
+		if err != nil {
+			return err
+		}
+
+		watch_for_changes(ps, url, envName)
+	}
+
+	return reportArtifacts(ps, url, envName)
+}
+
+func reportArtifacts(ps *server.PathsSpec, url string, envName string) error {
+
 	artifacts, err := server.CreatePathsArtifactsData(ps, logger)
 	if err != nil {
 		return err
 	}
+
 	payload := &server.ServerEnvRequest{
 		Artifacts: artifacts,
 	}
@@ -118,6 +139,38 @@ func (o *snapshotPathsOptions) run(args []string) error {
 	return err
 }
 
+func watch_for_changes(ps *server.PathsSpec, url string, envName string) bool {
+	watcher, err := fsnotify.NewWatcher()
+	if err != nil {
+		log.Fatal(err)
+	}
+	defer watcher.Close()
+
+	// Add every path in path spec to watcher
+	for _, pathSpec := range ps.Artifacts {
+		if err := watcher.Add(pathSpec.Path); err != nil {
+			logger.Error("failed to watch dir: %v", err)
+		}
+	}
+
+	for {
+		select {
+		case event := <-watcher.Events:
+			logger.Debug("Event: " + event.String())
+
+			if event.Op != fsnotify.Chmod {
+				err := reportArtifacts(ps, url, envName)
+				if err != nil {
+					logger.Error("failed to report artifacts: %v", err)
+				}
+			}
+
+		case err := <-watcher.Errors:
+			logger.Debug("Error: ", err)
+		}
+	}
+}
+
 func processPathSpecFile(pathsSpecFile string) (*server.PathsSpec, error) {
 	var ps *server.PathsSpec
 	v := viper.New()

go.mod

@@ -17,6 +17,7 @@ require (
 	github.com/aws/aws-sdk-go-v2/service/s3 v1.31.0
 	github.com/aws/smithy-go v1.13.5
 	github.com/docker/docker v24.0.9+incompatible
+	github.com/fsnotify/fsnotify v1.7.0
 	github.com/go-git/go-billy/v5 v5.5.0
 	github.com/go-git/go-git/v5 v5.11.0
 	github.com/go-playground/validator/v10 v10.19.0
@@ -91,7 +92,6 @@ require (
 	github.com/evanphx/json-patch/v5 v5.2.0 // indirect
 	github.com/fatih/structs v1.1.0 // indirect
 	github.com/felixge/httpsnoop v1.0.3 // indirect
-	github.com/fsnotify/fsnotify v1.7.0 // indirect
 	github.com/gabriel-vasile/mimetype v1.4.3 // indirect
 	github.com/go-git/gcfg v1.5.1-0.20230307220236-3a3c6141e376 // indirect
 	github.com/go-logr/logr v1.4.1 // indirect

kosli-paths.yaml

@@ -0,0 +1,6 @@
+version: 1
+artifacts:
+  service-a:
+    path: bin/
+  service-b:
+    path: hack/