fix(FastifyServer): fix fastify responding early

Snazzah · Sep 10, 2024 · 2459a91 · 2459a91
1 parent 7a5b728
commit 2459a91
Showing 1 changed file with 24 additions and 22 deletions.
diff --git a/src/servers/fastify.ts b/src/servers/fastify.ts
@@ -40,28 +40,30 @@ export class FastifyServer extends Server {
         }
       );
 
-      app.post(path, (req: any, res: any) =>
-        handler(
-          {
-            headers: req.headers,
-            body: req.body,
-            request: req,
-            response: res,
-            rawBody: req.rawBody
-          },
-          async (response) => {
-            res.status(response.status || 200);
-            if (response.headers) res.headers(response.headers);
-            if (response.files) {
-              const data = new MultipartData();
-              res.header('Content-Type', 'multipart/form-data; boundary=' + data.boundary);
-              for (const i in response.files)
-                data.attach(`files[${i}]`, response.files[i].file, response.files[i].name);
-              data.attach('payload_json', JSON.stringify(response.body));
-              res.send(Buffer.concat(data.finish()));
-            } else res.send(response.body);
-          }
-        )
+      app.post(
+        path,
+        (req: any, res: any) =>
+          void handler(
+            {
+              headers: req.headers,
+              body: req.body,
+              request: req,
+              response: res,
+              rawBody: req.rawBody
+            },
+            async (response) => {
+              res.status(response.status || 200);
+              if (response.headers) res.headers(response.headers);
+              if (response.files) {
+                const data = new MultipartData();
+                res.header('Content-Type', 'multipart/form-data; boundary=' + data.boundary);
+                for (const i in response.files)
+                  data.attach(`files[${i}]`, response.files[i].file, response.files[i].name);
+                data.attach('payload_json', JSON.stringify(response.body));
+                res.send(Buffer.concat(data.finish()));
+              } else res.send(response.body);
+            }
+          )
       );
     });
   }