Awaiting asynchronous operations

1
const stopped = await runOperation(
2
  operationUuid => startPlayback(sessionUuid, {
3
    operation_uuid: operationUuid,
4
    type: 'files',
5
    urls: ['https://example.com/welcome.mp3'],
6
  }),
7
  {
8
    resolveOn: ['playback.stopped'],
9
    rejectOn: ['playback.failed'],
10
  },
11
);

1
const crypto = require('node:crypto');
2
const { EventEmitter } = require('node:events');
3
4
const events = new EventEmitter();
5
6
function runOperation(
7
  sendCommand,
8
  { resolveOn, rejectOn, timeoutMs = 30_000 },
9
) {
10
  const operationUuid = crypto.randomUUID();
11
12
  return new Promise((resolve, reject) => {
13
    const finish = (callback, value) => {
14
      clearTimeout(timeout);
15
      events.off(operationUuid, onEvent);
16
      callback(value);
17
    };
18
19
    const onEvent = event => {
20
      if (resolveOn.includes(event.event)) finish(resolve, event);
21
      if (rejectOn.includes(event.event)) finish(reject, event);
22
    };
23
24
    events.on(operationUuid, onEvent);
25
26
    const timeout = setTimeout(
27
      () => finish(reject, new Error('Operation timed out')),
28
      timeoutMs,
29
    );
30
31
    void (async () => {
32
      try {
33
        await sendCommand(operationUuid);
34
      } catch (error) {
35
        finish(reject, error);
36
      }
37
    })();
38
  });
39
}
40
41
function handleOperationEvent(event) {
42
  if (event.operation_uuid) {
43
    events.emit(event.operation_uuid, event);
44
  }
45
}