Skip to content

Commit

Permalink
lint fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
Gareth Emslie committed Sep 28, 2021
1 parent ea7a15f commit 8ec5292
Show file tree
Hide file tree
Showing 6 changed files with 637 additions and 499 deletions.
19 changes: 14 additions & 5 deletions libs/nexus-v2/IhttpHelper.ts
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,15 @@
export interface IhttpHelper {
execute_http(searchUri : URL) : Promise<string>;
execute_http(searchUri : URL, username? : string, password? : string) : Promise<string>;
execute_https(searchUri : URL, acceptUntrustedCerts : boolean) : Promise<string>;
execute_https(searchUri : URL, acceptUntrustedCerts : boolean, username? : string, password? : string) : Promise<string>;
};
execute_http(searchUri: URL): Promise<string>;
execute_http(
searchUri: URL,
username?: string,
password?: string
): Promise<string>;
execute_https(searchUri: URL, acceptUntrustedCerts: boolean): Promise<string>;
execute_https(
searchUri: URL,
acceptUntrustedCerts: boolean,
username?: string,
password?: string
): Promise<string>;
}
316 changes: 173 additions & 143 deletions libs/nexus-v2/httpHelper.ts
View file
Original file line number Diff line number Diff line change
@@ -1,157 +1,187 @@
import tl = require('azure-pipelines-task-lib/task');
import path = require("path");
import path = require('path');
import fs = require('fs');
import http = require('http');
import https = require('https');
import { IhttpHelper } from './IhttpHelper';

