73 lines
1.6 KiB
Go
73 lines
1.6 KiB
Go
package pebble
|
|
|
|
import (
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/hybridgroup/gobot"
|
|
"github.com/hybridgroup/gobot/gobottest"
|
|
)
|
|
|
|
var _ gobot.Driver = (*PebbleDriver)(nil)
|
|
|
|
func initTestPebbleDriver() *PebbleDriver {
|
|
return NewPebbleDriver(NewPebbleAdaptor("adaptor"), "pebble")
|
|
}
|
|
|
|
func TestPebbleDriverStart(t *testing.T) {
|
|
d := initTestPebbleDriver()
|
|
gobottest.Assert(t, len(d.Start()), 0)
|
|
}
|
|
|
|
func TestPebbleDriverHalt(t *testing.T) {
|
|
d := initTestPebbleDriver()
|
|
gobottest.Assert(t, len(d.Halt()), 0)
|
|
}
|
|
|
|
func TestPebbleDriver(t *testing.T) {
|
|
d := initTestPebbleDriver()
|
|
|
|
gobottest.Assert(t, d.Name(), "pebble")
|
|
gobottest.Assert(t, d.Connection().Name(), "adaptor")
|
|
|
|
sem := make(chan bool)
|
|
d.SendNotification("Hello")
|
|
d.SendNotification("World")
|
|
|
|
gobottest.Assert(t, d.Messages[0], "Hello")
|
|
gobottest.Assert(t, d.PendingMessage(), "Hello")
|
|
gobottest.Assert(t, d.PendingMessage(), "World")
|
|
gobottest.Assert(t, d.PendingMessage(), "")
|
|
|
|
d.On(d.Event("button"), func(data interface{}) {
|
|
sem <- true
|
|
})
|
|
|
|
d.PublishEvent("button", "")
|
|
|
|
select {
|
|
case <-sem:
|
|
case <-time.After(100 * time.Millisecond):
|
|
t.Errorf("Button Event was not published")
|
|
}
|
|
|
|
d.On(d.Event("accel"), func(data interface{}) {
|
|
sem <- true
|
|
})
|
|
|
|
d.Command("publish_event")(map[string]interface{}{"name": "accel", "data": "100"})
|
|
|
|
select {
|
|
case <-sem:
|
|
case <-time.After(100 * time.Millisecond):
|
|
t.Errorf("Accel Event was not published")
|
|
}
|
|
|
|
d.Command("send_notification")(map[string]interface{}{"message": "Hey buddy!"})
|
|
gobottest.Assert(t, d.Messages[0], "Hey buddy!")
|
|
|
|
message := d.Command("pending_message")(map[string]interface{}{})
|
|
gobottest.Assert(t, message, "Hey buddy!")
|
|
|
|
}
|