@@ -122,7 +122,7 @@ let utilitiesModule = {
122
122
} ,
123
123
extractRawBLEDataPackets : ( dataBuffer ) => {
124
124
let rawDataPackets = [ ] ;
125
- if ( ! _ . isBuffer ( dataBuffer ) ) return rawDataPackets ;
125
+ if ( _ . isNull ( dataBuffer ) ) return rawDataPackets ;
126
126
// Verify the packet is of length 20
127
127
if ( dataBuffer . byteLength !== k . OBCIPacketSizeBLECyton ) return rawDataPackets ;
128
128
let sampleNumbers = [ 0 , 0 , 0 ] ;
@@ -132,10 +132,9 @@ let utilitiesModule = {
132
132
sampleNumbers [ 2 ] = sampleNumbers [ 1 ] + 1 ;
133
133
if ( sampleNumbers [ 2 ] > 255 ) sampleNumbers [ 2 ] -= 256 ;
134
134
for ( let i = 0 ; i < k . OBCICytonBLESamplesPerPacket ; i ++ ) {
135
- let rawDataPacket = Buffer . alloc ( k . OBCIPacketSize ) ;
135
+ let rawDataPacket = utilitiesModule . samplePacketZero ( sampleNumbers [ i ] ) ;
136
136
rawDataPacket [ 0 ] = k . OBCIByteStart ;
137
137
rawDataPacket [ k . OBCIPacketPositionStopByte ] = dataBuffer [ 0 ] ;
138
- rawDataPacket [ k . OBCIPacketPositionSampleNumber ] = sampleNumbers [ i ] ;
139
138
dataBuffer . copy ( rawDataPacket , k . OBCIPacketPositionChannelDataStart , k . OBCIPacketPositionChannelDataStart + ( i * 6 ) , k . OBCIPacketPositionChannelDataStart + 6 + ( i * 6 ) ) ;
140
139
rawDataPackets . push ( rawDataPacket ) ;
141
140
}
@@ -554,6 +553,9 @@ let utilitiesModule = {
554
553
samplePacket : sampleNumber => {
555
554
return new Buffer ( [ 0xA0 , sampleNumberNormalize ( sampleNumber ) , 0 , 0 , 1 , 0 , 0 , 2 , 0 , 0 , 3 , 0 , 0 , 4 , 0 , 0 , 5 , 0 , 0 , 6 , 0 , 0 , 7 , 0 , 0 , 8 , 0 , 0 , 0 , 1 , 0 , 2 , makeTailByteFromPacketType ( k . OBCIStreamPacketStandardAccel ) ] ) ;
556
555
} ,
556
+ samplePacketZero : sampleNumber => {
557
+ return new Buffer ( [ 0xA0 , sampleNumberNormalize ( sampleNumber ) , 0 , 0 , 0 , 0 , 0 , 0 , 0 , 0 , 0 , 0 , 0 , 0 , 0 , 0 , 0 , 0 , 0 , 0 , 0 , 0 , 0 , 0 , 0 , 0 , 0 , 0 , 0 , 0 , 0 , 0 , makeTailByteFromPacketType ( k . OBCIStreamPacketStandardAccel ) ] ) ;
558
+ } ,
557
559
samplePacketReal : sampleNumber => {
558
560
return new Buffer ( [ 0xA0 , sampleNumberNormalize ( sampleNumber ) , 0x8F , 0xF2 , 0x40 , 0x8F , 0xDF , 0xF4 , 0x90 , 0x2B , 0xB6 , 0x8F , 0xBF , 0xBF , 0x7F , 0xFF , 0xFF , 0x7F , 0xFF , 0xFF , 0x94 , 0x25 , 0x34 , 0x20 , 0xB6 , 0x7D , 0 , 0xE0 , 0 , 0xE0 , 0x0F , 0x70 , makeTailByteFromPacketType ( k . OBCIStreamPacketStandardAccel ) ] ) ;
559
561
} ,
0 commit comments