verdaccio/test/functional/sanity/incomplete.ts

import { API_ERROR, HEADER_TYPE, HTTP_STATUS } from '../../../src/lib/constants';
import { DOMAIN_SERVERS, PORT_SERVER_APP } from '../config.functional';

const defaultPkg = {
  name: 'testexp-incomplete',
  versions: {
    '0.1.0': {
      name: 'testexp_tags',
      version: '0.1.0',
      dist: {
        shasum: 'fake',
        tarball: `http://${DOMAIN_SERVERS}:${PORT_SERVER_APP}/testexp-incomplete/-/content-length.tar.gz`
      }
    },
    '0.1.1': {
      name: 'testexp_tags',
      version: '0.1.1',
      dist: {
        shasum: 'fake',
        tarball: `http://${DOMAIN_SERVERS}:${PORT_SERVER_APP}/testexp-incomplete/-/chunked.tar.gz`
      }
    }
  }
};

export default function (server, express) {
  const listofCalls = [HEADER_TYPE.CONTENT_LENGTH, 'chunked'];

  describe('test send incomplete packages', () => {
    beforeAll(function () {
      express.get('/testexp-incomplete', function (_, res) {
        res.send(defaultPkg);
      });
    });

    listofCalls.forEach((type) => {
      test(`should not store tarballs / ${type}`, (callback) => {
        let called;
        express.get(`/testexp-incomplete/-/${type}.tar.gz`, function (_, response) {
          if (called) {
            return response.socket.destroy();
          }

          called = true;
          if (type !== 'chunked') {
            response.header(HEADER_TYPE.CONTENT_LENGTH, 1e6);
          }

          response.write('test test test\n');

          setTimeout(function () {
            response.socket.write('200\nsss\n');
            response.socket.destroy();
            cb();
          }, 10);
        });

        server
          .request({ uri: '/testexp-incomplete/-/' + type + '.tar.gz' })
          .status(HTTP_STATUS.OK)
          .response(function (res) {
            if (type !== 'chunked') {
              expect(parseInt(res.headers[HEADER_TYPE.CONTENT_LENGTH], 10)).toBe(1e6);
            }
          })
          .then(function (body) {
            expect(body).toMatch(/test test test/);
          });

        function cb() {
          server
            .request({ uri: '/testexp-incomplete/-/' + type + '.tar.gz' })
            .body_error(API_ERROR.INTERNAL_SERVER_ERROR)
            .then(function () {
              callback();
            });
        }
      });
    });
  });
}