feat: run local --watch flag

go.mod

@@ -9,6 +9,7 @@ require (
 	github.com/dustin/go-humanize v1.0.1
 	github.com/fatih/color v1.15.0
 	github.com/fatih/structs v1.1.0
+	github.com/fsnotify/fsnotify v1.7.0
 	github.com/golang/mock v1.6.0
 	github.com/google/shlex v0.0.0-20191202100458-e7afc7fbc510
 	github.com/google/uuid v1.4.0

go.sum

@@ -81,6 +81,8 @@ github.com/fatih/color v1.15.0 h1:kOqh6YHBtK8aywxGerMG2Eq3H6Qgoqeo13Bk2Mv/nBs=
 github.com/fatih/color v1.15.0/go.mod h1:0h5ZqXfHYED7Bhv2ZJamyIOUej9KtShiJESRwBDUSsw=
 github.com/fatih/structs v1.1.0 h1:Q7juDM0QtcnhCpeyLGQKyg4TOIghuNXrkL32pHAUMxo=
 github.com/fatih/structs v1.1.0/go.mod h1:9NiDSp5zOcgEDl+j00MP/WkGVPOlPRLejGD8Ga6PJ7M=
+github.com/fsnotify/fsnotify v1.7.0 h1:8JEhPFa5W2WU7YfeZzPNqzMP6Lwt7L2715Ggo0nosvA=
+github.com/fsnotify/fsnotify v1.7.0/go.mod h1:40Bi/Hjc2AVfZrqy+aj+yEI+/bRxZnMJyTJwOpGvigM=
 github.com/go-gl/glfw v0.0.0-20190409004039-e6da0acd62b1/go.mod h1:vR7hzQXu2zJy9AVAgeJqvqgH9Q5CA+iKCZ2gyEVpxRU=
 github.com/go-gl/glfw/v3.3/glfw v0.0.0-20191125211704-12ad95a8df72/go.mod h1:tQ2UAYgL5IevRw8kRxooKSPJfGvJ9fJQFa0TUsXzTg8=
 github.com/go-gl/glfw/v3.3/glfw v0.0.0-20200222043503-6f7a984d4dc4/go.mod h1:tQ2UAYgL5IevRw8kRxooKSPJfGvJ9fJQFa0TUsXzTg8=

internal/pkg/cli/file/filetest/watchertest.go

@@ -0,0 +1,38 @@
+// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+// SPDX-License-Identifier: Apache-2.0
+
+package filetest
+
+import "github.com/fsnotify/fsnotify"
+
+// Double is a test double for file.RecursiveWatcher
+type Double struct {
+	EventsFn func() <-chan fsnotify.Event
+	ErrorsFn func() <-chan error
+}
+
+// Add is a no-op for Double.
+func (d *Double) Add(string) error {
+	return nil
+}
+
+// Close is a no-op for Double.
+func (d *Double) Close() error {
+	return nil
+}
+
+// Events calls the stubbed function.
+func (d *Double) Events() <-chan fsnotify.Event {
+	if d.EventsFn == nil {
+		return nil
+	}
+	return d.EventsFn()
+}
+
+// Errors calls the stubbed function.
+func (d *Double) Errors() <-chan error {
+	if d.ErrorsFn == nil {
+		return nil
+	}
+	return d.ErrorsFn()
+}

internal/pkg/cli/file/hidden.go

@@ -0,0 +1,13 @@
+//go:build !windows
+
+// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+// SPDX-License-Identifier: Apache-2.0
+
+package file
+
+import "path/filepath"
+
+// IsHiddenFile returns true if the file is hidden on non-windows.
+func IsHiddenFile(filename string) (bool, error) {
+	return filepath.Base(filename)[0] == '.', nil
+}

internal/pkg/cli/file/hidden_windows.go

@@ -0,0 +1,21 @@
+// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+// SPDX-License-Identifier: Apache-2.0
+
+package file
+
+import (
+	"syscall"
+)
+
+// IsHiddenFile returns true if the file is hidden on windows.
+func IsHiddenFile(filename string) (bool, error) {
+	pointer, err := syscall.UTF16PtrFromString(filename)
+	if err != nil {
+		return false, err
+	}
+	attributes, err := syscall.GetFileAttributes(pointer)
+	if err != nil {
+		return false, err
+	}
+	return attributes&syscall.FILE_ATTRIBUTE_HIDDEN != 0, nil
+}

internal/pkg/cli/file/watch.go

@@ -0,0 +1,130 @@
+// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+// SPDX-License-Identifier: Apache-2.0
+
+package file
+
+import (
+	"io/fs"
+	"os"
+	"path/filepath"
+
+	"github.com/fsnotify/fsnotify"
+)
+
+// RecursiveWatcher wraps an fsnotify Watcher to recursively watch all files in a directory.
+type RecursiveWatcher struct {
+	fsnotifyWatcher *fsnotify.Watcher
+	done            chan struct{}
+	closed          bool
+	events          chan fsnotify.Event
+	errors          chan error
+}
+
+// NewRecursiveWatcher returns a RecursiveWatcher which notifies when changes are made to files inside a recursive directory tree.
+func NewRecursiveWatcher(dir string) (*RecursiveWatcher, error) {
+	watcher, err := fsnotify.NewWatcher()
+	if err != nil {
+		return nil, err
+	}
+
+	rw := &RecursiveWatcher{
+		events:          make(chan fsnotify.Event),
+		errors:          make(chan error),
+		fsnotifyWatcher: watcher,
+		done:            make(chan struct{}),
+		closed:          false,
+	}
+
+	go rw.start()
+
+	return rw, nil
+}
+
+// Add recursively adds a directory tree to the list of watched files.
+func (rw *RecursiveWatcher) Add(path string) error {
+	if rw.closed {
+		return fsnotify.ErrClosed
+	}
+	if err := filepath.WalkDir(path, func(path string, d fs.DirEntry, err error) error {
+		if err != nil {
+			return err
+		}
+		if d.IsDir() {
+			return rw.fsnotifyWatcher.Add(path)
+		}
+		return nil
+	}); err != nil {
+		return err
+	}
+	return nil
+}
+
+// Remove recursively removes a directory tree from the list of watched files.
+func (rw *RecursiveWatcher) Remove(path string) error {
+	if rw.closed {
+		return nil
+	}
+	if err := filepath.WalkDir(path, func(path string, d fs.DirEntry, err error) error {
+		if err != nil {
+			return err
+		}
+		if d.IsDir() {
+			return rw.fsnotifyWatcher.Remove(path)
+		}
+		return nil
+	}); err != nil {
+		return err
+	}
+	return nil
+}
+
+// Events returns the events channel.
+func (rw *RecursiveWatcher) Events() <-chan fsnotify.Event {
+	return rw.events
+}
+
+// Errors returns the errors channel.
+func (rw *RecursiveWatcher) Errors() <-chan error {
+	return rw.errors
+}
+
+// Close closes the RecursiveWatcher.
+func (rw *RecursiveWatcher) Close() error {
+	rw.closed = true
+	close(rw.done)
+	return rw.fsnotifyWatcher.Close()
+}
+
+func (rw *RecursiveWatcher) start() {
+	for {
+		select {
+		case event := <-rw.fsnotifyWatcher.Events:
+			info, err := os.Stat(event.Name)
+			if err != nil {
+				break
+			}
+			if info.IsDir() {
+				switch event.Op {
+				case fsnotify.Create:
+					err := rw.Add(event.Name)
+					if err != nil {
+						rw.errors <- err
+					}
+				case fsnotify.Remove:
+					err := rw.Remove(event.Name)
+					if err != nil {
+						rw.errors <- err
+					}
+				}
+			} else {
+				rw.events <- event
+			}
+		case err := <-rw.fsnotifyWatcher.Errors:
+			rw.errors <- err
+		case <-rw.done:
+			close(rw.events)
+			close(rw.errors)
+			return
+		}
+	}
+}

internal/pkg/cli/flag.go

@@ -70,6 +70,7 @@ const (
 	portOverrideFlag   = "port-override"
 	envVarOverrideFlag = "env-var-override"
 	proxyFlag          = "proxy"
+	watchFlag          = "watch"
 
 	// Flags for CI/CD.
 	githubURLFlag         = "github-url"
@@ -322,6 +323,7 @@ Format: [container]:KEY=VALUE. Omit container name to apply to all containers.`
 	portOverridesFlagDescription = `Optional. Override ports exposed by service. Format: <host port>:<service port>.
 Example: --port-override 5000:80 binds localhost:5000 to the service's port 80.`
 	proxyFlagDescription = `Optional. Proxy outbound requests to your environment's VPC.`
+	watchFlagDescription = `Optional. Watch changes to local files and restart containers when updated.`
 
 	svcManifestFlagDescription = `Optional. Name of the environment in which the service was deployed;
 output the manifest file used for that deployment.`