-
Notifications
You must be signed in to change notification settings - Fork 0
/
homekit-pair.js
58 lines (53 loc) · 1.99 KB
/
homekit-pair.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
module.exports = function (RED) {
function HomekitPairingNode(config) {
const { HttpClient, IPDiscovery } = require('hap-controller');
const discovery = new IPDiscovery();
RED.nodes.createNode(this, config);
var node = this;
this.PairingDataDB = RED.nodes.getNode(config.pairingData);
// Handle incoming messages with list of deivces in array.
node.on('input', async function (msg) {
let HomeKitAccessory = msg.payload.HomeKitAccessory;
let service = HomeKitAccessory
if (service != null) {
if (service.availableToPair) {
try {
pin = msg.payload.pairingPin;
//run pair
const pairMethod = await discovery.getPairMethod(service);
const client = new HttpClient(service.id, service.address, service.port);
await client.pairSetup(pin, pairMethod);
let pairingData = await client.getLongTermData();
client.close();
//Save Pairing Data to JSON DB
console.log(`${service.id}: ${pairingData}`)
await this.PairingDataDB.SaveData(service.id,
{
id: service.id,
name: service.name,
pairingData: pairingData
});
//update msg
msg.payload.pairingData = pairingData
let pairingDataOutputMsg = {
msg: {
id: service.id,
name: service.name,
pairingData: pairingData
}
}
node.send([msg, pairingDataOutputMsg, null]);
} catch (e) {
console.error(`${service.name}: `, e);
node.send([null, null, e]);
}
} else {
var sendMsg = { payload: { error: "Can't pair accessory. It is already paired with a HomeKit controller.", device: (service) } }
node.send(null, sendMsg);
}
}
});
}
// Register the node type
RED.nodes.registerType("homekit-pair", HomekitPairingNode);
};