initial commit

Author: darrachequesne

.github/workflows/ci.yml

@@ -0,0 +1,33 @@
+name: CI
+
+on:
+  push:
+    branches:
+      - '**'
+  pull_request:
+  schedule:
+    - cron: '0 0 * * 0'
+
+permissions:
+  contents: read
+
+jobs:
+  test-bun:
+    runs-on: ubuntu-latest
+    timeout-minutes: 10
+
+    strategy:
+      fail-fast: false
+
+    steps:
+      - name: Checkout repository
+        uses: actions/checkout@v4
+
+      - name: Install Bun
+        uses: oven-sh/setup-bun@v2
+
+      - name: Install dependencies
+        run: bun install
+
+      - name: Run tests
+        run: bun test

.github/workflows/publish.yml

@@ -0,0 +1,39 @@
+# reference: https://docs.npmjs.com/generating-provenance-statements
+
+name: Publish
+
+on:
+  push:
+    tags:
+      - '*'
+
+jobs:
+  publish:
+    runs-on: ubuntu-latest
+    permissions:
+      contents: read
+      id-token: write
+
+    steps:
+      - name: Checkout repository
+        uses: actions/checkout@v4
+
+      - name: Install Bun
+        uses: oven-sh/setup-bun@v2
+
+      - name: Install dependencies
+        run: bun install
+
+      - name: Compile project
+        run: bun run compile
+
+      - name: Use Node.js 20
+        uses: actions/setup-node@v4
+        with:
+          node-version: 20
+          registry-url: 'https://registry.npmjs.org'
+
+      - name: Publish package
+        run: npm publish --provenance --access public
+        env:
+          NODE_AUTH_TOKEN: ${{ secrets.NPM_TOKEN }}

.gitignore

@@ -0,0 +1,34 @@
+# dependencies (bun install)
+node_modules
+
+# output
+out
+dist
+*.tgz
+
+# code coverage
+coverage
+*.lcov
+
+# logs
+logs
+_.log
+report.[0-9]_.[0-9]_.[0-9]_.[0-9]_.json
+
+# dotenv environment variable files
+.env
+.env.development.local
+.env.test.local
+.env.production.local
+.env.local
+
+# caches
+.eslintcache
+.cache
+*.tsbuildinfo
+
+# IntelliJ based IDEs
+.idea
+
+# Finder (MacOS) folder config
+.DS_Store

LICENSE

@@ -0,0 +1,21 @@
+The MIT License (MIT)
+
+Copyright (c) 2025-present Guillermo Rauch and Socket.IO contributors
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in
+all copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
+THE SOFTWARE.

README.md

@@ -0,0 +1,29 @@
+# @socket.io/bun-engine
+
+## How to use
+
+```js
+import { Server as Engine } from "@socket.io/bun-engine";
+import { Server } from "socket.io";
+
+const io = new Server();
+
+const engine = new Engine({
+  path: "/socket.io/",
+});
+
+io.bind(engine);
+
+Bun.serve({
+  ...engine.handler(),
+  port: 3000,
+});
+
+io.on("connection", (socket) => {
+  // ...
+});
+```
+
+## License
+
+[MIT](/LICENSE)

bun.lock

@@ -0,0 +1,99 @@
+type OriginOption = boolean | string | RegExp | (string | RegExp)[];
+
+export interface CorsOptions {
+  origin?: OriginOption;
+  methods?: string | string[];
+  allowedHeaders?: string | string[];
+  exposedHeaders?: string | string[];
+  credentials?: boolean;
+  maxAge?: number;
+}
+
+export function addCorsHeaders(
+  headers: Headers,
+  opts: CorsOptions,
+  req: Request,
+) {
+  addOrigin(opts, headers, req);
+  addCredentials(opts, headers);
+  addExposedHeaders(opts, headers);
+
+  if (req.method === "OPTIONS") {
+    addMethods(opts, headers);
+    addAllowedHeaders(opts, headers, req);
+    addMaxAge(opts, headers);
+  }
+}
+
+function join(arg: string | string[]) {
+  return Array.isArray(arg) ? arg.join(",") : arg;
+}
+
+function isOriginAllowed(allowedOrigin: OriginOption, origin: string): boolean {
+  if (Array.isArray(allowedOrigin)) {
+    for (let i = 0; i < allowedOrigin.length; i++) {
+      if (isOriginAllowed(allowedOrigin[i]!, origin)) {
+        return true;
+      }
+    }
+    return false;
+  } else if (typeof allowedOrigin === "string") {
+    return allowedOrigin === origin;
+  } else if (allowedOrigin instanceof RegExp) {
+    return allowedOrigin.test(origin);
+  } else {
+    return !!allowedOrigin;
+  }
+}
+
+function addOrigin(opts: CorsOptions, headers: Headers, req: Request) {
+  const origin = req.headers.get("origin")!;
+  const allowedOrigin = opts.origin;
+
+  if (!allowedOrigin || allowedOrigin === "*") {
+    headers.set("Access-Control-Allow-Origin", "*");
+  } else if (typeof allowedOrigin === "string") {
+    headers.set("Access-Control-Allow-Origin", allowedOrigin);
+    headers.append("Vary", "Origin");
+  } else {
+    const isAllowed = isOriginAllowed(allowedOrigin, origin);
+    headers.set("Access-Control-Allow-Origin", isAllowed ? origin : "false");
+    headers.append("Vary", "Origin");
+  }
+}
+
+function addMethods(opts: CorsOptions, headers: Headers) {
+  if (opts.methods) {
+    headers.set("Access-Control-Allow-Methods", join(opts.methods));
+  }
+}
+
+function addAllowedHeaders(opts: CorsOptions, headers: Headers, req: Request) {
+  if (opts.allowedHeaders) {
+    headers.set("Access-Control-Allow-Headers", join(opts.allowedHeaders));
+    return;
+  }
+  const requestedHeaders = req.headers.get("access-control-request-headers");
+  if (requestedHeaders) {
+    headers.append("Vary", "Access-Control-Request-Headers");
+    headers.set("Access-Control-Allow-Headers", requestedHeaders);
+  }
+}
+
+function addExposedHeaders(opts: CorsOptions, headers: Headers) {
+  if (opts.exposedHeaders) {
+    headers.set("Access-Control-Expose-Headers", join(opts.exposedHeaders));
+  }
+}
+
+function addCredentials(opts: CorsOptions, headers: Headers) {
+  if (opts.credentials) {
+    headers.set("Access-Control-Allow-Credentials", "true");
+  }
+}
+
+function addMaxAge(opts: CorsOptions, headers: Headers) {
+  if (opts.maxAge) {
+    headers.set("Access-Control-Max-Age", opts.maxAge.toString());
+  }
+}