Function test

test/integration/gridfs/gridfs_stream.test.ts:32–63

()

    metadata: { requires: { topology: ['single'] } },

    async test() {
      const bucket = new GridFSBucket(db);
      const readStream = fs.createReadStream('./LICENSE.md');
      const uploadStream = bucket.openUploadStream('test.dat');

      const license = fs.readFileSync('./LICENSE.md');
      const id = uploadStream.id;

      await pipeline(readStream, uploadStream);

      const chunksCollection = db.collection('fs.chunks');
      const filesCollection = db.collection('fs.files');

      // Get all the chunks
      const chunks = await chunksCollection.find({ files_id: id }).toArray();
      expect(chunks.length).to.equal(1);
      expect(chunks[0].data.toString('hex')).to.equal(license.toString('hex'));

      // Get all the files
      const files = await filesCollection.find({ _id: id }).toArray();
      expect(files.length).to.equal(1);
      expect(files[0]).to.not.have.property('md5');

      // Make sure we created indexes
      const chunkIndexes = await chunksCollection.listIndexes().toArray();
      expect(chunkIndexes.length).to.equal(2);
      expect(chunkIndexes[1].name).to.equal('files_id_1_n_1');

      const fileIndexes = await filesCollection.listIndexes().toArray();
      expect(fileIndexes.length).to.equal(2);
      expect(fileIndexes[1].name).to.equal('filename_1_uploadDate_1');
    }
  });

  it('.destroy() publishes provided error', {