Add dummy ctx to bun/deno/node

Author: lauriro

lib/bun.mjs

@@ -1,6 +1,5 @@
 
-import { worker } from './worker.mjs'
-import { httpsRedirect, readCert } from './env.mjs'
+import { httpsRedirect, readCert, worker } from './env.mjs'
 
 
 var listen = (app, env = {}) => {

lib/deno.mjs

@@ -1,6 +1,5 @@
 
-import { worker } from './worker.mjs'
-import { httpsRedirect, readCert } from './env.mjs'
+import { httpsRedirect, readCert, worker } from './env.mjs'
 
 
 var listen = (app, env = {}) => {

lib/env.mjs

@@ -2,6 +2,7 @@
 import { readdirSync, readFileSync } from 'node:fs'
 import { join } from 'node:path'
 import { isArr, isFn } from '../util.mjs'
+import { worker as sharedWorker } from './worker.mjs'
 
 
 var loadEnv = (file, rest) => {
@@ -77,9 +78,11 @@ var loadEnv = (file, rest) => {
 		opts.onReload?.()
 	})
 }
+, ctx = { waitUntil() {} }
+, worker = (app, env, handle = sharedWorker(app, env)) => (req, e) => handle(req, e, ctx)
 
 export * from './shim-cloudflare.mjs'
 export { Database as DB } from '#sqlite'
 export { serveRange, serveStatic } from './serve.mjs'
-export { httpsRedirect, loadEnv, readCert, readFiles, setupShutdown }
+export { httpsRedirect, loadEnv, readCert, readFiles, setupShutdown, worker }
 

lib/node.mjs

@@ -2,8 +2,7 @@
 import { createServer } from 'node:http'
 import { createServer as createSecureServer } from 'node:https'
 import { Readable } from 'node:stream'
-import { worker } from './worker.mjs'
-import { httpsRedirect, readCert } from './env.mjs'
+import { httpsRedirect, readCert, worker } from './env.mjs'
 
 
 var listen = (app, env = {}) => {

test/adapters.mjs

@@ -155,6 +155,7 @@ describe('{0} adapter', !skip && [
 
 		var app = App()
 		app.get('x', () => name)
+		app.get('defer', (req, env, ctx) => (ctx.waitUntil(Promise.resolve()), name))
 		var env = loadEnv(null, { HOSTNAME: 'test.litejs.com', PORT: 1234 })
 		, server = lib.listen(app, env)
 
@@ -166,6 +167,9 @@ describe('{0} adapter', !skip && [
 		var res = await calls[0].fetch(new Request('http://localhost/x'))
 		assert.equal(await res.text(), name, 'serve handler routes through the app')
 
+		var deferred = await calls[0].fetch(new Request('http://localhost/defer'))
+		assert.equal(await deferred.text(), name, 'ctx.waitUntil is wired (no-op off Workers)')
+
 		server.close()
 		assert.equal(stop.called, 1, 'close() stops the single listener')
 		server.reload() // without a TLS listener reload is a no-op