Function syncEmail

apps/web/services/accounts/sync.ts:83–133

({
  status,
  accountId,
  pathDomain,
}: {
  status: SyncStatus;
  accountId: string;
  pathDomain: string | null;
})

}

async function syncEmail({
  status,
  accountId,
  pathDomain,
}: {
  status: SyncStatus;
  accountId: string;
  pathDomain: string | null;
}) {
  try {
    const account = await prisma.accounts.findUnique({
      where: { id: accountId },
    });
    if (account) {
      const admins = await prisma.users.findMany({
        where: {
          role: { in: [Roles.ADMIN, Roles.OWNER] },
          accountsId: account.id,
        },
        include: {
          auth: true,
        },
      });
      if (admins.length > 0) {
        await Promise.all(
          admins.map(async (admin) => {
            const email = admin.auth?.email;
            if (!email) {
              return Promise.resolve();
            }
            if (status === SyncStatus.IN_PROGRESS) {
              return SyncMailer.start({ to: email });
            }
            if (status === SyncStatus.DONE) {
              return SyncMailer.end({
                to: email,
                url: `https://www.linen.dev/s/${pathDomain}`,
              });
            }
            if (status === SyncStatus.ERROR) {
              return SyncMailer.error({ to: email });
            }
            return Promise.resolve();
          })
        );
      }
    }
  } catch (exception) {
    console.error('Failed to send sync emails: ', exception);
  }
}

function identifySyncType(
  account: