b06d666dbf
Remove the Addresser type. It isn't really necessary (the Address type can change between OSes) and makes it difficult to fix a heap allocation in interrupts (on the Nordic SoftDevices). This is a backwards incompatible change, but only programs that use SetConnectHandler should notice this.
55 lines
1.8 KiB
Go
55 lines
1.8 KiB
Go
package bluetooth
|
|
|
|
import (
|
|
"fmt"
|
|
|
|
"github.com/go-ole/go-ole"
|
|
"github.com/saltosystems/winrt-go"
|
|
"github.com/saltosystems/winrt-go/windows/devices/bluetooth/advertisement"
|
|
"github.com/saltosystems/winrt-go/windows/foundation"
|
|
)
|
|
|
|
type Adapter struct {
|
|
watcher *advertisement.BluetoothLEAdvertisementWatcher
|
|
|
|
connectHandler func(device Address, connected bool)
|
|
}
|
|
|
|
// DefaultAdapter is the default adapter on the system.
|
|
//
|
|
// Make sure to call Enable() before using it to initialize the adapter.
|
|
var DefaultAdapter = &Adapter{
|
|
connectHandler: func(device Address, connected bool) {
|
|
return
|
|
},
|
|
}
|
|
|
|
// Enable configures the BLE stack. It must be called before any
|
|
// Bluetooth-related calls (unless otherwise indicated).
|
|
func (a *Adapter) Enable() error {
|
|
return ole.RoInitialize(1) // initialize with multithreading enabled
|
|
}
|
|
|
|
func awaitAsyncOperation(asyncOperation *foundation.IAsyncOperation, genericParamSignature string) error {
|
|
var status foundation.AsyncStatus
|
|
|
|
// We need to obtain the GUID of the AsyncOperationCompletedHandler, but its a generic delegate
|
|
// so we also need the generic parameter type's signature:
|
|
// AsyncOperationCompletedHandler<genericParamSignature>
|
|
iid := winrt.ParameterizedInstanceGUID(foundation.GUIDAsyncOperationCompletedHandler, genericParamSignature)
|
|
|
|
// Wait until the async operation completes.
|
|
waitChan := make(chan struct{})
|
|
asyncOperation.SetCompleted(foundation.NewAsyncOperationCompletedHandler(ole.NewGUID(iid), func(instance *foundation.AsyncOperationCompletedHandler, asyncInfo *foundation.IAsyncOperation, asyncStatus foundation.AsyncStatus) {
|
|
status = asyncStatus
|
|
close(waitChan)
|
|
}))
|
|
// Wait until async operation has stopped, and finish.
|
|
<-waitChan
|
|
|
|
if status != foundation.AsyncStatusCompleted {
|
|
return fmt.Errorf("async operation failed with status %d", status)
|
|
}
|
|
return nil
|
|
}
|