Function test

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

()

    metadata: { requires: { topology: [class="st">'single'] } },

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

      const license = fs.readFileSync(class="st">'./LICENSE.md');
      const id = uploadStream.id;

      await pipeline(readStream, uploadStream);

      const chunksCollection = db.collection(class="st">'fs.chunks');
      const filesCollection = db.collection(class="st">'fs.files');

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

      class="cm">// 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(class="st">'md5');

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

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

  it(class="st">'.destroy() publishes provided error', {