feat(packages): add @stenodb/fastify

Author: crashmax-dev

examples/with-fastify/nodemon.json

@@ -0,0 +1,8 @@
+{
+  "watch": [
+    "src"
+  ],
+  "ignore": ["database", "dist"],
+  "exec": "cross-env TS_NODE_TRANSPILE_ONLY=true NODE_ENV=development node --no-warnings --loader ts-node/esm --enable-source-maps --trace-warnings --inspect=0.0.0.0:9234 --nolazy src/index.ts",
+  "ext": "ts"
+}

examples/with-fastify/package.json

@@ -0,0 +1,19 @@
+{
+  "name": "with-fastify",
+  "type": "module",
+  "private": true,
+  "scripts": {
+    "start": "pnpm build && node dist/index.js",
+    "dev": "nodemon",
+    "build": "rm -rf dist && tsc"
+  },
+  "dependencies": {
+    "@stenodb/fastify": "workspace:*",
+    "class-transformer": "0.5.1",
+    "fastify": "4.13.0",
+    "reflect-metadata": "0.1.13"
+  },
+  "devDependencies": {
+    "@types/node": "18.11.19"
+  }
+}

examples/with-fastify/src/entities.ts

@@ -0,0 +1,38 @@
+import { Type } from 'class-transformer'
+
+export class Users {
+  @Type(() => User)
+  users: User[]
+
+  constructor(...users: User[]) {
+    this.users = users
+  }
+}
+
+export class User {
+  username: string
+
+  @Type(() => Post)
+  posts: Post[]
+
+  constructor(username: string, ...posts: Post[]) {
+    this.username = username
+    this.posts = posts
+  }
+
+  addPost(post: Post) {
+    this.posts.push(post)
+  }
+}
+
+export class Post {
+  title: string
+
+  constructor(title: string) {
+    this.title = title
+  }
+
+  changeTitle(title: string) {
+    this.title = title
+  }
+}

examples/with-fastify/src/index.ts

@@ -0,0 +1,24 @@
+import 'reflect-metadata'
+import { dirname, resolve } from 'node:path'
+import { fileURLToPath } from 'node:url'
+import { FastifySteno } from '@stenodb/fastify'
+import Fastify from 'fastify'
+import { Post, User, Users } from './entities.js'
+
+const fastify = Fastify()
+const path = resolve(dirname(fileURLToPath(import.meta.url)), '..', 'db')
+
+fastify.register(FastifySteno, { path })
+
+fastify.get('/', async (req, rep) => {
+  const users = fastify.steno.get<Users>('users')
+  return users?.data
+})
+
+fastify.listen({ host: '0.0.0.0', port: 3000 }, async (err, address) => {
+  if (err) throw err
+
+  await fastify.steno.create('users', Users, new Users(new User('John')))
+
+  console.log(address)
+})

examples/with-fastify/tsconfig.json

@@ -0,0 +1,11 @@
+{
+  "extends": "@crashmax/tsconfig",
+  "compilerOptions": {
+    "experimentalDecorators": true,
+    "emitDecoratorMetadata": true,
+    "outDir": "dist"
+  },
+  "include": [
+    "src"
+  ]
+}

packages/fastify/package.json

@@ -0,0 +1,37 @@
+{
+  "name": "@stenodb/fastify",
+  "version": "3.3.2",
+  "exports": {
+    ".": {
+      "types": "./dist/index.d.ts",
+      "require": "./dist/index.js",
+      "default": "./dist/index.mjs"
+    }
+  },
+  "types": "./dist/index.d.ts",
+  "main": "./dist/index.js",
+  "module": "./dist/index.mjs",
+  "files": [
+    "dist",
+    "src"
+  ],
+  "scripts": {
+    "dev": "pnpm build -- --watch src",
+    "build": "tsup src/index.ts --format esm,cjs --dts --clean"
+  },
+  "dependencies": {
+    "@stenodb/node": "workspace:3.3.2",
+    "fastify-plugin": "4.5.0"
+  },
+  "devDependencies": {
+    "@types/node": "18.11.19",
+    "fastify": "^4.13.0"
+  },
+  "peerDependencies": {
+    "@stenodb/node": "workspace:3.3.2",
+    "fastify": "^4.0.0"
+  },
+  "engines": {
+    "node": ">=14.16"
+  }
+}

packages/fastify/src/index.ts

@@ -0,0 +1,44 @@
+import { AsyncAdapter, NodeProvider } from '@stenodb/node'
+import fp from 'fastify-plugin'
+import type { Steno } from '@stenodb/node'
+import type { FastifyInstance } from 'fastify'
+import './types.js'
+
+function fastifyPlugin(
+  fastify: FastifyInstance,
+  options: Steno.NodeProviderOptions,
+  next: () => void
+) {
+  const database = new Map<string, Steno.NodeProvider<unknown>>()
+  const provider = new NodeProvider(options)
+
+  async function createDatabase<T>(
+    name: string,
+    entity: Steno.Entity<T>,
+    initialData?: T
+  ): Promise<void> {
+    const adapter = new AsyncAdapter(name, entity, initialData)
+    const db = await provider.create(adapter)
+    await db.read()
+    database.set(name, db)
+  }
+
+  function getDatabase<T>(name: string): Steno.NodeProvider<T> | undefined {
+    return database.get(name) as Steno.NodeProvider<T>
+  }
+
+  fastify.decorate('steno', {
+    create: createDatabase,
+    get: getDatabase
+  })
+
+  next()
+}
+
+const FastifySteno = fp(fastifyPlugin, {
+  name: '@stenodb/fastify',
+  fastify: '4.x'
+})
+
+export { FastifySteno }
+export default fastifyPlugin

packages/fastify/src/types.ts

@@ -0,0 +1,14 @@
+import type { NodeProvider, Steno } from '@stenodb/node'
+
+declare module 'fastify' {
+  export interface FastifyInstance {
+    steno: {
+      create: <T>(
+        name: string,
+        entity: Steno.Entity<T>,
+        initialData?: T
+      ) => Promise<void>
+      get: <T>(name: string) => Steno.NodeProvider<T> | undefined
+    }
+  }
+}

packages/fastify/tsconfig.json

@@ -0,0 +1,9 @@
+{
+  "extends": "@crashmax/tsconfig",
+  "compilerOptions": {
+    "outDir": "dist"
+  },
+  "include": [
+    "src"
+  ]
+}