pkgs/cloudflare-workers
pkgs/cloudflare-workers
1
0
Fork 0
mirror of https://github.com/syumai/workers.git synced 2025-03-10 17:29:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

remove reqObj from runHonoMiddleware func parameters

Browse Source
This commit is contained in:
syumai 2024-02-11 19:51:22 +09:00
parent 8cf026a01b
commit d9dc0f1480
1 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
exp/hono/middleware.go
View File

@ -32,17 +32,16 @@ func ChainMiddlewares(middlewares ...Middleware) Middleware {
func init() { func init() {
runHonoMiddlewareCallback := js.FuncOf(func(_ js.Value, args []js.Value) any { runHonoMiddlewareCallback := js.FuncOf(func(_ js.Value, args []js.Value) any {
if len(args) > 2 { if len(args) > 1 {
panic(fmt.Errorf("too many args given to handleRequest: %d", len(args))) panic(fmt.Errorf("too many args given to handleRequest: %d", len(args)))
} }
reqObj := args[0] nextFnObj := args[0]
nextFnObj := args[1]
var cb js.Func var cb js.Func
cb = js.FuncOf(func(_ js.Value, pArgs []js.Value) any { cb = js.FuncOf(func(_ js.Value, pArgs []js.Value) any {
defer cb.Release() defer cb.Release()
resolve := pArgs[0] resolve := pArgs[0]
go func() { go func() {
err := runHonoMiddleware(reqObj, nextFnObj) err := runHonoMiddleware(nextFnObj)
if err != nil { if err != nil {
panic(err) panic(err)
} }
@ -55,11 +54,11 @@ func init() {
jsutil.Binding.Set("runHonoMiddleware", runHonoMiddlewareCallback) jsutil.Binding.Set("runHonoMiddleware", runHonoMiddlewareCallback)
} }
func runHonoMiddleware(reqObj, nextFnObj js.Value) error { func runHonoMiddleware(nextFnObj js.Value) error {
if middleware == nil { if middleware == nil {
return fmt.Errorf("ServeMiddleware must be called before runHonoMiddleware.") return fmt.Errorf("ServeMiddleware must be called before runHonoMiddleware.")
} }
c := newContext(reqObj) c := newContext(jsutil.RuntimeContext)
next := func() { next := func() {
jsutil.AwaitPromise(nextFnObj.Invoke()) jsutil.AwaitPromise(nextFnObj.Invoke())
} }