feat: sls use lz4-napi

Author: crimson-gao

alibabacloud-gateway-sls/ts/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@alicloud/gateway-sls",
-  "version": "0.3.0",
+  "version": "0.3.1",
   "description": "",
   "main": "dist/client.js",
   "scripts": {
@@ -29,7 +29,7 @@
     "@alicloud/darabonba-array": "^0.1.0",
     "@alicloud/darabonba-encode-util": "^0.0.2",
     "@alicloud/darabonba-signature-util": "^0.0.4",
-    "@alicloud/gateway-sls-util": "^0.3.0"
+    "@alicloud/gateway-sls-util": "^0.3.1"
   },
   "files": [
     "dist",

alibabacloud-gateway-sls/util/ts/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@alicloud/gateway-sls-util",
-  "version": "0.3.0",
+  "version": "0.3.1",
   "description": "",
   "main": "dist/client.js",
   "scripts": {
@@ -12,15 +12,14 @@
   "author": "",
   "license": "ISC",
   "devDependencies": {
-    "@types/lz4": "^0.6.4",
     "@types/node": "^12.12.26",
     "nyc": "^15.0.0",
     "source-map-support": "^0.5.16",
     "ts-node": "^8.6.2",
     "typescript": "^3.7.5"
   },
   "dependencies": {
-    "lz4": "^0.6.5"
+    "lz4-napi": "^2.9.0"
   },
   "files": [
     "dist",

alibabacloud-gateway-sls/util/ts/src/compress.ts

@@ -1,12 +1,10 @@
-import lz4 from 'lz4';
+import {compress as napiLz4Compress} from 'lz4-napi';
 import zlib from 'zlib';
 
 const supportedCompressor = ['lz4', 'gzip', 'deflate']
 
 export async function lz4Compress(data: Buffer): Promise<Buffer> {
-    const output = Buffer.alloc(lz4.encodeBound(data.length));
-    const n = lz4.encodeBlock(data, output);
-    return Buffer.from(output.slice(0, n));
+    return await napiLz4Compress(data);
 }
 
 export async function gzipCompress(data: Buffer): Promise<Buffer> {

alibabacloud-gateway-sls/util/ts/src/decompress.ts

@@ -1,6 +1,6 @@
 import { Readable } from 'stream';
 import { readableStreamToBuffer } from './common';
-import lz4 from 'lz4';
+import {uncompress as napiLz4Uncompress} from 'lz4-napi';
 import zlib from 'zlib';
 
 const supportedDecompressor = ['lz4', 'gzip', 'deflate']
@@ -10,12 +10,11 @@ export async function isDecompressorAvailable(compressType: string): Promise<boo
 }
 
 export async function lz4Decompress(input: Readable, bodyRawSize: number): Promise<Buffer> {
-    const output = Buffer.alloc(bodyRawSize);
-    const n = lz4.decodeBlock(await readableStreamToBuffer(input), output);
-    if (n !== bodyRawSize) {
-        return Buffer.from(output.slice(0, n));
+    const napiOutput = await napiLz4Uncompress(await readableStreamToBuffer(input));
+    if (napiOutput.length !== bodyRawSize) {
+        return Buffer.from(napiOutput.slice(0, bodyRawSize));
     }
-    return output;
+    return napiOutput;
 }
 
 export async function gzipDecompress(input: Readable, bodyRawSize: number): Promise<Buffer> {