Compare commits
14 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 2612f61082 | |||
| 5a8b03a038 | |||
| 6c363f8d8c | |||
| cea0c3f1cf | |||
| 2b13f78a0d | |||
| 810431d82b | |||
| 118a8912f6 | |||
| f78c9d961c | |||
| ae78cb2358 | |||
| 7d89f6b945 | |||
| 94dc6a37b9 | |||
| 38ffdec2db | |||
| c28de00928 | |||
| 9d76b8297e |
@ -1 +0,0 @@
|
|||||||
source /nvm.sh
|
|
||||||
41
.drone.yml
Normal file
41
.drone.yml
Normal file
@ -0,0 +1,41 @@
|
|||||||
|
kind: pipeline
|
||||||
|
type: docker
|
||||||
|
name: default
|
||||||
|
|
||||||
|
clone:
|
||||||
|
disable: true
|
||||||
|
|
||||||
|
steps:
|
||||||
|
- name: clone
|
||||||
|
image: alpine/git
|
||||||
|
commands:
|
||||||
|
- git clone https://gitea.watsonlabs.net/watsonb8/homebridge-harmony-control.git .
|
||||||
|
- git checkout $DRONE_COMMIT
|
||||||
|
|
||||||
|
- name: build
|
||||||
|
image: node
|
||||||
|
commands:
|
||||||
|
- npm install
|
||||||
|
- npm run build
|
||||||
|
|
||||||
|
- name: publish
|
||||||
|
image: plugins/npm
|
||||||
|
settings:
|
||||||
|
username: admin
|
||||||
|
password:
|
||||||
|
from_secret: npm_password
|
||||||
|
email: brandon@watsonlabs.net
|
||||||
|
registry: "http://linuxhost.me:4873/"
|
||||||
|
when:
|
||||||
|
event:
|
||||||
|
- tag
|
||||||
|
|
||||||
|
notify:
|
||||||
|
image: drillster/drone-email
|
||||||
|
host: smtp.watsonlabs.net
|
||||||
|
username: srvGitea
|
||||||
|
password:
|
||||||
|
from_secret: smtp_password
|
||||||
|
from: drone@watsonlabs.net
|
||||||
|
when:
|
||||||
|
status: [failure]
|
||||||
33
.vscode/launch.json
vendored
33
.vscode/launch.json
vendored
@ -1,16 +1,19 @@
|
|||||||
{
|
{
|
||||||
// Use IntelliSense to learn about possible attributes.
|
// Use IntelliSense to learn about possible attributes.
|
||||||
// Hover to view descriptions of existing attributes.
|
// Hover to view descriptions of existing attributes.
|
||||||
// For more information, visit: https://go.microsoft.com/fwlink/?linkid=830387
|
// For more information, visit: https://go.microsoft.com/fwlink/?linkid=830387
|
||||||
"version": "0.2.0",
|
"version": "0.2.0",
|
||||||
"configurations": [
|
"configurations": [
|
||||||
{
|
{
|
||||||
"type": "node",
|
"type": "node",
|
||||||
"request": "launch",
|
"request": "launch",
|
||||||
"name": "Launch Program",
|
"name": "Launch Program",
|
||||||
"preLaunchTask": "build and install",
|
"preLaunchTask": "build",
|
||||||
"program": "/Users/brandonwatson/.npm-global/bin/homebridge",
|
"program": "/Users/brandonwatson/.nvm/versions/node/v14.15.0/lib/node_modules/homebridge/bin/homebridge",
|
||||||
"sourceMaps": true,
|
"env": {
|
||||||
}
|
"HOMEBRIDGE_OPTS": "/Users/brandonwatson/.homebridge"
|
||||||
]
|
},
|
||||||
}
|
"sourceMaps": true
|
||||||
|
}
|
||||||
|
]
|
||||||
|
}
|
||||||
|
|||||||
33
.vscode/tasks.json
vendored
33
.vscode/tasks.json
vendored
@ -1,17 +1,18 @@
|
|||||||
{
|
{
|
||||||
// See https://go.microsoft.com/fwlink/?LinkId=733558
|
// See https://go.microsoft.com/fwlink/?LinkId=733558
|
||||||
// for the documentation about the tasks.json format
|
// for the documentation about the tasks.json format
|
||||||
"version": "2.0.0",
|
"version": "2.0.0",
|
||||||
"tasks": [
|
"tasks": [
|
||||||
{
|
{
|
||||||
"type": "npm",
|
"type": "npm",
|
||||||
"script": "build",
|
"script": "build",
|
||||||
"problemMatcher": []
|
"label": "build",
|
||||||
},
|
"problemMatcher": []
|
||||||
{
|
},
|
||||||
"type": "shell",
|
{
|
||||||
"label": "build and install",
|
"type": "shell",
|
||||||
"command": "npm run build&&sudo npm install -g --unsafe-perm ."
|
"label": "build and install",
|
||||||
}
|
"command": "npm run build&&sudo npm install -g --unsafe-perm ."
|
||||||
]
|
}
|
||||||
}
|
]
|
||||||
|
}
|
||||||
|
|||||||
178
README.md
Normal file
178
README.md
Normal file
@ -0,0 +1,178 @@
|
|||||||
|
# homebridge-harmony-control
|
||||||
|
|
||||||
|
A convenient way to control your home through homekit utilizing one or many Logitech Harmony remotes.
|
||||||
|
|
||||||
|
## Description
|
||||||
|
|
||||||
|
This plugin not only allows for control of your one or many entertainment consoles, but it also supports use of a more complicated matrix switch if applicable. In addition, this plugin can expose any entertainment devices directly to homekit via stateless or stateful switch.
|
||||||
|
|
||||||
|
## Installation
|
||||||
|
|
||||||
|
1. Clone the repository by running `git clone ssh://git@thebword.ddns.net:3122/watsonb8/homebridge-harmony-control.git`
|
||||||
|
2. Run `npm install` to install required modules
|
||||||
|
3. Run `npm run build` to build the module
|
||||||
|
4. Run `npm link` or install globally to link this instance to your global homebridge instance
|
||||||
|
|
||||||
|
## Configuration
|
||||||
|
|
||||||
|
```
|
||||||
|
{
|
||||||
|
"platform": "HarmonyHubMatrix",
|
||||||
|
"EmitDevicesOnStartup": false,
|
||||||
|
"Hubs": [
|
||||||
|
{
|
||||||
|
"Name": "LivingRoomHub",
|
||||||
|
"Ip": "exampleOne.com"
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"Name": "RackHub",
|
||||||
|
"Ip": "exampleTwo.com"
|
||||||
|
}
|
||||||
|
],
|
||||||
|
"Devices": [
|
||||||
|
{
|
||||||
|
"Name": "LG TV",
|
||||||
|
"Hub": "LivingRoomHub"
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"Name": "JVC AV Receiver",
|
||||||
|
"Hub": "LivingRoomHub"
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"Name": "Microsoft Xbox One",
|
||||||
|
"Hub": "RackHub"
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"Name": "Apple TV Gen 4",
|
||||||
|
"Hub": "RackHub"
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"Name": "Gefen AV Switch",
|
||||||
|
"Hub": "RackHub"
|
||||||
|
}
|
||||||
|
],
|
||||||
|
"Matrix": {
|
||||||
|
"DeviceName": "Gefen AV Switch",
|
||||||
|
"Inputs": [
|
||||||
|
{
|
||||||
|
"InputNumber": "1",
|
||||||
|
"InputDevice": "Microsoft Xbox One"
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"InputNumber": "5",
|
||||||
|
"InputDevice": "Apple TV Gen 4"
|
||||||
|
},
|
||||||
|
],
|
||||||
|
"Outputs": [
|
||||||
|
{
|
||||||
|
"OutputLetter": "B",
|
||||||
|
"OutputDevice": "LG TV"
|
||||||
|
},
|
||||||
|
]
|
||||||
|
},
|
||||||
|
"ControlUnits": [
|
||||||
|
{
|
||||||
|
"DisplayName": "Living Room",
|
||||||
|
"Activities": [
|
||||||
|
{
|
||||||
|
"DisplayName": "Xbox One",
|
||||||
|
"DeviceSetupList": [
|
||||||
|
{
|
||||||
|
"DeviceName": "Microsoft Xbox One",
|
||||||
|
"Input": []
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"DeviceName": "LG TV",
|
||||||
|
"Input": "Hdmi1"
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"DeviceName": "JVC AV Receiver",
|
||||||
|
"Input": "Dvd"
|
||||||
|
}
|
||||||
|
],
|
||||||
|
"VolumeDevice": "JVC AV Receiver",
|
||||||
|
"ControlDevice": "Microsoft Xbox One",
|
||||||
|
"OutputDevice": "LG TV",
|
||||||
|
"UseMatrix": true
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"DisplayName": "Apple TV",
|
||||||
|
"DeviceSetupList": [
|
||||||
|
{
|
||||||
|
"DeviceName": "Apple TV Gen 4",
|
||||||
|
"Input": []
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"DeviceName": "LG TV",
|
||||||
|
"Input": "Hdmi1"
|
||||||
|
},
|
||||||
|
{
|
||||||
|
"DeviceName": "JVC AV Receiver",
|
||||||
|
"Input": "Dvd"
|
||||||
|
}
|
||||||
|
],
|
||||||
|
"VolumeDevice": "JVC AV Receiver",
|
||||||
|
"ControlDevice": "Apple TV Gen 4",
|
||||||
|
"OutputDevice": "LG TV",
|
||||||
|
"UseMatrix": true
|
||||||
|
},
|
||||||
|
]
|
||||||
|
},
|
||||||
|
],
|
||||||
|
"DeviceButtons": [
|
||||||
|
{
|
||||||
|
"DeviceName": "JVC AV Receiver",
|
||||||
|
"ButtonName": "SurroundToggle",
|
||||||
|
"DisplayName": "Surround Toggle",
|
||||||
|
"IsStateful": true
|
||||||
|
},
|
||||||
|
]
|
||||||
|
}
|
||||||
|
```
|
||||||
|
|
||||||
|
#### Platform
|
||||||
|
|
||||||
|
- `EmitDevicesOnStartup`: If true, each device frome each hub will be written to the console on startup
|
||||||
|
|
||||||
|
- `Hubs`: A list of harmony hub configurations
|
||||||
|
|
||||||
|
- `Devices`: A list of devices to be used and corresponding hubs
|
||||||
|
|
||||||
|
- `Matrix`: An optional configuration for an hdmi matrix
|
||||||
|
|
||||||
|
- `ControlUnits`: Configures one logical control unit. This is usually a single TV in a single room.
|
||||||
|
|
||||||
|
#### Devices
|
||||||
|
|
||||||
|
- `Name`: The name of the device to use from an existing harmony hub configuration
|
||||||
|
|
||||||
|
> Note: Use `EmitDevicesOnStartup` if you are unsure of which devices are available.
|
||||||
|
|
||||||
|
- `Hub`: The name of the hub to look the device on
|
||||||
|
|
||||||
|
#### Matrix
|
||||||
|
|
||||||
|
- `DeviceName`: The name of the matrix device as seen in the harmony configuration
|
||||||
|
|
||||||
|
> Note: This device must appear in the device list
|
||||||
|
|
||||||
|
- `Inputs`: A list of input devices and their corresponding input number as it relates to the matrix switch
|
||||||
|
|
||||||
|
- `Outputs`: A list of output devices and their corresponding output letter as it relates to the matrix switch
|
||||||
|
|
||||||
|
#### ControlUnits
|
||||||
|
|
||||||
|
This is the logical display unit. It will appear as a tv accessory in the home app.
|
||||||
|
|
||||||
|
- `DisplayName`: The name of the control unit
|
||||||
|
|
||||||
|
- `Activities`: A list of activity configurations. These will be the inputs associated with the tv accessory
|
||||||
|
- `DeviceSetupList`: A list of devices associated with an activity and their corresponding input setting
|
||||||
|
|
||||||
|
- `VolumeDevice`: The device that should be used to control the volume of the activity. This is usually a stereo or a tv
|
||||||
|
|
||||||
|
- `ControlDevice`: The device that is used to control UI navigation
|
||||||
|
|
||||||
|
- `OutputDevice`: The device that is used to display the content. This is usually a TV
|
||||||
|
|
||||||
|
- `UseMatrix`: If true, corresponding commands will be issued to the matrix device to route input to output
|
||||||
303
config.json
303
config.json
@ -1,303 +0,0 @@
|
|||||||
{
|
|
||||||
"bridge": {
|
|
||||||
"name": "Homebridge",
|
|
||||||
"username": "CC:22:3D:E3:CE:74",
|
|
||||||
"port": 51826,
|
|
||||||
"pin": "031-45-154"
|
|
||||||
},
|
|
||||||
"platforms": [
|
|
||||||
{
|
|
||||||
"platform": "websocket",
|
|
||||||
"name": "websocket",
|
|
||||||
"port": 4050
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"platform": "HarmonyHubMatrix",
|
|
||||||
"hubIp": "192.168.1.14",
|
|
||||||
"Matrix": {
|
|
||||||
"DeviceName": "Gefen AV Switch",
|
|
||||||
"Inputs": [
|
|
||||||
{
|
|
||||||
"InputNumber": "1",
|
|
||||||
"InputDevice": "Microsoft Xbox One"
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"InputNumber": "5",
|
|
||||||
"InputDevice": "Apple TV Gen 4"
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"InputNumber": "3",
|
|
||||||
"InputDevice": "Chromecast"
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"InputNumber": "2",
|
|
||||||
"InputDevice": "Sony PS4"
|
|
||||||
}
|
|
||||||
],
|
|
||||||
"Outputs": [
|
|
||||||
{
|
|
||||||
"OutputLetter": "B",
|
|
||||||
"OutputDevice": "LG TV"
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"OutputLetter": "C",
|
|
||||||
"OutputDevice": "Vizio TV"
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"OutputLetter": "D",
|
|
||||||
"OutputDevice": "Westinghouse TV"
|
|
||||||
}
|
|
||||||
]
|
|
||||||
},
|
|
||||||
"ControlUnits": [
|
|
||||||
{
|
|
||||||
"DisplayName": "Living Room",
|
|
||||||
"Activities": [
|
|
||||||
{
|
|
||||||
"DisplayName": "Chromecast",
|
|
||||||
"DeviceSetupList": [
|
|
||||||
{
|
|
||||||
"DeviceName": "LG TV",
|
|
||||||
"Input": "Hdmi1"
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"DeviceName": "JVC AV Receiver",
|
|
||||||
"Input": "Dvd"
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"DeviceName": "Chromecast",
|
|
||||||
"Input": []
|
|
||||||
}
|
|
||||||
],
|
|
||||||
"VolumeDevice": "JVC AV Receiver",
|
|
||||||
"ControlDevice": "Chromecast",
|
|
||||||
"OutputDevice": "LG TV",
|
|
||||||
"UseMatrix": "true"
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"DisplayName": "Play Xbox One",
|
|
||||||
"DeviceSetupList": [
|
|
||||||
{
|
|
||||||
"DeviceName": "Microsoft Xbox One",
|
|
||||||
"Input": []
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"DeviceName": "LG TV",
|
|
||||||
"Input": "Hdmi1"
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"DeviceName": "JVC AV Receiver",
|
|
||||||
"Input": "Dvd"
|
|
||||||
}
|
|
||||||
],
|
|
||||||
"VolumeDevice": "JVC AV Receiver",
|
|
||||||
"ControlDevice": "Microsoft Xbox One",
|
|
||||||
"OutputDevice": "LG TV",
|
|
||||||
"UseMatrix": "true"
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"DisplayName": "Play PS4",
|
|
||||||
"DeviceSetupList": [
|
|
||||||
{
|
|
||||||
"DeviceName": "Sony PS4",
|
|
||||||
"Input": []
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"DeviceName": "LG TV",
|
|
||||||
"Input": "Hdmi1"
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"DeviceName": "JVC AV Receiver",
|
|
||||||
"Input": "Dvd"
|
|
||||||
}
|
|
||||||
],
|
|
||||||
"VolumeDevice": "JVC AV Receiver",
|
|
||||||
"ControlDevice": "Sony PS4",
|
|
||||||
"OutputDevice": "LG TV",
|
|
||||||
"UseMatrix": "true"
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"DisplayName": "Apple TV",
|
|
||||||
"DeviceSetupList": [
|
|
||||||
{
|
|
||||||
"DeviceName": "Apple TV Gen 4",
|
|
||||||
"Input": []
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"DeviceName": "LG TV",
|
|
||||||
"Input": "Hdmi1"
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"DeviceName": "JVC AV Receiver",
|
|
||||||
"Input": "Dvd"
|
|
||||||
}
|
|
||||||
],
|
|
||||||
"VolumeDevice": "JVC AV Receiver",
|
|
||||||
"ControlDevice": "Apple TV Gen 4",
|
|
||||||
"OutputDevice": "LG TV",
|
|
||||||
"UseMatrix": "true"
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"DisplayName": "Listen to Music",
|
|
||||||
"DeviceSetupList": [
|
|
||||||
{
|
|
||||||
"DeviceName": "JVC AV Receiver",
|
|
||||||
"Input": "CD"
|
|
||||||
}
|
|
||||||
],
|
|
||||||
"VolumeDevice": "JVC AV Receiver",
|
|
||||||
"ControlDevice": [],
|
|
||||||
"OutputDevice": [],
|
|
||||||
"UseMatrix": "false"
|
|
||||||
}
|
|
||||||
]
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"DisplayName": "Bedroom",
|
|
||||||
"Activities": [
|
|
||||||
{
|
|
||||||
"DisplayName": "Chromecast",
|
|
||||||
"DeviceSetupList": [
|
|
||||||
{
|
|
||||||
"DeviceName": "Vizio TV",
|
|
||||||
"Input": "Hdmi1"
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"DeviceName": "Harman Kardon AV Receiver",
|
|
||||||
"Input": "Game"
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"DeviceName": "Chromecast",
|
|
||||||
"Input": []
|
|
||||||
}
|
|
||||||
],
|
|
||||||
"VolumeDevice": "Harman Kardon AV Receiver",
|
|
||||||
"ControlDevice": "Chromecast",
|
|
||||||
"OutputDevice": "Vizio TV",
|
|
||||||
"UseMatrix": "true"
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"DisplayName": "Play Xbox One",
|
|
||||||
"DeviceSetupList": [
|
|
||||||
{
|
|
||||||
"DeviceName": "Microsoft Xbox One",
|
|
||||||
"Input": []
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"DeviceName": "Vizio TV",
|
|
||||||
"Input": "Hdmi1"
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"DeviceName": "Harman Kardon AV Receiver",
|
|
||||||
"Input": "Game"
|
|
||||||
}
|
|
||||||
],
|
|
||||||
"VolumeDevice": "Harman Kardon AV Receiver",
|
|
||||||
"ControlDevice": "Microsoft Xbox One",
|
|
||||||
"OutputDevice": "Vizio TV",
|
|
||||||
"UseMatrix": "true"
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"DisplayName": "Play PS4",
|
|
||||||
"DeviceSetupList": [
|
|
||||||
{
|
|
||||||
"DeviceName": "Sony PS4",
|
|
||||||
"Input": []
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"DeviceName": "Vizio TV",
|
|
||||||
"Input": "Hdmi1"
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"DeviceName": "Harman Kardon AV Receiver",
|
|
||||||
"Input": "Dvd"
|
|
||||||
}
|
|
||||||
],
|
|
||||||
"VolumeDevice": "Harman Kardon AV Receiver",
|
|
||||||
"ControlDevice": "Sony PS4",
|
|
||||||
"OutputDevice": "LG TV",
|
|
||||||
"UseMatrix": "true"
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"DisplayName": "Apple TV",
|
|
||||||
"DeviceSetupList": [
|
|
||||||
{
|
|
||||||
"DeviceName": "Apple TV Gen 4",
|
|
||||||
"Input": []
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"DeviceName": "Vizio TV",
|
|
||||||
"Input": "Hdmi1"
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"DeviceName": "Harman Kardon AV Receiver",
|
|
||||||
"Input": "Game"
|
|
||||||
}
|
|
||||||
],
|
|
||||||
"VolumeDevice": "Harman Kardon AV Receiver",
|
|
||||||
"ControlDevice": "Apple TV Gen 4",
|
|
||||||
"OutputDevice": "Vizio TV",
|
|
||||||
"UseMatrix": "true"
|
|
||||||
}
|
|
||||||
]
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"DisplayName": "Kitchen",
|
|
||||||
"Activities": [
|
|
||||||
{
|
|
||||||
"DisplayName": "Chromecast",
|
|
||||||
"DeviceSetupList": [
|
|
||||||
{
|
|
||||||
"DeviceName": "Chromecast",
|
|
||||||
"Input": []
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"DeviceName": "Westinghouse TV",
|
|
||||||
"Input": "Hdmi1"
|
|
||||||
}
|
|
||||||
],
|
|
||||||
"VolumeDevice": "Westinghouse TV",
|
|
||||||
"ControlDevice": "Chromecast",
|
|
||||||
"OutputDevice": "Westinghouse TV",
|
|
||||||
"UseMatrix": "true"
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"DisplayName": "Watch Apple Tv",
|
|
||||||
"DeviceSetupList": [
|
|
||||||
{
|
|
||||||
"DeviceName": "Apple TV Gen 4",
|
|
||||||
"Input": []
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"DeviceName": "Westinghouse TV",
|
|
||||||
"Input": "Hdmi1"
|
|
||||||
}
|
|
||||||
],
|
|
||||||
"VolumeDevice": "Westinghouse TV",
|
|
||||||
"ControlDevice": "Apple TV Gen 4",
|
|
||||||
"OutputDevice": "Westinghouse TV",
|
|
||||||
"UseMatrix": "true"
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"DisplayName": "Play Xbox One",
|
|
||||||
"DeviceSetupList": [
|
|
||||||
{
|
|
||||||
"DeviceName": "Westinghouse TV",
|
|
||||||
"Input": "Hdmi1"
|
|
||||||
},
|
|
||||||
{
|
|
||||||
"DeviceName": "Microsoft Xbox One",
|
|
||||||
"Input": []
|
|
||||||
}
|
|
||||||
],
|
|
||||||
"VolumeDevice": "Westinghouse TV",
|
|
||||||
"ControlDevice": "Microsoft Xbox One",
|
|
||||||
"OutputDevice": "Westinghouse TV",
|
|
||||||
"UseMatrix": "true"
|
|
||||||
}
|
|
||||||
]
|
|
||||||
}
|
|
||||||
]
|
|
||||||
}
|
|
||||||
]
|
|
||||||
}
|
|
||||||
@ -1,6 +1,6 @@
|
|||||||
#!/bin/bash
|
#!/bin/bash
|
||||||
remote_user="bmw"
|
remote_user="bmw"
|
||||||
remote_server="192.168.1.31"
|
remote_server="linuxhost.me"
|
||||||
deploy_location="/home/bmw/homebridge-harmony-control"
|
deploy_location="/home/bmw/homebridge-harmony-control"
|
||||||
homebridge_location="/var/lib/homebridge/"
|
homebridge_location="/var/lib/homebridge/"
|
||||||
|
|
||||||
|
|||||||
2035
package-lock.json
generated
2035
package-lock.json
generated
File diff suppressed because it is too large
Load Diff
85
package.json
85
package.json
@ -1,42 +1,45 @@
|
|||||||
{
|
{
|
||||||
"name": "homebridge-harmony-control",
|
"name": "homebridge-harmony-control",
|
||||||
"version": "1.0.7",
|
"version": "1.1.0",
|
||||||
"description": "Homebridge platform to control smart home equipment by room.",
|
"description": "Homebridge platform to control smart home equipment by room.",
|
||||||
"main": "bin/index.js",
|
"main": "bin/index.js",
|
||||||
"scripts": {
|
"publishConfig": {
|
||||||
"build": "tsc",
|
"registry": "http://linuxhost.me:4873/"
|
||||||
"prepublishOnly": "npm run build"
|
},
|
||||||
},
|
"scripts": {
|
||||||
"repository": {
|
"build": "tsc --build",
|
||||||
"type": "git",
|
"prepublishOnly": "npm run build"
|
||||||
"url": "ssh://git@watsonb8.ddns.net:2122/misc/homebridge-harmony-control.git"
|
},
|
||||||
},
|
"repository": {
|
||||||
"author": "Brandon Watson",
|
"type": "git",
|
||||||
"license": "ISC",
|
"url": "ssh://git@watsonb8.ddns.net:2122/misc/homebridge-harmony-control.git"
|
||||||
"keywords": [
|
},
|
||||||
"homebridge-plugin",
|
"author": "Brandon Watson",
|
||||||
"harmony",
|
"license": "ISC",
|
||||||
"websocket",
|
"keywords": [
|
||||||
"harmonyhub",
|
"homebridge-plugin",
|
||||||
"homekit"
|
"harmony",
|
||||||
],
|
"websocket",
|
||||||
"engines": {
|
"harmonyhub",
|
||||||
"homebridge": ">=0.4.21",
|
"homekit"
|
||||||
"node": ">=7.6.0"
|
],
|
||||||
},
|
"engines": {
|
||||||
"devDependencies": {
|
"homebridge": ">=1.1.6",
|
||||||
"rollup-plugin-typescript": "^1.0.1",
|
"node": ">=7.6.0"
|
||||||
"tslib": "^1.10.0",
|
},
|
||||||
"tslint": "^5.17.0",
|
"devDependencies": {
|
||||||
"typescript": "^3.5.1"
|
"rollup-plugin-typescript": "^1.0.1",
|
||||||
},
|
"tslib": "^1.10.0",
|
||||||
"dependencies": {
|
"tslint": "^5.17.0",
|
||||||
"@babel/core": "^7.4.5",
|
"typescript": "^3.5.1"
|
||||||
"@babel/preset-env": "^7.4.5",
|
},
|
||||||
"@babel/preset-typescript": "^7.3.3",
|
"dependencies": {
|
||||||
"@types/node": "^12.0.7",
|
"@babel/core": "^7.4.5",
|
||||||
"harmony-websocket": "^1.1.0",
|
"@babel/preset-env": "^7.4.5",
|
||||||
"homebridge": "^0.4.50",
|
"@babel/preset-typescript": "^7.3.3",
|
||||||
"request": "^2.88.0"
|
"@types/node": "^12.0.7",
|
||||||
}
|
"harmony-websocket": "^1.1.0",
|
||||||
}
|
"homebridge": "^1.1.16",
|
||||||
|
"request": "^2.88.0"
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|||||||
@ -1,294 +1,286 @@
|
|||||||
import * as Config from "../Models/Config"
|
import { PlatformAccessory, RemoteController, Service } from "homebridge";
|
||||||
import { IAccessory } from './IAccessory';
|
import HarmonyDataProvider from "../DataProviders/HarmonyDataProvider";
|
||||||
import callbackify from '../Util/Callbackify';
|
import { IActivity } from "../Models/Config";
|
||||||
import HarmonyDataProvider from '../DataProviders/HarmonyDataProvider';
|
import { Platform } from "../platform";
|
||||||
|
import callbackify from "../Util/Callbackify";
|
||||||
let Service: HAPNodeJS.Service;
|
|
||||||
let Characteristic: HAPNodeJS.Characteristic;
|
|
||||||
let Api: any;
|
|
||||||
let homebridge: any;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Enum describing remote key presses from homebridge.
|
* Enum describing remote key presses from homebridge.
|
||||||
*/
|
*/
|
||||||
export enum RemoteKey {
|
export enum RemoteKey {
|
||||||
REWIND = 0,
|
REWIND = 0,
|
||||||
FAST_FORWARD = 1,
|
FAST_FORWARD = 1,
|
||||||
NEXT_TRACK = 2,
|
NEXT_TRACK = 2,
|
||||||
PREVIOUS_TRACK = 3,
|
PREVIOUS_TRACK = 3,
|
||||||
ARROW_UP = 4,
|
ARROW_UP = 4,
|
||||||
ARROW_DOWN = 5,
|
ARROW_DOWN = 5,
|
||||||
ARROW_LEFT = 6,
|
ARROW_LEFT = 6,
|
||||||
ARROW_RIGHT = 7,
|
ARROW_RIGHT = 7,
|
||||||
SELECT = 8,
|
SELECT = 8,
|
||||||
BACK = 9,
|
BACK = 9,
|
||||||
EXIT = 10,
|
EXIT = 10,
|
||||||
PLAY_PAUSE = 11,
|
PLAY_PAUSE = 11,
|
||||||
INFORMATION = 15,
|
INFORMATION = 15,
|
||||||
}
|
}
|
||||||
|
|
||||||
export interface IControlUnitProps {
|
export class ControlUnit {
|
||||||
dataProvider: HarmonyDataProvider,
|
constructor(
|
||||||
displayName: string,
|
private readonly _platform: Platform,
|
||||||
activities: Array<Config.IActivity>,
|
private readonly _accessory: PlatformAccessory,
|
||||||
api: any,
|
private _dataProvider: HarmonyDataProvider,
|
||||||
log: any,
|
private _activities: Array<IActivity>
|
||||||
homebridge: any,
|
) {
|
||||||
}
|
this._accessory
|
||||||
|
.getService(this._platform.Service.AccessoryInformation)!
|
||||||
|
.setCharacteristic(
|
||||||
|
this._platform.Characteristic.Manufacturer,
|
||||||
|
"Brandon Watson"
|
||||||
|
)
|
||||||
|
.setCharacteristic(
|
||||||
|
this._platform.Characteristic.Model,
|
||||||
|
"Matrix Output Television"
|
||||||
|
)
|
||||||
|
.setCharacteristic(
|
||||||
|
this._platform.Characteristic.SerialNumber,
|
||||||
|
"123-456-789"
|
||||||
|
);
|
||||||
|
|
||||||
/**
|
const televisionUUID = this._platform.api.hap.uuid.generate(
|
||||||
* ControlUnit accessory
|
`${this._accessory.displayName} Television`
|
||||||
*/
|
);
|
||||||
export class ControlUnit implements IAccessory {
|
//Init services
|
||||||
|
const televisionService =
|
||||||
|
this._accessory.getService(this._platform.Service.Television) ||
|
||||||
|
this._accessory.addService(
|
||||||
|
this._platform.Service.Television,
|
||||||
|
"Television",
|
||||||
|
televisionUUID
|
||||||
|
);
|
||||||
|
this.configureTvService(televisionService);
|
||||||
|
|
||||||
|
const televisionSpeakerUUID = this._platform.api.hap.uuid.generate(
|
||||||
|
`${this._accessory.displayName} Television Speaker`
|
||||||
|
);
|
||||||
|
const televisionSpeakerService =
|
||||||
|
this._accessory.getService(this._platform.Service.TelevisionSpeaker) ||
|
||||||
|
this._accessory.addService(
|
||||||
|
this._platform.Service.TelevisionSpeaker,
|
||||||
|
"Television Speaker",
|
||||||
|
televisionSpeakerUUID
|
||||||
|
);
|
||||||
|
this.configureTvSpeakerService(televisionService, televisionSpeakerService);
|
||||||
|
|
||||||
//fields
|
this.configureInputSourceService(televisionService);
|
||||||
private log: any = {};
|
}
|
||||||
private displayName: string = "";
|
|
||||||
|
|
||||||
//Service fields
|
/*************
|
||||||
private _televisionService: HAPNodeJS.Service | undefined;
|
*
|
||||||
private _televisionSpeakerService: HAPNodeJS.Service | undefined;
|
* Tv Service
|
||||||
private _infoService: HAPNodeJS.Service;
|
*
|
||||||
private _inputServices: Array<HAPNodeJS.Service | undefined> = [];
|
*************/
|
||||||
|
|
||||||
//Harmony fields
|
/**
|
||||||
private _activities: Array<Config.IActivity> = [];
|
* Configure television service
|
||||||
private _dataProvider: HarmonyDataProvider;
|
*/
|
||||||
|
private configureTvService(televisionService: Service): void {
|
||||||
|
televisionService.setCharacteristic(
|
||||||
|
this._platform.Characteristic.ConfiguredName,
|
||||||
|
this._accessory.displayName
|
||||||
|
);
|
||||||
|
//@ts-ignore
|
||||||
|
televisionService.setCharacteristic(
|
||||||
|
this._platform.Characteristic.SleepDiscoveryMode,
|
||||||
|
this._platform.Characteristic.SleepDiscoveryMode.ALWAYS_DISCOVERABLE
|
||||||
|
);
|
||||||
|
televisionService.setCharacteristic(
|
||||||
|
this._platform.Characteristic.ActiveIdentifier,
|
||||||
|
1
|
||||||
|
);
|
||||||
|
televisionService.setCharacteristic(
|
||||||
|
this._platform.Characteristic.Active,
|
||||||
|
false
|
||||||
|
);
|
||||||
|
|
||||||
/**
|
//setup listeners
|
||||||
* Constructor
|
televisionService
|
||||||
* @param props Input properties
|
.getCharacteristic(this._platform.Characteristic.Active)
|
||||||
*/
|
//@ts-ignore
|
||||||
constructor(props: IControlUnitProps) {
|
.on("set", callbackify(this.onSetAccessoryActive))
|
||||||
//Assign class variables
|
//@ts-ignore
|
||||||
this.log = props.log;
|
.on("get", callbackify(this.onGetAccessoryActive));
|
||||||
Api = props.api;
|
|
||||||
Service = props.api.hap.Service;
|
|
||||||
Characteristic = props.api.hap.Characteristic;
|
|
||||||
this.name = props.displayName;
|
|
||||||
this.displayName = props.displayName;
|
|
||||||
|
|
||||||
this._activities = props.activities;
|
//Set remote characteristics if is external
|
||||||
|
televisionService
|
||||||
|
.getCharacteristic(this._platform.Characteristic.RemoteKey)
|
||||||
|
//@ts-ignore
|
||||||
|
.on("set", callbackify(this.onSetRemoteKey));
|
||||||
|
|
||||||
this._dataProvider = props.dataProvider;
|
televisionService
|
||||||
homebridge = props.homebridge;
|
.getCharacteristic(this._platform.Characteristic.ActiveIdentifier)
|
||||||
|
//@ts-ignore
|
||||||
|
.on("set", callbackify(this.onSetActiveIdentifier))
|
||||||
|
//@ts-ignore
|
||||||
|
.on("get", callbackify(this.onGetActiveIdentifier));
|
||||||
|
}
|
||||||
|
|
||||||
this.platformAccessory = new homebridge.platformAccessory(this.displayName, this.generateUUID(), homebridge.hap.Accessory.Categories.TELEVISION);
|
/**
|
||||||
|
* Event handler for SET active characteristic
|
||||||
//@ts-ignore
|
*/
|
||||||
this._infoService = new Service.AccessoryInformation();
|
private onSetAccessoryActive = async (value: any) => {
|
||||||
this._infoService.setCharacteristic(Characteristic.Manufacturer, "Brandon Watson")
|
switch (value) {
|
||||||
this._infoService.setCharacteristic(Characteristic.Model, "Matrix Output Television")
|
case 0:
|
||||||
this._infoService.setCharacteristic(Characteristic.SerialNumber, "123-456-789");
|
this._dataProvider.powerOff(this._accessory.displayName);
|
||||||
|
break;
|
||||||
//Configure services
|
//Turn on with first activity
|
||||||
this.configureTvService();
|
case 1:
|
||||||
|
this._dataProvider.powerOn(
|
||||||
this.configureTvSpeakerService();
|
this._accessory.displayName,
|
||||||
|
this._activities[0]
|
||||||
|
|
||||||
// this.configureAccessoryInformation();
|
|
||||||
this.configureInputSourceService();
|
|
||||||
|
|
||||||
//Configure external services
|
|
||||||
this.getServices().forEach(service => {
|
|
||||||
try {
|
|
||||||
this.platformAccessory.addService(service);
|
|
||||||
} catch (error) { }
|
|
||||||
|
|
||||||
//@ts-ignore
|
|
||||||
if (service.linked) {
|
|
||||||
//@ts-ignore
|
|
||||||
this._televisionService!.addLinkedService(service);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
//Required by homebridge
|
|
||||||
name: string = "";
|
|
||||||
public platformAccessory: any;
|
|
||||||
|
|
||||||
/*************
|
|
||||||
*
|
|
||||||
* Tv Service
|
|
||||||
*
|
|
||||||
*************/
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Configure television service
|
|
||||||
*/
|
|
||||||
private configureTvService(): void {
|
|
||||||
this._televisionService = new Service.Television(
|
|
||||||
this.displayName,
|
|
||||||
'tvService'
|
|
||||||
)
|
|
||||||
|
|
||||||
this._televisionService.setCharacteristic(Characteristic.ConfiguredName, this.displayName);
|
|
||||||
//@ts-ignore
|
|
||||||
this._televisionService.setCharacteristic(Characteristic.SleepDiscoveryMode, Characteristic.SleepDiscoveryMode.ALWAYS_DISCOVERABLE);
|
|
||||||
this._televisionService.setCharacteristic(Characteristic.ActiveIdentifier, 1);
|
|
||||||
this._televisionService.setCharacteristic(Characteristic.Active, false);
|
|
||||||
|
|
||||||
//setup listeners
|
|
||||||
this._televisionService.getCharacteristic(Characteristic.Active)
|
|
||||||
//@ts-ignore
|
|
||||||
.on("set", callbackify(this.onSetAccessoryActive))
|
|
||||||
//@ts-ignore
|
|
||||||
.on("get", callbackify(this.onGetAccessoryActive));
|
|
||||||
|
|
||||||
//Set remote characteristics if is external
|
|
||||||
this._televisionService.getCharacteristic(Characteristic.RemoteKey)
|
|
||||||
//@ts-ignore
|
|
||||||
.on("set", callbackify(this.onSetRemoteKey));
|
|
||||||
|
|
||||||
|
|
||||||
this._televisionService.getCharacteristic(Characteristic.ActiveIdentifier)
|
|
||||||
//@ts-ignore
|
|
||||||
.on("set", callbackify(this.onSetActiveIdentifier))
|
|
||||||
//@ts-ignore
|
|
||||||
.on("get", callbackify(this.onGetActiveIdentifier));
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Event handler for SET active characteristic
|
|
||||||
*/
|
|
||||||
private onSetAccessoryActive = async (value: any) => {
|
|
||||||
switch (value) {
|
|
||||||
case 0: this._dataProvider.powerOff(this.name); break;
|
|
||||||
//Turn on with first activity
|
|
||||||
case 1: this._dataProvider.powerOn(this.name, this._activities[0]); break;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Event handler for GET active characteristic
|
|
||||||
*/
|
|
||||||
private onGetAccessoryActive = async () => {
|
|
||||||
//@ts-ignore
|
|
||||||
return this._dataProvider.getIsActive(this.name) ? Characteristic.Active.Active : Characteristic.Active.Inactive
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Event handler for SET remote key
|
|
||||||
*/
|
|
||||||
private onSetRemoteKey = async (key: any) => {
|
|
||||||
this._dataProvider.sendKeyPress(this.name, key);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Event handler for SET active identifier characteristic
|
|
||||||
*/
|
|
||||||
private onSetActiveIdentifier = async (identifier: any) => {
|
|
||||||
this._dataProvider.startActivity(this.name, this._activities[identifier]);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Event handler for GET active identifier characteristic
|
|
||||||
*/
|
|
||||||
private onGetActiveIdentifier = async () => {
|
|
||||||
let currentActivity: Config.IActivity = this._dataProvider.getIsActive(this.name)!;
|
|
||||||
let identifier: number = 0;
|
|
||||||
if (currentActivity) {
|
|
||||||
identifier = this._activities.findIndex(e => e.DisplayName === currentActivity.DisplayName);
|
|
||||||
}
|
|
||||||
return identifier;
|
|
||||||
}
|
|
||||||
|
|
||||||
/******************
|
|
||||||
*
|
|
||||||
* Speaker Service
|
|
||||||
*
|
|
||||||
*****************/
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Configure Speaker Service
|
|
||||||
*/
|
|
||||||
private configureTvSpeakerService(): void {
|
|
||||||
this._televisionSpeakerService = new Service.TelevisionSpeaker(
|
|
||||||
this.displayName,
|
|
||||||
'tvSpeakerService'
|
|
||||||
);
|
);
|
||||||
this._televisionSpeakerService.setCharacteristic(Characteristic.Name, this.displayName);
|
break;
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Event handler for GET active characteristic
|
||||||
|
*/
|
||||||
|
private onGetAccessoryActive = async () => {
|
||||||
|
//@ts-ignore
|
||||||
|
return this._dataProvider.getIsActive(this._accessory.displayName)
|
||||||
|
? this._platform.Characteristic.Active.ACTIVE
|
||||||
|
: this._platform.Characteristic.Active.INACTIVE;
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Event handler for SET remote key
|
||||||
|
*/
|
||||||
|
private onSetRemoteKey = async (key: any) => {
|
||||||
|
this._dataProvider.sendKeyPress(this._accessory.displayName, key);
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Event handler for SET active identifier characteristic
|
||||||
|
*/
|
||||||
|
private onSetActiveIdentifier = async (identifier: any) => {
|
||||||
|
this._dataProvider.startActivity(
|
||||||
|
this._accessory.displayName,
|
||||||
|
this._activities[identifier]
|
||||||
|
);
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Event handler for GET active identifier characteristic
|
||||||
|
*/
|
||||||
|
private onGetActiveIdentifier = async () => {
|
||||||
|
let currentActivity: IActivity = this._dataProvider.getIsActive(
|
||||||
|
this._accessory.displayName
|
||||||
|
)!;
|
||||||
|
let identifier: number = 0;
|
||||||
|
if (currentActivity) {
|
||||||
|
identifier = this._activities.findIndex(
|
||||||
|
(e) => e.DisplayName === currentActivity.DisplayName
|
||||||
|
);
|
||||||
|
}
|
||||||
|
return identifier;
|
||||||
|
};
|
||||||
|
|
||||||
|
/******************
|
||||||
|
*
|
||||||
|
* Speaker Service
|
||||||
|
*
|
||||||
|
*****************/
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Configure Speaker Service
|
||||||
|
*/
|
||||||
|
private configureTvSpeakerService(
|
||||||
|
televisionService: Service,
|
||||||
|
televisionSpeakerService: Service
|
||||||
|
): void {
|
||||||
|
televisionSpeakerService.setCharacteristic(
|
||||||
|
this._platform.Characteristic.Name,
|
||||||
|
this._accessory.displayName
|
||||||
|
);
|
||||||
|
//@ts-ignore
|
||||||
|
televisionSpeakerService.setCharacteristic(
|
||||||
|
this._platform.Characteristic.Active,
|
||||||
|
this._platform.Characteristic.Active.ACTIVE
|
||||||
|
);
|
||||||
|
//@ts-ignore
|
||||||
|
televisionSpeakerService.setCharacteristic(
|
||||||
|
this._platform.Characteristic.VolumeControlType,
|
||||||
|
this._platform.Characteristic.VolumeControlType.ABSOLUTE
|
||||||
|
);
|
||||||
|
televisionSpeakerService.subtype = this._accessory.displayName + "Volume";
|
||||||
|
if (televisionService) {
|
||||||
|
//@ts-ignore
|
||||||
|
televisionService.addLinkedService(televisionSpeakerService);
|
||||||
|
}
|
||||||
|
|
||||||
|
//Setup listeners
|
||||||
|
televisionSpeakerService
|
||||||
|
.getCharacteristic(this._platform.Characteristic.VolumeSelector)
|
||||||
|
//@ts-ignore
|
||||||
|
.on("set", callbackify(this.onSetVolumeSelector));
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Event handler for SET volume characteristic
|
||||||
|
*/
|
||||||
|
private onSetVolumeSelector = async (value: any) => {
|
||||||
|
switch (value) {
|
||||||
|
case 0:
|
||||||
|
this._dataProvider.volumeUp(this._accessory.displayName);
|
||||||
|
break;
|
||||||
|
case 1:
|
||||||
|
this._dataProvider.volumeDown(this._accessory.displayName);
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
/*****************
|
||||||
|
*
|
||||||
|
* Input services
|
||||||
|
*
|
||||||
|
*****************/
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Configure input service
|
||||||
|
*/
|
||||||
|
private configureInputSourceService(televisionService: Service): void {
|
||||||
|
let inputs: Array<Service> = [];
|
||||||
|
this._activities.forEach((activity: IActivity, index: number) => {
|
||||||
|
const inputUUID = this._platform.api.hap.uuid.generate(
|
||||||
|
`${activity.DisplayName} Input`
|
||||||
|
);
|
||||||
|
let inputService =
|
||||||
|
this._accessory.getService(activity.DisplayName) ||
|
||||||
|
this._accessory.addService(
|
||||||
|
this._platform.Service.InputSource,
|
||||||
|
activity.DisplayName,
|
||||||
|
inputUUID
|
||||||
|
);
|
||||||
|
|
||||||
|
inputService
|
||||||
|
.setCharacteristic(this._platform.Characteristic.Identifier, index)
|
||||||
|
.setCharacteristic(
|
||||||
|
this._platform.Characteristic.ConfiguredName,
|
||||||
|
activity.DisplayName
|
||||||
|
)
|
||||||
|
.setCharacteristic(
|
||||||
|
this._platform.Characteristic.IsConfigured,
|
||||||
|
//@ts-ignore
|
||||||
|
this._platform.Characteristic.IsConfigured.CONFIGURED
|
||||||
|
)
|
||||||
//@ts-ignore
|
//@ts-ignore
|
||||||
this._televisionSpeakerService.setCharacteristic(Characteristic.Active, Characteristic.Active.ACTIVE);
|
.setCharacteristic(
|
||||||
//@ts-ignore
|
this._platform.Characteristic.InputSourceType,
|
||||||
this._televisionSpeakerService.setCharacteristic(Characteristic.VolumeControlType, Characteristic.VolumeControlType.ABSOLUTE);
|
this._platform.Characteristic.InputSourceType.HDMI
|
||||||
this._televisionSpeakerService.subtype = this.displayName + "Volume";
|
);
|
||||||
if (this._televisionService) {
|
|
||||||
//@ts-ignore
|
|
||||||
this._televisionService.addLinkedService(this._televisionSpeakerService);
|
|
||||||
}
|
|
||||||
|
|
||||||
//Setup listeners
|
//@ts-ignore
|
||||||
this._televisionSpeakerService.getCharacteristic(Characteristic.VolumeSelector)
|
televisionService!.addLinkedService(inputService);
|
||||||
//@ts-ignore
|
inputs.push(inputService);
|
||||||
.on("set", callbackify(this.onSetVolumeSelector));
|
});
|
||||||
}
|
}
|
||||||
|
}
|
||||||
/**
|
|
||||||
* Event handler for SET volume characteristic
|
|
||||||
*/
|
|
||||||
private onSetVolumeSelector = async (value: any) => {
|
|
||||||
switch (value) {
|
|
||||||
case 0: this._dataProvider.volumeUp(this.name); break;
|
|
||||||
case 1: this._dataProvider.volumeDown(this.name); break;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/*****************
|
|
||||||
*
|
|
||||||
* Input services
|
|
||||||
*
|
|
||||||
*****************/
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Configure input service
|
|
||||||
*/
|
|
||||||
private configureInputSourceService(): void {
|
|
||||||
let inputs: Array<HAPNodeJS.Service> = [];
|
|
||||||
this._activities.forEach((activity: Config.IActivity, index: number) => {
|
|
||||||
let inputService = new Service.InputSource(activity.DisplayName, 'activity' + activity.DisplayName);
|
|
||||||
inputService
|
|
||||||
.setCharacteristic(Characteristic.Identifier, index)
|
|
||||||
.setCharacteristic(
|
|
||||||
Characteristic.ConfiguredName,
|
|
||||||
activity.DisplayName)
|
|
||||||
.setCharacteristic(
|
|
||||||
Characteristic.IsConfigured,
|
|
||||||
//@ts-ignore
|
|
||||||
Characteristic.IsConfigured.CONFIGURED
|
|
||||||
)
|
|
||||||
//@ts-ignore
|
|
||||||
.setCharacteristic(Characteristic.InputSourceType, Characteristic.InputSourceType.HDMI);
|
|
||||||
|
|
||||||
//@ts-ignore
|
|
||||||
this._televisionService!.addLinkedService(inputService);
|
|
||||||
inputs.push(inputService);
|
|
||||||
});
|
|
||||||
this._inputServices = inputs;
|
|
||||||
}
|
|
||||||
|
|
||||||
private generateUUID(): string { // Public Domain/MIT
|
|
||||||
var d = new Date().getTime();
|
|
||||||
if (typeof performance !== 'undefined' && typeof performance.now === 'function') {
|
|
||||||
d += performance.now(); //use high-precision timer if available
|
|
||||||
}
|
|
||||||
return 'xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx'.replace(/[xy]/g, function (c) {
|
|
||||||
var r = (d + Math.random() * 16) % 16 | 0;
|
|
||||||
d = Math.floor(d / 16);
|
|
||||||
return (c === 'x' ? r : (r & 0x3 | 0x8)).toString(16);
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Called by homebridge to gather services for this accessory.
|
|
||||||
*/
|
|
||||||
getServices(): Array<HAPNodeJS.Service> {
|
|
||||||
let services: Array<HAPNodeJS.Service> = [this._infoService, this._televisionService!, this._televisionSpeakerService!];
|
|
||||||
this._inputServices.forEach((service: HAPNodeJS.Service | undefined) => {
|
|
||||||
services.push(service!);
|
|
||||||
});
|
|
||||||
return (services);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|||||||
@ -1,155 +1,111 @@
|
|||||||
|
import { PlatformAccessory, Service } from "homebridge";
|
||||||
import HarmonyDataProvider from "../DataProviders/HarmonyDataProvider";
|
import HarmonyDataProvider from "../DataProviders/HarmonyDataProvider";
|
||||||
import { IDeviceButton } from "../Models/Config";
|
import { IDeviceButton } from "../Models/Config";
|
||||||
import { IAccessory } from "./IAccessory";
|
|
||||||
import { ICommand } from "../Models";
|
|
||||||
import { HarmonyDevice } from "../Models/HarmonyDevice";
|
import { HarmonyDevice } from "../Models/HarmonyDevice";
|
||||||
|
import { Platform } from "../platform";
|
||||||
|
|
||||||
let Service: HAPNodeJS.Service;
|
export class DeviceButton {
|
||||||
let Characteristic: HAPNodeJS.Characteristic;
|
private _buttonState: boolean;
|
||||||
|
private _device!: HarmonyDevice;
|
||||||
|
private _switchService: Service;
|
||||||
|
|
||||||
export interface IDeviceButtonProps {
|
constructor(
|
||||||
dataProvider: HarmonyDataProvider,
|
private readonly _platform: Platform,
|
||||||
buttonName: string,
|
private readonly _accessory: PlatformAccessory,
|
||||||
displayName: string,
|
private _dataProvider: HarmonyDataProvider,
|
||||||
deviceInfo: IDeviceButton,
|
private _deviceInfo: IDeviceButton
|
||||||
api: any,
|
) {
|
||||||
log: any,
|
this._buttonState = false;
|
||||||
homebridge: any,
|
|
||||||
|
if (this._deviceInfo.NumberOfKeyPresses && this._deviceInfo.IsStateful) {
|
||||||
|
throw new Error(
|
||||||
|
"A button cannot be stateful and be pressed more than once"
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
this._accessory
|
||||||
|
.getService(this._platform.Service.AccessoryInformation)!
|
||||||
|
.setCharacteristic(
|
||||||
|
this._platform.Characteristic.Manufacturer,
|
||||||
|
"Brandon Watson"
|
||||||
|
)
|
||||||
|
.setCharacteristic(this._platform.Characteristic.Model, "Device Button")
|
||||||
|
.setCharacteristic(
|
||||||
|
this._platform.Characteristic.SerialNumber,
|
||||||
|
"123-456-789"
|
||||||
|
);
|
||||||
|
|
||||||
|
const switchUUID = this._platform.api.hap.uuid.generate(
|
||||||
|
`${this._accessory.displayName} Switch`
|
||||||
|
);
|
||||||
|
|
||||||
|
this._switchService =
|
||||||
|
this._accessory.getService(this._platform.Service.Switch) ||
|
||||||
|
this._accessory.addService(
|
||||||
|
this._platform.Service.Switch,
|
||||||
|
this._accessory.displayName,
|
||||||
|
switchUUID
|
||||||
|
);
|
||||||
|
|
||||||
|
this._switchService
|
||||||
|
.getCharacteristic(this._platform.Characteristic.On)
|
||||||
|
//@ts-ignore
|
||||||
|
.on("set", this.onSwitchSet)
|
||||||
|
.updateValue(this._buttonState)
|
||||||
|
.on("get", this.onSwitchGet);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Handler for switch set event
|
||||||
|
* @param callback The callback function to call when complete
|
||||||
|
*/
|
||||||
|
private onSwitchSet = async (
|
||||||
|
newState: boolean,
|
||||||
|
callback: (error?: Error | null | undefined) => void
|
||||||
|
) => {
|
||||||
|
if (!this._deviceInfo.IsStateful && newState === this._buttonState) {
|
||||||
|
return callback();
|
||||||
|
}
|
||||||
|
|
||||||
|
//Get device command if we don't have it
|
||||||
|
if (!this._device) {
|
||||||
|
this._device = this._dataProvider.getDeviceFromName(
|
||||||
|
this._deviceInfo.DeviceName
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
//Execute command
|
||||||
|
if (this._device) {
|
||||||
|
//change state if stateful
|
||||||
|
if (this._deviceInfo.IsStateful && this._buttonState != newState) {
|
||||||
|
this._buttonState = newState;
|
||||||
|
await this._device.sendCommand(this._deviceInfo.ButtonName);
|
||||||
|
} else if (!this._deviceInfo.IsStateful) {
|
||||||
|
//Send the number of configured key presses
|
||||||
|
for (let i = 0; i < this._deviceInfo.NumberOfKeyPresses; i++) {
|
||||||
|
await this._device.sendCommand(this._deviceInfo.ButtonName);
|
||||||
|
}
|
||||||
|
this._switchService
|
||||||
|
.getCharacteristic(this._platform.Characteristic.On)
|
||||||
|
.updateValue(false);
|
||||||
|
return callback(new Error("Normal Response"));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return callback();
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Handler for switch get event
|
||||||
|
* @param callback The callback function to call when complete
|
||||||
|
*/
|
||||||
|
private onSwitchGet = (
|
||||||
|
callback: (error: Error | null, value: boolean) => void
|
||||||
|
) => {
|
||||||
|
//Only return state if button is stateful
|
||||||
|
if (this._deviceInfo.IsStateful) {
|
||||||
|
return callback(null, this._buttonState);
|
||||||
|
} else {
|
||||||
|
return callback(null, false);
|
||||||
|
}
|
||||||
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
export class DeviceButton implements IAccessory {
|
|
||||||
private _api: any;
|
|
||||||
private _homebridge: any;
|
|
||||||
private _log: any = {};
|
|
||||||
|
|
||||||
//Service fields
|
|
||||||
private _switchService: HAPNodeJS.Service;
|
|
||||||
private _infoService: HAPNodeJS.Service;
|
|
||||||
|
|
||||||
private _buttonInfo: IDeviceButton;
|
|
||||||
|
|
||||||
private _dataProvider: HarmonyDataProvider;
|
|
||||||
|
|
||||||
private _device!: HarmonyDevice;
|
|
||||||
|
|
||||||
private _buttonState: boolean;
|
|
||||||
|
|
||||||
constructor(props: IDeviceButtonProps) {
|
|
||||||
//Assign class variables
|
|
||||||
this._log = props.log;
|
|
||||||
this._api = props.api;
|
|
||||||
Service = props.api.hap.Service;
|
|
||||||
Characteristic = props.api.hap.Characteristic;
|
|
||||||
this.name = props.displayName;
|
|
||||||
this._homebridge = props.homebridge;
|
|
||||||
|
|
||||||
this._buttonInfo = props.deviceInfo;
|
|
||||||
|
|
||||||
this._dataProvider = props.dataProvider;
|
|
||||||
|
|
||||||
this._buttonState = false;
|
|
||||||
|
|
||||||
if (this._buttonInfo.NumberOfKeyPresses && this._buttonInfo.IsStateful) {
|
|
||||||
throw new Error("A button cannot be stateful and be pressed more than once");
|
|
||||||
}
|
|
||||||
|
|
||||||
//Assign default number of key presses
|
|
||||||
if (!this._buttonInfo.NumberOfKeyPresses) {
|
|
||||||
this._buttonInfo.NumberOfKeyPresses = 1;
|
|
||||||
}
|
|
||||||
|
|
||||||
this.platformAccessory = new this._homebridge.platformAccessory(this.name, this.generateUUID(), this._homebridge.hap.Accessory.Categories.SWITCH);
|
|
||||||
|
|
||||||
//@ts-ignore
|
|
||||||
this._infoService = new Service.AccessoryInformation();
|
|
||||||
this._infoService.setCharacteristic(Characteristic.Manufacturer, "Brandon Watson")
|
|
||||||
this._infoService.setCharacteristic(Characteristic.Model, "Device Button")
|
|
||||||
this._infoService.setCharacteristic(Characteristic.SerialNumber, "123-456-789");
|
|
||||||
|
|
||||||
this._switchService = new Service.Switch(
|
|
||||||
this.name,
|
|
||||||
'switchService'
|
|
||||||
)
|
|
||||||
|
|
||||||
this._switchService.getCharacteristic(Characteristic.On)
|
|
||||||
//@ts-ignore
|
|
||||||
.on("set", this.onSwitchSet)
|
|
||||||
.updateValue(this._buttonState)
|
|
||||||
.on("get", this.onSwitchGet);
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Required by homebridge.
|
|
||||||
*/
|
|
||||||
public name: string;
|
|
||||||
|
|
||||||
public platformAccessory: any;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Called by homebridge to gather services.
|
|
||||||
*/
|
|
||||||
public getServices = (): Array<HAPNodeJS.Service> => {
|
|
||||||
return [this._infoService, this._switchService!];
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Handler for switch set event
|
|
||||||
* @param callback The callback function to call when complete
|
|
||||||
*/
|
|
||||||
private onSwitchSet = async (newState: boolean, callback: (error?: Error | null | undefined) => void) => {
|
|
||||||
if (!this._buttonInfo.IsStateful && newState === this._buttonState) {
|
|
||||||
return callback();
|
|
||||||
}
|
|
||||||
|
|
||||||
//Get device command if we don't have it
|
|
||||||
if (!this._device) {
|
|
||||||
this._device = this._dataProvider.getDeviceFromName(this._buttonInfo.DeviceName);
|
|
||||||
}
|
|
||||||
|
|
||||||
//Execute command
|
|
||||||
if (this._device) {
|
|
||||||
//change state if stateful
|
|
||||||
if (this._buttonInfo.IsStateful && this._buttonState != newState) {
|
|
||||||
this._buttonState = newState
|
|
||||||
await this._device.sendCommand(this._buttonInfo.ButtonName);
|
|
||||||
} else if (!this._buttonInfo.IsStateful) {
|
|
||||||
//Send the number of configured key presses
|
|
||||||
for (let i = 0; i < this._buttonInfo.NumberOfKeyPresses; i++) {
|
|
||||||
await this._device.sendCommand(this._buttonInfo.ButtonName);
|
|
||||||
}
|
|
||||||
this._switchService.getCharacteristic(Characteristic.On).updateValue(false);
|
|
||||||
return callback(new Error("Normal Response"));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return callback();
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Handler for switch get event
|
|
||||||
* @param callback The callback function to call when complete
|
|
||||||
*/
|
|
||||||
private onSwitchGet = (callback: (error: Error | null, value: boolean) => void) => {
|
|
||||||
//Only return state if button is stateful
|
|
||||||
if (this._buttonInfo.IsStateful) {
|
|
||||||
return callback(null, this._buttonState);
|
|
||||||
} else {
|
|
||||||
return callback(null, false)
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Helper function to generate a UUID
|
|
||||||
*/
|
|
||||||
private generateUUID(): string { // Public Domain/MIT
|
|
||||||
var d = new Date().getTime();
|
|
||||||
if (typeof performance !== 'undefined' && typeof performance.now === 'function') {
|
|
||||||
d += performance.now(); //use high-precision timer if available
|
|
||||||
}
|
|
||||||
return 'xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx'.replace(/[xy]/g, function (c) {
|
|
||||||
var r = (d + Math.random() * 16) % 16 | 0;
|
|
||||||
d = Math.floor(d / 16);
|
|
||||||
return (c === 'x' ? r : (r & 0x3 | 0x8)).toString(16);
|
|
||||||
});
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,14 +0,0 @@
|
|||||||
|
|
||||||
/**
|
|
||||||
* Interface to describe homebridge required elements.
|
|
||||||
*/
|
|
||||||
export interface IAccessory {
|
|
||||||
/**
|
|
||||||
* Required by homebridge.
|
|
||||||
*/
|
|
||||||
name: string,
|
|
||||||
/**
|
|
||||||
* Called by homebridge to gather services.
|
|
||||||
*/
|
|
||||||
getServices(): Array<HAPNodeJS.Service>,
|
|
||||||
}
|
|
||||||
@ -1,3 +1,2 @@
|
|||||||
export { ControlUnit } from './ControlUnit';
|
export { ControlUnit } from './ControlUnit';
|
||||||
export { DeviceButton } from './DeviceButton';
|
export { DeviceButton } from './DeviceButton';
|
||||||
export { IAccessory } from './IAccessory';
|
|
||||||
@ -1,348 +1,404 @@
|
|||||||
import { IActivity } from "../Models/Config/IActivity";
|
import { IActivity } from "../Models/Config/IActivity";
|
||||||
import { IDeviceSetupItem } from "../Models/Config/IDeviceSetupItem";
|
import { IDeviceSetupItem } from "../Models/Config/IDeviceSetupItem";
|
||||||
import { IInput, IMatrix, IOutput } from "../Models/Config/IMatrix";
|
import { IInput, IMatrix, IOutput } from "../Models/Config/IMatrix";
|
||||||
import { RemoteKey } from '../Accessories/ControlUnit';
|
import { RemoteKey } from "../Accessories/ControlUnit";
|
||||||
import { EventEmitter } from "events";
|
import { EventEmitter } from "events";
|
||||||
import { ICommand } from '../Models/IDevice';
|
|
||||||
import { IHub } from "../Models/Config/IHub";
|
import { IHub } from "../Models/Config/IHub";
|
||||||
import { IDeviceConfig } from "../Models/Config/IDeviceConfig";
|
import { IDeviceConfig } from "../Models/Config/IDeviceConfig";
|
||||||
import { HarmonyDevice } from "../Models/HarmonyDevice";
|
import { HarmonyDevice } from "../Models/HarmonyDevice";
|
||||||
import { HarmonyHub } from "../Models/HarmonyHub";
|
import { HarmonyHub } from "../Models/HarmonyHub";
|
||||||
|
|
||||||
let Characteristic: HAPNodeJS.Characteristic;
|
|
||||||
|
|
||||||
const Harmony = require("harmony-websocket");
|
const Harmony = require("harmony-websocket");
|
||||||
|
|
||||||
interface IActivityState {
|
interface IActivityState {
|
||||||
currentActivity: IActivity
|
currentActivity: IActivity;
|
||||||
}
|
}
|
||||||
|
|
||||||
interface IHarmonyDataProviderProps {
|
interface IHarmonyDataProviderProps {
|
||||||
hubs: Array<IHub>;
|
hubs: Array<IHub>;
|
||||||
deviceConfigs: Array<IDeviceConfig>;
|
deviceConfigs: Array<IDeviceConfig>;
|
||||||
log: any,
|
log: any;
|
||||||
matrix: IMatrix
|
matrix: IMatrix;
|
||||||
}
|
}
|
||||||
|
|
||||||
class HarmonyDataProvider extends EventEmitter {
|
class HarmonyDataProvider extends EventEmitter {
|
||||||
private _log: any;
|
private _log: any;
|
||||||
private _hubsByDevice: { [deviceName: string]: string } = {};
|
private _hubsByDevice: { [deviceName: string]: string } = {};
|
||||||
private _hubs: { [hubName: string]: HarmonyHub } = {};
|
private _hubs: { [hubName: string]: HarmonyHub } = {};
|
||||||
// private _devicesByHub: { [hubName: string]: { [deviceName: string]: HarmonyDevice } } = {};
|
// private _devicesByHub: { [hubName: string]: { [deviceName: string]: HarmonyDevice } } = {};
|
||||||
private _states: { [controlUnitName: string]: (IActivityState | undefined) } = {};
|
private _states: {
|
||||||
|
[controlUnitName: string]: IActivityState | undefined;
|
||||||
|
} = {};
|
||||||
|
|
||||||
private _matrix: IMatrix;
|
private _matrix: IMatrix;
|
||||||
|
|
||||||
constructor(props: IHarmonyDataProviderProps) {
|
constructor(props: IHarmonyDataProviderProps) {
|
||||||
super();
|
super();
|
||||||
this._log = props.log;
|
this._log = props.log;
|
||||||
this._matrix = props.matrix;
|
this._matrix = props.matrix;
|
||||||
props.deviceConfigs.forEach((deviceConfig: IDeviceConfig) => {
|
props.deviceConfigs.forEach((deviceConfig: IDeviceConfig) => {
|
||||||
this._hubsByDevice[deviceConfig.Name] = deviceConfig.Hub;
|
this._hubsByDevice[deviceConfig.Name] = deviceConfig.Hub;
|
||||||
});
|
});
|
||||||
// this._deviceConfigs = props.deviceConfigs;
|
// this._deviceConfigs = props.deviceConfigs;
|
||||||
|
|
||||||
this.connect(props.hubs);
|
this.connect(props.hubs);
|
||||||
|
}
|
||||||
|
|
||||||
|
// public get devicesByHub(): { [hubName: string]: { [deviceName: string]: HarmonyDevice } } {
|
||||||
|
// return this._devicesByHub;
|
||||||
|
// }
|
||||||
|
|
||||||
|
public get hubs(): { [hubName: string]: HarmonyHub } {
|
||||||
|
return this._hubs;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Power on all devices in an activity.
|
||||||
|
*/
|
||||||
|
public powerOn = async (controlUnitName: string, activity: IActivity) => {
|
||||||
|
//Only power on if not alread on
|
||||||
|
let currentActivity = this._states[controlUnitName]
|
||||||
|
? this._states[controlUnitName]!.currentActivity
|
||||||
|
: undefined;
|
||||||
|
if (!currentActivity) {
|
||||||
|
await this.startActivity(controlUnitName, activity);
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Power off all devices in an activity that aren't being used.
|
||||||
|
*/
|
||||||
|
public powerOff = async (controlUnitName: string) => {
|
||||||
|
if (!this._states[controlUnitName]) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
//Build potential list of devices to turn off
|
||||||
|
let devicesToTurnOff: Array<HarmonyDevice> = this._states[
|
||||||
|
controlUnitName
|
||||||
|
]!.currentActivity.DeviceSetupList.map(
|
||||||
|
(value: IDeviceSetupItem): HarmonyDevice => {
|
||||||
|
return this.getDeviceFromName(value.DeviceName);
|
||||||
|
}
|
||||||
|
);
|
||||||
|
|
||||||
|
//Resolve device conflicts with other controlUnits
|
||||||
|
devicesToTurnOff = this.sanitizeDeviceList(
|
||||||
|
devicesToTurnOff,
|
||||||
|
controlUnitName
|
||||||
|
);
|
||||||
|
|
||||||
|
//Turn off devices
|
||||||
|
devicesToTurnOff.forEach(async (device: HarmonyDevice) => {
|
||||||
|
if (device) {
|
||||||
|
await device.powerOff();
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
this._states[controlUnitName] = undefined;
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Start an activity
|
||||||
|
*/
|
||||||
|
public startActivity = async (
|
||||||
|
controlUnitName: string,
|
||||||
|
activity: IActivity
|
||||||
|
) => {
|
||||||
|
this._log(
|
||||||
|
`Starting activity ${activity.DisplayName} for controlUnit: ${controlUnitName}`
|
||||||
|
);
|
||||||
|
let lastActivity: IActivity | undefined = undefined;
|
||||||
|
if (this._states[controlUnitName]) {
|
||||||
|
lastActivity = this._states[controlUnitName]!.currentActivity;
|
||||||
}
|
}
|
||||||
|
|
||||||
// public get devicesByHub(): { [hubName: string]: { [deviceName: string]: HarmonyDevice } } {
|
//Build potential list of devices to to turn on
|
||||||
// return this._devicesByHub;
|
let devicesToTurnOn: Array<HarmonyDevice> = activity.DeviceSetupList.map(
|
||||||
// }
|
(value: IDeviceSetupItem): HarmonyDevice => {
|
||||||
|
return this.getDeviceFromName(value.DeviceName);
|
||||||
|
}
|
||||||
|
);
|
||||||
|
|
||||||
public get hubs(): { [hubName: string]: HarmonyHub } {
|
//Resolve device conflicts with other controlUnits
|
||||||
return this._hubs;
|
devicesToTurnOn = this.sanitizeDeviceList(devicesToTurnOn, controlUnitName);
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
//Turn on devices
|
||||||
* Power on all devices in an activity.
|
await Promise.all(
|
||||||
*/
|
devicesToTurnOn.map(async (device: HarmonyDevice) => {
|
||||||
public powerOn = async (controlUnitName: string, activity: IActivity) => {
|
if (device && device.name) {
|
||||||
//Only power on if not alread on
|
if (!device.on) {
|
||||||
let currentActivity = this._states[controlUnitName] ? this._states[controlUnitName]!.currentActivity : undefined;
|
this._log(`Turning on device ${device.name}`);
|
||||||
if (!currentActivity) {
|
await device.powerOn();
|
||||||
await this.startActivity(controlUnitName, activity);
|
}
|
||||||
}
|
}
|
||||||
|
})
|
||||||
|
);
|
||||||
|
|
||||||
|
//Assign correct input
|
||||||
|
await Promise.all(
|
||||||
|
activity.DeviceSetupList.map(async (value: IDeviceSetupItem) => {
|
||||||
|
let device: HarmonyDevice = this.getDeviceFromName(value.DeviceName);
|
||||||
|
|
||||||
|
if (device && device.supportsCommand(`Input${value.Input}`)) {
|
||||||
|
await device.sendCommand(`Input${value.Input}`);
|
||||||
|
}
|
||||||
|
})
|
||||||
|
);
|
||||||
|
|
||||||
|
if (activity.UseMatrix) {
|
||||||
|
//get input and output
|
||||||
|
let input: IInput = this._matrix.Inputs.filter(
|
||||||
|
(e) => e.InputDevice === activity.ControlDevice
|
||||||
|
)[0];
|
||||||
|
let output: IOutput = this._matrix.Outputs.filter(
|
||||||
|
(e) => e.OutputDevice === activity.OutputDevice
|
||||||
|
)[0];
|
||||||
|
|
||||||
|
let inputCommandName: string = `In ${input.InputNumber}`;
|
||||||
|
let outputCommandName: string = `Out ${output.OutputLetter}`;
|
||||||
|
|
||||||
|
let matrixDevice: HarmonyDevice = this.getDeviceFromName(
|
||||||
|
this._matrix.DeviceName
|
||||||
|
);
|
||||||
|
|
||||||
|
//Route hdmi
|
||||||
|
if (
|
||||||
|
matrixDevice.supportsCommand(inputCommandName) &&
|
||||||
|
matrixDevice.supportsCommand(outputCommandName)
|
||||||
|
) {
|
||||||
|
await matrixDevice.sendCommand(outputCommandName);
|
||||||
|
await matrixDevice.sendCommand(inputCommandName);
|
||||||
|
await matrixDevice.sendCommand(outputCommandName);
|
||||||
|
await matrixDevice.sendCommand(inputCommandName);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
//Build potential list of devices to turn off
|
||||||
* Power off all devices in an activity that aren't being used.
|
if (lastActivity) {
|
||||||
*/
|
let devicesToTurnOff: Array<HarmonyDevice> = lastActivity.DeviceSetupList.map(
|
||||||
public powerOff = async (controlUnitName: string) => {
|
(value: IDeviceSetupItem): HarmonyDevice => {
|
||||||
if (!this._states[controlUnitName]) {
|
return this.getDeviceFromName(value.DeviceName);
|
||||||
return;
|
|
||||||
}
|
}
|
||||||
//Build potential list of devices to turn off
|
);
|
||||||
let devicesToTurnOff: Array<HarmonyDevice> = this._states[controlUnitName]!.currentActivity.DeviceSetupList
|
|
||||||
.map((value: IDeviceSetupItem): HarmonyDevice => {
|
|
||||||
return this.getDeviceFromName(value.DeviceName);
|
|
||||||
});
|
|
||||||
|
|
||||||
//Resolve device conflicts with other controlUnits
|
//remove devices that will be used for next activity from list
|
||||||
devicesToTurnOff = this.sanitizeDeviceList(devicesToTurnOff, controlUnitName);
|
//delete array[index] is stupid because it just nulls out the index. But now i have to deal with nulls
|
||||||
|
devicesToTurnOff.forEach((device: HarmonyDevice, index: number) => {
|
||||||
|
if (
|
||||||
|
device &&
|
||||||
|
device.name &&
|
||||||
|
activity.DeviceSetupList.some((e) => {
|
||||||
|
return e && e.DeviceName === device.name;
|
||||||
|
})
|
||||||
|
) {
|
||||||
|
delete devicesToTurnOff[index];
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
//Resolve device conflicts with other controlUnits
|
||||||
|
devicesToTurnOff = this.sanitizeDeviceList(
|
||||||
|
devicesToTurnOff,
|
||||||
|
controlUnitName
|
||||||
|
);
|
||||||
|
|
||||||
|
this._log(
|
||||||
|
`Sanatized devices to turn off: ${JSON.stringify(
|
||||||
|
devicesToTurnOff.map((e) => (e ? e.name : ""))
|
||||||
|
)}`
|
||||||
|
);
|
||||||
|
|
||||||
|
await Promise.all(
|
||||||
//Turn off devices
|
//Turn off devices
|
||||||
devicesToTurnOff.forEach(async (device: HarmonyDevice) => {
|
devicesToTurnOff.map(async (device: HarmonyDevice) => {
|
||||||
if (device) {
|
if (device) {
|
||||||
await device.powerOff();
|
if (device.on) {
|
||||||
|
this._log(`Turning off device ${device.name}`);
|
||||||
|
await device.powerOff();
|
||||||
}
|
}
|
||||||
});
|
}
|
||||||
|
})
|
||||||
this._states[controlUnitName] = undefined;
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
//Assign current activity
|
||||||
* Start an activity
|
this._states[controlUnitName] = { currentActivity: activity };
|
||||||
*/
|
};
|
||||||
public startActivity = async (controlUnitName: string, activity: IActivity) => {
|
|
||||||
this._log(`Starting activity ${activity.DisplayName} for controlUnit: ${controlUnitName}`)
|
/**
|
||||||
let lastActivity: IActivity | undefined = undefined;
|
* Turn the volume up for the current running activity.
|
||||||
if (this._states[controlUnitName]) {
|
*/
|
||||||
lastActivity = this._states[controlUnitName]!.currentActivity;
|
public volumeUp = async (controlUnitName: string) => {
|
||||||
|
let volumeUpCommand: string = "Volume Up";
|
||||||
|
if (this._states[controlUnitName]) {
|
||||||
|
let volumeDevice: HarmonyDevice = this.getDeviceFromName(
|
||||||
|
this._states[controlUnitName]!.currentActivity.VolumeDevice
|
||||||
|
);
|
||||||
|
await volumeDevice.sendCommand(volumeUpCommand);
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Volume down for current running activity.
|
||||||
|
*/
|
||||||
|
public volumeDown = async (controlUnitName: string) => {
|
||||||
|
let volumeDownCommand: string = "Volume Down";
|
||||||
|
if (this._states[controlUnitName]) {
|
||||||
|
let volumeDevice: HarmonyDevice = this.getDeviceFromName(
|
||||||
|
this._states[controlUnitName]!.currentActivity.VolumeDevice
|
||||||
|
);
|
||||||
|
await volumeDevice.sendCommand(volumeDownCommand);
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Send key press for current activity.
|
||||||
|
*
|
||||||
|
* @param controlUnitName The name of the control unit to act on.
|
||||||
|
* @param key The key to send.
|
||||||
|
*/
|
||||||
|
public sendKeyPress = async (controlUnitName: string, key: any) => {
|
||||||
|
if (this._states[controlUnitName]) {
|
||||||
|
let commandName: string = "";
|
||||||
|
|
||||||
|
let device: HarmonyDevice = this.getDeviceFromName(
|
||||||
|
this._states[controlUnitName]!.currentActivity.ControlDevice
|
||||||
|
);
|
||||||
|
switch (key) {
|
||||||
|
case RemoteKey.ARROW_UP: {
|
||||||
|
commandName = "Direction Up";
|
||||||
|
break;
|
||||||
}
|
}
|
||||||
|
case RemoteKey.ARROW_DOWN: {
|
||||||
|
commandName = "Direction Down";
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
case RemoteKey.ARROW_LEFT: {
|
||||||
|
commandName = "Direction Left";
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
case RemoteKey.ARROW_RIGHT: {
|
||||||
|
commandName = "Direction Right";
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
case RemoteKey.SELECT: {
|
||||||
|
commandName = "Select";
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
case RemoteKey.PLAY_PAUSE: {
|
||||||
|
commandName = "Pause";
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
case RemoteKey.INFORMATION: {
|
||||||
|
commandName = "Menu";
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
case RemoteKey.BACK: {
|
||||||
|
commandName = "Back";
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
case RemoteKey.EXIT: {
|
||||||
|
commandName = "Back";
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
//Build potential list of devices to to turn on
|
await device.sendCommand(commandName);
|
||||||
let devicesToTurnOn: Array<HarmonyDevice> = activity.DeviceSetupList.map((value: IDeviceSetupItem): HarmonyDevice => {
|
}
|
||||||
return this.getDeviceFromName(value.DeviceName);
|
};
|
||||||
});
|
|
||||||
|
|
||||||
//Resolve device conflicts with other controlUnits
|
/**
|
||||||
devicesToTurnOn = this.sanitizeDeviceList(devicesToTurnOn, controlUnitName);
|
* Return if a control unit is active
|
||||||
|
* @param controlUnitName
|
||||||
|
*/
|
||||||
|
public getIsActive(controlUnitName: string): IActivity | undefined {
|
||||||
|
return this._states[controlUnitName]
|
||||||
|
? this._states[controlUnitName]!.currentActivity
|
||||||
|
: undefined;
|
||||||
|
}
|
||||||
|
|
||||||
//Turn on devices
|
/**
|
||||||
await Promise.all(devicesToTurnOn.map(async (device: HarmonyDevice) => {
|
* Get the IDevice by name.
|
||||||
if (device && device.name) {
|
* @param deviceName The device to retrieve.
|
||||||
if (!device.on) {
|
*/
|
||||||
this._log(`Turning on device ${device.name}`)
|
public getDeviceFromName(deviceName: string): HarmonyDevice {
|
||||||
await device.powerOn();
|
let device: HarmonyDevice | undefined;
|
||||||
}
|
try {
|
||||||
|
device = this._hubs[this._hubsByDevice[deviceName]].getDeviceByName(
|
||||||
|
deviceName
|
||||||
|
);
|
||||||
|
} catch (err) {
|
||||||
|
this._log(`Error retrieving device from hub: ${err}`);
|
||||||
|
}
|
||||||
|
|
||||||
|
return device!;
|
||||||
|
}
|
||||||
|
|
||||||
|
// /**
|
||||||
|
// * Gets device button commands
|
||||||
|
// * @param deviceCommandName The device command name
|
||||||
|
// * @param deviceName The device name
|
||||||
|
// */
|
||||||
|
// public getCommand(deviceCommandName: string, deviceName: string): ICommand | undefined {
|
||||||
|
// const device: HarmonyDevice = this.getDeviceFromName(deviceName);
|
||||||
|
// if (device && device.supportsCommand(deviceCommandName)) {
|
||||||
|
// return device.getCommand(deviceCommandName);
|
||||||
|
// } else {
|
||||||
|
// return undefined;
|
||||||
|
// }
|
||||||
|
// }
|
||||||
|
|
||||||
|
private connect = async (hubs: Array<IHub>) => {
|
||||||
|
let readyCount = 0;
|
||||||
|
await Promise.all(
|
||||||
|
hubs.map(
|
||||||
|
async (hub: IHub): Promise<void> => {
|
||||||
|
const newHarmonyHub = new HarmonyHub(hub.Name, hub.Ip, this._log);
|
||||||
|
this._hubs[hub.Name] = newHarmonyHub;
|
||||||
|
newHarmonyHub.on("Ready", () => {
|
||||||
|
readyCount++;
|
||||||
|
if (readyCount === Object.keys(this._hubs).length) {
|
||||||
|
this.emit("Ready");
|
||||||
}
|
}
|
||||||
}));
|
});
|
||||||
|
await newHarmonyHub.initialize();
|
||||||
|
}
|
||||||
|
)
|
||||||
|
);
|
||||||
|
};
|
||||||
|
|
||||||
//Assign correct input
|
/**
|
||||||
await Promise.all(
|
* Helper function to make sure no control unit depends on device list.
|
||||||
activity.DeviceSetupList.map(async (value: IDeviceSetupItem) => {
|
* @param devicesToTurnOn The list of devices to modify.
|
||||||
let device: HarmonyDevice = this.getDeviceFromName(value.DeviceName);
|
* @param controlUnitName The name of the control unit in question.
|
||||||
|
*/
|
||||||
|
private sanitizeDeviceList(
|
||||||
|
devicesToTurnOn: Array<HarmonyDevice>,
|
||||||
|
controlUnitName: string
|
||||||
|
): Array<HarmonyDevice> {
|
||||||
|
for (let controlUnitKey in this._states) {
|
||||||
|
//Skip self
|
||||||
|
if (controlUnitKey === controlUnitName) {
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
let currentOtherState: IActivityState = this._states[controlUnitKey]!;
|
||||||
|
|
||||||
if (device && device.supportsCommand(`Input${value.Input}`)) {
|
if (currentOtherState) {
|
||||||
await device.sendCommand(`Input${value.Input}`)
|
currentOtherState.currentActivity.DeviceSetupList.forEach(
|
||||||
}
|
(value: IDeviceSetupItem) => {
|
||||||
})
|
//there are devices to remove
|
||||||
|
if (devicesToTurnOn.some((e) => e && e.name === value.DeviceName)) {
|
||||||
|
let deviceToRemove: HarmonyDevice = devicesToTurnOn.filter(
|
||||||
|
(i) => i.name === value.DeviceName
|
||||||
|
)[0];
|
||||||
|
delete devicesToTurnOn[devicesToTurnOn.indexOf(deviceToRemove)];
|
||||||
|
}
|
||||||
|
}
|
||||||
);
|
);
|
||||||
|
}
|
||||||
if (activity.UseMatrix) {
|
|
||||||
//get input and output
|
|
||||||
let input: IInput = this._matrix.Inputs.filter(e => e.InputDevice === activity.ControlDevice)[0];
|
|
||||||
let output: IOutput = this._matrix.Outputs.filter(e => e.OutputDevice === activity.OutputDevice)[0];
|
|
||||||
|
|
||||||
let inputCommandName: string = `In ${input.InputNumber}`;
|
|
||||||
let outputCommandName: string = `Out ${output.OutputLetter}`;
|
|
||||||
|
|
||||||
let matrixDevice: HarmonyDevice = this.getDeviceFromName(this._matrix.DeviceName);
|
|
||||||
|
|
||||||
//Route hdmi
|
|
||||||
if (matrixDevice.supportsCommand(inputCommandName) && matrixDevice.supportsCommand(outputCommandName)) {
|
|
||||||
await matrixDevice.sendCommand(outputCommandName);
|
|
||||||
await matrixDevice.sendCommand(inputCommandName);
|
|
||||||
await matrixDevice.sendCommand(outputCommandName);
|
|
||||||
await matrixDevice.sendCommand(inputCommandName);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
//Build potential list of devices to turn off
|
|
||||||
if (lastActivity) {
|
|
||||||
let devicesToTurnOff: Array<HarmonyDevice> = lastActivity.DeviceSetupList.map((value: IDeviceSetupItem): HarmonyDevice => {
|
|
||||||
return this.getDeviceFromName(value.DeviceName);
|
|
||||||
});
|
|
||||||
|
|
||||||
//remove devices that will be used for next activity from list
|
|
||||||
//delete array[index] is stupid because it just nulls out the index. But now i have to deal with nulls
|
|
||||||
devicesToTurnOff.forEach((device: HarmonyDevice, index: number) => {
|
|
||||||
if (device && device.name && activity.DeviceSetupList.some(e => {
|
|
||||||
return (e && e.DeviceName === device.name)
|
|
||||||
})) {
|
|
||||||
delete devicesToTurnOff[index];
|
|
||||||
}
|
|
||||||
})
|
|
||||||
|
|
||||||
//Resolve device conflicts with other controlUnits
|
|
||||||
devicesToTurnOff = this.sanitizeDeviceList(devicesToTurnOff, controlUnitName);
|
|
||||||
|
|
||||||
this._log(`Sanatized devices to turn off: ${JSON.stringify(devicesToTurnOff.map(e => e ? e.name : ""))}`);
|
|
||||||
|
|
||||||
await Promise.all(
|
|
||||||
//Turn off devices
|
|
||||||
devicesToTurnOff.map(async (device: HarmonyDevice) => {
|
|
||||||
if (device) {
|
|
||||||
if (device.on) {
|
|
||||||
this._log(`Turning off device ${device.name}`)
|
|
||||||
await device.powerOff();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
})
|
|
||||||
);
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
//Assign current activity
|
|
||||||
this._states[controlUnitName] = { currentActivity: activity };
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
return devicesToTurnOn;
|
||||||
* Turn the volume up for the current running activity.
|
}
|
||||||
*/
|
|
||||||
public volumeUp = async (controlUnitName: string) => {
|
|
||||||
let volumeUpCommand: string = "Volume Up"
|
|
||||||
if (this._states[controlUnitName]) {
|
|
||||||
let volumeDevice: HarmonyDevice = this.getDeviceFromName(this._states[controlUnitName]!.currentActivity.VolumeDevice);
|
|
||||||
await volumeDevice.sendCommand(volumeUpCommand);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Volume down for current running activity.
|
|
||||||
*/
|
|
||||||
public volumeDown = async (controlUnitName: string) => {
|
|
||||||
let volumeDownCommand: string = "Volume Down"
|
|
||||||
if (this._states[controlUnitName]) {
|
|
||||||
let volumeDevice: HarmonyDevice = this.getDeviceFromName(this._states[controlUnitName]!.currentActivity.VolumeDevice);
|
|
||||||
await volumeDevice.sendCommand(volumeDownCommand);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Send key press for current activity.
|
|
||||||
*
|
|
||||||
* @param controlUnitName The name of the control unit to act on.
|
|
||||||
* @param key The key to send.
|
|
||||||
*/
|
|
||||||
public sendKeyPress = async (controlUnitName: string, key: any) => {
|
|
||||||
if (this._states[controlUnitName]) {
|
|
||||||
let commandName: string = "";
|
|
||||||
|
|
||||||
let device: HarmonyDevice = this.getDeviceFromName(this._states[controlUnitName]!.currentActivity.ControlDevice);
|
|
||||||
switch (key) {
|
|
||||||
case RemoteKey.ARROW_UP: {
|
|
||||||
commandName = "Direction Up";
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
case RemoteKey.ARROW_DOWN: {
|
|
||||||
commandName = "Direction Down";
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
case RemoteKey.ARROW_LEFT: {
|
|
||||||
commandName = "Direction Left";
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
case RemoteKey.ARROW_RIGHT: {
|
|
||||||
commandName = "Direction Right";
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
case RemoteKey.SELECT: {
|
|
||||||
commandName = "Select";
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
case RemoteKey.PLAY_PAUSE: {
|
|
||||||
commandName = "Pause";
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
case RemoteKey.INFORMATION: {
|
|
||||||
commandName = "Menu";
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
case RemoteKey.BACK: {
|
|
||||||
commandName = "Back";
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
case RemoteKey.EXIT: {
|
|
||||||
commandName = "Back";
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
await device.sendCommand(commandName);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Return if a control unit is active
|
|
||||||
* @param controlUnitName
|
|
||||||
*/
|
|
||||||
public getIsActive(controlUnitName: string): IActivity | undefined {
|
|
||||||
return this._states[controlUnitName] ? this._states[controlUnitName]!.currentActivity : undefined;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Get the IDevice by name.
|
|
||||||
* @param deviceName The device to retrieve.
|
|
||||||
*/
|
|
||||||
public getDeviceFromName(deviceName: string): HarmonyDevice {
|
|
||||||
let device: HarmonyDevice | undefined;
|
|
||||||
try {
|
|
||||||
device = this._hubs[this._hubsByDevice[deviceName]].getDeviceByName(deviceName);
|
|
||||||
} catch (err) {
|
|
||||||
this._log(`Error retrieving device from hub: ${err}`);
|
|
||||||
}
|
|
||||||
|
|
||||||
return device!;
|
|
||||||
}
|
|
||||||
|
|
||||||
// /**
|
|
||||||
// * Gets device button commands
|
|
||||||
// * @param deviceCommandName The device command name
|
|
||||||
// * @param deviceName The device name
|
|
||||||
// */
|
|
||||||
// public getCommand(deviceCommandName: string, deviceName: string): ICommand | undefined {
|
|
||||||
// const device: HarmonyDevice = this.getDeviceFromName(deviceName);
|
|
||||||
// if (device && device.supportsCommand(deviceCommandName)) {
|
|
||||||
// return device.getCommand(deviceCommandName);
|
|
||||||
// } else {
|
|
||||||
// return undefined;
|
|
||||||
// }
|
|
||||||
// }
|
|
||||||
|
|
||||||
private connect = async (hubs: Array<IHub>) => {
|
|
||||||
let readyCount = 0;
|
|
||||||
await Promise.all(
|
|
||||||
hubs.map(async (hub: IHub): Promise<void> => {
|
|
||||||
const newHarmonyHub = new HarmonyHub(hub.Name, hub.Ip, this._log);
|
|
||||||
this._hubs[hub.Name] = newHarmonyHub;
|
|
||||||
newHarmonyHub.on("Ready", () => {
|
|
||||||
readyCount++;
|
|
||||||
if (readyCount === Object.keys(this._hubs).length) {
|
|
||||||
this.emit("Ready");
|
|
||||||
}
|
|
||||||
})
|
|
||||||
await newHarmonyHub.initialize();
|
|
||||||
})
|
|
||||||
)
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Helper function to make sure no control unit depends on device list.
|
|
||||||
* @param devicesToTurnOn The list of devices to modify.
|
|
||||||
* @param controlUnitName The name of the control unit in question.
|
|
||||||
*/
|
|
||||||
private sanitizeDeviceList(devicesToTurnOn: Array<HarmonyDevice>, controlUnitName: string): Array<HarmonyDevice> {
|
|
||||||
for (let controlUnitKey in this._states) {
|
|
||||||
//Skip self
|
|
||||||
if (controlUnitKey === controlUnitName) {
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
let currentOtherState: IActivityState = this._states[controlUnitKey]!;
|
|
||||||
|
|
||||||
if (currentOtherState) {
|
|
||||||
currentOtherState.currentActivity.DeviceSetupList.forEach((value: IDeviceSetupItem) => {
|
|
||||||
//there are devices to remove
|
|
||||||
if (devicesToTurnOn.some(e => e && e.name === value.DeviceName)) {
|
|
||||||
let deviceToRemove: HarmonyDevice = devicesToTurnOn.filter(i => i.name === value.DeviceName)[0];
|
|
||||||
delete devicesToTurnOn[devicesToTurnOn.indexOf(deviceToRemove)];
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return devicesToTurnOn;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
export default HarmonyDataProvider;
|
export default HarmonyDataProvider;
|
||||||
|
|||||||
@ -34,6 +34,13 @@ export class HarmonyHub extends EventEmitter {
|
|||||||
public initialize = async () => {
|
public initialize = async () => {
|
||||||
this._harmony = new Harmony();
|
this._harmony = new Harmony();
|
||||||
await this._harmony.connect(this._ip);
|
await this._harmony.connect(this._ip);
|
||||||
|
this._harmony.on('stateDigest', (data: any) => {
|
||||||
|
console.log(data);
|
||||||
|
});
|
||||||
|
|
||||||
|
this._harmony.on('automationState', (data: any) => {
|
||||||
|
console.log(data);
|
||||||
|
});
|
||||||
|
|
||||||
//Gather devices
|
//Gather devices
|
||||||
let devices: any = await this._harmony.getDevices();
|
let devices: any = await this._harmony.getDevices();
|
||||||
|
|||||||
456
src/Types/HAPNodeJS.d.ts
vendored
456
src/Types/HAPNodeJS.d.ts
vendored
@ -1,456 +0,0 @@
|
|||||||
declare namespace HAPNodeJS {
|
|
||||||
|
|
||||||
export interface uuid {
|
|
||||||
generate(data: string): string;
|
|
||||||
isValid(UUID: string): boolean;
|
|
||||||
unparse(bug: string, offset: number): string;
|
|
||||||
}
|
|
||||||
|
|
||||||
type EventService = "characteristic-change" | "service-configurationChange"
|
|
||||||
|
|
||||||
export interface IEventEmitterAccessory {
|
|
||||||
addListener(event: EventService, listener: Function): this;
|
|
||||||
on(event: EventService, listener: Function): this;
|
|
||||||
once(event: EventService, listener: Function): this;
|
|
||||||
removeListener(event: EventService, listener: Function): this;
|
|
||||||
removeAllListeners(event?: EventService): this;
|
|
||||||
setMaxListeners(n: number): this;
|
|
||||||
getMaxListeners(): number;
|
|
||||||
listeners(event: EventService): Function[];
|
|
||||||
emit(event: EventService, ...args: any[]): boolean;
|
|
||||||
listenerCount(type: string): number;
|
|
||||||
}
|
|
||||||
|
|
||||||
export interface Service extends IEventEmitterAccessory {
|
|
||||||
new(displayName: string, UUID: string, subtype: string): Service;
|
|
||||||
|
|
||||||
displayName: string;
|
|
||||||
UUID: string;
|
|
||||||
subtype: string;
|
|
||||||
iid: string;
|
|
||||||
characteristics: Characteristic[];
|
|
||||||
optionalCharacteristics: Characteristic[];
|
|
||||||
|
|
||||||
addCharacteristic(characteristic: Characteristic | Function): Characteristic;
|
|
||||||
removeCharacteristic(characteristic: Characteristic): void;
|
|
||||||
getCharacteristic(name: string | Function): Characteristic;
|
|
||||||
testCharacteristic(name: string | Function): boolean;
|
|
||||||
setCharacteristic(name: string | Function, value: CharacteristicValue): Service;
|
|
||||||
updateCharacteristic(name: string | Function, value: CharacteristicValue): Service;
|
|
||||||
addOptionalCharacteristic(characteristic: Characteristic | Function): void;
|
|
||||||
getCharacteristicByIID(iid: string): Characteristic;
|
|
||||||
|
|
||||||
toHAP(opt: any): JSON;
|
|
||||||
|
|
||||||
AccessoryInformation: PredefinedService;
|
|
||||||
AirPurifier: PredefinedService;
|
|
||||||
AirQualitySensor: PredefinedService;
|
|
||||||
BatteryService: PredefinedService;
|
|
||||||
BridgeConfiguration: PredefinedService;
|
|
||||||
BridgingState: PredefinedService;
|
|
||||||
CameraControl: PredefinedService;
|
|
||||||
CameraRTPStreamManagement: PredefinedService;
|
|
||||||
CarbonDioxideSensor: PredefinedService;
|
|
||||||
CarbonMonoxideSensor: PredefinedService;
|
|
||||||
ContactSensor: PredefinedService;
|
|
||||||
Door: PredefinedService;
|
|
||||||
Doorbell: PredefinedService;
|
|
||||||
Fan: PredefinedService;
|
|
||||||
Fanv2: PredefinedService;
|
|
||||||
Faucet: PredefinedService;
|
|
||||||
FilterMaintenance: PredefinedService;
|
|
||||||
GarageDoorOpener: PredefinedService;
|
|
||||||
HeaterCooler: PredefinedService;
|
|
||||||
HumidifierDehumidifier: PredefinedService;
|
|
||||||
HumiditySensor: PredefinedService;
|
|
||||||
InputSource: PredefinedService;
|
|
||||||
IrrigationSystem: PredefinedService;
|
|
||||||
LeakSensor: PredefinedService;
|
|
||||||
LightSensor: PredefinedService;
|
|
||||||
Lightbulb: PredefinedService;
|
|
||||||
LockManagement: PredefinedService;
|
|
||||||
LockMechanism: PredefinedService;
|
|
||||||
Microphone: PredefinedService;
|
|
||||||
MotionSensor: PredefinedService;
|
|
||||||
OccupancySensor: PredefinedService;
|
|
||||||
Outlet: PredefinedService;
|
|
||||||
Pairing: PredefinedService;
|
|
||||||
ProtocolInformation: PredefinedService;
|
|
||||||
Relay: PredefinedService;
|
|
||||||
SecuritySystem: PredefinedService;
|
|
||||||
ServiceLabel: PredefinedService;
|
|
||||||
Slat: PredefinedService;
|
|
||||||
SmokeSensor: PredefinedService;
|
|
||||||
Speaker: PredefinedService;
|
|
||||||
StatefulProgrammableSwitch: PredefinedService;
|
|
||||||
StatelessProgrammableSwitch: PredefinedService;
|
|
||||||
Switch: PredefinedService;
|
|
||||||
Television: PredefinedService;
|
|
||||||
TelevisionSpeaker: PredefinedService;
|
|
||||||
TemperatureSensor: PredefinedService;
|
|
||||||
Thermostat: PredefinedService;
|
|
||||||
TimeInformation: PredefinedService;
|
|
||||||
TunneledBTLEAccessoryService: PredefinedService;
|
|
||||||
Valve: PredefinedService;
|
|
||||||
Window: PredefinedService;
|
|
||||||
WindowCovering: PredefinedService;
|
|
||||||
}
|
|
||||||
|
|
||||||
export interface PredefinedService {
|
|
||||||
new(displayName: string, subtype: string): Service;
|
|
||||||
}
|
|
||||||
|
|
||||||
export interface CameraSource {
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
type EventAccessory = "service-configurationChange" | "service-characteristic-change" | "identify"
|
|
||||||
|
|
||||||
export interface IEventEmitterAccessory {
|
|
||||||
addListener(event: EventAccessory, listener: Function): this;
|
|
||||||
on(event: EventAccessory, listener: Function): this;
|
|
||||||
once(event: EventAccessory, listener: Function): this;
|
|
||||||
removeListener(event: EventAccessory, listener: Function): this;
|
|
||||||
removeAllListeners(event?: EventAccessory): this;
|
|
||||||
setMaxListeners(n: number): this;
|
|
||||||
getMaxListeners(): number;
|
|
||||||
listeners(event: EventAccessory): Function[];
|
|
||||||
emit(event: EventAccessory, ...args: any[]): boolean;
|
|
||||||
listenerCount(type: string): number;
|
|
||||||
}
|
|
||||||
|
|
||||||
export interface CharacteristicProps {
|
|
||||||
format: Characteristic.Formats;
|
|
||||||
unit: Characteristic.Units,
|
|
||||||
minValue: number,
|
|
||||||
maxValue: number,
|
|
||||||
minStep: number,
|
|
||||||
perms: Characteristic.Perms[]
|
|
||||||
}
|
|
||||||
|
|
||||||
type EventCharacteristic = "get" | "set"
|
|
||||||
type CharacteristicValue = boolean | string | number
|
|
||||||
|
|
||||||
export type CharacteristicGetCallback<T = CharacteristicValue> = (error: Error | null, value: T) => void
|
|
||||||
export type CharacteristicSetCallback = (error?: Error | null) => void
|
|
||||||
export type CharacteristicCallback = CharacteristicGetCallback | CharacteristicSetCallback
|
|
||||||
|
|
||||||
export interface IEventEmitterCharacteristic {
|
|
||||||
addListener(event: EventCharacteristic, listener: CharacteristicCallback): this;
|
|
||||||
on(event: EventCharacteristic, listener: CharacteristicCallback): this;
|
|
||||||
once(event: EventCharacteristic, listener: CharacteristicCallback): this;
|
|
||||||
removeListener(event: EventCharacteristic, listener: CharacteristicCallback): this;
|
|
||||||
removeAllListeners(event?: EventCharacteristic): this;
|
|
||||||
setMaxListeners(n: number): this;
|
|
||||||
getMaxListeners(): number;
|
|
||||||
listeners(event: EventCharacteristic): CharacteristicCallback[];
|
|
||||||
emit(event: EventCharacteristic, ...args: any[]): boolean;
|
|
||||||
listenerCount(type: string): number;
|
|
||||||
}
|
|
||||||
|
|
||||||
export interface Characteristic extends IEventEmitterCharacteristic {
|
|
||||||
new(displayName: string, UUID: string, props?: CharacteristicProps): Characteristic;
|
|
||||||
|
|
||||||
Formats: typeof Characteristic.Formats;
|
|
||||||
Units: typeof Characteristic.Units;
|
|
||||||
Perms: typeof Characteristic.Perms;
|
|
||||||
|
|
||||||
setProps(props: CharacteristicProps): Characteristic
|
|
||||||
getValue(callback?: CharacteristicGetCallback, context?: any, connectionID?: string): void;
|
|
||||||
setValue(newValue: CharacteristicValue, callback?: CharacteristicSetCallback, context?: any, connectionID?: string): Characteristic;
|
|
||||||
updateValue(newValue: CharacteristicValue, callback?: () => void, context?: any): Characteristic;
|
|
||||||
getDefaultValue(): CharacteristicValue;
|
|
||||||
toHAP(opt: any): JSON;
|
|
||||||
|
|
||||||
AccessoryFlags: Characteristic;
|
|
||||||
AccessoryIdentifier: Characteristic;
|
|
||||||
Active: Characteristic;
|
|
||||||
ActiveIdentifier: Characteristic;
|
|
||||||
AdministratorOnlyAccess: Characteristic;
|
|
||||||
AirParticulateDensity: Characteristic;
|
|
||||||
AirParticulateSize: Characteristic;
|
|
||||||
AirQuality: Characteristic;
|
|
||||||
AppMatchingIdentifier: Characteristic;
|
|
||||||
AudioFeedback: Characteristic;
|
|
||||||
BatteryLevel: Characteristic;
|
|
||||||
Brightness: Characteristic;
|
|
||||||
CarbonDioxideDetected: Characteristic;
|
|
||||||
CarbonDioxideLevel: Characteristic;
|
|
||||||
CarbonDioxidePeakLevel: Characteristic;
|
|
||||||
CarbonMonoxideDetected: Characteristic;
|
|
||||||
CarbonMonoxideLevel: Characteristic;
|
|
||||||
CarbonMonoxidePeakLevel: Characteristic;
|
|
||||||
Category: Characteristic;
|
|
||||||
ChargingState: Characteristic;
|
|
||||||
ClosedCaptions: Characteristic;
|
|
||||||
ColorTemperature: Characteristic;
|
|
||||||
ConfigureBridgedAccessory: Characteristic;
|
|
||||||
ConfigureBridgedAccessoryStatus: Characteristic;
|
|
||||||
ConfiguredName: Characteristic;
|
|
||||||
ContactSensorState: Characteristic;
|
|
||||||
CoolingThresholdTemperature: Characteristic;
|
|
||||||
CurrentAirPurifierState: Characteristic;
|
|
||||||
CurrentAmbientLightLevel: Characteristic;
|
|
||||||
CurrentDoorState: Characteristic;
|
|
||||||
CurrentFanState: Characteristic;
|
|
||||||
CurrentHeaterCoolerState: Characteristic;
|
|
||||||
CurrentHeatingCoolingState: Characteristic;
|
|
||||||
CurrentHorizontalTiltAngle: Characteristic;
|
|
||||||
CurrentHumidifierDehumidifierState: Characteristic;
|
|
||||||
CurrentMediaState: Characteristic;
|
|
||||||
CurrentPosition: Characteristic;
|
|
||||||
CurrentRelativeHumidity: Characteristic;
|
|
||||||
CurrentSlatState: Characteristic;
|
|
||||||
CurrentTemperature: Characteristic;
|
|
||||||
CurrentTiltAngle: Characteristic;
|
|
||||||
CurrentTime: Characteristic;
|
|
||||||
CurrentVerticalTiltAngle: Characteristic;
|
|
||||||
CurrentVisibilityState: Characteristic;
|
|
||||||
DayoftheWeek: Characteristic;
|
|
||||||
DigitalZoom: Characteristic;
|
|
||||||
DiscoverBridgedAccessories: Characteristic;
|
|
||||||
DiscoveredBridgedAccessories: Characteristic;
|
|
||||||
DisplayOrder: Characteristic;
|
|
||||||
FilterChangeIndication: Characteristic;
|
|
||||||
FilterLifeLevel: Characteristic;
|
|
||||||
FirmwareRevision: Characteristic;
|
|
||||||
HardwareRevision: Characteristic;
|
|
||||||
HeatingThresholdTemperature: Characteristic;
|
|
||||||
HoldPosition: Characteristic;
|
|
||||||
Hue: Characteristic;
|
|
||||||
Identifier: Characteristic;
|
|
||||||
Identify: Characteristic;
|
|
||||||
ImageMirroring: Characteristic;
|
|
||||||
ImageRotation: Characteristic;
|
|
||||||
InUse: Characteristic;
|
|
||||||
InputDeviceType: Characteristic;
|
|
||||||
InputSourceType: Characteristic;
|
|
||||||
IsConfigured: Characteristic;
|
|
||||||
LeakDetected: Characteristic;
|
|
||||||
LinkQuality: Characteristic;
|
|
||||||
LockControlPoint: Characteristic;
|
|
||||||
LockCurrentState: Characteristic;
|
|
||||||
LockLastKnownAction: Characteristic;
|
|
||||||
LockManagementAutoSecurityTimeout: Characteristic;
|
|
||||||
LockPhysicalControls: Characteristic;
|
|
||||||
LockTargetState: Characteristic;
|
|
||||||
Logs: Characteristic;
|
|
||||||
Manufacturer: Characteristic;
|
|
||||||
Model: Characteristic;
|
|
||||||
MotionDetected: Characteristic;
|
|
||||||
Mute: Characteristic;
|
|
||||||
Name: Characteristic;
|
|
||||||
NightVision: Characteristic;
|
|
||||||
NitrogenDioxideDensity: Characteristic;
|
|
||||||
ObstructionDetected: Characteristic;
|
|
||||||
OccupancyDetected: Characteristic;
|
|
||||||
On: Characteristic;
|
|
||||||
OpticalZoom: Characteristic;
|
|
||||||
OutletInUse: Characteristic;
|
|
||||||
OzoneDensity: Characteristic;
|
|
||||||
PM10Density: Characteristic;
|
|
||||||
PM2_5Density: Characteristic;
|
|
||||||
PairSetup: Characteristic;
|
|
||||||
PairVerify: Characteristic;
|
|
||||||
PairingFeatures: Characteristic;
|
|
||||||
PairingPairings: Characteristic;
|
|
||||||
PictureMode: Characteristic;
|
|
||||||
PositionState: Characteristic;
|
|
||||||
PowerModeSelection: Characteristic;
|
|
||||||
ProgramMode: Characteristic;
|
|
||||||
ProgrammableSwitchEvent: Characteristic;
|
|
||||||
ProgrammableSwitchOutputState: Characteristic;
|
|
||||||
Reachable: Characteristic;
|
|
||||||
RelativeHumidityDehumidifierThreshold: Characteristic;
|
|
||||||
RelativeHumidityHumidifierThreshold: Characteristic;
|
|
||||||
RelayControlPoint: Characteristic;
|
|
||||||
RelayEnabled: Characteristic;
|
|
||||||
RelayState: Characteristic;
|
|
||||||
RemainingDuration: Characteristic;
|
|
||||||
RemoteKey: Characteristic;
|
|
||||||
ResetFilterIndication: Characteristic;
|
|
||||||
RotationDirection: Characteristic;
|
|
||||||
RotationSpeed: Characteristic;
|
|
||||||
Saturation: Characteristic;
|
|
||||||
SecuritySystemAlarmType: Characteristic;
|
|
||||||
SecuritySystemCurrentState: Characteristic;
|
|
||||||
SecuritySystemTargetState: Characteristic;
|
|
||||||
SelectedRTPStreamConfiguration: Characteristic;
|
|
||||||
SerialNumber: Characteristic;
|
|
||||||
ServiceLabelIndex: Characteristic;
|
|
||||||
ServiceLabelNamespace: Characteristic;
|
|
||||||
SetDuration: Characteristic;
|
|
||||||
SetupEndpoints: Characteristic;
|
|
||||||
SlatType: Characteristic;
|
|
||||||
SleepDiscoveryMode: Characteristic;
|
|
||||||
SmokeDetected: Characteristic;
|
|
||||||
SoftwareRevision: Characteristic;
|
|
||||||
StatusActive: Characteristic;
|
|
||||||
StatusFault: Characteristic;
|
|
||||||
StatusJammed: Characteristic;
|
|
||||||
StatusLowBattery: Characteristic;
|
|
||||||
StatusTampered: Characteristic;
|
|
||||||
StreamingStatus: Characteristic;
|
|
||||||
SulphurDioxideDensity: Characteristic;
|
|
||||||
SupportedAudioStreamConfiguration: Characteristic;
|
|
||||||
SupportedRTPConfiguration: Characteristic;
|
|
||||||
SupportedVideoStreamConfiguration: Characteristic;
|
|
||||||
SwingMode: Characteristic;
|
|
||||||
TargetAirPurifierState: Characteristic;
|
|
||||||
TargetAirQuality: Characteristic;
|
|
||||||
TargetDoorState: Characteristic;
|
|
||||||
TargetFanState: Characteristic;
|
|
||||||
TargetHeaterCoolerState: Characteristic;
|
|
||||||
TargetHeatingCoolingState: Characteristic;
|
|
||||||
TargetHorizontalTiltAngle: Characteristic;
|
|
||||||
TargetHumidifierDehumidifierState: Characteristic;
|
|
||||||
TargetMediaState: Characteristic;
|
|
||||||
TargetPosition: Characteristic;
|
|
||||||
TargetRelativeHumidity: Characteristic;
|
|
||||||
TargetSlatState: Characteristic;
|
|
||||||
TargetTemperature: Characteristic;
|
|
||||||
TargetTiltAngle: Characteristic;
|
|
||||||
TargetVerticalTiltAngle: Characteristic;
|
|
||||||
TargetVisibilityState: Characteristic;
|
|
||||||
TemperatureDisplayUnits: Characteristic;
|
|
||||||
TimeUpdate: Characteristic;
|
|
||||||
TunnelConnectionTimeout: Characteristic;
|
|
||||||
TunneledAccessoryAdvertising: Characteristic;
|
|
||||||
TunneledAccessoryConnected: Characteristic;
|
|
||||||
TunneledAccessoryStateNumber: Characteristic;
|
|
||||||
VOCDensity: Characteristic;
|
|
||||||
ValveType: Characteristic;
|
|
||||||
Version: Characteristic;
|
|
||||||
Volume: Characteristic;
|
|
||||||
VolumeControlType: Characteristic;
|
|
||||||
VolumeSelector: Characteristic;
|
|
||||||
WaterLevel: Characteristic;
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
module Characteristic {
|
|
||||||
export enum Formats {
|
|
||||||
BOOL,
|
|
||||||
INT,
|
|
||||||
FLOAT,
|
|
||||||
STRING,
|
|
||||||
ARRAY, // unconfirmed
|
|
||||||
DICTIONARY, // unconfirmed
|
|
||||||
UINT8,
|
|
||||||
UINT16,
|
|
||||||
UINT32,
|
|
||||||
UINT64,
|
|
||||||
DATA, // unconfirmed
|
|
||||||
TLV8
|
|
||||||
}
|
|
||||||
|
|
||||||
export enum Units {
|
|
||||||
// HomeKit only defines Celsius, for Fahrenheit, it requires iOS app to do the conversion.
|
|
||||||
CELSIUS,
|
|
||||||
PERCENTAGE,
|
|
||||||
ARC_DEGREE,
|
|
||||||
LUX,
|
|
||||||
SECONDS
|
|
||||||
}
|
|
||||||
|
|
||||||
export enum Perms {
|
|
||||||
READ,
|
|
||||||
WRITE,
|
|
||||||
NOTIFY,
|
|
||||||
HIDDEN
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
export interface PublishInfo {
|
|
||||||
port: number;
|
|
||||||
username: string;
|
|
||||||
pincode: string;
|
|
||||||
category: number;
|
|
||||||
}
|
|
||||||
|
|
||||||
export interface Accessory extends IEventEmitterAccessory {
|
|
||||||
new(displayName: string, UUID: string): Accessory;
|
|
||||||
displayName: string;
|
|
||||||
username: string;
|
|
||||||
pincode: string;
|
|
||||||
UUID: string;
|
|
||||||
aid: string;
|
|
||||||
bridged: boolean;
|
|
||||||
bridgedAccessories: Accessory[];
|
|
||||||
reachable: boolean;
|
|
||||||
category: Accessory.Categories;
|
|
||||||
services: Service[];
|
|
||||||
cameraSource: CameraSource;
|
|
||||||
Categories: typeof Accessory.Categories
|
|
||||||
addService(service: Service | Function): Service;
|
|
||||||
removeService(service: Service): void;
|
|
||||||
getService(name: string | Function): Service;
|
|
||||||
updateReachability(reachable: boolean): void;
|
|
||||||
addBridgedAccessory(accessory: Accessory, deferUpdate: boolean): Accessory;
|
|
||||||
addBridgedAccessories(accessories: Accessory[]): void
|
|
||||||
removeBridgedAccessory(accessory: Accessory, deferUpdate: boolean): void;
|
|
||||||
removeBridgedAccessories(accessories: Accessory[]): void;
|
|
||||||
getCharacteristicByIID(iid: string): Characteristic;
|
|
||||||
getBridgedAccessoryByAID(aid: string): Accessory;
|
|
||||||
findCharacteristic(aid: string, iid: string): Accessory;
|
|
||||||
configureCameraSource(cameraSource: CameraSource): void;
|
|
||||||
toHAP(opt: any): JSON;
|
|
||||||
publish(info: PublishInfo, allowInsecureRequest: boolean): void;
|
|
||||||
destroy(): void;
|
|
||||||
setupURI(): string;
|
|
||||||
}
|
|
||||||
|
|
||||||
module Accessory {
|
|
||||||
export enum Categories {
|
|
||||||
OTHER = 1,
|
|
||||||
BRIDGE = 2,
|
|
||||||
FAN = 3,
|
|
||||||
GARAGE_DOOR_OPENER = 4,
|
|
||||||
LIGHTBULB = 5,
|
|
||||||
DOOR_LOCK = 6,
|
|
||||||
OUTLET = 7,
|
|
||||||
SWITCH = 8,
|
|
||||||
THERMOSTAT = 9,
|
|
||||||
SENSOR = 10,
|
|
||||||
ALARM_SYSTEM = 11,
|
|
||||||
SECURITY_SYSTEM = 11,
|
|
||||||
DOOR = 12,
|
|
||||||
WINDOW = 13,
|
|
||||||
WINDOW_COVERING = 14,
|
|
||||||
PROGRAMMABLE_SWITCH = 15,
|
|
||||||
RANGE_EXTENDER = 16,
|
|
||||||
CAMERA = 17,
|
|
||||||
IP_CAMERA = 17,
|
|
||||||
VIDEO_DOORBELL = 18,
|
|
||||||
AIR_PURIFIER = 19,
|
|
||||||
AIR_HEATER = 20,
|
|
||||||
AIR_CONDITIONER = 21,
|
|
||||||
AIR_HUMIDIFIER = 22,
|
|
||||||
AIR_DEHUMIDIFIER = 23,
|
|
||||||
APPLE_TV = 24,
|
|
||||||
SPEAKER = 26,
|
|
||||||
AIRPORT = 27,
|
|
||||||
SPRINKLER = 28,
|
|
||||||
FAUCET = 29,
|
|
||||||
SHOWER_HEAD = 30,
|
|
||||||
TELEVISION = 31,
|
|
||||||
TARGET_CONTROLLER = 32
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
export interface HAPNodeJS {
|
|
||||||
init(storagePath?: string): void,
|
|
||||||
uuid: uuid,
|
|
||||||
Accessory: Accessory,
|
|
||||||
Service: Service,
|
|
||||||
Characteristic: Characteristic
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
declare var hapNodeJS: HAPNodeJS.HAPNodeJS;
|
|
||||||
|
|
||||||
declare module "hap-nodejs" {
|
|
||||||
export = hapNodeJS;
|
|
||||||
}
|
|
||||||
@ -1,30 +1,32 @@
|
|||||||
|
|
||||||
/**
|
/**
|
||||||
* Helper function to convert callbacks into promises
|
* Helper function to convert callbacks into promises
|
||||||
* @param func
|
* @param func
|
||||||
*/
|
*/
|
||||||
export default function callbackify(func: (...args: any[]) => Promise<any>): Function {
|
|
||||||
return (...args: any[]) => {
|
|
||||||
const onlyArgs: any[] = [];
|
|
||||||
let maybeCallback: Function | null = null;
|
|
||||||
|
|
||||||
for (const arg of args) {
|
export default function callbackify(
|
||||||
if (typeof arg === 'function') {
|
func: (...args: any[]) => Promise<any>
|
||||||
maybeCallback = arg;
|
): Function {
|
||||||
break;
|
return (...args: any[]) => {
|
||||||
}
|
const onlyArgs: any[] = [];
|
||||||
|
let maybeCallback: Function | null = null;
|
||||||
|
|
||||||
onlyArgs.push(arg);
|
for (const arg of args) {
|
||||||
}
|
if (typeof arg === "function") {
|
||||||
|
maybeCallback = arg;
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
|
||||||
if (!maybeCallback) {
|
onlyArgs.push(arg);
|
||||||
throw new Error("Missing callback parameter!");
|
|
||||||
}
|
|
||||||
|
|
||||||
const callback = maybeCallback;
|
|
||||||
|
|
||||||
func(...onlyArgs)
|
|
||||||
.then((data: any) => callback(null, data))
|
|
||||||
.catch((err: any) => callback(err))
|
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
if (!maybeCallback) {
|
||||||
|
throw new Error("Missing callback parameter!");
|
||||||
|
}
|
||||||
|
|
||||||
|
const callback = maybeCallback;
|
||||||
|
|
||||||
|
func(...onlyArgs)
|
||||||
|
.then((data: any) => callback(null, data))
|
||||||
|
.catch((err: any) => callback(err));
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|||||||
2
src/Util/index.ts
Normal file
2
src/Util/index.ts
Normal file
@ -0,0 +1,2 @@
|
|||||||
|
export * from "./Callbackify";
|
||||||
|
export * from "./Sleep";
|
||||||
123
src/index.ts
123
src/index.ts
@ -1,122 +1,11 @@
|
|||||||
import * as Accessories from "./Accessories";
|
import { API } from "homebridge";
|
||||||
import HarmonyDataProvider from "./DataProviders/HarmonyDataProvider";
|
|
||||||
import * as Config from "./Models/Config";
|
|
||||||
import { IDevice } from "./Models";
|
|
||||||
import { HarmonyDevice } from "./Models/HarmonyDevice";
|
|
||||||
import { HarmonyHub } from "./Models/HarmonyHub";
|
|
||||||
|
|
||||||
let Accessory: any;
|
import { PLATFORM_NAME } from "./settings";
|
||||||
let Homebridge: any;
|
import { Platform } from "./platform";
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Main entry.
|
* This method registers the platform with Homebridge
|
||||||
* @param homebridge
|
|
||||||
*/
|
*/
|
||||||
export default function (homebridge: any) {
|
export = (api: API) => {
|
||||||
Homebridge = homebridge;
|
api.registerPlatform(PLATFORM_NAME, Platform);
|
||||||
Accessory = homebridge.platformAccessory;
|
|
||||||
homebridge.registerPlatform(
|
|
||||||
'homebridge-harmony-watson',
|
|
||||||
'HarmonyHubMatrix',
|
|
||||||
HarmonyMatrixPlatform,
|
|
||||||
true
|
|
||||||
);
|
|
||||||
};
|
};
|
||||||
|
|
||||||
class HarmonyMatrixPlatform {
|
|
||||||
log: any = {};
|
|
||||||
config: Config.IConfig;
|
|
||||||
api: any;
|
|
||||||
dataProvider: HarmonyDataProvider | null;
|
|
||||||
accessoryList: Array<Accessories.IAccessory> = [];
|
|
||||||
|
|
||||||
constructor(log: any, config: any, api: any) {
|
|
||||||
this.log = log;
|
|
||||||
this.config = config;
|
|
||||||
this.api = api;
|
|
||||||
this.log('INFO - Registering Harmony Matrix Platform');
|
|
||||||
this.api.on('didFinishLaunching', this.didFinishLaunching.bind(this));
|
|
||||||
|
|
||||||
this.dataProvider = null;
|
|
||||||
|
|
||||||
if (this.config) {
|
|
||||||
//construct data provider
|
|
||||||
this.dataProvider = new HarmonyDataProvider({
|
|
||||||
hubs: this.config.Hubs,
|
|
||||||
deviceConfigs: this.config.Devices,
|
|
||||||
matrix: this.config.Matrix,
|
|
||||||
log: this.log
|
|
||||||
});
|
|
||||||
|
|
||||||
//Emit devices if requested
|
|
||||||
|
|
||||||
this.dataProvider.on("Ready", () => {
|
|
||||||
this.log("All hubs connected");
|
|
||||||
if (this.config.EmitDevicesOnStartup) {
|
|
||||||
const hubs = this.dataProvider!.hubs;
|
|
||||||
Object.values(hubs).forEach((hub: HarmonyHub) => {
|
|
||||||
const deviceDictionary = hub.devices;
|
|
||||||
this.log(`${hub.hubName}`)
|
|
||||||
|
|
||||||
Object.values(deviceDictionary).forEach((device: HarmonyDevice) => {
|
|
||||||
this.log(` ${device.name} : ${device.id}`);
|
|
||||||
Object.keys(device.commands).forEach((command: string) => {
|
|
||||||
this.log(` ${command}`);
|
|
||||||
});
|
|
||||||
});
|
|
||||||
});
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Handler for didFinishLaunching
|
|
||||||
* Happens after constructor
|
|
||||||
*/
|
|
||||||
didFinishLaunching() {
|
|
||||||
this.log(`Publishing external accessories`);
|
|
||||||
|
|
||||||
//This is required in order to have multiple tv remotes on one platform
|
|
||||||
this.accessoryList.forEach((accessory: Accessories.IAccessory) => {
|
|
||||||
if (accessory instanceof Accessories.ControlUnit) {
|
|
||||||
this.api.publishExternalAccessories("HarmonyMatrixPlatform", [accessory.platformAccessory]);
|
|
||||||
}
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Called by homebridge to gather accessories.
|
|
||||||
* @param callback
|
|
||||||
*/
|
|
||||||
accessories(callback: (accessories: Array<Accessories.IAccessory>) => void) {
|
|
||||||
|
|
||||||
//Add control units
|
|
||||||
this.config.ControlUnits.forEach((unit: Config.IControlUnit) => {
|
|
||||||
this.accessoryList.push(new Accessories.ControlUnit({
|
|
||||||
dataProvider: this.dataProvider!,
|
|
||||||
displayName: unit.DisplayName,
|
|
||||||
api: this.api,
|
|
||||||
log: this.log,
|
|
||||||
activities: unit.Activities,
|
|
||||||
homebridge: Homebridge,
|
|
||||||
}));
|
|
||||||
});
|
|
||||||
|
|
||||||
//Add device buttons
|
|
||||||
this.config.DeviceButtons.forEach((button: Config.IDeviceButton) => {
|
|
||||||
this.accessoryList.push(new Accessories.DeviceButton({
|
|
||||||
dataProvider: this.dataProvider!,
|
|
||||||
buttonName: button.ButtonName,
|
|
||||||
displayName: button.DisplayName,
|
|
||||||
deviceInfo: button,
|
|
||||||
api: this.api,
|
|
||||||
log: this.log,
|
|
||||||
homebridge: Homebridge,
|
|
||||||
|
|
||||||
}))
|
|
||||||
});
|
|
||||||
callback(this.accessoryList);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
144
src/platform.ts
Normal file
144
src/platform.ts
Normal file
@ -0,0 +1,144 @@
|
|||||||
|
import {
|
||||||
|
API,
|
||||||
|
Characteristic,
|
||||||
|
DynamicPlatformPlugin,
|
||||||
|
Logger,
|
||||||
|
PlatformAccessory,
|
||||||
|
PlatformConfig,
|
||||||
|
Service,
|
||||||
|
} from "homebridge";
|
||||||
|
import { ControlUnit, DeviceButton } from "./Accessories";
|
||||||
|
import HarmonyDataProvider from "./DataProviders/HarmonyDataProvider";
|
||||||
|
import { IConfig, IControlUnit, IDeviceButton } from "./Models/Config";
|
||||||
|
import { HarmonyDevice } from "./Models/HarmonyDevice";
|
||||||
|
import { HarmonyHub } from "./Models/HarmonyHub";
|
||||||
|
import { PLATFORM_NAME, PLUGIN_NAME } from "./settings";
|
||||||
|
|
||||||
|
export class Platform implements DynamicPlatformPlugin {
|
||||||
|
constructor(
|
||||||
|
public readonly log: Logger,
|
||||||
|
config: PlatformConfig,
|
||||||
|
public readonly api: API
|
||||||
|
) {
|
||||||
|
this.log.debug("Finished initializing platform:", config.name);
|
||||||
|
|
||||||
|
this.config = (config as unknown) as IConfig;
|
||||||
|
//construct data provider
|
||||||
|
const dataProvider = new HarmonyDataProvider({
|
||||||
|
hubs: this.config.Hubs,
|
||||||
|
deviceConfigs: this.config.Devices,
|
||||||
|
matrix: this.config.Matrix,
|
||||||
|
log: this.log,
|
||||||
|
});
|
||||||
|
|
||||||
|
this.api.on("didFinishLaunching", async () => {
|
||||||
|
log.debug("Executed didFinishLaunching callback");
|
||||||
|
this.discoverDevices(dataProvider);
|
||||||
|
});
|
||||||
|
|
||||||
|
this.dataProvider = null;
|
||||||
|
|
||||||
|
if (this.config) {
|
||||||
|
//construct data provider
|
||||||
|
this.dataProvider = new HarmonyDataProvider({
|
||||||
|
hubs: this.config.Hubs,
|
||||||
|
deviceConfigs: this.config.Devices,
|
||||||
|
matrix: this.config.Matrix,
|
||||||
|
log: this.log,
|
||||||
|
});
|
||||||
|
|
||||||
|
//Emit devices if requested
|
||||||
|
|
||||||
|
this.dataProvider.on("Ready", () => {
|
||||||
|
this.log.info("All hubs connected");
|
||||||
|
if (this.config.EmitDevicesOnStartup) {
|
||||||
|
const hubs = this.dataProvider!.hubs;
|
||||||
|
Object.values(hubs).forEach((hub: HarmonyHub) => {
|
||||||
|
const deviceDictionary = hub.devices;
|
||||||
|
this.log.info(`${hub.hubName}`);
|
||||||
|
|
||||||
|
Object.values(deviceDictionary).forEach((device: HarmonyDevice) => {
|
||||||
|
this.log.info(` ${device.name} : ${device.id}`);
|
||||||
|
Object.keys(device.commands).forEach((command: string) => {
|
||||||
|
this.log.info(` ${command}`);
|
||||||
|
});
|
||||||
|
});
|
||||||
|
});
|
||||||
|
}
|
||||||
|
});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public readonly Service: typeof Service = this.api.hap.Service;
|
||||||
|
public readonly Characteristic: typeof Characteristic = this.api.hap
|
||||||
|
.Characteristic;
|
||||||
|
|
||||||
|
// this is used to track restored cached accessories
|
||||||
|
public readonly accessories: PlatformAccessory[] = [];
|
||||||
|
public config: IConfig;
|
||||||
|
public dataProvider: HarmonyDataProvider | null;
|
||||||
|
|
||||||
|
public discoverDevices(dataProvider: HarmonyDataProvider) {
|
||||||
|
this.config.ControlUnits.forEach((unit: IControlUnit) => {
|
||||||
|
const uuid = this.api.hap.uuid.generate(unit.DisplayName);
|
||||||
|
const existingAccessory = this.accessories.find((e) => e.UUID === uuid);
|
||||||
|
if (existingAccessory) {
|
||||||
|
this.log.info(
|
||||||
|
"Restoring existing accessory from cache: " +
|
||||||
|
existingAccessory.displayName
|
||||||
|
);
|
||||||
|
|
||||||
|
new ControlUnit(this, existingAccessory, dataProvider, unit.Activities);
|
||||||
|
|
||||||
|
this.api.publishExternalAccessories(PLUGIN_NAME, [existingAccessory]);
|
||||||
|
console.log("Publishing external accessory: " + uuid);
|
||||||
|
} else {
|
||||||
|
this.log.info("Adding new accessory: " + unit.DisplayName);
|
||||||
|
const accessory = new this.api.platformAccessory(
|
||||||
|
unit.DisplayName,
|
||||||
|
uuid
|
||||||
|
);
|
||||||
|
accessory.context["DeviceName"] = unit.DisplayName;
|
||||||
|
|
||||||
|
new ControlUnit(this, accessory, dataProvider, unit.Activities);
|
||||||
|
|
||||||
|
this.api.publishExternalAccessories(PLUGIN_NAME, [accessory]);
|
||||||
|
console.log("Publishing external accessory: " + uuid);
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
this.config.DeviceButtons.forEach((button: IDeviceButton) => {
|
||||||
|
const uuid = this.api.hap.uuid.generate(button.DisplayName);
|
||||||
|
const existingAccessory = this.accessories.find((e) => e.UUID === uuid);
|
||||||
|
if (existingAccessory) {
|
||||||
|
this.log.info(
|
||||||
|
"Restoring existing accessory from cache: " +
|
||||||
|
existingAccessory.displayName
|
||||||
|
);
|
||||||
|
|
||||||
|
new DeviceButton(this, existingAccessory, dataProvider, button);
|
||||||
|
this.api.updatePlatformAccessories([existingAccessory]);
|
||||||
|
} else {
|
||||||
|
this.log.info("Adding new accessory: " + button.DisplayName);
|
||||||
|
const accessory = new this.api.platformAccessory(
|
||||||
|
button.DisplayName,
|
||||||
|
uuid
|
||||||
|
);
|
||||||
|
accessory.context["DeviceName"] = button.DisplayName;
|
||||||
|
|
||||||
|
new DeviceButton(this, accessory, dataProvider, button);
|
||||||
|
|
||||||
|
this.api.registerPlatformAccessories(PLUGIN_NAME, PLATFORM_NAME, [
|
||||||
|
accessory,
|
||||||
|
]);
|
||||||
|
}
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
configureAccessory(accessory: PlatformAccessory<Record<string, any>>): void {
|
||||||
|
this.log.info("Loading accessory from cache:", accessory.displayName);
|
||||||
|
|
||||||
|
// add the restored accessory to the accessories cache so we can track if it has already been registered
|
||||||
|
this.accessories.push(accessory);
|
||||||
|
}
|
||||||
|
}
|
||||||
9
src/settings.ts
Normal file
9
src/settings.ts
Normal file
@ -0,0 +1,9 @@
|
|||||||
|
/**
|
||||||
|
* This is the name of the platform that users will use to register the plugin in the Homebridge config.json
|
||||||
|
*/
|
||||||
|
export const PLATFORM_NAME = "HarmonyHubMatrix";
|
||||||
|
|
||||||
|
/**
|
||||||
|
* This must match the name of your plugin as defined the package.json
|
||||||
|
*/
|
||||||
|
export const PLUGIN_NAME = "homebridge-harmony-control";
|
||||||
@ -1,17 +1,13 @@
|
|||||||
{
|
{
|
||||||
"compilerOptions": {
|
"compilerOptions": {
|
||||||
"target": "es6",
|
"target": "es6",
|
||||||
"module": "commonjs",
|
"module": "commonjs",
|
||||||
"declaration": true,
|
"declaration": true,
|
||||||
"outDir": "./bin",
|
"outDir": "./bin",
|
||||||
"strict": true,
|
"strict": true,
|
||||||
"sourceMap": true,
|
"sourceMap": true,
|
||||||
},
|
"skipLibCheck": true
|
||||||
"include": [
|
},
|
||||||
"src"
|
"include": ["src"],
|
||||||
],
|
"exclude": ["**/node_modules", "**/__tests__/*"]
|
||||||
"exclude": [
|
}
|
||||||
"node_modules",
|
|
||||||
"**/__tests__/*"
|
|
||||||
]
|
|
||||||
}
|
|
||||||
|
|||||||
Reference in New Issue
Block a user