feat[bluetooth]: noble wrapper

package.json

@@ -60,6 +60,7 @@
     "echarts": "^4.7.0",
     "element-ui": "^2.13.1",
     "koa": "^2.2.0",
+    "noble": "^1.9.1",
     "socket.io": "^2.3.0",
     "vue": "^2.5.16",
     "vue-echarts": "^5.0.0-beta.0",

src/renderer/assets/heatmap_gradient.json

@@ -0,0 +1,164 @@
+{
+  "0.00000": "#0000E3",
+  "0.00392": "#0000E3",
+  "0.00784": "#0000E3",
+  "0.01176": "#0000E3",
+  "0.01569": "#0000E3",
+  "0.01961": "#0000E3",
+  "0.02353": "#0000E3",
+  "0.02745": "#0000E3",
+  "0.03137": "#0000E3",
+  "0.03529": "#0000E3",
+  "0.03922": "#0000E3",
+  "0.04314": "#0000E3",
+  "0.04706": "#0000E3",
+  "0.05098": "#0000E3",
+  "0.05490": "#0000E3",
+  "0.05882": "#0000E3",
+  "0.06275": "#0000E3",
+  "0.06667": "#0000E3",
+  "0.07059": "#0000E3",
+  "0.07451": "#0000E3",
+  "0.07843": "#0000E3",
+  "0.08235": "#0000E3",
+  "0.08627": "#0000E3",
+  "0.09020": "#0000E3",
+  "0.09412": "#0000E3",
+  "0.09804": "#0000E3",
+  "0.10196": "#0000E3",
+  "0.10588": "#0000E3",
+  "0.10980": "#0000E3",
+  "0.11373": "#0000E3",
+  "0.11765": "#0000E3",
+  "0.12157": "#0000E3",
+  "0.12549": "#0000E3",
+  "0.12941": "#0000E3",
+  "0.13333": "#0000E3",
+  "0.13725": "#0000E3",
+  "0.14118": "#0000E3",
+  "0.14510": "#0000E3",
+  "0.14902": "#0000E3",
+  "0.15294": "#0000E3",
+  "0.15686": "#0000E3",
+  "0.16078": "#0000E3",
+  "0.16471": "#0000E3",
+  "0.16863": "#0000E3",
+  "0.17255": "#0000E3",
+  "0.17647": "#0000E3",
+  "0.18039": "#0000E3",
+  "0.18431": "#0000E3",
+  "0.18824": "#0004FF",
+  "0.19216": "#0004FF",
+  "0.19608": "#0004FF",
+  "0.20000": "#0004FF",
+  "0.20392": "#0004FF",
+  "0.20784": "#0004FF",
+  "0.21176": "#0004FF",
+  "0.21569": "#0004FF",
+  "0.21961": "#0004FF",
+  "0.22353": "#0004FF",
+  "0.22745": "#0004FF",
+  "0.23137": "#0004FF",
+  "0.23529": "#0004FF",
+  "0.23922": "#0004FF",
+  "0.24314": "#0004FF",
+  "0.24706": "#0004FF",
+  "0.25098": "#0004FF",
+  "0.25490": "#0004FF",
+  "0.25882": "#0004FF",
+  "0.26275": "#0004FF",
+  "0.26667": "#0004FF",
+  "0.27059": "#0004FF",
+  "0.27451": "#0004FF",
+  "0.27843": "#0004FF",
+  "0.28235": "#0004FF",
+  "0.28627": "#0004FF",
+  "0.29020": "#0004FF",
+  "0.29412": "#0004FF",
+  "0.29804": "#0004FF",
+  "0.30196": "#0004FF",
+  "0.30588": "#0004FF",
+  "0.30980": "#0004FF",
+  "0.31373": "#0004FF",
+  "0.31765": "#0004FF",
+  "0.32157": "#0004FF",
+  "0.32549": "#0030FF",
+  "0.32941": "#0030FF",
+  "0.33333": "#0030FF",
+  "0.33725": "#0030FF",
+  "0.34118": "#0030FF",
+  "0.34510": "#0030FF",
+  "0.34902": "#0030FF",
+  "0.35294": "#0030FF",
+  "0.35686": "#0030FF",
+  "0.36078": "#0030FF",
+  "0.36471": "#0030FF",
+  "0.36863": "#0030FF",
+  "0.37255": "#0030FF",
+  "0.37647": "#0030FF",
+  "0.38039": "#0030FF",
+  "0.38431": "#0030FF",
+  "0.38824": "#0030FF",
+  "0.39216": "#0030FF",
+  "0.39608": "#0030FF",
+  ".40": "#007bff",
+  ".41": "#028aff",
+  ".42": "#0297ff",
+  ".43": "#04b9ff",
+  ".44": "#02ffe9",
+  ".45": "#00ffab",
+  ".46": "#00ff97",
+  ".47": "#00ff84",
+  ".48": "#00ff71",
+  ".49": "#00ff5d",
+  ".50": "#00ff4a",
+  ".51": "#00ff38",
+  ".52": "#00ff28",
+  ".53": "#00ff18",
+  ".54": "#00ff07",
+  ".55": "#09ff00",
+  ".56": "#19ff00",
+  ".57": "#29ff00",
+  ".58": "#39ff00",
+  ".59": "#4aff00",
+  ".60": "#5aff00",
+  ".61": "#6aff00",
+  ".62": "#7aff00",
+  ".63": "#8aff00",
+  ".64": "#9bff00",
+  ".65": "#abff00",
+  ".66": "#bbff00",
+  ".67": "#cbff00",
+  ".68": "#dcff00",
+  ".69": "#ecff00",
+  ".70": "#fcff00",
+  ".71": "#fffa00",
+  ".72": "#fff500",
+  ".73": "#fff000",
+  ".74": "#ffea00",
+  ".75": "#ffe500",
+  ".76": "#ffdf00",
+  ".77": "#ffda00",
+  ".78": "#ffd400",
+  ".79": "#ffcf00",
+  ".80": "#ffca00",
+  ".81": "#ffc400",
+  ".82": "#ffbf00",
+  ".83": "#ffb900",
+  ".84": "#ffb400",
+  ".85": "#ffaf00",
+  ".86": "#ffa900",
+  ".87": "#ffa400",
+  ".88": "#ff9e00",
+  ".89": "#ff9900",
+  ".90": "#ff9300",
+  ".91": "#ff8c00",
+  ".92": "#ff8400",
+  ".93": "#ff7d00",
+  ".94": "#ff7500",
+  ".95": "#ff6d00",
+  ".96": "#ff6600",
+  ".97": "#ff5e00",
+  ".98": "#fa5500",
+  ".99": "#ff4f00"
+}

src/renderer/components/LandingPage.vue

@@ -35,6 +35,7 @@
     <el-button @click="resetDevice" :disabled="hasConnectCount == 0">复位</el-button>
     <el-button @click="toConfig" :disabled="hasConnectCount == 0">跳转至配置</el-button>
     <el-button @click="toBlueToothSend" :disabled="deviceStatus != 'deviceSuccess'" >跳转至蓝牙发送</el-button>
+    <el-button @click="toRealTimeBluetooth" >跳转至 实时蓝牙</el-button>
     <br/>
     <div style="width:540px;height:540px;position:relative;margin-top:30px" >
       <div ref="heatsample" style="width:540px;height:540px;position:absolute;top:0;left:0" />
@@ -87,180 +88,21 @@
       },
       toBlueToothSend() {
           this.$router.push('/blueTooth')
+      },
+      toRealTimeBluetooth() {
+        this.$router.push('/rt_ble')
       }
     },
     mounted() {
         this.$socket.emit('syncConnectCount','resetDevice')
         setTimeout(()=>{
+            var gradient = require('../assets/heatmap_gradient.json')
             var dst = this.$refs.heatsample;
             var heatmap = h337.create({
                 container: dst,
                 radius:6,
                 blur:0.7,
-                gradient:{
-                    "0.00000":"#0000E3",
-                    "0.00392":"#0000E3",
-                    "0.00784":"#0000E3",
-                    "0.01176":"#0000E3",
-                    "0.01569":"#0000E3",
-                    "0.01961":"#0000E3",
-                    "0.02353":"#0000E3",
-                    "0.02745":"#0000E3",
-                    "0.03137":"#0000E3",
-                    "0.03529":"#0000E3",
-                    "0.03922":"#0000E3",
-                    "0.04314":"#0000E3",
-                    "0.04706":"#0000E3",
-                    "0.05098":"#0000E3",
-                    "0.05490":"#0000E3",
-                    "0.05882":"#0000E3",
-                    "0.06275":"#0000E3",
-                    "0.06667":"#0000E3",
-                    "0.07059":"#0000E3",
-                    "0.07451":"#0000E3",
-                    "0.07843":"#0000E3",
-                    "0.08235":"#0000E3",
-                    "0.08627":"#0000E3",
-                    "0.09020":"#0000E3",
-                    "0.09412":"#0000E3",
-                    "0.09804":"#0000E3",
-                    "0.10196":"#0000E3",
-                    "0.10588":"#0000E3",
-                    "0.10980":"#0000E3",
-                    "0.11373":"#0000E3",
-                    "0.11765":"#0000E3",
-                    "0.12157":"#0000E3",
-                    "0.12549":"#0000E3",
-                    "0.12941":"#0000E3",
-                    "0.13333":"#0000E3",
-                    "0.13725":"#0000E3",
-                    "0.14118":"#0000E3",
-                    "0.14510":"#0000E3",
-                    "0.14902":"#0000E3",
-                    "0.15294":"#0000E3",
-                    "0.15686":"#0000E3",
-                    "0.16078":"#0000E3",
-                    "0.16471":"#0000E3",
-                    "0.16863":"#0000E3",
-                    "0.17255":"#0000E3",
-                    "0.17647":"#0000E3",
-                    "0.18039":"#0000E3",
-                    "0.18431":"#0000E3",
-                    "0.18824":"#0004FF",
-                    "0.19216":"#0004FF",
-                    "0.19608":"#0004FF",
-                    "0.20000":"#0004FF",
-                    "0.20392":"#0004FF",
-                    "0.20784":"#0004FF",
-                    "0.21176":"#0004FF",
-                    "0.21569":"#0004FF",
-                    "0.21961":"#0004FF",
-                    "0.22353":"#0004FF",
-                    "0.22745":"#0004FF",
-                    "0.23137":"#0004FF",
-                    "0.23529":"#0004FF",
-                    "0.23922":"#0004FF",
-                    "0.24314":"#0004FF",
-                    "0.24706":"#0004FF",
-                    "0.25098":"#0004FF",
-                    "0.25490":"#0004FF",
-                    "0.25882":"#0004FF",
-                    "0.26275":"#0004FF",
-                    "0.26667":"#0004FF",
-                    "0.27059":"#0004FF",
-                    "0.27451":"#0004FF",
-                    "0.27843":"#0004FF",
-                    "0.28235":"#0004FF",
-                    "0.28627":"#0004FF",
-                    "0.29020":"#0004FF",
-                    "0.29412":"#0004FF",
-                    "0.29804":"#0004FF",
-                    "0.30196":"#0004FF",
-                    "0.30588":"#0004FF",
-                    "0.30980":"#0004FF",
-                    "0.31373":"#0004FF",
-                    "0.31765":"#0004FF",
-                    "0.32157":"#0004FF",
-                    "0.32549":"#0030FF",
-                    "0.32941":"#0030FF",
-                    "0.33333":"#0030FF",
-                    "0.33725":"#0030FF",
-                    "0.34118":"#0030FF",
-                    "0.34510":"#0030FF",
-                    "0.34902":"#0030FF",
-                    "0.35294":"#0030FF",
-                    "0.35686":"#0030FF",
-                    "0.36078":"#0030FF",
-                    "0.36471":"#0030FF",
-                    "0.36863":"#0030FF",
-                    "0.37255":"#0030FF",
-                    "0.37647":"#0030FF",
-                    "0.38039":"#0030FF",
-                    "0.38431":"#0030FF",
-                    "0.38824":"#0030FF",
-                    "0.39216":"#0030FF",
-                    "0.39608":"#0030FF",
-                    '.40': '#007bff',
-                    '.41': '#028aff',
-                    '.42': '#0297ff',
-                    '.43': '#04b9ff',
-                    '.44': '#02ffe9',
-                    '.45': '#00ffab',
-                    '.46':'#00ff97',
-                    '.47': '#00ff84',
-                    '.48': '#00ff71',
-                    '.49': '#00ff5d',
-                    '.50': '#00ff4a',
-                    '.51': '#00ff38',
-                    '.52': '#00ff28',
-                    '.53': '#00ff18',
-                    '.54': '#00ff07',
-                    '.55': '#09ff00',
-                    '.56': '#19ff00',
-                    '.57': '#29ff00',
-                    '.58': '#39ff00',
-                    '.59': '#4aff00',
-                    '.60': '#5aff00',
-                    '.61': '#6aff00',
-                    '.62': '#7aff00',
-                    '.63': '#8aff00',
-                    '.64': '#9bff00',
-                    '.65': '#abff00',
-                    '.66': '#bbff00',
-                    '.67': '#cbff00',
-                    '.68': '#dcff00',
-                    '.69': '#ecff00',
-                    '.70': '#fcff00',
-                    '.71': '#fffa00',
-                    '.72': '#fff500',
-                    '.73': '#fff000',
-                    '.74': '#ffea00',
-                    '.75': '#ffe500',
-                    '.76': '#ffdf00',
-                    '.77': '#ffda00',
-                    '.78': '#ffd400',
-                    '.79': '#ffcf00',
-                    '.80': '#ffca00',
-                    '.81': '#ffc400',
-                    '.82': '#ffbf00',
-                    '.83': '#ffb900',
-                    '.84': '#ffb400',
-                    '.85': '#ffaf00',
-                    '.86': '#ffa900',
-                    '.87': '#ffa400',
-                    '.88': '#ff9e00',
-                    '.89': '#ff9900',
-                    '.90': '#ff9300',
-                    '.91': '#ff8c00',
-                    '.92': '#ff8400',
-                    '.93': '#ff7d00',
-                    '.94': '#ff7500',
-                    '.95': '#ff6d00',
-                    '.96': '#ff6600',
-                    '.97': '#ff5e00',
-                    '.98': '#fa5500',
-                    '.99': '#ff4f00',
-                }
+                gradient: gradient
             });
             this.h337 = heatmap;
         },1000)

src/renderer/components/ble/rt_ble.vue

@@ -0,0 +1,60 @@
+<template>
+  <div class="bluetoothContent">
+
+    <el-button @click="toIndex">返回首页</el-button>
+    <el-button @click="search">搜索</el-button>
+    <el-button @click="connect">连接</el-button>
+    <el-button @click="send">发送</el-button>
+
+    <div>
+      <el-radio v-for="(item,index) in blueDeviceList" v-model="choseBlueDeviceId" :key="'device'+index"
+                :label="item.id">
+        {{item.localName}}
+      </el-radio>
+    </div>
+
+
+  </div>
+
+</template>
+
+<script>
+  import {mapGetters} from "vuex"
+
+  export default {
+    name: "rt_ble",
+    data() {
+      return {
+        choseBlueDeviceId: undefined
+      }
+    },
+    created() {
+      this.search()
+    },
+
+    methods: {
+      toIndex() {
+        this.$router.push('/')
+      },
+      search() {
+        this.$socket.emit('ble', {cmd: 'scan'})
+      },
+      connect() {
+        this.$socket.emit('ble', {cmd: 'connect', args: {id: this.choseBlueDeviceId}})
+      },
+      send() {
+        this.$socket.emit('ble', {cmd: 'send', args: {msg: '0123'}})
+      }
+    },
+    computed: {
+      ...mapGetters([
+        'blueDeviceList'
+      ])
+    },
+    watch: {}
+  }
+</script>
+
+<style scoped>
+
+</style>

src/renderer/router/index.js

@@ -24,6 +24,11 @@ export default new Router({
         name: 'blueTooth',
         component: require('@/components/BlueTooth').default
     },
+    {
+        path: '/rt_ble',
+        name: 'rt_ble',
+        component: require('@/components/ble/rt_ble').default
+    },
 
   ]
 })

