infisical/backend/src/services/secret-reminder-recipients/secret-reminder-recipients-dal.ts

import { Knex } from "knex";

import { TDbClient } from "@app/db";
import { TableName } from "@app/db/schemas";
import { ormify, selectAllTableCols } from "@app/lib/knex";

export type TSecretReminderRecipientsDALFactory = ReturnType<typeof secretReminderRecipientsDALFactory>;

export const secretReminderRecipientsDALFactory = (db: TDbClient) => {
  const secretReminderRecipientsOrm = ormify(db, TableName.SecretReminderRecipients);

  const findUsersBySecretId = async (secretId: string, tx?: Knex) => {
    const res = await (tx || db.replicaNode())(TableName.SecretReminderRecipients)
      .where({ secretId })
      .leftJoin(TableName.Users, `${TableName.SecretReminderRecipients}.userId`, `${TableName.Users}.id`)
      .leftJoin(TableName.Project, `${TableName.SecretReminderRecipients}.projectId`, `${TableName.Project}.id`)
      .leftJoin(TableName.OrgMembership, (bd) => {
        void bd
          .on(`${TableName.OrgMembership}.userId`, "=", `${TableName.SecretReminderRecipients}.userId`)
          .andOn(`${TableName.OrgMembership}.orgId`, "=", `${TableName.Project}.orgId`);
      })

      .where(`${TableName.OrgMembership}.isActive`, true)
      .select(selectAllTableCols(TableName.SecretReminderRecipients))
      .select(
        db.ref("email").withSchema(TableName.Users).as("email"),
        db.ref("username").withSchema(TableName.Users).as("username"),
        db.ref("firstName").withSchema(TableName.Users).as("firstName"),
        db.ref("lastName").withSchema(TableName.Users).as("lastName")
      );

    return res;
  };

  return { ...secretReminderRecipientsOrm, findUsersBySecretId };
};