"csv-stringify": "^6.9.0",

        "jszip": "^3.10.2",

    "node_modules/core-util-is": {

      "version": "1.0.3",

      "resolved": "https://registry.npmjs.org/core-util-is/-/core-util-is-1.0.3.tgz",

      "integrity": "sha512-ZQBvi1DcpJ4GDqanjucZ2Hj3wEO5pZDS89BWbkcrvdxksJorwUDDZamX9ldFkp9aw2lmBDLgkObEA4DWNJ9FYQ==",

      "license": "MIT"

    },

      "license": "MIT"

    },

    "node_modules/csv-stringify": {

      "version": "6.9.0",

      "resolved": "https://registry.npmjs.org/csv-stringify/-/csv-stringify-6.9.0.tgz",

      "integrity": "sha512-6b3e29CILFfSQ2nDRuZMRROzQOpPuJ+s8zPB5H7eK5ncXBbFOyVuRLU5Sx/zAUmVri3Ly49GyC8NEme4SVSAbA==",

    "node_modules/immediate": {

      "version": "3.0.6",

      "resolved": "https://registry.npmjs.org/immediate/-/immediate-3.0.6.tgz",

      "integrity": "sha512-XXOFtyqDjNDAQxVfYxuF7g9Il/IbWmmlQg2MYKOH8ExIT1qg6xc4zyS3HaEEATgs1btfzxq15ciUiY7gjSXRGQ==",

      "license": "MIT"

    },

    "node_modules/isarray": {

      "version": "1.0.0",

      "resolved": "https://registry.npmjs.org/isarray/-/isarray-1.0.0.tgz",

      "integrity": "sha512-VLghIWNM6ELQzo7zwmcg0NmTVyWKYjvIeM83yjp0wRDTmUnrM678fQbcKBo6n2CJEF0szoG//ytg+TKla89ALQ==",

      "license": "MIT"

    },

    "node_modules/jszip": {

      "version": "3.10.2",

      "resolved": "https://registry.npmjs.org/jszip/-/jszip-3.10.2.tgz",

      "integrity": "sha512-3l+rb15IOWtUhU0H5MFqES/T6Kh7abYwjosBey/vD6hDt8zoEffkSC5Ws5SGtgVw3gBx2NEbhTeSW1+kWkpyTQ==",

      "license": "(MIT OR GPL-3.0-or-later)",

      "dependencies": {

        "lie": "~3.3.0",

        "pako": "~1.0.2",

        "readable-stream": "~2.3.6",

        "setimmediate": "^1.0.5"

      }

    },

    "node_modules/jszip/node_modules/readable-stream": {

      "version": "2.3.8",

      "resolved": "https://registry.npmjs.org/readable-stream/-/readable-stream-2.3.8.tgz",

      "integrity": "sha512-8p0AUk4XODgIewSi0l8Epjs+EVnWiK7NoDIEGU0HhE7+ZyY8D1IMY7odu5lRrFXGg71L15KG8QrPmum45RTtdA==",

      "license": "MIT",

      "dependencies": {

        "core-util-is": "~1.0.0",

        "inherits": "~2.0.3",

        "isarray": "~1.0.0",

        "process-nextick-args": "~2.0.0",

        "safe-buffer": "~5.1.1",

        "string_decoder": "~1.1.1",

        "util-deprecate": "~1.0.1"

      }

    },

    "node_modules/jszip/node_modules/safe-buffer": {

      "version": "5.1.2",

      "resolved": "https://registry.npmjs.org/safe-buffer/-/safe-buffer-5.1.2.tgz",

      "integrity": "sha512-Gd2UZBJDkXlY7GbJxfsE8/nvKkUEU1G38c1siN6QP6a9PT9MmHB8GnpscSmMJSoF8LOIrt8ud/wPtojys4G6+g==",

      "license": "MIT"

    },

    "node_modules/jszip/node_modules/string_decoder": {

      "version": "1.1.1",

      "resolved": "https://registry.npmjs.org/string_decoder/-/string_decoder-1.1.1.tgz",

      "integrity": "sha512-n/ShnvDi6FHbbVfviro+WojiFzv+s8MPMHBczVePfUpDJLwoLT0ht1l4YwBCbi8pJAveEEdnkHyPyTP/mzRfwg==",

      "license": "MIT",

      "dependencies": {

        "safe-buffer": "~5.1.0"

      }

    },

      }

    },

    "node_modules/lie": {

      "version": "3.3.0",

      "resolved": "https://registry.npmjs.org/lie/-/lie-3.3.0.tgz",

      "integrity": "sha512-UaiMJzeWRlEujzAuw5LokY1L5ecNQYZKfmyZ9L7wDHb/p5etKaxXhohBcrw0EYby+G/NA52vRSN4N39dxHAIwQ==",

      "license": "MIT",

      "dependencies": {

        "immediate": "~3.0.5"

    "node_modules/process-nextick-args": {

      "version": "2.0.1",

      "resolved": "https://registry.npmjs.org/process-nextick-args/-/process-nextick-args-2.0.1.tgz",

      "integrity": "sha512-3ouUOpQhtgrbOa17J7+uxOTpITYWaGP7/AhoR3+A+/1e9skrzelGi/dXzEYyvbxubEF6Wn2ypscTKiKJFFn1ag==",

      "license": "MIT"

    },

    },

    "node_modules/setimmediate": {

      "version": "1.0.5",

      "resolved": "https://registry.npmjs.org/setimmediate/-/setimmediate-1.0.5.tgz",

      "integrity": "sha512-MATJdZp8sLqDl/68LfQmbP8zKPLQNV6BIZoIgrscFDQ+RsvK/BxeDQOgyxKKoh0y/8h3BqVFnCqQ/gd+reiIXA==",

      "license": "MIT"

    "csv-stringify": "^6.9.0",

    "jszip": "^3.10.2",

import { Response, NextFunction } from "express";

import { getQueue } from "@app/lib/queue";

import { ExportJobName } from "@app/lib/queue/types";

import { AuthenticatedRequest } from "@app/middleware/auth";

export const ExportsController = {

  create: async (req: AuthenticatedRequest, res: Response, next: NextFunction) => {

    try {

      await getQueue("exports").add(ExportJobName.Data, {

        userId: req.userId!,

      });

      return res.status(202).json({

        message:

          "Tudo certo! Você receberá seus dados por e-mail em instantes.",

      });

    } catch (err) {

      next(err);

    }

  },

};

import exportsRouter from "@app/routes/exports";

  app.use("/exports", exportsRouter);

export type QueueName =

  | "mail"

  | "insights"

  | "medicine-reminders"

  | "daily-reminders"

  | "exports";

import { exportProcessor } from "@app/lib/queue/processors/exports";

  exports: exportProcessor,

  exports: 5,

import { Job } from "bullmq";

import {

  ExportJobData,

  ExportJobName,

  ExportPayload,

} from "@app/lib/queue/types";

import { buildExportArchive } from "@app/services/export/export.service";

import {

  sendExportFailedEmail,

  sendExportReadyEmail,

} from "@app/services/mail";

export async function exportProcessor(

  job: Job<ExportJobData["data"]>,

): Promise<void> {

  switch (job.name as ExportJobName) {

    case ExportJobName.Data: {

      const { userId } = job.data as ExportPayload;

      try {

        const archive = await buildExportArchive(userId);

        await sendExportReadyEmail(userId, archive);

      } catch (err) {

        // Only the last attempt notifies the user; earlier ones are retried

        const attempts = job.opts.attempts ?? 1;

        const isFinalAttempt = job.attemptsMade + 1 >= attempts;

        if (isFinalAttempt) {

          try {

            await sendExportFailedEmail(userId);

          } catch (mailErr) {

            console.error(

              `[exports] failed to send the failure email for user ${userId}:`,

              mailErr,

            );

          }

        }

        throw err;

      }

      break;

    }

    default:

      throw new Error(`Unknown export job: ${job.name}`);

  }

}

// Export queue

export enum ExportJobName {

  Data = "export:data",

}

export type ExportPayload = {

  userId: number;

};

export type ExportJobData = {

  name: ExportJobName.Data;

  data: ExportPayload;

};

import { Router } from "express";

import { ExportsController } from "@app/controllers/exports";

import { requireAuth } from "@app/middleware/auth";

const router = Router();

router.post("/", requireAuth, ExportsController.create);

export default router;

import { stringify } from "csv-stringify/sync";

import { CsvTable, CsvValue, ExportFile } from "@app/services/export/types";

// Dates become ISO-8601 strings so they are quoted like any other string and

// sort unambiguously regardless of the reader's locale.

const normalize = (value: CsvValue): string | number | null => {

  if (value === null || value === undefined) return null;

  if (value instanceof Date) return value.toISOString();

  return value;

};

export function serializeCsv<Row>(table: CsvTable<Row>, rows: Row[]): ExportFile {

  const records = rows.map((row) => {

    const record: Record<string, string | number | null> = {};

    for (const column of table.columns) {

      record[column.header] = normalize(column.value(row));

    }

    return record;

  });

  const body = stringify(records, {

    header: true,

    columns: table.columns.map((column) => column.header),

    record_delimiter: "\r\n",

    quoted_string: true,

  });

  return {

    filename: table.filename,

    content: Buffer.from(`\ufeff${body}`, "utf8"),

    rows: rows.length,

  };

}

import { findUserById } from "@app/services/user.service";

import { serializeCsv } from "@app/services/export/csv.serializer";

import { buildManifest } from "@app/services/export/manifest.builder";

import { profileTable } from "@app/services/export/table.descriptors";

import { buildZip } from "@app/services/export/zip.builder";

import { ExportArchive, ExportFile } from "@app/services/export/types";

export async function buildExportArchive(userId: number): Promise<ExportArchive> {

  const user = await findUserById(userId);

  if (!user) {

    throw new Error(`Usuário ${userId} não encontrado para exportação`);

  }

  const generatedAt = new Date();

  const files: ExportFile[] = [serializeCsv(profileTable, [user])];

  const manifest = buildManifest(files, generatedAt);

  return {

    filename: `nexo-dados-${generatedAt.toISOString().slice(0, 10)}.zip`,

    buffer: await buildZip([...files, manifest]),

  };

}

import { ExportFile } from "@app/services/export/types";

const countLabel = (rows: number): string =>

  rows === 1 ? "1 registro" : `${rows} registros`;

export function buildManifest(files: ExportFile[], generatedAt: Date): ExportFile {

  const fileLines = files.map(

    (file) => `- \`${file.filename}\` — ${countLabel(file.rows)}`,

  );

  const content = [

    "# Seus dados do nexo",

    "",

    `Arquivo gerado em ${generatedAt.toISOString()}.`,

    "",

    "Este pacote reúne os seus dados do nexo, com um arquivo CSV para cada tipo",

    "de registro.",

    "",

    "## Arquivos",

    "",

    ...fileLines,

    "",

    "## Como ler os arquivos",

    "",

    "As colunas `id` e as terminadas em `_id` são identificadores técnicos. Elas",

    "ligam os registros entre si: por exemplo, um `mood_id` aponta para o `id` do",

    "registro correspondente em `moods.csv`. Mantivemos esses nomes para que você",

    "consiga cruzar as tabelas.",

    "",

  ].join("\n");

  return {

    filename: "leia-me.md",

    content: Buffer.from(content, "utf8"),

    rows: 0,

  };

}

import { User } from "@prisma/client";

import { CsvTable } from "@app/services/export/types";

const booleanLabel = (value: boolean): string => (value ? "Sim" : "Não");

export const profileTable: CsvTable<User> = {

  filename: "profile.csv",

  columns: [

    { header: "id", value: (user) => user.id },

    { header: "Nome", value: (user) => user.firstName },

    { header: "Sobrenome", value: (user) => user.lastName },

    { header: "Email", value: (user) => user.email },

    { header: "Ativo", value: (user) => booleanLabel(user.active) },

    {

      header: "Notificações",

      value: (user) => booleanLabel(user.notificationsEnabled),

    },

    { header: "Lembrete diário", value: (user) => user.dailyReminderTime },

    { header: "Criado em", value: (user) => user.createdAt },

    { header: "Atualizado em", value: (user) => user.updatedAt },

  ],

};

export type CsvValue = string | number | Date | null | undefined;

export type CsvColumn<Row> = {

  header: string;

  value: (row: Row) => CsvValue;

};

export type CsvTable<Row> = {

  filename: string;

  columns: CsvColumn<Row>[];

};

export type ExportFile = {

  filename: string;

  content: Buffer;

  rows: number;

};

export type ExportArchive = {

  filename: string;

  buffer: Buffer;

};

import JSZip from "jszip";

import { ExportFile } from "@app/services/export/types";

export async function buildZip(files: ExportFile[]): Promise<Buffer> {

  const zip = new JSZip();

  for (const file of files) {

    zip.file(file.filename, file.content);

  }

  return zip.generateAsync({ type: "nodebuffer", compression: "DEFLATE" });

}

export { sendExportReadyEmail } from '@app/services/mail/sendExportReady';

export { sendExportFailedEmail } from '@app/services/mail/sendExportFailed';

import { sendEmail } from '@app/lib/mail';

import { findUserById } from '@app/services/user.service';

const email = (firstName: string) => (`

Oi, ${firstName}.

Infelizmente não conseguimos preparar o arquivo com os seus dados do nexo

agora. Nada se perdeu — é só tentar de novo pela opção "Exportar Meus Dados"

nas configurações.

Qualquer coisa prende o grito!

`);

export async function sendExportFailedEmail(userId: number): Promise<void> {

  const user = await findUserById(userId);

  const { error } = await sendEmail({

    to: user!.email,

    subject: 'Não conseguimos exportar seus dados',

    text: email(user!.firstName),

  });

  if (error) {

    console.error("Error sending export failure email: ", error);

    throw new Error("Não foi possível enviar o e-mail de falha da exportação");