src/renderer/store/modules/socket.js

@@ -1,11 +1,13 @@
-import Vue from 'vue'
 import func from '../../utils/FunctionSet'
+
 const state = {
     hasConnectCount:0,
     pressureData:[],
     blueToothDevice:'',
     deviceStatus:'',
-    blueSendData:''
+    blueSendData:'',
+
+    blueDeviceList: []
 }
 
 const actions = {
@@ -38,6 +40,15 @@ const mutations = {
     },
     SOCKET_sendBlueData(state,data) {
         state.blueSendData = func.buf2hex(data)
+    },
+    SOCKET_blueDeviceList(state, resp) {
+            console.log(resp)
+        if (resp.ok) {
+            state.blueDeviceList = resp.data;
+
+        } else {
+            console.log(resp)
+        }
     }
 }
 
@@ -47,6 +58,8 @@ const getters = {
     blueToothDevice:state=>state.blueToothDevice,
     deviceStatus:state=>state.deviceStatus,
     blueSendData:state=>state.blueSendData,
+
+    blueDeviceList:state=>state.blueDeviceList,
 }
 
 

static/server/app.js

@@ -8,7 +8,11 @@ io = require('socket.io').listen(server);
 var sendProtocal = require('./protocal/sendProtocal')
 var command = require('./protocal/command')
 var commonFunction = require('./protocal/commonFunction')
