Function loader

apps/webapp/app/routes/admin.api.v1.snapshot.ts:26–58

({ request }: DataFunctionArgs)

}

export async function loader({ request }: DataFunctionArgs) {
  const user = await requireUser(request);

  if (!user.admin) {
    throw new Response("You must be an admin to perform this action", { status: 403 });
  }

  const tempDir = os.tmpdir();
  const filepath = path.join(
    tempDir,
    `${getTaskIdentifier()}-${formatDate(new Date())}.heapsnapshot`
  );

  const snapshotPath = v8.writeHeapSnapshot(filepath);
  if (!snapshotPath) {
    throw new Response("No snapshot saved", { status: 500 });
  }

  const body = new PassThrough();
  const stream = fs.createReadStream(snapshotPath);
  stream.on("open", () => stream.pipe(body));
  stream.on("error", (err) => body.end(err));
  stream.on("end", () => body.end());

  return new Response(body as any, {
    status: 200,
    headers: {
      "Content-Type": "application/octet-stream",
      "Content-Disposition": `attachment; filename="${path.basename(snapshotPath)}"`,
      "Content-Length": (await fs.promises.stat(snapshotPath)).size.toString(),
    },
  });
}

function getTaskIdentifier() {
  if (!process.env.ECS_CONTAINER_METADATA_URI) {