chore: add neon serverless adapter

Author: ryanleecode

.changeset/gold-fans-draw.md

@@ -0,0 +1,5 @@
+---
+"@systemfsoftware/neon-serverless-adapter": patch
+---
+
+chore: add neon serverless adapter

packages/neon-serverless-adapter/api-extractor.json

@@ -0,0 +1,4 @@
+{
+  "$schema": "https://developer.microsoft.com/json-schemas/api-extractor/v7/api-extractor.schema.json",
+  "extends": "@systemfsoftware/api-extractor/api-extractor.json"
+}

packages/neon-serverless-adapter/package.json

@@ -0,0 +1,50 @@
+{
+  "name": "@systemfsoftware/neon-serverless-adapter",
+  "version": "0.0.0",
+  "type": "module",
+  "exports": {
+    "./package.json": "./package.json",
+    ".": {
+      "import": {
+        "@systemfsoftware/source": "./src/mod.ts",
+        "types": "./dist/esm/mod.d.ts",
+        "default": "./dist/esm/mod.js"
+      }
+    }
+  },
+  "module": "./dist/esm/mod.js",
+  "files": [
+    "dist"
+  ],
+  "tshy": {
+    "dialects": [
+      "esm"
+    ],
+    "project": "./tsconfig.build.json",
+    "exports": {
+      "./package.json": "./package.json",
+      ".": "./src/mod.ts"
+    },
+    "sourceDialects": [
+      "@systemfsoftware/source"
+    ]
+  },
+  "scripts": {
+    "prepare": "pnpm turbo build",
+    "clean": "rimraf dist .tshy .tshy-build",
+    "build": "pnpm run clean && tshy && pnpm run extract",
+    "extract": "api-extractor run"
+  },
+  "dependencies": {
+    "@effect/platform": "catalog:",
+    "drizzle-orm": "~0.34.1",
+    "@neondatabase/serverless": "^0.9.5"
+  },
+  "devDependencies": {
+    "effect": "catalog:",
+    "@systemfsoftware/api-extractor": "workspace:^"
+  },
+  "peerDependencies": {
+    "effect": "catalog:"
+  }
+}

packages/neon-serverless-adapter/src/mod.ts

@@ -0,0 +1,62 @@
+import * as Socket from '@effect/platform/Socket'
+import * as neon from '@neondatabase/serverless'
+import type { DrizzleConfig } from 'drizzle-orm'
+import { drizzle, type NeonDatabase } from 'drizzle-orm/neon-serverless'
+import { Config as C, Effect, pipe } from 'effect'
+import type { ConfigError } from 'effect/ConfigError'
+
+/**
+ * @public
+ */
+export namespace Adapter {
+  export type TSchema = Record<string, unknown>
+
+  export type DB<T extends TSchema = Record<string, never>> = NeonDatabase<T>
+  export type Options<T extends TSchema = Record<string, never>> = DrizzleConfig<T>
+  export type Pool = neon.Pool
+  export type WebSocketConstructor = Socket.WebSocketConstructor
+
+  export type Adapter<T extends TSchema = Record<string, never>> = Effect.Effect<
+    {
+      pool: Pool
+      db: DB<T>
+    },
+    ConfigError,
+    Socket.WebSocketConstructor
+  >
+
+  export type Config = Readonly<{
+    DATABASE_URL: C.Config<string>
+  }>
+}
+
+/**
+ * @public
+ */
+export function Adapter<T extends Adapter.TSchema = Record<string, never>>(
+  options?: Adapter.Options<T>,
+): Adapter.Adapter<T> {
+  return Effect.gen(function*() {
+    const connectionString = yield* Config.DATABASE_URL
+    const webSocketConstructor = yield* Socket.WebSocketConstructor
+
+    yield* Effect.sync(() => {
+      neon.neonConfig.webSocketConstructor = webSocketConstructor
+    })
+
+    const pool = yield* Effect.sync(() => new neon.Pool({ connectionString }))
+    const db = yield* Effect.sync(() => drizzle(pool, options))
+
+    return { pool, db }
+  })
+}
+
+/**
+ * @public
+ */
+export const Config: Adapter.Config = Object.freeze({
+  DATABASE_URL: pipe(
+    C.nonEmptyString('DATABASE_URL'),
+    C.withDescription('Neon database connection string'),
+  ),
+})

packages/neon-serverless-adapter/tsconfig.build.json

@@ -0,0 +1,9 @@
+{
+  "extends": "./tsconfig.json",
+  "compilerOptions": {
+    "declaration": true,
+    "sourceMap": true,
+    "declarationMap": true,
+    "stripInternal": true
+  }
+}

packages/neon-serverless-adapter/tsconfig.json

@@ -0,0 +1,8 @@
+{
+  "$schema": "https://json.schemastore.org/tsconfig",
+  "extends": "@total-typescript/tsconfig/tsc/no-dom/library-monorepo",
+  "compilerOptions": {
+    "customConditions": ["@systemfsoftware/source"]
+  },
+  "include": ["src"]
+}