[enh] rewriting stream/auth_request with an async callback

Author: xeioex

README.rst

@@ -1338,14 +1338,16 @@ example.js:
   function preread_verify(s) {
       var collect = '';
 
-      s.on('upload', function (data, flags) {
+      s.on('upload', async function (data, flags) {
           collect += data;
 
           if (collect.length >= 5 && collect.startsWith('MAGiK')) {
               s.off('upload');
-              ngx.fetch('http://127.0.0.1:8080/validate',
-                        {body: collect.slice(5,7), headers: {Host:'aaa'}})
-              .then(reply => (reply.status == 200) ? s.done(): s.deny())
+              let reply = ngx.fetch('http://127.0.0.1:8080/validate',
+                                    {body: collect.slice(5,7),
+                                     headers: {Host:'aaa'}});
+
+              (reply.status == 200) ? s.done(): s.deny();
 
           } else if (collect.length) {
               s.deny();

njs/stream/auth_request.js

@@ -1,14 +1,17 @@
 function preread_verify(s) {
     var collect = '';
 
-    s.on('upload', function (data, flags) {
+    s.on('upload', async function (data, flags) {
         collect += data;
 
         if (collect.length >= 5 && collect.startsWith('MAGiK')) {
             s.off('upload');
-            ngx.fetch('http://127.0.0.1:8080/validate',
-                      {body: collect.slice(5,7), headers: {Host:'aaa'}})
-            .then(reply => (reply.status == 200) ? s.done(): s.deny())
+
+            let reply = await ngx.fetch('http://127.0.0.1:8080/validate',
+                                        {body: collect.slice(5,7),
+                                         headers: {Host:'aaa'}});
+
+            (reply.status == 200) ? s.done(): s.deny();
 
         } else if (collect.length) {
             s.deny();