Skip to content

M
mycard
Commit 0b335a3a authored by 神楽坂玲奈's avatar 神楽坂玲奈
Browse files
Options

Merge branch 'v3' of github.com:mycard/mycard into v3

parents e676ab65 9b3f8f5d
Show whitespace changes
Inline Side-by-side
Showing with 230 additions and 129 deletions
app/apps.service.ts
View file @ 0b335a3a
......@@ -11,7 +11,7 @@ import "rxjs/Rx";
import * as readline from "readline";
import {AppLocal} from "./app-local";
import * as ini from "ini";
import {DownloadService} from "./download.service";
import {DownloadService, DownloadStatus} from "./download.service";
import {InstallOption} from "./install-option";
import {ComparableSet} from "./shared/ComparableSet";
import {Observable, Observer} from "rxjs/Rx";
......@@ -21,7 +21,14 @@ import ReadableStream = NodeJS.ReadableStream;
const Aria2 = require('aria2');
const sudo = require('electron-sudo');
const Logger = {
info: (...message: any[]) => {
console.log("AppService [INFO]: ", ...message);
},
error: (...message: any[]) => {
console.error("AppService [ERROR]: ", ...message);
}
};
interface InstallTask {
app: App;
option: InstallOption;
......@@ -126,9 +133,9 @@ export class AppsService {
}
// 设置App关系
//TODO: 这里有必要重新整理一下么？
for (let [id, app] of apps) {
let temp = app.actions;
for (let [id,app] of apps) {
let temp=app.actions;
let map = new Map<string,any>();
for (let action of Object.keys(temp)) {
let openId = temp[action]["open"];
......@@ -197,46 +204,26 @@ export class AppsService {
}
await this.doInstall(task);
};
// TODO: 重构这个函数
const addDownloadTask = async(app: App, dir: string) => {
const addDownloadTask = async(app: App, dir: string): Promise<{app: App,files: string[]} > => {
let metalinkUrl = app.download;
if (app.id === "ygopro") {
// TODO: 需要特化平台下载的还有个desmume
metalinkUrl = "https://thief.mycard.moe/metalinks/ygopro-" + process.platform + ".meta4";
}
let metalink = await this.http.get(metalinkUrl).map((response) => response.text()).toPromise();
if (app.id === "desmume") {
metalinkUrl = "https://thief.mycard.moe/metalinks/desmume-" + process.platform + ".meta4";
}
app.status.status = "downloading";
let metalink = await this.http.get(metalinkUrl).map((response) => response.text()).toPromise();
let downloadId = await this.downloadService.addMetalink(metalink, dir);
let observable = this.downloadService.downloadProgress(downloadId);
return new Promise((resolve, reject) => {
observable.subscribe((task) => {
if (task.totalLength) {
app.status.total = task.totalLength;
} else {
app.status.total = 0;
}
app.status.progress = task.completedLength;
console.log(task);
if (task.downloadSpeed) {
let currentSpeed = parseInt(task.downloadSpeed);
const speedUnit = ["Byte/s", "KB/s", "MB/s", "GB/s", "TB/s"];
let currentUnit = Math.floor(Math.log(currentSpeed) / Math.log(1024));
console.log(currentSpeed, currentUnit);
app.status.progressMessage = (currentSpeed / 1024 ** currentUnit).toFixed(1) + " " + speedUnit[currentUnit];
} else {
app.status.progressMessage = '';
}
await this.downloadService.progress(downloadId, (status: DownloadStatus) => {
app.status.progress = status.completedLength;
app.status.total = status.totalLength;
app.status.progressMessage = status.downloadSpeedText;
this.ref.tick();
}, (error) => {
reject(error);
}, async() => {
app.status.status = "waiting";
let files = await this.downloadService.getFile(downloadId);
resolve({app: app, files: files});
})
});
let files = await this.downloadService.getFiles(downloadId);
app.status.status = "waiting";
return {app: app, files: files}
};
if (!app.isInstalled()) {
let apps: App[] = [];
......@@ -247,16 +234,16 @@ export class AppsService {
try {
let downloadPath = path.join(option.installLibrary, 'downloading');
let tasks: Promise<any>[] = [];
Logger.info("Start to Download", apps);
for (let a of apps) {
tasks.push(addDownloadTask(a, downloadPath));
}
let downloadResults = await Promise.all(tasks);
Logger.info("Download Complete", downloadResults);
let installTasks: Promise<void>[] = [];
for (let result of downloadResults) {
console.log(result);
let o = new InstallOption(result.app, option.installLibrary);
o.downloadFiles = result.files;
let task = tryToInstall({app: result.app, option: o});
installTasks.push(task);
}
......@@ -268,7 +255,6 @@ export class AppsService {
a.reset()
}
}
console.log(e);
throw e;
}
}
......@@ -277,7 +263,7 @@ export class AppsService {
findChildren(app: App): App[] {
let children: App[] = [];
for (let [id,child] of this.apps) {
if (child.parent === app) {
if (child.parent === app || child.dependencies && child.dependencies.has(app.id)) {
children.push(child);
}
}
......@@ -421,7 +407,6 @@ export class AppsService {
if (connection) {
connection.connection.close();
}
// console.log(server.url);
connection = {connection: new WebSocket(server.url), address: null};
let id: Timer | null;
this.connections.set(app, connection);
......@@ -484,7 +469,7 @@ export class AppsService {
let app = task.app;
if (!app.isWaiting()) {
console.error('doUninstall', "应用不处于等待安装状态", JSON.stringify(app));
console.error('doUninstall', "应用不处于等待安装状态", app);
throw("应用不处于等待安装状态");
}
......@@ -689,9 +674,8 @@ export class AppsService {
for (let line of response.text().split('\n')) {
if (line !== "") {
let [checksum,filename]=line.split(' ', 2);
if (filename.endsWith("\\") || filename.endsWith("/")) {
map.set(filename, "");
}
// checksum文件里没有文件夹，这里添加上
map.set(path.dirname(filename), "");
map.set(filename, checksum);
}
}
......@@ -718,16 +702,19 @@ export class AppsService {
}
async uninstall(app: App) {
// TODO: 级联卸载mod
let children = this.findChildren(app);
let hasInstalledChild = children.find((child) => {
return child.isInstalled();
return child.isInstalled() && child.parent != app;
});
if (hasInstalledChild) {
throw "无法卸载，还有依赖此程序的游戏。"
} else if (app.isReady()) {
for (let child of children) {
if (child.parent === app && child.isReady()) {
await this.doUninstall(child);
}
}
if (app.isReady()) {
return this.doUninstall(app);
return await this.doUninstall(app);
}
}
......@@ -760,7 +747,7 @@ export class AppsService {
let parentSet = new ComparableSet(Array.from(app.parent.local!.files.keys()));
let difference = parentSet.intersection(fileSet);
if (difference) {
this.restoreFiles(appDir, backupDir, Array.from(difference))
await this.restoreFiles(appDir, backupDir, Array.from(difference))
}
}
......
app/download.service.ts
View file @ 0b335a3a
......@@ -7,30 +7,103 @@ import {Observable} from "rxjs/Observable";
import {App} from "./app";
import {Observer} from "rxjs";
import Timer = NodeJS.Timer;
import {error} from "util";
const Logger = {
"error": (message: string) => {
console.error("DownloadService: ", message);
}
};
const Aria2 = require('aria2');
const MAX_LIST_NUM = 1000;
const ARIA2_INTERVAL = 1000;
export interface DownloadStatus {
completedLength: string;
downloadSpeed: string;
export class DownloadStatus {
completedLength: number;
downloadSpeed: number;
get downloadSpeedText(): string {
if (!isNaN(this.downloadSpeed)) {
const speedUnit = ["Byte/s", "KB/s", "MB/s", "GB/s", "TB/s"];
let currentUnit = Math.floor(Math.log(this.downloadSpeed) / Math.log(1024));
return (this.downloadSpeed / 1024 ** currentUnit).toFixed(1) + " " + speedUnit[currentUnit];
}
return "";
};
gid: string;
status: string;
totalLength: string;
totalLength: number;
totalLengthText: string;
errorCode: string;
errorMessage: string;
combine(...others: DownloadStatus[]): DownloadStatus {
const priority = {
undefined: -1,
"": -1,
"active": 0,
"complete": 0,
"paused": 1,
"waiting": 1,
"removed": 2,
"error": 3
};
let status = Object.assign(new DownloadStatus(), this);
for (let o of others) {
if (priority[o.status] > priority[status.status]) {
status.status = o.status;
if (status.status === "error") {
status.errorCode = o.errorCode;
status.errorMessage = o.errorMessage;
}
status.downloadSpeed += o.downloadSpeed;
status.totalLength += o.totalLength;
status.completedLength += o.completedLength;
}
}
return status;
}
// 0相等. 1不想等
compareTo(other: DownloadStatus): number {
if (this.status !== other.status ||
this.downloadSpeed !== other.downloadSpeed ||
this.completedLength !== other.completedLength ||
this.totalLength !== other.totalLength) {
return 1;
} else {
return 0;
}
}
constructor(item ?: any) {
if (item) {
this.completedLength = parseInt(item.completedLength) || 0;
this.downloadSpeed = parseInt(item.downloadSpeed) || 0;
this.totalLength = parseInt(item.totalLength) || 0;
this.gid = item.gid;
this.status = item.status;
this.errorCode = item.errorCode;
this.errorMessage = item.errorMessage;
} else {
this.completedLength = 0;
this.downloadSpeed = 0;
this.totalLength = 0;
}
}
}
@Injectable()
export class DownloadService {
aria2 = new Aria2();
open = this.aria2.open();
updateEmitter = new EventEmitter<string>();
progressList: Map<string,(Observable<any>)> = new Map();
taskList: Map<string,DownloadStatus> = new Map();
updateEmitter = new EventEmitter<void>();
downloadList: Map<string,DownloadStatus> = new Map();
map: Map<string,string[]> = new Map();
taskMap: Map<string,string[]> = new Map();
constructor(private ngZone: NgZone, private http: Http) {
ngZone.runOutsideAngular(async() => {
......@@ -40,15 +113,15 @@ export class DownloadService {
let waitList = await this.aria2.tellWaiting(0, MAX_LIST_NUM);
let stoppedList = await this.aria2.tellStopped(0, MAX_LIST_NUM);
for (let item of activeList) {
this.taskList.set(item.gid, item);
this.downloadList.set(item.gid, new DownloadStatus(item));
}
for (let item of waitList) {
this.taskList.set(item.gid, item);
this.downloadList.set(item.gid, new DownloadStatus(item));
}
for (let item of stoppedList) {
this.taskList.set(item.gid, item);
this.downloadList.set(item.gid, new DownloadStatus(item));
}
this.updateEmitter.emit("updated");
this.updateEmitter.emit();
}, ARIA2_INTERVAL);
})
}
......@@ -64,72 +137,111 @@ export class DownloadService {
s4() + '-' + s4() + s4() + s4();
}
downloadProgress(id: string): Observable<any> {
let progress = this.progressList.get(id);
if (progress) {
return progress;
async progress(id: string, callback: (downloadStatus: DownloadStatus)=>void) {
return new Promise((resolve, reject) => {
let gids = this.taskMap.get(id);
if (gids) {
let allStatus: DownloadStatus;
this.updateEmitter.subscribe(() => {
let status: DownloadStatus = new DownloadStatus();
// 合并每个状态信息
status =
gids!.map((value, index, array) => {
let s = this.downloadList.get(value);
if (!s) {
throw new Error("Gid not Exists");
}
return s;
})
.reduce((previousValue, currentValue, currentIndex, array) => {
return previousValue.combine(currentValue);
}, status);
if (!allStatus) {
allStatus = status;
} else {
return Observable.create((observer: Observer<any>) => {
let status = '';
let completedLength = 0;
let totalLength = 0;
let downloadSpeed = 0;
let gidList = this.map.get(id) !;
this.updateEmitter.subscribe((value: string) => {
let statusList = new Array(gidList.length);
let newCompletedLength = 0;
let newTotalLength = 0;
let newDownloadSpeed = 0;
for (let [index,gid] of gidList.entries()) {
let task = this.taskList.get(gid)!;
if (task) {
statusList[index] = task.status;
newCompletedLength += parseInt(task.completedLength);
newTotalLength += parseInt(task.totalLength);
newDownloadSpeed += parseInt(task.downloadSpeed);
}
}
if (newCompletedLength !== completedLength || newTotalLength !== totalLength) {
completedLength = newCompletedLength;
totalLength = newTotalLength;
downloadSpeed = newDownloadSpeed;
observer.next({
status: status,
completedLength: completedLength,
totalLength: totalLength,
downloadSpeed: downloadSpeed
});
if (allStatus.compareTo(status) != 0) {
allStatus = status;
}
status = statusList.reduce((value, current) => {
if (value === "complete" && current === "complete") {
return "complete";
}
if (current != "complete" && current != "active") {
return "error";
if (allStatus.status === "error") {
reject(`Download Error: code ${allStatus.errorCode}, message: ${allStatus.errorMessage}`);
} else if (allStatus.status === "complete") {
resolve();
} else {
callback(allStatus);
}
});
if (status === "complete") {
observer.complete();
} else if (status == "error") {
observer.error("Download Error");
}
return () => {
} else {
throw "Try to access invalid download id";
}
}, () => {
}, () => {
})
});
}
}
async getFile(id: string): Promise<string[]> {
let gids = this.map.get(id)!;
console.log('gids ', gids);
// downloadProgress(id: string): Observable<any> {
// let progress = this.progressList.get(id);
// if (progress) {
// return progress;
// } else {
// return Observable.create((observer: Observer<any>) => {
// let status = '';
// let completedLength = 0;
// let totalLength = 0;
// let downloadSpeed = 0;
//
// let gidList = this.taskMap.get(id) !;
// this.updateEmitter.subscribe((value: string) => {
// let statusList = new Array(gidList.length);
// let newCompletedLength = 0;
// let newTotalLength = 0;
// let newDownloadSpeed = 0;
// for (let [index,gid] of gidList.entries()) {
// let task = this.downloadList.get(gid)!;
// if (task) {
// statusList[index] = task.status;
// newCompletedLength += parseInt(task.completedLength);
// newTotalLength += parseInt(task.totalLength);
// newDownloadSpeed += parseInt(task.downloadSpeed);
// }
// }
// if (newCompletedLength !== completedLength || newTotalLength !== totalLength) {
// completedLength = newCompletedLength;
// totalLength = newTotalLength;
// downloadSpeed = newDownloadSpeed;
// observer.next({
// status: status,
// completedLength: completedLength,
// totalLength: totalLength,
// downloadSpeed: downloadSpeed
// });
// }
// status = statusList.reduce((value, current) => {
// if (value === "complete" && current === "complete") {
// return "complete";
// }
// if (current != "complete" && current != "active") {
// return "error";
// }
// });
// if (status === "complete") {
// observer.complete();
// } else if (status == "error") {
// observer.error("Download Error");
// }
// return () => {
//
// }
// }, () => {
//
// }, () => {
//
// })
// });
//
// }
// }
async getFiles(id: string): Promise<string[]> {
let gids = this.taskMap.get(id)!;
let files: string[] = [];
for (let gid of gids) {
let file = await this.aria2.getFiles(gid);
......@@ -142,14 +254,16 @@ export class DownloadService {
let encodedMeta4 = new Buffer((metalink)).toString('base64');
let gidList = await this.aria2.addMetalink(encodedMeta4, {dir: library});
let taskId = this.createId();
this.map.set(taskId, gidList);
this.taskMap.set(taskId, gidList);
return taskId;
}
async addUri(url: string, destination: string): Promise<string> {
await this.open;
let id = await this.aria2.addUri([url], {dir: destination});
return id;
let taskId = this.createId();
let gid = await this.aria2.addUri([url], {dir: destination});
this.taskMap.set(taskId, [gid]);
return taskId;
}
async pause(id: string): Promise<void> {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment