Method enqueue

src/Push/PushQueue.js:26–64

(body, where, config, auth, pushStatus)

  }

  enqueue(body, where, config, auth, pushStatus) {
    const limit = this.batchSize;

    where = applyDeviceTokenExists(where);

    // Order by objectId so no impact on the DB
    const order = 'objectId';
    return Promise.resolve()
      .then(() => {
        return rest.find(config, auth, '_Installation', where, {
          limit: 0,
          count: true,
        });
      })
      .then(({ results, count }) => {
        if (!results || count == 0) {
          return pushStatus.complete();
        }
        pushStatus.setRunning(Math.ceil(count / limit));
        let skip = 0;
        while (skip < count) {
          const query = {
            where,
            limit,
            skip,
            order,
          };

          const pushWorkItem = {
            body,
            query,
            pushStatus: { objectId: pushStatus.objectId },
            applicationId: config.applicationId,
          };
          this.parsePublisher.publish(this.channel, JSON.stringify(pushWorkItem));
          skip += limit;
        }
      });
  }
}