artifact-engine
Advanced tools
Comparing version 0.1.29 to 1.0.0-preview.0
@@ -7,3 +7,3 @@ import * as models from '../Models'; | ||
processArtifactItemImplementation(sourceProvider: models.IArtifactProvider, item: models.ArtifactItem, destProvider: models.IArtifactProvider, artifactEngineOptions: ArtifactEngineOptions, resolve: any, reject: any, retryCount?: number): void; | ||
private getRetryIntervalInSeconds(baseRetryInterval, retryCount); | ||
private getRetryIntervalInSeconds; | ||
createPatternList(artifactEngineOptions: ArtifactEngineOptions): void; | ||
@@ -10,0 +10,0 @@ private artifactItemStore; |
"use strict"; | ||
const path = require('path'); | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.ArtifactEngine = void 0; | ||
const path = require("path"); | ||
var tl = require('azure-pipelines-task-lib/task'); | ||
const models = require('../Models'); | ||
const ci = require('./cilogger'); | ||
const artifactItemStore_1 = require('../Store/artifactItemStore'); | ||
const models = require("../Models"); | ||
const ci = require("./cilogger"); | ||
const artifactItemStore_1 = require("../Store/artifactItemStore"); | ||
const artifactEngineOptions_1 = require("./artifactEngineOptions"); | ||
const logger_1 = require('./logger'); | ||
const worker_1 = require('./worker'); | ||
const logger_1 = require("./logger"); | ||
const worker_1 = require("./worker"); | ||
class ArtifactEngine { | ||
@@ -11,0 +13,0 @@ constructor() { |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.ArtifactEngineOptions = void 0; | ||
class ArtifactEngineOptions { | ||
@@ -3,0 +5,0 @@ constructor() { |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.publishEvent = void 0; | ||
var tl = require('azure-pipelines-task-lib'); | ||
@@ -3,0 +5,0 @@ var packagejson = require('../package.json'); |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.ArtifactEngine = exports.ArtifactEngineOptions = void 0; | ||
var artifactEngineOptions_1 = require("./artifactEngineOptions"); | ||
exports.ArtifactEngineOptions = artifactEngineOptions_1.ArtifactEngineOptions; | ||
Object.defineProperty(exports, "ArtifactEngineOptions", { enumerable: true, get: function () { return artifactEngineOptions_1.ArtifactEngineOptions; } }); | ||
var artifactEngine_1 = require("./artifactEngine"); | ||
exports.ArtifactEngine = artifactEngine_1.ArtifactEngine; | ||
Object.defineProperty(exports, "ArtifactEngine", { enumerable: true, get: function () { return artifactEngine_1.ArtifactEngine; } }); | ||
//# sourceMappingURL=index.js.map |
@@ -9,3 +9,3 @@ import { ArtifactItemStore } from '../Store/artifactItemStore'; | ||
logSummary(): void; | ||
private padText(textToPad, maxTextLength, padChar?); | ||
private padText; | ||
static verbose: boolean; | ||
@@ -12,0 +12,0 @@ private store; |
"use strict"; | ||
var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) { | ||
function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); } | ||
return new (P || (P = Promise))(function (resolve, reject) { | ||
function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } } | ||
function rejected(value) { try { step(generator.throw(value)); } catch (e) { reject(e); } } | ||
function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); } | ||
step((generator = generator.apply(thisArg, _arguments)).next()); | ||
function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } } | ||
function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); } | ||
step((generator = generator.apply(thisArg, _arguments || [])).next()); | ||
}); | ||
}; | ||
const Models_1 = require('../Models'); | ||
const ticketState_1 = require('../Models/ticketState'); | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.Logger = void 0; | ||
const Models_1 = require("../Models"); | ||
const ticketState_1 = require("../Models/ticketState"); | ||
var tl = require('azure-pipelines-task-lib'); | ||
const ci = require('./cilogger'); | ||
const ci = require("./cilogger"); | ||
class Logger { | ||
@@ -30,21 +33,23 @@ constructor(store) { | ||
if (Logger.verbose) { | ||
var progressLogger = () => __awaiter(this, void 0, void 0, function* () { return setTimeout(() => { | ||
var tickets = this.store.getTickets(); | ||
var queuedItems = tickets.filter(x => x.state == ticketState_1.TicketState.InQueue); | ||
var processingItems = tickets.filter(x => x.state == ticketState_1.TicketState.Processing); | ||
var processedItems = tickets.filter(x => x.state == ticketState_1.TicketState.Processed); | ||
var skippedItems = tickets.filter(x => x.state == ticketState_1.TicketState.Skipped); | ||
var failedItems = tickets.filter(x => x.state == ticketState_1.TicketState.Failed); | ||
var currentTime = new Date(); | ||
tl.debug("Total Items: " + tickets.length | ||
+ ", Processed: " + processedItems.length | ||
+ ", Processing: " + processingItems.length | ||
+ ", Queued: " + queuedItems.length | ||
+ ", Skipped: " + skippedItems.length | ||
+ ", Failed: " + failedItems.length | ||
+ ", Time elapsed: " + ((currentTime.valueOf() - this.startTime.valueOf()) / 1000) + "secs"); | ||
if (this.store.itemsPendingProcessing() && !this.store.hasDownloadFailed()) { | ||
progressLogger(); | ||
} | ||
}, 5000); }); | ||
var progressLogger = () => __awaiter(this, void 0, void 0, function* () { | ||
return setTimeout(() => { | ||
var tickets = this.store.getTickets(); | ||
var queuedItems = tickets.filter(x => x.state == ticketState_1.TicketState.InQueue); | ||
var processingItems = tickets.filter(x => x.state == ticketState_1.TicketState.Processing); | ||
var processedItems = tickets.filter(x => x.state == ticketState_1.TicketState.Processed); | ||
var skippedItems = tickets.filter(x => x.state == ticketState_1.TicketState.Skipped); | ||
var failedItems = tickets.filter(x => x.state == ticketState_1.TicketState.Failed); | ||
var currentTime = new Date(); | ||
tl.debug("Total Items: " + tickets.length | ||
+ ", Processed: " + processedItems.length | ||
+ ", Processing: " + processingItems.length | ||
+ ", Queued: " + queuedItems.length | ||
+ ", Skipped: " + skippedItems.length | ||
+ ", Failed: " + failedItems.length | ||
+ ", Time elapsed: " + ((currentTime.valueOf() - this.startTime.valueOf()) / 1000) + "secs"); | ||
if (this.store.itemsPendingProcessing() && !this.store.hasDownloadFailed()) { | ||
progressLogger(); | ||
} | ||
}, 5000); | ||
}); | ||
progressLogger(); | ||
@@ -51,0 +56,0 @@ } |
"use strict"; | ||
const logger_1 = require('./logger'); | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.Worker = void 0; | ||
const logger_1 = require("./logger"); | ||
class Worker { | ||
@@ -4,0 +6,0 @@ constructor(id, execute, getNextItem, canExit, hasDownloadFailed) { |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.ArtifactDownloadTicket = void 0; | ||
class ArtifactDownloadTicket { | ||
@@ -3,0 +5,0 @@ } |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.ArtifactItem = void 0; | ||
class ArtifactItem { | ||
@@ -3,0 +5,0 @@ constructor() { |
@@ -0,1 +1,2 @@ | ||
/// <reference types="node" /> | ||
import { ArtifactItem } from "./artifactItem"; | ||
@@ -2,0 +3,0 @@ import { ArtifactItemStore } from '../Store/artifactItemStore'; |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
//# sourceMappingURL=artifactprovider.js.map |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.Constants = void 0; | ||
class Constants { | ||
} | ||
exports.Constants = Constants; | ||
Constants.DestinationUrlKey = "destinationUrl"; | ||
exports.Constants = Constants; | ||
//# sourceMappingURL=constants.js.map |
"use strict"; | ||
var artifactDownloadTicket_1 = require('./artifactDownloadTicket'); | ||
exports.ArtifactDownloadTicket = artifactDownloadTicket_1.ArtifactDownloadTicket; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.Constants = exports.TicketState = exports.ItemType = exports.ArtifactItem = exports.ArtifactDownloadTicket = void 0; | ||
var artifactDownloadTicket_1 = require("./artifactDownloadTicket"); | ||
Object.defineProperty(exports, "ArtifactDownloadTicket", { enumerable: true, get: function () { return artifactDownloadTicket_1.ArtifactDownloadTicket; } }); | ||
var artifactItem_1 = require("./artifactItem"); | ||
exports.ArtifactItem = artifactItem_1.ArtifactItem; | ||
var itemType_1 = require('./itemType'); | ||
exports.ItemType = itemType_1.ItemType; | ||
var ticketState_1 = require('./ticketState'); | ||
exports.TicketState = ticketState_1.TicketState; | ||
var constants_1 = require('./constants'); | ||
exports.Constants = constants_1.Constants; | ||
Object.defineProperty(exports, "ArtifactItem", { enumerable: true, get: function () { return artifactItem_1.ArtifactItem; } }); | ||
var itemType_1 = require("./itemType"); | ||
Object.defineProperty(exports, "ItemType", { enumerable: true, get: function () { return itemType_1.ItemType; } }); | ||
var ticketState_1 = require("./ticketState"); | ||
Object.defineProperty(exports, "TicketState", { enumerable: true, get: function () { return ticketState_1.TicketState; } }); | ||
var constants_1 = require("./constants"); | ||
Object.defineProperty(exports, "Constants", { enumerable: true, get: function () { return constants_1.Constants; } }); | ||
//# sourceMappingURL=index.js.map |
export declare enum ItemType { | ||
Any, | ||
Folder, | ||
File, | ||
File | ||
} |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.ItemType = void 0; | ||
var ItemType; | ||
(function (ItemType) { | ||
@@ -6,4 +9,3 @@ ItemType[ItemType["Any"] = "any"] = "Any"; | ||
ItemType[ItemType["File"] = "file"] = "File"; | ||
})(exports.ItemType || (exports.ItemType = {})); | ||
var ItemType = exports.ItemType; | ||
})(ItemType = exports.ItemType || (exports.ItemType = {})); | ||
//# sourceMappingURL=itemType.js.map |
@@ -6,3 +6,3 @@ export declare enum TicketState { | ||
Skipped, | ||
Failed, | ||
Failed | ||
} |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.TicketState = void 0; | ||
var TicketState; | ||
(function (TicketState) { | ||
@@ -8,4 +11,3 @@ TicketState[TicketState["InQueue"] = "inqueue"] = "InQueue"; | ||
TicketState[TicketState["Failed"] = "failed"] = "Failed"; | ||
})(exports.TicketState || (exports.TicketState = {})); | ||
var TicketState = exports.TicketState; | ||
})(TicketState = exports.TicketState || (exports.TicketState = {})); | ||
//# sourceMappingURL=ticketState.js.map |
{ | ||
"name": "artifact-engine", | ||
"version": "0.1.29", | ||
"version": "1.0.0-preview.0", | ||
"description": "Artifact Engine to download artifacts from jenkins, teamcity, vsts", | ||
@@ -21,12 +21,11 @@ "repository": { | ||
"minimatch": "3.0.2", | ||
"azure-pipelines-task-lib": "2.8.0", | ||
"azure-pipelines-task-lib": "^3.0.6-preview.1", | ||
"tunnel": "0.0.4" | ||
}, | ||
"devDependencies": { | ||
"@types/handlebars": "^3.0.28", | ||
"@types/minimatch": "^2.0.29", | ||
"@types/mocha": "^2.2.5", | ||
"@types/mocha": "^5.2.7", | ||
"@types/mockery": "1.4.29", | ||
"@types/node": "6.0.31", | ||
"@types/xml2js": "^0.4.0", | ||
"@types/node": "^10.17.0", | ||
"@types/xml2js": "^0.4.8", | ||
"assert": "1.4.1", | ||
@@ -38,3 +37,3 @@ "mocha": "2.3.3", | ||
"sinon": "4.0.1", | ||
"typescript": "1.8.7", | ||
"typescript": "4.0.2", | ||
"nock": "9.1.0", | ||
@@ -41,0 +40,0 @@ "nconf": "0.10.0", |
@@ -0,1 +1,2 @@ | ||
/// <reference types="node" /> | ||
import * as models from '../Models'; | ||
@@ -11,5 +12,5 @@ import { ArtifactItemStore } from '../Store/artifactItemStore'; | ||
dispose(): void; | ||
private getItems(itemsPath, parentRelativePath?); | ||
private getItems; | ||
private _rootLocation; | ||
private _rootItemPath; | ||
} |
"use strict"; | ||
const path = require('path'); | ||
const fs = require('fs'); | ||
const models = require('../Models'); | ||
const logger_1 = require('../Engine/logger'); | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.FilesystemProvider = void 0; | ||
const path = require("path"); | ||
const fs = require("fs"); | ||
const models = require("../Models"); | ||
const logger_1 = require("../Engine/logger"); | ||
var tl = require('azure-pipelines-task-lib'); | ||
@@ -7,0 +9,0 @@ class FilesystemProvider { |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.StubProvider = exports.ZipProvider = exports.FilesystemProvider = exports.WebProvider = void 0; | ||
var webProvider_1 = require("./webProvider"); | ||
exports.WebProvider = webProvider_1.WebProvider; | ||
Object.defineProperty(exports, "WebProvider", { enumerable: true, get: function () { return webProvider_1.WebProvider; } }); | ||
var filesystemProvider_1 = require("./filesystemProvider"); | ||
exports.FilesystemProvider = filesystemProvider_1.FilesystemProvider; | ||
Object.defineProperty(exports, "FilesystemProvider", { enumerable: true, get: function () { return filesystemProvider_1.FilesystemProvider; } }); | ||
var zipProvider_1 = require("./zipProvider"); | ||
exports.ZipProvider = zipProvider_1.ZipProvider; | ||
Object.defineProperty(exports, "ZipProvider", { enumerable: true, get: function () { return zipProvider_1.ZipProvider; } }); | ||
var stubProvider_1 = require("./stubProvider"); | ||
exports.StubProvider = stubProvider_1.StubProvider; | ||
Object.defineProperty(exports, "StubProvider", { enumerable: true, get: function () { return stubProvider_1.StubProvider; } }); | ||
//# sourceMappingURL=index.js.map |
@@ -0,1 +1,2 @@ | ||
/// <reference types="node" /> | ||
import * as models from '../Models'; | ||
@@ -2,0 +3,0 @@ import { ItemType } from '../Models'; |
"use strict"; | ||
var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) { | ||
function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); } | ||
return new (P || (P = Promise))(function (resolve, reject) { | ||
function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } } | ||
function rejected(value) { try { step(generator.throw(value)); } catch (e) { reject(e); } } | ||
function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); } | ||
step((generator = generator.apply(thisArg, _arguments)).next()); | ||
function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } } | ||
function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); } | ||
step((generator = generator.apply(thisArg, _arguments || [])).next()); | ||
}); | ||
}; | ||
const Stream = require('stream'); | ||
const models = require('../Models'); | ||
const Models_1 = require('../Models'); | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.StubProvider = void 0; | ||
const Stream = require("stream"); | ||
const models = require("../Models"); | ||
const Models_1 = require("../Models"); | ||
class StubProvider { | ||
@@ -22,3 +25,3 @@ constructor() { | ||
getRootItems() { | ||
return __awaiter(this, void 0, Promise, function* () { | ||
return __awaiter(this, void 0, void 0, function* () { | ||
this.getRootItemsCalledCount++; | ||
@@ -29,3 +32,3 @@ return [this.getItem(1, 1, 3, Models_1.ItemType.File), this.getItem(1, 2, 3, Models_1.ItemType.File), this.getItem(1, 3, 3, Models_1.ItemType.File), this.getItem(2, 1, 1, Models_1.ItemType.Folder), this.getItem(3, 1, 5, Models_1.ItemType.File), this.getItem(4, 1, 3, Models_1.ItemType.File), this.getItem(5, 1, 4, Models_1.ItemType.Folder)]; | ||
getArtifactItems(artifactItem) { | ||
return __awaiter(this, void 0, Promise, function* () { | ||
return __awaiter(this, void 0, void 0, function* () { | ||
this.getArtifactItemsCalledCount++; | ||
@@ -39,3 +42,3 @@ if (artifactItem.path === 'path5') { | ||
getArtifactItem(artifactItem) { | ||
return __awaiter(this, void 0, Promise, function* () { | ||
return __awaiter(this, void 0, void 0, function* () { | ||
this.getArtifactItemCalledCount++; | ||
@@ -42,0 +45,0 @@ this.itemsDownloaded.push(artifactItem); |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.PersonalAccessTokenCredentialHandler = exports.NtlmCredentialHandler = exports.BearerCredentialHandler = exports.BasicCredentialHandler = void 0; | ||
var basiccreds_1 = require("./handlers/basiccreds"); | ||
exports.BasicCredentialHandler = basiccreds_1.BasicCredentialHandler; | ||
Object.defineProperty(exports, "BasicCredentialHandler", { enumerable: true, get: function () { return basiccreds_1.BasicCredentialHandler; } }); | ||
var bearertoken_1 = require("./handlers/bearertoken"); | ||
exports.BearerCredentialHandler = bearertoken_1.BearerCredentialHandler; | ||
Object.defineProperty(exports, "BearerCredentialHandler", { enumerable: true, get: function () { return bearertoken_1.BearerCredentialHandler; } }); | ||
var ntlm_1 = require("./handlers/ntlm"); | ||
exports.NtlmCredentialHandler = ntlm_1.NtlmCredentialHandler; | ||
Object.defineProperty(exports, "NtlmCredentialHandler", { enumerable: true, get: function () { return ntlm_1.NtlmCredentialHandler; } }); | ||
var personalaccesstoken_1 = require("./handlers/personalaccesstoken"); | ||
exports.PersonalAccessTokenCredentialHandler = personalaccesstoken_1.PersonalAccessTokenCredentialHandler; | ||
Object.defineProperty(exports, "PersonalAccessTokenCredentialHandler", { enumerable: true, get: function () { return personalaccesstoken_1.PersonalAccessTokenCredentialHandler; } }); | ||
//# sourceMappingURL=Handlers.js.map |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.BasicCredentialHandler = void 0; | ||
class BasicCredentialHandler { | ||
@@ -3,0 +5,0 @@ constructor(username, password) { |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.BearerCredentialHandler = void 0; | ||
class BearerCredentialHandler { | ||
@@ -3,0 +5,0 @@ constructor(token) { |
@@ -11,4 +11,4 @@ import ifm = require('../Interfaces'); | ||
handleAuthentication(httpClient: any, protocol: any, options: any, objs: any, finalCallback: any): void; | ||
private sendType1Message(httpClient, protocol, options, objs, keepaliveAgent, callback); | ||
private sendType3Message(httpClient, protocol, options, objs, keepaliveAgent, res, callback); | ||
private sendType1Message; | ||
private sendType3Message; | ||
} |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.NtlmCredentialHandler = void 0; | ||
const http = require("http"); | ||
@@ -3,0 +5,0 @@ const https = require("https"); |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.PersonalAccessTokenCredentialHandler = void 0; | ||
class PersonalAccessTokenCredentialHandler { | ||
@@ -3,0 +5,0 @@ constructor(token) { |
@@ -0,1 +1,2 @@ | ||
/// <reference types="node" /> | ||
import url = require("url"); | ||
@@ -29,3 +30,3 @@ import http = require("http"); | ||
ServiceUnavailable = 503, | ||
GatewayTimeout = 504, | ||
GatewayTimeout = 504 | ||
} | ||
@@ -72,7 +73,7 @@ export declare class HttpClientResponse { | ||
dispose(): void; | ||
private _requestRaw(info, data); | ||
private _prepareRequest(method, requestUrl, headers); | ||
private _getAgent(requestUrl); | ||
private _getProxy(requestUrl); | ||
private _isBypassProxy(requestUrl); | ||
private _requestRaw; | ||
private _prepareRequest; | ||
private _getAgent; | ||
private _getProxy; | ||
private _isBypassProxy; | ||
} |
"use strict"; | ||
var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) { | ||
function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); } | ||
return new (P || (P = Promise))(function (resolve, reject) { | ||
function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } } | ||
function rejected(value) { try { step(generator.throw(value)); } catch (e) { reject(e); } } | ||
function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); } | ||
step((generator = generator.apply(thisArg, _arguments)).next()); | ||
function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } } | ||
function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); } | ||
step((generator = generator.apply(thisArg, _arguments || [])).next()); | ||
}); | ||
}; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.HttpClient = exports.isHttps = exports.HttpClientResponse = exports.HttpCodes = void 0; | ||
const url = require("url"); | ||
@@ -14,3 +17,4 @@ const http = require("http"); | ||
var tunnel = require("tunnel"); | ||
const fs = require('fs'); | ||
const fs = require("fs"); | ||
var HttpCodes; | ||
(function (HttpCodes) { | ||
@@ -42,4 +46,3 @@ HttpCodes[HttpCodes["OK"] = 200] = "OK"; | ||
HttpCodes[HttpCodes["GatewayTimeout"] = 504] = "GatewayTimeout"; | ||
})(exports.HttpCodes || (exports.HttpCodes = {})); | ||
var HttpCodes = exports.HttpCodes; | ||
})(HttpCodes = exports.HttpCodes || (exports.HttpCodes = {})); | ||
const HttpRedirectCodes = [HttpCodes.MovedPermanently, HttpCodes.ResourceMoved, HttpCodes.TemporaryRedirect, HttpCodes.PermanentRedirect]; | ||
@@ -141,3 +144,3 @@ class HttpClientResponse { | ||
request(verb, requestUrl, data, headers) { | ||
return __awaiter(this, void 0, Promise, function* () { | ||
return __awaiter(this, void 0, void 0, function* () { | ||
if (this._disposed) { | ||
@@ -144,0 +147,0 @@ throw new Error("Client has already been disposed"); |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
//# sourceMappingURL=Index.js.map |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
; | ||
//# sourceMappingURL=Interfaces.js.map |
@@ -0,1 +1,2 @@ | ||
/// <reference types="node" /> | ||
import httpm = require('./HttpClient'); | ||
@@ -24,4 +25,4 @@ import ifm = require("./Interfaces"); | ||
uploadStream<T>(verb: string, requestUrl: string, stream: NodeJS.ReadableStream, options?: IRequestOptions): Promise<IRestResponse<T>>; | ||
private _headersFromOptions(options, contentType?); | ||
private _processResponse<T>(res, options); | ||
private _headersFromOptions; | ||
private _processResponse; | ||
} |
"use strict"; | ||
var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) { | ||
function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); } | ||
return new (P || (P = Promise))(function (resolve, reject) { | ||
function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } } | ||
function rejected(value) { try { step(generator.throw(value)); } catch (e) { reject(e); } } | ||
function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); } | ||
step((generator = generator.apply(thisArg, _arguments)).next()); | ||
function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } } | ||
function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); } | ||
step((generator = generator.apply(thisArg, _arguments || [])).next()); | ||
}); | ||
}; | ||
const httpm = require('./HttpClient'); | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.RestClient = void 0; | ||
const httpm = require("./HttpClient"); | ||
const util = require("./Util"); | ||
@@ -20,3 +23,3 @@ class RestClient { | ||
options(requestUrl, options) { | ||
return __awaiter(this, void 0, Promise, function* () { | ||
return __awaiter(this, void 0, void 0, function* () { | ||
let url = util.getUrl(requestUrl, this._baseUrl); | ||
@@ -28,3 +31,3 @@ let res = yield this.client.options(url, this._headersFromOptions(options)); | ||
get(requestUrl, options) { | ||
return __awaiter(this, void 0, Promise, function* () { | ||
return __awaiter(this, void 0, void 0, function* () { | ||
let url = util.getUrl(requestUrl, this._baseUrl); | ||
@@ -36,3 +39,3 @@ let res = yield this.client.get(url, this._headersFromOptions(options)); | ||
del(requestUrl, options) { | ||
return __awaiter(this, void 0, Promise, function* () { | ||
return __awaiter(this, void 0, void 0, function* () { | ||
let url = util.getUrl(requestUrl, this._baseUrl); | ||
@@ -44,3 +47,3 @@ let res = yield this.client.del(url, this._headersFromOptions(options)); | ||
create(requestUrl, resources, options) { | ||
return __awaiter(this, void 0, Promise, function* () { | ||
return __awaiter(this, void 0, void 0, function* () { | ||
let url = util.getUrl(requestUrl, this._baseUrl); | ||
@@ -54,3 +57,3 @@ let headers = this._headersFromOptions(options, true); | ||
update(requestUrl, resources, options) { | ||
return __awaiter(this, void 0, Promise, function* () { | ||
return __awaiter(this, void 0, void 0, function* () { | ||
let url = util.getUrl(requestUrl, this._baseUrl); | ||
@@ -64,3 +67,3 @@ let headers = this._headersFromOptions(options, true); | ||
replace(requestUrl, resources, options) { | ||
return __awaiter(this, void 0, Promise, function* () { | ||
return __awaiter(this, void 0, void 0, function* () { | ||
let url = util.getUrl(requestUrl, this._baseUrl); | ||
@@ -74,3 +77,3 @@ let headers = this._headersFromOptions(options, true); | ||
uploadStream(verb, requestUrl, stream, options) { | ||
return __awaiter(this, void 0, Promise, function* () { | ||
return __awaiter(this, void 0, void 0, function* () { | ||
let url = util.getUrl(requestUrl, this._baseUrl); | ||
@@ -92,3 +95,3 @@ let headers = this._headersFromOptions(options, true); | ||
_processResponse(res, options) { | ||
return __awaiter(this, void 0, Promise, function* () { | ||
return __awaiter(this, void 0, void 0, function* () { | ||
return new Promise((resolve, reject) => __awaiter(this, void 0, void 0, function* () { | ||
@@ -95,0 +98,0 @@ let rres = {}; |
"use strict"; | ||
const url = require('url'); | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.getUrl = void 0; | ||
const url = require("url"); | ||
function getUrl(requestUrl, baseUrl) { | ||
@@ -4,0 +6,0 @@ if (!baseUrl) { |
"use strict"; | ||
var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) { | ||
function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); } | ||
return new (P || (P = Promise))(function (resolve, reject) { | ||
function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } } | ||
function rejected(value) { try { step(generator.throw(value)); } catch (e) { reject(e); } } | ||
function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); } | ||
step((generator = generator.apply(thisArg, _arguments)).next()); | ||
function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } } | ||
function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); } | ||
step((generator = generator.apply(thisArg, _arguments || [])).next()); | ||
}); | ||
}; | ||
const httpm = require('./typed-rest-client/HttpClient'); | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.WebClient = void 0; | ||
const httpm = require("./typed-rest-client/HttpClient"); | ||
var tl = require('azure-pipelines-task-lib/task'); | ||
@@ -12,0 +15,0 @@ var packagejson = require('../package.json'); |
export declare class WebClientFactory { | ||
static getClient(handlers: any[], options: any): any; | ||
private static initializeProxy(options); | ||
private static _readTaskLibSecrets(lookupKey); | ||
private static initializeProxy; | ||
private static _readTaskLibSecrets; | ||
} |
"use strict"; | ||
const fs = require('fs'); | ||
const crypto = require('crypto'); | ||
const webClient_1 = require('./webClient'); | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.WebClientFactory = void 0; | ||
const fs = require("fs"); | ||
const crypto = require("crypto"); | ||
const webClient_1 = require("./webClient"); | ||
class WebClientFactory { | ||
@@ -6,0 +8,0 @@ static getClient(handlers, options) { |
@@ -0,1 +1,2 @@ | ||
/// <reference types="node" /> | ||
import * as stream from 'stream'; | ||
@@ -14,5 +15,5 @@ import { ArtifactItem, IArtifactProvider } from '../Models'; | ||
dispose(): void; | ||
private getItems(itemsUrl, contentType); | ||
private getTemplateFilePath(); | ||
private extend(target, source); | ||
private getItems; | ||
private getTemplateFilePath; | ||
private extend; | ||
private rootItemsLocation; | ||
@@ -19,0 +20,0 @@ private templateFile; |
"use strict"; | ||
const fs = require('fs'); | ||
const path = require('path'); | ||
const zlib = require('zlib'); | ||
const Models_1 = require('../Models'); | ||
const logger_1 = require('../Engine/logger'); | ||
const webClientFactory_1 = require('./webClientFactory'); | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.WebProvider = void 0; | ||
const fs = require("fs"); | ||
const path = require("path"); | ||
const zlib = require("zlib"); | ||
const Models_1 = require("../Models"); | ||
const logger_1 = require("../Engine/logger"); | ||
const webClientFactory_1 = require("./webClientFactory"); | ||
var handlebars = require('handlebars'); | ||
@@ -9,0 +11,0 @@ var tl = require('azure-pipelines-task-lib/task'); |
@@ -0,1 +1,2 @@ | ||
/// <reference types="node" /> | ||
import { ArtifactItemStore } from '../Store/artifactItemStore'; | ||
@@ -2,0 +3,0 @@ import { ArtifactItem, IArtifactProvider } from '../Models'; |
"use strict"; | ||
const Models_1 = require('../Models'); | ||
const factory = require('./webClientFactory'); | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.ZipProvider = void 0; | ||
const Models_1 = require("../Models"); | ||
const factory = require("./webClientFactory"); | ||
class ZipProvider { | ||
@@ -5,0 +7,0 @@ constructor(zipLocation, handler, requestOptions) { |
"use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.ArtifactItemStore = void 0; | ||
const models = require("../Models"); | ||
@@ -3,0 +5,0 @@ class ArtifactItemStore { |
"use strict"; | ||
var artifactItemStore_1 = require('./artifactItemStore'); | ||
exports.ArtifactItemStore = artifactItemStore_1.ArtifactItemStore; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.ArtifactItemStore = void 0; | ||
var artifactItemStore_1 = require("./artifactItemStore"); | ||
Object.defineProperty(exports, "ArtifactItemStore", { enumerable: true, get: function () { return artifactItemStore_1.ArtifactItemStore; } }); | ||
//# sourceMappingURL=index.js.map |
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
NPM Shrinkwrap
Supply chain riskPackage contains a shrinkwrap file. This may allow the package to bypass normal install procedures.
Found 1 instance in 1 package
New author
Supply chain riskA new npm collaborator published a version of the package for the first time. New collaborators are usually benign additions to a project, but do indicate a change to the security surface area of a package.
Found 1 instance in 1 package
Filesystem access
Supply chain riskAccesses the file system, and could potentially read sensitive data.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
Filesystem access
Supply chain riskAccesses the file system, and could potentially read sensitive data.
Found 1 instance in 1 package
283517
15
84
6177
1
5
+ Added@types/concat-stream@1.6.1(transitive)
+ Added@types/form-data@0.0.33(transitive)
+ Added@types/node@10.17.608.10.66(transitive)
+ Added@types/qs@6.9.17(transitive)
+ Addedasap@2.0.6(transitive)
+ Addedasynckit@0.4.0(transitive)
+ Addedazure-pipelines-task-lib@3.4.0(transitive)
+ Addedbuffer-from@1.1.2(transitive)
+ Addedcall-bind@1.0.7(transitive)
+ Addedcaseless@0.12.0(transitive)
+ Addedcombined-stream@1.0.8(transitive)
+ Addedconcat-stream@1.6.2(transitive)
+ Addedcore-util-is@1.0.3(transitive)
+ Addeddefine-data-property@1.1.4(transitive)
+ Addeddelayed-stream@1.0.0(transitive)
+ Addedes-define-property@1.0.0(transitive)
+ Addedes-errors@1.3.0(transitive)
+ Addedform-data@2.5.2(transitive)
+ Addedfs.realpath@1.0.0(transitive)
+ Addedfunction-bind@1.1.2(transitive)
+ Addedget-intrinsic@1.2.4(transitive)
+ Addedget-port@3.2.0(transitive)
+ Addedglob@7.2.3(transitive)
+ Addedgopd@1.0.1(transitive)
+ Addedhas-property-descriptors@1.0.2(transitive)
+ Addedhas-proto@1.0.3(transitive)
+ Addedhas-symbols@1.0.3(transitive)
+ Addedhasown@2.0.2(transitive)
+ Addedhttp-basic@8.1.3(transitive)
+ Addedhttp-response-object@3.0.2(transitive)
+ Addedinflight@1.0.6(transitive)
+ Addedinherits@2.0.4(transitive)
+ Addedinterpret@1.4.0(transitive)
+ Addedis-core-module@2.15.1(transitive)
+ Addedisarray@1.0.0(transitive)
+ Addedmime-db@1.52.0(transitive)
+ Addedmime-types@2.1.35(transitive)
+ Addedminimatch@3.0.53.1.2(transitive)
+ Addedmockery@2.1.0(transitive)
+ Addedobject-inspect@1.13.3(transitive)
+ Addedonce@1.4.0(transitive)
+ Addedparse-cache-control@1.0.1(transitive)
+ Addedpath-is-absolute@1.0.1(transitive)
+ Addedpath-parse@1.0.7(transitive)
+ Addedprocess-nextick-args@2.0.1(transitive)
+ Addedpromise@8.3.0(transitive)
+ Addedqs@6.13.1(transitive)
+ Addedreadable-stream@2.3.8(transitive)
+ Addedrechoir@0.6.2(transitive)
+ Addedresolve@1.22.8(transitive)
+ Addedsafe-buffer@5.1.25.2.1(transitive)
+ Addedset-function-length@1.2.2(transitive)
+ Addedshelljs@0.8.5(transitive)
+ Addedside-channel@1.0.6(transitive)
+ Addedstring_decoder@1.1.1(transitive)
+ Addedsupports-preserve-symlinks-flag@1.0.0(transitive)
+ Addedsync-request@6.1.0(transitive)
+ Addedsync-rpc@1.3.6(transitive)
+ Addedthen-request@6.0.2(transitive)
+ Addedtypedarray@0.0.6(transitive)
+ Addedutil-deprecate@1.0.2(transitive)
+ Addedwrappy@1.0.2(transitive)
- Removedazure-pipelines-task-lib@2.8.0(transitive)
- Removedminimatch@3.0.4(transitive)
- Removedmockery@1.7.0(transitive)
- Removedshelljs@0.3.0(transitive)