16mm
/
intval3
1
0
Fork 0
Code Issues 1 Pull Requests 9 Projects Releases Wiki Activity

Add bleno types.

This commit is contained in:
mmcwilliams 2019-11-26 21:16:13 -05:00
parent a627143c22
commit de481ee185
8 changed files with 467 additions and 342 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

168
lib/ble/index.js
View File

@ -1,31 +1,38 @@
'use strict';
var __importDefault = (this && this.__importDefault) || function (mod) {
return (mod && mod.__esModule) ? mod : { "default": mod };
};
Object.defineProperty(exports, "__esModule", { value: true });
/** @module ble */
/** Bluetooth Low Energy module */
const util = require('util');
const os = require('os');
const util_1 = require("util");
const os_1 = require("os");
const fs_extra_1 = require("fs-extra");
const log = require('../log')('ble');
const wifi = require('../wifi');
const wifi_1 = require("../wifi");
const wifi = new wifi_1.Wifi();
const DEVICE_NAME = process.env.DEVICE_NAME || 'intval3';
const SERVICE_ID = process.env.SERVICE_ID || 'intval3_ble';
const CHAR_ID = process.env.CHAR_ID || 'intval3char';
const WIFI_ID = process.env.WIFI_ID || 'wifichar';
const NETWORK = os.networkInterfaces();
const NETWORK = os_1.networkInterfaces(); //?type?
const MAC = getMac() || spoofMac();
//Give the device a unique device name, needs to be in env
process.env.BLENO_DEVICE_NAME += '_' + MAC;
const bleno = require('bleno');
const bleno_1 = __importDefault(require("bleno"));
const { Characteristic } = bleno_1.default;
let currentWifi = 'disconnected';
let currentAddr = null;
let getState;
const chars = [];
function createChar(name, uuid, prop, write, read) {
function characteristic() {
bleno.Characteristic.call(this, {
uuid: uuid,
const characteristic = function () {
Characteristic.call(this, {
uuid,
properties: prop
});
}
util.inherits(characteristic, bleno.Characteristic);
};
util_1.inherits(characteristic, Characteristic);
if (prop.indexOf('read') !== -1) {
//data, offset, withoutResponse, callback
characteristic.prototype.onReadRequest = read;
@ -36,61 +43,67 @@ function createChar(name, uuid, prop, write, read) {
chars.push(new characteristic());
}
function createChars(onWrite, onRead) {
createChar('intval3', CHAR_ID, ['read', 'write'], onWrite, onRead);
createChar('wifi', WIFI_ID, ['read', 'write'], onWifiWrite, onWifiRead);
const permissions = ['read', 'write'];
createChar('intval3', CHAR_ID, permissions, onWrite, onRead);
createChar('wifi', WIFI_ID, permissions, onWifiWrite, onWifiRead);
}
function onWifiWrite(data, offset, withoutResponse, callback) {
async function onWifiWrite(data, offset) {
let result;
let utf8;
let obj;
let obj = {};
let ssid;
let pwd;
let psk;
if (offset) {
log.warn(`Offset scenario`);
result = bleno.Characteristic.RESULT_ATTR_NOT_LONG;
return callback(result);
result = bleno_1.default.Characteristic.RESULT_ATTR_NOT_LONG;
return result;
}
utf8 = data.toString('utf8');
obj = JSON.parse(utf8);
ssid = obj.ssid;
pwd = obj.pwd;
log.info(`connecting to AP`, { ssid: ssid });
return wifi.createPSK(ssid, pwd, (err, hash, plaintext) => {
if (err) {
log.error('Error hashing wifi password', err);
result = bleno.Characteristic.RESULT_UNLIKELY_ERROR;
return callback(result);
}
return wifi.setNetwork(ssid, plaintext, hash, (err, data) => {
if (err) {
log.error('Error configuring wifi', err);
result = bleno.Characteristic.RESULT_UNLIKELY_ERROR;
return callback(result);
}
currentWifi = ssid;
currentAddr = getIp();
log.info(`Connected to AP`, { ssid: ssid, ip: currentAddr });
result = bleno.Characteristic.RESULT_SUCCESS;
return callback(result);
});
});
try {
psk = await wifi.createPSK(ssid, pwd);
}
catch (err) {
log.error('Error hashing wifi password', err);
result = bleno_1.default.Characteristic.RESULT_UNLIKELY_ERROR;
return result;
}
try {
await wifi.setNetwork(ssid, psk.plaintext, psk.hash);
}
catch (err) {
log.error('Error configuring wifi', err);
result = bleno_1.default.Characteristic.RESULT_UNLIKELY_ERROR;
return result;
}
currentWifi = ssid;
currentAddr = getIp();
log.info(`Connected to AP`, { ssid, ip: currentAddr });
result = bleno_1.default.Characteristic.RESULT_SUCCESS;
return result;
}
function onWifiRead(offset, callback) {
let result = bleno.Characteristic.RESULT_SUCCESS;
async function onWifiRead(offset, callback) {
let result = bleno_1.default.Characteristic.RESULT_SUCCESS;
let wifiRes = {};
let data;
wifi.list((err, list) => {
if (err) {
result = bleno.Characteristic.RESULT_UNLIKELY_ERROR;
return callback(result);
}
wifiRes.available = list;
wifiRes.current = currentWifi;
wifiRes.ip = currentAddr;
log.info('Discovered available APs', { found: list.length });
data = new Buffer(JSON.stringify(wifiRes));
callback(result, data.slice(offset, data.length));
});
let list;
try {
list = await wifi.list();
}
catch (err) {
result = bleno_1.default.Characteristic.RESULT_UNLIKELY_ERROR;
return callback(result);
}
wifiRes.available = list;
wifiRes.current = currentWifi;
wifiRes.ip = currentAddr;
log.info('Discovered available APs', { found: list.length });
data = new Buffer(JSON.stringify(wifiRes));
return callback(result, data.slice(offset, data.length));
}
function getMac() {
const colonRe = new RegExp(':', 'g');
@ -102,15 +115,15 @@ function getMac() {
function spoofMac() {
const fs = require('fs');
const FSPATH = require.resolve('uuid');
const IDFILE = os.homedir() + '/.intval3id';
const IDFILE = os_1.homedir() + '/.intval3id';
let uuid;
let UUIDPATH;
let TMP;
let MACTMP;
let dashRe;
delete require.cache[FSPATH];
if (fs.existsSync(IDFILE)) {
return fs.readFileSync(IDFILE, 'utf8');
if (fs_extra_1.existsSync(IDFILE)) {
return fs_extra_1.readFileSync(IDFILE, 'utf8');
}
uuid = require('uuid').v4;
UUIDPATH = require.resolve('uuid');
@ -118,13 +131,13 @@ function spoofMac() {
TMP = uuid();
MACTMP = TMP.replace(dashRe, '').substring(0, 12);
dashRe = new RegExp('-', 'g');
fs.writeFileSync(IDFILE, MACTMP, 'utf8');
fs_extra_1.writeFileSync(IDFILE, MACTMP, 'utf8');
return MACTMP;
}
function getIp() {
let addr = null;
let ipv4;
const ifaces = os.networkInterfaces();
const ifaces = os_1.networkInterfaces();
if (ifaces && ifaces.wlan0) {
ipv4 = ifaces.wlan0.filter(iface => {
if (iface.family === 'IPv4') {
@ -137,8 +150,8 @@ function getIp() {
}
return addr;
}
function capitalize(s) {
return s[0].toUpperCase() + s.slice(1);
function capitalize(str) {
return str[0].toUpperCase() + str.slice(1);
}
/** Class representing the bluetooth interface */
class BLE {
@ -150,42 +163,47 @@ class BLE {
constructor(bleGetState) {
log.info('Starting bluetooth service');
getState = bleGetState;
bleno.on('stateChange', state => {
bleno_1.default.on('stateChange', state => {
log.info('stateChange', { state: state });
if (state === 'poweredOn') {
log.info('Starting advertising', { DEVICE_NAME, DEVICE_ID: process.env.BLENO_DEVICE_NAME });
bleno.startAdvertising(DEVICE_NAME, [CHAR_ID]);
bleno_1.default.startAdvertising(DEVICE_NAME, [CHAR_ID]);
}
else {
bleno.stopAdvertising();
bleno_1.default.stopAdvertising();
}
});
bleno.on('advertisingStart', err => {
bleno_1.default.on('advertisingStart', err => {
log.info('advertisingStart', { res: (err ? 'error ' + err : 'success') });
createChars(this._onWrite.bind(this), this._onRead.bind(this));
if (!err) {
bleno.setServices([
new bleno.PrimaryService({
bleno_1.default.setServices([
new bleno_1.default.PrimaryService({
uuid: SERVICE_ID,
characteristics: chars
})
]);
}
});
bleno.on('accept', clientAddress => {
bleno_1.default.on('accept', clientAddress => {
log.info('accept', { clientAddress: clientAddress });
});
bleno.on('disconnect', clientAddress => {
bleno_1.default.on('disconnect', clientAddress => {
log.info('disconnect', { clientAddress: clientAddress });
});
wifi.getNetwork((err, ssid) => {
if (err) {
return log.error('wifi.getNetwork', err);
}
currentWifi = ssid;
currentAddr = getIp();
log.info('wifi.getNetwork', { ssid: ssid, ip: currentAddr });
});
this._refreshWifi();
}
async _refreshWifi() {
let ssid;
try {
ssid = await wifi.getNetwork();
}
catch (err) {
return log.error('wifi.getNetwork', err);
}
currentWifi = ssid;
currentAddr = getIp();
log.info('wifi.getNetwork', { ssid: ssid, ip: currentAddr });
}
_onWrite(data, offset, withoutResponse, callback) {
let result = {};
@ -194,12 +212,12 @@ class BLE {
let fn;
if (offset) {
log.warn(`Offset scenario`);
result = bleno.Characteristic.RESULT_ATTR_NOT_LONG;
result = bleno_1.default.Characteristic.RESULT_ATTR_NOT_LONG;
return callback(result);
}
utf8 = data.toString('utf8');
obj = JSON.parse(utf8);
result = bleno.Characteristic.RESULT_SUCCESS;
result = bleno_1.default.Characteristic.RESULT_SUCCESS;
fn = `_on${capitalize(obj.type)}`;
if (obj.type && this[fn]) {
return this[fn](obj, () => {
@ -211,7 +229,7 @@ class BLE {
}
}
_onRead(offset, callback) {
const result = bleno.Characteristic.RESULT_SUCCESS;
const result = bleno_1.default.Characteristic.RESULT_SUCCESS;
const state = getState();
const data = new Buffer(JSON.stringify(state));
callback(result, data.slice(offset, data.length));

2
lib/ble/index.js.map
View File

File diff suppressed because one or more lines are too long

204
lib/wifi/index.js
View File

@ -10,114 +10,117 @@ const iwgetid = '/sbin/iwgetid';
const log = require('../log')('wifi');
const child_process_1 = require("child_process");
const fs_1 = require("fs");
let _entry = null;
let _ssid = null;
/** Class representing the wifi features */
class Wifi {
constructor() {
this._cb = null;
this._ssid = null;
this._entry = null;
}
/**
* List available wifi access points
*
* @param {function} callback Function which gets invoked after list is returned
*/
list(callback) {
child_process_1.exec(iwlist, (err, stdout, stderr) => {
if (err) {
console.error(err);
return callback(err);
}
const limit = 20;
const lines = stdout.split('\n');
let output = [];
let line;
let i = 0;
for (let l of lines) {
line = l.replace('ESSID:', '').trim();
if (line !== '""' && i < limit) {
line = line.replace(quoteRe, '');
output.push(line);
async list() {
return new Promise((resolve, reject) => {
return child_process_1.exec(iwlist, (err, stdout, stderr) => {
if (err) {
log.error('list', err);
return reject(err);
}
i++;
}
output = output.filter(ap => {
if (ap !== '')
return ap;
const limit = 20;
const lines = stdout.split('\n');
let output = [];
let line;
let i = 0;
for (let l of lines) {
line = l.replace('ESSID:', '').trim();
if (line !== '""' && i < limit) {
line = line.replace(quoteRe, '');
output.push(line);
}
i++;
}
output = output.filter(ap => {
if (ap !== '')
return ap;
});
return resolve(output);
});
return callback(null, output);
});
}
/**
* (internal function) Invoked after config file is read,
* then invokes file write on the config file
*
* @param {object} err (optional) Error object only present if problem reading config file
* @param {string} data Contents of the config file
*/
_readConfigCb(err, data) {
async _readConfig() {
let data;
let parsed;
let current;
if (err) {
console.error(err);
return this._cb(err);
try {
data = await fs_1.readFile(filePath, 'utf8');
}
catch (err) {
log.error('_readConfig', err);
throw err;
}
parsed = this._parseConfig(data);
current = parsed.find((network) => {
return network.ssid === _ssid;
return network.ssid === this._ssid;
});
if (typeof current !== 'undefined') {
data = data.replace(current.raw, _entry);
data = data.replace(current.raw, this._entry);
}
else {
data += '\n\n' + _entry;
data += '\n\n' + this._entry;
}
_entry = null;
fs_1.writeFile(filePath, data, 'utf8', this._writeConfigCb.bind(this));
this._entry = null;
return data;
}
/**
* (internal function) Invoked after config file is written,
* then executes reconfiguration command
*
* @param {object} err (optional) Error object only present if problem writing config file
*/
_writeConfigCb(err) {
if (err) {
console.error(err);
return this._cb(err);
async _writeConfig(data) {
try {
await fs_1.writeFile(filePath, data, { encoding: 'utf-8' });
}
catch (err) {
log.error('_readConfigCb', err);
throw err;
}
child_process_1.exec(reconfigure, this._reconfigureCb.bind(this));
}
/**
* (internal function) Invoked after reconfiguration command is complete
*
* @param {object} err (optional) Error object only present if configuration command fails
* @param {string} stdout Standard output from reconfiguration command
* @param {string} stderr Error output from command if fails
*/
_reconfigureCb(err, stdout, stderr) {
if (err) {
console.error(err);
return this._cb(err);
}
log.info('Wifi reconfigured');
child_process_1.exec(refresh, this._refreshCb.bind(this));
async _reconfigure() {
return new Promise((resolve, reject) => {
return child_process_1.exec(reconfigure, (err, stdout, stderr) => {
if (err) {
return reject(err);
}
log.info('Wifi reconfigured');
return resolve(true);
});
});
}
/**
* (internal function) Invoked after wifi refresh command is complete
*
* @param {object} err (optional) Error object only present if refresh command fails
* @param {string} stdout Standard output from refresh command
* @param {string} stderr Error output from command if fails
*/
_refreshCb(err, stdout, stderr) {
if (err) {
console.error(err);
return this._cb(err);
}
log.info('Wifi refreshed');
this._cb(null, { ssid: _ssid });
this._cb = () => { };
async _refresh() {
return new Promise((resolve, reject) => {
return child_process_1.exec(refresh, (err, stdout, stderr) => {
if (err) {
return reject(err);
}
log.info('Wifi refreshed');
return resolve({ ssid: this._ssid });
});
});
}
_parseConfig(str) {
const networks = [];
@ -157,21 +160,22 @@ class Wifi {
*
* @param {string} ssid SSID of wifi network
* @param {string} pwd Plaintext passphrase of wifi network
* @param {function} callback Function called after psk hash is generated
*/
createPSK(ssid, pwd, callback) {
createPSK(ssid, pwd) {
const cmd = `wpa_passphrase '${ssid.replace(/'/g, `'\\''`)}' '${pwd.replace(/'/g, `'\\''`)}' | grep "psk="`;
let lines;
let hash;
let plaintext;
child_process_1.exec(cmd, (err, stdout, stderr) => {
if (err) {
return callback(err);
}
lines = stdout.replace('#psk=', '').split('psk=');
hash = lines[1];
plaintext = lines[0];
callback(null, hash.trim(), plaintext.trim());
return new Promise((resolve, reject) => {
return child_process_1.exec(cmd, (err, stdout, stderr) => {
if (err) {
return reject(err);
}
lines = stdout.replace('#psk=', '').split('psk=');
hash = lines[1];
plaintext = lines[0];
return resolve({ hash: hash.trim(), plaintext: plaintext.trim() });
});
});
}
/**
@ -180,30 +184,56 @@ class Wifi {
* @param {string} ssid SSID of network to configure
* @param {string} pwd Password of access point, plaintext to be masked
* @param {string} hash Password/SSID of access point, securely hashed
* @param {function} callback Function invoked after process is complete, or fails
*/
setNetwork(ssid, pwd, hash, callback) {
async setNetwork(ssid, pwd, hash) {
let masked = pwd.split('').map(char => { return char !== '"' ? '*' : '"'; }).join('');
_entry = `network={\n\tssid="${ssid}"\n\t#psk=${masked}\n\tpsk=${hash}\n}\n`;
this._cb = callback;
_ssid = ssid;
fs_1.readFile(filePath, 'utf8', this._readConfigCb.bind(this));
let data;
this._entry = `network={\n\tssid="${ssid}"\n\t#psk=${masked}\n\tpsk=${hash}\n}\n`;
this._ssid = ssid;
try {
data = await this._readConfig();
}
catch (err) {
log.error(err);
}
try {
await this._writeConfig(data);
}
catch (err) {
log.error(err);
}
try {
await this._reconfigure();
}
catch (err) {
log.error(err);
}
try {
await this._refresh();
}
catch (err) {
log.error(err);
}
return { ssid: this._ssid };
}
/**
* Executes command which gets the currently connected network
*
* @param {function} callback Function which is invoked after command is completed
*/
getNetwork(callback) {
async getNetwork() {
let output;
child_process_1.exec(iwgetid, (err, stdout, stderr) => {
if (err) {
return callback(err);
}
output = stdout.split('ESSID:')[1].replace(quoteRe, '').trim();
callback(null, output);
return new Promise((resolve, reject) => {
return child_process_1.exec(iwgetid, (err, stdout, stderr) => {
if (err) {
return reject(err);
}
output = stdout.split('ESSID:')[1].replace(quoteRe, '').trim();
return resolve(output);
});
});
}
}
module.exports = new Wifi();
exports.Wifi = Wifi;
module.exports.Wifi = Wifi;
//# sourceMappingURL=index.js.map

2
lib/wifi/index.js.map
View File

File diff suppressed because one or more lines are too long

9
package-lock.json generated
View File

@ -57,6 +57,15 @@
"integrity": "sha512-shAmDyaQC4H92APFoIaVDHCx5bStIocgvbwQyxPRrbUY20V1EYTbSDchWbuwlMG3V17cprZhA6+78JfB+3DTPw==",
"dev": true
},
"@types/bleno": {
"version": "0.4.1",
"resolved": "https://registry.npmjs.org/@types/bleno/-/bleno-0.4.1.tgz",
"integrity": "sha512-CY4CG5jFURnigEi1qQVnKgtyxg7jQEAmTjBpawejmt91XRThKowP90IvZksv/Qrjfh5IgZIGLe0SXGMUpwS6ZA==",
"dev": true,
"requires": {
"@types/node": "*"
}
},
"@types/events": {
"version": "3.0.0",
"resolved": "https://registry.npmjs.org/@types/events/-/events-3.0.0.tgz",

1
package.json
View File

@ -43,6 +43,7 @@
"winston": "^3.2.1"
},
"devDependencies": {
"@types/bleno": "^0.4.1",
"@types/fs-extra": "^8.0.0",
"@types/node": "^12.7.12",
"@types/node-persist": "0.0.33",

208
src/ble/index.ts
View File

@ -3,38 +3,51 @@
/** @module ble */
/** Bluetooth Low Energy module */
const util = require('util')
const os = require('os')
import { inherits } from 'util'
import { networkInterfaces, homedir } from 'os'
import { readFileSync, existsSync, writeFileSync } from 'fs-extra'
const log = require('../log')('ble')
const wifi = require('../wifi')
import { Wifi } from '../wifi'
const wifi = new Wifi()
const DEVICE_NAME = process.env.DEVICE_NAME || 'intval3'
const SERVICE_ID = process.env.SERVICE_ID || 'intval3_ble'
const CHAR_ID = process.env.CHAR_ID || 'intval3char'
const WIFI_ID = process.env.WIFI_ID || 'wifichar'
const NETWORK = os.networkInterfaces()
const MAC = getMac() || spoofMac()
const DEVICE_NAME : string = process.env.DEVICE_NAME || 'intval3'
const SERVICE_ID : string = process.env.SERVICE_ID || 'intval3_ble'
const CHAR_ID : string = process.env.CHAR_ID || 'intval3char'
const WIFI_ID : string = process.env.WIFI_ID || 'wifichar'
const NETWORK : any = networkInterfaces() //?type?
const MAC : string = getMac() || spoofMac()
//Give the device a unique device name, needs to be in env
process.env.BLENO_DEVICE_NAME += '_' + MAC
const bleno = require('bleno')
import bleno from 'bleno'
const { Characteristic } = bleno
let currentWifi : string = 'disconnected'
let currentAddr : string = null
let getState : Function
let currentWifi = 'disconnected'
let currentAddr = null
let getState
const chars : any[] = []
const chars = []
interface WifiInfo {
ssid : string
pwd : string
}
function createChar(name, uuid, prop, write, read) {
function characteristic () {
bleno.Characteristic.call(this, {
uuid : uuid,
interface WifiResponse {
available : string[]
current : string
ip : string
}
function createChar(name : string, uuid : string, prop : string[], write : Function, read : Function) {
const characteristic : any = function () {
Characteristic.call(this, {
uuid,
properties: prop
})
}
util.inherits(characteristic, bleno.Characteristic)
inherits(characteristic, Characteristic)
if (prop.indexOf('read') !== -1) {
//data, offset, withoutResponse, callback
characteristic.prototype.onReadRequest = read
@ -45,64 +58,76 @@ function createChar(name, uuid, prop, write, read) {
chars.push(new characteristic())
}
function createChars (onWrite, onRead) {
createChar('intval3', CHAR_ID, ['read', 'write'], onWrite, onRead)
createChar('wifi', WIFI_ID, ['read', 'write'], onWifiWrite, onWifiRead)
function createChars (onWrite : Function, onRead : Function) {
const permissions : string[] = ['read', 'write'];
createChar('intval3', CHAR_ID, permissions, onWrite, onRead)
createChar('wifi', WIFI_ID, permissions, onWifiWrite, onWifiRead)
}
function onWifiWrite (data, offset, withoutResponse, callback) {
let result
let utf8
let obj
let ssid
let pwd
async function onWifiWrite (data : any, offset : number) {
let result : any
let utf8 : string
let obj : WifiInfo = {} as WifiInfo
let ssid : string
let pwd : string
let psk : any
if (offset) {
log.warn(`Offset scenario`)
result = bleno.Characteristic.RESULT_ATTR_NOT_LONG
return callback(result)
}
return result
}
utf8 = data.toString('utf8')
obj = JSON.parse(utf8)
ssid = obj.ssid
pwd = obj.pwd
log.info(`connecting to AP`, { ssid : ssid })
return wifi.createPSK(ssid, pwd, (err, hash, plaintext) => {
if (err) {
log.error('Error hashing wifi password', err)
result = bleno.Characteristic.RESULT_UNLIKELY_ERROR
return callback(result)
}
return wifi.setNetwork(ssid, plaintext, hash, (err, data) => {
if (err) {
log.error('Error configuring wifi', err)
result = bleno.Characteristic.RESULT_UNLIKELY_ERROR
return callback(result)
}
currentWifi = ssid
currentAddr = getIp()
log.info(`Connected to AP`, { ssid : ssid, ip : currentAddr })
result = bleno.Characteristic.RESULT_SUCCESS
return callback(result)
})
})
log.info(`connecting to AP`, { ssid : ssid })
try {
psk = await wifi.createPSK(ssid, pwd)
} catch (err) {
log.error('Error hashing wifi password', err)
result = bleno.Characteristic.RESULT_UNLIKELY_ERROR
return result
}
try {
await wifi.setNetwork(ssid, psk.plaintext, psk.hash)
} catch (err) {
log.error('Error configuring wifi', err)
result = bleno.Characteristic.RESULT_UNLIKELY_ERROR
return result
}
currentWifi = ssid
currentAddr = getIp()
log.info(`Connected to AP`, { ssid, ip : currentAddr })
result = bleno.Characteristic.RESULT_SUCCESS
return result
}
function onWifiRead (offset, callback) {
let result = bleno.Characteristic.RESULT_SUCCESS
let wifiRes = {}
let data
wifi.list((err, list) => {
if (err) {
result = bleno.Characteristic.RESULT_UNLIKELY_ERROR
return callback(result)
}
wifiRes.available = list
wifiRes.current = currentWifi
wifiRes.ip = currentAddr
log.info('Discovered available APs', { found : list.length })
data = new Buffer(JSON.stringify(wifiRes))
callback(result, data.slice(offset, data.length))
})
async function onWifiRead (offset : number, callback : Function) {
let result : any = bleno.Characteristic.RESULT_SUCCESS
let wifiRes : WifiResponse = {} as WifiResponse
let data : any
let list : any
try {
list = await wifi.list()
} catch (err) {
result = bleno.Characteristic.RESULT_UNLIKELY_ERROR
return callback(result)
}
wifiRes.available = list
wifiRes.current = currentWifi
wifiRes.ip = currentAddr
log.info('Discovered available APs', { found : list.length })
data = new Buffer(JSON.stringify(wifiRes))
return callback(result, data.slice(offset, data.length))
}
function getMac () {
@ -116,15 +141,15 @@ function getMac () {
function spoofMac () {
const fs = require('fs')
const FSPATH = require.resolve('uuid')
const IDFILE = os.homedir() + '/.intval3id'
const IDFILE = homedir() + '/.intval3id'
let uuid
let UUIDPATH
let TMP
let MACTMP
let dashRe
delete require.cache[FSPATH]
if (fs.existsSync(IDFILE)) {
return fs.readFileSync(IDFILE, 'utf8')
if (existsSync(IDFILE)) {
return readFileSync(IDFILE, 'utf8')
}
uuid = require('uuid').v4
UUIDPATH = require.resolve('uuid')
@ -132,14 +157,14 @@ function spoofMac () {
TMP = uuid()
MACTMP = TMP.replace(dashRe, '').substring(0, 12)
dashRe = new RegExp('-', 'g')
fs.writeFileSync(IDFILE, MACTMP, 'utf8')
writeFileSync(IDFILE, MACTMP, 'utf8')
return MACTMP
}
function getIp () {
let addr = null
let ipv4
const ifaces = os.networkInterfaces()
const ifaces = networkInterfaces()
if (ifaces && ifaces.wlan0) {
ipv4 = ifaces.wlan0.filter(iface => {
if (iface.family === 'IPv4') {
@ -154,8 +179,8 @@ function getIp () {
}
function capitalize (s) {
return s[0].toUpperCase() + s.slice(1)
function capitalize (str : string) {
return str[0].toUpperCase() + str.slice(1)
}
/** Class representing the bluetooth interface */
@ -165,7 +190,7 @@ class BLE {
*
* @constructor
*/
constructor (bleGetState) {
constructor (bleGetState : Function) {
log.info('Starting bluetooth service')
getState = bleGetState
@ -201,29 +226,38 @@ class BLE {
log.info('disconnect', { clientAddress : clientAddress })
})
wifi.getNetwork((err, ssid) => {
if (err) {
return log.error('wifi.getNetwork', err)
}
currentWifi = ssid
currentAddr = getIp()
log.info('wifi.getNetwork', {ssid : ssid, ip : currentAddr })
})
this._refreshWifi()
}
_onWrite (data, offset, withoutResponse, callback) {
private async _refreshWifi () {
let ssid : string
try {
ssid = await wifi.getNetwork() as string
} catch (err) {
return log.error('wifi.getNetwork', err)
}
currentWifi = ssid
currentAddr = getIp()
log.info('wifi.getNetwork', {ssid : ssid, ip : currentAddr })
}
private _onWrite (data : any, offset : number, withoutResponse : Function, callback : Function) {
let result = {}
let utf8
let obj
let fn
if (offset) {
log.warn(`Offset scenario`)
result = bleno.Characteristic.RESULT_ATTR_NOT_LONG
return callback(result)
}
}
utf8 = data.toString('utf8')
obj = JSON.parse(utf8)
result = bleno.Characteristic.RESULT_SUCCESS
fn = `_on${capitalize(obj.type)}`
fn = `_on${capitalize(obj.type)}`
if (obj.type && this[fn]) {
return this[fn](obj, () => {
callback(result)
@ -233,7 +267,7 @@ class BLE {
}
}
_onRead (offset, callback) {
private _onRead (offset : number, callback : Function) {
const result = bleno.Characteristic.RESULT_SUCCESS
const state = getState()
const data = new Buffer(JSON.stringify( state ))
@ -245,7 +279,7 @@ class BLE {
* @param {string} eventName Name of the event to to bind
* @param {function} callback Invoked when the event is triggered
*/
on (eventName, callback) {
on (eventName : string, callback : Function) {
this[`_on${capitalize(eventName)}`] = callback
}

215
src/wifi/index.ts
View File

@ -12,9 +12,7 @@ const iwgetid : string = '/sbin/iwgetid'
const log : any = require('../log')('wifi')
import { exec } from 'child_process'
import { readFile, writeFile } from 'fs'
let _entry : string = null
let _ssid : string = null
import { reject } from 'q'
interface Network {
raw : string
@ -22,8 +20,10 @@ interface Network {
}
/** Class representing the wifi features */
class Wifi {
private _cb : Function = null
export class Wifi {
private _ssid : string = null
private _entry : string = null
constructor () {
}
@ -32,102 +32,110 @@ class Wifi {
*
* @param {function} callback Function which gets invoked after list is returned
*/
list (callback : Function) {
exec(iwlist, (err, stdout, stderr) => {
if (err) {
console.error(err)
return callback(err)
}
const limit = 20;
const lines = stdout.split('\n')
let output = []
let line
let i = 0
for (let l of lines) {
line = l.replace('ESSID:', '').trim()
if (line !== '""' && i < limit) {
line = line.replace(quoteRe, '')
output.push(line)
public async list () {
return new Promise ((resolve : Function, reject : Function) => {
return exec(iwlist, (err, stdout, stderr) => {
if (err) {
log.error('list', err)
return reject(err)
}
i++
}
output = output.filter(ap => {
if (ap !== '') return ap
const limit : number = 20;
const lines : string[] = stdout.split('\n')
let output : string[] = []
let line : string
let i = 0
for (let l of lines) {
line = l.replace('ESSID:', '').trim()
if (line !== '""' && i < limit) {
line = line.replace(quoteRe, '')
output.push(line)
}
i++
}
output = output.filter(ap => {
if (ap !== '') return ap
})
return resolve(output)
})
return callback(null, output)
})
}
/**
* (internal function) Invoked after config file is read,
* then invokes file write on the config file
*
* @param {object} err (optional) Error object only present if problem reading config file
* @param {string} data Contents of the config file
*/
_readConfigCb (err : Error, data : string) {
async _readConfig () {
let data : string
let parsed : Network[]
let current : Network
if (err) {
console.error(err)
return this._cb(err)
try {
data = await readFile(filePath, 'utf8')
} catch (err) {
log.error('_readConfig', err)
throw err
}
parsed = this._parseConfig(data)
current = parsed.find((network : Network) => {
return network.ssid === _ssid
return network.ssid === this._ssid
})
if (typeof current !== 'undefined') {
data = data.replace(current.raw, _entry)
data = data.replace(current.raw, this._entry)
} else {
data += '\n\n' + _entry
data += '\n\n' + this._entry
}
_entry = null
writeFile(filePath, data, 'utf8', this._writeConfigCb.bind(this))
this._entry = null
return data
}
/**
* (internal function) Invoked after config file is written,
* then executes reconfiguration command
*
* @param {object} err (optional) Error object only present if problem writing config file
*/
_writeConfigCb (err : Error) {
if (err) {
console.error(err)
return this._cb(err)
private async _writeConfig (data : string) {
try {
await writeFile(filePath, data, { encoding : 'utf-8' })
} catch (err) {
log.error('_readConfigCb', err)
throw err
}
exec(reconfigure, this._reconfigureCb.bind(this))
}
/**
* (internal function) Invoked after reconfiguration command is complete
*
* @param {object} err (optional) Error object only present if configuration command fails
* @param {string} stdout Standard output from reconfiguration command
* @param {string} stderr Error output from command if fails
*/
_reconfigureCb (err : Error, stdout : string, stderr : string) {
if (err) {
console.error(err)
return this._cb(err)
}
log.info('Wifi reconfigured')
exec(refresh, this._refreshCb.bind(this))
private async _reconfigure () {
return new Promise((resolve : Function, reject : Function) => {
return exec(reconfigure, (err : Error, stdout : string, stderr : string) => {
if (err) {
return reject(err)
}
log.info('Wifi reconfigured')
return resolve(true)
})
})
}
/**
* (internal function) Invoked after wifi refresh command is complete
*
* @param {object} err (optional) Error object only present if refresh command fails
* @param {string} stdout Standard output from refresh command
* @param {string} stderr Error output from command if fails
*/
_refreshCb (err : Error, stdout : string, stderr : string) {
if (err) {
console.error(err)
return this._cb(err)
}
log.info('Wifi refreshed')
this._cb(null, { ssid : _ssid })
this._cb = () => {}
private async _refresh () {
return new Promise((resolve : Function, reject : Function) => {
return exec(refresh, (err : Error, stdout : string, stderr : string) => {
if (err) {
return reject(err)
}
log.info('Wifi refreshed')
return resolve({ ssid : this._ssid });
})
})
}
_parseConfig (str : string) : Network[] {
private _parseConfig (str : string) : Network[] {
const networks : Network[] = []
const lines = str.split('\n')
let network : Network = {} as Network
@ -162,21 +170,22 @@ class Wifi {
*
* @param {string} ssid SSID of wifi network
* @param {string} pwd Plaintext passphrase of wifi network
* @param {function} callback Function called after psk hash is generated
*/
createPSK (ssid : string, pwd : string, callback : Function) {
createPSK (ssid : string, pwd : string) {
const cmd : string = `wpa_passphrase '${ssid.replace(/'/g, `'\\''`)}' '${pwd.replace(/'/g, `'\\''`)}' | grep "psk="`
let lines : string[]
let hash : string
let plaintext : string
exec(cmd, (err, stdout, stderr) => {
if (err) {
return callback(err)
}
lines = stdout.replace('#psk=', '').split('psk=')
hash = lines[1]
plaintext = lines[0]
callback(null, hash.trim(), plaintext.trim())
return new Promise ((resolve : Function, reject : Function) => {
return exec(cmd, (err, stdout, stderr) => {
if (err) {
return reject(err)
}
lines = stdout.replace('#psk=', '').split('psk=')
hash = lines[1]
plaintext = lines[0]
return resolve({ hash : hash.trim(), plaintext : plaintext.trim()})
})
})
}
/**
@ -185,30 +194,54 @@ class Wifi {
* @param {string} ssid SSID of network to configure
* @param {string} pwd Password of access point, plaintext to be masked
* @param {string} hash Password/SSID of access point, securely hashed
* @param {function} callback Function invoked after process is complete, or fails
*/
setNetwork (ssid : string, pwd : string, hash : string, callback : Function) {
async setNetwork (ssid : string, pwd : string, hash : string) {
let masked : string = pwd.split('').map(char => { return char !== '"' ? '*' : '"' }).join('')
_entry = `network={\n\tssid="${ssid}"\n\t#psk=${masked}\n\tpsk=${hash}\n}\n`
this._cb = callback
_ssid = ssid
readFile(filePath, 'utf8', this._readConfigCb.bind(this))
let data : string
this._entry = `network={\n\tssid="${ssid}"\n\t#psk=${masked}\n\tpsk=${hash}\n}\n`
this._ssid = ssid
try {
data = await this._readConfig()
} catch (err) {
log.error(err)
}
try {
await this._writeConfig(data)
} catch (err) {
log.error(err)
}
try {
await this._reconfigure()
} catch (err) {
log.error(err)
}
try {
await this._refresh()
} catch (err) {
log.error(err)
}
return { ssid : this._ssid }
}
/**
* Executes command which gets the currently connected network
*
* @param {function} callback Function which is invoked after command is completed
*/
getNetwork (callback : Function) {
let output
exec(iwgetid, (err, stdout, stderr) => {
if (err) {
return callback(err)
}
output = stdout.split('ESSID:')[1].replace(quoteRe, '').trim()
callback(null, output)
})
public async getNetwork () {
let output : string
return new Promise((resolve : Function, reject : Function) => {
return exec(iwgetid, (err : Error, stdout : string, stderr : string) => {
if (err) {
return reject(err)
}
output = stdout.split('ESSID:')[1].replace(quoteRe, '').trim()
return resolve(output)
})
})
}
}
module.exports = new Wifi()
module.exports.Wifi = Wifi