Function renderWithoutCallback

packages/cli/src/server/render.ts:77–150

(req: Request, res: Response)

}

async function renderWithoutCallback(req: Request, res: Response) {
  // TODO: validate request body
  const {variables, streamProgress, settings} = req.body;
  const tempProjectName: `${string}.mp4` = `${uuidv4()}.mp4`;
  const resultFilePath = path.join(process.cwd(), `output/${tempProjectName}`);

  if (streamProgress) {
    res.writeHead(200, {
      // eslint-disable-next-line
      'Content-Type': 'text/event-stream',
      // eslint-disable-next-line
      'Cache-Control': 'no-cache',
      // eslint-disable-next-line
      Connection: 'keep-alive',
    });

    const sendProgress = (worker: number, progress: number) => {
      res.write(`event: progress\n`);
      res.write(`data: ${JSON.stringify({worker, progress})}\n\n`);
    };

    try {
      await renderVideo({
        projectFile: process.env.PROJECT_FILE || '',
        variables,
        settings: {
          ...settings,
          outFile: tempProjectName,
          progressCallback: sendProgress,
        },
      });

      const downloadLink = `${req.protocol}://${req.get('host')}/download/${tempProjectName}`;
      res.write(`event: completed\n`);
      res.write(
        `data: ${JSON.stringify({status: 'success', downloadLink})}\n\n`,
      );
      res.end();
      scheduleCleanup(resultFilePath);
    } catch (error: any) {
      console.error(error);
      res.write(`event: error\n`);
      res.write(
        `data: ${JSON.stringify({status: 'error', message: error.message})}\n\n`,
      );
      res.end();
    }
  } else {
    try {
      await renderVideo({
        projectFile: process.env.PROJECT_FILE || '',
        variables,
        settings: {
          ...settings,
          outFile: tempProjectName,
        },
      });