validation code saga marble test part 1

validation-code.saga.spec.ts

const generatePayload = (): SendValidationCodeCommandPayload => { 
  const user = {
    id: faker.random.uuid() as User["id"],
  } as UserInContext;

  return {
    user,
    code: faker.random.word(),
    channel: VALIDATION_CODE_CHANNEL.TEXT,
    reason: GenerateValidationCodeReason.PHONE_NUMBER_VERIFICATION,
  };
};

describe("validation code saga", () => {
  let testScheduler: TestScheduler;
  beforeEach(() => {
    testScheduler = new TestScheduler((actual, expected) => expect(actual).toStrictEqual(expected));
  });

  it("throttle events for one user in 5 second frames", () => {
    const payload = generatePayload();

    testScheduler.run(({ hot, expectObservable }) => {
      const events$ = hot("-vv-v- 5s -vv-|", {
        v: new ValidationCodeGeneratedEvent(payload),
      });

      const saga = new ValidationCodeSagas();
      const output$ = saga.ValidationCodeRequested(events$);

      expectObservable(output$).toBe("-s---- 5s -s--|", {
        s: new SendValidationCodeCommand(payload),
      });
    });
  });
});