export class httpHelper implements IhttpHelper {
public async execute_http(searchUri : URL) : Promise<string>;
public async execute_http(searchUri : URL, username? : string, password? : string) : Promise<string>
{
tl.debug(`execute_http.`);

let options : http.RequestOptions = {
host: searchUri.hostname,
path: `${searchUri.pathname}?${searchUri.searchParams}`,
method: 'GET',
headers: {
'Accept': 'application/xml'
}
};

if(username &&
password)
{
const authBase64 : string = Buffer.from(username + ':' + password).toString('base64');

// Make sure the secret is correctly scrubbed from any logs
tl.setSecret(authBase64);
options.headers['Authorization'] = 'Basic ' + authBase64;
}

// Setup new agent dont use the global one
options.agent = new http.Agent();
options.port = searchUri.port || options.defaultPort;

// execute the http request
return await this.execute_request(http, options);
public async execute_http(searchUri: URL): Promise<string>;
public async execute_http(
searchUri: URL,
username?: string,
password?: string
): Promise<string> {
tl.debug('execute_http.');

const options: http.RequestOptions = {
host: searchUri.hostname,
path: `${searchUri.pathname}?${searchUri.searchParams}`,
method: 'GET',
headers: {
Accept: 'application/xml',
},
};

if (username && password) {
const authBase64: string = Buffer.from(
username + ':' + password
).toString('base64');

// Make sure the secret is correctly scrubbed from any logs
tl.setSecret(authBase64);
options.headers['Authorization'] = 'Basic ' + authBase64;
}

public async execute_https(searchUri : URL, acceptUntrustedCerts : boolean) : Promise<string>;
public async execute_https(searchUri : URL, acceptUntrustedCerts : boolean, username? : string, password? : string) : Promise<string>
{
tl.debug(`execute_https.`);

let options : https.RequestOptions = {
host: searchUri.hostname,
path: `${searchUri.pathname}?${searchUri.searchParams}`,
method: 'GET',
rejectUnauthorized: !acceptUntrustedCerts, // By default ensure we validate SSL certificates
headers: {
'Accept': 'application/xml'
}
};

if(username &&
password)
{
const authBase64 : string = Buffer.from(username + ':' + password).toString('base64');

// Make sure the secret is correctly scrubbed from any logs
tl.setSecret(authBase64);
options.headers['Authorization'] = 'Basic ' + authBase64;
}

// Setup new agent dont use the global one
options.agent = new https.Agent();
options.port = searchUri.port || options.defaultPort;

// execute the https request
return await this.execute_request(https, options);
// Setup new agent dont use the global one
options.agent = new http.Agent();
options.port = searchUri.port || options.defaultPort;

// execute the http request
return await this.execute_request(http, options);
}

public async execute_https(
searchUri: URL,
acceptUntrustedCerts: boolean
): Promise<string>;
public async execute_https(
searchUri: URL,
acceptUntrustedCerts: boolean,
username?: string,
password?: string
): Promise<string> {
tl.debug('execute_https.');

const options: https.RequestOptions = {
host: searchUri.hostname,
path: `${searchUri.pathname}?${searchUri.searchParams}`,
method: 'GET',
rejectUnauthorized: !acceptUntrustedCerts, // By default ensure we validate SSL certificates
headers: {
Accept: 'application/xml',
},
};

if (username && password) {
const authBase64: string = Buffer.from(
username + ':' + password
).toString('base64');

// Make sure the secret is correctly scrubbed from any logs
tl.setSecret(authBase64);
options.headers['Authorization'] = 'Basic ' + authBase64;
}

private async execute_request(client : any, options : http.RequestOptions | https.RequestOptions) : Promise<string>
{
tl.debug(`HTTP Request Options: ${JSON.stringify(options)}.`);

return new Promise((resolve, reject) => {
let req : http.ClientRequest = client.request(options, function(res : http.IncomingMessage) {
tl.debug(`HTTP Response Status Code: ${res.statusCode}.`);
tl.debug(`HTTP Response Status Message: ${res.statusMessage}.`);
tl.debug(`HTTP Response Headers: ${JSON.stringify(res.headers)}.`);

if (res.statusCode == 301 || res.statusCode == 307) {
const downloadUri : URL = new URL(res.headers.location);

// Set correct options for the new request to download our file
options.host = downloadUri.hostname;
options.path = downloadUri.pathname;
options.port = downloadUri.port || options.defaultPort;

console.log(`Download file using '${downloadUri}'.`);
let filename : string = path.basename(downloadUri.pathname);
console.log(`Download filename '${filename}'`);

let inner_req : http.ClientRequest = client.request(options, function(inner_res : http.IncomingMessage) {
tl.debug(`HTTP Response Status Code: ${inner_res.statusCode}.`);
tl.debug(`HTTP Response Status Message: ${inner_res.statusMessage}.`);
tl.debug(`HTTP Response Headers: ${JSON.stringify(inner_res.headers)}.`);

if(inner_res.statusCode == 200)
{
const file : fs.WriteStream = fs.createWriteStream(filename);
inner_res.on('data', function(chunk : any){
file.write(chunk);
}).on('end', function(){
file.end();

// Maintain a list of files that have been downloaded and set a pipeline variable containing the list
let MAVEN_REPOSITORY_ASSET_FILENAMES : string = tl.getVariable("MAVEN_REPOSITORY_ASSET_FILENAMES");
if(MAVEN_REPOSITORY_ASSET_FILENAMES)
{
if(!MAVEN_REPOSITORY_ASSET_FILENAMES.includes(filename))
{
tl.setVariable("MAVEN_REPOSITORY_ASSET_FILENAMES", `${MAVEN_REPOSITORY_ASSET_FILENAMES},${filename}`, false);
}
}
else
{
tl.setVariable("MAVEN_REPOSITORY_ASSET_FILENAMES", filename, false);
}

console.log(`Successfully downloaded asset '${filename}' using '${downloadUri}'.`);
resolve();
});
} else
{
console.log(`Asset download was not successful!`);
reject(`Asset download was not successful!`);
// Setup new agent dont use the global one
options.agent = new https.Agent();
options.port = searchUri.port || options.defaultPort;

// execute the https request
return await this.execute_request(https, options);
}

private async execute_request(
client: any,
options: http.RequestOptions | https.RequestOptions
): Promise<string> {
tl.debug(`HTTP Request Options: ${JSON.stringify(options)}.`);

return new Promise((resolve, reject) => {
const req: http.ClientRequest = client.request(
options,
function (res: http.IncomingMessage) {
tl.debug(`HTTP Response Status Code: ${res.statusCode}.`);
tl.debug(`HTTP Response Status Message: ${res.statusMessage}.`);
tl.debug(`HTTP Response Headers: ${JSON.stringify(res.headers)}.`);

if (res.statusCode == 301 || res.statusCode == 307) {
const downloadUri: URL = new URL(res.headers.location);

// Set correct options for the new request to download our file
options.host = downloadUri.hostname;
options.path = downloadUri.pathname;
options.port = downloadUri.port || options.defaultPort;

console.log(`Download file using '${downloadUri}'.`);
const filename: string = path.basename(downloadUri.pathname);
console.log(`Download filename '${filename}'`);

const inner_req: http.ClientRequest = client.request(
options,
function (inner_res: http.IncomingMessage) {
tl.debug(`HTTP Response Status Code: ${inner_res.statusCode}.`);
tl.debug(
`HTTP Response Status Message: ${inner_res.statusMessage}.`
);
tl.debug(
`HTTP Response Headers: ${JSON.stringify(inner_res.headers)}.`
);

if (inner_res.statusCode == 200) {
const file: fs.WriteStream = fs.createWriteStream(filename);
inner_res
.on('data', function (chunk: any) {
file.write(chunk);
})
.on('end', function () {
file.end();

// Maintain a list of files that have been downloaded and set a pipeline variable containing the list
const MAVEN_REPOSITORY_ASSET_FILENAMES: string =
tl.getVariable('MAVEN_REPOSITORY_ASSET_FILENAMES');
if (MAVEN_REPOSITORY_ASSET_FILENAMES) {
if (
!MAVEN_REPOSITORY_ASSET_FILENAMES.includes(filename)
) {
tl.setVariable(
'MAVEN_REPOSITORY_ASSET_FILENAMES',
`${MAVEN_REPOSITORY_ASSET_FILENAMES},${filename}`,
false
);
}
} else {
tl.setVariable(
'MAVEN_REPOSITORY_ASSET_FILENAMES',
filename,
false
);
}

console.log(
`Successfully downloaded asset '${filename}' using '${downloadUri}'.`
);
resolve();
});
inner_req.end();
}else if(res.statusCode == 200)
{
tl.debug(`Http Get request was successful!`);
// get response body
const body = [];
res.on('data', (chunk) => body.push(chunk));
// we are done, resolve promise with those joined chunks
res.on('end', () => resolve(body.join('')));
}else
{
tl.debug(`Asset search was not successful!`);
let message : string = `Asset search was not successful!`;
if (res.statusCode == 401) {
message = `Invalid Nexus Repo Manager credentials!`;
} else if (res.statusCode == 404) {
message = `Asset does not exist for search, or invalid Nexus Repo Manager Url!`;
}
console.log(message);
reject(message);
} else {
console.log('Asset download was not successful!');
reject('Asset download was not successful!');
}
});
req.end();
});
}
}
}
);
inner_req.end();
} else if (res.statusCode == 200) {
tl.debug('Http Get request was successful!');
// get response body
const body = [];
res.on('data', (chunk) => body.push(chunk));
// we are done, resolve promise with those joined chunks
res.on('end', () => resolve(body.join('')));
} else {
tl.debug('Asset search was not successful!');
let message = 'Asset search was not successful!';
if (res.statusCode == 401) {
message = 'Invalid Nexus Repo Manager credentials!';
} else if (res.statusCode == 404) {
message =
'Asset does not exist for search, or invalid Nexus Repo Manager Url!';
}
console.log(message);
reject(message);
}
}
);
req.end();
});
}
}
Loading

0 comments on commit 8ec5292

Please sign in to comment.