80 lines
2.3 KiB
Go
80 lines
2.3 KiB
Go
package microbit
|
|
|
|
import (
|
|
"sync"
|
|
|
|
"gobot.io/x/gobot/platforms/ble"
|
|
)
|
|
|
|
var _ ble.BLEConnector = (*bleTestClientAdaptor)(nil)
|
|
|
|
type bleTestClientAdaptor struct {
|
|
name string
|
|
address string
|
|
mtx sync.Mutex
|
|
withoutResponses bool
|
|
|
|
testSubscribe func([]byte, error)
|
|
testReadCharacteristic func(string) ([]byte, error)
|
|
testWriteCharacteristic func(string, []byte) error
|
|
}
|
|
|
|
func (t *bleTestClientAdaptor) Connect() (err error) { return }
|
|
func (t *bleTestClientAdaptor) Reconnect() (err error) { return }
|
|
func (t *bleTestClientAdaptor) Disconnect() (err error) { return }
|
|
func (t *bleTestClientAdaptor) Finalize() (err error) { return }
|
|
func (t *bleTestClientAdaptor) Name() string { return t.name }
|
|
func (t *bleTestClientAdaptor) SetName(n string) { t.name = n }
|
|
func (t *bleTestClientAdaptor) Address() string { return t.address }
|
|
func (t *bleTestClientAdaptor) WithoutResponses(use bool) { t.withoutResponses = use }
|
|
|
|
func (t *bleTestClientAdaptor) ReadCharacteristic(cUUID string) (data []byte, err error) {
|
|
t.mtx.Lock()
|
|
defer t.mtx.Unlock()
|
|
return t.testReadCharacteristic(cUUID)
|
|
}
|
|
|
|
func (t *bleTestClientAdaptor) WriteCharacteristic(cUUID string, data []byte) (err error) {
|
|
t.mtx.Lock()
|
|
defer t.mtx.Unlock()
|
|
return t.testWriteCharacteristic(cUUID, data)
|
|
}
|
|
|
|
func (t *bleTestClientAdaptor) Subscribe(cUUID string, f func([]byte, error)) (err error) {
|
|
t.testSubscribe = f
|
|
return
|
|
}
|
|
|
|
func (t *bleTestClientAdaptor) TestReadCharacteristic(f func(cUUID string) (data []byte, err error)) {
|
|
t.mtx.Lock()
|
|
defer t.mtx.Unlock()
|
|
t.testReadCharacteristic = f
|
|
}
|
|
|
|
func (t *bleTestClientAdaptor) TestWriteCharacteristic(f func(cUUID string, data []byte) (err error)) {
|
|
t.mtx.Lock()
|
|
defer t.mtx.Unlock()
|
|
t.testWriteCharacteristic = f
|
|
}
|
|
|
|
func (t *bleTestClientAdaptor) TestReceiveNotification(data []byte, err error) {
|
|
t.mtx.Lock()
|
|
defer t.mtx.Unlock()
|
|
t.testSubscribe(data, err)
|
|
}
|
|
|
|
func NewBleTestAdaptor() *bleTestClientAdaptor {
|
|
return &bleTestClientAdaptor{
|
|
address: "01:02:03:04:05:06",
|
|
testReadCharacteristic: func(cUUID string) (data []byte, e error) {
|
|
return
|
|
},
|
|
testWriteCharacteristic: func(cUUID string, data []byte) (e error) {
|
|
return
|
|
},
|
|
testSubscribe: func([]byte, error) {
|
|
return
|
|
},
|
|
}
|
|
}
|