mirror of
https://github.com/go-task/task.git
synced 2025-05-13 22:16:31 +02:00
ffeb3bcc3f
* refactor: executor functional options * refactor: minor tidy up of list code * fix: WithVersionCheck missing from call to NewExecutor * feat: docstrings for structs with functional options * refactor: prefix the functional options with the name of the struct they belong to
101 lines
2.0 KiB
Go
101 lines
2.0 KiB
Go
//go:build watch
|
|
// +build watch
|
|
|
|
package task_test
|
|
|
|
import (
|
|
"bytes"
|
|
"context"
|
|
"fmt"
|
|
"os"
|
|
"strings"
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/stretchr/testify/assert"
|
|
"github.com/stretchr/testify/require"
|
|
|
|
"github.com/go-task/task/v3"
|
|
"github.com/go-task/task/v3/internal/filepathext"
|
|
"github.com/go-task/task/v3/taskfile/ast"
|
|
)
|
|
|
|
func TestFileWatcherInterval(t *testing.T) {
|
|
const dir = "testdata/watcher_interval"
|
|
expectedOutput := strings.TrimSpace(`
|
|
task: Started watching for tasks: default
|
|
task: [default] echo "Hello, World!"
|
|
Hello, World!
|
|
task: [default] echo "Hello, World!"
|
|
Hello, World!
|
|
`)
|
|
|
|
var buff bytes.Buffer
|
|
e := &task.NewExecutor(
|
|
task.WithDir(dir),
|
|
task.WithStdout(&buff),
|
|
task.WithStderr(&buff),
|
|
task.WithWatch(true),
|
|
)
|
|
|
|
require.NoError(t, e.Setup())
|
|
buff.Reset()
|
|
|
|
err := os.MkdirAll(filepathext.SmartJoin(dir, "src"), 0755)
|
|
require.NoError(t, err)
|
|
|
|
err = os.WriteFile(filepathext.SmartJoin(dir, "src/a"), []byte("test"), 0644)
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
|
|
ctx := context.Background()
|
|
ctx, cancel := context.WithCancel(ctx)
|
|
|
|
go func(ctx context.Context) {
|
|
for {
|
|
select {
|
|
case <-ctx.Done():
|
|
return
|
|
default:
|
|
err := e.Run(ctx, &ast.Call{Task: "default"})
|
|
if err != nil {
|
|
return
|
|
}
|
|
}
|
|
}
|
|
}(ctx)
|
|
|
|
time.Sleep(10 * time.Millisecond)
|
|
err = os.WriteFile(filepathext.SmartJoin(dir, "src/a"), []byte("test updated"), 0644)
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
time.Sleep(700 * time.Millisecond)
|
|
cancel()
|
|
assert.Equal(t, expectedOutput, strings.TrimSpace(buff.String()))
|
|
buff.Reset()
|
|
err = os.RemoveAll(filepathext.SmartJoin(dir, ".task"))
|
|
require.NoError(t, err)
|
|
err = os.RemoveAll(filepathext.SmartJoin(dir, "src"))
|
|
require.NoError(t, err)
|
|
}
|
|
|
|
func TestShouldIgnoreFile(t *testing.T) {
|
|
tt := []struct {
|
|
path string
|
|
expect bool
|
|
}{
|
|
{"/.git/hooks", true},
|
|
{"/.github/workflows/build.yaml", false},
|
|
}
|
|
|
|
for k, ct := range tt {
|
|
ct := ct
|
|
t.Run(fmt.Sprintf("ignore - %d", k), func(t *testing.T) {
|
|
t.Parallel()
|
|
require.Equal(t, task.ShouldIgnoreFile(ct.path), ct.expect)
|
|
})
|
|
}
|
|
}
|