fix: read stream without streamify

lidofinance · Feb 16, 2024 · 9bc22c8 · 9bc22c8
1 parent 3a9f4fd
commit 9bc22c8
Showing 1 changed file with 23 additions and 15 deletions.
diff --git a/src/http/sr-modules-operators-keys/sr-modules-operators-keys.controller.ts b/src/http/sr-modules-operators-keys/sr-modules-operators-keys.controller.ts
@@ -122,21 +122,29 @@ export class SRModulesOperatorsKeysController {
 
     reply.type('application/json').send(jsonStream);
 
-    try {
-      await this.entityManager.transactional(
-        () => pipeline([streamify(this.srModulesOperatorsKeys.getModulesOperatorsKeysGenerator()), jsonStream]),
-        { isolationLevel: IsolationLevel.REPEATABLE_READ },
-      );
-    } catch (error) {
-      jsonStream.destroy();
+    const generator = await this.srModulesOperatorsKeys.getModulesOperatorsKeysGenerator();
 
-      if (error instanceof Error) {
-        const message = error.message;
-        const stack = error.stack;
-        this.logger.error(`modules-operators-keys error: ${message}`, stack);
-      } else {
-        this.logger.error('modules-operators-keys unknown error');
-      }
-    }
+    await this.entityManager.transactional(
+      async () => {
+        try {
+          for await (const value of generator) {
+            jsonStream.write(value);
+          }
+
+          jsonStream.end();
+        } catch (error) {
+          if (error instanceof Error) {
+            const message = error.message;
+            const stack = error.stack;
+            this.logger.error(`modules-operators-keys error: ${message}`, stack);
+          } else {
+            this.logger.error('modules-operators-keys unknown error');
+          }
+
+          jsonStream.destroy();
+        }
+      },
+      { isolationLevel: IsolationLevel.REPEATABLE_READ },
+    );
   }
 }