Function createPasscodeLibrary

packages/core/src/libraries/passcode.ts:52–230

(queries: Queries, connectorLibrary: ConnectorLibrary)

};

export const createPasscodeLibrary = (queries: Queries, connectorLibrary: ConnectorLibrary) => {
  const {
    consumePasscode,
    deletePasscodesByIds,
    findUnconsumedPasscodeByJtiAndType,
    findUnconsumedPasscodesByJtiAndType,
    findUnconsumedPasscodeByIdentifierAndType,
    findUnconsumedPasscodesByIdentifierAndType,
    increasePasscodeTryCount,
    insertPasscode,
  } = queries.passcodes;
  const { getMessageConnector } = connectorLibrary;

  const createPasscode = async (
    jti: string | undefined,
    type: TemplateType,
    payload: { phone: string } | { email: string }
  ) => {
    // Disable existing passcodes.
    const passcodes = jti
      ? // Session based flows. E.g. SignIn, Register, etc.
        await findUnconsumedPasscodesByJtiAndType(jti, type)
      : // Generic flow. E.g. Triggered by management API
        await findUnconsumedPasscodesByIdentifierAndType({ type, ...payload });

    if (passcodes.length > 0) {
      await deletePasscodesByIds(passcodes.map(({ id }) => id));
    }

    return insertPasscode({
      id: nanoid(),
      interactionJti: jti,
      type,
      code: randomCode(),
      ...payload,
    });
  };

  /**
   *
   * @param {Passcode} passcode The passcode object being sent.
   * @param {SendPasscodeContextPayload} contextPayload The extra context information for the verification code email template.
   */
  const sendPasscode = async (passcode: Passcode, contextPayload?: SendPasscodeContextPayload) => {
    const emailOrPhone = passcode.email ?? passcode.phone;

    if (!emailOrPhone) {
      throw new RequestError('verification_code.phone_email_empty');
    }

    const templateType = resolveTemplateType(passcode.type);
    const expectType = passcode.phone ? ConnectorType.Sms : ConnectorType.Email;
    const connector = await getMessageConnector(expectType);
    const { dbEntry, metadata, sendMessage } = connector;

    const { ip, ...payloadContext } = contextPayload ?? {};

    const response = await sendMessage({