mirror of
https://github.com/nick-fields/retry.git
synced 2026-02-10 07:05:29 +00:00
Compare commits
7 Commits
anthonyc/m
...
snyk-fix-b
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
24c7db625d | ||
|
|
b4fa57557d | ||
|
|
616fa81820 | ||
|
|
a25f198007 | ||
|
|
0f986c438b | ||
|
|
3dad7de805 | ||
|
|
14b6b46d04 |
1
.config/.eslintignore
Normal file
1
.config/.eslintignore
Normal file
@@ -0,0 +1 @@
|
|||||||
|
.eslintrc.js
|
||||||
7
.config/.eslintrc.js
Normal file
7
.config/.eslintrc.js
Normal file
@@ -0,0 +1,7 @@
|
|||||||
|
module.exports = {
|
||||||
|
root: true,
|
||||||
|
parser: '@typescript-eslint/parser',
|
||||||
|
plugins: ['@typescript-eslint'],
|
||||||
|
extends: ['eslint:recommended', 'plugin:@typescript-eslint/recommended', 'prettier'],
|
||||||
|
ignorePatterns: ['**/*.js', 'dist/'],
|
||||||
|
};
|
||||||
2
.config/.prettierignore
Normal file
2
.config/.prettierignore
Normal file
@@ -0,0 +1,2 @@
|
|||||||
|
dist/
|
||||||
|
node_modules/
|
||||||
5
.config/.prettierrc.yml
Normal file
5
.config/.prettierrc.yml
Normal file
@@ -0,0 +1,5 @@
|
|||||||
|
trailingComma: 'es5'
|
||||||
|
tabWidth: 2
|
||||||
|
semi: true
|
||||||
|
singleQuote: true
|
||||||
|
printWidth: 100
|
||||||
13
.config/jest.config.js
Normal file
13
.config/jest.config.js
Normal file
@@ -0,0 +1,13 @@
|
|||||||
|
module.exports = {
|
||||||
|
clearMocks: true,
|
||||||
|
moduleFileExtensions: ['js', 'ts'],
|
||||||
|
rootDir: '..',
|
||||||
|
testEnvironment: 'node',
|
||||||
|
testMatch: ['<rootDir>/src/**/*.test.ts'],
|
||||||
|
transform: {
|
||||||
|
'^.+\\.ts$': 'ts-jest',
|
||||||
|
},
|
||||||
|
verbose: true,
|
||||||
|
collectCoverage: true,
|
||||||
|
collectCoverageFrom: ['src/**/*.{js,ts,jsx,tsx}'],
|
||||||
|
};
|
||||||
1
.github/ISSUE_TEMPLATE/bug-report.md
vendored
1
.github/ISSUE_TEMPLATE/bug-report.md
vendored
@@ -4,7 +4,6 @@ about: Create a report to help us improve
|
|||||||
title: ''
|
title: ''
|
||||||
labels: ''
|
labels: ''
|
||||||
assignees: nick-invision
|
assignees: nick-invision
|
||||||
|
|
||||||
---
|
---
|
||||||
|
|
||||||
**Describe the bug**
|
**Describe the bug**
|
||||||
|
|||||||
12
.github/codecov.yml
vendored
Normal file
12
.github/codecov.yml
vendored
Normal file
@@ -0,0 +1,12 @@
|
|||||||
|
# see https://docs.codecov.com/docs/codecovyml-reference
|
||||||
|
codecov:
|
||||||
|
require_ci_to_pass: false
|
||||||
|
comment:
|
||||||
|
layout: 'diff, flags'
|
||||||
|
behavior: default
|
||||||
|
require_changes: true
|
||||||
|
coverage:
|
||||||
|
# don't pass/fail PRs for coverage yet
|
||||||
|
status:
|
||||||
|
project: off
|
||||||
|
patch: off
|
||||||
612
.github/workflows/ci_cd.yml
vendored
612
.github/workflows/ci_cd.yml
vendored
@@ -4,10 +4,30 @@ on:
|
|||||||
|
|
||||||
jobs:
|
jobs:
|
||||||
# runs on branch pushes only
|
# runs on branch pushes only
|
||||||
ci:
|
ci_unit:
|
||||||
name: Run Tests
|
name: Run Unit Tests
|
||||||
if: startsWith(github.ref, 'refs/heads')
|
if: startsWith(github.ref, 'refs/heads')
|
||||||
runs-on: ubuntu-18.04
|
runs-on: ubuntu-latest
|
||||||
|
steps:
|
||||||
|
- name: Checkout
|
||||||
|
uses: actions/checkout@v2
|
||||||
|
- name: Setup Node.js
|
||||||
|
uses: actions/setup-node@v1
|
||||||
|
with:
|
||||||
|
node-version: 16
|
||||||
|
- name: Install dependencies
|
||||||
|
run: npm ci
|
||||||
|
- name: Run Unit Tests
|
||||||
|
run: npm test
|
||||||
|
- uses: codecov/codecov-action@v3
|
||||||
|
with:
|
||||||
|
directory: ./coverage/
|
||||||
|
verbose: true
|
||||||
|
|
||||||
|
ci_integration:
|
||||||
|
name: Run Integration Tests
|
||||||
|
if: startsWith(github.ref, 'refs/heads')
|
||||||
|
runs-on: ubuntu-latest
|
||||||
steps:
|
steps:
|
||||||
- name: Checkout
|
- name: Checkout
|
||||||
uses: actions/checkout@v2
|
uses: actions/checkout@v2
|
||||||
@@ -36,94 +56,6 @@ jobs:
|
|||||||
command: node ./.github/scripts/log-examples.js
|
command: node ./.github/scripts/log-examples.js
|
||||||
timeout_minutes: 1
|
timeout_minutes: 1
|
||||||
|
|
||||||
- name: sad-path (retry_wait_seconds)
|
|
||||||
id: sad_path_wait_sec
|
|
||||||
uses: ./
|
|
||||||
continue-on-error: true
|
|
||||||
with:
|
|
||||||
timeout_minutes: 1
|
|
||||||
max_attempts: 3
|
|
||||||
retry_wait_seconds: 15
|
|
||||||
command: npm install this-isnt-a-real-package-name-zzz
|
|
||||||
- uses: nick-invision/assert-action@v1
|
|
||||||
with:
|
|
||||||
expected: 3
|
|
||||||
actual: ${{ steps.sad_path_wait_sec.outputs.total_attempts }}
|
|
||||||
- uses: nick-invision/assert-action@v1
|
|
||||||
with:
|
|
||||||
expected: failure
|
|
||||||
actual: ${{ steps.sad_path_wait_sec.outcome }}
|
|
||||||
- uses: nick-invision/assert-action@v1
|
|
||||||
with:
|
|
||||||
expected: 'Final attempt failed'
|
|
||||||
actual: ${{ steps.sad_path_wait_sec.outputs.exit_error }}
|
|
||||||
comparison: contains
|
|
||||||
|
|
||||||
- name: new-command-on-retry
|
|
||||||
id: new-command-on-retry
|
|
||||||
uses: ./
|
|
||||||
with:
|
|
||||||
timeout_minutes: 1
|
|
||||||
max_attempts: 3
|
|
||||||
command: node -e "process.exit(1)"
|
|
||||||
new_command_on_retry: node -e "console.log('this is the new command on retry')"
|
|
||||||
|
|
||||||
- name: on-retry-cmd
|
|
||||||
id: on-retry-cmd
|
|
||||||
uses: ./
|
|
||||||
continue-on-error: true
|
|
||||||
with:
|
|
||||||
timeout_minutes: 1
|
|
||||||
max_attempts: 3
|
|
||||||
command: node -e "process.exit(1)"
|
|
||||||
on_retry_command: node -e "console.log('this is a retry command')"
|
|
||||||
|
|
||||||
- name: retry_on_exit_code (with expected error code)
|
|
||||||
id: retry_on_exit_code_expected
|
|
||||||
uses: ./
|
|
||||||
continue-on-error: true
|
|
||||||
with:
|
|
||||||
timeout_minutes: 1
|
|
||||||
retry_on_exit_code: 2
|
|
||||||
max_attempts: 3
|
|
||||||
command: node -e "process.exit(2)"
|
|
||||||
- uses: nick-invision/assert-action@v1
|
|
||||||
with:
|
|
||||||
expected: failure
|
|
||||||
actual: ${{ steps.retry_on_exit_code_expected.outcome }}
|
|
||||||
- uses: nick-invision/assert-action@v1
|
|
||||||
with:
|
|
||||||
expected: 3
|
|
||||||
actual: ${{ steps.retry_on_exit_code_expected.outputs.total_attempts }}
|
|
||||||
|
|
||||||
- name: retry_on_exit_code (with unexpected error code)
|
|
||||||
id: retry_on_exit_code_unexpected
|
|
||||||
uses: ./
|
|
||||||
continue-on-error: true
|
|
||||||
with:
|
|
||||||
timeout_minutes: 1
|
|
||||||
retry_on_exit_code: 2
|
|
||||||
max_attempts: 3
|
|
||||||
command: node -e "process.exit(1)"
|
|
||||||
- uses: nick-invision/assert-action@v1
|
|
||||||
with:
|
|
||||||
expected: failure
|
|
||||||
actual: ${{ steps.retry_on_exit_code_unexpected.outcome }}
|
|
||||||
- uses: nick-invision/assert-action@v1
|
|
||||||
with:
|
|
||||||
expected: 1
|
|
||||||
actual: ${{ steps.retry_on_exit_code_unexpected.outputs.total_attempts }}
|
|
||||||
|
|
||||||
- name: on-retry-cmd (on-retry fails)
|
|
||||||
id: on-retry-cmd-fails
|
|
||||||
uses: ./
|
|
||||||
continue-on-error: true
|
|
||||||
with:
|
|
||||||
timeout_minutes: 1
|
|
||||||
max_attempts: 3
|
|
||||||
command: node -e "process.exit(1)"
|
|
||||||
on_retry_command: node -e "throw new Error('This is an on-retry command error')"
|
|
||||||
|
|
||||||
- name: sad-path (error)
|
- name: sad-path (error)
|
||||||
id: sad_path_error
|
id: sad_path_error
|
||||||
uses: ./
|
uses: ./
|
||||||
@@ -141,41 +73,6 @@ jobs:
|
|||||||
expected: failure
|
expected: failure
|
||||||
actual: ${{ steps.sad_path_error.outcome }}
|
actual: ${{ steps.sad_path_error.outcome }}
|
||||||
|
|
||||||
- name: happy-path (continue_on_error)
|
|
||||||
id: happy_path_continue_on_error
|
|
||||||
uses: ./
|
|
||||||
with:
|
|
||||||
command: node -e "process.exit(0)"
|
|
||||||
timeout_minutes: 1
|
|
||||||
continue_on_error: true
|
|
||||||
- name: sad-path (continue_on_error)
|
|
||||||
id: sad_path_continue_on_error
|
|
||||||
uses: ./
|
|
||||||
with:
|
|
||||||
command: node -e "process.exit(33)"
|
|
||||||
timeout_minutes: 1
|
|
||||||
continue_on_error: true
|
|
||||||
- name: Verify continue_on_error returns correct exit code on success
|
|
||||||
uses: nick-invision/assert-action@v1
|
|
||||||
with:
|
|
||||||
expected: 0
|
|
||||||
actual: ${{ steps.happy_path_continue_on_error.outputs.exit_code }}
|
|
||||||
- name: Verify continue_on_error exits with correct outcome on success
|
|
||||||
uses: nick-invision/assert-action@v1
|
|
||||||
with:
|
|
||||||
expected: success
|
|
||||||
actual: ${{ steps.happy_path_continue_on_error.outcome }}
|
|
||||||
- name: Verify continue_on_error returns correct exit code on error
|
|
||||||
uses: nick-invision/assert-action@v1
|
|
||||||
with:
|
|
||||||
expected: 33
|
|
||||||
actual: ${{ steps.sad_path_continue_on_error.outputs.exit_code }}
|
|
||||||
- name: Verify continue_on_error exits with successful outcome when an error occurs
|
|
||||||
uses: nick-invision/assert-action@v1
|
|
||||||
with:
|
|
||||||
expected: success
|
|
||||||
actual: ${{ steps.sad_path_continue_on_error.outcome }}
|
|
||||||
|
|
||||||
- name: retry_on (timeout) fails early if error encountered
|
- name: retry_on (timeout) fails early if error encountered
|
||||||
id: retry_on_timeout_fail
|
id: retry_on_timeout_fail
|
||||||
uses: ./
|
uses: ./
|
||||||
@@ -220,7 +117,270 @@ jobs:
|
|||||||
expected: 2
|
expected: 2
|
||||||
actual: ${{ steps.retry_on_error.outputs.exit_code }}
|
actual: ${{ steps.retry_on_error.outputs.exit_code }}
|
||||||
|
|
||||||
# timeout tests (takes longer to run so run last)
|
- name: sad-path (wrong shell for OS)
|
||||||
|
id: wrong_shell
|
||||||
|
uses: ./
|
||||||
|
continue-on-error: true
|
||||||
|
with:
|
||||||
|
timeout_minutes: 1
|
||||||
|
max_attempts: 2
|
||||||
|
shell: cmd
|
||||||
|
command: 'dir'
|
||||||
|
- uses: nick-invision/assert-action@v1
|
||||||
|
with:
|
||||||
|
expected: 2
|
||||||
|
actual: ${{ steps.wrong_shell.outputs.total_attempts }}
|
||||||
|
- uses: nick-invision/assert-action@v1
|
||||||
|
with:
|
||||||
|
expected: failure
|
||||||
|
actual: ${{ steps.wrong_shell.outcome }}
|
||||||
|
|
||||||
|
ci_integration_envvar:
|
||||||
|
name: Run Integration Env Var Tests
|
||||||
|
if: startsWith(github.ref, 'refs/heads')
|
||||||
|
runs-on: ubuntu-latest
|
||||||
|
steps:
|
||||||
|
- name: Checkout
|
||||||
|
uses: actions/checkout@v2
|
||||||
|
- name: Setup Node.js
|
||||||
|
uses: actions/setup-node@v1
|
||||||
|
with:
|
||||||
|
node-version: 16
|
||||||
|
- name: Install dependencies
|
||||||
|
run: npm ci
|
||||||
|
- name: env-vars-passed-through
|
||||||
|
uses: ./
|
||||||
|
env:
|
||||||
|
NODE_OPTIONS: '--max_old_space_size=3072'
|
||||||
|
with:
|
||||||
|
timeout_minutes: 1
|
||||||
|
max_attempts: 2
|
||||||
|
command: node -e 'console.log(process.env.NODE_OPTIONS)'
|
||||||
|
|
||||||
|
ci_integration_large_output:
|
||||||
|
name: Run Integration Large Output Tests
|
||||||
|
if: startsWith(github.ref, 'refs/heads')
|
||||||
|
runs-on: ubuntu-latest
|
||||||
|
steps:
|
||||||
|
- name: Checkout
|
||||||
|
uses: actions/checkout@v2
|
||||||
|
- name: Setup Node.js
|
||||||
|
uses: actions/setup-node@v1
|
||||||
|
with:
|
||||||
|
node-version: 16
|
||||||
|
- name: Install dependencies
|
||||||
|
run: npm ci
|
||||||
|
- name: Test 100MiB of output can be processed
|
||||||
|
id: large-output
|
||||||
|
continue-on-error: true
|
||||||
|
uses: ./
|
||||||
|
with:
|
||||||
|
max_attempts: 1
|
||||||
|
timeout_minutes: 5
|
||||||
|
command: 'make -C ./test-data/large-output bytes-102400'
|
||||||
|
- name: Assert test had expected result
|
||||||
|
uses: nick-invision/assert-action@v1
|
||||||
|
with:
|
||||||
|
expected: failure
|
||||||
|
actual: ${{ steps.large-output.outcome }}
|
||||||
|
- name: Assert exit code is expected
|
||||||
|
uses: nick-invision/assert-action@v1
|
||||||
|
with:
|
||||||
|
expected: 2
|
||||||
|
actual: ${{ steps.large-output.outputs.exit_code }}
|
||||||
|
|
||||||
|
ci_integration_retry_on_exit_code:
|
||||||
|
name: Run Integration retry_on_exit_code Tests
|
||||||
|
if: startsWith(github.ref, 'refs/heads')
|
||||||
|
runs-on: ubuntu-latest
|
||||||
|
steps:
|
||||||
|
- name: Checkout
|
||||||
|
uses: actions/checkout@v2
|
||||||
|
- name: Setup Node.js
|
||||||
|
uses: actions/setup-node@v1
|
||||||
|
with:
|
||||||
|
node-version: 16
|
||||||
|
- name: Install dependencies
|
||||||
|
run: npm ci
|
||||||
|
- name: retry_on_exit_code (with expected error code)
|
||||||
|
id: retry_on_exit_code_expected
|
||||||
|
uses: ./
|
||||||
|
continue-on-error: true
|
||||||
|
with:
|
||||||
|
timeout_minutes: 1
|
||||||
|
retry_on_exit_code: 2
|
||||||
|
max_attempts: 3
|
||||||
|
command: node -e "process.exit(2)"
|
||||||
|
- uses: nick-invision/assert-action@v1
|
||||||
|
with:
|
||||||
|
expected: failure
|
||||||
|
actual: ${{ steps.retry_on_exit_code_expected.outcome }}
|
||||||
|
- uses: nick-invision/assert-action@v1
|
||||||
|
with:
|
||||||
|
expected: 3
|
||||||
|
actual: ${{ steps.retry_on_exit_code_expected.outputs.total_attempts }}
|
||||||
|
|
||||||
|
- name: retry_on_exit_code (with unexpected error code)
|
||||||
|
id: retry_on_exit_code_unexpected
|
||||||
|
uses: ./
|
||||||
|
continue-on-error: true
|
||||||
|
with:
|
||||||
|
timeout_minutes: 1
|
||||||
|
retry_on_exit_code: 2
|
||||||
|
max_attempts: 3
|
||||||
|
command: node -e "process.exit(1)"
|
||||||
|
- uses: nick-invision/assert-action@v1
|
||||||
|
with:
|
||||||
|
expected: failure
|
||||||
|
actual: ${{ steps.retry_on_exit_code_unexpected.outcome }}
|
||||||
|
- uses: nick-invision/assert-action@v1
|
||||||
|
with:
|
||||||
|
expected: 1
|
||||||
|
actual: ${{ steps.retry_on_exit_code_unexpected.outputs.total_attempts }}
|
||||||
|
|
||||||
|
ci_integration_continue_on_error:
|
||||||
|
name: Run Integration continue_on_error Tests
|
||||||
|
if: startsWith(github.ref, 'refs/heads')
|
||||||
|
runs-on: ubuntu-latest
|
||||||
|
steps:
|
||||||
|
- name: Checkout
|
||||||
|
uses: actions/checkout@v2
|
||||||
|
- name: Setup Node.js
|
||||||
|
uses: actions/setup-node@v1
|
||||||
|
with:
|
||||||
|
node-version: 16
|
||||||
|
- name: Install dependencies
|
||||||
|
run: npm ci
|
||||||
|
- name: happy-path (continue_on_error)
|
||||||
|
id: happy_path_continue_on_error
|
||||||
|
uses: ./
|
||||||
|
with:
|
||||||
|
command: node -e "process.exit(0)"
|
||||||
|
timeout_minutes: 1
|
||||||
|
continue_on_error: true
|
||||||
|
- name: sad-path (continue_on_error)
|
||||||
|
id: sad_path_continue_on_error
|
||||||
|
uses: ./
|
||||||
|
with:
|
||||||
|
command: node -e "process.exit(33)"
|
||||||
|
timeout_minutes: 1
|
||||||
|
continue_on_error: true
|
||||||
|
- name: Verify continue_on_error returns correct exit code on success
|
||||||
|
uses: nick-invision/assert-action@v1
|
||||||
|
with:
|
||||||
|
expected: 0
|
||||||
|
actual: ${{ steps.happy_path_continue_on_error.outputs.exit_code }}
|
||||||
|
- name: Verify continue_on_error exits with correct outcome on success
|
||||||
|
uses: nick-invision/assert-action@v1
|
||||||
|
with:
|
||||||
|
expected: success
|
||||||
|
actual: ${{ steps.happy_path_continue_on_error.outcome }}
|
||||||
|
- name: Verify continue_on_error returns correct exit code on error
|
||||||
|
uses: nick-invision/assert-action@v1
|
||||||
|
with:
|
||||||
|
expected: 33
|
||||||
|
actual: ${{ steps.sad_path_continue_on_error.outputs.exit_code }}
|
||||||
|
- name: Verify continue_on_error exits with successful outcome when an error occurs
|
||||||
|
uses: nick-invision/assert-action@v1
|
||||||
|
with:
|
||||||
|
expected: success
|
||||||
|
actual: ${{ steps.sad_path_continue_on_error.outcome }}
|
||||||
|
|
||||||
|
ci_integration_retry_wait_seconds:
|
||||||
|
name: Run Integration Tests (retry_wait_seconds)
|
||||||
|
if: startsWith(github.ref, 'refs/heads')
|
||||||
|
runs-on: ubuntu-latest
|
||||||
|
steps:
|
||||||
|
- name: Checkout
|
||||||
|
uses: actions/checkout@v2
|
||||||
|
- name: Setup Node.js
|
||||||
|
uses: actions/setup-node@v1
|
||||||
|
with:
|
||||||
|
node-version: 16
|
||||||
|
- name: Install dependencies
|
||||||
|
run: npm ci
|
||||||
|
|
||||||
|
- name: sad-path (retry_wait_seconds)
|
||||||
|
id: sad_path_wait_sec
|
||||||
|
uses: ./
|
||||||
|
continue-on-error: true
|
||||||
|
with:
|
||||||
|
timeout_minutes: 1
|
||||||
|
max_attempts: 3
|
||||||
|
retry_wait_seconds: 15
|
||||||
|
command: npm install this-isnt-a-real-package-name-zzz
|
||||||
|
- uses: nick-invision/assert-action@v1
|
||||||
|
with:
|
||||||
|
expected: 3
|
||||||
|
actual: ${{ steps.sad_path_wait_sec.outputs.total_attempts }}
|
||||||
|
- uses: nick-invision/assert-action@v1
|
||||||
|
with:
|
||||||
|
expected: failure
|
||||||
|
actual: ${{ steps.sad_path_wait_sec.outcome }}
|
||||||
|
- uses: nick-invision/assert-action@v1
|
||||||
|
with:
|
||||||
|
expected: 'Final attempt failed'
|
||||||
|
actual: ${{ steps.sad_path_wait_sec.outputs.exit_error }}
|
||||||
|
comparison: contains
|
||||||
|
|
||||||
|
ci_integration_on_retry_cmd:
|
||||||
|
name: Run Integration Tests (on_retry_command)
|
||||||
|
if: startsWith(github.ref, 'refs/heads')
|
||||||
|
runs-on: ubuntu-latest
|
||||||
|
steps:
|
||||||
|
- name: Checkout
|
||||||
|
uses: actions/checkout@v2
|
||||||
|
- name: Setup Node.js
|
||||||
|
uses: actions/setup-node@v1
|
||||||
|
with:
|
||||||
|
node-version: 16
|
||||||
|
- name: Install dependencies
|
||||||
|
run: npm ci
|
||||||
|
|
||||||
|
- name: new-command-on-retry
|
||||||
|
id: new-command-on-retry
|
||||||
|
uses: ./
|
||||||
|
with:
|
||||||
|
timeout_minutes: 1
|
||||||
|
max_attempts: 3
|
||||||
|
command: node -e "process.exit(1)"
|
||||||
|
new_command_on_retry: node -e "console.log('this is the new command on retry')"
|
||||||
|
|
||||||
|
- name: on-retry-cmd
|
||||||
|
id: on-retry-cmd
|
||||||
|
uses: ./
|
||||||
|
continue-on-error: true
|
||||||
|
with:
|
||||||
|
timeout_minutes: 1
|
||||||
|
max_attempts: 3
|
||||||
|
command: node -e "process.exit(1)"
|
||||||
|
on_retry_command: node -e "console.log('this is a retry command')"
|
||||||
|
|
||||||
|
- name: on-retry-cmd (on-retry fails)
|
||||||
|
id: on-retry-cmd-fails
|
||||||
|
uses: ./
|
||||||
|
continue-on-error: true
|
||||||
|
with:
|
||||||
|
timeout_minutes: 1
|
||||||
|
max_attempts: 3
|
||||||
|
command: node -e "process.exit(1)"
|
||||||
|
on_retry_command: node -e "throw new Error('This is an on-retry command error')"
|
||||||
|
|
||||||
|
# timeout tests take longer to run so run in parallel
|
||||||
|
ci_integration_timeout_seconds:
|
||||||
|
name: Run Integration Timeout Tests (seconds)
|
||||||
|
if: startsWith(github.ref, 'refs/heads')
|
||||||
|
runs-on: ubuntu-latest
|
||||||
|
steps:
|
||||||
|
- name: Checkout
|
||||||
|
uses: actions/checkout@v2
|
||||||
|
- name: Setup Node.js
|
||||||
|
uses: actions/setup-node@v1
|
||||||
|
with:
|
||||||
|
node-version: 16
|
||||||
|
- name: Install dependencies
|
||||||
|
run: npm ci
|
||||||
|
|
||||||
- name: sad-path (timeout)
|
- name: sad-path (timeout)
|
||||||
id: sad_path_timeout
|
id: sad_path_timeout
|
||||||
uses: ./
|
uses: ./
|
||||||
@@ -238,6 +398,20 @@ jobs:
|
|||||||
expected: failure
|
expected: failure
|
||||||
actual: ${{ steps.sad_path_timeout.outcome }}
|
actual: ${{ steps.sad_path_timeout.outcome }}
|
||||||
|
|
||||||
|
ci_integration_timeout_retry_on_timeout:
|
||||||
|
name: Run Integration Timeout Tests (retry_on timeout)
|
||||||
|
if: startsWith(github.ref, 'refs/heads')
|
||||||
|
runs-on: ubuntu-latest
|
||||||
|
steps:
|
||||||
|
- name: Checkout
|
||||||
|
uses: actions/checkout@v2
|
||||||
|
- name: Setup Node.js
|
||||||
|
uses: actions/setup-node@v1
|
||||||
|
with:
|
||||||
|
node-version: 16
|
||||||
|
- name: Install dependencies
|
||||||
|
run: npm ci
|
||||||
|
|
||||||
- name: retry_on (timeout)
|
- name: retry_on (timeout)
|
||||||
id: retry_on_timeout
|
id: retry_on_timeout
|
||||||
uses: ./
|
uses: ./
|
||||||
@@ -256,6 +430,20 @@ jobs:
|
|||||||
expected: failure
|
expected: failure
|
||||||
actual: ${{ steps.retry_on_timeout.outcome }}
|
actual: ${{ steps.retry_on_timeout.outcome }}
|
||||||
|
|
||||||
|
ci_integration_timeout_retry_on_error:
|
||||||
|
name: Run Integration Timeout Tests (retry_on error)
|
||||||
|
if: startsWith(github.ref, 'refs/heads')
|
||||||
|
runs-on: ubuntu-latest
|
||||||
|
steps:
|
||||||
|
- name: Checkout
|
||||||
|
uses: actions/checkout@v2
|
||||||
|
- name: Setup Node.js
|
||||||
|
uses: actions/setup-node@v1
|
||||||
|
with:
|
||||||
|
node-version: 16
|
||||||
|
- name: Install dependencies
|
||||||
|
run: npm ci
|
||||||
|
|
||||||
- name: retry_on (error) fails early if timeout encountered
|
- name: retry_on (error) fails early if timeout encountered
|
||||||
id: retry_on_error_fail
|
id: retry_on_error_fail
|
||||||
uses: ./
|
uses: ./
|
||||||
@@ -278,6 +466,20 @@ jobs:
|
|||||||
expected: 1
|
expected: 1
|
||||||
actual: ${{ steps.retry_on_error_fail.outputs.exit_code }}
|
actual: ${{ steps.retry_on_error_fail.outputs.exit_code }}
|
||||||
|
|
||||||
|
ci_integration_timeout_minutes:
|
||||||
|
name: Run Integration Timeout Tests (minutes)
|
||||||
|
if: startsWith(github.ref, 'refs/heads')
|
||||||
|
runs-on: ubuntu-latest
|
||||||
|
steps:
|
||||||
|
- name: Checkout
|
||||||
|
uses: actions/checkout@v2
|
||||||
|
- name: Setup Node.js
|
||||||
|
uses: actions/setup-node@v1
|
||||||
|
with:
|
||||||
|
node-version: 16
|
||||||
|
- name: Install dependencies
|
||||||
|
run: npm ci
|
||||||
|
|
||||||
- name: sad-path (timeout minutes)
|
- name: sad-path (timeout minutes)
|
||||||
id: sad_path_timeout_minutes
|
id: sad_path_timeout_minutes
|
||||||
uses: ./
|
uses: ./
|
||||||
@@ -289,137 +491,11 @@ jobs:
|
|||||||
- uses: nick-invision/assert-action@v1
|
- uses: nick-invision/assert-action@v1
|
||||||
with:
|
with:
|
||||||
expected: 2
|
expected: 2
|
||||||
actual: ${{ steps.sad_path_timeout.outputs.total_attempts }}
|
actual: ${{ steps.sad_path_timeout_minutes.outputs.total_attempts }}
|
||||||
- uses: nick-invision/assert-action@v1
|
- uses: nick-invision/assert-action@v1
|
||||||
with:
|
with:
|
||||||
expected: failure
|
expected: failure
|
||||||
actual: ${{ steps.sad_path_timeout.outcome }}
|
actual: ${{ steps.sad_path_timeout_minutes.outcome }}
|
||||||
|
|
||||||
- name: sad-path (wrong shell for OS)
|
|
||||||
id: wrong_shell
|
|
||||||
uses: ./
|
|
||||||
continue-on-error: true
|
|
||||||
with:
|
|
||||||
timeout_minutes: 1
|
|
||||||
max_attempts: 2
|
|
||||||
shell: cmd
|
|
||||||
command: 'dir'
|
|
||||||
- uses: nick-invision/assert-action@v1
|
|
||||||
with:
|
|
||||||
expected: 2
|
|
||||||
actual: ${{ steps.wrong_shell.outputs.total_attempts }}
|
|
||||||
- uses: nick-invision/assert-action@v1
|
|
||||||
with:
|
|
||||||
expected: failure
|
|
||||||
actual: ${{ steps.wrong_shell.outcome }}
|
|
||||||
|
|
||||||
ci_multiline_tests:
|
|
||||||
name: Run Tests (Multiline)
|
|
||||||
if: startsWith(github.ref, 'refs/heads')
|
|
||||||
runs-on: ubuntu-18.04
|
|
||||||
steps:
|
|
||||||
- name: Checkout
|
|
||||||
uses: actions/checkout@v2
|
|
||||||
- name: Setup Node.js
|
|
||||||
uses: actions/setup-node@v1
|
|
||||||
with:
|
|
||||||
node-version: 16
|
|
||||||
- name: Install dependencies
|
|
||||||
run: npm ci
|
|
||||||
|
|
||||||
- name: Multi-line 2 commands non existent first command
|
|
||||||
id: multi_line_2_commands_non_existent_first_command
|
|
||||||
uses: ./
|
|
||||||
continue-on-error: true
|
|
||||||
with:
|
|
||||||
shell: bash
|
|
||||||
timeout_seconds: 1
|
|
||||||
max_attempts: 2
|
|
||||||
command: |
|
|
||||||
i-do-not-exist && \
|
|
||||||
echo "i-exist"
|
|
||||||
- uses: nick-invision/assert-action@v1
|
|
||||||
with:
|
|
||||||
expected: 2
|
|
||||||
actual: ${{ steps.multi_line_2_commands_non_existent_first_command.outputs.total_attempts }}
|
|
||||||
- uses: nick-invision/assert-action@v1
|
|
||||||
with:
|
|
||||||
expected: 'Final attempt failed'
|
|
||||||
actual: ${{ steps.multi_line_2_commands_non_existent_first_command.outputs.exit_error }}
|
|
||||||
comparison: contains
|
|
||||||
- uses: nick-invision/assert-action@v1
|
|
||||||
with:
|
|
||||||
# The 127 error code indicates “command not found”.
|
|
||||||
expected: '127'
|
|
||||||
actual: ${{ steps.multi_line_2_commands_non_existent_first_command.outputs.exit_code }}
|
|
||||||
comparison: contains
|
|
||||||
- uses: nick-invision/assert-action@v1
|
|
||||||
with:
|
|
||||||
expected: 'i-exist'
|
|
||||||
actual: ${{ steps.multi_line_2_commands_non_existent_first_command.outputs.exit_error }}
|
|
||||||
comparison: notContains
|
|
||||||
|
|
||||||
- name: Multi-line 2 commands happy path test
|
|
||||||
id: multi_line_2_commands_happy_path
|
|
||||||
uses: ./
|
|
||||||
with:
|
|
||||||
shell: bash
|
|
||||||
timeout_seconds: 1
|
|
||||||
max_attempts: 2
|
|
||||||
command: |
|
|
||||||
echo "foo" && \
|
|
||||||
echo "bar"
|
|
||||||
- uses: nick-invision/assert-action@v1
|
|
||||||
with:
|
|
||||||
expected: 1
|
|
||||||
actual: ${{ steps.multi_line_2_commands_happy_path.outputs.total_attempts }}
|
|
||||||
|
|
||||||
- name: Conventional multi-line non existent first command
|
|
||||||
id: conventional_multi_line_non_existent_first_command
|
|
||||||
uses: ./
|
|
||||||
continue-on-error: true
|
|
||||||
with:
|
|
||||||
shell: bash
|
|
||||||
timeout_seconds: 1
|
|
||||||
max_attempts: 2
|
|
||||||
command: |
|
|
||||||
i-do-not-exist
|
|
||||||
echo "i-exist"
|
|
||||||
- uses: nick-invision/assert-action@v1
|
|
||||||
with:
|
|
||||||
expected: 2
|
|
||||||
actual: ${{ steps.conventional_multi_line_non_existent_first_command.outputs.total_attempts }}
|
|
||||||
- uses: nick-invision/assert-action@v1
|
|
||||||
with:
|
|
||||||
expected: 'Final attempt failed'
|
|
||||||
actual: ${{ steps.conventional_multi_line_non_existent_first_command.outputs.exit_error }}
|
|
||||||
comparison: contains
|
|
||||||
- uses: nick-invision/assert-action@v1
|
|
||||||
with:
|
|
||||||
# The 127 error code indicates “command not found”.
|
|
||||||
expected: '127'
|
|
||||||
actual: ${{ steps.conventional_multi_line_non_existent_first_command.outputs.exit_code }}
|
|
||||||
comparison: contains
|
|
||||||
- uses: nick-invision/assert-action@v1
|
|
||||||
with:
|
|
||||||
expected: 'i-exist'
|
|
||||||
actual: ${{ steps.conventional_multi_line_non_existent_first_command.outputs.exit_error }}
|
|
||||||
comparison: notContains
|
|
||||||
|
|
||||||
- name: Conventional multi-line happy path test
|
|
||||||
id: conventional_multi_line_happy_path
|
|
||||||
uses: ./
|
|
||||||
with:
|
|
||||||
shell: bash
|
|
||||||
timeout_seconds: 1
|
|
||||||
max_attempts: 2
|
|
||||||
command: |
|
|
||||||
echo "foo"
|
|
||||||
echo "bar"
|
|
||||||
- uses: nick-invision/assert-action@v1
|
|
||||||
with:
|
|
||||||
expected: 1
|
|
||||||
actual: ${{ steps.conventional_multi_line_happy_path.outputs.total_attempts }}
|
|
||||||
|
|
||||||
ci_windows:
|
ci_windows:
|
||||||
name: Run Windows Tests
|
name: Run Windows Tests
|
||||||
@@ -473,12 +549,34 @@ jobs:
|
|||||||
echo "this is
|
echo "this is
|
||||||
a test"
|
a test"
|
||||||
|
|
||||||
|
ci_all_tests_passed:
|
||||||
|
name: All tests passed
|
||||||
|
needs:
|
||||||
|
[
|
||||||
|
ci_unit,
|
||||||
|
ci_integration,
|
||||||
|
ci_integration_envvar,
|
||||||
|
ci_integration_large_output,
|
||||||
|
ci_integration_on_retry_cmd,
|
||||||
|
ci_integration_retry_wait_seconds,
|
||||||
|
ci_integration_continue_on_error,
|
||||||
|
ci_integration_retry_on_exit_code,
|
||||||
|
ci_integration_timeout_seconds,
|
||||||
|
ci_integration_timeout_minutes,
|
||||||
|
ci_integration_timeout_retry_on_timeout,
|
||||||
|
ci_integration_timeout_retry_on_error,
|
||||||
|
ci_windows,
|
||||||
|
]
|
||||||
|
runs-on: ubuntu-latest
|
||||||
|
steps:
|
||||||
|
- run: echo "If this is hit, all tests successfully passed"
|
||||||
|
|
||||||
# runs on push to master only
|
# runs on push to master only
|
||||||
cd:
|
cd:
|
||||||
name: Publish Action
|
name: Publish Action
|
||||||
needs: ci
|
needs: [ci_all_tests_passed]
|
||||||
if: github.ref == 'refs/heads/master'
|
if: github.ref == 'refs/heads/master'
|
||||||
runs-on: ubuntu-18.04
|
runs-on: ubuntu-latest
|
||||||
steps:
|
steps:
|
||||||
- name: Checkout
|
- name: Checkout
|
||||||
uses: actions/checkout@v2
|
uses: actions/checkout@v2
|
||||||
|
|||||||
5
.husky/commit-msg
Executable file
5
.husky/commit-msg
Executable file
@@ -0,0 +1,5 @@
|
|||||||
|
#!/usr/bin/env sh
|
||||||
|
. "$(dirname -- "$0")/_/husky.sh"
|
||||||
|
|
||||||
|
# lint commit message
|
||||||
|
npx --no -- commitlint --config ./.config/.commitlintrc.js --edit $1
|
||||||
8
.husky/pre-commit
Executable file
8
.husky/pre-commit
Executable file
@@ -0,0 +1,8 @@
|
|||||||
|
#!/usr/bin/env sh
|
||||||
|
. "$(dirname -- "$0")/_/husky.sh"
|
||||||
|
|
||||||
|
# run lint/styling on staged changes
|
||||||
|
npx lint-staged
|
||||||
|
|
||||||
|
# regenerate dist
|
||||||
|
npm run prepare && git add .
|
||||||
@@ -1,7 +0,0 @@
|
|||||||
module.exports = {
|
|
||||||
tabWidth: 2,
|
|
||||||
printWidth: 100,
|
|
||||||
semi: true,
|
|
||||||
singleQuote: true,
|
|
||||||
trailingComma: 'es5',
|
|
||||||
};
|
|
||||||
3
.vscode/extensions.json
vendored
Normal file
3
.vscode/extensions.json
vendored
Normal file
@@ -0,0 +1,3 @@
|
|||||||
|
{
|
||||||
|
"recommendations": ["esbenp.prettier-vscode"]
|
||||||
|
}
|
||||||
7
.vscode/settings.json
vendored
7
.vscode/settings.json
vendored
@@ -1,6 +1,7 @@
|
|||||||
{
|
{
|
||||||
|
"editor.defaultFormatter": "esbenp.prettier-vscode",
|
||||||
"editor.formatOnSave": true,
|
"editor.formatOnSave": true,
|
||||||
"prettier.requireConfig": true,
|
"prettier.configPath": "./.config/.prettierrc.yml",
|
||||||
"typescript.tsdk": "node_modules/typescript/lib",
|
"prettier.ignorePath": "./.config/.prettierignore",
|
||||||
"editor.tabSize": 2
|
"typescript.tsdk": "node_modules/typescript/lib"
|
||||||
}
|
}
|
||||||
|
|||||||
414
dist/index.js
vendored
414
dist/index.js
vendored
@@ -527,7 +527,7 @@ module.exports = require("https");
|
|||||||
/***/ }),
|
/***/ }),
|
||||||
|
|
||||||
/***/ 322:
|
/***/ 322:
|
||||||
/***/ (function(__unusedmodule, exports) {
|
/***/ (function(__unusedmodule, exports, __webpack_require__) {
|
||||||
|
|
||||||
"use strict";
|
"use strict";
|
||||||
|
|
||||||
@@ -568,7 +568,8 @@ var __generator = (this && this.__generator) || function (thisArg, body) {
|
|||||||
}
|
}
|
||||||
};
|
};
|
||||||
Object.defineProperty(exports, "__esModule", { value: true });
|
Object.defineProperty(exports, "__esModule", { value: true });
|
||||||
exports.wait = void 0;
|
exports.retryWait = exports.wait = void 0;
|
||||||
|
var core_1 = __webpack_require__(470);
|
||||||
function wait(ms) {
|
function wait(ms) {
|
||||||
return __awaiter(this, void 0, void 0, function () {
|
return __awaiter(this, void 0, void 0, function () {
|
||||||
return __generator(this, function (_a) {
|
return __generator(this, function (_a) {
|
||||||
@@ -577,6 +578,24 @@ function wait(ms) {
|
|||||||
});
|
});
|
||||||
}
|
}
|
||||||
exports.wait = wait;
|
exports.wait = wait;
|
||||||
|
function retryWait(retryWaitSeconds) {
|
||||||
|
return __awaiter(this, void 0, void 0, function () {
|
||||||
|
var waitStart;
|
||||||
|
return __generator(this, function (_a) {
|
||||||
|
switch (_a.label) {
|
||||||
|
case 0:
|
||||||
|
waitStart = Date.now();
|
||||||
|
return [4 /*yield*/, wait(retryWaitSeconds)];
|
||||||
|
case 1:
|
||||||
|
_a.sent();
|
||||||
|
(0, core_1.debug)("Waited ".concat(Date.now() - waitStart, "ms"));
|
||||||
|
(0, core_1.debug)("Configured wait: ".concat(retryWaitSeconds, "ms"));
|
||||||
|
return [2 /*return*/];
|
||||||
|
}
|
||||||
|
});
|
||||||
|
});
|
||||||
|
}
|
||||||
|
exports.retryWait = retryWait;
|
||||||
|
|
||||||
|
|
||||||
/***/ }),
|
/***/ }),
|
||||||
@@ -630,160 +649,88 @@ var core_1 = __webpack_require__(470);
|
|||||||
var child_process_1 = __webpack_require__(129);
|
var child_process_1 = __webpack_require__(129);
|
||||||
var milliseconds_1 = __importDefault(__webpack_require__(156));
|
var milliseconds_1 = __importDefault(__webpack_require__(156));
|
||||||
var tree_kill_1 = __importDefault(__webpack_require__(791));
|
var tree_kill_1 = __importDefault(__webpack_require__(791));
|
||||||
|
var inputs_1 = __webpack_require__(679);
|
||||||
var util_1 = __webpack_require__(322);
|
var util_1 = __webpack_require__(322);
|
||||||
// inputs
|
|
||||||
var TIMEOUT_MINUTES = getInputNumber('timeout_minutes', false);
|
|
||||||
var TIMEOUT_SECONDS = getInputNumber('timeout_seconds', false);
|
|
||||||
var MAX_ATTEMPTS = getInputNumber('max_attempts', true) || 3;
|
|
||||||
var COMMAND = core_1.getInput('command', { required: true });
|
|
||||||
var RETRY_WAIT_SECONDS = getInputNumber('retry_wait_seconds', false) || 10;
|
|
||||||
var SHELL = core_1.getInput('shell');
|
|
||||||
var POLLING_INTERVAL_SECONDS = getInputNumber('polling_interval_seconds', false) || 1;
|
|
||||||
var RETRY_ON = core_1.getInput('retry_on') || 'any';
|
|
||||||
var WARNING_ON_RETRY = core_1.getInput('warning_on_retry').toLowerCase() === 'true';
|
|
||||||
var ON_RETRY_COMMAND = core_1.getInput('on_retry_command');
|
|
||||||
var CONTINUE_ON_ERROR = getInputBoolean('continue_on_error');
|
|
||||||
var NEW_COMMAND_ON_RETRY = core_1.getInput('new_command_on_retry');
|
|
||||||
var RETRY_ON_EXIT_CODE = getInputNumber('retry_on_exit_code', false);
|
|
||||||
var OS = process.platform;
|
var OS = process.platform;
|
||||||
var OUTPUT_TOTAL_ATTEMPTS_KEY = 'total_attempts';
|
var OUTPUT_TOTAL_ATTEMPTS_KEY = 'total_attempts';
|
||||||
var OUTPUT_EXIT_CODE_KEY = 'exit_code';
|
var OUTPUT_EXIT_CODE_KEY = 'exit_code';
|
||||||
var OUTPUT_EXIT_ERROR_KEY = 'exit_error';
|
var OUTPUT_EXIT_ERROR_KEY = 'exit_error';
|
||||||
var exit;
|
var exit;
|
||||||
var done;
|
var done;
|
||||||
function getInputNumber(id, required) {
|
function getExecutable(inputs) {
|
||||||
var input = core_1.getInput(id, { required: required });
|
if (!inputs.shell) {
|
||||||
var num = Number.parseInt(input);
|
return OS === 'win32' ? 'powershell' : 'bash';
|
||||||
// empty is ok
|
|
||||||
if (!input && !required) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
if (!Number.isInteger(num)) {
|
|
||||||
throw "Input " + id + " only accepts numbers. Received " + input;
|
|
||||||
}
|
|
||||||
return num;
|
|
||||||
}
|
|
||||||
function getInputBoolean(id) {
|
|
||||||
var input = core_1.getInput(id);
|
|
||||||
if (!['true', 'false'].includes(input.toLowerCase())) {
|
|
||||||
throw "Input " + id + " only accepts boolean values. Received " + input;
|
|
||||||
}
|
|
||||||
return input.toLowerCase() === 'true';
|
|
||||||
}
|
|
||||||
function retryWait() {
|
|
||||||
return __awaiter(this, void 0, void 0, function () {
|
|
||||||
var waitStart;
|
|
||||||
return __generator(this, function (_a) {
|
|
||||||
switch (_a.label) {
|
|
||||||
case 0:
|
|
||||||
waitStart = Date.now();
|
|
||||||
return [4 /*yield*/, util_1.wait(milliseconds_1.default.seconds(RETRY_WAIT_SECONDS))];
|
|
||||||
case 1:
|
|
||||||
_a.sent();
|
|
||||||
core_1.debug("Waited " + (Date.now() - waitStart) + "ms");
|
|
||||||
core_1.debug("Configured wait: " + milliseconds_1.default.seconds(RETRY_WAIT_SECONDS) + "ms");
|
|
||||||
return [2 /*return*/];
|
|
||||||
}
|
|
||||||
});
|
|
||||||
});
|
|
||||||
}
|
|
||||||
function validateInputs() {
|
|
||||||
return __awaiter(this, void 0, void 0, function () {
|
|
||||||
return __generator(this, function (_a) {
|
|
||||||
if ((!TIMEOUT_MINUTES && !TIMEOUT_SECONDS) || (TIMEOUT_MINUTES && TIMEOUT_SECONDS)) {
|
|
||||||
throw new Error('Must specify either timeout_minutes or timeout_seconds inputs');
|
|
||||||
}
|
|
||||||
return [2 /*return*/];
|
|
||||||
});
|
|
||||||
});
|
|
||||||
}
|
|
||||||
function getTimeout() {
|
|
||||||
if (TIMEOUT_MINUTES) {
|
|
||||||
return milliseconds_1.default.minutes(TIMEOUT_MINUTES);
|
|
||||||
}
|
|
||||||
else if (TIMEOUT_SECONDS) {
|
|
||||||
return milliseconds_1.default.seconds(TIMEOUT_SECONDS);
|
|
||||||
}
|
|
||||||
throw new Error('Must specify either timeout_minutes or timeout_seconds inputs');
|
|
||||||
}
|
|
||||||
function getExecutable() {
|
|
||||||
if (!SHELL) {
|
|
||||||
return OS === 'win32' ? 'powershell' : 'bash -e';
|
|
||||||
}
|
}
|
||||||
var executable;
|
var executable;
|
||||||
switch (SHELL) {
|
switch (inputs.shell) {
|
||||||
case "bash": {
|
case 'bash':
|
||||||
// -e to not ignore errors, but exit with non-zero code.
|
case 'python':
|
||||||
executable = "bash -e";
|
case 'pwsh': {
|
||||||
|
executable = inputs.shell;
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
case "python":
|
case 'sh': {
|
||||||
case "pwsh": {
|
|
||||||
executable = SHELL;
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
case "sh": {
|
|
||||||
if (OS === 'win32') {
|
if (OS === 'win32') {
|
||||||
throw new Error("Shell " + SHELL + " not allowed on OS " + OS);
|
throw new Error("Shell ".concat(inputs.shell, " not allowed on OS ").concat(OS));
|
||||||
}
|
}
|
||||||
executable = SHELL;
|
executable = inputs.shell;
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
case "cmd":
|
case 'cmd':
|
||||||
case "powershell": {
|
case 'powershell': {
|
||||||
if (OS !== 'win32') {
|
if (OS !== 'win32') {
|
||||||
throw new Error("Shell " + SHELL + " not allowed on OS " + OS);
|
throw new Error("Shell ".concat(inputs.shell, " not allowed on OS ").concat(OS));
|
||||||
}
|
}
|
||||||
executable = SHELL + ".exe";
|
executable = inputs.shell + '.exe';
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
default: {
|
default: {
|
||||||
throw new Error("Shell " + SHELL + " not supported. See https://docs.github.com/en/free-pro-team@latest/actions/reference/workflow-syntax-for-github-actions#using-a-specific-shell for supported shells");
|
throw new Error("Shell ".concat(inputs.shell, " not supported. See https://docs.github.com/en/free-pro-team@latest/actions/reference/workflow-syntax-for-github-actions#using-a-specific-shell for supported shells"));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return executable;
|
return executable;
|
||||||
}
|
}
|
||||||
function runRetryCmd() {
|
function runRetryCmd(inputs) {
|
||||||
return __awaiter(this, void 0, void 0, function () {
|
return __awaiter(this, void 0, void 0, function () {
|
||||||
var error_1;
|
var error_1;
|
||||||
return __generator(this, function (_a) {
|
return __generator(this, function (_a) {
|
||||||
switch (_a.label) {
|
switch (_a.label) {
|
||||||
case 0:
|
case 0:
|
||||||
// if no retry script, just continue
|
// if no retry script, just continue
|
||||||
if (!ON_RETRY_COMMAND) {
|
if (!inputs.on_retry_command) {
|
||||||
return [2 /*return*/];
|
return [2 /*return*/];
|
||||||
}
|
}
|
||||||
_a.label = 1;
|
_a.label = 1;
|
||||||
case 1:
|
case 1:
|
||||||
_a.trys.push([1, 3, , 4]);
|
_a.trys.push([1, 3, , 4]);
|
||||||
return [4 /*yield*/, child_process_1.execSync(ON_RETRY_COMMAND, { stdio: 'inherit' })];
|
return [4 /*yield*/, (0, child_process_1.execSync)(inputs.on_retry_command, { stdio: 'inherit' })];
|
||||||
case 2:
|
case 2:
|
||||||
_a.sent();
|
_a.sent();
|
||||||
return [3 /*break*/, 4];
|
return [3 /*break*/, 4];
|
||||||
case 3:
|
case 3:
|
||||||
error_1 = _a.sent();
|
error_1 = _a.sent();
|
||||||
core_1.info("WARNING: Retry command threw the error " + error_1.message);
|
(0, core_1.info)("WARNING: Retry command threw the error ".concat(error_1.message));
|
||||||
return [3 /*break*/, 4];
|
return [3 /*break*/, 4];
|
||||||
case 4: return [2 /*return*/];
|
case 4: return [2 /*return*/];
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
function runCmd(attempt) {
|
function runCmd(attempt, inputs) {
|
||||||
var _a, _b;
|
var _a, _b;
|
||||||
return __awaiter(this, void 0, void 0, function () {
|
return __awaiter(this, void 0, void 0, function () {
|
||||||
var end_time, executable, child;
|
var end_time, executable, child;
|
||||||
return __generator(this, function (_c) {
|
return __generator(this, function (_c) {
|
||||||
switch (_c.label) {
|
switch (_c.label) {
|
||||||
case 0:
|
case 0:
|
||||||
end_time = Date.now() + getTimeout();
|
end_time = Date.now() + (0, inputs_1.getTimeout)(inputs);
|
||||||
executable = getExecutable();
|
executable = getExecutable(inputs);
|
||||||
exit = 0;
|
exit = 0;
|
||||||
done = false;
|
done = false;
|
||||||
core_1.debug("Running command " + COMMAND + " on " + OS + " using shell \"" + executable + "\"");
|
(0, core_1.debug)("Running command ".concat(inputs.command, " on ").concat(OS, " using shell ").concat(executable));
|
||||||
child = attempt > 1 && NEW_COMMAND_ON_RETRY
|
child = attempt > 1 && inputs.new_command_on_retry
|
||||||
? child_process_1.exec(NEW_COMMAND_ON_RETRY, { 'shell': executable })
|
? (0, child_process_1.spawn)(inputs.new_command_on_retry, { shell: executable })
|
||||||
: child_process_1.exec(COMMAND, { 'shell': executable });
|
: (0, child_process_1.spawn)(inputs.command, { shell: executable });
|
||||||
(_a = child.stdout) === null || _a === void 0 ? void 0 : _a.on('data', function (data) {
|
(_a = child.stdout) === null || _a === void 0 ? void 0 : _a.on('data', function (data) {
|
||||||
process.stdout.write(data);
|
process.stdout.write(data);
|
||||||
});
|
});
|
||||||
@@ -791,8 +738,8 @@ function runCmd(attempt) {
|
|||||||
process.stdout.write(data);
|
process.stdout.write(data);
|
||||||
});
|
});
|
||||||
child.on('exit', function (code, signal) {
|
child.on('exit', function (code, signal) {
|
||||||
core_1.debug("Code: " + code);
|
(0, core_1.debug)("Code: ".concat(code));
|
||||||
core_1.debug("Signal: " + signal);
|
(0, core_1.debug)("Signal: ".concat(signal));
|
||||||
if (code && code > 0) {
|
if (code && code > 0) {
|
||||||
exit = code;
|
exit = code;
|
||||||
}
|
}
|
||||||
@@ -803,7 +750,7 @@ function runCmd(attempt) {
|
|||||||
done = true;
|
done = true;
|
||||||
});
|
});
|
||||||
_c.label = 1;
|
_c.label = 1;
|
||||||
case 1: return [4 /*yield*/, util_1.wait(milliseconds_1.default.seconds(POLLING_INTERVAL_SECONDS))];
|
case 1: return [4 /*yield*/, (0, util_1.wait)(milliseconds_1.default.seconds(inputs.polling_interval_seconds))];
|
||||||
case 2:
|
case 2:
|
||||||
_c.sent();
|
_c.sent();
|
||||||
_c.label = 3;
|
_c.label = 3;
|
||||||
@@ -811,68 +758,68 @@ function runCmd(attempt) {
|
|||||||
if (Date.now() < end_time && !done) return [3 /*break*/, 1];
|
if (Date.now() < end_time && !done) return [3 /*break*/, 1];
|
||||||
_c.label = 4;
|
_c.label = 4;
|
||||||
case 4:
|
case 4:
|
||||||
if (!!done) return [3 /*break*/, 6];
|
if (!(!done && child.pid)) return [3 /*break*/, 6];
|
||||||
tree_kill_1.default(child.pid);
|
(0, tree_kill_1.default)(child.pid);
|
||||||
return [4 /*yield*/, retryWait()];
|
return [4 /*yield*/, (0, util_1.retryWait)(milliseconds_1.default.seconds(inputs.retry_wait_seconds))];
|
||||||
case 5:
|
case 5:
|
||||||
_c.sent();
|
_c.sent();
|
||||||
throw new Error("Timeout of " + getTimeout() + "ms hit");
|
throw new Error("Timeout of ".concat((0, inputs_1.getTimeout)(inputs), "ms hit"));
|
||||||
case 6:
|
case 6:
|
||||||
if (!(exit > 0)) return [3 /*break*/, 8];
|
if (!(exit > 0)) return [3 /*break*/, 8];
|
||||||
return [4 /*yield*/, retryWait()];
|
return [4 /*yield*/, (0, util_1.retryWait)(milliseconds_1.default.seconds(inputs.retry_wait_seconds))];
|
||||||
case 7:
|
case 7:
|
||||||
_c.sent();
|
_c.sent();
|
||||||
throw new Error("Child_process exited with error code " + exit);
|
throw new Error("Child_process exited with error code ".concat(exit));
|
||||||
case 8: return [2 /*return*/];
|
case 8: return [2 /*return*/];
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
function runAction() {
|
function runAction(inputs) {
|
||||||
return __awaiter(this, void 0, void 0, function () {
|
return __awaiter(this, void 0, void 0, function () {
|
||||||
var attempt, error_2;
|
var attempt, error_2;
|
||||||
return __generator(this, function (_a) {
|
return __generator(this, function (_a) {
|
||||||
switch (_a.label) {
|
switch (_a.label) {
|
||||||
case 0: return [4 /*yield*/, validateInputs()];
|
case 0: return [4 /*yield*/, (0, inputs_1.validateInputs)(inputs)];
|
||||||
case 1:
|
case 1:
|
||||||
_a.sent();
|
_a.sent();
|
||||||
attempt = 1;
|
attempt = 1;
|
||||||
_a.label = 2;
|
_a.label = 2;
|
||||||
case 2:
|
case 2:
|
||||||
if (!(attempt <= MAX_ATTEMPTS)) return [3 /*break*/, 13];
|
if (!(attempt <= inputs.max_attempts)) return [3 /*break*/, 13];
|
||||||
_a.label = 3;
|
_a.label = 3;
|
||||||
case 3:
|
case 3:
|
||||||
_a.trys.push([3, 5, , 12]);
|
_a.trys.push([3, 5, , 12]);
|
||||||
// just keep overwriting attempts output
|
// just keep overwriting attempts output
|
||||||
core_1.setOutput(OUTPUT_TOTAL_ATTEMPTS_KEY, attempt);
|
(0, core_1.setOutput)(OUTPUT_TOTAL_ATTEMPTS_KEY, attempt);
|
||||||
return [4 /*yield*/, runCmd(attempt)];
|
return [4 /*yield*/, runCmd(attempt, inputs)];
|
||||||
case 4:
|
case 4:
|
||||||
_a.sent();
|
_a.sent();
|
||||||
core_1.info("Command completed after " + attempt + " attempt(s).");
|
(0, core_1.info)("Command completed after ".concat(attempt, " attempt(s)."));
|
||||||
return [3 /*break*/, 13];
|
return [3 /*break*/, 13];
|
||||||
case 5:
|
case 5:
|
||||||
error_2 = _a.sent();
|
error_2 = _a.sent();
|
||||||
if (!(attempt === MAX_ATTEMPTS)) return [3 /*break*/, 6];
|
if (!(attempt === inputs.max_attempts)) return [3 /*break*/, 6];
|
||||||
throw new Error("Final attempt failed. " + error_2.message);
|
throw new Error("Final attempt failed. ".concat(error_2.message));
|
||||||
case 6:
|
case 6:
|
||||||
if (!(!done && RETRY_ON === 'error')) return [3 /*break*/, 7];
|
if (!(!done && inputs.retry_on === 'error')) return [3 /*break*/, 7];
|
||||||
// error: timeout
|
// error: timeout
|
||||||
throw error_2;
|
throw error_2;
|
||||||
case 7:
|
case 7:
|
||||||
if (!(RETRY_ON_EXIT_CODE && RETRY_ON_EXIT_CODE !== exit)) return [3 /*break*/, 8];
|
if (!(inputs.retry_on_exit_code && inputs.retry_on_exit_code !== exit)) return [3 /*break*/, 8];
|
||||||
throw error_2;
|
throw error_2;
|
||||||
case 8:
|
case 8:
|
||||||
if (!(exit > 0 && RETRY_ON === 'timeout')) return [3 /*break*/, 9];
|
if (!(exit > 0 && inputs.retry_on === 'timeout')) return [3 /*break*/, 9];
|
||||||
// error: error
|
// error: error
|
||||||
throw error_2;
|
throw error_2;
|
||||||
case 9: return [4 /*yield*/, runRetryCmd()];
|
case 9: return [4 /*yield*/, runRetryCmd(inputs)];
|
||||||
case 10:
|
case 10:
|
||||||
_a.sent();
|
_a.sent();
|
||||||
if (WARNING_ON_RETRY) {
|
if (inputs.warning_on_retry) {
|
||||||
core_1.warning("Attempt " + attempt + " failed. Reason: " + error_2.message);
|
(0, core_1.warning)("Attempt ".concat(attempt, " failed. Reason: ").concat(error_2.message));
|
||||||
}
|
}
|
||||||
else {
|
else {
|
||||||
core_1.info("Attempt " + attempt + " failed. Reason: " + error_2.message);
|
(0, core_1.info)("Attempt ".concat(attempt, " failed. Reason: ").concat(error_2.message));
|
||||||
}
|
}
|
||||||
_a.label = 11;
|
_a.label = 11;
|
||||||
case 11: return [3 /*break*/, 12];
|
case 11: return [3 /*break*/, 12];
|
||||||
@@ -884,26 +831,27 @@ function runAction() {
|
|||||||
});
|
});
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
runAction()
|
var inputs = (0, inputs_1.getInputs)();
|
||||||
|
runAction(inputs)
|
||||||
.then(function () {
|
.then(function () {
|
||||||
core_1.setOutput(OUTPUT_EXIT_CODE_KEY, 0);
|
(0, core_1.setOutput)(OUTPUT_EXIT_CODE_KEY, 0);
|
||||||
process.exit(0); // success
|
process.exit(0); // success
|
||||||
})
|
})
|
||||||
.catch(function (err) {
|
.catch(function (err) {
|
||||||
// exact error code if available, otherwise just 1
|
// exact error code if available, otherwise just 1
|
||||||
var exitCode = exit > 0 ? exit : 1;
|
var exitCode = exit > 0 ? exit : 1;
|
||||||
if (CONTINUE_ON_ERROR) {
|
if (inputs.continue_on_error) {
|
||||||
core_1.warning(err.message);
|
(0, core_1.warning)(err.message);
|
||||||
}
|
}
|
||||||
else {
|
else {
|
||||||
core_1.error(err.message);
|
(0, core_1.error)(err.message);
|
||||||
}
|
}
|
||||||
// these can be helpful to know if continue-on-error is true
|
// these can be helpful to know if continue-on-error is true
|
||||||
core_1.setOutput(OUTPUT_EXIT_ERROR_KEY, err.message);
|
(0, core_1.setOutput)(OUTPUT_EXIT_ERROR_KEY, err.message);
|
||||||
core_1.setOutput(OUTPUT_EXIT_CODE_KEY, exitCode);
|
(0, core_1.setOutput)(OUTPUT_EXIT_CODE_KEY, exitCode);
|
||||||
// if continue_on_error, exit with exact error code else exit gracefully
|
// if continue_on_error, exit with exact error code else exit gracefully
|
||||||
// mimics native continue-on-error that is not supported in composite actions
|
// mimics native continue-on-error that is not supported in composite actions
|
||||||
process.exit(CONTINUE_ON_ERROR ? 0 : exitCode);
|
process.exit(inputs.continue_on_error ? 0 : exitCode);
|
||||||
});
|
});
|
||||||
|
|
||||||
|
|
||||||
@@ -1960,6 +1908,13 @@ Object.defineProperty(exports, "summary", { enumerable: true, get: function () {
|
|||||||
*/
|
*/
|
||||||
var summary_2 = __webpack_require__(665);
|
var summary_2 = __webpack_require__(665);
|
||||||
Object.defineProperty(exports, "markdownSummary", { enumerable: true, get: function () { return summary_2.markdownSummary; } });
|
Object.defineProperty(exports, "markdownSummary", { enumerable: true, get: function () { return summary_2.markdownSummary; } });
|
||||||
|
/**
|
||||||
|
* Path exports
|
||||||
|
*/
|
||||||
|
var path_utils_1 = __webpack_require__(573);
|
||||||
|
Object.defineProperty(exports, "toPosixPath", { enumerable: true, get: function () { return path_utils_1.toPosixPath; } });
|
||||||
|
Object.defineProperty(exports, "toWin32Path", { enumerable: true, get: function () { return path_utils_1.toWin32Path; } });
|
||||||
|
Object.defineProperty(exports, "toPlatformPath", { enumerable: true, get: function () { return path_utils_1.toPlatformPath; } });
|
||||||
//# sourceMappingURL=core.js.map
|
//# sourceMappingURL=core.js.map
|
||||||
|
|
||||||
/***/ }),
|
/***/ }),
|
||||||
@@ -2052,6 +2007,71 @@ exports.PersonalAccessTokenCredentialHandler = PersonalAccessTokenCredentialHand
|
|||||||
|
|
||||||
/***/ }),
|
/***/ }),
|
||||||
|
|
||||||
|
/***/ 573:
|
||||||
|
/***/ (function(__unusedmodule, exports, __webpack_require__) {
|
||||||
|
|
||||||
|
"use strict";
|
||||||
|
|
||||||
|
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;
|
||||||
|
});
|
||||||
|
var __importStar = (this && this.__importStar) || function (mod) {
|
||||||
|
if (mod && mod.__esModule) return mod;
|
||||||
|
var result = {};
|
||||||
|
if (mod != null) for (var k in mod) if (k !== "default" && Object.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
|
||||||
|
__setModuleDefault(result, mod);
|
||||||
|
return result;
|
||||||
|
};
|
||||||
|
Object.defineProperty(exports, "__esModule", { value: true });
|
||||||
|
exports.toPlatformPath = exports.toWin32Path = exports.toPosixPath = void 0;
|
||||||
|
const path = __importStar(__webpack_require__(622));
|
||||||
|
/**
|
||||||
|
* toPosixPath converts the given path to the posix form. On Windows, \\ will be
|
||||||
|
* replaced with /.
|
||||||
|
*
|
||||||
|
* @param pth. Path to transform.
|
||||||
|
* @return string Posix path.
|
||||||
|
*/
|
||||||
|
function toPosixPath(pth) {
|
||||||
|
return pth.replace(/[\\]/g, '/');
|
||||||
|
}
|
||||||
|
exports.toPosixPath = toPosixPath;
|
||||||
|
/**
|
||||||
|
* toWin32Path converts the given path to the win32 form. On Linux, / will be
|
||||||
|
* replaced with \\.
|
||||||
|
*
|
||||||
|
* @param pth. Path to transform.
|
||||||
|
* @return string Win32 path.
|
||||||
|
*/
|
||||||
|
function toWin32Path(pth) {
|
||||||
|
return pth.replace(/[/]/g, '\\');
|
||||||
|
}
|
||||||
|
exports.toWin32Path = toWin32Path;
|
||||||
|
/**
|
||||||
|
* toPlatformPath converts the given path to a platform-specific path. It does
|
||||||
|
* this by replacing instances of / and \ with the platform-specific path
|
||||||
|
* separator.
|
||||||
|
*
|
||||||
|
* @param pth The path to platformize.
|
||||||
|
* @return string The platform-specific path.
|
||||||
|
*/
|
||||||
|
function toPlatformPath(pth) {
|
||||||
|
return pth.replace(/[/\\]/g, path.sep);
|
||||||
|
}
|
||||||
|
exports.toPlatformPath = toPlatformPath;
|
||||||
|
//# sourceMappingURL=path-utils.js.map
|
||||||
|
|
||||||
|
/***/ }),
|
||||||
|
|
||||||
/***/ 605:
|
/***/ 605:
|
||||||
/***/ (function(module) {
|
/***/ (function(module) {
|
||||||
|
|
||||||
@@ -2375,6 +2395,132 @@ exports.summary = _summary;
|
|||||||
|
|
||||||
module.exports = require("util");
|
module.exports = require("util");
|
||||||
|
|
||||||
|
/***/ }),
|
||||||
|
|
||||||
|
/***/ 679:
|
||||||
|
/***/ (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 __generator = (this && this.__generator) || function (thisArg, body) {
|
||||||
|
var _ = { label: 0, sent: function() { if (t[0] & 1) throw t[1]; return t[1]; }, trys: [], ops: [] }, f, y, t, g;
|
||||||
|
return g = { next: verb(0), "throw": verb(1), "return": verb(2) }, typeof Symbol === "function" && (g[Symbol.iterator] = function() { return this; }), g;
|
||||||
|
function verb(n) { return function (v) { return step([n, v]); }; }
|
||||||
|
function step(op) {
|
||||||
|
if (f) throw new TypeError("Generator is already executing.");
|
||||||
|
while (_) try {
|
||||||
|
if (f = 1, y && (t = op[0] & 2 ? y["return"] : op[0] ? y["throw"] || ((t = y["return"]) && t.call(y), 0) : y.next) && !(t = t.call(y, op[1])).done) return t;
|
||||||
|
if (y = 0, t) op = [op[0] & 2, t.value];
|
||||||
|
switch (op[0]) {
|
||||||
|
case 0: case 1: t = op; break;
|
||||||
|
case 4: _.label++; return { value: op[1], done: false };
|
||||||
|
case 5: _.label++; y = op[1]; op = [0]; continue;
|
||||||
|
case 7: op = _.ops.pop(); _.trys.pop(); continue;
|
||||||
|
default:
|
||||||
|
if (!(t = _.trys, t = t.length > 0 && t[t.length - 1]) && (op[0] === 6 || op[0] === 2)) { _ = 0; continue; }
|
||||||
|
if (op[0] === 3 && (!t || (op[1] > t[0] && op[1] < t[3]))) { _.label = op[1]; break; }
|
||||||
|
if (op[0] === 6 && _.label < t[1]) { _.label = t[1]; t = op; break; }
|
||||||
|
if (t && _.label < t[2]) { _.label = t[2]; _.ops.push(op); break; }
|
||||||
|
if (t[2]) _.ops.pop();
|
||||||
|
_.trys.pop(); continue;
|
||||||
|
}
|
||||||
|
op = body.call(thisArg, _);
|
||||||
|
} catch (e) { op = [6, e]; y = 0; } finally { f = t = 0; }
|
||||||
|
if (op[0] & 5) throw op[1]; return { value: op[0] ? op[1] : void 0, done: true };
|
||||||
|
}
|
||||||
|
};
|
||||||
|
var __importDefault = (this && this.__importDefault) || function (mod) {
|
||||||
|
return (mod && mod.__esModule) ? mod : { "default": mod };
|
||||||
|
};
|
||||||
|
Object.defineProperty(exports, "__esModule", { value: true });
|
||||||
|
exports.getInputs = exports.getTimeout = exports.validateInputs = exports.getInputBoolean = exports.getInputNumber = void 0;
|
||||||
|
var core_1 = __webpack_require__(470);
|
||||||
|
var milliseconds_1 = __importDefault(__webpack_require__(156));
|
||||||
|
function getInputNumber(id, required) {
|
||||||
|
var input = (0, core_1.getInput)(id, { required: required });
|
||||||
|
var num = Number.parseInt(input);
|
||||||
|
// empty is ok
|
||||||
|
if (!input && !required) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
if (!Number.isInteger(num)) {
|
||||||
|
throw "Input ".concat(id, " only accepts numbers. Received ").concat(input);
|
||||||
|
}
|
||||||
|
return num;
|
||||||
|
}
|
||||||
|
exports.getInputNumber = getInputNumber;
|
||||||
|
function getInputBoolean(id) {
|
||||||
|
var input = (0, core_1.getInput)(id);
|
||||||
|
if (!['true', 'false'].includes(input.toLowerCase())) {
|
||||||
|
throw "Input ".concat(id, " only accepts boolean values. Received ").concat(input);
|
||||||
|
}
|
||||||
|
return input.toLowerCase() === 'true';
|
||||||
|
}
|
||||||
|
exports.getInputBoolean = getInputBoolean;
|
||||||
|
function validateInputs(inputs) {
|
||||||
|
return __awaiter(this, void 0, void 0, function () {
|
||||||
|
return __generator(this, function (_a) {
|
||||||
|
if ((!inputs.timeout_minutes && !inputs.timeout_seconds) ||
|
||||||
|
(inputs.timeout_minutes && inputs.timeout_seconds)) {
|
||||||
|
throw new Error('Must specify either timeout_minutes or timeout_seconds inputs');
|
||||||
|
}
|
||||||
|
return [2 /*return*/];
|
||||||
|
});
|
||||||
|
});
|
||||||
|
}
|
||||||
|
exports.validateInputs = validateInputs;
|
||||||
|
function getTimeout(inputs) {
|
||||||
|
if (inputs.timeout_minutes) {
|
||||||
|
return milliseconds_1.default.minutes(inputs.timeout_minutes);
|
||||||
|
}
|
||||||
|
else if (inputs.timeout_seconds) {
|
||||||
|
return milliseconds_1.default.seconds(inputs.timeout_seconds);
|
||||||
|
}
|
||||||
|
throw new Error('Must specify either timeout_minutes or timeout_seconds inputs');
|
||||||
|
}
|
||||||
|
exports.getTimeout = getTimeout;
|
||||||
|
function getInputs() {
|
||||||
|
var timeout_minutes = getInputNumber('timeout_minutes', false);
|
||||||
|
var timeout_seconds = getInputNumber('timeout_seconds', false);
|
||||||
|
var max_attempts = getInputNumber('max_attempts', true) || 3;
|
||||||
|
var command = (0, core_1.getInput)('command', { required: true });
|
||||||
|
var retry_wait_seconds = getInputNumber('retry_wait_seconds', false) || 10;
|
||||||
|
var shell = (0, core_1.getInput)('shell');
|
||||||
|
var polling_interval_seconds = getInputNumber('polling_interval_seconds', false) || 1;
|
||||||
|
var retry_on = (0, core_1.getInput)('retry_on') || 'any';
|
||||||
|
var warning_on_retry = (0, core_1.getInput)('warning_on_retry').toLowerCase() === 'true';
|
||||||
|
var on_retry_command = (0, core_1.getInput)('on_retry_command');
|
||||||
|
var continue_on_error = getInputBoolean('continue_on_error');
|
||||||
|
var new_command_on_retry = (0, core_1.getInput)('new_command_on_retry');
|
||||||
|
var retry_on_exit_code = getInputNumber('retry_on_exit_code', false);
|
||||||
|
return {
|
||||||
|
timeout_minutes: timeout_minutes,
|
||||||
|
timeout_seconds: timeout_seconds,
|
||||||
|
max_attempts: max_attempts,
|
||||||
|
command: command,
|
||||||
|
retry_wait_seconds: retry_wait_seconds,
|
||||||
|
shell: shell,
|
||||||
|
polling_interval_seconds: polling_interval_seconds,
|
||||||
|
retry_on: retry_on,
|
||||||
|
warning_on_retry: warning_on_retry,
|
||||||
|
on_retry_command: on_retry_command,
|
||||||
|
continue_on_error: continue_on_error,
|
||||||
|
new_command_on_retry: new_command_on_retry,
|
||||||
|
retry_on_exit_code: retry_on_exit_code,
|
||||||
|
};
|
||||||
|
}
|
||||||
|
exports.getInputs = getInputs;
|
||||||
|
|
||||||
|
|
||||||
/***/ }),
|
/***/ }),
|
||||||
|
|
||||||
/***/ 742:
|
/***/ 742:
|
||||||
|
|||||||
10545
package-lock.json
generated
10545
package-lock.json
generated
File diff suppressed because it is too large
Load Diff
41
package.json
41
package.json
@@ -3,8 +3,13 @@
|
|||||||
"version": "0.0.0-managed-by-semantic-release",
|
"version": "0.0.0-managed-by-semantic-release",
|
||||||
"description": "Retries a GitHub Action step on failure or timeout.",
|
"description": "Retries a GitHub Action step on failure or timeout.",
|
||||||
"scripts": {
|
"scripts": {
|
||||||
|
"lint:base": "eslint --config ./.config/.eslintrc.js ",
|
||||||
|
"lint": "npm run lint:base -- .",
|
||||||
"local": "npm run prepare && node -r dotenv/config ./dist/index.js",
|
"local": "npm run prepare && node -r dotenv/config ./dist/index.js",
|
||||||
"prepare": "ncc build src/index.ts"
|
"prepare": "ncc build src/index.ts && husky install",
|
||||||
|
"style:base": "prettier --config ./.config/.prettierrc.yml --ignore-path ./.config/.prettierignore --write ",
|
||||||
|
"style": "npm run style:base -- .",
|
||||||
|
"test": "jest -c ./.config/jest.config.js"
|
||||||
},
|
},
|
||||||
"repository": {
|
"repository": {
|
||||||
"type": "git",
|
"type": "git",
|
||||||
@@ -18,7 +23,7 @@
|
|||||||
},
|
},
|
||||||
"homepage": "https://github.com/nick-invision/retry#readme",
|
"homepage": "https://github.com/nick-invision/retry#readme",
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@actions/core": "^1.8.2",
|
"@actions/core": "^1.9.1",
|
||||||
"milliseconds": "^1.0.3",
|
"milliseconds": "^1.0.3",
|
||||||
"tree-kill": "^1.2.2"
|
"tree-kill": "^1.2.2"
|
||||||
},
|
},
|
||||||
@@ -27,19 +32,35 @@
|
|||||||
"@commitlint/config-conventional": "^16.2.1",
|
"@commitlint/config-conventional": "^16.2.1",
|
||||||
"@semantic-release/changelog": "^6.0.1",
|
"@semantic-release/changelog": "^6.0.1",
|
||||||
"@semantic-release/git": "^10.0.1",
|
"@semantic-release/git": "^10.0.1",
|
||||||
|
"@types/jest": "^28.1.6",
|
||||||
"@types/milliseconds": "0.0.30",
|
"@types/milliseconds": "0.0.30",
|
||||||
"@types/node": "14.14.7",
|
"@types/node": "^16.11.7",
|
||||||
|
"@typescript-eslint/eslint-plugin": "^5.32.0",
|
||||||
|
"@typescript-eslint/parser": "^5.32.0",
|
||||||
"@zeit/ncc": "^0.20.5",
|
"@zeit/ncc": "^0.20.5",
|
||||||
"dotenv": "8.2.0",
|
"dotenv": "8.2.0",
|
||||||
"husky": "^4.3.8",
|
"eslint": "^8.21.0",
|
||||||
|
"eslint-config-prettier": "^8.5.0",
|
||||||
|
"husky": "^8.0.1",
|
||||||
|
"jest": "^28.1.3",
|
||||||
|
"lint-staged": "^13.0.3",
|
||||||
|
"prettier": "^2.7.1",
|
||||||
"semantic-release": "19.0.3",
|
"semantic-release": "19.0.3",
|
||||||
|
"ts-jest": "^28.0.7",
|
||||||
"ts-node": "9.0.0",
|
"ts-node": "9.0.0",
|
||||||
"typescript": "4.0.5"
|
"typescript": "^4.7.4",
|
||||||
|
"yaml-lint": "^1.7.0"
|
||||||
},
|
},
|
||||||
"husky": {
|
"lint-staged": {
|
||||||
"hooks": {
|
"**/*.ts": [
|
||||||
"commit-msg": "commitlint -E HUSKY_GIT_PARAMS",
|
"npm run style:base --",
|
||||||
"pre-commit": "npm run prepare && git add ."
|
"npm run lint:base --"
|
||||||
}
|
],
|
||||||
|
"**/*.{md,yaml,yml}": [
|
||||||
|
"npm run style:base --"
|
||||||
|
],
|
||||||
|
"**/*.{yaml,yml}": [
|
||||||
|
"npx yamllint "
|
||||||
|
]
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
12
sample.env
12
sample.env
@@ -1,7 +1,11 @@
|
|||||||
|
# these are the bare minimum envvars required
|
||||||
INPUT_TIMEOUT_MINUTES=1
|
INPUT_TIMEOUT_MINUTES=1
|
||||||
INPUT_MAX_ATTEMPTS=3
|
INPUT_MAX_ATTEMPTS=3
|
||||||
INPUT_COMMAND="node -e 'process.exit(99)'"
|
INPUT_COMMAND="node -e 'process.exit(99)'"
|
||||||
INPUT_RETRY_WAIT_SECONDS=10
|
INPUT_CONTINUE_ON_ERROR=false
|
||||||
SHELL=pwsh
|
|
||||||
INPUT_POLLING_INTERVAL_SECONDS=1
|
# these are optional
|
||||||
INPUT_RETRY_ON=any
|
#INPUT_RETRY_WAIT_SECONDS=10
|
||||||
|
#SHELL=pwsh
|
||||||
|
#INPUT_POLLING_INTERVAL_SECONDS=1
|
||||||
|
#INPUT_RETRY_ON=any
|
||||||
|
|||||||
181
src/index.ts
181
src/index.ts
@@ -1,144 +1,82 @@
|
|||||||
import { getInput, error, warning, info, debug, setOutput } from '@actions/core';
|
import { error, warning, info, debug, setOutput } from '@actions/core';
|
||||||
import { exec, execSync } from 'child_process';
|
import { execSync, spawn } from 'child_process';
|
||||||
import ms from 'milliseconds';
|
import ms from 'milliseconds';
|
||||||
import kill from 'tree-kill';
|
import kill from 'tree-kill';
|
||||||
|
|
||||||
import { wait } from './util';
|
import { getInputs, getTimeout, Inputs, validateInputs } from './inputs';
|
||||||
|
import { retryWait, wait } from './util';
|
||||||
// inputs
|
|
||||||
const TIMEOUT_MINUTES = getInputNumber('timeout_minutes', false);
|
|
||||||
const TIMEOUT_SECONDS = getInputNumber('timeout_seconds', false);
|
|
||||||
const MAX_ATTEMPTS = getInputNumber('max_attempts', true) || 3;
|
|
||||||
const COMMAND = getInput('command', { required: true });
|
|
||||||
const RETRY_WAIT_SECONDS = getInputNumber('retry_wait_seconds', false) || 10;
|
|
||||||
const SHELL = getInput('shell');
|
|
||||||
const POLLING_INTERVAL_SECONDS = getInputNumber('polling_interval_seconds', false) || 1;
|
|
||||||
const RETRY_ON = getInput('retry_on') || 'any';
|
|
||||||
const WARNING_ON_RETRY = getInput('warning_on_retry').toLowerCase() === 'true';
|
|
||||||
const ON_RETRY_COMMAND = getInput('on_retry_command');
|
|
||||||
const CONTINUE_ON_ERROR = getInputBoolean('continue_on_error');
|
|
||||||
const NEW_COMMAND_ON_RETRY = getInput('new_command_on_retry');
|
|
||||||
const RETRY_ON_EXIT_CODE = getInputNumber('retry_on_exit_code', false);
|
|
||||||
|
|
||||||
const OS = process.platform;
|
const OS = process.platform;
|
||||||
const OUTPUT_TOTAL_ATTEMPTS_KEY = 'total_attempts';
|
const OUTPUT_TOTAL_ATTEMPTS_KEY = 'total_attempts';
|
||||||
const OUTPUT_EXIT_CODE_KEY = 'exit_code';
|
const OUTPUT_EXIT_CODE_KEY = 'exit_code';
|
||||||
const OUTPUT_EXIT_ERROR_KEY = 'exit_error';
|
const OUTPUT_EXIT_ERROR_KEY = 'exit_error';
|
||||||
|
|
||||||
var exit: number;
|
let exit: number;
|
||||||
var done: boolean;
|
let done: boolean;
|
||||||
|
|
||||||
function getInputNumber(id: string, required: boolean): number | undefined {
|
function getExecutable(inputs: Inputs): string {
|
||||||
const input = getInput(id, { required });
|
if (!inputs.shell) {
|
||||||
const num = Number.parseInt(input);
|
return OS === 'win32' ? 'powershell' : 'bash';
|
||||||
|
|
||||||
// empty is ok
|
|
||||||
if (!input && !required) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!Number.isInteger(num)) {
|
|
||||||
throw `Input ${id} only accepts numbers. Received ${input}`;
|
|
||||||
}
|
|
||||||
|
|
||||||
return num;
|
|
||||||
}
|
|
||||||
|
|
||||||
function getInputBoolean(id: string): Boolean {
|
|
||||||
const input = getInput(id);
|
|
||||||
|
|
||||||
if (!['true','false'].includes(input.toLowerCase())) {
|
|
||||||
throw `Input ${id} only accepts boolean values. Received ${input}`;
|
|
||||||
}
|
|
||||||
return input.toLowerCase() === 'true'
|
|
||||||
}
|
|
||||||
|
|
||||||
async function retryWait() {
|
|
||||||
const waitStart = Date.now();
|
|
||||||
await wait(ms.seconds(RETRY_WAIT_SECONDS));
|
|
||||||
debug(`Waited ${Date.now() - waitStart}ms`);
|
|
||||||
debug(`Configured wait: ${ms.seconds(RETRY_WAIT_SECONDS)}ms`);
|
|
||||||
}
|
|
||||||
|
|
||||||
async function validateInputs() {
|
|
||||||
if ((!TIMEOUT_MINUTES && !TIMEOUT_SECONDS) || (TIMEOUT_MINUTES && TIMEOUT_SECONDS)) {
|
|
||||||
throw new Error('Must specify either timeout_minutes or timeout_seconds inputs');
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
function getTimeout(): number {
|
|
||||||
if (TIMEOUT_MINUTES) {
|
|
||||||
return ms.minutes(TIMEOUT_MINUTES);
|
|
||||||
} else if (TIMEOUT_SECONDS) {
|
|
||||||
return ms.seconds(TIMEOUT_SECONDS);
|
|
||||||
}
|
|
||||||
|
|
||||||
throw new Error('Must specify either timeout_minutes or timeout_seconds inputs');
|
|
||||||
}
|
|
||||||
|
|
||||||
function getExecutable(): string {
|
|
||||||
if (!SHELL) {
|
|
||||||
return OS === 'win32' ? 'powershell' : 'bash -e';
|
|
||||||
}
|
}
|
||||||
|
|
||||||
let executable: string;
|
let executable: string;
|
||||||
switch (SHELL) {
|
switch (inputs.shell) {
|
||||||
case "bash": {
|
case 'bash':
|
||||||
// -e to not ignore errors, but exit with non-zero code.
|
case 'python':
|
||||||
executable = "bash -e";
|
case 'pwsh': {
|
||||||
|
executable = inputs.shell;
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
case "python":
|
case 'sh': {
|
||||||
case "pwsh": {
|
|
||||||
executable = SHELL;
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
case "sh": {
|
|
||||||
if (OS === 'win32') {
|
if (OS === 'win32') {
|
||||||
throw new Error(`Shell ${SHELL} not allowed on OS ${OS}`);
|
throw new Error(`Shell ${inputs.shell} not allowed on OS ${OS}`);
|
||||||
}
|
}
|
||||||
executable = SHELL;
|
executable = inputs.shell;
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
case "cmd":
|
case 'cmd':
|
||||||
case "powershell": {
|
case 'powershell': {
|
||||||
if (OS !== 'win32') {
|
if (OS !== 'win32') {
|
||||||
throw new Error(`Shell ${SHELL} not allowed on OS ${OS}`);
|
throw new Error(`Shell ${inputs.shell} not allowed on OS ${OS}`);
|
||||||
}
|
}
|
||||||
executable = SHELL + ".exe";
|
executable = inputs.shell + '.exe';
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
default: {
|
default: {
|
||||||
throw new Error(`Shell ${SHELL} not supported. See https://docs.github.com/en/free-pro-team@latest/actions/reference/workflow-syntax-for-github-actions#using-a-specific-shell for supported shells`);
|
throw new Error(
|
||||||
|
`Shell ${inputs.shell} not supported. See https://docs.github.com/en/free-pro-team@latest/actions/reference/workflow-syntax-for-github-actions#using-a-specific-shell for supported shells`
|
||||||
|
);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return executable
|
return executable;
|
||||||
}
|
}
|
||||||
|
|
||||||
async function runRetryCmd(): Promise<void> {
|
async function runRetryCmd(inputs: Inputs): Promise<void> {
|
||||||
// if no retry script, just continue
|
// if no retry script, just continue
|
||||||
if (!ON_RETRY_COMMAND) {
|
if (!inputs.on_retry_command) {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
try {
|
try {
|
||||||
await execSync(ON_RETRY_COMMAND, { stdio: 'inherit' });
|
await execSync(inputs.on_retry_command, { stdio: 'inherit' });
|
||||||
} catch (error) {
|
// eslint-disable-next-line
|
||||||
info(`WARNING: Retry command threw the error ${error.message}`)
|
} catch (error: any) {
|
||||||
|
info(`WARNING: Retry command threw the error ${error.message}`);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
async function runCmd(attempt: number) {
|
async function runCmd(attempt: number, inputs: Inputs) {
|
||||||
const end_time = Date.now() + getTimeout();
|
const end_time = Date.now() + getTimeout(inputs);
|
||||||
const executable = getExecutable();
|
const executable = getExecutable(inputs);
|
||||||
|
|
||||||
exit = 0;
|
exit = 0;
|
||||||
done = false;
|
done = false;
|
||||||
|
|
||||||
debug(`Running command ${COMMAND} on ${OS} using shell "${executable}"`)
|
debug(`Running command ${inputs.command} on ${OS} using shell ${executable}`);
|
||||||
var child = attempt > 1 && NEW_COMMAND_ON_RETRY
|
const child =
|
||||||
? exec(NEW_COMMAND_ON_RETRY, { 'shell': executable })
|
attempt > 1 && inputs.new_command_on_retry
|
||||||
: exec(COMMAND, { 'shell': executable });
|
? spawn(inputs.new_command_on_retry, { shell: executable })
|
||||||
|
: spawn(inputs.command, { shell: executable });
|
||||||
|
|
||||||
child.stdout?.on('data', (data) => {
|
child.stdout?.on('data', (data) => {
|
||||||
process.stdout.write(data);
|
process.stdout.write(data);
|
||||||
@@ -161,45 +99,46 @@ async function runCmd(attempt: number) {
|
|||||||
});
|
});
|
||||||
|
|
||||||
do {
|
do {
|
||||||
await wait(ms.seconds(POLLING_INTERVAL_SECONDS));
|
await wait(ms.seconds(inputs.polling_interval_seconds));
|
||||||
} while (Date.now() < end_time && !done);
|
} while (Date.now() < end_time && !done);
|
||||||
|
|
||||||
if (!done) {
|
if (!done && child.pid) {
|
||||||
kill(child.pid);
|
kill(child.pid);
|
||||||
await retryWait();
|
await retryWait(ms.seconds(inputs.retry_wait_seconds));
|
||||||
throw new Error(`Timeout of ${getTimeout()}ms hit`);
|
throw new Error(`Timeout of ${getTimeout(inputs)}ms hit`);
|
||||||
} else if (exit > 0) {
|
} else if (exit > 0) {
|
||||||
await retryWait();
|
await retryWait(ms.seconds(inputs.retry_wait_seconds));
|
||||||
throw new Error(`Child_process exited with error code ${exit}`);
|
throw new Error(`Child_process exited with error code ${exit}`);
|
||||||
} else {
|
} else {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
async function runAction() {
|
async function runAction(inputs: Inputs) {
|
||||||
await validateInputs();
|
await validateInputs(inputs);
|
||||||
|
|
||||||
for (let attempt = 1; attempt <= MAX_ATTEMPTS; attempt++) {
|
for (let attempt = 1; attempt <= inputs.max_attempts; attempt++) {
|
||||||
try {
|
try {
|
||||||
// just keep overwriting attempts output
|
// just keep overwriting attempts output
|
||||||
setOutput(OUTPUT_TOTAL_ATTEMPTS_KEY, attempt);
|
setOutput(OUTPUT_TOTAL_ATTEMPTS_KEY, attempt);
|
||||||
await runCmd(attempt);
|
await runCmd(attempt, inputs);
|
||||||
info(`Command completed after ${attempt} attempt(s).`);
|
info(`Command completed after ${attempt} attempt(s).`);
|
||||||
break;
|
break;
|
||||||
} catch (error) {
|
// eslint-disable-next-line
|
||||||
if (attempt === MAX_ATTEMPTS) {
|
} catch (error: any) {
|
||||||
|
if (attempt === inputs.max_attempts) {
|
||||||
throw new Error(`Final attempt failed. ${error.message}`);
|
throw new Error(`Final attempt failed. ${error.message}`);
|
||||||
} else if (!done && RETRY_ON === 'error') {
|
} else if (!done && inputs.retry_on === 'error') {
|
||||||
// error: timeout
|
// error: timeout
|
||||||
throw error;
|
throw error;
|
||||||
} else if (RETRY_ON_EXIT_CODE && RETRY_ON_EXIT_CODE !== exit){
|
} else if (inputs.retry_on_exit_code && inputs.retry_on_exit_code !== exit) {
|
||||||
throw error;
|
throw error;
|
||||||
} else if (exit > 0 && RETRY_ON === 'timeout') {
|
} else if (exit > 0 && inputs.retry_on === 'timeout') {
|
||||||
// error: error
|
// error: error
|
||||||
throw error;
|
throw error;
|
||||||
} else {
|
} else {
|
||||||
await runRetryCmd();
|
await runRetryCmd(inputs);
|
||||||
if (WARNING_ON_RETRY) {
|
if (inputs.warning_on_retry) {
|
||||||
warning(`Attempt ${attempt} failed. Reason: ${error.message}`);
|
warning(`Attempt ${attempt} failed. Reason: ${error.message}`);
|
||||||
} else {
|
} else {
|
||||||
info(`Attempt ${attempt} failed. Reason: ${error.message}`);
|
info(`Attempt ${attempt} failed. Reason: ${error.message}`);
|
||||||
@@ -209,7 +148,9 @@ async function runAction() {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
runAction()
|
const inputs = getInputs();
|
||||||
|
|
||||||
|
runAction(inputs)
|
||||||
.then(() => {
|
.then(() => {
|
||||||
setOutput(OUTPUT_EXIT_CODE_KEY, 0);
|
setOutput(OUTPUT_EXIT_CODE_KEY, 0);
|
||||||
process.exit(0); // success
|
process.exit(0); // success
|
||||||
@@ -218,7 +159,7 @@ runAction()
|
|||||||
// exact error code if available, otherwise just 1
|
// exact error code if available, otherwise just 1
|
||||||
const exitCode = exit > 0 ? exit : 1;
|
const exitCode = exit > 0 ? exit : 1;
|
||||||
|
|
||||||
if (CONTINUE_ON_ERROR) {
|
if (inputs.continue_on_error) {
|
||||||
warning(err.message);
|
warning(err.message);
|
||||||
} else {
|
} else {
|
||||||
error(err.message);
|
error(err.message);
|
||||||
@@ -230,5 +171,5 @@ runAction()
|
|||||||
|
|
||||||
// if continue_on_error, exit with exact error code else exit gracefully
|
// if continue_on_error, exit with exact error code else exit gracefully
|
||||||
// mimics native continue-on-error that is not supported in composite actions
|
// mimics native continue-on-error that is not supported in composite actions
|
||||||
process.exit(CONTINUE_ON_ERROR ? 0 : exitCode);
|
process.exit(inputs.continue_on_error ? 0 : exitCode);
|
||||||
});
|
});
|
||||||
|
|||||||
94
src/inputs.ts
Normal file
94
src/inputs.ts
Normal file
@@ -0,0 +1,94 @@
|
|||||||
|
import { getInput } from '@actions/core';
|
||||||
|
import ms from 'milliseconds';
|
||||||
|
|
||||||
|
export interface Inputs {
|
||||||
|
timeout_minutes: number | undefined;
|
||||||
|
timeout_seconds: number | undefined;
|
||||||
|
max_attempts: number;
|
||||||
|
command: string;
|
||||||
|
retry_wait_seconds: number;
|
||||||
|
shell: string | undefined;
|
||||||
|
polling_interval_seconds: number;
|
||||||
|
retry_on: string | undefined;
|
||||||
|
warning_on_retry: boolean;
|
||||||
|
on_retry_command: string | undefined;
|
||||||
|
continue_on_error: boolean;
|
||||||
|
new_command_on_retry: string | undefined;
|
||||||
|
retry_on_exit_code: number | undefined;
|
||||||
|
}
|
||||||
|
|
||||||
|
export function getInputNumber(id: string, required: boolean): number | undefined {
|
||||||
|
const input = getInput(id, { required });
|
||||||
|
const num = Number.parseInt(input);
|
||||||
|
|
||||||
|
// empty is ok
|
||||||
|
if (!input && !required) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!Number.isInteger(num)) {
|
||||||
|
throw `Input ${id} only accepts numbers. Received ${input}`;
|
||||||
|
}
|
||||||
|
|
||||||
|
return num;
|
||||||
|
}
|
||||||
|
|
||||||
|
export function getInputBoolean(id: string): boolean {
|
||||||
|
const input = getInput(id);
|
||||||
|
|
||||||
|
if (!['true', 'false'].includes(input.toLowerCase())) {
|
||||||
|
throw `Input ${id} only accepts boolean values. Received ${input}`;
|
||||||
|
}
|
||||||
|
return input.toLowerCase() === 'true';
|
||||||
|
}
|
||||||
|
|
||||||
|
export async function validateInputs(inputs: Inputs) {
|
||||||
|
if (
|
||||||
|
(!inputs.timeout_minutes && !inputs.timeout_seconds) ||
|
||||||
|
(inputs.timeout_minutes && inputs.timeout_seconds)
|
||||||
|
) {
|
||||||
|
throw new Error('Must specify either timeout_minutes or timeout_seconds inputs');
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
export function getTimeout(inputs: Inputs): number {
|
||||||
|
if (inputs.timeout_minutes) {
|
||||||
|
return ms.minutes(inputs.timeout_minutes);
|
||||||
|
} else if (inputs.timeout_seconds) {
|
||||||
|
return ms.seconds(inputs.timeout_seconds);
|
||||||
|
}
|
||||||
|
|
||||||
|
throw new Error('Must specify either timeout_minutes or timeout_seconds inputs');
|
||||||
|
}
|
||||||
|
|
||||||
|
export function getInputs(): Inputs {
|
||||||
|
const timeout_minutes = getInputNumber('timeout_minutes', false);
|
||||||
|
const timeout_seconds = getInputNumber('timeout_seconds', false);
|
||||||
|
const max_attempts = getInputNumber('max_attempts', true) || 3;
|
||||||
|
const command = getInput('command', { required: true });
|
||||||
|
const retry_wait_seconds = getInputNumber('retry_wait_seconds', false) || 10;
|
||||||
|
const shell = getInput('shell');
|
||||||
|
const polling_interval_seconds = getInputNumber('polling_interval_seconds', false) || 1;
|
||||||
|
const retry_on = getInput('retry_on') || 'any';
|
||||||
|
const warning_on_retry = getInput('warning_on_retry').toLowerCase() === 'true';
|
||||||
|
const on_retry_command = getInput('on_retry_command');
|
||||||
|
const continue_on_error = getInputBoolean('continue_on_error');
|
||||||
|
const new_command_on_retry = getInput('new_command_on_retry');
|
||||||
|
const retry_on_exit_code = getInputNumber('retry_on_exit_code', false);
|
||||||
|
|
||||||
|
return {
|
||||||
|
timeout_minutes,
|
||||||
|
timeout_seconds,
|
||||||
|
max_attempts,
|
||||||
|
command,
|
||||||
|
retry_wait_seconds,
|
||||||
|
shell,
|
||||||
|
polling_interval_seconds,
|
||||||
|
retry_on,
|
||||||
|
warning_on_retry,
|
||||||
|
on_retry_command,
|
||||||
|
continue_on_error,
|
||||||
|
new_command_on_retry,
|
||||||
|
retry_on_exit_code,
|
||||||
|
};
|
||||||
|
}
|
||||||
17
src/util.test.ts
Normal file
17
src/util.test.ts
Normal file
@@ -0,0 +1,17 @@
|
|||||||
|
import 'jest';
|
||||||
|
import { getHeapStatistics } from 'v8';
|
||||||
|
|
||||||
|
import { wait } from './util';
|
||||||
|
|
||||||
|
// mocks the setTimeout function, see https://jestjs.io/docs/timer-mocks
|
||||||
|
jest.useFakeTimers();
|
||||||
|
jest.spyOn(global, 'setTimeout');
|
||||||
|
|
||||||
|
describe('util', () => {
|
||||||
|
test('wait', async () => {
|
||||||
|
const waitTime = 1000;
|
||||||
|
wait(waitTime);
|
||||||
|
expect(setTimeout).toHaveBeenCalledTimes(1);
|
||||||
|
expect(setTimeout).toHaveBeenLastCalledWith(expect.any(Function), waitTime);
|
||||||
|
});
|
||||||
|
});
|
||||||
@@ -1,3 +1,12 @@
|
|||||||
|
import { debug } from '@actions/core';
|
||||||
|
|
||||||
export async function wait(ms: number) {
|
export async function wait(ms: number) {
|
||||||
return new Promise((r) => setTimeout(r, ms));
|
return new Promise((r) => setTimeout(r, ms));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
export async function retryWait(retryWaitSeconds: number) {
|
||||||
|
const waitStart = Date.now();
|
||||||
|
await wait(retryWaitSeconds);
|
||||||
|
debug(`Waited ${Date.now() - waitStart}ms`);
|
||||||
|
debug(`Configured wait: ${retryWaitSeconds}ms`);
|
||||||
|
}
|
||||||
|
|||||||
13
test-data/large-output/Makefile
Normal file
13
test-data/large-output/Makefile
Normal file
@@ -0,0 +1,13 @@
|
|||||||
|
SHELL = bash
|
||||||
|
|
||||||
|
# this tests fix for the following issues
|
||||||
|
# https://github.com/nick-fields/retry/issues/76
|
||||||
|
# https://github.com/nick-fields/retry/issues/84
|
||||||
|
|
||||||
|
bytes-%:
|
||||||
|
for i in {1..$*}; do cat kibibyte.txt; done; exit 2
|
||||||
|
.PHONY: bytes-%
|
||||||
|
|
||||||
|
lines-%:
|
||||||
|
for i in {1..$*}; do echo a; done; exit 2
|
||||||
|
.PHONY: lines-%
|
||||||
13
test-data/large-output/kibibyte.txt
Normal file
13
test-data/large-output/kibibyte.txt
Normal file
@@ -0,0 +1,13 @@
|
|||||||
|
1: 0000 aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa
|
||||||
|
2: 0081 aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa
|
||||||
|
3: 0162 aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa
|
||||||
|
4: 243 aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa
|
||||||
|
5: 324 aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa
|
||||||
|
6: 405 aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa
|
||||||
|
7: 486 aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa
|
||||||
|
8: 567 aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa
|
||||||
|
9: 648 aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa
|
||||||
|
a: 729 aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa
|
||||||
|
b: 810 aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa
|
||||||
|
c: 891 aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa
|
||||||
|
d: 972 aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa
|
||||||
Reference in New Issue
Block a user