CalvinBackup/anonymous_github
1
0
Fork 0
mirror of https://github.com/tdurieux/anonymous_github.git synced 2026-07-06 05:38:09 +02:00
Code Issues Packages Projects Releases Wiki Activity

prevent parallel downloads

Browse Source
This commit is contained in:
tdurieux
2021-08-13 11:50:57 +02:00
parent 308cc40cde
commit fa24ec344d
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/source/GitHubDownload.ts
+5 -2
View File
@@ -1,5 +1,4 @@
import { Octokit } from "@octokit/rest"; import { Octokit } from "@octokit/rest";
import * as path from "path";
import config from "../../config"; import config from "../../config";
import storage from "../storage"; import storage from "../storage";
import Repository from "../Repository"; import Repository from "../Repository";
@@ -7,7 +6,7 @@ import Repository from "../Repository";
import GitHubBase from "./GitHubBase"; import GitHubBase from "./GitHubBase";
import AnonymizedFile from "../AnonymizedFile"; import AnonymizedFile from "../AnonymizedFile";
import { SourceBase } from "../types"; import { SourceBase } from "../types";
import * as got from "got"; import got from "got";
import * as stream from "stream"; import * as stream from "stream";
import { OctokitResponse } from "@octokit/types"; import { OctokitResponse } from "@octokit/types";
@@ -39,6 +38,8 @@ export default class GitHubDownload extends GitHubBase implements SourceBase {
} }
async download() { async download() {
if (this.repository.status == "download")
throw new Error("repo_in_download");
let response: OctokitResponse<unknown, number>; let response: OctokitResponse<unknown, number>;
try { try {
response = await this._getZipUrl(await this.getToken()); response = await this._getZipUrl(await this.getToken());
@@ -53,9 +54,11 @@ export default class GitHubDownload extends GitHubBase implements SourceBase {
throw new Error("repo_not_accessible"); throw new Error("repo_not_accessible");
} }
} }
await this.repository.updateStatus("download");
const originalPath = this.repository.originalCachePath; const originalPath = this.repository.originalCachePath;
await storage.mk(originalPath); await storage.mk(originalPath);
await storage.extractTar(originalPath, got.stream(response.url)); await storage.extractTar(originalPath, got.stream(response.url));
await this.repository.updateStatus("ready");
} }
async getFileContent(file: AnonymizedFile): Promise<stream.Readable> { async getFileContent(file: AnonymizedFile): Promise<stream.Readable> {