Integrating with newer test waiters system about ember-orbit

[dgeb]

@ef4 Each of these queues is an Orbit TaskQueue. When the queues are empty they emit a complete event, which you can listen for:

currentSource.requestQueue.on('complete', () => { 
  // optionally return a promise here if you want to delay future actions of the queue until the promise resolves or errors
});

Remember to cleanup with off.

[ef4]

Thanks. Is there a corresponding event for going from empty to active?

[dgeb]

beforeTask is emitted before each task in the queue is processed. I think this is most like an "active" indicator.

Another event to be aware of is change which is emitted whenever the contents of the queue change, but this may happen when the queue is complete or processing has paused and its contents are changed.

[ef4]

Thanks, that set me on the right track. I ended up going with beforeTask for start and task or fail for end. Here is a utility that may help others (and could potentially go into ember-orbit):

import { buildWaiter } from '@ember/test-waiters';

export function buildOrbitWaiter(label) {
  let waiter = buildWaiter(label);

  const taskTokens = new WeakMap();

  function taskStarted(task) {
    let token = waiter.beginAsync();
    taskTokens.set(task, token);
  }
  function taskEnded(task) {
    let token = taskTokens.get(task);
    if (token) {
      waiter.endAsync(token);
    }
  }

  function waitForSource(source) {
    source.requestQueue.on('beforeTask', taskStarted);
    source.requestQueue.on('task', taskEnded);
    source.requestQueue.on('fail', taskEnded);
    source.syncQueue.on('beforeTask', taskStarted);
    source.syncQueue.on('task', taskEnded);
    source.syncQueue.on('fail', taskEnded);
    return source;
  }

  return { waitForSource };
}

You use it like:

import JSONAPISource from '@orbit/jsonapi';
import { buildOrbitWaiter } from '../lib/orbit-waiter';

let { waitForSource } = buildOrbitWaiter('data-source:rails');

export default {
  create(injections = {}) {
    return waitForSource(new JSONAPISource(injections));
  }
}

[dgeb]

Looks good @ef4 - thanks for sharing! I've opened tracking issue #341 to ensure that we add your work, or something similar, to ember-orbit soon.