Init

Mqxx · Mqxx · commit 0fd67dc06cd8 · 2025-11-10T17:01:04.000+01:00
diff --git a/cli.ts b/cli.ts
diff --git a/deno.json b/deno.json
@@ -1,32 +1,29 @@
 {
-  "name": "@denoplayground/template",
+  "name": "@typescriptplayground/socket",
   "version": "0.1.0",
+  "license": "./LICENSE",
+  "exports": {
+    ".": "./src/index.ts"
+  },
   "tasks": {
-    "run": {
-      "description": "Run the main application.",
-      "command": "deno run -A --check ./src/index.ts"
-    },
-    "run:watch": {
-      "description": "Run the main application in watch mode.",
-      "command": "deno run -A --check --watch ./src/index.ts"
-    },
     "lint": {
-      "description": "Run the linting tool.",
+      "description": "Run linter.",
       "command": "deno lint"
     },
+    "format": {
+      "description": "Run formatter.",
+      "command": "deno lint --fix"
+    },
     "test": {
       "description": "Run the test suite.",
       "command": "deno test -A --check --permit-no-files --reload --doc --junit-path=\"./reports/report.xml\""
     }
   },
   "compilerOptions": {
-    "allowJs": false,
     "lib": [
       "deno.ns",
       "deno.window",
-      "deno.worker",
-      "decorators",
-      "esnext"
+      "deno.worker"
     ]
   },
   "test": {
@@ -35,6 +32,11 @@
     ]
   },
   "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"
+    ],
     "rules": {
       "tags": [
         "recommended"
@@ -62,5 +64,8 @@
     "lineWidth": 120,
     "typeLiteral.separatorKind": "comma",
     "useBraces": "always"
+  },
+  "imports": {
+    "@std/assert": "jsr:@std/assert@^1.0.15"
   }
 }
