Как протестировать загрузку изображения (поток) с помощью супертеста и шутки?

Это должно работать. Чтобы передать данные запросу, вы должны сообщить читаемому потоку передать запрос. Другой способ — получение данных с сервера. Здесь также используется done вместо async, поскольку каналы не работают с async/await.

Также ничего не стоит то, что по умолчанию канал вызовет end, а затем суперагент вызовет end, что приведет к ошибке о двойном вызове end. Чтобы решить эту проблему, вы должны указать вызову канала не делать этого, а затем вызвать end в событии on end потока.

import request from 'supertest'

const testImage = `${__dirname}/../../../assets/test_image.jpg`

describe('Upload endpoint', () => {

  test('Successfully uploads jpg image', (done) => {
      const req = request(app)
          .post(`${ROOT_URL}${endpoints.add_image.route}`)
          .set('Authorization', `Bearer ${process.env.testUserJWT}`)
          .set('content-type', 'application/octet-stream')

      const imgStream = fs.createReadStream(testImage);
      imgStream.on('end', () => req.end(done));
      imgStream.pipe(req, {end: false})
  })
})

Отредактировано для добавления: у меня это сработало с небольшими файлами. Если я попытаюсь протестировать его с помощью большого файла test_image.jpg, время запроса истечет.

Мне пришлось сделать предположения о том, что ваш метод загрузки принимает в качестве входных данных тело, а не составные данные формы. Итак, ниже приведен пример, когда необработанное тело передается для загрузки.

const request = require('supertest');
const express = require('express');
const fs = require('fs')
const app = express();
var bodyParser = require('body-parser')
app.use(bodyParser.raw({type: 'application/octet-stream'}))

app.post('/user', function(req, res) {
    res.status(200).json({ name: 'tobi' });
});

testImage = './package.json'

resp = request(app)
    .post('/user')

    resp.set('Authorization', `Bearer Test`).set('Content-Type', 'application/octet-stream')

    resp.send(fs.readFileSync(testImage, 'utf-8'))
    resp.expect(200)
    .then(response => {
        console.log("response",response);
    }).catch((err) => {
        console.log(err)
    })

Если вы используете multipart/form-data, то ниже приведен пример кода

const request = require('supertest');
const express = require('express');
const fs = require('fs')
const app = express();

app.post('/user', function(req, res) {
    // capture the encoded form data
    req.on('data', (data) => {
        console.log(data.toString());
    });

    // send a response when finished reading
    // the encoded form data
    req.on('end', () => {
        res.status(200).json({ name: 'tobi' });
    });

});

testImage = './package.json'

resp = request(app)
    .post('/user')

    resp.set('Authorization', `Bearer Test`)
    resp.attach("file", testImage)
    resp.expect(200)
    .then(response => {
        console.log("response",response);
    }).catch((err) => {
        console.log(err)
    })

Я думаю, вы на самом деле хотите использовать fs.createReadStream(testImage) для чтения этого изображения в своем запросе, поскольку fs.createWriteStream(testImage) будет записывать данные в предоставленный файловый дескриптор (в данном случае testImage). Не стесняйтесь проверить Node Streams, чтобы узнать, как они работают более подробно.

Я не совсем уверен, откуда вы получаете событие finish для supertest, но вы можете увидеть, как использовать метод .pipe() здесь.

Вы также можете рассмотреть возможность использования supertest составных вложений, если это лучше подходит для вашего теста. .