mirror of
https://github.com/anchore/syft.git
synced 2025-11-17 16:33:21 +01:00
* generalize ui events for cataloging tasks Signed-off-by: Alex Goodman <wagoodman@users.noreply.github.com> * moderate review comments Signed-off-by: Alex Goodman <wagoodman@users.noreply.github.com> * incorporate review comments Signed-off-by: Alex Goodman <wagoodman@users.noreply.github.com> * rename cataloger task progress object Signed-off-by: Alex Goodman <wagoodman@users.noreply.github.com> * migrate cataloger task fn to bus helper Signed-off-by: Alex Goodman <wagoodman@users.noreply.github.com> --------- Signed-off-by: Alex Goodman <wagoodman@users.noreply.github.com>
103 lines
2.0 KiB
Go
103 lines
2.0 KiB
Go
package ui
|
|
|
|
import (
|
|
"testing"
|
|
"time"
|
|
|
|
tea "github.com/charmbracelet/bubbletea"
|
|
"github.com/gkampitakis/go-snaps/snaps"
|
|
"github.com/stretchr/testify/require"
|
|
"github.com/wagoodman/go-partybus"
|
|
"github.com/wagoodman/go-progress"
|
|
|
|
"github.com/anchore/bubbly/bubbles/taskprogress"
|
|
syftEvent "github.com/anchore/syft/syft/event"
|
|
)
|
|
|
|
func TestHandler_handleFileIndexingStarted(t *testing.T) {
|
|
|
|
tests := []struct {
|
|
name string
|
|
eventFn func(*testing.T) partybus.Event
|
|
iterations int
|
|
}{
|
|
{
|
|
name: "cataloging in progress",
|
|
eventFn: func(t *testing.T) partybus.Event {
|
|
prog := &progress.Manual{}
|
|
prog.SetTotal(100)
|
|
prog.Set(50)
|
|
|
|
mon := struct {
|
|
progress.Progressable
|
|
progress.Stager
|
|
}{
|
|
Progressable: prog,
|
|
Stager: &progress.Stage{
|
|
Current: "current",
|
|
},
|
|
}
|
|
|
|
return partybus.Event{
|
|
Type: syftEvent.FileIndexingStarted,
|
|
Source: "/some/path",
|
|
Value: mon,
|
|
}
|
|
},
|
|
},
|
|
{
|
|
name: "cataloging complete",
|
|
eventFn: func(t *testing.T) partybus.Event {
|
|
prog := &progress.Manual{}
|
|
prog.SetTotal(100)
|
|
prog.Set(100)
|
|
prog.SetCompleted()
|
|
|
|
mon := struct {
|
|
progress.Progressable
|
|
progress.Stager
|
|
}{
|
|
Progressable: prog,
|
|
Stager: &progress.Stage{
|
|
Current: "current",
|
|
},
|
|
}
|
|
|
|
return partybus.Event{
|
|
Type: syftEvent.FileIndexingStarted,
|
|
Source: "/some/path",
|
|
Value: mon,
|
|
}
|
|
},
|
|
},
|
|
}
|
|
for _, tt := range tests {
|
|
t.Run(tt.name, func(t *testing.T) {
|
|
event := tt.eventFn(t)
|
|
handler := New(DefaultHandlerConfig())
|
|
handler.WindowSize = tea.WindowSizeMsg{
|
|
Width: 100,
|
|
Height: 80,
|
|
}
|
|
|
|
models, _ := handler.Handle(event)
|
|
require.Len(t, models, 1)
|
|
model := models[0]
|
|
|
|
tsk, ok := model.(taskprogress.Model)
|
|
require.True(t, ok)
|
|
|
|
gotModel := runModel(t, tsk, tt.iterations, taskprogress.TickMsg{
|
|
Time: time.Now(),
|
|
Sequence: tsk.Sequence(),
|
|
ID: tsk.ID(),
|
|
})
|
|
|
|
got := gotModel.View()
|
|
|
|
t.Log(got)
|
|
snaps.MatchSnapshot(t, got)
|
|
})
|
|
}
|
|
}
|