add a few comments

flash-oss · May 18, 2024 · d8cb868 · d8cb868
1 parent a492975
commit d8cb868
Showing 1 changed file with 18 additions and 14 deletions.
diff --git a/src/server/Allserver.js b/src/server/Allserver.js
@@ -50,6 +50,13 @@ module.exports = require("stampit")({
             await this.transport.prepareIntrospectionReply(ctx);
         },
 
+        /**
+         * This method does not throw.
+         * The `ctx.procedure` is the function to call.
+         * @param ctx
+         * @return {Promise<void>}
+         * @private
+         */
         async _callProcedure(ctx) {
             if (!isFunction(ctx.procedure)) {
                 ctx.result = {
@@ -99,24 +106,21 @@ module.exports = require("stampit")({
                     return;
                 }
                 const middleware = middlewares[0];
+                async function handleMiddlewareResult(result) {
+                    if (result !== undefined) {
+                        ctx.result = result;
+                        // Do not call any more middlewares
+                    } else {
+                        await runMiddlewares(middlewares.slice(1));
+                    }
+                }
                 try {
                     if (middleware.length > 1) {
-                        await middleware.call(this, ctx, async (result) => {
-                            if (result !== undefined) {
-                                ctx.result = result;
-                                // Do not call any more middlewares
-                            } else {
-                                await runMiddlewares(middlewares.slice(1));
-                            }
-                        });
+                        // This middleware accepts more than one argument
+                        await middleware.call(this, ctx, handleMiddlewareResult);
                     } else {
                         const result = await middleware.call(this, ctx);
-                        if (result !== undefined) {
-                            ctx.result = result;
-                            // Do not call any more middlewares
-                        } else {
-                            await runMiddlewares(middlewares.slice(1));
-                        }
+                        await handleMiddlewareResult(result);
                     }
                 } catch (err) {
                     const code = err.code || "ALLSERVER_MIDDLEWARE_ERROR";