mirror of
https://github.com/sasjs/adapter.git
synced 2026-04-15 02:13:13 +00:00
Compare commits
39 Commits
v4.15.0
...
fix/bump_a
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
38d84e56d4 | ||
|
|
180e2ef425 | ||
|
|
9177dce3e1 | ||
|
|
9f4064b46e | ||
|
|
44c5eab638 | ||
|
|
0f9f16bef1 | ||
|
|
5c61ede51a | ||
|
|
fccb3ab965 | ||
|
|
b92487819a | ||
|
|
3cc37e0b5b | ||
|
|
d87b9ecc34 | ||
|
|
3b00ae4bef | ||
|
|
87efdfff2e | ||
|
|
73556c9fdf | ||
|
|
72318ced00 | ||
|
|
d7053ba628 | ||
|
|
52371da4db | ||
|
|
8e8efd22e9 | ||
|
|
f80d0c87f9 | ||
|
|
5bd641b843 | ||
|
|
539fe5f4ed | ||
|
|
9252e7e384 | ||
|
|
bbf0eed443 | ||
|
|
677c0a5046 | ||
|
|
ff927caf73 | ||
|
|
e23aa4426c | ||
|
|
8064a843e8 | ||
|
|
d45b528846 | ||
|
|
cd64ebc518 | ||
|
|
8246722ae8 | ||
|
|
0f8a3f4b53 | ||
|
|
ca9ffdbc17 | ||
|
|
03b7592521 | ||
|
|
ba64ed1f20 | ||
|
|
480510b980 | ||
|
|
8c7767a36d | ||
|
|
f335be344e | ||
|
|
680f5a4872 | ||
|
|
c42a20a8ee |
1
.gitattributes
vendored
Normal file
1
.gitattributes
vendored
Normal file
@@ -0,0 +1 @@
|
|||||||
|
* text=auto eol=lf
|
||||||
8
.github/workflows/build-unit-tests.yml
vendored
8
.github/workflows/build-unit-tests.yml
vendored
@@ -11,8 +11,9 @@ jobs:
|
|||||||
runs-on: ubuntu-22.04
|
runs-on: ubuntu-22.04
|
||||||
|
|
||||||
strategy:
|
strategy:
|
||||||
|
fail-fast: false
|
||||||
matrix:
|
matrix:
|
||||||
node-version: [lts/hydrogen]
|
node-version: [20, 22, 24]
|
||||||
|
|
||||||
steps:
|
steps:
|
||||||
- uses: actions/checkout@v2
|
- uses: actions/checkout@v2
|
||||||
@@ -21,7 +22,7 @@ jobs:
|
|||||||
with:
|
with:
|
||||||
node-version: ${{ matrix.node-version }}
|
node-version: ${{ matrix.node-version }}
|
||||||
|
|
||||||
# 2. Restore npm cache manually
|
# 2. Restore npm cache manually
|
||||||
- name: Restore npm cache
|
- name: Restore npm cache
|
||||||
uses: actions/cache@v3
|
uses: actions/cache@v3
|
||||||
id: npm-cache
|
id: npm-cache
|
||||||
@@ -32,7 +33,7 @@ jobs:
|
|||||||
${{ runner.os }}-node-
|
${{ runner.os }}-node-
|
||||||
|
|
||||||
- name: Check npm audit
|
- name: Check npm audit
|
||||||
run: npm audit --production --audit-level=low
|
run: npm audit --omit=dev --audit-level=low
|
||||||
|
|
||||||
- name: Install Dependencies
|
- name: Install Dependencies
|
||||||
run: npm ci
|
run: npm ci
|
||||||
@@ -53,6 +54,7 @@ jobs:
|
|||||||
|
|
||||||
# For some reason if coverage report action is run before other commands, those commands can't access the directories and files on which they depend on
|
# For some reason if coverage report action is run before other commands, those commands can't access the directories and files on which they depend on
|
||||||
- name: Generate coverage report
|
- name: Generate coverage report
|
||||||
|
if: matrix.node-version == 22
|
||||||
uses: artiomtr/jest-coverage-report-action@v2.0-rc.2
|
uses: artiomtr/jest-coverage-report-action@v2.0-rc.2
|
||||||
with:
|
with:
|
||||||
github-token: ${{ secrets.GITHUB_TOKEN }}
|
github-token: ${{ secrets.GITHUB_TOKEN }}
|
||||||
|
|||||||
8
.github/workflows/generateDocs.yml
vendored
8
.github/workflows/generateDocs.yml
vendored
@@ -11,7 +11,7 @@ jobs:
|
|||||||
|
|
||||||
strategy:
|
strategy:
|
||||||
matrix:
|
matrix:
|
||||||
node-version: [lts/hydrogen]
|
node-version: [22]
|
||||||
|
|
||||||
steps:
|
steps:
|
||||||
- name: Checkout
|
- name: Checkout
|
||||||
@@ -20,9 +20,10 @@ jobs:
|
|||||||
- name: Setup Node
|
- name: Setup Node
|
||||||
uses: actions/setup-node@v2
|
uses: actions/setup-node@v2
|
||||||
with:
|
with:
|
||||||
node-version: ${{ matrix.node-version }}
|
node-version:
|
||||||
|
${{ matrix.node-version }}
|
||||||
|
|
||||||
# 2. Restore npm cache manually
|
# 2. Restore npm cache manually
|
||||||
- name: Restore npm cache
|
- name: Restore npm cache
|
||||||
uses: actions/cache@v3
|
uses: actions/cache@v3
|
||||||
id: npm-cache
|
id: npm-cache
|
||||||
@@ -50,4 +51,3 @@ jobs:
|
|||||||
publish_branch: gh-pages
|
publish_branch: gh-pages
|
||||||
publish_dir: ./docs
|
publish_dir: ./docs
|
||||||
cname: adapter.sasjs.io
|
cname: adapter.sasjs.io
|
||||||
|
|
||||||
|
|||||||
7
.github/workflows/npmpublish.yml
vendored
7
.github/workflows/npmpublish.yml
vendored
@@ -14,7 +14,7 @@ jobs:
|
|||||||
|
|
||||||
strategy:
|
strategy:
|
||||||
matrix:
|
matrix:
|
||||||
node-version: [lts/hydrogen]
|
node-version: [22]
|
||||||
|
|
||||||
steps:
|
steps:
|
||||||
- uses: actions/checkout@v2
|
- uses: actions/checkout@v2
|
||||||
@@ -23,7 +23,7 @@ jobs:
|
|||||||
with:
|
with:
|
||||||
node-version: ${{ matrix.node-version }}
|
node-version: ${{ matrix.node-version }}
|
||||||
|
|
||||||
# 2. Restore npm cache manually
|
# 2. Restore npm cache manually
|
||||||
- name: Restore npm cache
|
- name: Restore npm cache
|
||||||
uses: actions/cache@v3
|
uses: actions/cache@v3
|
||||||
id: npm-cache
|
id: npm-cache
|
||||||
@@ -42,6 +42,9 @@ jobs:
|
|||||||
- name: Build Project
|
- name: Build Project
|
||||||
run: npm run build
|
run: npm run build
|
||||||
|
|
||||||
|
- name: Clean up ready for publishing
|
||||||
|
run: npm run publishInit
|
||||||
|
|
||||||
- name: Semantic Release
|
- name: Semantic Release
|
||||||
uses: cycjimmy/semantic-release-action@v3
|
uses: cycjimmy/semantic-release-action@v3
|
||||||
env:
|
env:
|
||||||
|
|||||||
230
.github/workflows/server-tests.yml
vendored
230
.github/workflows/server-tests.yml
vendored
@@ -1,107 +1,123 @@
|
|||||||
# This workflow will do a clean install of node dependencies, build the source code and run tests across different versions of node
|
# This workflow will do a clean install of node dependencies, build the source code and run tests across different versions of node
|
||||||
# For more information see: https://help.github.com/actions/language-and-framework-guides/using-nodejs-with-github-actions
|
# For more information see: https://help.github.com/actions/language-and-framework-guides/using-nodejs-with-github-actions
|
||||||
|
|
||||||
name: SASjs Build and Server Tests
|
name: SASjs Build and Server Tests
|
||||||
|
|
||||||
on:
|
on:
|
||||||
pull_request:
|
pull_request:
|
||||||
|
|
||||||
jobs:
|
jobs:
|
||||||
test:
|
test:
|
||||||
runs-on: ubuntu-22.04
|
runs-on: ubuntu-22.04
|
||||||
|
|
||||||
strategy:
|
strategy:
|
||||||
matrix:
|
matrix:
|
||||||
node-version: [lts/hydrogen]
|
node-version: [22]
|
||||||
|
|
||||||
steps:
|
steps:
|
||||||
- uses: actions/checkout@v2
|
- uses: actions/checkout@v2
|
||||||
- name: Use Node.js ${{ matrix.node-version }}
|
- name: Use Node.js ${{ matrix.node-version }}
|
||||||
uses: actions/setup-node@v2
|
uses: actions/setup-node@v2
|
||||||
with:
|
with:
|
||||||
node-version: ${{ matrix.node-version }}
|
node-version: ${{ matrix.node-version }}
|
||||||
|
|
||||||
# 2. Restore npm cache manually
|
# 2. Restore npm cache manually
|
||||||
- name: Restore npm cache
|
- name: Restore npm cache
|
||||||
uses: actions/cache@v3
|
uses: actions/cache@v3
|
||||||
id: npm-cache
|
id: npm-cache
|
||||||
with:
|
with:
|
||||||
path: ~/.npm
|
path: |
|
||||||
key: ${{ runner.os }}-node-${{ hashFiles('**/package-lock.json') }}
|
~/.npm
|
||||||
restore-keys: |
|
key: ${{ runner.os }}-node-${{ hashFiles('**/package-lock.json') }}
|
||||||
${{ runner.os }}-node-
|
restore-keys: |
|
||||||
|
${{ runner.os }}-node-
|
||||||
- name: Install Dependencies
|
|
||||||
run: npm ci
|
- name: Cache Cypress binary
|
||||||
|
uses: actions/cache@v3
|
||||||
- name: Install Rimraf
|
with:
|
||||||
run: npm i rimraf
|
path: ~/.cache/Cypress
|
||||||
|
key: cypress-${{ runner.os }}-${{ hashFiles('**/package-lock.json') }}
|
||||||
- name: Build Package
|
restore-keys: |
|
||||||
run: npm run package:lib
|
cypress-${{ runner.os }}-
|
||||||
env:
|
|
||||||
CI: true
|
- name: Install Dependencies
|
||||||
|
run: npm ci
|
||||||
- name: Write VPN Files
|
|
||||||
run: |
|
- name: Install Cypress binary
|
||||||
echo "$CA_CRT" > .github/vpn/ca.crt
|
run: npx cypress install
|
||||||
echo "$USER_CRT" > .github/vpn/user.crt
|
|
||||||
echo "$USER_KEY" > .github/vpn/user.key
|
- name: Install Rimraf
|
||||||
echo "$TLS_KEY" > .github/vpn/tls.key
|
run: npm i rimraf
|
||||||
shell: bash
|
|
||||||
env:
|
- name: Build Package
|
||||||
CA_CRT: ${{ secrets.CA_CRT}}
|
run: npm run package:lib
|
||||||
USER_CRT: ${{ secrets.USER_CRT }}
|
env:
|
||||||
USER_KEY: ${{ secrets.USER_KEY }}
|
CI: true
|
||||||
TLS_KEY: ${{ secrets.TLS_KEY }}
|
|
||||||
|
- name: Write VPN Files
|
||||||
- name: Chmod VPN files
|
run: |
|
||||||
run: |
|
echo "$CA_CRT" > .github/vpn/ca.crt
|
||||||
chmod 600 .github/vpn/ca.crt .github/vpn/user.crt .github/vpn/user.key .github/vpn/tls.key
|
echo "$USER_CRT" > .github/vpn/user.crt
|
||||||
|
echo "$USER_KEY" > .github/vpn/user.key
|
||||||
- name: Install Open VPN
|
echo "$TLS_KEY" > .github/vpn/tls.key
|
||||||
run: |
|
shell: bash
|
||||||
sudo apt install apt-transport-https
|
env:
|
||||||
sudo wget https://swupdate.openvpn.net/repos/openvpn-repo-pkg-key.pub
|
CA_CRT: ${{ secrets.CA_CRT}}
|
||||||
sudo apt-key add openvpn-repo-pkg-key.pub
|
USER_CRT: ${{ secrets.USER_CRT }}
|
||||||
sudo wget -O /etc/apt/sources.list.d/openvpn3.list https://swupdate.openvpn.net/community/openvpn3/repos/openvpn3-jammy.list
|
USER_KEY: ${{ secrets.USER_KEY }}
|
||||||
sudo apt update
|
TLS_KEY: ${{ secrets.TLS_KEY }}
|
||||||
sudo apt install openvpn3=17~betaUb22042+jammy
|
|
||||||
|
- name: Chmod VPN files
|
||||||
- name: Start Open VPN 3
|
run: |
|
||||||
run: openvpn3 session-start --config .github/vpn/config.ovpn
|
chmod 600 .github/vpn/ca.crt .github/vpn/user.crt .github/vpn/user.key .github/vpn/tls.key
|
||||||
|
|
||||||
- name: install pm2
|
- name: Install Open VPN
|
||||||
run: npm i -g pm2
|
run: |
|
||||||
|
sudo apt install apt-transport-https
|
||||||
- name: Fetch SASJS server
|
sudo wget https://swupdate.openvpn.net/repos/openvpn-repo-pkg-key.pub
|
||||||
run: curl ${{ secrets.SASJS_SERVER_URL }}/SASjsApi/info
|
sudo apt-key add openvpn-repo-pkg-key.pub
|
||||||
|
sudo wget -O /etc/apt/sources.list.d/openvpn3.list https://swupdate.openvpn.net/community/openvpn3/repos/openvpn3-jammy.list
|
||||||
- name: Deploy sasjs-tests
|
sudo apt update
|
||||||
run: |
|
sudo apt install openvpn3=17~betaUb22042+jammy
|
||||||
npm install -g replace-in-files-cli
|
|
||||||
cd sasjs-tests
|
- name: Start Open VPN 3
|
||||||
replace-in-files --regex='"@sasjs/adapter".*' --replacement='"@sasjs/adapter":"latest",' ./package.json
|
run: openvpn3 session-start --config .github/vpn/config.ovpn
|
||||||
npm i
|
|
||||||
replace-in-files --regex='"serverUrl".*' --replacement='"serverUrl":"${{ secrets.SASJS_SERVER_URL }}",' ./public/config.json
|
- name: install pm2
|
||||||
replace-in-files --regex='"userName".*' --replacement='"userName":"${{ secrets.SASJS_USERNAME }}",' ./public/config.json
|
run: npm i -g pm2
|
||||||
replace-in-files --regex='"serverType".*' --replacement='"serverType":"SASJS",' ./public/config.json
|
|
||||||
replace-in-files --regex='"password".*' --replacement='"password":"${{ secrets.SASJS_PASSWORD }}",' ./public/config.json
|
- name: Fetch SASJS server
|
||||||
cat ./public/config.json
|
run: curl ${{ secrets.SASJS_SERVER_URL }}/SASjsApi/info
|
||||||
|
|
||||||
npm run update:adapter
|
- name: Deploy sasjs-tests
|
||||||
pm2 start --name sasjs-test npm -- start
|
run: |
|
||||||
|
sudo apt install jq
|
||||||
- name: Sleep for 10 seconds
|
cd sasjs-tests
|
||||||
run: sleep 10s
|
npm i --ignore-scripts
|
||||||
shell: bash
|
npm i ../build/sasjs-adapter-5.0.0.tgz
|
||||||
|
jq '.sasJsConfig.serverUrl |= "${{ secrets.SASJS_SERVER_URL }}"' ./public/config.json > ./public/config.temp && mv ./public/config.temp ./public/config.json
|
||||||
- name: Run cypress on sasjs
|
jq '.sasJsConfig.serverType |= "SASJS"' ./public/config.json > ./public/config.temp && mv ./public/config.temp ./public/config.json
|
||||||
run: |
|
jq '.sasJsConfig.loginMechanism |= "Default"' ./public/config.json > ./public/config.temp && mv ./public/config.temp ./public/config.json
|
||||||
replace-in-files --regex='"sasjsTestsUrl".*' --replacement='"sasjsTestsUrl":"http://localhost:3000",' ./cypress.json
|
jq '.userName |= "${{ secrets.SASJS_USERNAME }}"' ./public/config.json > ./public/config.temp && mv ./public/config.temp ./public/config.json
|
||||||
replace-in-files --regex='"username".*' --replacement='"username":"${{ secrets.SASJS_USERNAME }}",' ./cypress.json
|
jq '.password |= "${{ secrets.SASJS_PASSWORD }}"' ./public/config.json > ./public/config.temp && mv ./public/config.temp ./public/config.json
|
||||||
replace-in-files --regex='"password".*' --replacement='"password":"${{ secrets.SASJS_PASSWORD }}",' ./cypress.json
|
|
||||||
cat ./cypress.json
|
cat ./public/config.json
|
||||||
echo "SASJS_USERNAME=${{ secrets.SASJS_USERNAME }}"
|
|
||||||
|
npm run update:adapter
|
||||||
sh ./sasjs-tests/sasjs-cypress-run.sh ${{ secrets.MATRIX_TOKEN }} https://github.com/${{github.repository}}/actions/runs/${{github.run_id}}
|
pm2 start --name sasjs-test npm -- start
|
||||||
|
|
||||||
|
- name: Sleep for 10 seconds
|
||||||
|
run: sleep 10s
|
||||||
|
shell: bash
|
||||||
|
|
||||||
|
- name: Run cypress on sasjs
|
||||||
|
env:
|
||||||
|
TERM: dumb
|
||||||
|
run: |
|
||||||
|
sed -i "s|sasjsTestsUrl: '.*'|sasjsTestsUrl: 'http://localhost:3000'|g" ./cypress.config.js
|
||||||
|
sed -i "s|username: '.*'|username: '${{ secrets.SASJS_USERNAME }}'|g" ./cypress.config.js
|
||||||
|
sed -i "s|password: '.*'|password: '${{ secrets.SASJS_PASSWORD }}'|g" ./cypress.config.js
|
||||||
|
cat ./cypress.config.js
|
||||||
|
echo "SASJS_USERNAME=${{ secrets.SASJS_USERNAME }}"
|
||||||
|
|
||||||
|
sh ./sasjs-tests/sasjs-cypress-run.sh ${{ secrets.MATRIX_TOKEN }} https://github.com/${{github.repository}}/actions/runs/${{github.run_id}}
|
||||||
|
|||||||
@@ -1,2 +0,0 @@
|
|||||||
tasks:
|
|
||||||
- init: npm install && npm run build
|
|
||||||
18
cypress.config.js
Normal file
18
cypress.config.js
Normal file
@@ -0,0 +1,18 @@
|
|||||||
|
const { defineConfig } = require('cypress')
|
||||||
|
|
||||||
|
module.exports = defineConfig({
|
||||||
|
e2e: {
|
||||||
|
includeShadowDom: true,
|
||||||
|
chromeWebSecurity: false,
|
||||||
|
defaultCommandTimeout: 20000,
|
||||||
|
specPattern: 'cypress/integration/**/*.ts',
|
||||||
|
supportFile: 'cypress/support/index.js'
|
||||||
|
},
|
||||||
|
env: {
|
||||||
|
sasjsTestsUrl: 'http://localhost:3000',
|
||||||
|
username: '',
|
||||||
|
password: '',
|
||||||
|
screenshotOnRunFailure: false,
|
||||||
|
testingFinishTimeout: 600000
|
||||||
|
}
|
||||||
|
})
|
||||||
11
cypress.json
11
cypress.json
@@ -1,11 +0,0 @@
|
|||||||
{
|
|
||||||
"chromeWebSecurity": false,
|
|
||||||
"defaultCommandTimeout": 20000,
|
|
||||||
"env": {
|
|
||||||
"sasjsTestsUrl": "",
|
|
||||||
"username": "",
|
|
||||||
"password": "",
|
|
||||||
"screenshotOnRunFailure": false,
|
|
||||||
"testingFinishTimeout": 600000
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@@ -9,10 +9,12 @@ context('sasjs-tests', function () {
|
|||||||
})
|
})
|
||||||
|
|
||||||
beforeEach(() => {
|
beforeEach(() => {
|
||||||
cy.reload()
|
cy.visit(sasjsTestsUrl)
|
||||||
})
|
})
|
||||||
|
|
||||||
function loginIfNeeded() {
|
function loginIfNeeded() {
|
||||||
|
cy.get('login-form, tests-view', { timeout: 30000 }).should('exist')
|
||||||
|
|
||||||
cy.get('body').then(($body) => {
|
cy.get('body').then(($body) => {
|
||||||
if ($body.find('login-form').length > 0) {
|
if ($body.find('login-form').length > 0) {
|
||||||
cy.get('login-form')
|
cy.get('login-form')
|
||||||
|
|||||||
556
package-lock.json
generated
556
package-lock.json
generated
File diff suppressed because it is too large
Load Diff
19
package.json
19
package.json
@@ -4,17 +4,14 @@
|
|||||||
"homepage": "https://adapter.sasjs.io",
|
"homepage": "https://adapter.sasjs.io",
|
||||||
"scripts": {
|
"scripts": {
|
||||||
"nodeVersionMessage": "echo \u001b[33m make sure you are running node lts version \u001b[0m",
|
"nodeVersionMessage": "echo \u001b[33m make sure you are running node lts version \u001b[0m",
|
||||||
"preinstall": "npm run nodeVersionMessage",
|
"build": "npm run nodeVersionMessage && npx rimraf build && npx rimraf node && mkdir node && copyfiles -u 1 \"./src/**/*\" ./node && webpack && npx rimraf build/src && npx rimraf node",
|
||||||
"prebuild": "npm run nodeVersionMessage",
|
|
||||||
"build": "npx rimraf build && npx rimraf node && mkdir node && copyfiles -u 1 \"./src/**/*\" ./node && webpack && npx rimraf build/src && npx rimraf node",
|
|
||||||
"package:lib": "npm run build && copyfiles ./package.json build && cd build && npm version \"5.0.0\" && npm pack",
|
"package:lib": "npm run build && copyfiles ./package.json build && cd build && npm version \"5.0.0\" && npm pack",
|
||||||
"publish:lib": "npm run build && cd build && npm publish",
|
"publish:lib": "npm run build && cd build && npm publish",
|
||||||
"lint:fix": "npx prettier --loglevel silent --write \"src/**/*.{ts,tsx,js,jsx,html,css,sass,less,json,yml,md,graphql}\" && npx prettier --loglevel silent --write \"sasjs-tests/src/**/*.{ts,tsx,js,jsx,html,css,sass,less,json,yml,md,graphql}\" && npx prettier --loglevel silent --write \"cypress/**/*.{ts,tsx,js,jsx,html,css,sass,less,json,yml,md,graphql}\"",
|
"lint:fix": "npx prettier --log-level silent --write \"src/**/*.{ts,tsx,js,jsx,html,css,sass,less,json,yml,md,graphql}\" && npx prettier --log-level silent --write \"sasjs-tests/src/**/*.{ts,tsx,js,jsx,html,css,sass,less,json,yml,md,graphql}\" && npx prettier --log-level silent --write \"cypress/**/*.{ts,tsx,js,jsx,html,css,sass,less,json,yml,md,graphql}\"",
|
||||||
"lint": "npx prettier --check \"src/**/*.{ts,tsx,js,jsx,html,css,sass,less,json,yml,md,graphql}\" && npx prettier --check \"sasjs-tests/src/**/*.{ts,tsx,js,jsx,html,css,sass,less,json,yml,md,graphql}\" && npx prettier --check \"cypress/**/*.{ts,tsx,js,jsx,html,css,sass,less,json,yml,md,graphql}\"",
|
"lint": "npx prettier --check \"src/**/*.{ts,tsx,js,jsx,html,css,sass,less,json,yml,md,graphql}\" && npx prettier --check \"sasjs-tests/src/**/*.{ts,tsx,js,jsx,html,css,sass,less,json,yml,md,graphql}\" && npx prettier --check \"cypress/**/*.{ts,tsx,js,jsx,html,css,sass,less,json,yml,md,graphql}\"",
|
||||||
"lint:silent": "npx prettier --loglevel silent --check \"src/**/*.{ts,tsx,js,jsx,html,css,sass,less,json,yml,md,graphql}\" && npx prettier --loglevel silent --check \"sasjs-tests/src/**/*.{ts,tsx,js,jsx,html,css,sass,less,json,yml,md,graphql}\" && npx prettier --loglevel silent --check \"cypress/**/*.{ts,tsx,js,jsx,html,css,sass,less,json,yml,md,graphql}\"",
|
"lint:silent": "npx prettier --log-level silent --check \"src/**/*.{ts,tsx,js,jsx,html,css,sass,less,json,yml,md,graphql}\" && npx prettier --log-level silent --check \"sasjs-tests/src/**/*.{ts,tsx,js,jsx,html,css,sass,less,json,yml,md,graphql}\" && npx prettier --log-level silent --check \"cypress/**/*.{ts,tsx,js,jsx,html,css,sass,less,json,yml,md,graphql}\"",
|
||||||
"test": "jest --silent --coverage",
|
"test": "jest --silent --coverage",
|
||||||
"prepublishOnly": "cp -r ./build/* . && rm -rf ./build",
|
"publishInit": "cp -r ./build/* . && rm -rf ./build",
|
||||||
"postpublish": "git clean -fd",
|
|
||||||
"semantic-release": "semantic-release",
|
"semantic-release": "semantic-release",
|
||||||
"typedoc": "node createTSDocs",
|
"typedoc": "node createTSDocs",
|
||||||
"prepare": "git rev-parse --git-dir && git config core.hooksPath ./.git-hooks && git config core.autocrlf false || true",
|
"prepare": "git rev-parse --git-dir && git config core.hooksPath ./.git-hooks && git config core.autocrlf false || true",
|
||||||
@@ -54,7 +51,7 @@
|
|||||||
"copyfiles": "2.4.1",
|
"copyfiles": "2.4.1",
|
||||||
"cors": "^2.8.5",
|
"cors": "^2.8.5",
|
||||||
"cp": "0.2.0",
|
"cp": "0.2.0",
|
||||||
"cypress": "7.7.0",
|
"cypress": "^15.7.1",
|
||||||
"dotenv": "16.0.0",
|
"dotenv": "16.0.0",
|
||||||
"express": "4.17.3",
|
"express": "4.17.3",
|
||||||
"jest": "29.7.0",
|
"jest": "29.7.0",
|
||||||
@@ -63,7 +60,7 @@
|
|||||||
"node-polyfill-webpack-plugin": "1.1.4",
|
"node-polyfill-webpack-plugin": "1.1.4",
|
||||||
"path": "0.12.7",
|
"path": "0.12.7",
|
||||||
"pem": "1.14.5",
|
"pem": "1.14.5",
|
||||||
"prettier": "2.8.7",
|
"prettier": "3.8.2",
|
||||||
"process": "0.11.10",
|
"process": "0.11.10",
|
||||||
"semantic-release": "19.0.3",
|
"semantic-release": "19.0.3",
|
||||||
"terser-webpack-plugin": "5.3.6",
|
"terser-webpack-plugin": "5.3.6",
|
||||||
@@ -79,8 +76,8 @@
|
|||||||
},
|
},
|
||||||
"main": "index.js",
|
"main": "index.js",
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@sasjs/utils": "3.5.2",
|
"@sasjs/utils": "^3.5.6",
|
||||||
"axios": "1.12.2",
|
"axios": "1.15.0",
|
||||||
"axios-cookiejar-support": "5.0.5",
|
"axios-cookiejar-support": "5.0.5",
|
||||||
"form-data": "4.0.4",
|
"form-data": "4.0.4",
|
||||||
"https": "1.0.0",
|
"https": "1.0.0",
|
||||||
|
|||||||
@@ -6,13 +6,13 @@ Browser-based integration testing for [@sasjs/adapter](https://github.com/sasjs/
|
|||||||
|
|
||||||
When developing on `@sasjs/adapter`, it's good practice to run the test suite against your changed version of the adapter to ensure that existing functionality has not been impacted.
|
When developing on `@sasjs/adapter`, it's good practice to run the test suite against your changed version of the adapter to ensure that existing functionality has not been impacted.
|
||||||
|
|
||||||
You can use the provided `update:adapter` NPM script for this.
|
> **Note:** `@sasjs/adapter` is not listed as a dependency in `package.json` - it is installed from a local build. After cloning or running `npm install`, you must run `update:adapter` before building.
|
||||||
|
|
||||||
```bash
|
```bash
|
||||||
npm run update:adapter
|
npm run update:adapter
|
||||||
```
|
```
|
||||||
|
|
||||||
This scripts builds a new version of the adapter and installs it in the `sasjs-tests` project.
|
This script builds a new version of the adapter and installs it in the `sasjs-tests` project.
|
||||||
|
|
||||||
## Running tests
|
## Running tests
|
||||||
|
|
||||||
|
|||||||
@@ -12,10 +12,6 @@ body {
|
|||||||
background: #f5f5f5;
|
background: #f5f5f5;
|
||||||
}
|
}
|
||||||
|
|
||||||
#app {
|
|
||||||
min-height: 100vh;
|
|
||||||
}
|
|
||||||
|
|
||||||
.app__error {
|
.app__error {
|
||||||
max-width: 800px;
|
max-width: 800px;
|
||||||
margin: 50px auto;
|
margin: 50px auto;
|
||||||
@@ -40,4 +36,4 @@ body {
|
|||||||
border-radius: 4px;
|
border-radius: 4px;
|
||||||
overflow-x: auto;
|
overflow-x: auto;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
1680
sasjs-tests/package-lock.json
generated
1680
sasjs-tests/package-lock.json
generated
File diff suppressed because it is too large
Load Diff
@@ -18,8 +18,5 @@
|
|||||||
},
|
},
|
||||||
"overrides": {
|
"overrides": {
|
||||||
"vite": "npm:rolldown-vite@7.2.2"
|
"vite": "npm:rolldown-vite@7.2.2"
|
||||||
},
|
|
||||||
"dependencies": {
|
|
||||||
"@sasjs/adapter": "^4.14.0"
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -7,7 +7,7 @@
|
|||||||
"targets": [
|
"targets": [
|
||||||
{
|
{
|
||||||
"name": "4gl",
|
"name": "4gl",
|
||||||
"serverUrl": "https://sas9.4gl.io",
|
"serverUrl": "https://sas.4gl.io",
|
||||||
"serverType": "SASJS",
|
"serverType": "SASJS",
|
||||||
"httpsAgentOptions": {
|
"httpsAgentOptions": {
|
||||||
"allowInsecureRequests": false
|
"allowInsecureRequests": false
|
||||||
|
|||||||
@@ -1,5 +1,8 @@
|
|||||||
import { defineConfig } from 'vite'
|
import { defineConfig } from 'vite'
|
||||||
export default defineConfig({
|
export default defineConfig({
|
||||||
|
server: {
|
||||||
|
port: 3000
|
||||||
|
},
|
||||||
build: {
|
build: {
|
||||||
assetsInlineLimit: 0,
|
assetsInlineLimit: 0,
|
||||||
assetsDir: ''
|
assetsDir: ''
|
||||||
|
|||||||
@@ -32,16 +32,18 @@ export class ContextManager {
|
|||||||
return this.defaultLauncherContexts
|
return this.defaultLauncherContexts
|
||||||
}
|
}
|
||||||
|
|
||||||
constructor(private serverUrl: string, private requestClient: RequestClient) {
|
constructor(
|
||||||
|
private serverUrl: string,
|
||||||
|
private requestClient: RequestClient
|
||||||
|
) {
|
||||||
if (serverUrl) isUrl(serverUrl)
|
if (serverUrl) isUrl(serverUrl)
|
||||||
}
|
}
|
||||||
|
|
||||||
public async getComputeContexts(accessToken?: string) {
|
public async getComputeContexts(accessToken?: string) {
|
||||||
const { result: contexts } = await this.requestClient
|
const { result: contexts } = await this.requestClient
|
||||||
.get<{ items: Context[] }>(
|
.get<{
|
||||||
`${this.serverUrl}/compute/contexts?limit=10000`,
|
items: Context[]
|
||||||
accessToken
|
}>(`${this.serverUrl}/compute/contexts?limit=10000`, accessToken)
|
||||||
)
|
|
||||||
.catch((err) => {
|
.catch((err) => {
|
||||||
throw prefixMessage(err, 'Error while getting compute contexts. ')
|
throw prefixMessage(err, 'Error while getting compute contexts. ')
|
||||||
})
|
})
|
||||||
@@ -59,10 +61,9 @@ export class ContextManager {
|
|||||||
|
|
||||||
public async getLauncherContexts(accessToken?: string) {
|
public async getLauncherContexts(accessToken?: string) {
|
||||||
const { result: contexts } = await this.requestClient
|
const { result: contexts } = await this.requestClient
|
||||||
.get<{ items: Context[] }>(
|
.get<{
|
||||||
`${this.serverUrl}/launcher/contexts?limit=10000`,
|
items: Context[]
|
||||||
accessToken
|
}>(`${this.serverUrl}/launcher/contexts?limit=10000`, accessToken)
|
||||||
)
|
|
||||||
.catch((err) => {
|
.catch((err) => {
|
||||||
throw prefixMessage(err, 'Error while getting launcher contexts. ')
|
throw prefixMessage(err, 'Error while getting launcher contexts. ')
|
||||||
})
|
})
|
||||||
@@ -291,7 +292,9 @@ export class ContextManager {
|
|||||||
accessToken?: string
|
accessToken?: string
|
||||||
): Promise<Context> {
|
): Promise<Context> {
|
||||||
const { result: contexts } = await this.requestClient
|
const { result: contexts } = await this.requestClient
|
||||||
.get<{ items: Context[] }>(
|
.get<{
|
||||||
|
items: Context[]
|
||||||
|
}>(
|
||||||
`${this.serverUrl}/compute/contexts?filter=eq(name, "${contextName}")`,
|
`${this.serverUrl}/compute/contexts?filter=eq(name, "${contextName}")`,
|
||||||
accessToken
|
accessToken
|
||||||
)
|
)
|
||||||
@@ -332,7 +335,9 @@ export class ContextManager {
|
|||||||
authConfig?: AuthConfig
|
authConfig?: AuthConfig
|
||||||
) {
|
) {
|
||||||
const { result: contexts } = await this.requestClient
|
const { result: contexts } = await this.requestClient
|
||||||
.get<{ items: Context[] }>(
|
.get<{
|
||||||
|
items: Context[]
|
||||||
|
}>(
|
||||||
`${this.serverUrl}/compute/contexts?limit=10000`,
|
`${this.serverUrl}/compute/contexts?limit=10000`,
|
||||||
authConfig?.access_token
|
authConfig?.access_token
|
||||||
)
|
)
|
||||||
|
|||||||
@@ -35,6 +35,60 @@ interface JobExecutionResult {
|
|||||||
log?: string
|
log?: string
|
||||||
error?: object
|
error?: object
|
||||||
}
|
}
|
||||||
|
/* Viya /types/types?limit=999999 response structure */
|
||||||
|
interface IViyaTypesResponse {
|
||||||
|
accept: string
|
||||||
|
count: number
|
||||||
|
items: IViyaTypesItem[]
|
||||||
|
limit: number
|
||||||
|
links: IViyaTypesLink[]
|
||||||
|
name: string
|
||||||
|
start: number
|
||||||
|
version: number
|
||||||
|
}
|
||||||
|
|
||||||
|
/* Item element within the Viya types response */
|
||||||
|
interface IViyaTypesItem {
|
||||||
|
description?: string
|
||||||
|
extensions?: string[]
|
||||||
|
iconUri?: string
|
||||||
|
label: string
|
||||||
|
links: IViyaTypesLink[]
|
||||||
|
mappedTypes?: string[]
|
||||||
|
mediaType?: string
|
||||||
|
mediaTypes?: string[]
|
||||||
|
name?: string | undefined
|
||||||
|
pluralLabel?: string
|
||||||
|
properties?: IViyaTypesProperties
|
||||||
|
resourceUri?: string
|
||||||
|
serviceRootUri?: string
|
||||||
|
tags?: string[]
|
||||||
|
version: number
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Generic structure for a link
|
||||||
|
* in the links array of a Viya
|
||||||
|
* types/types api response
|
||||||
|
*/
|
||||||
|
type IViyaTypesLink = Record<string, string>
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Generic structure for a type's
|
||||||
|
* 'properties' object from the Viya
|
||||||
|
* types/types api response
|
||||||
|
*/
|
||||||
|
type IViyaTypesProperties = Record<string, string>
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Arbitrary interface for storing
|
||||||
|
* sufficient additional detail to
|
||||||
|
* create and patch a new file.
|
||||||
|
*/
|
||||||
|
interface IViyaTypesExtensionInfo {
|
||||||
|
typeDefName: string | undefined
|
||||||
|
properties: IViyaTypesProperties | undefined
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* A client for interfacing with the SAS Viya REST API.
|
* A client for interfacing with the SAS Viya REST API.
|
||||||
@@ -61,6 +115,9 @@ export class SASViyaApiClient {
|
|||||||
this.requestClient
|
this.requestClient
|
||||||
)
|
)
|
||||||
private folderMap = new Map<string, Job[]>()
|
private folderMap = new Map<string, Job[]>()
|
||||||
|
private fileExtensionMap = new Map<string, IViyaTypesExtensionInfo>()
|
||||||
|
private boolExtensionMap = false // required in case the map has zero entries
|
||||||
|
// after an attempt to populate it.
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* A helper method used to call appendRequest method of RequestClient
|
* A helper method used to call appendRequest method of RequestClient
|
||||||
@@ -434,15 +491,102 @@ export class SASViyaApiClient {
|
|||||||
const formData = new NodeFormData()
|
const formData = new NodeFormData()
|
||||||
formData.append('file', contentBuffer, fileName)
|
formData.append('file', contentBuffer, fileName)
|
||||||
|
|
||||||
return (
|
/** Query Viya for file metadata based on extension type. */
|
||||||
await this.requestClient.post<File>(
|
|
||||||
`/files/files?parentFolderUri=${parentFolderUri}&typeDefName=file#rawUpload`,
|
// typeDefName - Viya accepts this property during the file creation
|
||||||
formData,
|
let typeDefName: string | undefined = undefined
|
||||||
accessToken,
|
// Additional properties are supplied by a patch.
|
||||||
'multipart/form-data; boundary=' + (formData as any)._boundary,
|
let filePatch:
|
||||||
headers
|
| {
|
||||||
)
|
name: string
|
||||||
).result
|
properties: IViyaTypesProperties | undefined
|
||||||
|
}
|
||||||
|
| undefined = undefined
|
||||||
|
|
||||||
|
// The patching process requires properties related to the file-extension
|
||||||
|
const fileExtension: string | undefined = fileName
|
||||||
|
.split('.')
|
||||||
|
.pop()
|
||||||
|
?.toLowerCase()
|
||||||
|
|
||||||
|
if (fileExtension) {
|
||||||
|
if (!this.boolExtensionMap) {
|
||||||
|
// Populate the file extension map
|
||||||
|
// 1. Get Viya's response to this api call
|
||||||
|
const typesQueryUrl = `/types/types?limit=999999`
|
||||||
|
const response = (
|
||||||
|
await this.requestClient.get(typesQueryUrl, accessToken)
|
||||||
|
).result as IViyaTypesResponse
|
||||||
|
// 2. Filter the returned items that have file extensions into a map
|
||||||
|
// using forEach as an item may relate to multiple file extensions.
|
||||||
|
response.items
|
||||||
|
.filter((e) => e.extensions)
|
||||||
|
.forEach((e) => {
|
||||||
|
e.extensions?.forEach((ext) => {
|
||||||
|
this.fileExtensionMap.set(ext, {
|
||||||
|
// `name` becomes the typeDefName value at file creation time.
|
||||||
|
// `name` is ignored here if it is not populated in the map, or
|
||||||
|
// has a blank/empty value.
|
||||||
|
typeDefName: e.name
|
||||||
|
? e.name.trim().length
|
||||||
|
? e.name.trim()
|
||||||
|
: undefined
|
||||||
|
: undefined,
|
||||||
|
properties: e.properties
|
||||||
|
})
|
||||||
|
})
|
||||||
|
})
|
||||||
|
// 3. Toggle the flag to avoid repeating this step
|
||||||
|
this.boolExtensionMap = true
|
||||||
|
}
|
||||||
|
|
||||||
|
// Query the map for the current file extension
|
||||||
|
const fileExtInfo = this.fileExtensionMap.get(fileExtension)
|
||||||
|
if (fileExtInfo) {
|
||||||
|
// If the extension was found in the map, record the typeDefName and
|
||||||
|
// create a patch if a properties object was returned.
|
||||||
|
typeDefName = fileExtInfo.typeDefName
|
||||||
|
if (fileExtInfo.properties)
|
||||||
|
filePatch = { name: fileName, properties: fileExtInfo.properties }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// Create the file
|
||||||
|
const createFileResponse = await this.requestClient.post<File>(
|
||||||
|
`/files/files?parentFolderUri=${parentFolderUri}&typeDefName=${
|
||||||
|
typeDefName ?? 'file'
|
||||||
|
}#rawUpload`,
|
||||||
|
formData,
|
||||||
|
accessToken,
|
||||||
|
'multipart/form-data; boundary=' + (formData as any)._boundary,
|
||||||
|
headers
|
||||||
|
)
|
||||||
|
|
||||||
|
// If a patch was created...
|
||||||
|
if (filePatch) {
|
||||||
|
try {
|
||||||
|
const patchHeaders = {
|
||||||
|
Accept: 'application/json',
|
||||||
|
'If-Match': '*'
|
||||||
|
}
|
||||||
|
// Get the URI of the newly created file
|
||||||
|
const fileUri = createFileResponse.result.links.filter(
|
||||||
|
(e) => e.method == 'PATCH' && e.rel == 'patch'
|
||||||
|
)[0].uri
|
||||||
|
// and apply the patch
|
||||||
|
return (
|
||||||
|
await this.requestClient.patch<File>(
|
||||||
|
`${fileUri}`,
|
||||||
|
filePatch,
|
||||||
|
accessToken,
|
||||||
|
patchHeaders
|
||||||
|
)
|
||||||
|
).result
|
||||||
|
} catch (e: any) {
|
||||||
|
throw new Error(`Error patching file ${fileName}.\n${e.message}`)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return createFileResponse.result
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -882,9 +1026,8 @@ export class SASViyaApiClient {
|
|||||||
}
|
}
|
||||||
|
|
||||||
files.forEach((fileInfo, index) => {
|
files.forEach((fileInfo, index) => {
|
||||||
jobArguments[
|
jobArguments[`_webin_fileuri${index + 1}`] =
|
||||||
`_webin_fileuri${index + 1}`
|
`/files/files/${fileInfo.file.id}`
|
||||||
] = `/files/files/${fileInfo.file.id}`
|
|
||||||
jobArguments[`_webin_name${index + 1}`] = fileInfo.tableName
|
jobArguments[`_webin_name${index + 1}`] = fileInfo.tableName
|
||||||
})
|
})
|
||||||
|
|
||||||
|
|||||||
@@ -1063,8 +1063,8 @@ export default class SASjs {
|
|||||||
this.sasjsConfig.serverType === ServerType.SasViya
|
this.sasjsConfig.serverType === ServerType.SasViya
|
||||||
? this.sasjsConfig.pathSASViya
|
? this.sasjsConfig.pathSASViya
|
||||||
: this.sasjsConfig.serverType === ServerType.Sas9
|
: this.sasjsConfig.serverType === ServerType.Sas9
|
||||||
? this.sasjsConfig.pathSAS9
|
? this.sasjsConfig.pathSAS9
|
||||||
: this.sasjsConfig.pathSASJS
|
: this.sasjsConfig.pathSASJS
|
||||||
|
|
||||||
this.authManager = new AuthManager(
|
this.authManager = new AuthManager(
|
||||||
this.sasjsConfig.serverUrl,
|
this.sasjsConfig.serverUrl,
|
||||||
|
|||||||
@@ -125,9 +125,8 @@ export async function executeOnComputeApi(
|
|||||||
jobVariables['_webin_file_count'] = files.length
|
jobVariables['_webin_file_count'] = files.length
|
||||||
|
|
||||||
files.forEach((fileInfo, index) => {
|
files.forEach((fileInfo, index) => {
|
||||||
jobVariables[
|
jobVariables[`_webin_fileuri${index + 1}`] =
|
||||||
`_webin_fileuri${index + 1}`
|
`/files/files/${fileInfo.file.id}`
|
||||||
] = `/files/files/${fileInfo.file.id}`
|
|
||||||
jobVariables[`_webin_name${index + 1}`] = fileInfo.tableName
|
jobVariables[`_webin_name${index + 1}`] = fileInfo.tableName
|
||||||
})
|
})
|
||||||
} else {
|
} else {
|
||||||
|
|||||||
@@ -683,8 +683,8 @@ const mockSimplePoll = (runningCount = 2) => {
|
|||||||
count === 0
|
count === 0
|
||||||
? 'pending'
|
? 'pending'
|
||||||
: count <= runningCount
|
: count <= runningCount
|
||||||
? 'running'
|
? 'running'
|
||||||
: 'completed',
|
: 'completed',
|
||||||
etag: '',
|
etag: '',
|
||||||
status: 200
|
status: 200
|
||||||
})
|
})
|
||||||
|
|||||||
@@ -27,8 +27,8 @@ export class AuthManager {
|
|||||||
this.serverType === ServerType.Sas9
|
this.serverType === ServerType.Sas9
|
||||||
? '/SASLogon/logout?'
|
? '/SASLogon/logout?'
|
||||||
: this.serverType === ServerType.SasViya
|
: this.serverType === ServerType.SasViya
|
||||||
? '/SASLogon/logout.do?'
|
? '/SASLogon/logout.do?'
|
||||||
: '/SASLogon/logout'
|
: '/SASLogon/logout'
|
||||||
|
|
||||||
this.redirectedLoginUrl = this.serverUrl + this.redirectedLoginUrl
|
this.redirectedLoginUrl = this.serverUrl + this.redirectedLoginUrl
|
||||||
}
|
}
|
||||||
@@ -269,8 +269,8 @@ export class AuthManager {
|
|||||||
this.serverType === ServerType.SasViya
|
this.serverType === ServerType.SasViya
|
||||||
? `${this.serverUrl}/identities/users/@currentUser`
|
? `${this.serverUrl}/identities/users/@currentUser`
|
||||||
: this.serverType === ServerType.Sas9
|
: this.serverType === ServerType.Sas9
|
||||||
? `${this.serverUrl}/SASStoredProcess`
|
? `${this.serverUrl}/SASStoredProcess`
|
||||||
: `${this.serverUrl}/SASjsApi/session`
|
: `${this.serverUrl}/SASjsApi/session`
|
||||||
|
|
||||||
const { result: loginResponse } = await this.requestClient
|
const { result: loginResponse } = await this.requestClient
|
||||||
.get<string>(url, undefined, 'text/plain')
|
.get<string>(url, undefined, 'text/plain')
|
||||||
|
|||||||
@@ -10,7 +10,7 @@ describe('openWebPage', () => {
|
|||||||
describe('window.open is not blocked', () => {
|
describe('window.open is not blocked', () => {
|
||||||
const mockedOpen = jest
|
const mockedOpen = jest
|
||||||
.fn()
|
.fn()
|
||||||
.mockImplementation(() => ({} as unknown as Window))
|
.mockImplementation(() => ({}) as unknown as Window)
|
||||||
const originalOpen = window.open
|
const originalOpen = window.open
|
||||||
|
|
||||||
beforeAll(() => {
|
beforeAll(() => {
|
||||||
|
|||||||
@@ -8,7 +8,10 @@ import {
|
|||||||
import { BaseJobExecutor } from './JobExecutor'
|
import { BaseJobExecutor } from './JobExecutor'
|
||||||
|
|
||||||
export class ComputeJobExecutor extends BaseJobExecutor {
|
export class ComputeJobExecutor extends BaseJobExecutor {
|
||||||
constructor(serverUrl: string, private sasViyaApiClient: SASViyaApiClient) {
|
constructor(
|
||||||
|
serverUrl: string,
|
||||||
|
private sasViyaApiClient: SASViyaApiClient
|
||||||
|
) {
|
||||||
super(serverUrl, ServerType.SasViya)
|
super(serverUrl, ServerType.SasViya)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -10,7 +10,10 @@ import { BaseJobExecutor } from './JobExecutor'
|
|||||||
import { appendExtraResponseAttributes } from '../utils'
|
import { appendExtraResponseAttributes } from '../utils'
|
||||||
|
|
||||||
export class JesJobExecutor extends BaseJobExecutor {
|
export class JesJobExecutor extends BaseJobExecutor {
|
||||||
constructor(serverUrl: string, private sasViyaApiClient: SASViyaApiClient) {
|
constructor(
|
||||||
|
serverUrl: string,
|
||||||
|
private sasViyaApiClient: SASViyaApiClient
|
||||||
|
) {
|
||||||
super(serverUrl, ServerType.SasViya)
|
super(serverUrl, ServerType.SasViya)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -17,7 +17,10 @@ export interface JobExecutor {
|
|||||||
}
|
}
|
||||||
|
|
||||||
export abstract class BaseJobExecutor implements JobExecutor {
|
export abstract class BaseJobExecutor implements JobExecutor {
|
||||||
constructor(protected serverUrl: string, protected serverType: ServerType) {}
|
constructor(
|
||||||
|
protected serverUrl: string,
|
||||||
|
protected serverType: ServerType
|
||||||
|
) {}
|
||||||
|
|
||||||
private waitingRequests: ExecuteFunction[] = []
|
private waitingRequests: ExecuteFunction[] = []
|
||||||
|
|
||||||
|
|||||||
@@ -97,12 +97,10 @@ export class WebJobExecutor extends BaseJobExecutor {
|
|||||||
apiUrl = apiUrl.replace('_program=', '__program=')
|
apiUrl = apiUrl.replace('_program=', '__program=')
|
||||||
}
|
}
|
||||||
|
|
||||||
// if context name exists and is not blank string
|
// Append context name to URL if provided and non-empty
|
||||||
// then add _contextname variable in apiUrl
|
apiUrl += config.contextName?.trim()
|
||||||
apiUrl +=
|
? `&_contextname=${encodeURIComponent(config.contextName)}`
|
||||||
config.contextName && !/\s/.test(config.contextName)
|
: ''
|
||||||
? `&_contextname=${config.contextName}`
|
|
||||||
: ''
|
|
||||||
}
|
}
|
||||||
|
|
||||||
let requestParams = {
|
let requestParams = {
|
||||||
|
|||||||
@@ -273,9 +273,13 @@ export class RequestClient implements HttpClient {
|
|||||||
public async patch<T>(
|
public async patch<T>(
|
||||||
url: string,
|
url: string,
|
||||||
data: any = {},
|
data: any = {},
|
||||||
accessToken?: string
|
accessToken?: string,
|
||||||
|
overrideHeaders: { [key: string]: string | number } = {}
|
||||||
): Promise<{ result: T; etag: string }> {
|
): Promise<{ result: T; etag: string }> {
|
||||||
const headers = this.getHeaders(accessToken, 'application/json')
|
const headers = {
|
||||||
|
...this.getHeaders(accessToken, 'application/json'),
|
||||||
|
...overrideHeaders
|
||||||
|
}
|
||||||
|
|
||||||
return this.httpClient
|
return this.httpClient
|
||||||
.patch<T>(url, data, { headers, withXSRFToken: true })
|
.patch<T>(url, data, { headers, withXSRFToken: true })
|
||||||
|
|||||||
@@ -631,7 +631,7 @@ describe('RequestClient - Self Signed Server', () => {
|
|||||||
getTokenRequestErrorPrefixResponse(err.message, ServerType.SasViya)
|
getTokenRequestErrorPrefixResponse(err.message, ServerType.SasViya)
|
||||||
)
|
)
|
||||||
|
|
||||||
expect(rejectionErrorMessage).toEqual(expectedError)
|
expect(rejectionErrorMessage).toContain(expectedError)
|
||||||
})
|
})
|
||||||
|
|
||||||
it('should response the POST method using insecure flag', async () => {
|
it('should response the POST method using insecure flag', async () => {
|
||||||
|
|||||||
@@ -1,5 +1,8 @@
|
|||||||
export class AuthorizeError extends Error {
|
export class AuthorizeError extends Error {
|
||||||
constructor(public message: string, public confirmUrl: string) {
|
constructor(
|
||||||
|
public message: string,
|
||||||
|
public confirmUrl: string
|
||||||
|
) {
|
||||||
super(message)
|
super(message)
|
||||||
this.name = 'AuthorizeError'
|
this.name = 'AuthorizeError'
|
||||||
Object.setPrototypeOf(this, AuthorizeError.prototype)
|
Object.setPrototypeOf(this, AuthorizeError.prototype)
|
||||||
|
|||||||
@@ -1,7 +1,10 @@
|
|||||||
import { Job } from '../Job'
|
import { Job } from '../Job'
|
||||||
|
|
||||||
export class ComputeJobExecutionError extends Error {
|
export class ComputeJobExecutionError extends Error {
|
||||||
constructor(public job: Job, public log: string) {
|
constructor(
|
||||||
|
public job: Job,
|
||||||
|
public log: string
|
||||||
|
) {
|
||||||
super('Error: Job execution failed')
|
super('Error: Job execution failed')
|
||||||
this.name = 'ComputeJobExecutionError'
|
this.name = 'ComputeJobExecutionError'
|
||||||
Object.setPrototypeOf(this, ComputeJobExecutionError.prototype)
|
Object.setPrototypeOf(this, ComputeJobExecutionError.prototype)
|
||||||
|
|||||||
@@ -1,5 +1,8 @@
|
|||||||
export class JobStatePollError extends Error {
|
export class JobStatePollError extends Error {
|
||||||
constructor(id: string, public originalError: Error) {
|
constructor(
|
||||||
|
id: string,
|
||||||
|
public originalError: Error
|
||||||
|
) {
|
||||||
super(
|
super(
|
||||||
`Error while polling job state for job ${id}: ${
|
`Error while polling job state for job ${id}: ${
|
||||||
originalError.message || originalError
|
originalError.message || originalError
|
||||||
|
|||||||
@@ -110,8 +110,8 @@ export const convertToCSV = (
|
|||||||
longestValueForField
|
longestValueForField
|
||||||
? longestValueForField
|
? longestValueForField
|
||||||
: firstFoundType === 'chars'
|
: firstFoundType === 'chars'
|
||||||
? '1'
|
? '1'
|
||||||
: 'best'
|
: 'best'
|
||||||
}.`
|
}.`
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user