forked from dhutchison/homebridge-ebeco
-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathplatform.ts
147 lines (118 loc) · 6.24 KB
/
platform.ts
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
import { API, DynamicPlatformPlugin, Logger, PlatformAccessory, Service, Characteristic } from 'homebridge';
import { EbecoApi } from './lib/ebecoApi';
import { EbecoPlatformConfig, PLATFORM_NAME, PLUGIN_NAME } from './settings';
import { EbecoPlatformAccessory } from './platformAccessory';
/**
* HomebridgePlatform
* This class is the main constructor for your plugin, this is where you should
* parse the user config and discover/register accessories with Homebridge.
*/
export class EbecoHomebridgePlatform implements DynamicPlatformPlugin {
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[] = [];
constructor(
public readonly log: Logger,
public readonly config: EbecoPlatformConfig,
public readonly api: API,
) {
/* Validate the configuration */
if (!this.config.username || !this.config.password) {
this.log.warn('username & password not found in config');
throw new Error('Not all required configuration values found. Need "username" and "password".');
}
this.log.debug('Finished initializing platform:', this.config.name);
// When this event is fired it means Homebridge has restored all cached accessories from disk.
// Dynamic Platform plugins should only register new accessories after this event was fired,
// in order to ensure they weren't added to homebridge already. This event can also be used
// to start discovery of new accessories.
this.api.on('didFinishLaunching', () => {
log.debug('Executed didFinishLaunching callback');
/* Perform an initial login */
const apiClient = new EbecoApi(this, this.log, this.config);
apiClient.login()
.then(loginResponse => {
this.log.debug('Login: %o', loginResponse);
this.log.info('Logged in to Ebeco API. Token valid for %s seconds', loginResponse.expireInSeconds);
// run the method to discover / register your devices as accessories
this.discoverDevices();
})
.catch(err => {
this.log.error('Login failed %s', err);
});
});
}
/**
* This function is invoked when homebridge restores cached accessories from disk at startup.
* It should be used to setup event handlers for characteristics and update respective values.
*/
configureAccessory(accessory: PlatformAccessory) {
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);
}
/**
* This is an example method showing how to register discovered accessories.
* Accessories must only be registered once, previously created accessories
* must not be registered again to prevent "duplicate UUID" errors.
*/
discoverDevices() {
/* Load devices */
const apiClient = new EbecoApi(this, this.log, this.config);
apiClient.getUserDevices()
.then(devices => {
this.log.debug('Devices: %o', devices);
this.log.info('Discovered %s devices', devices.length);
/* loop over the discovered devices and register each one if it has not already been registered */
for (const device of devices) {
this.log.info('Device id %s has name %s', device.id, device.displayName);
/* Generate a unique id for the accessory this should be generated from
* something globally unique, but constant, for example, the device serial
* number or MAC address
*/
const uuid = this.api.hap.uuid.generate(device.id.toString());
/* See if an accessory with the same uuid has already been registered and restored from
* the cached devices we stored in the `configureAccessory` method above
*/
const existingAccessory = this.accessories.find(accessory => accessory.UUID === uuid);
if (existingAccessory) {
/* the accessory already exists */
if (device) {
this.log.info('Restoring existing accessory from cache:', existingAccessory.displayName);
/* Update the accessory with the new initial state */
existingAccessory.context.device = device;
this.api.updatePlatformAccessories([existingAccessory]);
// create the accessory handler for the restored accessory
// this is imported from `platformAccessory.ts`
new EbecoPlatformAccessory(this, existingAccessory);
// update accessory cache with any changes to the accessory details and information
this.api.updatePlatformAccessories([existingAccessory]);
} else if (!device) {
//TODO: Handle this correctly, wrong place
// it is possible to remove platform accessories at any time using `api.unregisterPlatformAccessories`, eg.:
// remove platform accessories when no longer present
this.api.unregisterPlatformAccessories(PLUGIN_NAME, PLATFORM_NAME, [existingAccessory]);
this.log.info('Removing existing accessory from cache:', existingAccessory.displayName);
}
} else {
// the accessory does not yet exist, so we need to create it
this.log.info('Adding new accessory:', device.displayName);
// create a new accessory
const accessory = new this.api.platformAccessory(device.displayName, uuid);
// store a copy of the device object in the `accessory.context`
// the `context` property can be used to store any data about the accessory you may need
accessory.context.device = device;
// create the accessory handler for the newly create accessory
// this is imported from `platformAccessory.ts`
new EbecoPlatformAccessory(this, accessory);
// link the accessory to your platform
this.api.registerPlatformAccessories(PLUGIN_NAME, PLATFORM_NAME, [accessory]);
}
}
})
.catch(err => {
this.log.error('Devices error: %s', err);
});
}
}