Skip to content

feat(agent/agentcontainers): add file watcher and dirty status #17573

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 23 commits into from
Apr 29, 2025
+909 −47
Merged

feat(agent/agentcontainers): add file watcher and dirty status #17573

Changes from 1 commit
Commits
Show all changes
23 commits
Select commit Hold shift + click to select a range
40c8de9
feat(agent/agentcontainers): add file watcher and dirty status
mafredri Apr 28, 2025
a997f82
make gen
mafredri Apr 28, 2025
0e568fb
fix copilot nits
mafredri Apr 28, 2025
4f788d9
log event string in case not write
mafredri Apr 28, 2025
bfeb1da
fix chmod on macos
mafredri Apr 28, 2025
45a978c
fix close of closed channel
mafredri Apr 28, 2025
d2721a7
add close protection to fsnotify watcher as well
mafredri Apr 28, 2025
c03bb7d
fix typo
mafredri Apr 28, 2025
aed7c30
fix pr suggestions and improve start loop
mafredri Apr 28, 2025
39526e6
update noop impl.
mafredri Apr 28, 2025
7edee90
s/file/path
mafredri Apr 28, 2025
9cf5415
rewrite watcher impl. to watch dirs
mafredri Apr 28, 2025
de2a42e
add rename and create to fsnotify test
mafredri Apr 28, 2025
0cbee38
add atomic file replacement
mafredri Apr 28, 2025
5ced7e1
add paranoid reset
mafredri Apr 28, 2025
5a96a55
fix oopsie
mafredri Apr 28, 2025
0b16448
s/ErrWatcherClosed/ErrClosed/g
mafredri Apr 28, 2025
eaf5922
inverse continue/return for clarity
mafredri Apr 28, 2025
617fed2
better close handling
mafredri Apr 28, 2025
8ee9914
restore removed comment
mafredri Apr 28, 2025
263c683
add note about name
mafredri Apr 28, 2025
58a70e8
fix test setup/clock advancement
mafredri Apr 28, 2025
9f739ca
outdent
mafredri Apr 28, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
add rename and create to fsnotify test
  • Loading branch information
@mafredri
mafredri committed Apr 28, 2025
commit de2a42e0ffcdc7ad99ea1e9c7040afe79be177ab
39 changes: 37 additions & 2 deletions agent/agentcontainers/watcher/watcher_test.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -44,15 +44,50 @@ func TestFSNotifyWatcher(t *testing.T) {
require.NoError(t, err, "next event failed")

require.NotNil(t, event, "want non-nil event")
if event.Has(fsnotify.Chmod) && !event.Has(fsnotify.Write) {
// Ignore plain chmod events.
if !event.Has(fsnotify.Write) {
t.Logf("Ignoring event: %s", event)
continue
}
require.Truef(t, event.Has(fsnotify.Write), "want write event: %s", event.String())
require.Equal(t, event.Name, testFile, "want event for test file")
break
}

// Rename the test file to trigger a rename event.
err = os.Rename(testFile, testFile+".bak")
require.NoError(t, err, "rename test file failed")

// Verify that we receive the event we want.
for {
event, err := wut.Next(ctx)
require.NoError(t, err, "next event failed")
require.NotNil(t, event, "want non-nil event")
if !event.Has(fsnotify.Rename) {
t.Logf("Ignoring event: %s", event)
continue
}
require.Truef(t, event.Has(fsnotify.Rename), "want rename event: %s", event.String())
require.Equal(t, event.Name, testFile, "want event for test file")
break
}

err = os.WriteFile(testFile, []byte(`{"test": "new"}`), 0o600)
require.NoError(t, err, "write new test file failed")

// Verify that we receive the event we want.
for {
event, err := wut.Next(ctx)
require.NoError(t, err, "next event failed")
require.NotNil(t, event, "want non-nil event")
if !event.Has(fsnotify.Create) {
t.Logf("Ignoring event: %s", event)
continue
}
require.Truef(t, event.Has(fsnotify.Create), "want create event: %s", event.String())
require.Equal(t, event.Name, testFile, "want event for test file")
break
}

// Test removing the file from the watcher.
err = wut.Remove(testFile)
require.NoError(t, err, "remove file from watcher failed")
Expand Down