1 | 'use strict';
|
2 | const { fromEvent } = require('rxjs');
|
3 | const { filter, map, share, takeUntil } = require('rxjs/operators');
|
4 |
|
5 | function normalizeKeypressEvents(value, key) {
|
6 | return { value, key: key || {} };
|
7 | }
|
8 |
|
9 | module.exports = function (rl) {
|
10 | const keypress = fromEvent(rl.input, 'keypress', normalizeKeypressEvents)
|
11 | .pipe(takeUntil(fromEvent(rl, 'close')))
|
12 |
|
13 | .pipe(filter(({ key }) => key.name !== 'enter' && key.name !== 'return'));
|
14 |
|
15 | return {
|
16 | line: fromEvent(rl, 'line'),
|
17 | keypress,
|
18 |
|
19 | normalizedUpKey: keypress.pipe(
|
20 | filter(
|
21 | ({ key }) =>
|
22 | key.name === 'up' || key.name === 'k' || (key.name === 'p' && key.ctrl)
|
23 | ),
|
24 | share()
|
25 | ),
|
26 |
|
27 | normalizedDownKey: keypress.pipe(
|
28 | filter(
|
29 | ({ key }) =>
|
30 | key.name === 'down' || key.name === 'j' || (key.name === 'n' && key.ctrl)
|
31 | ),
|
32 | share()
|
33 | ),
|
34 |
|
35 | numberKey: keypress.pipe(
|
36 | filter((e) => e.value && '123456789'.indexOf(e.value) >= 0),
|
37 | map((e) => Number(e.value)),
|
38 | share()
|
39 | ),
|
40 |
|
41 | spaceKey: keypress.pipe(
|
42 | filter(({ key }) => key && key.name === 'space'),
|
43 | share()
|
44 | ),
|
45 | aKey: keypress.pipe(
|
46 | filter(({ key }) => key && key.name === 'a'),
|
47 | share()
|
48 | ),
|
49 | iKey: keypress.pipe(
|
50 | filter(({ key }) => key && key.name === 'i'),
|
51 | share()
|
52 | ),
|
53 | };
|
54 | };
|