fix: use promisified pipeline from stream

server/core/system.js

@@ -4,7 +4,8 @@ const Promise = require('bluebird')
 const fs = require('fs-extra')
 const path = require('path')
 const zlib = require('zlib')
-const { pipeline, Readable, Transform } = require('stream')
+const { pipeline } = require('node:stream/promises')
+const { Readable, Transform } = require('node:stream')
 
 /* global WIKI */
 

server/modules/search/algolia/engine.js

@@ -1,6 +1,7 @@
 const _ = require('lodash')
 const algoliasearch = require('algoliasearch')
-const { pipeline, Transform } = require('stream')
+const { pipeline } = require('node:stream/promises')
+const { Transform } = require('node:stream')
 
 /* global WIKI */
 

server/modules/search/aws/engine.js

@@ -1,6 +1,7 @@
 const _ = require('lodash')
 const AWS = require('aws-sdk')
-const { pipeline, Transform } = require('stream')
+const { pipeline } = require('node:stream/promises')
+const { Transform } = require('node:stream')
 
 /* global WIKI */
 

server/modules/search/azure/engine.js

@@ -1,7 +1,8 @@
 const _ = require('lodash')
 const { SearchService, QueryType } = require('azure-search-client')
 const request = require('request-promise')
-const { pipeline, Transform } = require('stream')
+const { pipeline } = require('node:stream/promises')
+const { Transform } = require('node:stream')
 
 /* global WIKI */
 

server/modules/search/elasticsearch/engine.js

@@ -1,6 +1,7 @@
 const _ = require('lodash')
 const fs = require('fs')
-const { pipeline, Transform } = require('stream')
+const { pipeline } = require('node:stream/promises')
+const { Transform } = require('node:stream')
 
 /* global WIKI */
 

server/modules/search/postgres/engine.js

@@ -1,5 +1,6 @@
 const tsquery = require('pg-tsquery')()
-const { pipeline, Transform } = require('stream')
+const { pipeline } = require('node:stream/promises')
+const { Transform } = require('node:stream')
 
 /* global WIKI */
 

server/modules/storage/azure/storage.js

@@ -1,5 +1,6 @@
 const { BlobServiceClient, StorageSharedKeyCredential } = require('@azure/storage-blob')
-const { pipeline, Transform } = require('stream')
+const { pipeline } = require('node:stream/promises')
+const { Transform } = require('node:stream')
 const pageHelper = require('../../../helpers/page.js')
 const _ = require('lodash')
 

server/modules/storage/disk/common.js

@@ -1,6 +1,7 @@
 const fs = require('fs-extra')
 const path = require('path')
-const { pipeline, Transform } = require('stream')
+const { pipeline } = require('stream/promises')
+const { Transform } = require('stream')
 const klaw = require('klaw')
 const mime = require('mime-types').lookup
 const _ = require('lodash')

server/modules/storage/disk/storage.js

@@ -3,7 +3,8 @@ const path = require('path')
 const tar = require('tar-fs')
 const zlib = require('zlib')
 const _ = require('lodash')
-const { pipeline, Transform } = require('stream')
+const { pipeline } = require('node:stream/promises')
+const { Transform } = require('node:stream')
 const moment = require('moment')
 
 const pageHelper = require('../../../helpers/page')

server/modules/storage/git/storage.js

@@ -2,7 +2,8 @@ const path = require('path')
 const sgit = require('simple-git')
 const fs = require('fs-extra')
 const _ = require('lodash')
-const { pipeline, Transform } = require('stream')
+const { pipeline } = require('node:stream/promises')
+const { Transform } = require('node:stream')
 const klaw = require('klaw')
 const os = require('os')
 

server/modules/storage/s3/common.js

@@ -1,5 +1,6 @@
 const S3 = require('aws-sdk/clients/s3')
-const { pipeline, Transform } = require('stream')
+const { pipeline } = require('node:stream/promises')
+const { Transform } = require('node:stream')
 const _ = require('lodash')
 const pageHelper = require('../../../helpers/page.js')
 

server/modules/storage/sftp/storage.js

@@ -1,7 +1,8 @@
 const SSH2Promise = require('ssh2-promise')
 const _ = require('lodash')
 const path = require('path')
-const { pipeline, Transform } = require('stream')
+const { pipeline } = require('node:stream/promises')
+const { Transform } = require('node:stream')
 const pageHelper = require('../../../helpers/page.js')
 
 /* global WIKI */