mirror of
https://github.com/Maschell/JNUSLib.git
synced 2025-02-16 16:29:14 +01:00
Remove DecryptionService for now
This commit is contained in:
Maschell
parent
88c0bb8a9e
commit
53993dc8c4
@ -1,487 +0,0 @@
|
|||||||
/****************************************************************************
|
|
||||||
* Copyright (C) 2016-2018 Maschell
|
|
||||||
*
|
|
||||||
* This program is free software: you can redistribute it and/or modify
|
|
||||||
* it under the terms of the GNU General Public License as published by
|
|
||||||
* the Free Software Foundation, either version 3 of the License, or
|
|
||||||
* (at your option) any later version.
|
|
||||||
*
|
|
||||||
* This program is distributed in the hope that it will be useful,
|
|
||||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
||||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
||||||
* GNU General Public License for more details.
|
|
||||||
*
|
|
||||||
* You should have received a copy of the GNU General Public License
|
|
||||||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
||||||
****************************************************************************/
|
|
||||||
package de.mas.wiiu.jnus;
|
|
||||||
|
|
||||||
import java.io.ByteArrayOutputStream;
|
|
||||||
import java.io.File;
|
|
||||||
import java.io.FileNotFoundException;
|
|
||||||
import java.io.FileOutputStream;
|
|
||||||
import java.io.IOException;
|
|
||||||
import java.io.InputStream;
|
|
||||||
import java.io.OutputStream;
|
|
||||||
import java.io.PipedOutputStream;
|
|
||||||
import java.util.ArrayList;
|
|
||||||
import java.util.Arrays;
|
|
||||||
import java.util.List;
|
|
||||||
import java.util.concurrent.CompletableFuture;
|
|
||||||
import java.util.concurrent.CompletionException;
|
|
||||||
import java.util.concurrent.ExecutionException;
|
|
||||||
|
|
||||||
import de.mas.wiiu.jnus.entities.TMD;
|
|
||||||
import de.mas.wiiu.jnus.entities.Ticket;
|
|
||||||
import de.mas.wiiu.jnus.entities.content.Content;
|
|
||||||
import de.mas.wiiu.jnus.entities.fst.FSTEntry;
|
|
||||||
import de.mas.wiiu.jnus.interfaces.NUSDataProvider;
|
|
||||||
import de.mas.wiiu.jnus.utils.CheckSumWrongException;
|
|
||||||
import de.mas.wiiu.jnus.utils.FileUtils;
|
|
||||||
import de.mas.wiiu.jnus.utils.HashUtil;
|
|
||||||
import de.mas.wiiu.jnus.utils.Parallelizable;
|
|
||||||
import de.mas.wiiu.jnus.utils.StreamUtils;
|
|
||||||
import de.mas.wiiu.jnus.utils.Utils;
|
|
||||||
import de.mas.wiiu.jnus.utils.cryptography.NUSDecryption;
|
|
||||||
import lombok.Getter;
|
|
||||||
import lombok.val;
|
|
||||||
import lombok.extern.java.Log;
|
|
||||||
|
|
||||||
@Log
|
|
||||||
public final class DecryptionService {
|
|
||||||
@Getter private final NUSTitle NUSTitle;
|
|
||||||
|
|
||||||
private boolean parallelizable = false;
|
|
||||||
|
|
||||||
public static DecryptionService getInstance(NUSTitle nustitle) {
|
|
||||||
return new DecryptionService(nustitle);
|
|
||||||
}
|
|
||||||
|
|
||||||
private DecryptionService(NUSTitle nustitle) {
|
|
||||||
if (nustitle.getDataProvider() instanceof Parallelizable) {
|
|
||||||
parallelizable = true;
|
|
||||||
}
|
|
||||||
this.NUSTitle = nustitle;
|
|
||||||
}
|
|
||||||
|
|
||||||
public Ticket getTicket() {
|
|
||||||
return getNUSTitle().getTicket();
|
|
||||||
}
|
|
||||||
|
|
||||||
public void decryptFSTEntryTo(boolean useFullPath, FSTEntry entry, String outputPath, boolean skipExistingFile) {
|
|
||||||
try {
|
|
||||||
decryptFSTEntryToAsync(useFullPath, entry, outputPath, skipExistingFile).get();
|
|
||||||
} catch (InterruptedException | ExecutionException e) {
|
|
||||||
throw new RuntimeException(e);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
public CompletableFuture<Void> decryptFSTEntryToAsync(boolean useFullPath, FSTEntry entry, String outputPath, boolean skipExistingFile) {
|
|
||||||
return CompletableFuture.runAsync(() -> {
|
|
||||||
try {
|
|
||||||
if (entry.isNotInPackage() || entry.getContent() == null) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
log.info("Decrypting " + entry.getFilename());
|
|
||||||
|
|
||||||
String targetFilePath = new StringBuilder().append(outputPath).append("/").append(entry.getFilename()).toString();
|
|
||||||
String fullPath = new StringBuilder().append(outputPath).toString();
|
|
||||||
|
|
||||||
if (useFullPath) {
|
|
||||||
targetFilePath = new StringBuilder().append(outputPath).append(entry.getFullPath()).toString();
|
|
||||||
fullPath = new StringBuilder().append(outputPath).append(entry.getPath()).toString();
|
|
||||||
if (entry.isDir()) { // If the entry is a directory. Create it and return.
|
|
||||||
Utils.createDir(targetFilePath);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
} else if (entry.isDir()) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!Utils.createDir(fullPath)) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
File target = new File(targetFilePath);
|
|
||||||
|
|
||||||
if (skipExistingFile) {
|
|
||||||
File targetFile = new File(targetFilePath);
|
|
||||||
if (targetFile.exists()) {
|
|
||||||
if (entry.isDir()) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
if (targetFile.length() == entry.getFileSize()) {
|
|
||||||
Content c = entry.getContent();
|
|
||||||
if (c.isHashed()) {
|
|
||||||
log.info("File already exists: " + entry.getFilename());
|
|
||||||
return;
|
|
||||||
} else {
|
|
||||||
if (Arrays.equals(HashUtil.hashSHA1(target, (int) c.getDecryptedFileSize()), c.getSHA2Hash())) {
|
|
||||||
log.info("File already exists: " + entry.getFilename());
|
|
||||||
return;
|
|
||||||
} else {
|
|
||||||
log.info("File already exists with the same filesize, but the hash doesn't match: " + entry.getFilename());
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
} else {
|
|
||||||
log.info("File already exists but the filesize doesn't match: " + entry.getFilename());
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// to avoid having fragmented files.
|
|
||||||
FileUtils.FileAsOutputStreamWrapper(new File(targetFilePath), entry.getFileSize(), newOutputStream -> {
|
|
||||||
try {
|
|
||||||
decryptFSTEntryToStream(entry, newOutputStream);
|
|
||||||
} catch (CheckSumWrongException e) {
|
|
||||||
log.info("Hash doesn't match!");
|
|
||||||
// Wrapp it into a IOException
|
|
||||||
throw new IOException(e);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
} catch (Exception ex) {
|
|
||||||
throw new CompletionException(ex);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
public void decryptFSTEntryToStream(FSTEntry entry, OutputStream outputStream) throws IOException, CheckSumWrongException {
|
|
||||||
|
|
||||||
long fileSize = entry.getFileSize();
|
|
||||||
long fileOffset = entry.getFileOffset();
|
|
||||||
long fileOffsetBlock = entry.getFileOffsetBlock();
|
|
||||||
|
|
||||||
decryptFSTEntryToStream(entry, outputStream, fileSize, fileOffset, fileOffsetBlock);
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
public void decryptFSTEntryToStream(FSTEntry entry, OutputStream outputStream, long fileSize, long fileOffset, long fileOffsetBlock)
|
|
||||||
throws IOException, CheckSumWrongException {
|
|
||||||
if (entry.isNotInPackage() || entry.getContent() == null) {
|
|
||||||
outputStream.close();
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
Content c = entry.getContent();
|
|
||||||
|
|
||||||
NUSDataProvider dataProvider = getNUSTitle().getDataProvider();
|
|
||||||
|
|
||||||
InputStream in = dataProvider.getInputStreamFromContent(c, fileOffsetBlock);
|
|
||||||
if (in == null) {
|
|
||||||
String errormsg = "Failed to open the content " + c.getFilename() + " as input stream.";
|
|
||||||
log.warning(errormsg);
|
|
||||||
throw new FileNotFoundException(errormsg);
|
|
||||||
}
|
|
||||||
|
|
||||||
try {
|
|
||||||
decryptFSTEntryFromStreams(in, outputStream, fileSize, fileOffset, c);
|
|
||||||
} catch (CheckSumWrongException e) {
|
|
||||||
if (entry.getContent().isUNKNWNFlag1Set()) {
|
|
||||||
log.info("Hash doesn't match. But file is optional. Don't worry.");
|
|
||||||
} else {
|
|
||||||
StringBuilder sb = new StringBuilder();
|
|
||||||
sb.append("Hash doesn't match").append(System.lineSeparator());
|
|
||||||
sb.append("Detailed info:").append(System.lineSeparator());
|
|
||||||
sb.append(entry).append(System.lineSeparator());
|
|
||||||
sb.append(entry.getContent()).append(System.lineSeparator());
|
|
||||||
sb.append(String.format("%016x", this.NUSTitle.getTMD().getTitleID()));
|
|
||||||
sb.append(e.getMessage() + " Calculated Hash: " + Utils.ByteArrayToString(e.getGivenHash()) + ", expected hash: "
|
|
||||||
+ Utils.ByteArrayToString(e.getExpectedHash()));
|
|
||||||
log.info(sb.toString());
|
|
||||||
throw e;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private void decryptFSTEntryFromStreams(InputStream inputStream, OutputStream outputStream, long filesize, long fileoffset, Content content)
|
|
||||||
throws IOException, CheckSumWrongException {
|
|
||||||
decryptStreams(inputStream, outputStream, filesize, fileoffset, content);
|
|
||||||
}
|
|
||||||
|
|
||||||
private void decryptContentFromStream(InputStream inputStream, OutputStream outputStream, Content content) throws IOException, CheckSumWrongException {
|
|
||||||
long filesize = content.getDecryptedFileSize();
|
|
||||||
log.info("Decrypting Content " + String.format("%08X", content.getID()));
|
|
||||||
decryptStreams(inputStream, outputStream, filesize, 0L, content);
|
|
||||||
}
|
|
||||||
|
|
||||||
private void decryptStreams(InputStream inputStream, OutputStream outputStream, long size, long offset, Content content)
|
|
||||||
throws IOException, CheckSumWrongException {
|
|
||||||
NUSDecryption nusdecryption = new NUSDecryption(getTicket());
|
|
||||||
short contentIndex = (short) content.getIndex();
|
|
||||||
|
|
||||||
long encryptedFileSize = content.getEncryptedFileSize();
|
|
||||||
|
|
||||||
if (content.isEncrypted()) {
|
|
||||||
if (content.isHashed()) {
|
|
||||||
NUSDataProvider dataProvider = getNUSTitle().getDataProvider();
|
|
||||||
byte[] h3 = dataProvider.getContentH3Hash(content);
|
|
||||||
|
|
||||||
nusdecryption.decryptFileStreamHashed(inputStream, outputStream, size, offset, (short) contentIndex, h3);
|
|
||||||
} else {
|
|
||||||
try {
|
|
||||||
byte[] h3Hash = content.getSHA2Hash();
|
|
||||||
// We want to check if we read the whole file or just a part of it.
|
|
||||||
// There should be only one actual file inside a non-hashed content.
|
|
||||||
// But it could also contain a directory, so we need to filter.
|
|
||||||
long fstFileSize = content.getEntries().stream().filter(f -> !f.isDir()).findFirst().map(f -> f.getFileSize()).orElse(0L);
|
|
||||||
if (size > 0 && size < fstFileSize) {
|
|
||||||
h3Hash = null;
|
|
||||||
}
|
|
||||||
nusdecryption.decryptFileStream(inputStream, outputStream, size, offset, (short) contentIndex, h3Hash, encryptedFileSize);
|
|
||||||
} catch (Exception e) {
|
|
||||||
e.printStackTrace();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
StreamUtils.saveInputStreamToOutputStreamWithHash(inputStream, outputStream, size, content.getSHA2Hash(), encryptedFileSize);
|
|
||||||
}
|
|
||||||
|
|
||||||
synchronized (inputStream) {
|
|
||||||
inputStream.close();
|
|
||||||
}
|
|
||||||
synchronized (outputStream) {
|
|
||||||
outputStream.close();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
public void decryptContentToSync(Content content, String outPath, boolean skipExistingFile) {
|
|
||||||
try {
|
|
||||||
decryptContentToAsync(content, outPath, skipExistingFile).get();
|
|
||||||
} catch (InterruptedException | ExecutionException e) {
|
|
||||||
throw new RuntimeException(e);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
public CompletableFuture<Void> decryptContentToAsync(Content content, String outPath, boolean skipExistingFile) {
|
|
||||||
return CompletableFuture.runAsync(() -> {
|
|
||||||
try {
|
|
||||||
String targetFilePath = outPath + File.separator + content.getFilenameDecrypted();
|
|
||||||
if (skipExistingFile) {
|
|
||||||
File targetFile = new File(targetFilePath);
|
|
||||||
if (targetFile.exists()) {
|
|
||||||
if (targetFile.length() == content.getDecryptedFileSize()) {
|
|
||||||
log.info("File already exists : " + content.getFilenameDecrypted());
|
|
||||||
return;
|
|
||||||
} else {
|
|
||||||
log.info("File already exists but the filesize doesn't match: " + content.getFilenameDecrypted());
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!Utils.createDir(outPath)) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
log.info("Decrypting Content " + String.format("%08X", content.getID()));
|
|
||||||
|
|
||||||
FileOutputStream outputStream = new FileOutputStream(new File(targetFilePath));
|
|
||||||
|
|
||||||
decryptContentToStream(content, outputStream);
|
|
||||||
} catch (Exception ex) {
|
|
||||||
throw new CompletionException(ex);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
public void decryptContentToStream(Content content, OutputStream outputStream) throws IOException, CheckSumWrongException {
|
|
||||||
if (content == null) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
NUSDataProvider dataProvider = getNUSTitle().getDataProvider();
|
|
||||||
InputStream inputStream = dataProvider.getInputStreamFromContent(content, 0);
|
|
||||||
|
|
||||||
decryptContentFromStream(inputStream, outputStream, content);
|
|
||||||
}
|
|
||||||
|
|
||||||
public byte[] getChunkFromFile(FSTEntry entry, long offset, long size) throws IOException, CheckSumWrongException {
|
|
||||||
ByteArrayOutputStream out = new ByteArrayOutputStream();
|
|
||||||
|
|
||||||
long fileOffset = entry.getFileOffset() + offset;
|
|
||||||
long fileOffsetBlock = fileOffset;
|
|
||||||
|
|
||||||
if (entry.getContent().isHashed()) {
|
|
||||||
fileOffsetBlock = (fileOffset / 0xFC00) * 0x10000;
|
|
||||||
} else {
|
|
||||||
fileOffsetBlock = (fileOffset / 0x8000) * 0x8000;
|
|
||||||
// We need the previous IV if we don't start at the first block.
|
|
||||||
if (fileOffset >= 0x8000 && fileOffset % 0x8000 == 0) {
|
|
||||||
fileOffsetBlock -= 16;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
decryptFSTEntryToStream(entry, out, size, fileOffset, fileOffsetBlock);
|
|
||||||
return out.toByteArray();
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
public PipedInputStreamWithException getDecryptedOutputAsInputStream(FSTEntry fstEntry) throws IOException {
|
|
||||||
PipedInputStreamWithException in = new PipedInputStreamWithException();
|
|
||||||
PipedOutputStream out = new PipedOutputStream(in);
|
|
||||||
|
|
||||||
new Thread(() -> {
|
|
||||||
try {
|
|
||||||
decryptFSTEntryToStream(fstEntry, out);
|
|
||||||
in.throwException(null);
|
|
||||||
} catch (Exception e) {
|
|
||||||
in.throwException(e);
|
|
||||||
}
|
|
||||||
}).start();
|
|
||||||
|
|
||||||
return in;
|
|
||||||
}
|
|
||||||
|
|
||||||
public PipedInputStreamWithException getDecryptedContentAsInputStream(Content content) throws IOException, CheckSumWrongException {
|
|
||||||
PipedInputStreamWithException in = new PipedInputStreamWithException();
|
|
||||||
PipedOutputStream out = new PipedOutputStream(in);
|
|
||||||
|
|
||||||
new Thread(() -> {
|
|
||||||
try {// Throwing it in both cases is EXTREMLY important. Otherwise it'll end in a
|
|
||||||
// deadlock
|
|
||||||
decryptContentToStream(content, out);
|
|
||||||
in.throwException(null);
|
|
||||||
} catch (Exception e) {
|
|
||||||
in.throwException(e);
|
|
||||||
}
|
|
||||||
}).start();
|
|
||||||
|
|
||||||
return in;
|
|
||||||
}
|
|
||||||
|
|
||||||
// !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
|
|
||||||
// Decrypt FSTEntry to OutputStream
|
|
||||||
// !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
|
|
||||||
public void decryptFSTEntryTo(String entryFullPath, OutputStream outputStream) throws IOException, CheckSumWrongException {
|
|
||||||
FSTEntry entry = getNUSTitle().getFSTEntryByFullPath(entryFullPath).orElseThrow(() -> new FileNotFoundException("File not found: " + entryFullPath));
|
|
||||||
|
|
||||||
decryptFSTEntryToStream(entry, outputStream);
|
|
||||||
}
|
|
||||||
|
|
||||||
// !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
|
|
||||||
// Decrypt single FSTEntry to File
|
|
||||||
// !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
|
|
||||||
public void decryptFSTEntryTo(String entryFullPath, String outputFolder) throws IOException, CheckSumWrongException {
|
|
||||||
decryptFSTEntryTo(false, entryFullPath, outputFolder);
|
|
||||||
}
|
|
||||||
|
|
||||||
public void decryptFSTEntryTo(boolean fullPath, String entryFullPath, String outputFolder) throws IOException, CheckSumWrongException {
|
|
||||||
decryptFSTEntryTo(fullPath, entryFullPath, outputFolder, getNUSTitle().isSkipExistingFiles());
|
|
||||||
}
|
|
||||||
|
|
||||||
public void decryptFSTEntryTo(String entryFullPath, String outputFolder, boolean skipExistingFiles) throws IOException, CheckSumWrongException {
|
|
||||||
decryptFSTEntryTo(false, entryFullPath, outputFolder, getNUSTitle().isSkipExistingFiles());
|
|
||||||
}
|
|
||||||
|
|
||||||
public void decryptFSTEntryTo(boolean fullPath, String entryFullPath, String outputFolder, boolean skipExistingFiles)
|
|
||||||
throws IOException, CheckSumWrongException {
|
|
||||||
|
|
||||||
FSTEntry entry = getNUSTitle().getFSTEntryByFullPath(entryFullPath).orElseThrow(() -> new FileNotFoundException("File not found: " + entryFullPath));
|
|
||||||
|
|
||||||
decryptFSTEntryTo(fullPath, entry, outputFolder, skipExistingFiles);
|
|
||||||
}
|
|
||||||
|
|
||||||
public void decryptFSTEntryTo(FSTEntry entry, String outputFolder) throws IOException, CheckSumWrongException {
|
|
||||||
decryptFSTEntryTo(false, entry, outputFolder);
|
|
||||||
}
|
|
||||||
|
|
||||||
public void decryptFSTEntryTo(FSTEntry entry, String outputFolder, boolean skipExistingFiles) throws IOException, CheckSumWrongException {
|
|
||||||
decryptFSTEntryTo(false, entry, outputFolder, getNUSTitle().isSkipExistingFiles());
|
|
||||||
}
|
|
||||||
|
|
||||||
public void decryptFSTEntryTo(boolean fullPath, FSTEntry entry, String outputFolder) throws IOException, CheckSumWrongException {
|
|
||||||
decryptFSTEntryTo(fullPath, entry, outputFolder, getNUSTitle().isSkipExistingFiles());
|
|
||||||
}
|
|
||||||
|
|
||||||
// !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
|
|
||||||
// Decrypt list of FSTEntry to Files
|
|
||||||
// !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
|
|
||||||
public void decryptAllFSTEntriesTo(String outputFolder) throws IOException, CheckSumWrongException {
|
|
||||||
Utils.createDir(outputFolder + File.separator + "code");
|
|
||||||
Utils.createDir(outputFolder + File.separator + "content");
|
|
||||||
Utils.createDir(outputFolder + File.separator + "meta");
|
|
||||||
decryptFSTEntriesTo(true, ".*", outputFolder);
|
|
||||||
}
|
|
||||||
|
|
||||||
public void decryptFSTEntriesTo(String regEx, String outputFolder) throws IOException, CheckSumWrongException {
|
|
||||||
decryptFSTEntriesTo(true, regEx, outputFolder);
|
|
||||||
}
|
|
||||||
|
|
||||||
public void decryptFSTEntriesTo(boolean fullPath, String regEx, String outputFolder) throws IOException, CheckSumWrongException {
|
|
||||||
decryptFSTEntryListTo(fullPath, getNUSTitle().getFSTEntriesByRegEx(regEx), outputFolder);
|
|
||||||
}
|
|
||||||
|
|
||||||
public void decryptFSTEntryListTo(List<FSTEntry> list, String outputFolder) throws IOException, CheckSumWrongException {
|
|
||||||
decryptFSTEntryListTo(true, list, outputFolder);
|
|
||||||
}
|
|
||||||
|
|
||||||
public CompletableFuture<Void> decryptFSTEntryListToAsync(boolean fullPath, List<FSTEntry> list, String outputFolder)
|
|
||||||
throws IOException, CheckSumWrongException {
|
|
||||||
return CompletableFuture.allOf(list.stream().map(entry -> decryptFSTEntryToAsync(fullPath, entry, outputFolder, getNUSTitle().isSkipExistingFiles()))
|
|
||||||
.toArray(CompletableFuture[]::new));
|
|
||||||
}
|
|
||||||
|
|
||||||
public void decryptFSTEntryListTo(boolean fullPath, List<FSTEntry> list, String outputFolder) throws IOException, CheckSumWrongException {
|
|
||||||
if (parallelizable && Settings.ALLOW_PARALLELISATION) {
|
|
||||||
try {
|
|
||||||
decryptFSTEntryListToAsync(fullPath, list, outputFolder).get();
|
|
||||||
} catch (InterruptedException | ExecutionException e) {
|
|
||||||
throw new RuntimeException(e);
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
for (val entry : list) {
|
|
||||||
decryptFSTEntryTo(fullPath, entry, outputFolder, getNUSTitle().isSkipExistingFiles());
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
// !!!!!!!!!!!!!!!!!!!!!!!!!!!!!
|
|
||||||
// Save decrypted contents
|
|
||||||
// !!!!!!!!!!!!!!!!!!!!!!!!!!!!!
|
|
||||||
public void decryptPlainContentByID(int ID, String outputFolder) throws IOException, CheckSumWrongException {
|
|
||||||
decryptPlainContent(getTMDFromNUSTitle().getContentByID(ID), outputFolder);
|
|
||||||
}
|
|
||||||
|
|
||||||
public void decryptPlainContentByIndex(int index, String outputFolder) throws IOException, CheckSumWrongException {
|
|
||||||
decryptPlainContent(getTMDFromNUSTitle().getContentByIndex(index), outputFolder);
|
|
||||||
}
|
|
||||||
|
|
||||||
public void decryptPlainContent(Content c, String outputFolder) throws IOException, CheckSumWrongException {
|
|
||||||
decryptPlainContents(new ArrayList<Content>(Arrays.asList(c)), outputFolder);
|
|
||||||
}
|
|
||||||
|
|
||||||
public void decryptPlainContents(List<Content> list, String outputFolder) throws IOException, CheckSumWrongException {
|
|
||||||
|
|
||||||
if (parallelizable && Settings.ALLOW_PARALLELISATION) {
|
|
||||||
try {
|
|
||||||
decryptPlainContentsAsync(list, outputFolder).get();
|
|
||||||
} catch (InterruptedException | ExecutionException e) {
|
|
||||||
// wrap it.
|
|
||||||
throw new RuntimeException(e);
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
for (val c : list) {
|
|
||||||
decryptContentToSync(c, outputFolder, getNUSTitle().isSkipExistingFiles());
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
|
||||||
|
|
||||||
public CompletableFuture<Void> decryptPlainContentsAsync(List<Content> list, String outputFolder) throws IOException, CheckSumWrongException {
|
|
||||||
return CompletableFuture
|
|
||||||
.allOf(list.stream().map(c -> decryptContentToAsync(c, outputFolder, getNUSTitle().isSkipExistingFiles())).toArray(CompletableFuture[]::new));
|
|
||||||
}
|
|
||||||
|
|
||||||
public void decryptAllPlainContents(String outputFolder) throws IOException, CheckSumWrongException {
|
|
||||||
decryptPlainContents(new ArrayList<Content>(getTMDFromNUSTitle().getAllContents().values()), outputFolder);
|
|
||||||
}
|
|
||||||
|
|
||||||
// !!!!!!!!!!!!!!!!!!!!!!!!!!!!!
|
|
||||||
// Other
|
|
||||||
// !!!!!!!!!!!!!!!!!!!!!!!!!!!!!
|
|
||||||
private TMD getTMDFromNUSTitle() {
|
|
||||||
return getNUSTitle().getTMD();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
Loading…
x
Reference in New Issue
Block a user