swtor/ssn
0
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

🚧 Change streamToArraybuffer to return Buffer for better debuggin

Browse source
This commit is contained in:
C-3PO 2018-07-08 20:26:17 +02:00
parent 695ee74e72
commit 7b5cdd5498
Signed by: c3po
GPG key ID: 62993C4BB4D86F24
2 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/ssn/getPatch.ts
View file

@ -40,7 +40,7 @@ export default async function getPatch(product: Product, from: number, to: numbe
fileEntries.filter((file) => file.diffType === SsnDiffType.NewFile).forEach(async (file) => {
try {
const fileStream = await getFileFromDisks(diskFilenames, { diskStart: file.diskNumberStart, offset: file.offset, length: file.compressedSize });
const fileContents = extractFileStream(file, fileStream);
const fileContents = extractFileStream(file, fileStream, true);
console.debug(file.name, file.compressedSize, await streamToArrayBuffer(fileContents));
//TODO: need to write to disk
} catch (error) {
@ -52,7 +52,7 @@ export default async function getPatch(product: Product, from: number, to: numbe
fileEntries.filter((file) => file.diffType === SsnDiffType.Changed).forEach(async (file) => {
try {
const fileStream = await getFileFromDisks(diskFilenames, { diskStart: file.diskNumberStart, offset: file.offset, length: file.compressedSize });
const fileContents = extractFileStream(file, fileStream);
const fileContents = extractFileStream(file, fileStream, true);
console.debug(file.name, file.compressedSize, await streamToArrayBuffer(fileContents));
//TODO: need to apply diffing, then write to disk
} catch (error) {

4
src/ssn/streams/streamToArrayBuffer.ts
View file

@ -1,6 +1,6 @@
import * as stream from 'stream';
export default function streamToArrayBuffer(inputStream: stream.Readable): Promise<ArrayBuffer> {
export default function streamToArrayBuffer(inputStream: stream.Readable): Promise<Buffer> {
return new Promise((resolve, reject) => {
const chunks: Buffer[] = [];
let totalSize = 0;
@ -14,7 +14,7 @@ export default function streamToArrayBuffer(inputStream: stream.Readable): Promi
//Output final string
inputStream.on('end', () => {
const outBuffer = Buffer.concat(chunks, totalSize);
resolve(outBuffer.buffer as ArrayBuffer);
resolve(outBuffer);
});
//Exit on error