feat: Unit tests and response parsing logic

Author: Mqxx

.gitignore

@@ -1 +1,2 @@
 .vscode/
+reports/

deno.json

@@ -33,9 +33,9 @@
   },
   "lint": {
     "plugins": [
-      "jsr:@loat-dev/lint-plugins@0.3.6/colon_spacing",
-      "jsr:@loat-dev/lint-plugins@0.3.6/imports",
-      "jsr:@loat-dev/lint-plugins@0.3.6/arrays"
+      "jsr:@loat-dev/lint-plugins@0.3.11/colon_spacing",
+      "jsr:@loat-dev/lint-plugins@0.3.11/imports",
+      "jsr:@loat-dev/lint-plugins@0.3.11/arrays"
     ],
     "rules": {
       "tags": [

deno.lock

@@ -1 +1,2 @@
 export { InvalidStartLineError } from './invalid_start_line_error.ts'
+export { InvalidResponseError } from './invalid_response_error.ts'

src/http/error/index.ts

@@ -0,0 +1,5 @@
+export class InvalidResponseError extends Error {
+  constructor() {
+    super('Invalid response. Did not find header end.');
+  }
+}

src/http/error/invalid_response_error.ts

@@ -0,0 +1 @@
+export { parseChunkedBody } from './parse_chunked_body.ts'

src/http/response/body/index.ts

@@ -0,0 +1,3 @@
+export function parseChunkedBody(body : string) : string {
+  return body
+}

src/http/response/body/parse_chunked_body.ts

@@ -0,0 +1,43 @@
+import { assertEquals } from '@std/assert'
+import { parseHeaders } from './parse_headers.ts';
+
+Deno.test('Tests "parseHeaders"', async (test) => {
+  await test.step({
+    name: 'Parse valid HTTP headers.',
+    fn() : void {
+      const responseContent = 'key-1: value1\r\nkey-2: value 2 with space'
+      assertEquals(
+        Object.fromEntries(parseHeaders(responseContent)),
+        {
+          'key-1': 'value1',
+          'key-2': 'value 2 with space'
+        }
+      )
+    }
+  })
+
+  await test.step({
+    name: 'Parse (valid) HTTP headers. With leading/trailing newline.',
+    fn() : void {
+      const responseContent = '\r\nkey-1: value1\r\nkey-2: value 2 with space\r\n'
+      assertEquals(
+        Object.fromEntries(parseHeaders(responseContent)),
+        {
+          'key-1': 'value1',
+          'key-2': 'value 2 with space'
+        }
+      )
+    }
+  })
+
+  await test.step({
+    name: 'Parse (valid) HTTP headers. With space in key name.',
+    fn() : void {
+      const responseContent = 'key 1: value 1 with space'
+      assertEquals(
+        Object.fromEntries(parseHeaders(responseContent)),
+        {'key 1': 'value 1 with space'}
+      )
+    }
+  })
+})

src/http/response/headers/parse_headers.test.ts

@@ -1,6 +1,15 @@
 /**
- * This function parses the HTTP response, and returns the headers
+ * This function parses the HTTP response, and returns the headers.
+ *
+ * @param response Response string
+ * @returns The headers as `<key>: <value>` map.
  */
-export function parseHeaders(response : string) : Record<string, string> {
-  return {}
+export function parseHeaders(response : string) : Map<string, string> {
+  const headers = new Map<string, string>();
+  response.trim().split('\r\n').forEach((line) => {
+    const [key, value] = line.split(':');
+    headers.set(key, value.trim());
+  })
+
+  return headers;
 }

src/http/response/headers/parse_headers.ts

@@ -1,13 +1,18 @@
+import { parseStartLine } from './start_line/index.ts';
 import { parseHeaders } from './headers/index.ts';
+import { parseChunkedBody } from './body/index.ts';
 import { splitResponse } from './split_response.ts';
-import { parseStartLine } from './start_line/index.ts';
 
 export function parse(response : string) : Response {
   const splitResult = splitResponse(response)
 
   const startLine = parseStartLine(splitResult.startLine);
   const headers = parseHeaders(splitResult.headers);
-  const body = splitResult.body;
+  let body = splitResult.body;
+
+  if (headers.get('Transfer-Encoding') === 'chunked') {
+    body = parseChunkedBody(body);
+  }
 
   return new Response(
     body,