-var blueTouth = require('./blueTouth')
+
+// var blueTouth = require('./blueTouth')
+
+const nobleWrapper = require('./ble/nobleWrapper')
+
 // socket 服务开启
 
 let socketEvent = null;
@@ -56,9 +60,9 @@ io.sockets.on('connection', function (socket) {
             console.log('已有初始连接' +connectCount +'个')
         }
         io.sockets.emit('connectCount', connectCount);
-        io.sockets.emit('setDeviceStatus', blueTouth.getBlueServerStatus());
+        // io.sockets.emit('setDeviceStatus', blueTouth.getBlueServerStatus());
         // 将io对象传递给blueTooth js （发送连接客户端已经断开客户端消息发送）
-        blueTouth.setIo(io)
+        // blueTouth.setIo(io)
     })
     // 发送获取采样频率指令
     socket.on('checkCaiyang',function (sendData) {
@@ -161,6 +165,27 @@ io.sockets.on('connection', function (socket) {
             sendData,'serverIp','get')
         blueTouth.sendData(data)
     })
+
+    socket.on('ble', function(request) {
+        if (request.cmd === 'scan') {
+            nobleWrapper.scan(function(resp) {
+                io.sockets.emit('blueDeviceList', resp)
+            })
+        } else if (request.cmd === 'connect') {
+            let on_data_cb  = function (buffer) {
+                console.log('Received: "' + buffer.length + '"');
+            }
+            let resp_cb =  function(resp) {
+                io.sockets.emit('blueConnect', resp)
+            }
+            nobleWrapper.connect(request.args.id, on_data_cb, resp_cb);
+        } else if (request.cmd === 'send') {
+            nobleWrapper.write(request.args.msg, function(resp) {
+                io.sockets.emit('blueSend', resp)
+            });
+        }
+    });
+
 })
 
 const frame_header_and_size_bytes = 1 + 2;

