Function buildFixture

apps/api/tests/queues/queue-manager.test.ts:110–152

(withWebPush: boolean)

};

const buildFixture = (withWebPush: boolean) => {
  const accountMaintenance = makeQueueStub("account-maintenance");
  const emailDelivery = makeQueueStub<IEmailDeliveryJobData>("email-delivery", {
    waiting: 2,
    failed: 1,
  });
  const notificationDispatch = makeQueueStub<INotificationDispatchJobData>(
    "notification-dispatch"
  );
  const notificationMaintenance = makeQueueStub("notification-maintenance");
  const webPushDelivery =
    makeQueueStub<IWebPushDeliveryJobData>("web-push-delivery");
  const workers = {
    accountMaintenance: makeWorkerStub(),
    emailDelivery: makeWorkerStub(),
    notificationDispatch: makeWorkerStub(),
    notificationMaintenance: makeWorkerStub(),
    webPushDelivery: makeWorkerStub(),
  };

  const manager = new QueueManager({
    accountMaintenanceQueue: accountMaintenance.stub,
    accountMaintenanceWorker: workers.accountMaintenance.stub,
    emailDeliveryQueue: emailDelivery.stub,
    emailDeliveryWorker: workers.emailDelivery.stub,
    notificationDispatchQueue: notificationDispatch.stub,
    notificationDispatchWorker: workers.notificationDispatch.stub,
    notificationMaintenanceQueue: notificationMaintenance.stub,
    notificationMaintenanceWorker: workers.notificationMaintenance.stub,
    webPushDeliveryQueue: withWebPush ? webPushDelivery.stub : null,
    webPushDeliveryWorker: withWebPush ? workers.webPushDelivery.stub : null,
  });

  return {
    manager,
    accountMaintenance,
    emailDelivery,
    notificationDispatch,
    notificationMaintenance,
    webPushDelivery,
    workers,
  };
};

describe("QueueManager.enqueueEmailDelivery", () => {
  test("adds the job with the retry envelope from the queue defaults", async () => {