|
|
|
@ -4,57 +4,17 @@ import logger from 'logger' |
|
|
|
import { createCommand } from 'helpers/ipc' |
|
|
|
import { Observable } from 'rxjs' |
|
|
|
import CommNodeHid from '@ledgerhq/hw-transport-node-hid' |
|
|
|
import { DEVICE_DISCONNECT_DEBOUNCE, LISTEN_DEVICES_POLLING_INTERVAL } from 'config/constants' |
|
|
|
import { LISTEN_DEVICES_DEBOUNCE } from 'config/constants' |
|
|
|
|
|
|
|
CommNodeHid.setListenDevicesPollingInterval(LISTEN_DEVICES_POLLING_INTERVAL) |
|
|
|
CommNodeHid.setListenDevicesDebounce(LISTEN_DEVICES_DEBOUNCE) |
|
|
|
|
|
|
|
const cmd = createCommand('listenDevices', () => |
|
|
|
Observable.create(o => { |
|
|
|
const pendingRemovePerPath = {} |
|
|
|
const sub = CommNodeHid.listen({ |
|
|
|
next: e => { |
|
|
|
// debounce the add/remove in case we see quick `remove,add` events on same path.
|
|
|
|
switch (e.type) { |
|
|
|
case 'add': { |
|
|
|
const pendingRemove = pendingRemovePerPath[e.descriptor] |
|
|
|
if (pendingRemove) { |
|
|
|
logger.warn(`Skipping remove/add usb event for ${e.descriptor}`) |
|
|
|
// there where a recent "remove" event, we don't emit add because we didn't emit "remove" yet.
|
|
|
|
clearTimeout(pendingRemove) |
|
|
|
delete pendingRemovePerPath[e.descriptor] |
|
|
|
} else { |
|
|
|
// if there were no recent "remove", we just emit the "add"
|
|
|
|
o.next(e) |
|
|
|
} |
|
|
|
break |
|
|
|
} |
|
|
|
case 'remove': { |
|
|
|
// we we always debounce the "remove" event. emit it a bit later in case a "add" of same descriptor happen soon.
|
|
|
|
if (pendingRemovePerPath[e.descriptor]) { |
|
|
|
clearTimeout(pendingRemovePerPath[e.descriptor]) |
|
|
|
} |
|
|
|
pendingRemovePerPath[e.descriptor] = setTimeout(() => { |
|
|
|
delete pendingRemovePerPath[e.descriptor] |
|
|
|
o.next(e) |
|
|
|
}, DEVICE_DISCONNECT_DEBOUNCE) |
|
|
|
break |
|
|
|
} |
|
|
|
default: |
|
|
|
o.next(e) |
|
|
|
} |
|
|
|
}, |
|
|
|
complete: () => { |
|
|
|
o.complete() |
|
|
|
}, |
|
|
|
error: err => { |
|
|
|
o.error(err) |
|
|
|
}, |
|
|
|
}) |
|
|
|
return () => { |
|
|
|
Object.keys(pendingRemovePerPath).map(k => clearTimeout(pendingRemovePerPath[k])) |
|
|
|
sub.unsubscribe() |
|
|
|
} |
|
|
|
CommNodeHid.setListenDevicesDebug((msg, ...args) => |
|
|
|
logger.debug(msg, { |
|
|
|
type: 'listenDevices', |
|
|
|
args, |
|
|
|
}), |
|
|
|
) |
|
|
|
|
|
|
|
const cmd = createCommand('listenDevices', () => Observable.create(CommNodeHid.listen)) |
|
|
|
|
|
|
|
export default cmd |
|
|
|
|
Thibaut
7 years ago
GitHub