static/server/ble/nobleWrapper.js

@@ -0,0 +1,155 @@
+const resp = require('../util/resp')
+const noble = require('noble');
+
+let inRange = {};
+let blueDeviceList = []
+let blueCharacteristics = []
+
+const ECHO_SERVICE_UUID = 'ec00';
+const ECHO_CHARACTERISTIC_UUID = 'ec0e';
+
+let connectedCharacteristic = null;
+let on_data_callback = null;
+
+noble.on('discover', function (peripheral) {
+  inRange[peripheral.id] = {
+    peripheral: peripheral
+  };
+
+  var blueDevice = {
+    'id': peripheral.id,
+    'localName': peripheral.advertisement.localName,
+    'serviceUuids': JSON.stringify(peripheral.advertisement.serviceUuids),
+    'address': peripheral.address,
+    'addressType': peripheral.addressType,
+    'connectable': peripheral.connectable,
+    'rssi': peripheral.rssi,
+  }
+
+  blueDeviceList.push(blueDevice)
+
+  explore(peripheral)
+});
+
+
+function explore(peripheral) {
+  peripheral.connect(error => {
+    peripheral.discoverServices([], function (error, services) {
+      for (let serviceIndex = 0; serviceIndex < services.length; serviceIndex++) {
+        (function (service) {
+          service.discoverCharacteristics([], function (error, characteristics) {
+            for (let charIndex = 0; charIndex < characteristics.length; charIndex++) {
+              let c = characteristics[charIndex];
+
+              let info = {
+                id: peripheral.id,
+                uuid: service.uuid,
+                name: service.name,
+                characteristic: {
+                  'uuid': c.uuid,
+                  'properties': c.properties
+                }
+              }
+
+              blueCharacteristics.push(info)
+            }
+          })
+        })(services[serviceIndex])
+
+      }
+
+      setTimeout(function () {
+        peripheral.disconnect()
+      }, 1000)
+    })
+  })
+}
+
+function merge_scan_result() {
+  for (let i = 0; i < blueDeviceList.length; i++) {
+    let device = blueDeviceList[i]
+    device.characteristics = []
+
+    for (let j = 0; j < blueCharacteristics.length; j++) {
+      let character = blueCharacteristics[j]
+      if (device.id === character.id) {
+        device.characteristics.push(character)
+      }
+    }
+  }
+
+  return blueDeviceList
+}
+
+function connectAndSetUp(peripheral) {
+  peripheral.connect(error => {
+    console.log('Connected to', peripheral.id);
+
+    // specify the services and characteristics to discover
+    const serviceUUIDs = [ECHO_SERVICE_UUID];
+    const characteristicUUIDs = [ECHO_CHARACTERISTIC_UUID];
+
+    peripheral.discoverSomeServicesAndCharacteristics(
+      serviceUUIDs,
+      characteristicUUIDs,
+      onServicesAndCharacteristicsDiscovered
+    );
+  });
+
+  peripheral.on('disconnect', () => console.log('disconnected'));
+}
+
+function onServicesAndCharacteristicsDiscovered(error, services, characteristics) {
+  console.log('Discovered services and characteristics');
+  const echoCharacteristic = characteristics[0];
+
+  // data callback receives notifications
+  echoCharacteristic.on('data', (data, isNotification) => {
+    if (on_data_callback) {
+      on_data_callback(data)
+    }
+  });
+
+  // subscribe to be notified whenever the peripheral update the characteristic
+  echoCharacteristic.subscribe(error => {
+    if (error) {
+      console.error('Error subscribing to echoCharacteristic');
+    } else {
+      console.log('Subscribed for echoCharacteristic notifications');
+    }
+  });
+
+  connectedCharacteristic = echoCharacteristic
+}
+
+module.exports = {
+  scan: function (resp_callback) {
+
+    try {
+      blueDeviceList = []
+      blueCharacteristics = []
+
+      setTimeout(() => {
+        noble.stopScanning()
+        resp_callback(resp.ok_resp(merge_scan_result()))
+      }, 2000);
+      noble.startScanning()
+    } catch (e) {
+      resp_callback(resp.fail_resp(e.message))
+    }
+  },
+  connect: function (id, on_data_cb, resp_callback) {
+    on_data_callback = on_data_cb;
+    connectAndSetUp(inRange[id].peripheral)
+  },
+  write: function (msg, resp_callback) {
+    try {
+      const buffer = new Buffer(msg, 'utf-8');
+      if (connectedCharacteristic) {
+        connectedCharacteristic.write(buffer);
+      }
+    } catch (e) {
+      resp_callback(resp.fail_resp(e.message))
+    }
+  }
+}

static/server/util/resp.js

@@ -0,0 +1,9 @@
+module.exports = {
+  fail_resp: function fail_resp(msg) {
+    return {ok: false, msg: msg}
+  },
+
+  ok_resp: function ok_resp(data) {
+    return {ok: true, data: data}
+  }
+}