diff --git a/deno.lock b/deno.lock
diff --git a/response.txt b/response.txt
@@ -0,0 +1,15 @@
+HTTP/1.1 200 OK
+Api-Version: 1.51
+Content-Type: application/json
+Docker-Experimental: false
+Ostype: linux
+Server: Docker/28.3.3 (linux)
+Date: Mon, 10 Nov 2025 15:42:24 GMT
+Connection: close
+Transfer-Encoding: chunked
+
+bb7
+[{"Id":"0954fa1ee0b11120eeabb22c2b4bc924221840a8d8d8a408ac8881616019161a","Names":["/infallible_newton"],"Image":"node:20","ImageID":"sha256:d05db19b2fc951de57277a69bef61300129cfa87385b241b9201db91f01376ea","Command":"/bin/sh -c 'echo Container started\ntrap \"exit 0\" 15\n\nexec \"$@\"\nwhile sleep 1 & wait $!; do :; done' -","Created":1760434443,"Ports":[],"Labels":{"devcontainer.config_file":"/mnt/c/Users/17000181/Development/gitlab/me-optronic/webui/imc/imc5xx0/.devcontainer/devcontainer.json","devcontainer.local_folder":"c:\\Users\\17000181\\Development\\gitlab\\me-optronic\\webui\\imc\\imc5xx0","devcontainer.metadata":"[{\"postCreateCommand\":\"npm config set //gitlab02.micro-epsilon.de/api/v4/packages/npm/:_authToken=${localEnv:GL_AUTH_TOKEN} && npm ci && chmod -R a+rwx build && chmod -R a+rwx node_modules\",\"customizations\":{\"vscode\":{\"extensions\":[\"vunguyentuan.vscode-css-variables\",\"streetsidesoftware.code-spell-checker\",\"yzhang.markdown-all-in-one\",\"streetsidesoftware.code-spell-checker-german\",\"dbaeumer.vscode-eslint\"]}},\"mounts\":[{\"type\":\"volume\",\"target\":\"${containerWorkspaceFolder}/node_modules\"},{\"type\":\"volume\",\"target\":\"${containerWorkspaceFolder}/build\"}],\"containerEnv\":{\"NODE_ENV\":\"development\"},\"forwardPorts\":[\"localhost:8000\",\"localhost:8888\"]}]"},"State":"running","Status":"Up 8 hours","HostConfig":{"NetworkMode":"bridge"},"NetworkSettings":{"Networks":{"bridge":{"IPAMConfig":null,"Links":null,"Aliases":null,"MacAddress":"92:78:de:f3:58:a7","DriverOpts":null,"GwPriority":0,"NetworkID":"1aa367c5042af469d2505bf36f4ac40862cd222f4d6e743a6c8af8b44d48b15c","EndpointID":"5ebbb39dc5a779be73c516a4a8fe978a72825e7965714e6500a0844113e5d28d","Gateway":"172.17.0.1","IPAddress":"172.17.0.2","IPPrefixLen":16,"IPv6Gateway":"","GlobalIPv6Address":"","GlobalIPv6PrefixLen":0,"DNSNames":null}}},"Mounts":[{"Type":"volume","Name":"79c2c791138c00c10561ba5e325519138f33b4f57bc87951ef04a1ae039d91d9","Source":"/var/lib/docker/volumes/79c2c791138c00c10561ba5e325519138f33b4f57bc87951ef04a1ae039d91d9/_data","Destination":"/workspaces/imc5xx0/node_modules","Driver":"local","Mode":"z","RW":true,"Propagation":""},{"Type":"bind","Source":"/run/user/1001/wayland-0","Destination":"/tmp/vscode-wayland-9559a141-0286-44b8-8ab6-f67dc78d9af5.sock","Mode":"","RW":true,"Propagation":"rprivate"},{"Type":"volume","Name":"vscode","Source":"/var/lib/docker/volumes/vscode/_data","Destination":"/vscode","Driver":"local","Mode":"z","RW":true,"Propagation":""},{"Type":"bind","Source":"/mnt/c/Users/17000181/Development/gitlab/me-optronic/webui/imc/imc5xx0","Destination":"/workspaces/imc5xx0","Mode":"","RW":true,"Propagation":"rprivate"},{"Type":"volume","Name":"a1db817e930b814a9d8dd921cf2e663e7f0d21f336f1e8bc19e12f61de965b45","Source":"/var/lib/docker/volumes/a1db817e930b814a9d8dd921cf2e663e7f0d21f336f1e8bc19e12f61de965b45/_data","Destination":"/workspaces/imc5xx0/build","Driver":"local","Mode":"z","RW":true,"Propagation":""}]}]
+
+0
+
diff --git a/src/error/connection_closed_error.ts b/src/error/connection_closed_error.ts
@@ -0,0 +1,8 @@
+/**
+ * This error represents a connection that was closed before receiving a response.
+ */
+export class ConnectionClosedError extends Error {
+  constructor() {
+    super('Connection closed before receiving response')
+  }
+}
diff --git a/src/error/inclomplete_http_response_error.ts b/src/error/inclomplete_http_response_error.ts
@@ -0,0 +1,8 @@
+/**
+ * This error represents an incomplete HTTP response.
+ */
+export class IncompleteHttpResponseError extends Error {
+  constructor() {
+    super('Incomplete HTTP response');
+  }
+}
diff --git a/src/error/index.ts b/src/error/index.ts
@@ -0,0 +1,3 @@
+export { ConnectionClosedError } from './connection_closed_error.ts'
+export { IncompleteHttpResponseError } from './inclomplete_http_response_error.ts'
+export { InvalidHttpResponseError } from './invalid_http_response_error.ts'
diff --git a/src/error/invalid_http_response_error.ts b/src/error/invalid_http_response_error.ts
@@ -0,0 +1,5 @@
+export class InvalidHttpResponseError extends Error {
+  constructor(message : string) {
+    super(message);
+  }
+}
diff --git a/src/http/error/index.ts b/src/http/error/index.ts
@@ -0,0 +1 @@
+export { InvalidStartLineError } from './invalid_start_line_error.ts'
diff --git a/src/http/error/invalid_start_line_error.ts b/src/http/error/invalid_start_line_error.ts
@@ -0,0 +1,7 @@
+export class InvalidStartLineError extends Error {
+  content : string;
+  constructor(content : string) {
+    super(`Invalid HTTP status. Trying to parse: "${content}"`);
+    this.content = content;
+  }
+}
diff --git a/src/http/response/headers/index.ts b/src/http/response/headers/index.ts
@@ -0,0 +1 @@
+export { parseHeaders } from './parse_headers.ts'
diff --git a/src/http/response/headers/parse_headers.ts b/src/http/response/headers/parse_headers.ts
@@ -0,0 +1,6 @@
+/**
+ * This function parses the HTTP response, and returns the headers
+ */
+export function parseHeaders(response : string) : Record<string, string> {
+  return {}
+}
diff --git a/src/http/response/parse.ts b/src/http/response/parse.ts
@@ -0,0 +1,20 @@
+import { parseHeaders } from './headers/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;
+
+  return new Response(
+    body,
+    {
+      headers: headers,
+      status: startLine.code,
+      statusText: startLine.status
+    }
+  )
+}
diff --git a/src/http/response/split_response.ts b/src/http/response/split_response.ts
@@ -0,0 +1,13 @@
+import { SplitResponseResult } from './split_response_result.ts';
+
+export function splitResponse(response : string) : SplitResponseResult {
+  const [header, body] = response.split('\r\n\r\n', 2);
+
+  const [startLine, headers] = header.split('\r\n');
+
+  return {
+    startLine,
+    headers,
+    body
+  }
+}
diff --git a/src/http/response/split_response_result.ts b/src/http/response/split_response_result.ts
@@ -0,0 +1,5 @@
+export interface SplitResponseResult {
+  startLine : string,
+  headers : string,
+  body : string
+}
diff --git a/src/http/response/start_line/index.ts b/src/http/response/start_line/index.ts
@@ -0,0 +1 @@
+export { parseStartLine } from './parse_start_line.ts'
diff --git a/src/http/response/start_line/parse_start_line.test.ts b/src/http/response/start_line/parse_start_line.test.ts
@@ -0,0 +1,31 @@
+import { assertEquals, assertThrows } from '@std/assert'
+import { parseStartLine } from '../start_line/parse_start_line.ts';
+import { InvalidStartLineError } from '../../error/invalid_start_line_error.ts';
+
+Deno.test('Tests "parseStartLine"', async (test) => {
+  await test.step({
+    name: 'Parse valid HTTP response.',
+    fn() : void {
+      const responseContent = 'HTTP/1.1 200 OK\r\nfoo: bar\r\n\r\n'
+      assertEquals(
+        parseStartLine(responseContent),
+        {
+          protocol: 'HTTP/1.1',
+          code: 200,
+          status: 'OK'
+        }
+      )
+    }
+  })
+
+  await test.step({
+    name: 'Parse invalid HTTP response.',
+    fn() : void {
+      const responseContent = 'HTTP/1.1 OK\r\nfoo: bar\r\n\r\n'
+      assertThrows(
+        () => parseStartLine(responseContent),
+        InvalidStartLineError
+      )
+    }
+  })
+})
diff --git a/src/http/response/start_line/parse_start_line.ts b/src/http/response/start_line/parse_start_line.ts
@@ -0,0 +1,19 @@
+import { InvalidStartLineError } from '../../error/invalid_start_line_error.ts';
+import { StartLine } from './start_line.ts';
+
+/**
+ * This function parses the HTTP response, and returns the start line
+ */
+export function parseStartLine(content : string) : StartLine {
+  const startLine = content.match(/^(?<protocol>.+) (?<code>[0-9]{3}) (?<status>.*)/)
+
+  if (!startLine?.groups) {
+    throw new InvalidStartLineError(content);
+  }
+
+  return {
+    protocol: startLine.groups.protocol,
+    code: parseInt(startLine.groups.code),
+    status: startLine.groups.status
+  }
+}
diff --git a/src/http/response/start_line/start_line.ts b/src/http/response/start_line/start_line.ts
@@ -0,0 +1,8 @@
+/**
+ * This interface represents a HTTP response start line.
+ */
+export interface StartLine {
+  protocol : string,
+  code : number,
+  status : string
+}
diff --git a/src/index.ts b/src/index.ts
@@ -1 +1,9 @@
 
