Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More
Socket
Sign inDemoInstall
Socket

artifact-engine

Package Overview
Dependencies
Maintainers
4
Versions
43
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

artifact-engine - npm Package Compare versions

Comparing version 0.1.29 to 1.0.0-preview.0

npm-shrinkwrap.json

2

Engine/artifactEngine.d.ts

@@ -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

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc