OrgGo/termdash
1
0
Fork 0
mirror of https://github.com/mum4k/termdash.git synced 2025-04-28 13:48:51 +08:00
Code Issues Projects Releases Wiki Activity

Adding a test with misbehaving receiver.

Browse Source
This commit is contained in:
Jakub Sobon 2019-02-19 00:19:23 -05:00
parent 2ffbe5be94
commit a6ea1565a7
No known key found for this signature in database
GPG Key ID: F2451A77FB05D3B7
1 changed files with 72 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

83
event/event_test.go
View File

@ -13,25 +13,47 @@ import (
"github.com/mum4k/termdash/terminalapi"
)
// receiverMode defines how the receiver behaves.
type receiverMode int
const (
// receiverModeReceive tells the receiver to process the events
receiverModeReceive receiverMode = iota
// receiverModeBlock tells the receiver to block on the call to receive.
receiverModeBlock
)
// receiver receives events from the distribution system.
type receiver struct {
mu sync.Mutex
// mode sets how the receiver behaves when receive(0 is called.
mode receiverMode
// events are the received events.
events []terminalapi.Event
}
// newReceiver returns a new event receiver.
func newReceiver() *receiver {
return &receiver{}
func newReceiver(mode receiverMode) *receiver {
return &receiver{
mode: mode,
}
}
// receive receives an event.
func (r *receiver) receive(ev terminalapi.Event) {
r.mu.Lock()
defer r.mu.Unlock()
switch r.mode {
case receiverModeBlock:
for {
}
default:
r.mu.Lock()
defer r.mu.Unlock()
r.events = append(r.events, ev)
r.events = append(r.events, ev)
}
}
// getEvents returns the received events.
@ -120,7 +142,7 @@ func TestDistributionSystem(t *testing.T) {
subCase: []*subscriberCase{
{
filter: nil,
rec: newReceiver(),
rec: newReceiver(receiverModeReceive),
want: map[terminalapi.Event]bool{
&terminalapi.Keyboard{Key: keyboard.KeyEnter}: true,
&terminalapi.Mouse{Position: image.Point{1, 1}}: true,
@ -143,7 +165,7 @@ func TestDistributionSystem(t *testing.T) {
&terminalapi.Keyboard{},
&terminalapi.Mouse{},
},
rec: newReceiver(),
rec: newReceiver(receiverModeReceive),
want: map[terminalapi.Event]bool{
&terminalapi.Keyboard{Key: keyboard.KeyEnter}: true,
&terminalapi.Mouse{Position: image.Point{1, 1}}: true,
@ -165,7 +187,7 @@ func TestDistributionSystem(t *testing.T) {
&terminalapi.Keyboard{},
&terminalapi.Mouse{},
},
rec: newReceiver(),
rec: newReceiver(receiverModeReceive),
want: map[terminalapi.Event]bool{
&terminalapi.Keyboard{Key: keyboard.KeyEnter}: true,
&terminalapi.Mouse{Position: image.Point{1, 1}}: true,
@ -191,7 +213,7 @@ func TestDistributionSystem(t *testing.T) {
filter: []terminalapi.Event{
&terminalapi.Keyboard{},
},
rec: newReceiver(),
rec: newReceiver(receiverModeReceive),
want: map[terminalapi.Event]bool{
&terminalapi.Keyboard{Key: keyboard.KeyEnter}: true,
&terminalapi.Keyboard{Key: keyboard.KeyEsc}: true,
@ -204,7 +226,7 @@ func TestDistributionSystem(t *testing.T) {
&terminalapi.Mouse{},
&terminalapi.Resize{},
},
rec: newReceiver(),
rec: newReceiver(receiverModeReceive),
want: map[terminalapi.Event]bool{
&terminalapi.Mouse{Position: image.Point{0, 0}}: true,
&terminalapi.Mouse{Position: image.Point{1, 1}}: true,
@ -216,6 +238,42 @@ func TestDistributionSystem(t *testing.T) {
},
},
},
{
desc: "a misbehaving receiver only blocks itself",
events: []terminalapi.Event{
&terminalapi.Keyboard{Key: keyboard.KeyEnter},
&terminalapi.Keyboard{Key: keyboard.KeyEsc},
terminalapi.NewError("error1"),
terminalapi.NewError("error2"),
},
subCase: []*subscriberCase{
{
filter: []terminalapi.Event{
&terminalapi.Keyboard{},
},
rec: newReceiver(receiverModeReceive),
want: map[terminalapi.Event]bool{
&terminalapi.Keyboard{Key: keyboard.KeyEnter}: true,
&terminalapi.Keyboard{Key: keyboard.KeyEsc}: true,
terminalapi.NewError("error1"): true,
terminalapi.NewError("error2"): true,
},
},
{
filter: []terminalapi.Event{
&terminalapi.Keyboard{},
},
rec: newReceiver(receiverModeBlock),
want: map[terminalapi.Event]bool{
&terminalapi.Keyboard{Key: keyboard.KeyEnter}: true,
&terminalapi.Keyboard{Key: keyboard.KeyEsc}: true,
terminalapi.NewError("error1"): true,
terminalapi.NewError("error2"): true,
},
wantErr: true,
},
},
},
}
for _, tc := range tests {
@ -232,8 +290,11 @@ func TestDistributionSystem(t *testing.T) {
for i, sc := range tc.subCase {
got, err := sc.rec.waitFor(len(sc.want), 5*time.Second)
if (err != nil) != sc.wantErr {
t.Errorf("sc.rec.waitFor[%d] => unexpected error: %v, wantErr:%v", i, err, sc.wantErr)
}
if err != nil {
t.Fatalf("sc.rec.waitFor[%d] => unexpected error: %v", i, err)
continue
}
if diff := pretty.Compare(sc.want, got); diff != "" {