const { Buffer, copy, open, test } = Deno;import { assert, assertEquals, assertThrows, assertThrowsAsync,} from "../testing/asserts.ts";import * as path from "../path/mod.ts";import { MultipartReader, MultipartWriter, isFormFile, matchAfterPrefix, scanUntilBoundary,} from "./multipart.ts";import { StringWriter } from "../io/writers.ts";
const e = new TextEncoder();const boundary = "--abcde";const dashBoundary = e.encode("--" + boundary);const nlDashBoundary = e.encode("\r\n--" + boundary);
test(function multipartScanUntilBoundary1(): void { const data = `--${boundary}`; const n = scanUntilBoundary( e.encode(data), dashBoundary, nlDashBoundary, 0, true ); assertEquals(n, Deno.EOF);});
test(function multipartScanUntilBoundary2(): void { const data = `foo\r\n--${boundary}`; const n = scanUntilBoundary( e.encode(data), dashBoundary, nlDashBoundary, 0, true ); assertEquals(n, 3);});
test(function multipartScanUntilBoundary3(): void { const data = `foobar`; const n = scanUntilBoundary( e.encode(data), dashBoundary, nlDashBoundary, 0, false ); assertEquals(n, data.length);});
test(function multipartScanUntilBoundary4(): void { const data = `foo\r\n--`; const n = scanUntilBoundary( e.encode(data), dashBoundary, nlDashBoundary, 0, false ); assertEquals(n, 3);});
test(function multipartMatchAfterPrefix1(): void { const data = `${boundary}\r`; const v = matchAfterPrefix(e.encode(data), e.encode(boundary), false); assertEquals(v, 1);});
test(function multipartMatchAfterPrefix2(): void { const data = `${boundary}hoge`; const v = matchAfterPrefix(e.encode(data), e.encode(boundary), false); assertEquals(v, -1);});
test(function multipartMatchAfterPrefix3(): void { const data = `${boundary}`; const v = matchAfterPrefix(e.encode(data), e.encode(boundary), false); assertEquals(v, 0);});
test(async function multipartMultipartWriter(): Promise<void> { const buf = new Buffer(); const mw = new MultipartWriter(buf); await mw.writeField("foo", "foo"); await mw.writeField("bar", "bar"); const f = await open(path.resolve("./mime/testdata/sample.txt"), "r"); await mw.writeFile("file", "sample.txt", f); await mw.close(); f.close();});
test(function multipartMultipartWriter2(): void { const w = new StringWriter(); assertThrows( (): MultipartWriter => new MultipartWriter(w, ""), Error, "invalid boundary length" ); assertThrows( (): MultipartWriter => new MultipartWriter( w, "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa" + "aaaaaaaa" ), Error, "invalid boundary length" ); assertThrows( (): MultipartWriter => new MultipartWriter(w, "aaa aaa"), Error, "invalid boundary character" ); assertThrows( (): MultipartWriter => new MultipartWriter(w, "boundary¥¥"), Error, "invalid boundary character" );});
test(async function multipartMultipartWriter3(): Promise<void> { const w = new StringWriter(); const mw = new MultipartWriter(w); await mw.writeField("foo", "foo"); await mw.close(); await assertThrowsAsync( async (): Promise<void> => { await mw.close(); }, Error, "closed" ); await assertThrowsAsync( async (): Promise<void> => { await mw.writeFile("bar", "file", null); }, Error, "closed" ); await assertThrowsAsync( async (): Promise<void> => { await mw.writeField("bar", "bar"); }, Error, "closed" ); assertThrows( (): void => { mw.createFormField("bar"); }, Error, "closed" ); assertThrows( (): void => { mw.createFormFile("bar", "file"); }, Error, "closed" );});
test({ name: "[mime/multipart] readForm() basic", async fn() { const o = await open(path.resolve("./mime/testdata/sample.txt")); const mr = new MultipartReader( o, "--------------------------434049563556637648550474" ); const form = await mr.readForm(); assertEquals(form.value("foo"), "foo"); assertEquals(form.value("bar"), "bar"); const file = form.file("file"); assert(isFormFile(file)); assert(file.content !== void 0); o.close(); },});
test({ name: "[mime/multipart] readForm() should store big file in temp file", async fn() { const o = await open(path.resolve("./mime/testdata/sample.txt")); const mr = new MultipartReader( o, "--------------------------434049563556637648550474" ); const form = await mr.readForm(20); try { assertEquals(form.value("foo"), "foo"); assertEquals(form.value("bar"), "bar"); const file = form.file("file"); assert(file != null); assertEquals(file.type, "application/octet-stream"); assert(file.tempfile != null); const f = await open(file.tempfile); const w = new StringWriter(); await copy(w, f); const json = JSON.parse(w.toString()); assertEquals(json["compilerOptions"]["target"], "es2018"); f.close(); } finally { await form.removeAll(); o.close(); } },});
test({ name: "[mime/multipart] removeAll() should remove all tempfiles", async fn() { const o = await open(path.resolve("./mime/testdata/sample.txt")); const mr = new MultipartReader( o, "--------------------------434049563556637648550474" ); const form = await mr.readForm(20); const file = form.file("file"); assert(file != null); const { tempfile, content } = file; assert(tempfile != null); assert(content == null); const stat = await Deno.stat(tempfile); assertEquals(stat.size, file.size); await form.removeAll(); await assertThrowsAsync(async () => { await Deno.stat(tempfile); }, Deno.errors.NotFound); o.close(); },});
test({ name: "[mime/multipart] entries()", async fn() { const o = await open(path.resolve("./mime/testdata/sample.txt")); const mr = new MultipartReader( o, "--------------------------434049563556637648550474" ); const form = await mr.readForm(); const map = new Map(form.entries()); assertEquals(map.get("foo"), "foo"); assertEquals(map.get("bar"), "bar"); const file = map.get("file"); assert(isFormFile(file)); assertEquals(file.filename, "tsconfig.json"); o.close(); },});