2019-11-24 06:44:53 +07:00
module . exports =
/******/ ( function ( modules , runtime ) { // webpackBootstrap
/******/ "use strict" ;
/******/ // The module cache
/******/ var installedModules = { } ;
/******/
/******/ // The require function
/******/ function _ _webpack _require _ _ ( moduleId ) {
/******/
/******/ // Check if module is in cache
/******/ if ( installedModules [ moduleId ] ) {
/******/ return installedModules [ moduleId ] . exports ;
/******/ }
/******/ // Create a new module (and put it into the cache)
/******/ var module = installedModules [ moduleId ] = {
/******/ i : moduleId ,
/******/ l : false ,
/******/ exports : { }
/******/ } ;
/******/
/******/ // Execute the module function
2020-06-08 08:39:31 +07:00
/******/ var threw = true ;
/******/ try {
/******/ modules [ moduleId ] . call ( module . exports , module , module . exports , _ _webpack _require _ _ ) ;
/******/ threw = false ;
/******/ } finally {
/******/ if ( threw ) delete installedModules [ moduleId ] ;
/******/ }
2019-11-24 06:44:53 +07:00
/******/
/******/ // Flag the module as loaded
/******/ module . l = true ;
/******/
/******/ // Return the exports of the module
/******/ return module . exports ;
/******/ }
/******/
/******/
/******/ _ _webpack _require _ _ . ab = _ _dirname + "/" ;
/******/
/******/ // the startup function
/******/ function startup ( ) {
/******/ // Load entry module and return exports
/******/ return _ _webpack _require _ _ ( 655 ) ;
/******/ } ;
/******/
/******/ // run startup
/******/ return startup ( ) ;
/******/ } )
/************************************************************************/
/******/ ( {
2019-12-10 06:52:33 +07:00
/***/ 1 :
/***/ ( function ( _ _unusedmodule , exports , _ _webpack _require _ _ ) {
"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 ) : adopt ( result . value ) . then ( fulfilled , rejected ) ; }
step ( ( generator = generator . apply ( thisArg , _arguments || [ ] ) ) . next ( ) ) ;
} ) ;
} ;
Object . defineProperty ( exports , "__esModule" , { value : true } ) ;
const childProcess = _ _webpack _require _ _ ( 129 ) ;
const path = _ _webpack _require _ _ ( 622 ) ;
const util _1 = _ _webpack _require _ _ ( 669 ) ;
const ioUtil = _ _webpack _require _ _ ( 672 ) ;
const exec = util _1 . promisify ( childProcess . exec ) ;
/ * *
* Copies a file or folder .
* Based off of shelljs - https : //github.com/shelljs/shelljs/blob/9237f66c52e5daa40458f94f9565e18e8132f5a6/src/cp.js
*
* @ param source source path
* @ param dest destination path
* @ param options optional . See CopyOptions .
* /
function cp ( source , dest , options = { } ) {
return _ _awaiter ( this , void 0 , void 0 , function * ( ) {
const { force , recursive } = readCopyOptions ( options ) ;
const destStat = ( yield ioUtil . exists ( dest ) ) ? yield ioUtil . stat ( dest ) : null ;
// Dest is an existing file, but not forcing
if ( destStat && destStat . isFile ( ) && ! force ) {
return ;
}
// If dest is an existing directory, should copy inside.
const newDest = destStat && destStat . isDirectory ( )
? path . join ( dest , path . basename ( source ) )
: dest ;
if ( ! ( yield ioUtil . exists ( source ) ) ) {
throw new Error ( ` no such file or directory: ${ source } ` ) ;
}
const sourceStat = yield ioUtil . stat ( source ) ;
if ( sourceStat . isDirectory ( ) ) {
if ( ! recursive ) {
throw new Error ( ` Failed to copy. ${ source } is a directory, but tried to copy without recursive flag. ` ) ;
}
else {
yield cpDirRecursive ( source , newDest , 0 , force ) ;
}
}
else {
if ( path . relative ( source , newDest ) === '' ) {
// a file cannot be copied to itself
throw new Error ( ` ' ${ newDest } ' and ' ${ source } ' are the same file ` ) ;
}
yield copyFile ( source , newDest , force ) ;
}
} ) ;
}
exports . cp = cp ;
/ * *
* Moves a path .
*
* @ param source source path
* @ param dest destination path
* @ param options optional . See MoveOptions .
* /
function mv ( source , dest , options = { } ) {
return _ _awaiter ( this , void 0 , void 0 , function * ( ) {
if ( yield ioUtil . exists ( dest ) ) {
let destExists = true ;
if ( yield ioUtil . isDirectory ( dest ) ) {
// If dest is directory copy src into dest
dest = path . join ( dest , path . basename ( source ) ) ;
destExists = yield ioUtil . exists ( dest ) ;
}
if ( destExists ) {
if ( options . force == null || options . force ) {
yield rmRF ( dest ) ;
}
else {
throw new Error ( 'Destination already exists' ) ;
}
}
}
yield mkdirP ( path . dirname ( dest ) ) ;
yield ioUtil . rename ( source , dest ) ;
} ) ;
}
exports . mv = mv ;
/ * *
* Remove a path recursively with force
*
* @ param inputPath path to remove
* /
function rmRF ( inputPath ) {
return _ _awaiter ( this , void 0 , void 0 , function * ( ) {
if ( ioUtil . IS _WINDOWS ) {
// Node doesn't provide a delete operation, only an unlink function. This means that if the file is being used by another
// program (e.g. antivirus), it won't be deleted. To address this, we shell out the work to rd/del.
try {
if ( yield ioUtil . isDirectory ( inputPath , true ) ) {
yield exec ( ` rd /s /q " ${ inputPath } " ` ) ;
}
else {
yield exec ( ` del /f /a " ${ inputPath } " ` ) ;
}
}
catch ( err ) {
// if you try to delete a file that doesn't exist, desired result is achieved
// other errors are valid
if ( err . code !== 'ENOENT' )
throw err ;
}
// Shelling out fails to remove a symlink folder with missing source, this unlink catches that
try {
yield ioUtil . unlink ( inputPath ) ;
}
catch ( err ) {
// if you try to delete a file that doesn't exist, desired result is achieved
// other errors are valid
if ( err . code !== 'ENOENT' )
throw err ;
}
}
else {
let isDir = false ;
try {
isDir = yield ioUtil . isDirectory ( inputPath ) ;
}
catch ( err ) {
// if you try to delete a file that doesn't exist, desired result is achieved
// other errors are valid
if ( err . code !== 'ENOENT' )
throw err ;
return ;
}
if ( isDir ) {
yield exec ( ` rm -rf " ${ inputPath } " ` ) ;
}
else {
yield ioUtil . unlink ( inputPath ) ;
}
}
} ) ;
}
exports . rmRF = rmRF ;
/ * *
* Make a directory . Creates the full path with folders in between
* Will throw if it fails
*
* @ param fsPath path to create
* @ returns Promise < void >
* /
function mkdirP ( fsPath ) {
return _ _awaiter ( this , void 0 , void 0 , function * ( ) {
yield ioUtil . mkdirP ( fsPath ) ;
} ) ;
}
exports . mkdirP = mkdirP ;
/ * *
* Returns path of a tool had the tool actually been invoked . Resolves via paths .
* If you check and the tool does not exist , it will throw .
*
* @ param tool name of the tool
* @ param check whether to check if tool exists
* @ returns Promise < string > path to tool
* /
function which ( tool , check ) {
return _ _awaiter ( this , void 0 , void 0 , function * ( ) {
if ( ! tool ) {
throw new Error ( "parameter 'tool' is required" ) ;
}
// recursive when check=true
if ( check ) {
const result = yield which ( tool , false ) ;
if ( ! result ) {
if ( ioUtil . IS _WINDOWS ) {
throw new Error ( ` Unable to locate executable file: ${ tool } . Please verify either the file path exists or the file can be found within a directory specified by the PATH environment variable. Also verify the file has a valid extension for an executable file. ` ) ;
}
else {
throw new Error ( ` Unable to locate executable file: ${ tool } . Please verify either the file path exists or the file can be found within a directory specified by the PATH environment variable. Also check the file mode to verify the file is executable. ` ) ;
}
}
}
try {
// build the list of extensions to try
const extensions = [ ] ;
if ( ioUtil . IS _WINDOWS && process . env . PATHEXT ) {
for ( const extension of process . env . PATHEXT . split ( path . delimiter ) ) {
if ( extension ) {
extensions . push ( extension ) ;
}
}
}
// if it's rooted, return it if exists. otherwise return empty.
if ( ioUtil . isRooted ( tool ) ) {
const filePath = yield ioUtil . tryGetExecutablePath ( tool , extensions ) ;
if ( filePath ) {
return filePath ;
}
return '' ;
}
// if any path separators, return empty
if ( tool . includes ( '/' ) || ( ioUtil . IS _WINDOWS && tool . includes ( '\\' ) ) ) {
return '' ;
}
// build the list of directories
//
// Note, technically "where" checks the current directory on Windows. From a toolkit perspective,
// it feels like we should not do this. Checking the current directory seems like more of a use
// case of a shell, and the which() function exposed by the toolkit should strive for consistency
// across platforms.
const directories = [ ] ;
if ( process . env . PATH ) {
for ( const p of process . env . PATH . split ( path . delimiter ) ) {
if ( p ) {
directories . push ( p ) ;
}
}
}
// return the first match
for ( const directory of directories ) {
const filePath = yield ioUtil . tryGetExecutablePath ( directory + path . sep + tool , extensions ) ;
if ( filePath ) {
return filePath ;
}
}
return '' ;
}
catch ( err ) {
throw new Error ( ` which failed with message ${ err . message } ` ) ;
}
} ) ;
}
exports . which = which ;
function readCopyOptions ( options ) {
const force = options . force == null ? true : options . force ;
const recursive = Boolean ( options . recursive ) ;
return { force , recursive } ;
}
function cpDirRecursive ( sourceDir , destDir , currentDepth , force ) {
return _ _awaiter ( this , void 0 , void 0 , function * ( ) {
// Ensure there is not a run away recursive copy
if ( currentDepth >= 255 )
return ;
currentDepth ++ ;
yield mkdirP ( destDir ) ;
const files = yield ioUtil . readdir ( sourceDir ) ;
for ( const fileName of files ) {
const srcFile = ` ${ sourceDir } / ${ fileName } ` ;
const destFile = ` ${ destDir } / ${ fileName } ` ;
const srcFileStat = yield ioUtil . lstat ( srcFile ) ;
if ( srcFileStat . isDirectory ( ) ) {
// Recurse
yield cpDirRecursive ( srcFile , destFile , currentDepth , force ) ;
}
else {
yield copyFile ( srcFile , destFile , force ) ;
}
}
// Change the mode for the newly created directory
yield ioUtil . chmod ( destDir , ( yield ioUtil . stat ( sourceDir ) ) . mode ) ;
} ) ;
}
// Buffered file copy
function copyFile ( srcFile , destFile , force ) {
return _ _awaiter ( this , void 0 , void 0 , function * ( ) {
if ( ( yield ioUtil . lstat ( srcFile ) ) . isSymbolicLink ( ) ) {
// unlink/re-link it
try {
yield ioUtil . lstat ( destFile ) ;
yield ioUtil . unlink ( destFile ) ;
}
catch ( e ) {
// Try to override file permission
if ( e . code === 'EPERM' ) {
yield ioUtil . chmod ( destFile , '0666' ) ;
yield ioUtil . unlink ( destFile ) ;
}
// other errors = it doesn't exist, no work to do
}
// Copy over symlink
const symlinkFull = yield ioUtil . readlink ( srcFile ) ;
yield ioUtil . symlink ( symlinkFull , destFile , ioUtil . IS _WINDOWS ? 'junction' : null ) ;
}
else if ( ! ( yield ioUtil . exists ( destFile ) ) || force ) {
yield ioUtil . copyFile ( srcFile , destFile ) ;
}
} ) ;
}
//# sourceMappingURL=io.js.map
/***/ } ) ,
2019-11-24 06:44:53 +07:00
/***/ 9 :
/***/ ( function ( _ _unusedmodule , exports , _ _webpack _require _ _ ) {
"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 ) : adopt ( result . value ) . then ( fulfilled , rejected ) ; }
step ( ( generator = generator . apply ( thisArg , _arguments || [ ] ) ) . next ( ) ) ;
} ) ;
} ;
2020-05-13 23:18:11 +07:00
var _ _importStar = ( this && this . _ _importStar ) || function ( mod ) {
if ( mod && mod . _ _esModule ) return mod ;
var result = { } ;
if ( mod != null ) for ( var k in mod ) if ( Object . hasOwnProperty . call ( mod , k ) ) result [ k ] = mod [ k ] ;
result [ "default" ] = mod ;
return result ;
} ;
2019-11-24 06:44:53 +07:00
Object . defineProperty ( exports , "__esModule" , { value : true } ) ;
2020-05-13 23:18:11 +07:00
const os = _ _importStar ( _ _webpack _require _ _ ( 87 ) ) ;
const events = _ _importStar ( _ _webpack _require _ _ ( 614 ) ) ;
const child = _ _importStar ( _ _webpack _require _ _ ( 129 ) ) ;
const path = _ _importStar ( _ _webpack _require _ _ ( 622 ) ) ;
const io = _ _importStar ( _ _webpack _require _ _ ( 1 ) ) ;
const ioUtil = _ _importStar ( _ _webpack _require _ _ ( 672 ) ) ;
2019-11-24 06:44:53 +07:00
/* eslint-disable @typescript-eslint/unbound-method */
const IS _WINDOWS = process . platform === 'win32' ;
/ *
* Class for running command line tools . Handles quoting and arg parsing in a platform agnostic way .
* /
class ToolRunner extends events . EventEmitter {
constructor ( toolPath , args , options ) {
super ( ) ;
if ( ! toolPath ) {
throw new Error ( "Parameter 'toolPath' cannot be null or empty." ) ;
}
this . toolPath = toolPath ;
this . args = args || [ ] ;
this . options = options || { } ;
}
_debug ( message ) {
if ( this . options . listeners && this . options . listeners . debug ) {
this . options . listeners . debug ( message ) ;
}
}
_getCommandString ( options , noPrefix ) {
const toolPath = this . _getSpawnFileName ( ) ;
const args = this . _getSpawnArgs ( options ) ;
let cmd = noPrefix ? '' : '[command]' ; // omit prefix when piped to a second tool
if ( IS _WINDOWS ) {
// Windows + cmd file
if ( this . _isCmdFile ( ) ) {
cmd += toolPath ;
for ( const a of args ) {
cmd += ` ${ a } ` ;
}
}
// Windows + verbatim
else if ( options . windowsVerbatimArguments ) {
cmd += ` " ${ toolPath } " ` ;
for ( const a of args ) {
cmd += ` ${ a } ` ;
}
}
// Windows (regular)
else {
cmd += this . _windowsQuoteCmdArg ( toolPath ) ;
for ( const a of args ) {
cmd += ` ${ this . _windowsQuoteCmdArg ( a ) } ` ;
}
}
}
else {
// OSX/Linux - this can likely be improved with some form of quoting.
// creating processes on Unix is fundamentally different than Windows.
// on Unix, execvp() takes an arg array.
cmd += toolPath ;
for ( const a of args ) {
cmd += ` ${ a } ` ;
}
}
return cmd ;
}
_processLineBuffer ( data , strBuffer , onLine ) {
try {
let s = strBuffer + data . toString ( ) ;
let n = s . indexOf ( os . EOL ) ;
while ( n > - 1 ) {
const line = s . substring ( 0 , n ) ;
onLine ( line ) ;
// the rest of the string ...
s = s . substring ( n + os . EOL . length ) ;
n = s . indexOf ( os . EOL ) ;
}
strBuffer = s ;
}
catch ( err ) {
// streaming lines to console is best effort. Don't fail a build.
this . _debug ( ` error processing line. Failed with error ${ err } ` ) ;
}
}
_getSpawnFileName ( ) {
if ( IS _WINDOWS ) {
if ( this . _isCmdFile ( ) ) {
return process . env [ 'COMSPEC' ] || 'cmd.exe' ;
}
}
return this . toolPath ;
}
_getSpawnArgs ( options ) {
if ( IS _WINDOWS ) {
if ( this . _isCmdFile ( ) ) {
let argline = ` /D /S /C " ${ this . _windowsQuoteCmdArg ( this . toolPath ) } ` ;
for ( const a of this . args ) {
argline += ' ' ;
argline += options . windowsVerbatimArguments
? a
: this . _windowsQuoteCmdArg ( a ) ;
}
argline += '"' ;
return [ argline ] ;
}
}
return this . args ;
}
_endsWith ( str , end ) {
return str . endsWith ( end ) ;
}
_isCmdFile ( ) {
const upperToolPath = this . toolPath . toUpperCase ( ) ;
return ( this . _endsWith ( upperToolPath , '.CMD' ) ||
this . _endsWith ( upperToolPath , '.BAT' ) ) ;
}
_windowsQuoteCmdArg ( arg ) {
// for .exe, apply the normal quoting rules that libuv applies
if ( ! this . _isCmdFile ( ) ) {
return this . _uvQuoteCmdArg ( arg ) ;
}
// otherwise apply quoting rules specific to the cmd.exe command line parser.
// the libuv rules are generic and are not designed specifically for cmd.exe
// command line parser.
//
// for a detailed description of the cmd.exe command line parser, refer to
// http://stackoverflow.com/questions/4094699/how-does-the-windows-command-interpreter-cmd-exe-parse-scripts/7970912#7970912
// need quotes for empty arg
if ( ! arg ) {
return '""' ;
}
// determine whether the arg needs to be quoted
const cmdSpecialChars = [
' ' ,
'\t' ,
'&' ,
'(' ,
')' ,
'[' ,
']' ,
'{' ,
'}' ,
'^' ,
'=' ,
';' ,
'!' ,
"'" ,
'+' ,
',' ,
'`' ,
'~' ,
'|' ,
'<' ,
'>' ,
'"'
] ;
let needsQuotes = false ;
for ( const char of arg ) {
if ( cmdSpecialChars . some ( x => x === char ) ) {
needsQuotes = true ;
break ;
}
}
// short-circuit if quotes not needed
if ( ! needsQuotes ) {
return arg ;
}
// the following quoting rules are very similar to the rules that by libuv applies.
//
// 1) wrap the string in quotes
//
// 2) double-up quotes - i.e. " => ""
//
// this is different from the libuv quoting rules. libuv replaces " with \", which unfortunately
// doesn't work well with a cmd.exe command line.
//
// note, replacing " with "" also works well if the arg is passed to a downstream .NET console app.
// for example, the command line:
// foo.exe "myarg:""my val"""
// is parsed by a .NET console app into an arg array:
// [ "myarg:\"my val\"" ]
// which is the same end result when applying libuv quoting rules. although the actual
// command line from libuv quoting rules would look like:
// foo.exe "myarg:\"my val\""
//
// 3) double-up slashes that precede a quote,
// e.g. hello \world => "hello \world"
// hello\"world => "hello\\""world"
// hello\\"world => "hello\\\\""world"
// hello world\ => "hello world\\"
//
// technically this is not required for a cmd.exe command line, or the batch argument parser.
// the reasons for including this as a .cmd quoting rule are:
//
// a) this is optimized for the scenario where the argument is passed from the .cmd file to an
// external program. many programs (e.g. .NET console apps) rely on the slash-doubling rule.
//
// b) it's what we've been doing previously (by deferring to node default behavior) and we
// haven't heard any complaints about that aspect.
//
// note, a weakness of the quoting rules chosen here, is that % is not escaped. in fact, % cannot be
// escaped when used on the command line directly - even though within a .cmd file % can be escaped
// by using %%.
//
// the saving grace is, on the command line, %var% is left as-is if var is not defined. this contrasts
// the line parsing rules within a .cmd file, where if var is not defined it is replaced with nothing.
//
// one option that was explored was replacing % with ^% - i.e. %var% => ^%var^%. this hack would
// often work, since it is unlikely that var^ would exist, and the ^ character is removed when the
// variable is used. the problem, however, is that ^ is not removed when %* is used to pass the args
// to an external program.
//
// an unexplored potential solution for the % escaping problem, is to create a wrapper .cmd file.
// % can be escaped within a .cmd file.
let reverse = '"' ;
let quoteHit = true ;
for ( let i = arg . length ; i > 0 ; i -- ) {
// walk the string in reverse
reverse += arg [ i - 1 ] ;
if ( quoteHit && arg [ i - 1 ] === '\\' ) {
reverse += '\\' ; // double the slash
}
else if ( arg [ i - 1 ] === '"' ) {
quoteHit = true ;
reverse += '"' ; // double the quote
}
else {
quoteHit = false ;
}
}
reverse += '"' ;
return reverse
. split ( '' )
. reverse ( )
. join ( '' ) ;
}
_uvQuoteCmdArg ( arg ) {
// Tool runner wraps child_process.spawn() and needs to apply the same quoting as
// Node in certain cases where the undocumented spawn option windowsVerbatimArguments
// is used.
//
// Since this function is a port of quote_cmd_arg from Node 4.x (technically, lib UV,
// see https://github.com/nodejs/node/blob/v4.x/deps/uv/src/win/process.c for details),
// pasting copyright notice from Node within this function:
//
// Copyright Joyent, Inc. and other Node contributors. All rights reserved.
//
// Permission is hereby granted, free of charge, to any person obtaining a copy
// of this software and associated documentation files (the "Software"), to
// deal in the Software without restriction, including without limitation the
// rights to use, copy, modify, merge, publish, distribute, sublicense, and/or
// sell copies of the Software, and to permit persons to whom the Software is
// furnished to do so, subject to the following conditions:
//
// The above copyright notice and this permission notice shall be included in
// all copies or substantial portions of the Software.
//
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
// FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
// IN THE SOFTWARE.
if ( ! arg ) {
// Need double quotation for empty argument
return '""' ;
}
if ( ! arg . includes ( ' ' ) && ! arg . includes ( '\t' ) && ! arg . includes ( '"' ) ) {
// No quotation needed
return arg ;
}
if ( ! arg . includes ( '"' ) && ! arg . includes ( '\\' ) ) {
// No embedded double quotes or backslashes, so I can just wrap
// quote marks around the whole thing.
return ` " ${ arg } " ` ;
}
// Expected input/output:
// input : hello"world
// output: "hello\"world"
// input : hello""world
// output: "hello\"\"world"
// input : hello\world
// output: hello\world
// input : hello\\world
// output: hello\\world
// input : hello\"world
// output: "hello\\\"world"
// input : hello\\"world
// output: "hello\\\\\"world"
// input : hello world\
// output: "hello world\\" - note the comment in libuv actually reads "hello world\"
// but it appears the comment is wrong, it should be "hello world\\"
let reverse = '"' ;
let quoteHit = true ;
for ( let i = arg . length ; i > 0 ; i -- ) {
// walk the string in reverse
reverse += arg [ i - 1 ] ;
if ( quoteHit && arg [ i - 1 ] === '\\' ) {
reverse += '\\' ;
}
else if ( arg [ i - 1 ] === '"' ) {
quoteHit = true ;
reverse += '\\' ;
}
else {
quoteHit = false ;
}
}
reverse += '"' ;
return reverse
. split ( '' )
. reverse ( )
. join ( '' ) ;
}
_cloneExecOptions ( options ) {
options = options || { } ;
const result = {
cwd : options . cwd || process . cwd ( ) ,
env : options . env || process . env ,
silent : options . silent || false ,
windowsVerbatimArguments : options . windowsVerbatimArguments || false ,
failOnStdErr : options . failOnStdErr || false ,
ignoreReturnCode : options . ignoreReturnCode || false ,
delay : options . delay || 10000
} ;
result . outStream = options . outStream || process . stdout ;
result . errStream = options . errStream || process . stderr ;
return result ;
}
_getSpawnOptions ( options , toolPath ) {
options = options || { } ;
const result = { } ;
result . cwd = options . cwd ;
result . env = options . env ;
result [ 'windowsVerbatimArguments' ] =
options . windowsVerbatimArguments || this . _isCmdFile ( ) ;
if ( options . windowsVerbatimArguments ) {
result . argv0 = ` " ${ toolPath } " ` ;
}
return result ;
}
/ * *
* Exec a tool .
* Output will be streamed to the live console .
* Returns promise with return code
*
* @ param tool path to tool to exec
* @ param options optional exec options . See ExecOptions
* @ returns number
* /
exec ( ) {
return _ _awaiter ( this , void 0 , void 0 , function * ( ) {
2019-12-10 06:52:33 +07:00
// root the tool path if it is unrooted and contains relative pathing
if ( ! ioUtil . isRooted ( this . toolPath ) &&
( this . toolPath . includes ( '/' ) ||
( IS _WINDOWS && this . toolPath . includes ( '\\' ) ) ) ) {
// prefer options.cwd if it is specified, however options.cwd may also need to be rooted
this . toolPath = path . resolve ( process . cwd ( ) , this . options . cwd || process . cwd ( ) , this . toolPath ) ;
}
// if the tool is only a file name, then resolve it from the PATH
// otherwise verify it exists (add extension on Windows if necessary)
this . toolPath = yield io . which ( this . toolPath , true ) ;
2019-11-24 06:44:53 +07:00
return new Promise ( ( resolve , reject ) => {
this . _debug ( ` exec tool: ${ this . toolPath } ` ) ;
this . _debug ( 'arguments:' ) ;
for ( const arg of this . args ) {
this . _debug ( ` ${ arg } ` ) ;
}
const optionsNonNull = this . _cloneExecOptions ( this . options ) ;
if ( ! optionsNonNull . silent && optionsNonNull . outStream ) {
optionsNonNull . outStream . write ( this . _getCommandString ( optionsNonNull ) + os . EOL ) ;
}
const state = new ExecState ( optionsNonNull , this . toolPath ) ;
state . on ( 'debug' , ( message ) => {
this . _debug ( message ) ;
} ) ;
const fileName = this . _getSpawnFileName ( ) ;
const cp = child . spawn ( fileName , this . _getSpawnArgs ( optionsNonNull ) , this . _getSpawnOptions ( this . options , fileName ) ) ;
const stdbuffer = '' ;
if ( cp . stdout ) {
cp . stdout . on ( 'data' , ( data ) => {
if ( this . options . listeners && this . options . listeners . stdout ) {
this . options . listeners . stdout ( data ) ;
}
if ( ! optionsNonNull . silent && optionsNonNull . outStream ) {
optionsNonNull . outStream . write ( data ) ;
}
this . _processLineBuffer ( data , stdbuffer , ( line ) => {
if ( this . options . listeners && this . options . listeners . stdline ) {
this . options . listeners . stdline ( line ) ;
}
} ) ;
} ) ;
}
const errbuffer = '' ;
if ( cp . stderr ) {
cp . stderr . on ( 'data' , ( data ) => {
state . processStderr = true ;
if ( this . options . listeners && this . options . listeners . stderr ) {
this . options . listeners . stderr ( data ) ;
}
if ( ! optionsNonNull . silent &&
optionsNonNull . errStream &&
optionsNonNull . outStream ) {
const s = optionsNonNull . failOnStdErr
? optionsNonNull . errStream
: optionsNonNull . outStream ;
s . write ( data ) ;
}
this . _processLineBuffer ( data , errbuffer , ( line ) => {
if ( this . options . listeners && this . options . listeners . errline ) {
this . options . listeners . errline ( line ) ;
}
} ) ;
} ) ;
}
cp . on ( 'error' , ( err ) => {
state . processError = err . message ;
state . processExited = true ;
state . processClosed = true ;
state . CheckComplete ( ) ;
} ) ;
cp . on ( 'exit' , ( code ) => {
state . processExitCode = code ;
state . processExited = true ;
this . _debug ( ` Exit code ${ code } received from tool ' ${ this . toolPath } ' ` ) ;
state . CheckComplete ( ) ;
} ) ;
cp . on ( 'close' , ( code ) => {
state . processExitCode = code ;
state . processExited = true ;
state . processClosed = true ;
this . _debug ( ` STDIO streams have closed for tool ' ${ this . toolPath } ' ` ) ;
state . CheckComplete ( ) ;
} ) ;
state . on ( 'done' , ( error , exitCode ) => {
if ( stdbuffer . length > 0 ) {
this . emit ( 'stdline' , stdbuffer ) ;
}
if ( errbuffer . length > 0 ) {
this . emit ( 'errline' , errbuffer ) ;
}
cp . removeAllListeners ( ) ;
if ( error ) {
reject ( error ) ;
}
else {
resolve ( exitCode ) ;
}
} ) ;
2020-05-13 23:18:11 +07:00
if ( this . options . input ) {
if ( ! cp . stdin ) {
throw new Error ( 'child process missing stdin' ) ;
}
cp . stdin . end ( this . options . input ) ;
}
2019-11-24 06:44:53 +07:00
} ) ;
} ) ;
}
}
exports . ToolRunner = ToolRunner ;
/ * *
* Convert an arg string to an array of args . Handles escaping
*
* @ param argString string of arguments
* @ returns string [ ] array of arguments
* /
function argStringToArray ( argString ) {
const args = [ ] ;
let inQuotes = false ;
let escaped = false ;
let arg = '' ;
function append ( c ) {
// we only escape double quotes.
if ( escaped && c !== '"' ) {
arg += '\\' ;
}
arg += c ;
escaped = false ;
}
for ( let i = 0 ; i < argString . length ; i ++ ) {
const c = argString . charAt ( i ) ;
if ( c === '"' ) {
if ( ! escaped ) {
inQuotes = ! inQuotes ;
}
else {
append ( c ) ;
}
continue ;
}
if ( c === '\\' && escaped ) {
append ( c ) ;
continue ;
}
if ( c === '\\' && inQuotes ) {
escaped = true ;
continue ;
}
if ( c === ' ' && ! inQuotes ) {
if ( arg . length > 0 ) {
args . push ( arg ) ;
arg = '' ;
}
continue ;
}
append ( c ) ;
}
if ( arg . length > 0 ) {
args . push ( arg . trim ( ) ) ;
}
return args ;
}
exports . argStringToArray = argStringToArray ;
class ExecState extends events . EventEmitter {
constructor ( options , toolPath ) {
super ( ) ;
this . processClosed = false ; // tracks whether the process has exited and stdio is closed
this . processError = '' ;
this . processExitCode = 0 ;
this . processExited = false ; // tracks whether the process has exited
this . processStderr = false ; // tracks whether stderr was written to
this . delay = 10000 ; // 10 seconds
this . done = false ;
this . timeout = null ;
if ( ! toolPath ) {
throw new Error ( 'toolPath must not be empty' ) ;
}
this . options = options ;
this . toolPath = toolPath ;
if ( options . delay ) {
this . delay = options . delay ;
}
}
CheckComplete ( ) {
if ( this . done ) {
return ;
}
if ( this . processClosed ) {
this . _setResult ( ) ;
}
else if ( this . processExited ) {
this . timeout = setTimeout ( ExecState . HandleTimeout , this . delay , this ) ;
}
}
_debug ( message ) {
this . emit ( 'debug' , message ) ;
}
_setResult ( ) {
// determine whether there is an error
let error ;
if ( this . processExited ) {
if ( this . processError ) {
error = new Error ( ` There was an error when attempting to execute the process ' ${ this . toolPath } '. This may indicate the process failed to start. Error: ${ this . processError } ` ) ;
}
else if ( this . processExitCode !== 0 && ! this . options . ignoreReturnCode ) {
error = new Error ( ` The process ' ${ this . toolPath } ' failed with exit code ${ this . processExitCode } ` ) ;
}
else if ( this . processStderr && this . options . failOnStdErr ) {
error = new Error ( ` The process ' ${ this . toolPath } ' failed because one or more lines were written to the STDERR stream ` ) ;
}
}
// clear the timeout
if ( this . timeout ) {
clearTimeout ( this . timeout ) ;
this . timeout = null ;
}
this . done = true ;
this . emit ( 'done' , error , this . processExitCode ) ;
}
static HandleTimeout ( state ) {
if ( state . done ) {
return ;
}
if ( ! state . processClosed && state . processExited ) {
const message = ` The STDIO streams did not close within ${ state . delay /
1000 } seconds of the exit event from process '${state.toolPath}' . This may indicate a child process inherited the STDIO streams and has not yet exited . ` ;
state . _debug ( message ) ;
}
state . _setResult ( ) ;
}
}
//# sourceMappingURL=toolrunner.js.map
2019-12-19 04:08:12 +07:00
/***/ } ) ,
2020-07-07 18:06:32 +07:00
/***/ 16 :
/***/ ( function ( module ) {
module . exports = require ( "tls" ) ;
/***/ } ) ,
2019-12-19 04:08:12 +07:00
/***/ 86 :
/***/ ( function ( _ _unusedmodule , exports , _ _webpack _require _ _ ) {
"use strict" ;
2020-05-13 23:18:11 +07:00
var _ _createBinding = ( this && this . _ _createBinding ) || ( Object . create ? ( function ( o , m , k , k2 ) {
if ( k2 === undefined ) k2 = k ;
Object . defineProperty ( o , k2 , { enumerable : true , get : function ( ) { return m [ k ] ; } } ) ;
} ) : ( function ( o , m , k , k2 ) {
if ( k2 === undefined ) k2 = k ;
o [ k2 ] = m [ k ] ;
} ) ) ;
var _ _setModuleDefault = ( this && this . _ _setModuleDefault ) || ( Object . create ? ( function ( o , v ) {
Object . defineProperty ( o , "default" , { enumerable : true , value : v } ) ;
} ) : function ( o , v ) {
o [ "default" ] = v ;
} ) ;
2019-12-19 04:08:12 +07:00
var _ _importStar = ( this && this . _ _importStar ) || function ( mod ) {
if ( mod && mod . _ _esModule ) return mod ;
var result = { } ;
2020-06-08 08:39:31 +07:00
if ( mod != null ) for ( var k in mod ) if ( k !== "default" && Object . hasOwnProperty . call ( mod , k ) ) _ _createBinding ( result , mod , k ) ;
2020-05-13 23:18:11 +07:00
_ _setModuleDefault ( result , mod ) ;
2019-12-19 04:08:12 +07:00
return result ;
} ;
Object . defineProperty ( exports , "__esModule" , { value : true } ) ;
2020-05-13 23:18:11 +07:00
exports . addMatchers = void 0 ;
2019-12-19 04:08:12 +07:00
const path = _ _importStar ( _ _webpack _require _ _ ( 622 ) ) ;
const utils = _ _importStar ( _ _webpack _require _ _ ( 163 ) ) ;
const io = _ _importStar ( _ _webpack _require _ _ ( 1 ) ) ;
/ * *
* Cache json files for problem matchers
* /
2020-03-14 09:26:11 +07:00
async function addMatchers ( ) {
const config _path = path . join ( _ _dirname , '..' , 'src' , 'configs' , 'phpunit.json' ) ;
const runner _dir = await utils . getInput ( 'RUNNER_TOOL_CACHE' , false ) ;
await io . cp ( config _path , runner _dir ) ;
2019-12-19 04:08:12 +07:00
}
exports . addMatchers = addMatchers ;
2019-11-24 06:44:53 +07:00
/***/ } ) ,
/***/ 87 :
/***/ ( function ( module ) {
module . exports = require ( "os" ) ;
/***/ } ) ,
/***/ 129 :
/***/ ( function ( module ) {
module . exports = require ( "child_process" ) ;
2020-07-07 18:06:32 +07:00
/***/ } ) ,
/***/ 141 :
/***/ ( function ( _ _unusedmodule , exports , _ _webpack _require _ _ ) {
"use strict" ;
var net = _ _webpack _require _ _ ( 631 ) ;
var tls = _ _webpack _require _ _ ( 16 ) ;
var http = _ _webpack _require _ _ ( 605 ) ;
var https = _ _webpack _require _ _ ( 211 ) ;
var events = _ _webpack _require _ _ ( 614 ) ;
var assert = _ _webpack _require _ _ ( 357 ) ;
var util = _ _webpack _require _ _ ( 669 ) ;
exports . httpOverHttp = httpOverHttp ;
exports . httpsOverHttp = httpsOverHttp ;
exports . httpOverHttps = httpOverHttps ;
exports . httpsOverHttps = httpsOverHttps ;
function httpOverHttp ( options ) {
var agent = new TunnelingAgent ( options ) ;
agent . request = http . request ;
return agent ;
}
function httpsOverHttp ( options ) {
var agent = new TunnelingAgent ( options ) ;
agent . request = http . request ;
agent . createSocket = createSecureSocket ;
agent . defaultPort = 443 ;
return agent ;
}
function httpOverHttps ( options ) {
var agent = new TunnelingAgent ( options ) ;
agent . request = https . request ;
return agent ;
}
function httpsOverHttps ( options ) {
var agent = new TunnelingAgent ( options ) ;
agent . request = https . request ;
agent . createSocket = createSecureSocket ;
agent . defaultPort = 443 ;
return agent ;
}
function TunnelingAgent ( options ) {
var self = this ;
self . options = options || { } ;
self . proxyOptions = self . options . proxy || { } ;
self . maxSockets = self . options . maxSockets || http . Agent . defaultMaxSockets ;
self . requests = [ ] ;
self . sockets = [ ] ;
self . on ( 'free' , function onFree ( socket , host , port , localAddress ) {
var options = toOptions ( host , port , localAddress ) ;
for ( var i = 0 , len = self . requests . length ; i < len ; ++ i ) {
var pending = self . requests [ i ] ;
if ( pending . host === options . host && pending . port === options . port ) {
// Detect the request to connect same origin server,
// reuse the connection.
self . requests . splice ( i , 1 ) ;
pending . request . onSocket ( socket ) ;
return ;
}
}
socket . destroy ( ) ;
self . removeSocket ( socket ) ;
} ) ;
}
util . inherits ( TunnelingAgent , events . EventEmitter ) ;
TunnelingAgent . prototype . addRequest = function addRequest ( req , host , port , localAddress ) {
var self = this ;
var options = mergeOptions ( { request : req } , self . options , toOptions ( host , port , localAddress ) ) ;
if ( self . sockets . length >= this . maxSockets ) {
// We are over limit so we'll add it to the queue.
self . requests . push ( options ) ;
return ;
}
// If we are under maxSockets create a new one.
self . createSocket ( options , function ( socket ) {
socket . on ( 'free' , onFree ) ;
socket . on ( 'close' , onCloseOrRemove ) ;
socket . on ( 'agentRemove' , onCloseOrRemove ) ;
req . onSocket ( socket ) ;
function onFree ( ) {
self . emit ( 'free' , socket , options ) ;
}
function onCloseOrRemove ( err ) {
self . removeSocket ( socket ) ;
socket . removeListener ( 'free' , onFree ) ;
socket . removeListener ( 'close' , onCloseOrRemove ) ;
socket . removeListener ( 'agentRemove' , onCloseOrRemove ) ;
}
} ) ;
} ;
TunnelingAgent . prototype . createSocket = function createSocket ( options , cb ) {
var self = this ;
var placeholder = { } ;
self . sockets . push ( placeholder ) ;
var connectOptions = mergeOptions ( { } , self . proxyOptions , {
method : 'CONNECT' ,
path : options . host + ':' + options . port ,
agent : false ,
headers : {
host : options . host + ':' + options . port
}
} ) ;
if ( options . localAddress ) {
connectOptions . localAddress = options . localAddress ;
}
if ( connectOptions . proxyAuth ) {
connectOptions . headers = connectOptions . headers || { } ;
connectOptions . headers [ 'Proxy-Authorization' ] = 'Basic ' +
new Buffer ( connectOptions . proxyAuth ) . toString ( 'base64' ) ;
}
debug ( 'making CONNECT request' ) ;
var connectReq = self . request ( connectOptions ) ;
connectReq . useChunkedEncodingByDefault = false ; // for v0.6
connectReq . once ( 'response' , onResponse ) ; // for v0.6
connectReq . once ( 'upgrade' , onUpgrade ) ; // for v0.6
connectReq . once ( 'connect' , onConnect ) ; // for v0.7 or later
connectReq . once ( 'error' , onError ) ;
connectReq . end ( ) ;
function onResponse ( res ) {
// Very hacky. This is necessary to avoid http-parser leaks.
res . upgrade = true ;
}
function onUpgrade ( res , socket , head ) {
// Hacky.
process . nextTick ( function ( ) {
onConnect ( res , socket , head ) ;
} ) ;
}
function onConnect ( res , socket , head ) {
connectReq . removeAllListeners ( ) ;
socket . removeAllListeners ( ) ;
if ( res . statusCode !== 200 ) {
debug ( 'tunneling socket could not be established, statusCode=%d' ,
res . statusCode ) ;
socket . destroy ( ) ;
var error = new Error ( 'tunneling socket could not be established, ' +
'statusCode=' + res . statusCode ) ;
error . code = 'ECONNRESET' ;
options . request . emit ( 'error' , error ) ;
self . removeSocket ( placeholder ) ;
return ;
}
if ( head . length > 0 ) {
debug ( 'got illegal response body from proxy' ) ;
socket . destroy ( ) ;
var error = new Error ( 'got illegal response body from proxy' ) ;
error . code = 'ECONNRESET' ;
options . request . emit ( 'error' , error ) ;
self . removeSocket ( placeholder ) ;
return ;
}
debug ( 'tunneling connection has established' ) ;
self . sockets [ self . sockets . indexOf ( placeholder ) ] = socket ;
return cb ( socket ) ;
}
function onError ( cause ) {
connectReq . removeAllListeners ( ) ;
debug ( 'tunneling socket could not be established, cause=%s\n' ,
cause . message , cause . stack ) ;
var error = new Error ( 'tunneling socket could not be established, ' +
'cause=' + cause . message ) ;
error . code = 'ECONNRESET' ;
options . request . emit ( 'error' , error ) ;
self . removeSocket ( placeholder ) ;
}
} ;
TunnelingAgent . prototype . removeSocket = function removeSocket ( socket ) {
var pos = this . sockets . indexOf ( socket )
if ( pos === - 1 ) {
return ;
}
this . sockets . splice ( pos , 1 ) ;
var pending = this . requests . shift ( ) ;
if ( pending ) {
// If we have pending requests and a socket gets closed a new one
// needs to be created to take over in the pool for the one that closed.
this . createSocket ( pending , function ( socket ) {
pending . request . onSocket ( socket ) ;
} ) ;
}
} ;
function createSecureSocket ( options , cb ) {
var self = this ;
TunnelingAgent . prototype . createSocket . call ( self , options , function ( socket ) {
var hostHeader = options . request . getHeader ( 'host' ) ;
var tlsOptions = mergeOptions ( { } , self . options , {
socket : socket ,
servername : hostHeader ? hostHeader . replace ( /:.*$/ , '' ) : options . host
} ) ;
// 0 is dummy port for v0.6
var secureSocket = tls . connect ( 0 , tlsOptions ) ;
self . sockets [ self . sockets . indexOf ( socket ) ] = secureSocket ;
cb ( secureSocket ) ;
} ) ;
}
function toOptions ( host , port , localAddress ) {
if ( typeof host === 'string' ) { // since v0.10
return {
host : host ,
port : port ,
localAddress : localAddress
} ;
}
return host ; // for v0.11 or later
}
function mergeOptions ( target ) {
for ( var i = 1 , len = arguments . length ; i < len ; ++ i ) {
var overrides = arguments [ i ] ;
if ( typeof overrides === 'object' ) {
var keys = Object . keys ( overrides ) ;
for ( var j = 0 , keyLen = keys . length ; j < keyLen ; ++ j ) {
var k = keys [ j ] ;
if ( overrides [ k ] !== undefined ) {
target [ k ] = overrides [ k ] ;
}
}
}
}
return target ;
}
var debug ;
if ( process . env . NODE _DEBUG && /\btunnel\b/ . test ( process . env . NODE _DEBUG ) ) {
debug = function ( ) {
var args = Array . prototype . slice . call ( arguments ) ;
if ( typeof args [ 0 ] === 'string' ) {
args [ 0 ] = 'TUNNEL: ' + args [ 0 ] ;
} else {
args . unshift ( 'TUNNEL:' ) ;
}
console . error . apply ( console , args ) ;
}
} else {
debug = function ( ) { } ;
}
exports . debug = debug ; // for test
2019-11-24 06:44:53 +07:00
/***/ } ) ,
/***/ 163 :
/***/ ( function ( _ _unusedmodule , exports , _ _webpack _require _ _ ) {
"use strict" ;
2020-05-13 23:18:11 +07:00
var _ _createBinding = ( this && this . _ _createBinding ) || ( Object . create ? ( function ( o , m , k , k2 ) {
if ( k2 === undefined ) k2 = k ;
Object . defineProperty ( o , k2 , { enumerable : true , get : function ( ) { return m [ k ] ; } } ) ;
} ) : ( function ( o , m , k , k2 ) {
if ( k2 === undefined ) k2 = k ;
o [ k2 ] = m [ k ] ;
} ) ) ;
var _ _setModuleDefault = ( this && this . _ _setModuleDefault ) || ( Object . create ? ( function ( o , v ) {
Object . defineProperty ( o , "default" , { enumerable : true , value : v } ) ;
} ) : function ( o , v ) {
o [ "default" ] = v ;
} ) ;
2019-11-24 06:44:53 +07:00
var _ _importStar = ( this && this . _ _importStar ) || function ( mod ) {
if ( mod && mod . _ _esModule ) return mod ;
var result = { } ;
2020-06-08 08:39:31 +07:00
if ( mod != null ) for ( var k in mod ) if ( k !== "default" && Object . hasOwnProperty . call ( mod , k ) ) _ _createBinding ( result , mod , k ) ;
2020-05-13 23:18:11 +07:00
_ _setModuleDefault ( result , mod ) ;
2019-11-24 06:44:53 +07:00
return result ;
} ;
Object . defineProperty ( exports , "__esModule" , { value : true } ) ;
2020-05-13 23:18:11 +07:00
exports . suppressOutput = exports . getExtensionPrefix = exports . CSVArray = exports . extensionArray = exports . writeScript = exports . readScript = exports . addLog = exports . stepLog = exports . log = exports . color = exports . asyncForEach = exports . getInput = void 0 ;
2019-11-24 06:44:53 +07:00
const fs = _ _importStar ( _ _webpack _require _ _ ( 747 ) ) ;
const path = _ _importStar ( _ _webpack _require _ _ ( 622 ) ) ;
const core = _ _importStar ( _ _webpack _require _ _ ( 470 ) ) ;
/ * *
* Function to get inputs from both with and env annotations .
*
* @ param name
* @ param mandatory
* /
2020-03-14 09:26:11 +07:00
async function getInput ( name , mandatory ) {
const input = process . env [ name ] ;
switch ( input ) {
case '' :
case undefined :
return core . getInput ( name , { required : mandatory } ) ;
default :
return input ;
}
2019-11-24 06:44:53 +07:00
}
exports . getInput = getInput ;
/ * *
* Async foreach loop
*
* @ author https : //github.com/Atinux
* @ param array
* @ param callback
* /
2020-03-14 09:26:11 +07:00
async function asyncForEach ( array , callback ) {
for ( let index = 0 ; index < array . length ; index ++ ) {
await callback ( array [ index ] , index , array ) ;
}
2019-11-24 06:44:53 +07:00
}
exports . asyncForEach = asyncForEach ;
/ * *
* Get color index
*
* @ param type
* /
2020-03-14 09:26:11 +07:00
async function color ( type ) {
switch ( type ) {
case 'error' :
return '31' ;
default :
case 'success' :
return '32' ;
case 'warning' :
return '33' ;
}
2019-11-24 06:44:53 +07:00
}
exports . color = color ;
/ * *
* Log to console
*
* @ param message
* @ param os _version
* @ param log _type
* /
2020-03-14 09:26:11 +07:00
async function log ( message , os _version , log _type ) {
switch ( os _version ) {
case 'win32' :
return ( 'printf "\\033[' +
( await color ( log _type ) ) +
';1m' +
message +
' \\033[0m"' ) ;
case 'linux' :
case 'darwin' :
default :
return ( 'echo "\\033[' + ( await color ( log _type ) ) + ';1m' + message + '\\033[0m"' ) ;
}
2019-11-24 06:44:53 +07:00
}
exports . log = log ;
/ * *
* Function to log a step
*
* @ param message
* @ param os _version
* /
2020-03-14 09:26:11 +07:00
async function stepLog ( message , os _version ) {
switch ( os _version ) {
case 'win32' :
return 'Step-Log "' + message + '"' ;
case 'linux' :
case 'darwin' :
return 'step_log "' + message + '"' ;
default :
return await log ( 'Platform ' + os _version + ' is not supported' , os _version , 'error' ) ;
}
2019-11-24 06:44:53 +07:00
}
exports . stepLog = stepLog ;
/ * *
* Function to log a result
* @ param mark
* @ param subject
* @ param message
2020-03-14 09:23:43 +07:00
* @ param os _version
2019-11-24 06:44:53 +07:00
* /
2020-03-14 09:26:11 +07:00
async function addLog ( mark , subject , message , os _version ) {
switch ( os _version ) {
case 'win32' :
return 'Add-Log "' + mark + '" "' + subject + '" "' + message + '"' ;
case 'linux' :
case 'darwin' :
return 'add_log "' + mark + '" "' + subject + '" "' + message + '"' ;
default :
return await log ( 'Platform ' + os _version + ' is not supported' , os _version , 'error' ) ;
}
2019-11-24 06:44:53 +07:00
}
exports . addLog = addLog ;
/ * *
* Read the scripts
*
* @ param filename
* /
2020-03-14 09:26:11 +07:00
async function readScript ( filename ) {
return fs . readFileSync ( path . join ( _ _dirname , '../src/scripts/' + filename ) , 'utf8' ) ;
2019-11-24 06:44:53 +07:00
}
exports . readScript = readScript ;
/ * *
* Write final script which runs
*
* @ param filename
* @ param script
* /
2020-03-14 09:26:11 +07:00
async function writeScript ( filename , script ) {
const runner _dir = await getInput ( 'RUNNER_TOOL_CACHE' , false ) ;
const script _path = path . join ( runner _dir , filename ) ;
fs . writeFileSync ( script _path , script , { mode : 0o755 } ) ;
return script _path ;
2019-11-24 06:44:53 +07:00
}
exports . writeScript = writeScript ;
/ * *
* Function to break extension csv into an array
*
* @ param extension _csv
* /
2020-03-14 09:26:11 +07:00
async function extensionArray ( extension _csv ) {
switch ( extension _csv ) {
case '' :
case ' ' :
return [ ] ;
default :
return extension _csv
. split ( ',' )
. map ( function ( extension ) {
return extension
. trim ( )
. toLowerCase ( )
. replace ( 'php-' , '' )
. replace ( 'php_' , '' ) ;
} )
. filter ( Boolean ) ;
}
2019-11-24 06:44:53 +07:00
}
exports . extensionArray = extensionArray ;
/ * *
2019-12-27 08:26:49 +07:00
* Function to break csv into an array
2019-11-24 06:44:53 +07:00
*
2019-12-27 08:26:49 +07:00
* @ param values _csv
2019-11-24 06:44:53 +07:00
* @ constructor
* /
2020-03-14 09:26:11 +07:00
async function CSVArray ( values _csv ) {
switch ( values _csv ) {
case '' :
case ' ' :
return [ ] ;
default :
return values _csv
. split ( ',' )
. map ( function ( value ) {
return value . trim ( ) ;
} )
. filter ( Boolean ) ;
}
2019-11-24 06:44:53 +07:00
}
2019-12-27 08:26:49 +07:00
exports . CSVArray = CSVArray ;
2019-11-24 06:44:53 +07:00
/ * *
* Function to get prefix required to load an extension .
*
* @ param extension
* /
2020-03-14 09:26:11 +07:00
async function getExtensionPrefix ( extension ) {
const zend = [ 'xdebug' , 'opcache' , 'ioncube' , 'eaccelerator' ] ;
switch ( zend . indexOf ( extension ) ) {
case 0 :
case 1 :
return 'zend_extension' ;
case - 1 :
default :
return 'extension' ;
}
2019-11-24 06:44:53 +07:00
}
exports . getExtensionPrefix = getExtensionPrefix ;
/ * *
* Function to get the suffix to suppress console output
*
* @ param os _version
* /
2020-03-14 09:26:11 +07:00
async function suppressOutput ( os _version ) {
switch ( os _version ) {
case 'win32' :
return ' >$null 2>&1' ;
case 'linux' :
case 'darwin' :
return ' >/dev/null 2>&1' ;
default :
return await log ( 'Platform ' + os _version + ' is not supported' , os _version , 'error' ) ;
}
2019-11-24 06:44:53 +07:00
}
exports . suppressOutput = suppressOutput ;
2020-07-07 18:06:32 +07:00
/***/ } ) ,
/***/ 211 :
/***/ ( function ( module ) {
module . exports = require ( "https" ) ;
2019-12-10 06:52:33 +07:00
/***/ } ) ,
/***/ 357 :
/***/ ( function ( module ) {
module . exports = require ( "assert" ) ;
2020-07-07 18:06:32 +07:00
/***/ } ) ,
/***/ 413 :
/***/ ( function ( module , _ _unusedexports , _ _webpack _require _ _ ) {
module . exports = _ _webpack _require _ _ ( 141 ) ;
2019-11-24 06:44:53 +07:00
/***/ } ) ,
/***/ 431 :
/***/ ( function ( _ _unusedmodule , exports , _ _webpack _require _ _ ) {
"use strict" ;
2020-01-26 17:55:58 +07:00
var _ _importStar = ( this && this . _ _importStar ) || function ( mod ) {
if ( mod && mod . _ _esModule ) return mod ;
var result = { } ;
if ( mod != null ) for ( var k in mod ) if ( Object . hasOwnProperty . call ( mod , k ) ) result [ k ] = mod [ k ] ;
result [ "default" ] = mod ;
return result ;
} ;
2019-11-24 06:44:53 +07:00
Object . defineProperty ( exports , "__esModule" , { value : true } ) ;
2020-01-26 17:55:58 +07:00
const os = _ _importStar ( _ _webpack _require _ _ ( 87 ) ) ;
2019-11-24 06:44:53 +07:00
/ * *
* Commands
*
* Command Format :
2020-01-26 17:55:58 +07:00
* : : name key = value , key = value : : message
2019-11-24 06:44:53 +07:00
*
* Examples :
2020-01-26 17:55:58 +07:00
* : : warning : : This is the message
* : : set - env name = MY _VAR : : some value
2019-11-24 06:44:53 +07:00
* /
function issueCommand ( command , properties , message ) {
const cmd = new Command ( command , properties , message ) ;
process . stdout . write ( cmd . toString ( ) + os . EOL ) ;
}
exports . issueCommand = issueCommand ;
function issue ( name , message = '' ) {
issueCommand ( name , { } , message ) ;
}
exports . issue = issue ;
const CMD _STRING = '::' ;
class Command {
constructor ( command , properties , message ) {
if ( ! command ) {
command = 'missing.command' ;
}
this . command = command ;
this . properties = properties ;
this . message = message ;
}
toString ( ) {
let cmdStr = CMD _STRING + this . command ;
if ( this . properties && Object . keys ( this . properties ) . length > 0 ) {
cmdStr += ' ' ;
2020-01-17 15:15:04 +07:00
let first = true ;
2019-11-24 06:44:53 +07:00
for ( const key in this . properties ) {
if ( this . properties . hasOwnProperty ( key ) ) {
const val = this . properties [ key ] ;
if ( val ) {
2020-01-17 15:15:04 +07:00
if ( first ) {
first = false ;
}
else {
cmdStr += ',' ;
}
2020-01-26 17:55:58 +07:00
cmdStr += ` ${ key } = ${ escapeProperty ( val ) } ` ;
2019-11-24 06:44:53 +07:00
}
}
}
}
2020-01-26 17:55:58 +07:00
cmdStr += ` ${ CMD _STRING } ${ escapeData ( this . message ) } ` ;
2019-11-24 06:44:53 +07:00
return cmdStr ;
}
}
2020-05-13 23:18:11 +07:00
/ * *
* Sanitizes an input into a string so it can be passed into issueCommand safely
* @ param input input to sanitize into a string
* /
function toCommandValue ( input ) {
if ( input === null || input === undefined ) {
return '' ;
}
else if ( typeof input === 'string' || input instanceof String ) {
return input ;
}
return JSON . stringify ( input ) ;
}
exports . toCommandValue = toCommandValue ;
2019-11-24 06:44:53 +07:00
function escapeData ( s ) {
2020-05-13 23:18:11 +07:00
return toCommandValue ( s )
2020-01-26 17:55:58 +07:00
. replace ( /%/g , '%25' )
. replace ( /\r/g , '%0D' )
. replace ( /\n/g , '%0A' ) ;
2019-11-24 06:44:53 +07:00
}
2020-01-26 17:55:58 +07:00
function escapeProperty ( s ) {
2020-05-13 23:18:11 +07:00
return toCommandValue ( s )
2020-01-26 17:55:58 +07:00
. replace ( /%/g , '%25' )
2019-11-24 06:44:53 +07:00
. replace ( /\r/g , '%0D' )
. replace ( /\n/g , '%0A' )
2020-01-26 17:55:58 +07:00
. replace ( /:/g , '%3A' )
. replace ( /,/g , '%2C' ) ;
2019-11-24 06:44:53 +07:00
}
//# sourceMappingURL=command.js.map
/***/ } ) ,
/***/ 470 :
/***/ ( function ( _ _unusedmodule , exports , _ _webpack _require _ _ ) {
"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 ) : adopt ( result . value ) . then ( fulfilled , rejected ) ; }
step ( ( generator = generator . apply ( thisArg , _arguments || [ ] ) ) . next ( ) ) ;
} ) ;
} ;
2020-01-26 17:55:58 +07:00
var _ _importStar = ( this && this . _ _importStar ) || function ( mod ) {
if ( mod && mod . _ _esModule ) return mod ;
var result = { } ;
if ( mod != null ) for ( var k in mod ) if ( Object . hasOwnProperty . call ( mod , k ) ) result [ k ] = mod [ k ] ;
result [ "default" ] = mod ;
return result ;
} ;
2019-11-24 06:44:53 +07:00
Object . defineProperty ( exports , "__esModule" , { value : true } ) ;
const command _1 = _ _webpack _require _ _ ( 431 ) ;
2020-01-26 17:55:58 +07:00
const os = _ _importStar ( _ _webpack _require _ _ ( 87 ) ) ;
const path = _ _importStar ( _ _webpack _require _ _ ( 622 ) ) ;
2019-11-24 06:44:53 +07:00
/ * *
* The code to exit an action
* /
var ExitCode ;
( function ( ExitCode ) {
/ * *
* A code indicating that the action was successful
* /
ExitCode [ ExitCode [ "Success" ] = 0 ] = "Success" ;
/ * *
* A code indicating that the action was a failure
* /
ExitCode [ ExitCode [ "Failure" ] = 1 ] = "Failure" ;
} ) ( ExitCode = exports . ExitCode || ( exports . ExitCode = { } ) ) ;
//-----------------------------------------------------------------------
// Variables
//-----------------------------------------------------------------------
/ * *
* Sets env variable for this action and future actions in the job
* @ param name the name of the variable to set
2020-05-13 23:18:11 +07:00
* @ param val the value of the variable . Non - string values will be converted to a string via JSON . stringify
2019-11-24 06:44:53 +07:00
* /
2020-05-13 23:18:11 +07:00
// eslint-disable-next-line @typescript-eslint/no-explicit-any
2019-11-24 06:44:53 +07:00
function exportVariable ( name , val ) {
2020-05-13 23:18:11 +07:00
const convertedVal = command _1 . toCommandValue ( val ) ;
process . env [ name ] = convertedVal ;
command _1 . issueCommand ( 'set-env' , { name } , convertedVal ) ;
2019-11-24 06:44:53 +07:00
}
exports . exportVariable = exportVariable ;
/ * *
* Registers a secret which will get masked from logs
* @ param secret value of the secret
* /
function setSecret ( secret ) {
command _1 . issueCommand ( 'add-mask' , { } , secret ) ;
}
exports . setSecret = setSecret ;
/ * *
* Prepends inputPath to the PATH ( for this action and future actions )
* @ param inputPath
* /
function addPath ( inputPath ) {
command _1 . issueCommand ( 'add-path' , { } , inputPath ) ;
process . env [ 'PATH' ] = ` ${ inputPath } ${ path . delimiter } ${ process . env [ 'PATH' ] } ` ;
}
exports . addPath = addPath ;
/ * *
* Gets the value of an input . The value is also trimmed .
*
* @ param name name of the input to get
* @ param options optional . See InputOptions .
* @ returns string
* /
function getInput ( name , options ) {
const val = process . env [ ` INPUT_ ${ name . replace ( / /g , '_' ) . toUpperCase ( ) } ` ] || '' ;
if ( options && options . required && ! val ) {
throw new Error ( ` Input required and not supplied: ${ name } ` ) ;
}
return val . trim ( ) ;
}
exports . getInput = getInput ;
/ * *
* Sets the value of an output .
*
* @ param name name of the output to set
2020-05-13 23:18:11 +07:00
* @ param value value to store . Non - string values will be converted to a string via JSON . stringify
2019-11-24 06:44:53 +07:00
* /
2020-05-13 23:18:11 +07:00
// eslint-disable-next-line @typescript-eslint/no-explicit-any
2019-11-24 06:44:53 +07:00
function setOutput ( name , value ) {
command _1 . issueCommand ( 'set-output' , { name } , value ) ;
}
exports . setOutput = setOutput ;
2020-05-13 23:18:11 +07:00
/ * *
* Enables or disables the echoing of commands into stdout for the rest of the step .
* Echoing is disabled by default if ACTIONS _STEP _DEBUG is not set .
*
* /
function setCommandEcho ( enabled ) {
command _1 . issue ( 'echo' , enabled ? 'on' : 'off' ) ;
}
exports . setCommandEcho = setCommandEcho ;
2019-11-24 06:44:53 +07:00
//-----------------------------------------------------------------------
// Results
//-----------------------------------------------------------------------
/ * *
* Sets the action status to failed .
* When the action exits it will be with an exit code of 1
* @ param message add error issue message
* /
function setFailed ( message ) {
process . exitCode = ExitCode . Failure ;
error ( message ) ;
}
exports . setFailed = setFailed ;
//-----------------------------------------------------------------------
// Logging Commands
//-----------------------------------------------------------------------
2020-03-01 07:50:48 +07:00
/ * *
* Gets whether Actions Step Debug is on or not
* /
function isDebug ( ) {
return process . env [ 'RUNNER_DEBUG' ] === '1' ;
}
exports . isDebug = isDebug ;
2019-11-24 06:44:53 +07:00
/ * *
* Writes debug message to user log
* @ param message debug message
* /
function debug ( message ) {
command _1 . issueCommand ( 'debug' , { } , message ) ;
}
exports . debug = debug ;
/ * *
* Adds an error issue
2020-05-13 23:18:11 +07:00
* @ param message error issue message . Errors will be converted to string via toString ( )
2019-11-24 06:44:53 +07:00
* /
function error ( message ) {
2020-05-13 23:18:11 +07:00
command _1 . issue ( 'error' , message instanceof Error ? message . toString ( ) : message ) ;
2019-11-24 06:44:53 +07:00
}
exports . error = error ;
/ * *
* Adds an warning issue
2020-05-13 23:18:11 +07:00
* @ param message warning issue message . Errors will be converted to string via toString ( )
2019-11-24 06:44:53 +07:00
* /
function warning ( message ) {
2020-05-13 23:18:11 +07:00
command _1 . issue ( 'warning' , message instanceof Error ? message . toString ( ) : message ) ;
2019-11-24 06:44:53 +07:00
}
exports . warning = warning ;
/ * *
* Writes info to log with console . log .
* @ param message info message
* /
function info ( message ) {
process . stdout . write ( message + os . EOL ) ;
}
exports . info = info ;
/ * *
* Begin an output group .
*
* Output until the next ` groupEnd ` will be foldable in this group
*
* @ param name The name of the output group
* /
function startGroup ( name ) {
command _1 . issue ( 'group' , name ) ;
}
exports . startGroup = startGroup ;
/ * *
* End an output group .
* /
function endGroup ( ) {
command _1 . issue ( 'endgroup' ) ;
}
exports . endGroup = endGroup ;
/ * *
* Wrap an asynchronous function call in a group .
*
* Returns the same type as the function itself .
*
* @ param name The name of the group
* @ param fn The function to wrap in the group
* /
function group ( name , fn ) {
return _ _awaiter ( this , void 0 , void 0 , function * ( ) {
startGroup ( name ) ;
let result ;
try {
result = yield fn ( ) ;
}
finally {
endGroup ( ) ;
}
return result ;
} ) ;
}
exports . group = group ;
//-----------------------------------------------------------------------
// Wrapper action state
//-----------------------------------------------------------------------
/ * *
* Saves state for current action , the state can only be retrieved by this action ' s post job execution .
*
* @ param name name of the state to store
2020-05-13 23:18:11 +07:00
* @ param value value to store . Non - string values will be converted to a string via JSON . stringify
2019-11-24 06:44:53 +07:00
* /
2020-05-13 23:18:11 +07:00
// eslint-disable-next-line @typescript-eslint/no-explicit-any
2019-11-24 06:44:53 +07:00
function saveState ( name , value ) {
command _1 . issueCommand ( 'save-state' , { name } , value ) ;
}
exports . saveState = saveState ;
/ * *
* Gets the value of an state set by this action ' s main execution .
*
* @ param name name of the state to get
* @ returns string
* /
function getState ( name ) {
return process . env [ ` STATE_ ${ name } ` ] || '' ;
}
exports . getState = getState ;
//# sourceMappingURL=core.js.map
2019-12-27 08:26:49 +07:00
/***/ } ) ,
/***/ 534 :
/***/ ( function ( _ _unusedmodule , exports , _ _webpack _require _ _ ) {
"use strict" ;
2020-05-13 23:18:11 +07:00
var _ _createBinding = ( this && this . _ _createBinding ) || ( Object . create ? ( function ( o , m , k , k2 ) {
if ( k2 === undefined ) k2 = k ;
Object . defineProperty ( o , k2 , { enumerable : true , get : function ( ) { return m [ k ] ; } } ) ;
} ) : ( function ( o , m , k , k2 ) {
if ( k2 === undefined ) k2 = k ;
o [ k2 ] = m [ k ] ;
} ) ) ;
var _ _setModuleDefault = ( this && this . _ _setModuleDefault ) || ( Object . create ? ( function ( o , v ) {
Object . defineProperty ( o , "default" , { enumerable : true , value : v } ) ;
} ) : function ( o , v ) {
o [ "default" ] = v ;
} ) ;
2019-12-27 08:26:49 +07:00
var _ _importStar = ( this && this . _ _importStar ) || function ( mod ) {
if ( mod && mod . _ _esModule ) return mod ;
var result = { } ;
2020-06-08 08:39:31 +07:00
if ( mod != null ) for ( var k in mod ) if ( k !== "default" && Object . hasOwnProperty . call ( mod , k ) ) _ _createBinding ( result , mod , k ) ;
2020-05-13 23:18:11 +07:00
_ _setModuleDefault ( result , mod ) ;
2019-12-27 08:26:49 +07:00
return result ;
} ;
Object . defineProperty ( exports , "__esModule" , { value : true } ) ;
2020-07-07 18:06:32 +07:00
exports . addTools = exports . addPackage = exports . addDevTools = exports . addArchive = exports . getCleanedToolsList = exports . getComposerUrl = exports . addComposer = exports . getSymfonyUri = exports . getDeployerUrl = exports . getPharUrl = exports . addPhive = exports . getCodeceptionUri = exports . getCodeceptionUriBuilder = exports . getUri = exports . parseTool = exports . getToolVersion = exports . getCommand = void 0 ;
2019-12-27 08:26:49 +07:00
const utils = _ _importStar ( _ _webpack _require _ _ ( 163 ) ) ;
2020-07-07 18:06:32 +07:00
const httpm = _ _importStar ( _ _webpack _require _ _ ( 539 ) ) ;
2020-01-07 09:36:14 +07:00
/ * *
2020-03-01 07:50:48 +07:00
* Function to get command to setup tools
2020-01-07 09:36:14 +07:00
*
* @ param os _version
2020-03-14 09:23:43 +07:00
* @ param suffix
2020-01-07 09:36:14 +07:00
* /
2020-03-14 09:26:11 +07:00
async function getCommand ( os _version , suffix ) {
switch ( os _version ) {
case 'linux' :
case 'darwin' :
return 'add_' + suffix + ' ' ;
case 'win32' :
return 'Add-' + suffix . charAt ( 0 ) . toUpperCase ( ) + suffix . slice ( 1 ) + ' ' ;
default :
return await utils . log ( 'Platform ' + os _version + ' is not supported' , os _version , 'error' ) ;
}
2019-12-27 08:26:49 +07:00
}
2020-03-01 07:50:48 +07:00
exports . getCommand = getCommand ;
2020-01-07 09:36:14 +07:00
/ * *
* Function to get tool version
*
* @ param version
* /
2020-03-14 09:26:11 +07:00
async function getToolVersion ( version ) {
// semver_regex - https://semver.org/
const semver _regex = /^(0|[1-9]\d*)\.(0|[1-9]\d*)\.(0|[1-9]\d*)(?:-((?:0|[1-9]\d*|\d*[a-zA-Z-][0-9a-zA-Z-]*)(?:\.(?:0|[1-9]\d*|\d*[a-zA-Z-][0-9a-zA-Z-]*))*))?(?:\+([0-9a-zA-Z-]+(?:\.[0-9a-zA-Z-]+)*))?$/ ;
2020-06-03 16:21:22 +07:00
const composer _regex = /^stable$|^preview$|^snapshot$|^v?[1|2]$/ ;
2020-03-14 09:26:11 +07:00
version = version . replace ( /[><=^]*/ , '' ) ;
switch ( true ) {
2020-06-03 16:21:22 +07:00
case composer _regex . test ( version ) :
2020-03-14 09:26:11 +07:00
case semver _regex . test ( version ) :
return version ;
default :
return 'latest' ;
}
2020-01-07 09:36:14 +07:00
}
exports . getToolVersion = getToolVersion ;
/ * *
* Function to parse tool : version
*
* @ param release
* /
2020-03-14 09:26:11 +07:00
async function parseTool ( release ) {
const parts = release . split ( ':' ) ;
const tool = parts [ 0 ] ;
const version = parts [ 1 ] ;
switch ( version ) {
case undefined :
return {
name : tool ,
version : 'latest'
} ;
default :
return {
name : tool ,
version : await getToolVersion ( parts [ 1 ] )
} ;
}
2020-01-07 09:36:14 +07:00
}
exports . parseTool = parseTool ;
/ * *
* Function to get the url of tool with the given version
*
2020-03-14 09:23:43 +07:00
* @ param tool
* @ param extension
2020-01-07 09:36:14 +07:00
* @ param version
* @ param prefix
* @ param version _prefix
* @ param verb
* /
2020-03-14 09:26:11 +07:00
async function getUri ( tool , extension , version , prefix , version _prefix , verb ) {
switch ( version ) {
case 'latest' :
return [ prefix , version , verb , tool + extension ]
. filter ( Boolean )
. join ( '/' ) ;
default :
return [ prefix , verb , version _prefix + version , tool + extension ]
. filter ( Boolean )
. join ( '/' ) ;
}
2020-01-07 09:36:14 +07:00
}
exports . getUri = getUri ;
/ * *
* Helper function to get the codeception url
*
* @ param version
* @ param suffix
* /
2020-03-14 09:26:11 +07:00
async function getCodeceptionUriBuilder ( version , suffix ) {
return [ 'releases' , version , suffix , 'codecept.phar' ]
. filter ( Boolean )
. join ( '/' ) ;
2020-01-07 09:36:14 +07:00
}
exports . getCodeceptionUriBuilder = getCodeceptionUriBuilder ;
/ * *
* Function to get the codeception url
*
* @ param version
* @ param php _version
* /
2020-03-14 09:26:11 +07:00
async function getCodeceptionUri ( version , php _version ) {
const codecept = await getCodeceptionUriBuilder ( version , '' ) ;
const codecept54 = await getCodeceptionUriBuilder ( version , 'php54' ) ;
const codecept56 = await getCodeceptionUriBuilder ( version , 'php56' ) ;
// Refer to https://codeception.com/builds
switch ( true ) {
case /latest/ . test ( version ) :
switch ( true ) {
case /5\.6|7\.[0|1]/ . test ( php _version ) :
return 'php56/codecept.phar' ;
case /7\.[2-4]/ . test ( php _version ) :
default :
return 'codecept.phar' ;
}
case /(^[4-9]|\d{2,})\..*/ . test ( version ) :
switch ( true ) {
case /5\.6|7\.[0|1]/ . test ( php _version ) :
return codecept56 ;
case /7\.[2-4]/ . test ( php _version ) :
default :
return codecept ;
}
case /(^2\.[4-5]\.\d+|^3\.[0-1]\.\d+).*/ . test ( version ) :
switch ( true ) {
case /5\.6/ . test ( php _version ) :
return codecept54 ;
case /7\.[0-4]/ . test ( php _version ) :
default :
return codecept ;
}
case /^2\.3\.\d+.*/ . test ( version ) :
switch ( true ) {
case /5\.[4-6]/ . test ( php _version ) :
return codecept54 ;
case /^7\.[0-4]$/ . test ( php _version ) :
default :
return codecept ;
}
case /(^2\.(1\.([6-9]|\d{2,}))|^2\.2\.\d+).*/ . test ( version ) :
switch ( true ) {
case /5\.[4-5]/ . test ( php _version ) :
return codecept54 ;
case /5.6|7\.[0-4]/ . test ( php _version ) :
default :
return codecept ;
}
case /(^2\.(1\.[0-5]|0\.\d+)|^1\.[6-8]\.\d+).*/ . test ( version ) :
return codecept ;
default :
return codecept ;
}
2020-01-07 09:36:14 +07:00
}
exports . getCodeceptionUri = getCodeceptionUri ;
2020-01-21 03:10:24 +07:00
/ * *
* Helper function to get script to setup phive
*
* @ param version
* @ param os _version
* /
2020-03-14 09:26:11 +07:00
async function addPhive ( version , os _version ) {
switch ( version ) {
case 'latest' :
return ( ( await getCommand ( os _version , 'tool' ) ) +
'https://phar.io/releases/phive.phar phive' ) ;
default :
return ( ( await getCommand ( os _version , 'tool' ) ) +
'https://github.com/phar-io/phive/releases/download/' +
version +
'/phive-' +
version +
'.phar phive' ) ;
}
2020-01-21 03:10:24 +07:00
}
exports . addPhive = addPhive ;
2020-01-07 09:36:14 +07:00
/ * *
2020-03-01 07:50:48 +07:00
* Function to get the phar url in domain / tool - version . phar format
2020-01-07 09:36:14 +07:00
*
2020-03-14 09:23:43 +07:00
* @ param domain
* @ param tool
* @ param prefix
2020-01-07 09:36:14 +07:00
* @ param version
* /
2020-03-14 09:26:11 +07:00
async function getPharUrl ( domain , tool , prefix , version ) {
switch ( version ) {
case 'latest' :
return domain + '/' + tool + '.phar' ;
default :
return domain + '/' + tool + '-' + prefix + version + '.phar' ;
}
2020-01-07 09:36:14 +07:00
}
2020-03-01 07:50:48 +07:00
exports . getPharUrl = getPharUrl ;
2020-01-07 09:36:14 +07:00
/ * *
* Function to get the Deployer url
*
* @ param version
* /
2020-03-14 09:26:11 +07:00
async function getDeployerUrl ( version ) {
const deployer = 'https://deployer.org' ;
switch ( version ) {
case 'latest' :
return deployer + '/deployer.phar' ;
default :
return deployer + '/releases/v' + version + '/deployer.phar' ;
}
2020-01-07 09:36:14 +07:00
}
exports . getDeployerUrl = getDeployerUrl ;
2020-01-26 12:41:36 +07:00
/ * *
* Function to get the Deployer url
*
* @ param version
* @ param os _version
* /
2020-03-14 09:26:11 +07:00
async function getSymfonyUri ( version , os _version ) {
let filename = '' ;
switch ( os _version ) {
case 'linux' :
case 'darwin' :
filename = 'symfony_' + os _version + '_amd64' ;
break ;
case 'win32' :
filename = 'symfony_windows_amd64.exe' ;
break ;
default :
return await utils . log ( 'Platform ' + os _version + ' is not supported' , os _version , 'error' ) ;
}
switch ( version ) {
case 'latest' :
return 'releases/latest/download/' + filename ;
default :
return 'releases/download/v' + version + '/' + filename ;
}
2020-01-26 12:41:36 +07:00
}
exports . getSymfonyUri = getSymfonyUri ;
2020-01-07 09:36:14 +07:00
/ * *
* Function to add / move composer in the tools list
*
2020-03-14 09:23:43 +07:00
* @ param tools _list
2020-01-07 09:36:14 +07:00
* /
2020-03-14 09:26:11 +07:00
async function addComposer ( tools _list ) {
2020-06-03 16:21:22 +07:00
const regex _any = /^composer($|:.*)/ ;
const regex _valid = /^composer:?($|preview$|snapshot$|v?[1-2]$)/ ;
const matches = tools _list . filter ( tool => regex _valid . test ( tool ) ) ;
let composer = 'composer' ;
tools _list = tools _list . filter ( tool => ! regex _any . test ( tool ) ) ;
switch ( matches [ 0 ] ) {
2020-03-14 09:26:11 +07:00
case undefined :
break ;
default :
2020-06-03 16:21:22 +07:00
composer = matches [ matches . length - 1 ] . replace ( /v([1-2])/ , '$1' ) ;
2020-03-14 09:26:11 +07:00
break ;
}
2020-06-03 16:21:22 +07:00
tools _list . unshift ( composer ) ;
2020-03-14 09:26:11 +07:00
return tools _list ;
2020-01-07 09:36:14 +07:00
}
exports . addComposer = addComposer ;
2020-06-03 16:21:22 +07:00
/ * *
2020-07-07 18:06:32 +07:00
* Function to get composer URL for a given version
2020-06-03 16:21:22 +07:00
*
* @ param version
* /
2020-07-07 18:06:32 +07:00
async function getComposerUrl ( version ) {
const getComposerUrlHelper = async function ( version ) {
const client = new httpm . HttpClient ( 'setup-php' ) ;
const response = await client . get ( 'https://getcomposer.org/versions' ) ;
const data = JSON . parse ( await response . readBody ( ) ) ;
return 'https://getcomposer.org' + data [ version ] [ 0 ] [ 'path' ] ;
} ;
2020-06-03 16:21:22 +07:00
switch ( version ) {
case 'snapshot' :
2020-07-07 18:06:32 +07:00
return 'https://getcomposer.org/composer.phar' ;
2020-06-03 16:21:22 +07:00
case 'preview' :
case '1' :
case '2' :
2020-07-07 18:06:32 +07:00
return await getComposerUrlHelper ( version ) ;
2020-06-03 16:21:22 +07:00
default :
2020-07-07 18:06:32 +07:00
return 'https://getcomposer.org/composer-stable.phar' ;
2020-06-03 16:21:22 +07:00
}
}
2020-07-07 18:06:32 +07:00
exports . getComposerUrl = getComposerUrl ;
2020-01-07 09:36:14 +07:00
/ * *
* Function to get Tools list after cleanup
*
* @ param tools _csv
* /
2020-03-14 09:26:11 +07:00
async function getCleanedToolsList ( tools _csv ) {
let tools _list = await utils . CSVArray ( tools _csv ) ;
tools _list = await addComposer ( tools _list ) ;
tools _list = tools _list
. map ( function ( extension ) {
return extension
. trim ( )
. replace ( /robmorgan\/|hirak\/|narrowspark\/automatic-/ , '' ) ;
} )
. filter ( Boolean ) ;
return [ ... new Set ( tools _list ) ] ;
2020-01-07 09:36:14 +07:00
}
exports . getCleanedToolsList = getCleanedToolsList ;
/ * *
* Helper function to get script to setup a tool using a phar url
*
* @ param tool
* @ param version
* @ param url
* @ param os _version
* /
2020-03-14 09:26:11 +07:00
async function addArchive ( tool , version , url , os _version ) {
return ( await getCommand ( os _version , 'tool' ) ) + url + ' ' + tool ;
2020-01-07 09:36:14 +07:00
}
exports . addArchive = addArchive ;
2020-01-17 14:28:28 +07:00
/ * *
* Function to get the script to setup php - config and phpize
*
* @ param tool
* @ param os _version
* /
2020-03-14 09:26:11 +07:00
async function addDevTools ( tool , os _version ) {
switch ( os _version ) {
case 'linux' :
return ( 'add_devtools' +
'\n' +
( await utils . addLog ( '$tick' , tool , 'Added' , 'linux' ) ) ) ;
case 'darwin' :
return await utils . addLog ( '$tick' , tool , 'Added' , 'darwin' ) ;
case 'win32' :
return await utils . addLog ( '$cross' , tool , tool + ' is not a windows tool' , 'win32' ) ;
default :
return await utils . log ( 'Platform ' + os _version + ' is not supported' , os _version , 'error' ) ;
}
2020-01-17 14:28:28 +07:00
}
exports . addDevTools = addDevTools ;
2020-01-07 09:36:14 +07:00
/ * *
* Helper function to get script to setup a tool using composer
*
* @ param tool
* @ param release
* @ param prefix
* @ param os _version
* /
2020-03-14 09:26:11 +07:00
async function addPackage ( tool , release , prefix , os _version ) {
const tool _command = await getCommand ( os _version , 'composertool' ) ;
return tool _command + tool + ' ' + release + ' ' + prefix ;
2020-01-07 09:36:14 +07:00
}
exports . addPackage = addPackage ;
2019-12-27 08:26:49 +07:00
/ * *
* Setup tools
*
2020-03-14 09:23:43 +07:00
* @ param tools _csv
* @ param php _version
2019-12-27 08:26:49 +07:00
* @ param os _version
* /
2020-03-14 09:26:11 +07:00
async function addTools ( tools _csv , php _version , os _version ) {
let script = '\n' + ( await utils . stepLog ( 'Setup Tools' , os _version ) ) ;
const tools _list = await getCleanedToolsList ( tools _csv ) ;
await utils . asyncForEach ( tools _list , async function ( release ) {
const tool _data = await parseTool ( release ) ;
const tool = tool _data . name ;
const version = tool _data . version ;
const github = 'https://github.com/' ;
let uri = await getUri ( tool , '.phar' , version , 'releases' , '' , 'download' ) ;
script += '\n' ;
let url = '' ;
switch ( tool ) {
case 'cs2pr' :
uri = await getUri ( tool , '' , version , 'releases' , '' , 'download' ) ;
url = github + 'staabm/annotate-pull-request-from-checkstyle/' + uri ;
script += await addArchive ( tool , version , url , os _version ) ;
break ;
case 'php-cs-fixer' :
uri = await getUri ( tool , '.phar' , version , 'releases' , 'v' , 'download' ) ;
url = github + 'FriendsOfPHP/PHP-CS-Fixer/' + uri ;
script += await addArchive ( tool , version , url , os _version ) ;
break ;
case 'phpcs' :
case 'phpcbf' :
url = github + 'squizlabs/PHP_CodeSniffer/' + uri ;
script += await addArchive ( tool , version , url , os _version ) ;
break ;
case 'phive' :
script += await addPhive ( version , os _version ) ;
break ;
case 'phpstan' :
url = github + 'phpstan/phpstan/' + uri ;
script += await addArchive ( tool , version , url , os _version ) ;
break ;
case 'phpmd' :
url = github + 'phpmd/phpmd/' + uri ;
script += await addArchive ( tool , version , url , os _version ) ;
break ;
case 'psalm' :
url = github + 'vimeo/psalm/' + uri ;
script += await addArchive ( tool , version , url , os _version ) ;
break ;
case 'composer' :
2020-07-07 18:06:32 +07:00
url = await getComposerUrl ( version ) ;
script += await addArchive ( 'composer' , version , url , os _version ) ;
2020-03-14 09:26:11 +07:00
break ;
case 'codeception' :
url =
'https://codeception.com/' +
( await getCodeceptionUri ( version , php _version ) ) ;
script += await addArchive ( tool , version , url , os _version ) ;
break ;
case 'phpcpd' :
case 'phpunit' :
url = await getPharUrl ( 'https://phar.phpunit.de' , tool , '' , version ) ;
script += await addArchive ( tool , version , url , os _version ) ;
break ;
case 'deployer' :
url = await getDeployerUrl ( version ) ;
script += await addArchive ( tool , version , url , os _version ) ;
break ;
case 'phinx' :
script += await addPackage ( tool , release , 'robmorgan/' , os _version ) ;
break ;
case 'prestissimo' :
script += await addPackage ( tool , release , 'hirak/' , os _version ) ;
break ;
case 'composer-prefetcher' :
script += await addPackage ( tool , release , 'narrowspark/automatic-' , os _version ) ;
break ;
case 'pecl' :
script += await getCommand ( os _version , 'pecl' ) ;
break ;
case 'php-config' :
case 'phpize' :
script += await addDevTools ( tool , os _version ) ;
break ;
case 'symfony' :
case 'symfony-cli' :
uri = await getSymfonyUri ( version , os _version ) ;
url = github + 'symfony/cli/' + uri ;
script += await addArchive ( 'symfony' , version , url , os _version ) ;
break ;
default :
script += await utils . addLog ( '$cross' , tool , 'Tool ' + tool + ' is not supported' , os _version ) ;
break ;
}
2019-12-27 08:26:49 +07:00
} ) ;
2020-03-14 09:26:11 +07:00
return script ;
2019-12-27 08:26:49 +07:00
}
exports . addTools = addTools ;
2020-07-07 18:06:32 +07:00
/***/ } ) ,
/***/ 539 :
/***/ ( function ( _ _unusedmodule , exports , _ _webpack _require _ _ ) {
"use strict" ;
Object . defineProperty ( exports , "__esModule" , { value : true } ) ;
const url = _ _webpack _require _ _ ( 835 ) ;
const http = _ _webpack _require _ _ ( 605 ) ;
const https = _ _webpack _require _ _ ( 211 ) ;
const pm = _ _webpack _require _ _ ( 950 ) ;
let tunnel ;
var HttpCodes ;
( function ( HttpCodes ) {
HttpCodes [ HttpCodes [ "OK" ] = 200 ] = "OK" ;
HttpCodes [ HttpCodes [ "MultipleChoices" ] = 300 ] = "MultipleChoices" ;
HttpCodes [ HttpCodes [ "MovedPermanently" ] = 301 ] = "MovedPermanently" ;
HttpCodes [ HttpCodes [ "ResourceMoved" ] = 302 ] = "ResourceMoved" ;
HttpCodes [ HttpCodes [ "SeeOther" ] = 303 ] = "SeeOther" ;
HttpCodes [ HttpCodes [ "NotModified" ] = 304 ] = "NotModified" ;
HttpCodes [ HttpCodes [ "UseProxy" ] = 305 ] = "UseProxy" ;
HttpCodes [ HttpCodes [ "SwitchProxy" ] = 306 ] = "SwitchProxy" ;
HttpCodes [ HttpCodes [ "TemporaryRedirect" ] = 307 ] = "TemporaryRedirect" ;
HttpCodes [ HttpCodes [ "PermanentRedirect" ] = 308 ] = "PermanentRedirect" ;
HttpCodes [ HttpCodes [ "BadRequest" ] = 400 ] = "BadRequest" ;
HttpCodes [ HttpCodes [ "Unauthorized" ] = 401 ] = "Unauthorized" ;
HttpCodes [ HttpCodes [ "PaymentRequired" ] = 402 ] = "PaymentRequired" ;
HttpCodes [ HttpCodes [ "Forbidden" ] = 403 ] = "Forbidden" ;
HttpCodes [ HttpCodes [ "NotFound" ] = 404 ] = "NotFound" ;
HttpCodes [ HttpCodes [ "MethodNotAllowed" ] = 405 ] = "MethodNotAllowed" ;
HttpCodes [ HttpCodes [ "NotAcceptable" ] = 406 ] = "NotAcceptable" ;
HttpCodes [ HttpCodes [ "ProxyAuthenticationRequired" ] = 407 ] = "ProxyAuthenticationRequired" ;
HttpCodes [ HttpCodes [ "RequestTimeout" ] = 408 ] = "RequestTimeout" ;
HttpCodes [ HttpCodes [ "Conflict" ] = 409 ] = "Conflict" ;
HttpCodes [ HttpCodes [ "Gone" ] = 410 ] = "Gone" ;
HttpCodes [ HttpCodes [ "TooManyRequests" ] = 429 ] = "TooManyRequests" ;
HttpCodes [ HttpCodes [ "InternalServerError" ] = 500 ] = "InternalServerError" ;
HttpCodes [ HttpCodes [ "NotImplemented" ] = 501 ] = "NotImplemented" ;
HttpCodes [ HttpCodes [ "BadGateway" ] = 502 ] = "BadGateway" ;
HttpCodes [ HttpCodes [ "ServiceUnavailable" ] = 503 ] = "ServiceUnavailable" ;
HttpCodes [ HttpCodes [ "GatewayTimeout" ] = 504 ] = "GatewayTimeout" ;
} ) ( HttpCodes = exports . HttpCodes || ( exports . HttpCodes = { } ) ) ;
var Headers ;
( function ( Headers ) {
Headers [ "Accept" ] = "accept" ;
Headers [ "ContentType" ] = "content-type" ;
} ) ( Headers = exports . Headers || ( exports . Headers = { } ) ) ;
var MediaTypes ;
( function ( MediaTypes ) {
MediaTypes [ "ApplicationJson" ] = "application/json" ;
} ) ( MediaTypes = exports . MediaTypes || ( exports . MediaTypes = { } ) ) ;
/ * *
* Returns the proxy URL , depending upon the supplied url and proxy environment variables .
* @ param serverUrl The server URL where the request will be sent . For example , https : //api.github.com
* /
function getProxyUrl ( serverUrl ) {
let proxyUrl = pm . getProxyUrl ( url . parse ( serverUrl ) ) ;
return proxyUrl ? proxyUrl . href : '' ;
}
exports . getProxyUrl = getProxyUrl ;
const HttpRedirectCodes = [
HttpCodes . MovedPermanently ,
HttpCodes . ResourceMoved ,
HttpCodes . SeeOther ,
HttpCodes . TemporaryRedirect ,
HttpCodes . PermanentRedirect
] ;
const HttpResponseRetryCodes = [
HttpCodes . BadGateway ,
HttpCodes . ServiceUnavailable ,
HttpCodes . GatewayTimeout
] ;
const RetryableHttpVerbs = [ 'OPTIONS' , 'GET' , 'DELETE' , 'HEAD' ] ;
const ExponentialBackoffCeiling = 10 ;
const ExponentialBackoffTimeSlice = 5 ;
class HttpClientResponse {
constructor ( message ) {
this . message = message ;
}
readBody ( ) {
return new Promise ( async ( resolve , reject ) => {
let output = Buffer . alloc ( 0 ) ;
this . message . on ( 'data' , ( chunk ) => {
output = Buffer . concat ( [ output , chunk ] ) ;
} ) ;
this . message . on ( 'end' , ( ) => {
resolve ( output . toString ( ) ) ;
} ) ;
} ) ;
}
}
exports . HttpClientResponse = HttpClientResponse ;
function isHttps ( requestUrl ) {
let parsedUrl = url . parse ( requestUrl ) ;
return parsedUrl . protocol === 'https:' ;
}
exports . isHttps = isHttps ;
class HttpClient {
constructor ( userAgent , handlers , requestOptions ) {
this . _ignoreSslError = false ;
this . _allowRedirects = true ;
this . _allowRedirectDowngrade = false ;
this . _maxRedirects = 50 ;
this . _allowRetries = false ;
this . _maxRetries = 1 ;
this . _keepAlive = false ;
this . _disposed = false ;
this . userAgent = userAgent ;
this . handlers = handlers || [ ] ;
this . requestOptions = requestOptions ;
if ( requestOptions ) {
if ( requestOptions . ignoreSslError != null ) {
this . _ignoreSslError = requestOptions . ignoreSslError ;
}
this . _socketTimeout = requestOptions . socketTimeout ;
if ( requestOptions . allowRedirects != null ) {
this . _allowRedirects = requestOptions . allowRedirects ;
}
if ( requestOptions . allowRedirectDowngrade != null ) {
this . _allowRedirectDowngrade = requestOptions . allowRedirectDowngrade ;
}
if ( requestOptions . maxRedirects != null ) {
this . _maxRedirects = Math . max ( requestOptions . maxRedirects , 0 ) ;
}
if ( requestOptions . keepAlive != null ) {
this . _keepAlive = requestOptions . keepAlive ;
}
if ( requestOptions . allowRetries != null ) {
this . _allowRetries = requestOptions . allowRetries ;
}
if ( requestOptions . maxRetries != null ) {
this . _maxRetries = requestOptions . maxRetries ;
}
}
}
options ( requestUrl , additionalHeaders ) {
return this . request ( 'OPTIONS' , requestUrl , null , additionalHeaders || { } ) ;
}
get ( requestUrl , additionalHeaders ) {
return this . request ( 'GET' , requestUrl , null , additionalHeaders || { } ) ;
}
del ( requestUrl , additionalHeaders ) {
return this . request ( 'DELETE' , requestUrl , null , additionalHeaders || { } ) ;
}
post ( requestUrl , data , additionalHeaders ) {
return this . request ( 'POST' , requestUrl , data , additionalHeaders || { } ) ;
}
patch ( requestUrl , data , additionalHeaders ) {
return this . request ( 'PATCH' , requestUrl , data , additionalHeaders || { } ) ;
}
put ( requestUrl , data , additionalHeaders ) {
return this . request ( 'PUT' , requestUrl , data , additionalHeaders || { } ) ;
}
head ( requestUrl , additionalHeaders ) {
return this . request ( 'HEAD' , requestUrl , null , additionalHeaders || { } ) ;
}
sendStream ( verb , requestUrl , stream , additionalHeaders ) {
return this . request ( verb , requestUrl , stream , additionalHeaders ) ;
}
/ * *
* Gets a typed object from an endpoint
* Be aware that not found returns a null . Other errors ( 4 xx , 5 xx ) reject the promise
* /
async getJson ( requestUrl , additionalHeaders = { } ) {
additionalHeaders [ Headers . Accept ] = this . _getExistingOrDefaultHeader ( additionalHeaders , Headers . Accept , MediaTypes . ApplicationJson ) ;
let res = await this . get ( requestUrl , additionalHeaders ) ;
return this . _processResponse ( res , this . requestOptions ) ;
}
async postJson ( requestUrl , obj , additionalHeaders = { } ) {
let data = JSON . stringify ( obj , null , 2 ) ;
additionalHeaders [ Headers . Accept ] = this . _getExistingOrDefaultHeader ( additionalHeaders , Headers . Accept , MediaTypes . ApplicationJson ) ;
additionalHeaders [ Headers . ContentType ] = this . _getExistingOrDefaultHeader ( additionalHeaders , Headers . ContentType , MediaTypes . ApplicationJson ) ;
let res = await this . post ( requestUrl , data , additionalHeaders ) ;
return this . _processResponse ( res , this . requestOptions ) ;
}
async putJson ( requestUrl , obj , additionalHeaders = { } ) {
let data = JSON . stringify ( obj , null , 2 ) ;
additionalHeaders [ Headers . Accept ] = this . _getExistingOrDefaultHeader ( additionalHeaders , Headers . Accept , MediaTypes . ApplicationJson ) ;
additionalHeaders [ Headers . ContentType ] = this . _getExistingOrDefaultHeader ( additionalHeaders , Headers . ContentType , MediaTypes . ApplicationJson ) ;
let res = await this . put ( requestUrl , data , additionalHeaders ) ;
return this . _processResponse ( res , this . requestOptions ) ;
}
async patchJson ( requestUrl , obj , additionalHeaders = { } ) {
let data = JSON . stringify ( obj , null , 2 ) ;
additionalHeaders [ Headers . Accept ] = this . _getExistingOrDefaultHeader ( additionalHeaders , Headers . Accept , MediaTypes . ApplicationJson ) ;
additionalHeaders [ Headers . ContentType ] = this . _getExistingOrDefaultHeader ( additionalHeaders , Headers . ContentType , MediaTypes . ApplicationJson ) ;
let res = await this . patch ( requestUrl , data , additionalHeaders ) ;
return this . _processResponse ( res , this . requestOptions ) ;
}
/ * *
* Makes a raw http request .
* All other methods such as get , post , patch , and request ultimately call this .
* Prefer get , del , post and patch
* /
async request ( verb , requestUrl , data , headers ) {
if ( this . _disposed ) {
throw new Error ( 'Client has already been disposed.' ) ;
}
let parsedUrl = url . parse ( requestUrl ) ;
let info = this . _prepareRequest ( verb , parsedUrl , headers ) ;
// Only perform retries on reads since writes may not be idempotent.
let maxTries = this . _allowRetries && RetryableHttpVerbs . indexOf ( verb ) != - 1
? this . _maxRetries + 1
: 1 ;
let numTries = 0 ;
let response ;
while ( numTries < maxTries ) {
response = await this . requestRaw ( info , data ) ;
// Check if it's an authentication challenge
if ( response &&
response . message &&
response . message . statusCode === HttpCodes . Unauthorized ) {
let authenticationHandler ;
for ( let i = 0 ; i < this . handlers . length ; i ++ ) {
if ( this . handlers [ i ] . canHandleAuthentication ( response ) ) {
authenticationHandler = this . handlers [ i ] ;
break ;
}
}
if ( authenticationHandler ) {
return authenticationHandler . handleAuthentication ( this , info , data ) ;
}
else {
// We have received an unauthorized response but have no handlers to handle it.
// Let the response return to the caller.
return response ;
}
}
let redirectsRemaining = this . _maxRedirects ;
while ( HttpRedirectCodes . indexOf ( response . message . statusCode ) != - 1 &&
this . _allowRedirects &&
redirectsRemaining > 0 ) {
const redirectUrl = response . message . headers [ 'location' ] ;
if ( ! redirectUrl ) {
// if there's no location to redirect to, we won't
break ;
}
let parsedRedirectUrl = url . parse ( redirectUrl ) ;
if ( parsedUrl . protocol == 'https:' &&
parsedUrl . protocol != parsedRedirectUrl . protocol &&
! this . _allowRedirectDowngrade ) {
throw new Error ( 'Redirect from HTTPS to HTTP protocol. This downgrade is not allowed for security reasons. If you want to allow this behavior, set the allowRedirectDowngrade option to true.' ) ;
}
// we need to finish reading the response before reassigning response
// which will leak the open socket.
await response . readBody ( ) ;
// strip authorization header if redirected to a different hostname
if ( parsedRedirectUrl . hostname !== parsedUrl . hostname ) {
for ( let header in headers ) {
// header names are case insensitive
if ( header . toLowerCase ( ) === 'authorization' ) {
delete headers [ header ] ;
}
}
}
// let's make the request with the new redirectUrl
info = this . _prepareRequest ( verb , parsedRedirectUrl , headers ) ;
response = await this . requestRaw ( info , data ) ;
redirectsRemaining -- ;
}
if ( HttpResponseRetryCodes . indexOf ( response . message . statusCode ) == - 1 ) {
// If not a retry code, return immediately instead of retrying
return response ;
}
numTries += 1 ;
if ( numTries < maxTries ) {
await response . readBody ( ) ;
await this . _performExponentialBackoff ( numTries ) ;
}
}
return response ;
}
/ * *
* Needs to be called if keepAlive is set to true in request options .
* /
dispose ( ) {
if ( this . _agent ) {
this . _agent . destroy ( ) ;
}
this . _disposed = true ;
}
/ * *
* Raw request .
* @ param info
* @ param data
* /
requestRaw ( info , data ) {
return new Promise ( ( resolve , reject ) => {
let callbackForResult = function ( err , res ) {
if ( err ) {
reject ( err ) ;
}
resolve ( res ) ;
} ;
this . requestRawWithCallback ( info , data , callbackForResult ) ;
} ) ;
}
/ * *
* Raw request with callback .
* @ param info
* @ param data
* @ param onResult
* /
requestRawWithCallback ( info , data , onResult ) {
let socket ;
if ( typeof data === 'string' ) {
info . options . headers [ 'Content-Length' ] = Buffer . byteLength ( data , 'utf8' ) ;
}
let callbackCalled = false ;
let handleResult = ( err , res ) => {
if ( ! callbackCalled ) {
callbackCalled = true ;
onResult ( err , res ) ;
}
} ;
let req = info . httpModule . request ( info . options , ( msg ) => {
let res = new HttpClientResponse ( msg ) ;
handleResult ( null , res ) ;
} ) ;
req . on ( 'socket' , sock => {
socket = sock ;
} ) ;
// If we ever get disconnected, we want the socket to timeout eventually
req . setTimeout ( this . _socketTimeout || 3 * 60000 , ( ) => {
if ( socket ) {
socket . end ( ) ;
}
handleResult ( new Error ( 'Request timeout: ' + info . options . path ) , null ) ;
} ) ;
req . on ( 'error' , function ( err ) {
// err has statusCode property
// res should have headers
handleResult ( err , null ) ;
} ) ;
if ( data && typeof data === 'string' ) {
req . write ( data , 'utf8' ) ;
}
if ( data && typeof data !== 'string' ) {
data . on ( 'close' , function ( ) {
req . end ( ) ;
} ) ;
data . pipe ( req ) ;
}
else {
req . end ( ) ;
}
}
/ * *
* Gets an http agent . This function is useful when you need an http agent that handles
* routing through a proxy server - depending upon the url and proxy environment variables .
* @ param serverUrl The server URL where the request will be sent . For example , https : //api.github.com
* /
getAgent ( serverUrl ) {
let parsedUrl = url . parse ( serverUrl ) ;
return this . _getAgent ( parsedUrl ) ;
}
_prepareRequest ( method , requestUrl , headers ) {
const info = { } ;
info . parsedUrl = requestUrl ;
const usingSsl = info . parsedUrl . protocol === 'https:' ;
info . httpModule = usingSsl ? https : http ;
const defaultPort = usingSsl ? 443 : 80 ;
info . options = { } ;
info . options . host = info . parsedUrl . hostname ;
info . options . port = info . parsedUrl . port
? parseInt ( info . parsedUrl . port )
: defaultPort ;
info . options . path =
( info . parsedUrl . pathname || '' ) + ( info . parsedUrl . search || '' ) ;
info . options . method = method ;
info . options . headers = this . _mergeHeaders ( headers ) ;
if ( this . userAgent != null ) {
info . options . headers [ 'user-agent' ] = this . userAgent ;
}
info . options . agent = this . _getAgent ( info . parsedUrl ) ;
// gives handlers an opportunity to participate
if ( this . handlers ) {
this . handlers . forEach ( handler => {
handler . prepareRequest ( info . options ) ;
} ) ;
}
return info ;
}
_mergeHeaders ( headers ) {
const lowercaseKeys = obj => Object . keys ( obj ) . reduce ( ( c , k ) => ( ( c [ k . toLowerCase ( ) ] = obj [ k ] ) , c ) , { } ) ;
if ( this . requestOptions && this . requestOptions . headers ) {
return Object . assign ( { } , lowercaseKeys ( this . requestOptions . headers ) , lowercaseKeys ( headers ) ) ;
}
return lowercaseKeys ( headers || { } ) ;
}
_getExistingOrDefaultHeader ( additionalHeaders , header , _default ) {
const lowercaseKeys = obj => Object . keys ( obj ) . reduce ( ( c , k ) => ( ( c [ k . toLowerCase ( ) ] = obj [ k ] ) , c ) , { } ) ;
let clientHeader ;
if ( this . requestOptions && this . requestOptions . headers ) {
clientHeader = lowercaseKeys ( this . requestOptions . headers ) [ header ] ;
}
return additionalHeaders [ header ] || clientHeader || _default ;
}
_getAgent ( parsedUrl ) {
let agent ;
let proxyUrl = pm . getProxyUrl ( parsedUrl ) ;
let useProxy = proxyUrl && proxyUrl . hostname ;
if ( this . _keepAlive && useProxy ) {
agent = this . _proxyAgent ;
}
if ( this . _keepAlive && ! useProxy ) {
agent = this . _agent ;
}
// if agent is already assigned use that agent.
if ( ! ! agent ) {
return agent ;
}
const usingSsl = parsedUrl . protocol === 'https:' ;
let maxSockets = 100 ;
if ( ! ! this . requestOptions ) {
maxSockets = this . requestOptions . maxSockets || http . globalAgent . maxSockets ;
}
if ( useProxy ) {
// If using proxy, need tunnel
if ( ! tunnel ) {
tunnel = _ _webpack _require _ _ ( 413 ) ;
}
const agentOptions = {
maxSockets : maxSockets ,
keepAlive : this . _keepAlive ,
proxy : {
proxyAuth : proxyUrl . auth ,
host : proxyUrl . hostname ,
port : proxyUrl . port
}
} ;
let tunnelAgent ;
const overHttps = proxyUrl . protocol === 'https:' ;
if ( usingSsl ) {
tunnelAgent = overHttps ? tunnel . httpsOverHttps : tunnel . httpsOverHttp ;
}
else {
tunnelAgent = overHttps ? tunnel . httpOverHttps : tunnel . httpOverHttp ;
}
agent = tunnelAgent ( agentOptions ) ;
this . _proxyAgent = agent ;
}
// if reusing agent across request and tunneling agent isn't assigned create a new agent
if ( this . _keepAlive && ! agent ) {
const options = { keepAlive : this . _keepAlive , maxSockets : maxSockets } ;
agent = usingSsl ? new https . Agent ( options ) : new http . Agent ( options ) ;
this . _agent = agent ;
}
// if not using private agent and tunnel agent isn't setup then use global agent
if ( ! agent ) {
agent = usingSsl ? https . globalAgent : http . globalAgent ;
}
if ( usingSsl && this . _ignoreSslError ) {
// we don't want to set NODE_TLS_REJECT_UNAUTHORIZED=0 since that will affect request for entire process
// http.RequestOptions doesn't expose a way to modify RequestOptions.agent.options
// we have to cast it to any and change it directly
agent . options = Object . assign ( agent . options || { } , {
rejectUnauthorized : false
} ) ;
}
return agent ;
}
_performExponentialBackoff ( retryNumber ) {
retryNumber = Math . min ( ExponentialBackoffCeiling , retryNumber ) ;
const ms = ExponentialBackoffTimeSlice * Math . pow ( 2 , retryNumber ) ;
return new Promise ( resolve => setTimeout ( ( ) => resolve ( ) , ms ) ) ;
}
static dateTimeDeserializer ( key , value ) {
if ( typeof value === 'string' ) {
let a = new Date ( value ) ;
if ( ! isNaN ( a . valueOf ( ) ) ) {
return a ;
}
}
return value ;
}
async _processResponse ( res , options ) {
return new Promise ( async ( resolve , reject ) => {
const statusCode = res . message . statusCode ;
const response = {
statusCode : statusCode ,
result : null ,
headers : { }
} ;
// not found leads to null obj returned
if ( statusCode == HttpCodes . NotFound ) {
resolve ( response ) ;
}
let obj ;
let contents ;
// get the result from the body
try {
contents = await res . readBody ( ) ;
if ( contents && contents . length > 0 ) {
if ( options && options . deserializeDates ) {
obj = JSON . parse ( contents , HttpClient . dateTimeDeserializer ) ;
}
else {
obj = JSON . parse ( contents ) ;
}
response . result = obj ;
}
response . headers = res . message . headers ;
}
catch ( err ) {
// Invalid resource (contents not json); leaving result obj null
}
// note that 3xx redirects are handled by the http layer.
if ( statusCode > 299 ) {
let msg ;
// if exception/error in body, attempt to get better error
if ( obj && obj . message ) {
msg = obj . message ;
}
else if ( contents && contents . length > 0 ) {
// it may be the case that the exception is in the body message as string
msg = contents ;
}
else {
msg = 'Failed request: (' + statusCode + ')' ;
}
let err = new Error ( msg ) ;
// attach statusCode and body obj (if available) to the error object
err [ 'statusCode' ] = statusCode ;
if ( response . result ) {
err [ 'result' ] = response . result ;
}
reject ( err ) ;
}
else {
resolve ( response ) ;
}
} ) ;
}
}
exports . HttpClient = HttpClient ;
/***/ } ) ,
/***/ 605 :
/***/ ( function ( module ) {
module . exports = require ( "http" ) ;
2019-11-24 06:44:53 +07:00
/***/ } ) ,
/***/ 614 :
/***/ ( function ( module ) {
module . exports = require ( "events" ) ;
/***/ } ) ,
/***/ 622 :
/***/ ( function ( module ) {
module . exports = require ( "path" ) ;
/***/ } ) ,
2020-07-07 18:06:32 +07:00
/***/ 631 :
/***/ ( function ( module ) {
module . exports = require ( "net" ) ;
/***/ } ) ,
2019-11-24 06:44:53 +07:00
/***/ 635 :
/***/ ( function ( _ _unusedmodule , exports , _ _webpack _require _ _ ) {
"use strict" ;
2020-05-13 23:18:11 +07:00
var _ _createBinding = ( this && this . _ _createBinding ) || ( Object . create ? ( function ( o , m , k , k2 ) {
if ( k2 === undefined ) k2 = k ;
Object . defineProperty ( o , k2 , { enumerable : true , get : function ( ) { return m [ k ] ; } } ) ;
} ) : ( function ( o , m , k , k2 ) {
if ( k2 === undefined ) k2 = k ;
o [ k2 ] = m [ k ] ;
} ) ) ;
var _ _setModuleDefault = ( this && this . _ _setModuleDefault ) || ( Object . create ? ( function ( o , v ) {
Object . defineProperty ( o , "default" , { enumerable : true , value : v } ) ;
} ) : function ( o , v ) {
o [ "default" ] = v ;
} ) ;
2019-11-24 06:44:53 +07:00
var _ _importStar = ( this && this . _ _importStar ) || function ( mod ) {
if ( mod && mod . _ _esModule ) return mod ;
var result = { } ;
2020-06-08 08:39:31 +07:00
if ( mod != null ) for ( var k in mod ) if ( k !== "default" && Object . hasOwnProperty . call ( mod , k ) ) _ _createBinding ( result , mod , k ) ;
2020-05-13 23:18:11 +07:00
_ _setModuleDefault ( result , mod ) ;
2019-11-24 06:44:53 +07:00
return result ;
} ;
Object . defineProperty ( exports , "__esModule" , { value : true } ) ;
2020-05-13 23:18:11 +07:00
exports . addCoverage = exports . disableCoverage = exports . addCoveragePCOV = exports . addCoverageXdebug = void 0 ;
2019-11-24 06:44:53 +07:00
const utils = _ _importStar ( _ _webpack _require _ _ ( 163 ) ) ;
const extensions = _ _importStar ( _ _webpack _require _ _ ( 911 ) ) ;
const config = _ _importStar ( _ _webpack _require _ _ ( 641 ) ) ;
/ * *
* Function to setup Xdebug
*
* @ param version
* @ param os _version
2019-12-26 20:01:18 +07:00
* @ param pipe
2019-11-24 06:44:53 +07:00
* /
2020-03-14 09:26:11 +07:00
async function addCoverageXdebug ( version , os _version , pipe ) {
2020-06-19 16:17:34 +07:00
const xdebug = ( await extensions . addExtension ( 'xdebug' , version , os _version , true ) ) + pipe ;
const ini = await config . addINIValues ( 'xdebug.mode=coverage' , os _version , true ) ;
const log = await utils . addLog ( '$tick' , 'xdebug' , 'Xdebug enabled as coverage driver' , os _version ) ;
switch ( true ) {
case /8.[0-9]/ . test ( version ) :
return xdebug + '\n' + ini + '\n' + log ;
case /5\.[3-6]|7.[0-4]/ . test ( version ) :
2020-03-14 09:26:11 +07:00
default :
2020-06-19 16:17:34 +07:00
return xdebug + '\n' + log ;
2020-03-14 09:26:11 +07:00
}
2019-11-24 06:44:53 +07:00
}
exports . addCoverageXdebug = addCoverageXdebug ;
/ * *
* Function to setup PCOV
*
* @ param version
* @ param os _version
2019-12-26 20:01:18 +07:00
* @ param pipe
2019-11-24 06:44:53 +07:00
* /
2020-03-14 09:26:11 +07:00
async function addCoveragePCOV ( version , os _version , pipe ) {
let script = '\n' ;
switch ( version ) {
default :
script +=
( await extensions . addExtension ( 'pcov' , version , os _version , true ) ) +
pipe +
'\n' ;
script +=
( await config . addINIValues ( 'pcov.enabled=1' , os _version , true ) ) + '\n' ;
// add command to disable xdebug and enable pcov
switch ( os _version ) {
case 'linux' :
case 'darwin' :
script += 'remove_extension xdebug' + pipe + '\n' ;
break ;
case 'win32' :
script += 'Remove-Extension xdebug' + pipe + '\n' ;
break ;
}
// success
script += await utils . addLog ( '$tick' , 'coverage: pcov' , 'PCOV enabled as coverage driver' , os _version ) ;
// version is not supported
break ;
case '5.6' :
case '7.0' :
script += await utils . addLog ( '$cross' , 'pcov' , 'PHP 7.1 or newer is required' , os _version ) ;
break ;
}
return script ;
2019-11-24 06:44:53 +07:00
}
exports . addCoveragePCOV = addCoveragePCOV ;
/ * *
* Function to disable Xdebug and PCOV
*
* @ param version
* @ param os _version
2019-12-26 20:01:18 +07:00
* @ param pipe
2019-11-24 06:44:53 +07:00
* /
2020-03-14 09:26:11 +07:00
async function disableCoverage ( version , os _version , pipe ) {
let script = '\n' ;
switch ( os _version ) {
case 'linux' :
case 'darwin' :
script += 'remove_extension xdebug' + pipe + '\n' ;
script += 'remove_extension pcov' + pipe + '\n' ;
break ;
case 'win32' :
script += 'Remove-Extension xdebug' + pipe + '\n' ;
script += 'Remove-Extension pcov' + pipe + '\n' ;
break ;
}
script += await utils . addLog ( '$tick' , 'none' , 'Disabled Xdebug and PCOV' , os _version ) ;
return script ;
2019-11-24 06:44:53 +07:00
}
exports . disableCoverage = disableCoverage ;
/ * *
* Function to set coverage driver
*
* @ param coverage _driver
* @ param version
* @ param os _version
* /
2020-03-14 09:26:11 +07:00
async function addCoverage ( coverage _driver , version , os _version ) {
coverage _driver = coverage _driver . toLowerCase ( ) ;
const script = '\n' + ( await utils . stepLog ( 'Setup Coverage' , os _version ) ) ;
const pipe = await utils . suppressOutput ( os _version ) ;
switch ( coverage _driver ) {
case 'pcov' :
return script + ( await addCoveragePCOV ( version , os _version , pipe ) ) ;
case 'xdebug' :
return script + ( await addCoverageXdebug ( version , os _version , pipe ) ) ;
case 'none' :
return script + ( await disableCoverage ( version , os _version , pipe ) ) ;
default :
return '' ;
}
2019-11-24 06:44:53 +07:00
}
exports . addCoverage = addCoverage ;
/***/ } ) ,
/***/ 641 :
/***/ ( function ( _ _unusedmodule , exports , _ _webpack _require _ _ ) {
"use strict" ;
2020-05-13 23:18:11 +07:00
var _ _createBinding = ( this && this . _ _createBinding ) || ( Object . create ? ( function ( o , m , k , k2 ) {
if ( k2 === undefined ) k2 = k ;
Object . defineProperty ( o , k2 , { enumerable : true , get : function ( ) { return m [ k ] ; } } ) ;
} ) : ( function ( o , m , k , k2 ) {
if ( k2 === undefined ) k2 = k ;
o [ k2 ] = m [ k ] ;
} ) ) ;
var _ _setModuleDefault = ( this && this . _ _setModuleDefault ) || ( Object . create ? ( function ( o , v ) {
Object . defineProperty ( o , "default" , { enumerable : true , value : v } ) ;
} ) : function ( o , v ) {
o [ "default" ] = v ;
} ) ;
2019-11-24 06:44:53 +07:00
var _ _importStar = ( this && this . _ _importStar ) || function ( mod ) {
if ( mod && mod . _ _esModule ) return mod ;
var result = { } ;
2020-06-08 08:39:31 +07:00
if ( mod != null ) for ( var k in mod ) if ( k !== "default" && Object . hasOwnProperty . call ( mod , k ) ) _ _createBinding ( result , mod , k ) ;
2020-05-13 23:18:11 +07:00
_ _setModuleDefault ( result , mod ) ;
2019-11-24 06:44:53 +07:00
return result ;
} ;
Object . defineProperty ( exports , "__esModule" , { value : true } ) ;
2020-05-13 23:18:11 +07:00
exports . addINIValues = exports . addINIValuesWindows = exports . addINIValuesUnix = void 0 ;
2019-11-24 06:44:53 +07:00
const utils = _ _importStar ( _ _webpack _require _ _ ( 163 ) ) ;
/ * *
* Add script to set custom ini values for unix
*
* @ param ini _values _csv
* /
2020-03-14 09:26:11 +07:00
async function addINIValuesUnix ( ini _values _csv ) {
const ini _values = await utils . CSVArray ( ini _values _csv ) ;
let script = '\n' ;
await utils . asyncForEach ( ini _values , async function ( line ) {
script +=
( await utils . addLog ( '$tick' , line , 'Added to php.ini' , 'linux' ) ) + '\n' ;
2019-11-24 06:44:53 +07:00
} ) ;
2020-03-14 09:26:11 +07:00
return 'echo "' + ini _values . join ( '\n' ) + '" >> $ini_file' + script ;
2019-11-24 06:44:53 +07:00
}
exports . addINIValuesUnix = addINIValuesUnix ;
/ * *
* Add script to set custom ini values for windows
*
* @ param ini _values _csv
* /
2020-03-14 09:26:11 +07:00
async function addINIValuesWindows ( ini _values _csv ) {
const ini _values = await utils . CSVArray ( ini _values _csv ) ;
let script = '\n' ;
await utils . asyncForEach ( ini _values , async function ( line ) {
script +=
( await utils . addLog ( '$tick' , line , 'Added to php.ini' , 'win32' ) ) + '\n' ;
2019-11-24 06:44:53 +07:00
} ) ;
2020-03-14 09:26:11 +07:00
return ( 'Add-Content C:\\tools\\php\\php.ini "' +
ini _values . join ( '\n' ) +
'"' +
script ) ;
2019-11-24 06:44:53 +07:00
}
exports . addINIValuesWindows = addINIValuesWindows ;
/ * *
* Function to add custom ini values
*
* @ param ini _values _csv
* @ param os _version
2020-03-14 09:23:43 +07:00
* @ param no _step
2019-11-24 06:44:53 +07:00
* /
2020-03-14 09:26:11 +07:00
async function addINIValues ( ini _values _csv , os _version , no _step = false ) {
let script = '\n' ;
switch ( no _step ) {
case true :
script +=
( await utils . stepLog ( 'Add php.ini values' , os _version ) ) +
( await utils . suppressOutput ( os _version ) ) +
'\n' ;
break ;
case false :
default :
script += ( await utils . stepLog ( 'Add php.ini values' , os _version ) ) + '\n' ;
break ;
}
switch ( os _version ) {
case 'win32' :
return script + ( await addINIValuesWindows ( ini _values _csv ) ) ;
case 'darwin' :
case 'linux' :
return script + ( await addINIValuesUnix ( ini _values _csv ) ) ;
default :
return await utils . log ( 'Platform ' + os _version + ' is not supported' , os _version , 'error' ) ;
}
2019-11-24 06:44:53 +07:00
}
exports . addINIValues = addINIValues ;
/***/ } ) ,
/***/ 655 :
/***/ ( function ( _ _unusedmodule , exports , _ _webpack _require _ _ ) {
"use strict" ;
2020-05-13 23:18:11 +07:00
var _ _createBinding = ( this && this . _ _createBinding ) || ( Object . create ? ( function ( o , m , k , k2 ) {
if ( k2 === undefined ) k2 = k ;
Object . defineProperty ( o , k2 , { enumerable : true , get : function ( ) { return m [ k ] ; } } ) ;
} ) : ( function ( o , m , k , k2 ) {
if ( k2 === undefined ) k2 = k ;
o [ k2 ] = m [ k ] ;
} ) ) ;
var _ _setModuleDefault = ( this && this . _ _setModuleDefault ) || ( Object . create ? ( function ( o , v ) {
Object . defineProperty ( o , "default" , { enumerable : true , value : v } ) ;
} ) : function ( o , v ) {
o [ "default" ] = v ;
} ) ;
2019-11-24 06:44:53 +07:00
var _ _importStar = ( this && this . _ _importStar ) || function ( mod ) {
if ( mod && mod . _ _esModule ) return mod ;
var result = { } ;
2020-06-08 08:39:31 +07:00
if ( mod != null ) for ( var k in mod ) if ( k !== "default" && Object . hasOwnProperty . call ( mod , k ) ) _ _createBinding ( result , mod , k ) ;
2020-05-13 23:18:11 +07:00
_ _setModuleDefault ( result , mod ) ;
2019-11-24 06:44:53 +07:00
return result ;
} ;
Object . defineProperty ( exports , "__esModule" , { value : true } ) ;
2020-05-13 23:18:11 +07:00
exports . run = exports . build = void 0 ;
2019-11-24 06:44:53 +07:00
const exec _1 = _ _webpack _require _ _ ( 986 ) ;
const core = _ _importStar ( _ _webpack _require _ _ ( 470 ) ) ;
const config = _ _importStar ( _ _webpack _require _ _ ( 641 ) ) ;
const coverage = _ _importStar ( _ _webpack _require _ _ ( 635 ) ) ;
const extensions = _ _importStar ( _ _webpack _require _ _ ( 911 ) ) ;
2019-12-27 08:26:49 +07:00
const tools = _ _importStar ( _ _webpack _require _ _ ( 534 ) ) ;
2019-11-24 06:44:53 +07:00
const utils = _ _importStar ( _ _webpack _require _ _ ( 163 ) ) ;
2019-12-19 04:08:12 +07:00
const matchers = _ _importStar ( _ _webpack _require _ _ ( 86 ) ) ;
2019-11-24 06:44:53 +07:00
/ * *
* Build the script
*
* @ param filename
* @ param version
* @ param os _version
* /
2020-03-14 09:26:11 +07:00
async function build ( filename , version , os _version ) {
// taking inputs
const extension _csv = ( await utils . getInput ( 'extensions' , false ) ) ||
( await utils . getInput ( 'extension' , false ) ) ||
( await utils . getInput ( 'extension-csv' , false ) ) ;
const ini _values _csv = ( await utils . getInput ( 'ini-values' , false ) ) ||
( await utils . getInput ( 'ini-values-csv' , false ) ) ;
const coverage _driver = await utils . getInput ( 'coverage' , false ) ;
const pecl = await utils . getInput ( 'pecl' , false ) ;
let tools _csv = await utils . getInput ( 'tools' , false ) ;
if ( pecl == 'true' ||
/.*-(beta|alpha|devel|snapshot).*/ . test ( extension _csv ) ) {
tools _csv = 'pecl, ' + tools _csv ;
}
let script = await utils . readScript ( filename ) ;
script += await tools . addTools ( tools _csv , version , os _version ) ;
if ( extension _csv ) {
script += await extensions . addExtension ( extension _csv , version , os _version ) ;
}
if ( coverage _driver ) {
script += await coverage . addCoverage ( coverage _driver , version , os _version ) ;
}
2020-07-08 09:15:11 +07:00
if ( ini _values _csv ) {
script += await config . addINIValues ( ini _values _csv , os _version ) ;
}
2020-03-14 09:26:11 +07:00
return await utils . writeScript ( filename , script ) ;
2019-11-24 06:44:53 +07:00
}
exports . build = build ;
/ * *
* Run the script
* /
2020-03-14 09:26:11 +07:00
async function run ( ) {
try {
const os _version = process . platform ;
let version = await utils . getInput ( 'php-version' , true ) ;
version = version . length > 1 ? version . slice ( 0 , 3 ) : version + '.0' ;
// check the os version and run the respective script
let script _path = '' ;
switch ( os _version ) {
case 'darwin' :
case 'linux' :
script _path = await build ( os _version + '.sh' , version , os _version ) ;
2020-06-08 03:21:09 +07:00
await exec _1 . exec ( 'bash ' + script _path + ' ' + version + ' ' + _ _dirname ) ;
2020-03-14 09:26:11 +07:00
break ;
case 'win32' :
script _path = await build ( 'win32.ps1' , version , os _version ) ;
await exec _1 . exec ( 'pwsh ' + script _path + ' ' + version + ' ' + _ _dirname ) ;
break ;
2019-11-24 06:44:53 +07:00
}
2020-03-14 09:26:11 +07:00
await matchers . addMatchers ( ) ;
}
catch ( error ) {
core . setFailed ( error . message ) ;
}
2019-11-24 06:44:53 +07:00
}
exports . run = run ;
// call the run function
run ( ) ;
2019-12-10 06:52:33 +07:00
/***/ } ) ,
/***/ 669 :
/***/ ( function ( module ) {
module . exports = require ( "util" ) ;
/***/ } ) ,
/***/ 672 :
/***/ ( function ( _ _unusedmodule , exports , _ _webpack _require _ _ ) {
"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 ) : adopt ( result . value ) . then ( fulfilled , rejected ) ; }
step ( ( generator = generator . apply ( thisArg , _arguments || [ ] ) ) . next ( ) ) ;
} ) ;
} ;
var _a ;
Object . defineProperty ( exports , "__esModule" , { value : true } ) ;
const assert _1 = _ _webpack _require _ _ ( 357 ) ;
const fs = _ _webpack _require _ _ ( 747 ) ;
const path = _ _webpack _require _ _ ( 622 ) ;
_a = fs . promises , exports . chmod = _a . chmod , exports . copyFile = _a . copyFile , exports . lstat = _a . lstat , exports . mkdir = _a . mkdir , exports . readdir = _a . readdir , exports . readlink = _a . readlink , exports . rename = _a . rename , exports . rmdir = _a . rmdir , exports . stat = _a . stat , exports . symlink = _a . symlink , exports . unlink = _a . unlink ;
exports . IS _WINDOWS = process . platform === 'win32' ;
function exists ( fsPath ) {
return _ _awaiter ( this , void 0 , void 0 , function * ( ) {
try {
yield exports . stat ( fsPath ) ;
}
catch ( err ) {
if ( err . code === 'ENOENT' ) {
return false ;
}
throw err ;
}
return true ;
} ) ;
}
exports . exists = exists ;
function isDirectory ( fsPath , useStat = false ) {
return _ _awaiter ( this , void 0 , void 0 , function * ( ) {
const stats = useStat ? yield exports . stat ( fsPath ) : yield exports . lstat ( fsPath ) ;
return stats . isDirectory ( ) ;
} ) ;
}
exports . isDirectory = isDirectory ;
/ * *
* On OSX / Linux , true if path starts with '/' . On Windows , true for paths like :
* \ , \ hello , \ \ hello \ share , C : , and C : \ hello ( and corresponding alternate separator cases ) .
* /
function isRooted ( p ) {
p = normalizeSeparators ( p ) ;
if ( ! p ) {
throw new Error ( 'isRooted() parameter "p" cannot be empty' ) ;
}
if ( exports . IS _WINDOWS ) {
return ( p . startsWith ( '\\' ) || /^[A-Z]:/i . test ( p ) // e.g. \ or \hello or \\hello
) ; // e.g. C: or C:\hello
}
return p . startsWith ( '/' ) ;
}
exports . isRooted = isRooted ;
/ * *
* Recursively create a directory at ` fsPath ` .
*
* This implementation is optimistic , meaning it attempts to create the full
* path first , and backs up the path stack from there .
*
* @ param fsPath The path to create
* @ param maxDepth The maximum recursion depth
* @ param depth The current recursion depth
* /
function mkdirP ( fsPath , maxDepth = 1000 , depth = 1 ) {
return _ _awaiter ( this , void 0 , void 0 , function * ( ) {
assert _1 . ok ( fsPath , 'a path argument must be provided' ) ;
fsPath = path . resolve ( fsPath ) ;
if ( depth >= maxDepth )
return exports . mkdir ( fsPath ) ;
try {
yield exports . mkdir ( fsPath ) ;
return ;
}
catch ( err ) {
switch ( err . code ) {
case 'ENOENT' : {
yield mkdirP ( path . dirname ( fsPath ) , maxDepth , depth + 1 ) ;
yield exports . mkdir ( fsPath ) ;
return ;
}
default : {
let stats ;
try {
stats = yield exports . stat ( fsPath ) ;
}
catch ( err2 ) {
throw err ;
}
if ( ! stats . isDirectory ( ) )
throw err ;
}
}
}
} ) ;
}
exports . mkdirP = mkdirP ;
/ * *
* Best effort attempt to determine whether a file exists and is executable .
* @ param filePath file path to check
* @ param extensions additional file extensions to try
* @ return if file exists and is executable , returns the file path . otherwise empty string .
* /
function tryGetExecutablePath ( filePath , extensions ) {
return _ _awaiter ( this , void 0 , void 0 , function * ( ) {
let stats = undefined ;
try {
// test file exists
stats = yield exports . stat ( filePath ) ;
}
catch ( err ) {
if ( err . code !== 'ENOENT' ) {
// eslint-disable-next-line no-console
console . log ( ` Unexpected error attempting to determine if executable file exists ' ${ filePath } ': ${ err } ` ) ;
}
}
if ( stats && stats . isFile ( ) ) {
if ( exports . IS _WINDOWS ) {
// on Windows, test for valid extension
const upperExt = path . extname ( filePath ) . toUpperCase ( ) ;
if ( extensions . some ( validExt => validExt . toUpperCase ( ) === upperExt ) ) {
return filePath ;
}
}
else {
if ( isUnixExecutable ( stats ) ) {
return filePath ;
}
}
}
// try each extension
const originalFilePath = filePath ;
for ( const extension of extensions ) {
filePath = originalFilePath + extension ;
stats = undefined ;
try {
stats = yield exports . stat ( filePath ) ;
}
catch ( err ) {
if ( err . code !== 'ENOENT' ) {
// eslint-disable-next-line no-console
console . log ( ` Unexpected error attempting to determine if executable file exists ' ${ filePath } ': ${ err } ` ) ;
}
}
if ( stats && stats . isFile ( ) ) {
if ( exports . IS _WINDOWS ) {
// preserve the case of the actual file (since an extension was appended)
try {
const directory = path . dirname ( filePath ) ;
const upperName = path . basename ( filePath ) . toUpperCase ( ) ;
for ( const actualName of yield exports . readdir ( directory ) ) {
if ( upperName === actualName . toUpperCase ( ) ) {
filePath = path . join ( directory , actualName ) ;
break ;
}
}
}
catch ( err ) {
// eslint-disable-next-line no-console
console . log ( ` Unexpected error attempting to determine the actual case of the file ' ${ filePath } ': ${ err } ` ) ;
}
return filePath ;
}
else {
if ( isUnixExecutable ( stats ) ) {
return filePath ;
}
}
}
}
return '' ;
} ) ;
}
exports . tryGetExecutablePath = tryGetExecutablePath ;
function normalizeSeparators ( p ) {
p = p || '' ;
if ( exports . IS _WINDOWS ) {
// convert slashes on Windows
p = p . replace ( /\//g , '\\' ) ;
// remove redundant slashes
return p . replace ( /\\\\+/g , '\\' ) ;
}
// remove redundant slashes
return p . replace ( /\/\/+/g , '/' ) ;
}
// on Mac/Linux, test the execute bit
// R W X R W X R W X
// 256 128 64 32 16 8 4 2 1
function isUnixExecutable ( stats ) {
return ( ( stats . mode & 1 ) > 0 ||
( ( stats . mode & 8 ) > 0 && stats . gid === process . getgid ( ) ) ||
( ( stats . mode & 64 ) > 0 && stats . uid === process . getuid ( ) ) ) ;
}
//# sourceMappingURL=io-util.js.map
2019-11-24 06:44:53 +07:00
/***/ } ) ,
/***/ 747 :
/***/ ( function ( module ) {
module . exports = require ( "fs" ) ;
/***/ } ) ,
2020-07-07 18:06:32 +07:00
/***/ 835 :
/***/ ( function ( module ) {
module . exports = require ( "url" ) ;
/***/ } ) ,
2019-11-24 06:44:53 +07:00
/***/ 911 :
/***/ ( function ( _ _unusedmodule , exports , _ _webpack _require _ _ ) {
"use strict" ;
2020-05-13 23:18:11 +07:00
var _ _createBinding = ( this && this . _ _createBinding ) || ( Object . create ? ( function ( o , m , k , k2 ) {
if ( k2 === undefined ) k2 = k ;
Object . defineProperty ( o , k2 , { enumerable : true , get : function ( ) { return m [ k ] ; } } ) ;
} ) : ( function ( o , m , k , k2 ) {
if ( k2 === undefined ) k2 = k ;
o [ k2 ] = m [ k ] ;
} ) ) ;
var _ _setModuleDefault = ( this && this . _ _setModuleDefault ) || ( Object . create ? ( function ( o , v ) {
Object . defineProperty ( o , "default" , { enumerable : true , value : v } ) ;
} ) : function ( o , v ) {
o [ "default" ] = v ;
} ) ;
2019-11-24 06:44:53 +07:00
var _ _importStar = ( this && this . _ _importStar ) || function ( mod ) {
if ( mod && mod . _ _esModule ) return mod ;
var result = { } ;
2020-06-08 08:39:31 +07:00
if ( mod != null ) for ( var k in mod ) if ( k !== "default" && Object . hasOwnProperty . call ( mod , k ) ) _ _createBinding ( result , mod , k ) ;
2020-05-13 23:18:11 +07:00
_ _setModuleDefault ( result , mod ) ;
2019-11-24 06:44:53 +07:00
return result ;
} ;
Object . defineProperty ( exports , "__esModule" , { value : true } ) ;
2020-06-19 05:39:13 +07:00
exports . addExtension = exports . addExtensionLinux = exports . addExtensionWindows = exports . addExtensionDarwin = exports . getXdebugVersion = void 0 ;
2019-11-24 06:44:53 +07:00
const path = _ _importStar ( _ _webpack _require _ _ ( 622 ) ) ;
const utils = _ _importStar ( _ _webpack _require _ _ ( 163 ) ) ;
2020-06-19 05:39:13 +07:00
/ * *
* Function to get Xdebug version compatible with php versions
*
* @ param version
* /
async function getXdebugVersion ( version ) {
switch ( version ) {
case '5.3' :
return '2.2.7' ;
case '5.4' :
return '2.4.1' ;
case '5.5' :
return '2.5.5' ;
default :
return '2.9.6' ;
}
}
exports . getXdebugVersion = getXdebugVersion ;
2019-11-24 06:44:53 +07:00
/ * *
* Install and enable extensions for darwin
*
* @ param extension _csv
* @ param version
2019-12-26 20:01:18 +07:00
* @ param pipe
2019-11-24 06:44:53 +07:00
* /
2020-03-14 09:26:11 +07:00
async function addExtensionDarwin ( extension _csv , version , pipe ) {
const extensions = await utils . extensionArray ( extension _csv ) ;
let script = '\n' ;
await utils . asyncForEach ( extensions , async function ( extension ) {
const version _extension = version + extension ;
const [ extension _name , stability ] = extension . split ( '-' ) ;
const ext _prefix = await utils . getExtensionPrefix ( extension _name ) ;
const command _prefix = 'sudo pecl install -f ' ;
let command = '' ;
switch ( true ) {
// match pre-release versions
case /.*-(beta|alpha|devel|snapshot)/ . test ( version _extension ) :
script +=
'\nadd_unstable_extension ' +
extension _name +
' ' +
stability +
' ' +
ext _prefix ;
return ;
2020-07-03 16:36:42 +07:00
// match 5.6xdebug to 8.0xdebug, 5.6swoole to 8.0swoole
// match 5.6grpc to 7.4grpc, 5.6protobuf to 7.4protobuf
// match 7.1pcov to 8.0pcov
case /(5\.6|7\.[0-4]|8\.[0-9])(xdebug|swoole)/ . test ( version _extension ) :
case /(5\.6|7\.[0-4])(grpc|protobuf)/ . test ( version _extension ) :
2020-06-19 05:39:13 +07:00
case /(7\.[1-4]|8\.[0-9])pcov/ . test ( version _extension ) :
2020-07-03 16:36:42 +07:00
command = 'add_brew_extension ' + extension _name ;
2020-03-14 09:26:11 +07:00
break ;
// match 5.6redis
case /5\.6redis/ . test ( version _extension ) :
2020-06-19 05:39:13 +07:00
command = command _prefix + 'redis-2.2.8' ;
2020-03-14 09:26:11 +07:00
break ;
// match imagick
2020-03-16 08:08:50 +07:00
case /^imagick$/ . test ( extension ) :
2020-03-14 09:26:11 +07:00
command =
'brew install pkg-config imagemagick' +
pipe +
' && ' +
command _prefix +
'imagick' +
pipe ;
break ;
// match sqlite
2020-03-16 08:08:50 +07:00
case /^sqlite$/ . test ( extension ) :
2020-03-14 09:26:11 +07:00
extension = 'sqlite3' ;
2020-06-19 05:39:13 +07:00
command = command _prefix + extension ;
2020-03-14 09:26:11 +07:00
break ;
// match 7.0phalcon3...7.3phalcon3 and 7.2phalcon4...7.4phalcon4
case /^7\.[0-3]phalcon3$|^7\.[2-4]phalcon4$/ . test ( version _extension ) :
2019-11-24 06:44:53 +07:00
script +=
2020-05-13 23:18:11 +07:00
'\nbash ' +
2020-03-14 09:26:11 +07:00
path . join ( _ _dirname , '../src/scripts/ext/phalcon_darwin.sh' ) +
' ' +
2019-11-24 06:44:53 +07:00
extension +
2020-03-14 09:26:11 +07:00
' ' +
version ;
return ;
default :
2020-06-19 05:39:13 +07:00
command = command _prefix + extension ;
2020-03-14 09:26:11 +07:00
break ;
}
script +=
'\nadd_extension ' +
extension +
' "' +
command +
'" ' +
( await utils . getExtensionPrefix ( extension ) ) ;
2019-11-24 06:44:53 +07:00
} ) ;
2020-03-14 09:26:11 +07:00
return script ;
2019-11-24 06:44:53 +07:00
}
exports . addExtensionDarwin = addExtensionDarwin ;
/ * *
* Install and enable extensions for windows
*
* @ param extension _csv
* @ param version
* /
2020-03-14 09:26:11 +07:00
async function addExtensionWindows ( extension _csv , version ) {
const extensions = await utils . extensionArray ( extension _csv ) ;
let script = '\n' ;
await utils . asyncForEach ( extensions , async function ( extension ) {
const [ extension _name , stability ] = extension . split ( '-' ) ;
const version _extension = version + extension ;
switch ( true ) {
// match pre-release versions
case /.*-(beta|alpha|devel|snapshot)/ . test ( version _extension ) :
script += '\nAdd-Extension ' + extension _name + ' ' + stability ;
break ;
2020-03-16 08:08:50 +07:00
// match 5.6mysql, 5.6mysqli, 5.6mysqlnd
case /^5\.6(mysql|mysqli|mysqlnd)$/ . test ( version _extension ) :
script +=
'\nAdd-Extension mysql\nAdd-Extension mysqli\nAdd-Extension mysqlnd' ;
break ;
// match 7.0mysql..8.0mysql
// match 7.0mysqli..8.0mysqli
// match 7.0mysqlnd..8.0mysqlnd
case /[7-8]\.\d(mysql|mysqli|mysqlnd)$/ . test ( version _extension ) :
script += '\nAdd-Extension mysqli\nAdd-Extension mysqlnd' ;
break ;
2020-03-14 09:26:11 +07:00
// match sqlite
2020-03-16 08:08:50 +07:00
case /^sqlite$/ . test ( extension ) :
2020-03-14 09:26:11 +07:00
extension = 'sqlite3' ;
script += '\nAdd-Extension ' + extension ;
break ;
// match 7.0phalcon3...7.3phalcon3 and 7.2phalcon4...7.4phalcon4
case /^7\.[0-3]phalcon3$|^7\.[2-4]phalcon4$/ . test ( version _extension ) :
script +=
'\n& ' +
path . join ( _ _dirname , '../src/scripts/ext/phalcon.ps1' ) +
' ' +
extension +
' ' +
version +
'\n' ;
break ;
default :
script += '\nAdd-Extension ' + extension ;
break ;
}
2019-11-24 06:44:53 +07:00
} ) ;
2020-03-14 09:26:11 +07:00
return script ;
2019-11-24 06:44:53 +07:00
}
exports . addExtensionWindows = addExtensionWindows ;
/ * *
* Install and enable extensions for linux
*
* @ param extension _csv
* @ param version
2019-12-26 20:01:18 +07:00
* @ param pipe
2019-11-24 06:44:53 +07:00
* /
2020-03-14 09:26:11 +07:00
async function addExtensionLinux ( extension _csv , version , pipe ) {
const extensions = await utils . extensionArray ( extension _csv ) ;
let script = '\n' ;
await utils . asyncForEach ( extensions , async function ( extension ) {
const version _extension = version + extension ;
const [ extension _name , stability ] = extension . split ( '-' ) ;
const ext _prefix = await utils . getExtensionPrefix ( extension _name ) ;
const command _prefix = 'sudo $debconf_fix apt-get install -y php' ;
let command = '' ;
switch ( true ) {
// match pre-release versions
case /.*-(beta|alpha|devel|snapshot)/ . test ( version _extension ) :
2019-11-24 06:44:53 +07:00
script +=
2020-03-14 09:26:11 +07:00
'\nadd_unstable_extension ' +
extension _name +
' ' +
stability +
' ' +
ext _prefix ;
return ;
// match 5.6gearman..7.4gearman
case /^((5\.6)|(7\.[0-4]))gearman$/ . test ( version _extension ) :
command =
2020-05-13 23:18:11 +07:00
'\nbash ' +
2020-03-14 09:26:11 +07:00
path . join ( _ _dirname , '../src/scripts/ext/gearman.sh' ) +
' ' +
version +
pipe ;
break ;
// match 7.0phalcon3...7.3phalcon3 or 7.2phalcon4...7.4phalcon4
case /^7\.[0-3]phalcon3$|^7\.[2-4]phalcon4$/ . test ( version _extension ) :
script +=
2020-05-13 23:18:11 +07:00
'\nbash ' +
2020-03-14 09:26:11 +07:00
path . join ( _ _dirname , '../src/scripts/ext/phalcon.sh' ) +
' ' +
extension +
' ' +
version ;
return ;
// match 7.0xdebug..7.4xdebug
case /^7\.[0-4]xdebug$/ . test ( version _extension ) :
script +=
'\nupdate_extension xdebug 2.9.2' +
pipe +
'\n' +
( await utils . addLog ( '$tick' , 'xdebug' , 'Enabled' , 'linux' ) ) ;
return ;
2020-03-16 08:08:50 +07:00
// match sqlite
case /^sqlite$/ . test ( extension ) :
2020-03-14 09:26:11 +07:00
extension = 'sqlite3' ;
command = command _prefix + version + '-' + extension + pipe ;
break ;
default :
command =
command _prefix +
version +
'-' +
extension . replace ( 'pdo_' , '' ) . replace ( 'pdo-' , '' ) +
pipe ;
break ;
}
script +=
'\nadd_extension ' + extension + ' "' + command + '" ' + ext _prefix ;
2019-11-24 06:44:53 +07:00
} ) ;
2020-03-14 09:26:11 +07:00
return script ;
2019-11-24 06:44:53 +07:00
}
exports . addExtensionLinux = addExtensionLinux ;
/ * *
* Install and enable extensions
*
* @ param extension _csv
* @ param version
* @ param os _version
2020-03-14 09:12:02 +07:00
* @ param no _step
2019-11-24 06:44:53 +07:00
* /
2020-03-14 09:26:11 +07:00
async function addExtension ( extension _csv , version , os _version , no _step = false ) {
const pipe = await utils . suppressOutput ( os _version ) ;
let script = '\n' ;
switch ( no _step ) {
case true :
script += ( await utils . stepLog ( 'Setup Extensions' , os _version ) ) + pipe ;
break ;
case false :
default :
script += await utils . stepLog ( 'Setup Extensions' , os _version ) ;
break ;
}
switch ( os _version ) {
case 'win32' :
return script + ( await addExtensionWindows ( extension _csv , version ) ) ;
case 'darwin' :
return script + ( await addExtensionDarwin ( extension _csv , version , pipe ) ) ;
case 'linux' :
return script + ( await addExtensionLinux ( extension _csv , version , pipe ) ) ;
default :
return await utils . log ( 'Platform ' + os _version + ' is not supported' , os _version , 'error' ) ;
}
2019-11-24 06:44:53 +07:00
}
exports . addExtension = addExtension ;
2020-07-07 18:06:32 +07:00
/***/ } ) ,
/***/ 950 :
/***/ ( function ( _ _unusedmodule , exports , _ _webpack _require _ _ ) {
"use strict" ;
Object . defineProperty ( exports , "__esModule" , { value : true } ) ;
const url = _ _webpack _require _ _ ( 835 ) ;
function getProxyUrl ( reqUrl ) {
let usingSsl = reqUrl . protocol === 'https:' ;
let proxyUrl ;
if ( checkBypass ( reqUrl ) ) {
return proxyUrl ;
}
let proxyVar ;
if ( usingSsl ) {
proxyVar = process . env [ 'https_proxy' ] || process . env [ 'HTTPS_PROXY' ] ;
}
else {
proxyVar = process . env [ 'http_proxy' ] || process . env [ 'HTTP_PROXY' ] ;
}
if ( proxyVar ) {
proxyUrl = url . parse ( proxyVar ) ;
}
return proxyUrl ;
}
exports . getProxyUrl = getProxyUrl ;
function checkBypass ( reqUrl ) {
if ( ! reqUrl . hostname ) {
return false ;
}
let noProxy = process . env [ 'no_proxy' ] || process . env [ 'NO_PROXY' ] || '' ;
if ( ! noProxy ) {
return false ;
}
// Determine the request port
let reqPort ;
if ( reqUrl . port ) {
reqPort = Number ( reqUrl . port ) ;
}
else if ( reqUrl . protocol === 'http:' ) {
reqPort = 80 ;
}
else if ( reqUrl . protocol === 'https:' ) {
reqPort = 443 ;
}
// Format the request hostname and hostname with port
let upperReqHosts = [ reqUrl . hostname . toUpperCase ( ) ] ;
if ( typeof reqPort === 'number' ) {
upperReqHosts . push ( ` ${ upperReqHosts [ 0 ] } : ${ reqPort } ` ) ;
}
// Compare request host against noproxy
for ( let upperNoProxyItem of noProxy
. split ( ',' )
. map ( x => x . trim ( ) . toUpperCase ( ) )
. filter ( x => x ) ) {
if ( upperReqHosts . some ( x => x === upperNoProxyItem ) ) {
return true ;
}
}
return false ;
}
exports . checkBypass = checkBypass ;
2019-11-24 06:44:53 +07:00
/***/ } ) ,
/***/ 986 :
/***/ ( function ( _ _unusedmodule , exports , _ _webpack _require _ _ ) {
"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 ) : adopt ( result . value ) . then ( fulfilled , rejected ) ; }
step ( ( generator = generator . apply ( thisArg , _arguments || [ ] ) ) . next ( ) ) ;
} ) ;
} ;
2020-05-13 23:18:11 +07:00
var _ _importStar = ( this && this . _ _importStar ) || function ( mod ) {
if ( mod && mod . _ _esModule ) return mod ;
var result = { } ;
if ( mod != null ) for ( var k in mod ) if ( Object . hasOwnProperty . call ( mod , k ) ) result [ k ] = mod [ k ] ;
result [ "default" ] = mod ;
return result ;
} ;
2019-11-24 06:44:53 +07:00
Object . defineProperty ( exports , "__esModule" , { value : true } ) ;
2020-05-13 23:18:11 +07:00
const tr = _ _importStar ( _ _webpack _require _ _ ( 9 ) ) ;
2019-11-24 06:44:53 +07:00
/ * *
* Exec a command .
* Output will be streamed to the live console .
* Returns promise with return code
*
* @ param commandLine command to execute ( can include additional args ) . Must be correctly escaped .
* @ param args optional arguments for tool . Escaping is handled by the lib .
* @ param options optional exec options . See ExecOptions
* @ returns Promise < number > exit code
* /
function exec ( commandLine , args , options ) {
return _ _awaiter ( this , void 0 , void 0 , function * ( ) {
const commandArgs = tr . argStringToArray ( commandLine ) ;
if ( commandArgs . length === 0 ) {
throw new Error ( ` Parameter 'commandLine' cannot be null or empty. ` ) ;
}
// Path to tool to execute should be first arg
const toolPath = commandArgs [ 0 ] ;
args = commandArgs . slice ( 1 ) . concat ( args || [ ] ) ;
const runner = new tr . ToolRunner ( toolPath , args , options ) ;
return runner . exec ( ) ;
} ) ;
}
exports . exec = exec ;
//# sourceMappingURL=exec.js.map
/***/ } )
/******/ } ) ;