получение `Невозможно установить заголовки после их отправки клиенту` при экспорте данных в csv

Question

Я пытаюсь преобразовать данные в csv и отправить их клиенту для загрузки, но я получаю сообщение об ошибке, указанное в заголовке.

Я использую поток js узла, потому что я имею дело с большими данными.

Выше вы найдете мой код.

router.get('/backoffice/moderateur/organismes/export/:status', checkAuth, checkProfile('moderateur'), tryAndCatch(async (req, res) => {

    let codeRegion = req.user.codeRegion;
    let { status } = await Joi.validate(req.params, {
        status: Joi.string().allow(['all', 'active', 'inactive']).default('all'),
    }, { abortEarly: false });

    let stream = await db.collection('accounts').find({
        profile: 'organisme',
        codeRegion: codeRegion,
        ...(status === 'all' ? {} : { passwordHash: { $exists: status === 'active' } }),
    }).stream();

    // const organismes = await db.collection('accounts').find({
    //     profile: 'organisme',
    //     codeRegion: codeRegion,
    //     ...(status === 'all' ? {} : { passwordHash: { $exists: status === 'active' } }),
    // }).toArray();

    res.setHeader('Content-disposition', 'attachment; filename=avis.csv');
    res.setHeader('Content-Type', 'text/csv; charset=iso-8859-1');
    let lines = 'SIRET;EMAIL;NOM\n'
    res.write(lines);

     // organismes.forEach(organisme => {
     //    lines += organisme.SIRET + ';' +
     //        organisme.courriel + ';' +
     //        comment.courriel + '\n';
     // });

     let handleError = e => {
         logger.error('An error occurred', e);
         res.status(500);
         stream.push(Boom.boomify(e).output.payload);
     };

     stream
     .on('error', handleError)
     .pipe(transformObject(async organisme => {
       return organisme.SIRET + ';' +
          organisme.raisonSociale + ';' +
          organisme.courriel + '\n';
     }))
     .pipe(encodeStream('UTF-16BE'))
     .pipe(res);

     // res.send(organismes);

}));

Answer 1

Я должен был добавить это в конце:

.on('end', () => res.end());

Answer 2

Вы не указали, в какой строке вы получаете эту ошибку.

Однако, глядя на код, я думаю, что вы запускаете handleError, который пытается сделать res.status(500) этовызовет исключение, так как вы уже неявно отправили заголовки здесь res.write(lines).