Add LZMA Decompress operation
This commit is contained in:
parent
1ec7033d46
commit
d502dd9857
@ -330,8 +330,9 @@
|
|||||||
"Bzip2 Compress",
|
"Bzip2 Compress",
|
||||||
"Tar",
|
"Tar",
|
||||||
"Untar",
|
"Untar",
|
||||||
"LZString Compress",
|
|
||||||
"LZString Decompress",
|
"LZString Decompress",
|
||||||
|
"LZString Compress",
|
||||||
|
"LZMA Decompress",
|
||||||
"LZMA Compress"
|
"LZMA Compress"
|
||||||
]
|
]
|
||||||
},
|
},
|
||||||
|
@ -44,8 +44,9 @@ class LZMACompress extends Operation {
|
|||||||
* @returns {ArrayBuffer}
|
* @returns {ArrayBuffer}
|
||||||
*/
|
*/
|
||||||
run(input, args) {
|
run(input, args) {
|
||||||
|
const mode = Number(args[0]);
|
||||||
return new Promise((resolve, reject) => {
|
return new Promise((resolve, reject) => {
|
||||||
compress(new Uint8Array(input), Number(args[0]), (result, error) => {
|
compress(new Uint8Array(input), mode, (result, error) => {
|
||||||
if (error) {
|
if (error) {
|
||||||
reject(new OperationError(`Failed to compress input: ${error.message}`));
|
reject(new OperationError(`Failed to compress input: ${error.message}`));
|
||||||
}
|
}
|
||||||
|
51
src/core/operations/LZMADecompress.mjs
Normal file
51
src/core/operations/LZMADecompress.mjs
Normal file
@ -0,0 +1,51 @@
|
|||||||
|
/**
|
||||||
|
* @author Matt C [me@mitt.dev]
|
||||||
|
* @copyright Crown Copyright 2022
|
||||||
|
* @license Apache-2.0
|
||||||
|
*/
|
||||||
|
|
||||||
|
import Operation from "../Operation.mjs";
|
||||||
|
import OperationError from "../errors/OperationError.mjs";
|
||||||
|
import {decompress} from "@blu3r4y/lzma";
|
||||||
|
|
||||||
|
/**
|
||||||
|
* LZMA Decompress operation
|
||||||
|
*/
|
||||||
|
class LZMADecompress extends Operation {
|
||||||
|
|
||||||
|
/**
|
||||||
|
* LZMADecompress constructor
|
||||||
|
*/
|
||||||
|
constructor() {
|
||||||
|
super();
|
||||||
|
|
||||||
|
this.name = "LZMA Decompress";
|
||||||
|
this.module = "Compression";
|
||||||
|
this.description = "Decompresses data using the Lempel-Ziv-Markov chain Algorithm.";
|
||||||
|
this.infoURL = "https://wikipedia.org/wiki/Lempel%E2%80%93Ziv%E2%80%93Markov_chain_algorithm";
|
||||||
|
this.inputType = "ArrayBuffer";
|
||||||
|
this.outputType = "ArrayBuffer";
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @param {ArrayBuffer} input
|
||||||
|
* @param {Object[]} args
|
||||||
|
* @returns {ArrayBuffer}
|
||||||
|
*/
|
||||||
|
run(input, args) {
|
||||||
|
return new Promise((resolve, reject) => {
|
||||||
|
decompress(new Uint8Array(input), (result, error) => {
|
||||||
|
if (error) {
|
||||||
|
reject(new OperationError(`Failed to decompress input: ${error.message}`));
|
||||||
|
}
|
||||||
|
// The decompression returns as an Int8Array, but we can just get the unsigned data from the buffer
|
||||||
|
resolve(new Int8Array(result).buffer);
|
||||||
|
}, (percent) => {
|
||||||
|
self.sendStatusMessage(`Decompressing input: ${(percent*100).toFixed(2)}%`);
|
||||||
|
});
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
export default LZMADecompress;
|
Loading…
x
Reference in New Issue
Block a user