123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287 |
- // +build !windows
- package ble
- import (
- "encoding/hex"
- "fmt"
- golog "log"
- "time"
- "github.com/bettercap/bettercap/modules/utils"
- "github.com/bettercap/bettercap/network"
- "github.com/bettercap/bettercap/session"
- "github.com/bettercap/gatt"
- "github.com/evilsocket/islazy/str"
- )
- type BLERecon struct {
- session.SessionModule
- deviceId int
- gattDevice gatt.Device
- currDevice *network.BLEDevice
- writeUUID *gatt.UUID
- writeData []byte
- connected bool
- connTimeout int
- devTTL int
- quit chan bool
- done chan bool
- selector *utils.ViewSelector
- }
- func NewBLERecon(s *session.Session) *BLERecon {
- mod := &BLERecon{
- SessionModule: session.NewSessionModule("ble.recon", s),
- deviceId: -1,
- gattDevice: nil,
- quit: make(chan bool),
- done: make(chan bool),
- connTimeout: 5,
- devTTL: 30,
- currDevice: nil,
- connected: false,
- }
- mod.InitState("scanning")
- mod.selector = utils.ViewSelectorFor(&mod.SessionModule,
- "ble.show",
- []string{"rssi", "mac", "seen"}, "rssi asc")
- mod.AddHandler(session.NewModuleHandler("ble.recon on", "",
- "Start Bluetooth Low Energy devices discovery.",
- func(args []string) error {
- return mod.Start()
- }))
- mod.AddHandler(session.NewModuleHandler("ble.recon off", "",
- "Stop Bluetooth Low Energy devices discovery.",
- func(args []string) error {
- return mod.Stop()
- }))
- mod.AddHandler(session.NewModuleHandler("ble.clear", "",
- "Clear all devices collected by the BLE discovery module.",
- func(args []string) error {
- mod.Session.BLE.Clear()
- return nil
- }))
- mod.AddHandler(session.NewModuleHandler("ble.show", "",
- "Show discovered Bluetooth Low Energy devices.",
- func(args []string) error {
- return mod.Show()
- }))
- enum := session.NewModuleHandler("ble.enum MAC", "ble.enum "+network.BLEMacValidator,
- "Enumerate services and characteristics for the given BLE device.",
- func(args []string) error {
- if mod.isEnumerating() {
- return fmt.Errorf("An enumeration for %s is already running, please wait.", mod.currDevice.Device.ID())
- }
- mod.writeData = nil
- mod.writeUUID = nil
- return mod.enumAllTheThings(network.NormalizeMac(args[0]))
- })
- enum.Complete("ble.enum", s.BLECompleter)
- mod.AddHandler(enum)
- write := session.NewModuleHandler("ble.write MAC UUID HEX_DATA", "ble.write "+network.BLEMacValidator+" ([a-fA-F0-9]+) ([a-fA-F0-9]+)",
- "Write the HEX_DATA buffer to the BLE device with the specified MAC address, to the characteristics with the given UUID.",
- func(args []string) error {
- mac := network.NormalizeMac(args[0])
- uuid, err := gatt.ParseUUID(args[1])
- if err != nil {
- return fmt.Errorf("Error parsing %s: %s", args[1], err)
- }
- data, err := hex.DecodeString(args[2])
- if err != nil {
- return fmt.Errorf("Error parsing %s: %s", args[2], err)
- }
- return mod.writeBuffer(mac, uuid, data)
- })
- write.Complete("ble.write", s.BLECompleter)
- mod.AddHandler(write)
- mod.AddParam(session.NewIntParameter("ble.device",
- fmt.Sprintf("%d", mod.deviceId),
- "Index of the HCI device to use, -1 to autodetect."))
- mod.AddParam(session.NewIntParameter("ble.timeout",
- fmt.Sprintf("%d", mod.connTimeout),
- "Connection timeout in seconds."))
- mod.AddParam(session.NewIntParameter("ble.ttl",
- fmt.Sprintf("%d", mod.devTTL),
- "Seconds of inactivity for a device to be pruned."))
- return mod
- }
- func (mod BLERecon) Name() string {
- return "ble.recon"
- }
- func (mod BLERecon) Description() string {
- return "Bluetooth Low Energy devices discovery."
- }
- func (mod BLERecon) Author() string {
- return "Simone Margaritelli <evilsocket@gmail.com>"
- }
- func (mod *BLERecon) isEnumerating() bool {
- return mod.currDevice != nil
- }
- type dummyWriter struct {
- mod *BLERecon
- }
- func (w dummyWriter) Write(p []byte) (n int, err error) {
- w.mod.Debug("[gatt.log] %s", str.Trim(string(p)))
- return len(p), nil
- }
- func (mod *BLERecon) Configure() (err error) {
- if mod.Running() {
- return session.ErrAlreadyStarted(mod.Name())
- } else if mod.gattDevice == nil {
- if err, mod.deviceId = mod.IntParam("ble.device"); err != nil {
- return err
- }
- mod.Debug("initializing device (id:%d) ...", mod.deviceId)
- golog.SetFlags(0)
- golog.SetOutput(dummyWriter{mod})
- if mod.gattDevice, err = gatt.NewDevice(defaultBLEClientOptions...); err != nil {
- mod.Debug("error while creating new gatt device: %v", err)
- return err
- }
- mod.gattDevice.Handle(
- gatt.PeripheralDiscovered(mod.onPeriphDiscovered),
- gatt.PeripheralConnected(mod.onPeriphConnected),
- gatt.PeripheralDisconnected(mod.onPeriphDisconnected),
- )
- mod.gattDevice.Init(mod.onStateChanged)
- }
- if err, mod.connTimeout = mod.IntParam("ble.timeout"); err != nil {
- return err
- } else if err, mod.devTTL = mod.IntParam("ble.ttl"); err != nil {
- return err
- }
- return nil
- }
- func (mod *BLERecon) Start() error {
- if err := mod.Configure(); err != nil {
- return err
- }
- return mod.SetRunning(true, func() {
- go mod.pruner()
- <-mod.quit
- if mod.gattDevice != nil {
- mod.Info("stopping scan ...")
- if mod.currDevice != nil && mod.currDevice.Device != nil {
- mod.Debug("resetting connection with %v", mod.currDevice.Device)
- mod.gattDevice.CancelConnection(mod.currDevice.Device)
- }
- mod.Debug("stopping device")
- if err := mod.gattDevice.Stop(); err != nil {
- mod.Warning("error while stopping device: %v", err)
- } else {
- mod.Debug("gatt device closed")
- }
- }
- mod.done <- true
- })
- }
- func (mod *BLERecon) Stop() error {
- return mod.SetRunning(false, func() {
- mod.quit <- true
- <-mod.done
- mod.Debug("module stopped, cleaning state")
- mod.gattDevice = nil
- mod.setCurrentDevice(nil)
- mod.ResetState()
- })
- }
- func (mod *BLERecon) pruner() {
- blePresentInterval := time.Duration(mod.devTTL) * time.Second
- mod.Debug("started devices pruner with ttl %s", blePresentInterval)
- for mod.Running() {
- for _, dev := range mod.Session.BLE.Devices() {
- if time.Since(dev.LastSeen) > blePresentInterval {
- mod.Session.BLE.Remove(dev.Device.ID())
- }
- }
- time.Sleep(5 * time.Second)
- }
- }
- func (mod *BLERecon) setCurrentDevice(dev *network.BLEDevice) {
- mod.connected = false
- mod.currDevice = dev
- mod.State.Store("scanning", dev)
- }
- func (mod *BLERecon) writeBuffer(mac string, uuid gatt.UUID, data []byte) error {
- mod.writeUUID = &uuid
- mod.writeData = data
- return mod.enumAllTheThings(mac)
- }
- func (mod *BLERecon) enumAllTheThings(mac string) error {
- dev, found := mod.Session.BLE.Get(mac)
- if !found || dev == nil {
- return fmt.Errorf("BLE device with address %s not found.", mac)
- } else if mod.Running() {
- mod.gattDevice.StopScanning()
- }
- mod.setCurrentDevice(dev)
- if err := mod.Configure(); err != nil && err.Error() != session.ErrAlreadyStarted("ble.recon").Error() {
- return err
- }
- mod.Info("connecting to %s ...", mac)
- go func() {
- time.Sleep(time.Duration(mod.connTimeout) * time.Second)
- if mod.isEnumerating() && !mod.connected {
- mod.Warning("connection timeout")
- mod.Session.Events.Add("ble.connection.timeout", mod.currDevice)
- mod.onPeriphDisconnected(nil, nil)
- }
- }()
- mod.gattDevice.Connect(dev.Device)
- return nil
- }
|