-
Notifications
You must be signed in to change notification settings - Fork 3
Expand file tree
/
Copy pathnode-risco-client.js
More file actions
92 lines (77 loc) · 3.21 KB
/
node-risco-client.js
File metadata and controls
92 lines (77 loc) · 3.21 KB
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
const riscoClient = require('./lib')
module.exports = (config) => {
const ARMED = 3
const DISARMED = 1
const PARTIALLY_ARMED = 2
let accessToken, sessionId, siteId, logged
let { username, password, pin, languageId } = config
if (!username) throw new Error('username options is required')
if (!password) throw new Error('password options is required')
if (!pin) throw new Error('pin options is required')
if (!languageId) throw new Error('languageId options is required')
const _login = async () => {
({ accessToken, sessionId, siteId } = await riscoClient.login(username, password, pin, languageId))
logged = true
return Promise.resolve({ accessToken, sessionId, siteId })
}
const _setAlarmState = async (state, partitionId) => {
if (!logged) await _login()
return riscoClient.setAlarm(accessToken, sessionId, siteId, state, partitionId).catch(error => {
if (error.statusCode === 401) {
console.log('refreshing login due to session expired or invalid token during setting alarm state')
logged = false;
return _setAlarmState(state, partitionId)
}
throw new Error(error)
})
}
const getPartitions = async () => {
if (!logged) await _login()
return riscoClient.getState(accessToken, sessionId, siteId).then(result => {
return Promise.resolve(result.partitions)
}).catch(error => {
if (error.statusCode === 401) {
console.log('refreshing login due to session expired or invalid token retrieving partitions')
logged = false
return getPartitions()
}
throw new Error(error)
})
}
const getZones = async () => {
if (!logged) await _login()
return riscoClient.getState(accessToken, sessionId, siteId).then(result => {
return Promise.resolve(result.zones)
}).catch(error => {
if (error.statusCode === 401) {
console.log('refreshing login due to session expired or invalid token retrieving zones')
logged = false;
return getZones()
}
throw new Error(error)
})
}
const getEvents = async (newerThan, count) => {
if (!logged) await _login()
return riscoClient.getEvents(accessToken, sessionId, siteId, newerThan, count).then(result => {
return Promise.resolve(result.events)
}).catch(error => {
if (error.statusCode === 401) {
console.log('refreshing login due to session expired or invalid token retrieving events')
logged = false;
return getEvents(newerThan, count)
}
throw new Error(error)
})
}
const disarm = async (partitionId) => {
return _setAlarmState(DISARMED, partitionId)
}
const arm = async (partitionId) => {
return _setAlarmState(ARMED, partitionId)
}
const partiallyArm = async (partitionId) => {
return _setAlarmState(PARTIALLY_ARMED, partitionId)
}
return { getPartitions, getZones, getEvents, disarm, arm, partiallyArm }
}