+import { Socket } from './socket.ts';
+
+const socket = new Socket('/var/run/docker.sock');
+
+
+socket.request("/containers/json")
+  .then(res => res.json())
+  .then(json => console.log(json));
diff --git a/src/method.ts b/src/method.ts
@@ -0,0 +1,20 @@
+/**
+ * This object represents all possible methods for a request.
+ */
+export const method = {
+  GET: 'GET',
+  HEAD: 'HEAD',
+  POST: 'POST',
+  PUT: 'PUT',
+  DELETE: 'DELETE',
+  CONNECT: 'CONNECT',
+  OPTIONS: 'OPTIONS',
+  TRACE: 'TRACE',
+  PATCH: 'PATCH',
+} as const;
+
+/**
+ * This type represents possible methods.
+ */
+// deno-lint-ignore ban-types
+export type Method = typeof method[keyof typeof method] | (string & {});
diff --git a/src/parse_http_response.ts b/src/parse_http_response.ts
@@ -0,0 +1,53 @@
+import { ParsedResponse } from './parsed_response.ts';
+import * as error from './error/index.ts'
+
+/**
+ * This function parses an HTTP response.
+ * 
+ * @param data Data to parse
+ * @throws `IncompleteHttpResponseError` if the response is incomplete
+ * @throws `InvalidHttpResponseError` if the response is invalid
+ * @returns The parsed response.
+ */
+export function parseHttpResponse(data : string) : ParsedResponse {
+  Deno.writeTextFileSync('response.txt', data);
+  
+  const headerEnd = data.indexOf("\r\n\r\n");
+
+  if (headerEnd === -1) {
+    throw new error.IncompleteHttpResponseError();
+  }
+
+  const headerSection = data.slice(0, headerEnd);
+  const bodyStart = data.slice(headerEnd + 4);
+  
+  const lines = headerSection.split("\r\n");
+  const statusLine = lines[0];
+  
+  // HTTP/1.1 <code> <status>
+  const statusMatch = statusLine.match(/^HTTP\/\d\.\d\s+(\d+)\s*(.*)$/);
+  if (!statusMatch) {
+    throw new error.InvalidHttpResponseError(`Invalid status line: ${statusLine}`);
+  }
+  
+  const statusCode = parseInt(statusMatch[1], 10);
+  const statusText = statusMatch[2] || '';
+  
+  const headers : Record<string, string> = {};
+
+  for (let i = 1; i < lines.length; i++) {
+    const colonIndex = lines[i].indexOf(":");
+    if (colonIndex !== -1) {
+      const key = lines[i].slice(0, colonIndex).trim().toLowerCase();
+      const value = lines[i].slice(colonIndex + 1).trim();
+      headers[key] = value;
+    }
+  }
+
+  return {
+    statusCode,
+    statusText,
+    headers,
+    bodyStart
+  };
+}
diff --git a/src/parsed_response.ts b/src/parsed_response.ts
@@ -0,0 +1,6 @@
+export interface ParsedResponse {
+  statusCode : number;
+  statusText : string;
+  headers : Record<string, string>;
+  bodyStart : string;
+}
diff --git a/src/socket.ts b/src/socket.ts
diff --git a/src/socket_options.ts b/src/socket_options.ts
diff --git a/src/socket_request_init.ts b/src/socket_request_init.ts

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,3 @@`
	`1`	`+export { ConnectionClosedError } from './connection_closed_error.ts'`
	`2`	`+export { IncompleteHttpResponseError } from './inclomplete_http_response_error.ts'`
	`3`	`+export { InvalidHttpResponseError } from './invalid_http_response_error.ts'`
Original file line number	Diff line number	Diff line change
`@@ -0,0 +1 @@`
	`1`	`+export { InvalidStartLineError } from './invalid_start_line_error.ts'`