msgraph-sdk-javascript/test/node/tasks/StreamUpload.ts at dev · microsoftgraph/msgraph-sdk-javascript · GitHub

Repository navigation

History

98 lines (77 loc) · 4.07 KB

Raw

/**

* -------------------------------------------------------------------------------------------

* See License in the project root for license information.

* -------------------------------------------------------------------------------------------

import "isomorphic-fetch";

import { assert } from "chai";

import * as fs from "fs";

import { StreamUpload } from "../../../src/tasks/FileUploadTask/FileObjectClasses/StreamUpload";

const fileName = "sample_image.jpg";

const filePath = `./test/sample_files/${fileName}`;

const stats = fs.statSync(`./test/sample_files/${fileName}`);

const totalsize = stats.size;

describe("StreamUpload", () => {

it("Stream size smaller than upload range size", async () => {

const readStream = fs.createReadStream(`./test/sample_files/${fileName}`, { highWaterMark: 8 });

const sliceSize = 200;

const upload = new StreamUpload(readStream, fileName, totalsize);

const slice = await upload.sliceFile({ minValue: 0, maxValue: sliceSize - 1 });

assert.isDefined(slice);

assert.equal(sliceSize, (slice as Buffer).length);

});

it("Stream size greater than upload range size", async () => {

const readStream = fs.createReadStream(filePath, { highWaterMark: 200 });

const sliceSize = 100;

const upload = new StreamUpload(readStream, fileName, totalsize);

const slice = await upload.sliceFile({ minValue: 0, maxValue: sliceSize - 1 });

assert.isDefined(slice);

assert.equal(sliceSize, (slice as Buffer).length);

});

it("Stream size with complete file and greater than upload range size", async () => {

const readStream = fs.createReadStream(filePath, { highWaterMark: totalsize });

const sliceSize = 100;

const upload = new StreamUpload(readStream, fileName, totalsize);

const slice = await upload.sliceFile({ minValue: 0, maxValue: sliceSize - 1 });

assert.isDefined(slice);

assert.equal(sliceSize, (slice as Buffer).length);

});

describe("Stream upload resume", () => {

it("New range is equal to previous upload range", async () => {

const readStream = fs.createReadStream(filePath, { highWaterMark: totalsize });

const sliceSize = 20;

const upload = new StreamUpload(readStream, fileName, totalsize);

const slice = await upload.sliceFile({ minValue: 0, maxValue: sliceSize - 1 });

const retrySlice = await upload.sliceFile({ minValue: 0, maxValue: sliceSize - 1 });

assert.isDefined(slice);

assert.isDefined(retrySlice);

assert.equal(Buffer.compare(slice as Buffer, retrySlice as Buffer), 0);

});

it("New Range.Minimum greater than previous Range.Minimum and new Range.Maximum is equal previous Range.Maximum", async () => {

const readStream = fs.createReadStream(filePath, { highWaterMark: totalsize });

const sliceSize = 20;

const upload = new StreamUpload(readStream, fileName, totalsize);

const retryRangeMin = 15;

const slice = await upload.sliceFile({ minValue: 0, maxValue: sliceSize - 1 });

const retrySlice = await upload.sliceFile({ minValue: 15, maxValue: sliceSize - 1 });

assert.isDefined(slice);

assert.isDefined(retrySlice);

assert.equal(sliceSize, (slice as Buffer).length);

assert.equal(Buffer.compare(slice.slice(retryRangeMin, sliceSize) as Buffer, retrySlice as Buffer), 0);

});

it("New Range.Minimum greater than previous Range.Minimum and new Range.Maximum is greater than previous Range.Maximum", async () => {

const readStream = fs.createReadStream(filePath, { highWaterMark: totalsize });

const sliceSize = 20;

const retryRangeMin = 15;

const retryRangeMax = 21;

const upload = new StreamUpload(readStream, fileName, totalsize);

const slice = await upload.sliceFile({ minValue: 0, maxValue: sliceSize - 1 });

const retrySlice = (await upload.sliceFile({ minValue: retryRangeMin, maxValue: retryRangeMax })) as Buffer;

assert.isDefined(slice);

assert.isDefined(retrySlice);

assert.equal(retrySlice.length, retryRangeMax - retryRangeMin + 1);

assert.equal(Buffer.compare(slice.slice(retryRangeMin, sliceSize) as Buffer, retrySlice.slice(0, sliceSize - retryRangeMin)), 0);

});

msgraph-sdk-javascript/test/node/tasks/StreamUpload.ts at dev · microsoftgraph/msgraph-sdk-javascript · GitHub

Repository navigation

Expand file tree

Breadcrumbs

StreamUpload.ts

Latest commit

History

Breadcrumbs

StreamUpload.ts

File metadata and controls