feat: support spinning up in-memory mongo server for local development

Author: TillaTheHun0

.gitignore

@@ -0,0 +1 @@
+__hyper__

deno.lock

@@ -9,6 +9,9 @@ export * as R from 'npm:[email protected]'
 export { EJSON } from 'npm:[email protected]'
 export { type Collection, MongoClient } from 'npm:[email protected]'
 export { default as cuid } from 'npm:[email protected]'
+export { MongoMemoryServer } from 'npm:[email protected]'
+
+export { join } from 'https://deno.land/[email protected]/path/mod.ts'
 
 import {
   HyperErr,

deps.ts

@@ -1,10 +1,12 @@
+import { MongoMemoryServer, join } from './deps.ts'
 import type { AdapterConfig } from './types.ts'
 import PORT_NAME from './port_name.ts'
 
 import { AtlasDataClient } from './clients/atlas-data.ts'
 import { NativeClient } from './clients/native.ts'
 import type { MongoInstanceClient } from './clients/types.ts'
 
+import { mkdir } from './utils.ts'
 import { adapter } from './adapter.ts'
 import { MetaDb } from './meta.ts'
 
@@ -15,11 +17,31 @@ export default (config: AdapterConfig) => ({
   id: 'mongodb',
   port: PORT_NAME,
   load: async () => {
-    const url = new URL(config.url)
+    let url: URL
+    /**
+     * Dynamically create an in memory database
+     */
+    if (config.dir) {
+      const mongoMsDir = join(config.dir, 'mongoms')
+      await mkdir(join(mongoMsDir, 'data'))
+      /**
+       * See https://github.com/nodkz/mongodb-memory-server#available-options-for-mongomemoryserver
+       * for available options.
+       * 
+       * Other options may
+       */
+      url = await MongoMemoryServer.create({
+        instance: { dbPath: join(mongoMsDir, 'data'), storageEngine: 'wiredTiger' },
+        binary: { downloadDir: mongoMsDir, version: config.dirVersion }
+      }).then(mongod => new URL(mongod.getUri()))
+      console.log(`In-Memory MongoDB: ${url.toString()}`)
+    } else {
+      url = new URL(config.url as string)
+    }
     let client: NativeClient | AtlasDataClient
 
     if (isNative(url)) {
-      client = new NativeClient({ url: config.url })
+      client = new NativeClient({ url: url.toString() })
       await client.connect()
     } else if (isAtlas(url)) {
       if (!config.options?.atlas) {
@@ -29,7 +51,7 @@ export default (config: AdapterConfig) => ({
       }
       client = new AtlasDataClient({
         ...config.options.atlas,
-        endpoint: config.url,
+        endpoint: url.toString(),
         fetch,
       })
     } else {

mod.ts

@@ -1,5 +1,5 @@
 // Harness deps
-import { default as hyper } from 'https://raw.githubusercontent.com/hyper63/hyper/hyper%40v4.3.1/packages/core/mod.ts'
+import { default as hyper } from 'https://raw.githubusercontent.com/hyper63/hyper/hyper%40v4.3.2/packages/core/mod.ts'
 import { default as app } from 'https://raw.githubusercontent.com/hyper63/hyper/hyper-app-express%40v1.2.1/packages/app-express/mod.ts'
 
 import mongo from '../mod.ts'

test/hyper.ts

@@ -1,11 +1,16 @@
 export type AdapterConfig = {
-  url: string
+  url?: string
   options?: {
     atlas?: {
       dataSource: string
       auth: EmailPasswordAuthOptions | ApiKeyAuthOptions | CustomJwtAuthOptions
     }
-  }
+  },
+  /**
+   * config when wanting to use an in-memory Mongo instance
+   */
+  dir?: string,
+  dirVersion?: string
 }
 
 // deno-lint-ignore no-explicit-any

types.ts

@@ -3,6 +3,20 @@ import { crocks, HyperErr, isHyperErr, R } from './deps.ts'
 const { map, omit, ifElse, evolve, applyTo, propOr, always } = R
 const { Async } = crocks
 
+export async function mkdir(dir: string) {
+  try {
+    return await Deno.mkdir(dir, { recursive: true })
+  } catch (err) {
+    if (err instanceof Deno.errors.AlreadyExists) {
+      // already exists so return
+      return true
+    } else {
+      // unexpected error, maybe permissions, pass it along
+      throw err
+    }
+  }
+}
+
 export const handleHyperErr = ifElse(
   isHyperErr,
   Async.Resolved,