test: compiling now

Author: durran

Cargo.toml

@@ -13,7 +13,13 @@ napi = { version = "2.1.0", default-features = false, features = [
   "async"
 ] }
 napi-derive = "2.1.0"
-zstd = "0.10.0+zstd.1.5.2"
+async-compression = { version = "0.3.12", features = [
+  "tokio",
+  "zstd"
+] }
+tokio = { version = "1", features = [
+  "full"
+] }
 
 [build-dependencies]
 napi-build = "1.2.1"

src/lib.rs

@@ -1,14 +1,28 @@
 #[macro_use]
 extern crate napi_derive;
+extern crate tokio;
 
 use napi::bindgen_prelude::*;
+use async_compression::tokio::bufread::ZstdDecoder;
+use async_compression::tokio::write::ZstdEncoder;
+use tokio::io::AsyncReadExt as _;
+use tokio::io::AsyncWriteExt as _;
+use tokio::io::{BufReader, BufWriter};
 
 #[napi]
 async fn compress(buffer: Buffer) -> Result<Buffer> {
-  Ok(buffer)
+  let input: Vec<u8> = buffer.into();
+  let mut encoder = ZstdEncoder::new(BufWriter::new(input));
+  let mut output: Vec<u8> = vec![];
+  encoder.write_all(&mut output).await?;
+  Ok(Buffer::from(output))
 }
 
 #[napi]
 async fn decompress(buffer: Buffer) -> Result<Buffer> {
-  Ok(buffer)
+  let input: Vec<u8> = buffer.into();
+  let mut decoder = ZstdDecoder::new(BufReader::new(input.as_slice()));
+  let mut output: Vec<u8> = vec![];
+  decoder.read_to_end(&mut output).await?;
+  Ok(Buffer::from(output))
 }

test/debug.js

@@ -0,0 +1,10 @@
+const { compress, decompress } = require('../index');
+
+async function run() {
+    const buffer = Buffer.from('test');
+    const compressed = await compress(buffer);
+    const decompressed = await decompress(compressed);
+    console.log(compressed, decompressed);
+}
+
+run();

test/index.test.js

@@ -5,7 +5,7 @@ describe('zstd', () => {
   describe('#compress', () => {
     const buffer = Buffer.from('test');
 
-    it('returns the buffer', async () => {
+    it('returns a compressed buffer', async () => {
       const result = await compress(buffer);
       expect(result).to.deep.equal(buffer);
     });