mirror of
https://github.com/sasjs/adapter.git
synced 2026-06-12 11:40:22 +00:00
Compare commits
15 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| eb1186b4b9 | |||
| ef1e816b09 | |||
| 6552c768f9 | |||
| 31b3959e2c | |||
| a38548d8de | |||
| 7a130e129f | |||
| 27a69f2959 | |||
| 38d84e56d4 | |||
| 180e2ef425 | |||
| 9177dce3e1 | |||
| 9f4064b46e | |||
| 44c5eab638 | |||
| 0f9f16bef1 | |||
| 5c61ede51a | |||
| fccb3ab965 |
@@ -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/iron]
|
node-version: [22, 24]
|
||||||
|
|
||||||
steps:
|
steps:
|
||||||
- uses: actions/checkout@v2
|
- uses: actions/checkout@v2
|
||||||
@@ -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 }}
|
||||||
|
|||||||
@@ -11,7 +11,7 @@ jobs:
|
|||||||
|
|
||||||
strategy:
|
strategy:
|
||||||
matrix:
|
matrix:
|
||||||
node-version: [lts/iron]
|
node-version: [22]
|
||||||
|
|
||||||
steps:
|
steps:
|
||||||
- name: Checkout
|
- name: Checkout
|
||||||
|
|||||||
@@ -14,7 +14,7 @@ jobs:
|
|||||||
|
|
||||||
strategy:
|
strategy:
|
||||||
matrix:
|
matrix:
|
||||||
node-version: [lts/iron]
|
node-version: [22]
|
||||||
|
|
||||||
steps:
|
steps:
|
||||||
- uses: actions/checkout@v2
|
- uses: actions/checkout@v2
|
||||||
|
|||||||
@@ -12,7 +12,7 @@ jobs:
|
|||||||
|
|
||||||
strategy:
|
strategy:
|
||||||
matrix:
|
matrix:
|
||||||
node-version: [lts/iron]
|
node-version: [22]
|
||||||
|
|
||||||
steps:
|
steps:
|
||||||
- uses: actions/checkout@v2
|
- uses: actions/checkout@v2
|
||||||
@@ -93,8 +93,8 @@ jobs:
|
|||||||
run: |
|
run: |
|
||||||
sudo apt install jq
|
sudo apt install jq
|
||||||
cd sasjs-tests
|
cd sasjs-tests
|
||||||
jq '.dependencies."@sasjs/adapter" |= "latest"' ./package.json > ./package.temp && mv ./package.temp ./package.json
|
npm i --ignore-scripts
|
||||||
npm i
|
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
|
jq '.sasJsConfig.serverUrl |= "${{ secrets.SASJS_SERVER_URL }}"' ./public/config.json > ./public/config.temp && mv ./public/config.temp ./public/config.json
|
||||||
jq '.sasJsConfig.serverType |= "SASJS"' ./public/config.json > ./public/config.temp && mv ./public/config.temp ./public/config.json
|
jq '.sasJsConfig.serverType |= "SASJS"' ./public/config.json > ./public/config.temp && mv ./public/config.temp ./public/config.json
|
||||||
jq '.sasJsConfig.loginMechanism |= "Default"' ./public/config.json > ./public/config.temp && mv ./public/config.temp ./public/config.json
|
jq '.sasJsConfig.loginMechanism |= "Default"' ./public/config.json > ./public/config.temp && mv ./public/config.temp ./public/config.json
|
||||||
|
|||||||
Generated
+14
-12
@@ -8,7 +8,7 @@
|
|||||||
"license": "ISC",
|
"license": "ISC",
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@sasjs/utils": "^3.5.6",
|
"@sasjs/utils": "^3.5.6",
|
||||||
"axios": "1.15.0",
|
"axios": "1.16.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",
|
||||||
@@ -34,7 +34,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",
|
||||||
@@ -3527,12 +3527,12 @@
|
|||||||
"license": "MIT"
|
"license": "MIT"
|
||||||
},
|
},
|
||||||
"node_modules/axios": {
|
"node_modules/axios": {
|
||||||
"version": "1.15.0",
|
"version": "1.16.0",
|
||||||
"resolved": "https://registry.npmjs.org/axios/-/axios-1.15.0.tgz",
|
"resolved": "https://registry.npmjs.org/axios/-/axios-1.16.0.tgz",
|
||||||
"integrity": "sha512-wWyJDlAatxk30ZJer+GeCWS209sA42X+N5jU2jy6oHTp7ufw8uzUTVFBX9+wTfAlhiJXGS0Bq7X6efruWjuK9Q==",
|
"integrity": "sha512-6hp5CwvTPlN2A31g5dxnwAX0orzM7pmCRDLnZSX772mv8WDqICwFjowHuPs04Mc8deIld1+ejhtaMn5vp6b+1w==",
|
||||||
"license": "MIT",
|
"license": "MIT",
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"follow-redirects": "^1.15.11",
|
"follow-redirects": "^1.16.0",
|
||||||
"form-data": "^4.0.5",
|
"form-data": "^4.0.5",
|
||||||
"proxy-from-env": "^2.1.0"
|
"proxy-from-env": "^2.1.0"
|
||||||
}
|
}
|
||||||
@@ -6135,9 +6135,9 @@
|
|||||||
}
|
}
|
||||||
},
|
},
|
||||||
"node_modules/follow-redirects": {
|
"node_modules/follow-redirects": {
|
||||||
"version": "1.15.11",
|
"version": "1.16.0",
|
||||||
"resolved": "https://registry.npmjs.org/follow-redirects/-/follow-redirects-1.15.11.tgz",
|
"resolved": "https://registry.npmjs.org/follow-redirects/-/follow-redirects-1.16.0.tgz",
|
||||||
"integrity": "sha512-deG2P0JfjrTxl50XGCDyfI97ZGVCxIpfKYmfyrQ54n5FO/0gfIES8C/Psl6kWVDolizcaaxZJnTS0QSMxvnsBQ==",
|
"integrity": "sha512-y5rN/uOsadFT/JfYwhxRS5R7Qce+g3zG97+JrtFZlC9klX/W5hD7iiLzScI4nZqUS7DNUdhPgw4xI8W2LuXlUw==",
|
||||||
"funding": [
|
"funding": [
|
||||||
{
|
{
|
||||||
"type": "individual",
|
"type": "individual",
|
||||||
@@ -12321,14 +12321,16 @@
|
|||||||
}
|
}
|
||||||
},
|
},
|
||||||
"node_modules/prettier": {
|
"node_modules/prettier": {
|
||||||
"version": "2.8.7",
|
"version": "3.8.2",
|
||||||
|
"resolved": "https://registry.npmjs.org/prettier/-/prettier-3.8.2.tgz",
|
||||||
|
"integrity": "sha512-8c3mgTe0ASwWAJK+78dpviD+A8EqhndQPUBpNUIPt6+xWlIigCwfN01lWr9MAede4uqXGTEKeQWTvzb3vjia0Q==",
|
||||||
"dev": true,
|
"dev": true,
|
||||||
"license": "MIT",
|
"license": "MIT",
|
||||||
"bin": {
|
"bin": {
|
||||||
"prettier": "bin-prettier.js"
|
"prettier": "bin/prettier.cjs"
|
||||||
},
|
},
|
||||||
"engines": {
|
"engines": {
|
||||||
"node": ">=10.13.0"
|
"node": ">=14"
|
||||||
},
|
},
|
||||||
"funding": {
|
"funding": {
|
||||||
"url": "https://github.com/prettier/prettier?sponsor=1"
|
"url": "https://github.com/prettier/prettier?sponsor=1"
|
||||||
|
|||||||
+4
-4
@@ -7,9 +7,9 @@
|
|||||||
"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",
|
"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",
|
||||||
"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",
|
||||||
"publishInit": "cp -r ./build/* . && rm -rf ./build",
|
"publishInit": "cp -r ./build/* . && rm -rf ./build",
|
||||||
"semantic-release": "semantic-release",
|
"semantic-release": "semantic-release",
|
||||||
@@ -60,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",
|
||||||
@@ -77,7 +77,7 @@
|
|||||||
"main": "index.js",
|
"main": "index.js",
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@sasjs/utils": "^3.5.6",
|
"@sasjs/utils": "^3.5.6",
|
||||||
"axios": "1.15.0",
|
"axios": "1.16.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
|
||||||
|
|
||||||
|
|||||||
Generated
+54
-1633
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"
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -4,8 +4,8 @@
|
|||||||
"sasJsConfig": {
|
"sasJsConfig": {
|
||||||
"loginMechanism": "Redirected",
|
"loginMechanism": "Redirected",
|
||||||
"serverUrl": "",
|
"serverUrl": "",
|
||||||
"appLoc": "/Public/app/adapter-tests/services",
|
"appLoc": "/Public/app/adapter-tests",
|
||||||
"serverType": "SASVIYA",
|
"serverType": "SASJS",
|
||||||
"debug": false,
|
"debug": false,
|
||||||
"contextName": "SAS Job Execution compute context",
|
"contextName": "SAS Job Execution compute context",
|
||||||
"useComputeApi": true
|
"useComputeApi": true
|
||||||
|
|||||||
@@ -72,7 +72,7 @@ export class TestCard extends HTMLElement {
|
|||||||
? `
|
? `
|
||||||
<div class="error">
|
<div class="error">
|
||||||
<strong>Error:</strong>
|
<strong>Error:</strong>
|
||||||
<pre>${(error as Error).message || String(error)}</pre>
|
<pre>${formatError(error)}</pre>
|
||||||
</div>
|
</div>
|
||||||
`
|
`
|
||||||
: ''
|
: ''
|
||||||
@@ -110,4 +110,35 @@ export class TestCard extends HTMLElement {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
const escapeHtml = (s: string) =>
|
||||||
|
s.replace(/&/g, '&').replace(/</g, '<').replace(/>/g, '>')
|
||||||
|
|
||||||
|
const formatError = (err: unknown): string => {
|
||||||
|
if (err == null) return ''
|
||||||
|
if (typeof err === 'string') return escapeHtml(err)
|
||||||
|
|
||||||
|
const anyErr = err as any
|
||||||
|
// Adapter ErrorResponse: { error: { message, details, raw } }
|
||||||
|
const nestedMsg = anyErr?.error?.message
|
||||||
|
const directMsg = anyErr?.message
|
||||||
|
const msg = directMsg || nestedMsg
|
||||||
|
|
||||||
|
if (msg) {
|
||||||
|
const details = anyErr?.error?.details ?? anyErr?.details
|
||||||
|
const detailsStr =
|
||||||
|
details && typeof details === 'object'
|
||||||
|
? `\n${JSON.stringify(details, null, 2)}`
|
||||||
|
: details
|
||||||
|
? `\n${details}`
|
||||||
|
: ''
|
||||||
|
return escapeHtml(`${msg}${detailsStr}`)
|
||||||
|
}
|
||||||
|
|
||||||
|
try {
|
||||||
|
return escapeHtml(JSON.stringify(err, null, 2))
|
||||||
|
} catch {
|
||||||
|
return escapeHtml(String(err))
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
customElements.define('test-card', TestCard)
|
customElements.define('test-card', TestCard)
|
||||||
|
|||||||
@@ -22,6 +22,7 @@ import { sendArrTests, sendObjTests } from './testSuites/RequestData'
|
|||||||
import { fileUploadTests } from './testSuites/FileUpload'
|
import { fileUploadTests } from './testSuites/FileUpload'
|
||||||
import { computeTests } from './testSuites/Compute'
|
import { computeTests } from './testSuites/Compute'
|
||||||
import { sasjsRequestTests } from './testSuites/SasjsRequests'
|
import { sasjsRequestTests } from './testSuites/SasjsRequests'
|
||||||
|
import { specialCaseTests } from './testSuites/SpecialCases'
|
||||||
|
|
||||||
async function init() {
|
async function init() {
|
||||||
const appContainer = document.getElementById('app')
|
const appContainer = document.getElementById('app')
|
||||||
@@ -98,7 +99,7 @@ function showTests(
|
|||||||
// basicTests(adapter, configTyped.userName || '', configTyped.password || ''),
|
// basicTests(adapter, configTyped.userName || '', configTyped.password || ''),
|
||||||
sendArrTests(adapter, appLoc),
|
sendArrTests(adapter, appLoc),
|
||||||
sendObjTests(adapter),
|
sendObjTests(adapter),
|
||||||
// specialCaseTests(adapter),
|
specialCaseTests(adapter),
|
||||||
sasjsRequestTests(adapter),
|
sasjsRequestTests(adapter),
|
||||||
fileUploadTests(adapter)
|
fileUploadTests(adapter)
|
||||||
]
|
]
|
||||||
|
|||||||
@@ -77,7 +77,7 @@ export const basicTests = (
|
|||||||
await adapter.logOut()
|
await adapter.logOut()
|
||||||
|
|
||||||
return await adapter.request(
|
return await adapter.request(
|
||||||
'common/sendArr',
|
'services/common/sendArr',
|
||||||
stringData,
|
stringData,
|
||||||
undefined,
|
undefined,
|
||||||
async () => {
|
async () => {
|
||||||
@@ -97,7 +97,11 @@ export const basicTests = (
|
|||||||
useComputeApi: false
|
useComputeApi: false
|
||||||
}
|
}
|
||||||
|
|
||||||
return await adapter.request('common/sendArr', stringData, config)
|
return await adapter.request(
|
||||||
|
'services/common/sendArr',
|
||||||
|
stringData,
|
||||||
|
config
|
||||||
|
)
|
||||||
},
|
},
|
||||||
assertion: (response: any) => {
|
assertion: (response: any) => {
|
||||||
return response.table1[0][0] === stringData.table1[0].col1
|
return response.table1[0][0] === stringData.table1[0].col1
|
||||||
@@ -112,7 +116,11 @@ export const basicTests = (
|
|||||||
debug: true
|
debug: true
|
||||||
}
|
}
|
||||||
|
|
||||||
return await adapter.request('common/sendArr', stringData, config)
|
return await adapter.request(
|
||||||
|
'services/common/sendArr',
|
||||||
|
stringData,
|
||||||
|
config
|
||||||
|
)
|
||||||
},
|
},
|
||||||
assertion: (response: any) => {
|
assertion: (response: any) => {
|
||||||
return response.table1[0][0] === stringData.table1[0].col1
|
return response.table1[0][0] === stringData.table1[0].col1
|
||||||
|
|||||||
@@ -11,7 +11,7 @@ export const computeTests = (adapter: SASjs, appLoc: string): TestSuite => ({
|
|||||||
title: 'Compute API request',
|
title: 'Compute API request',
|
||||||
description: 'Should run the request with compute API approach',
|
description: 'Should run the request with compute API approach',
|
||||||
test: async () => {
|
test: async () => {
|
||||||
return await adapter.request('common/sendArr', stringData)
|
return await adapter.request('services/common/sendArr', stringData)
|
||||||
},
|
},
|
||||||
assertion: (response: any) => {
|
assertion: (response: any) => {
|
||||||
return response.table1[0][0] === stringData.table1[0].col1
|
return response.table1[0][0] === stringData.table1[0].col1
|
||||||
@@ -25,7 +25,11 @@ export const computeTests = (adapter: SASjs, appLoc: string): TestSuite => ({
|
|||||||
useComputeApi: false
|
useComputeApi: false
|
||||||
}
|
}
|
||||||
|
|
||||||
return await adapter.request('common/sendArr', stringData, config)
|
return await adapter.request(
|
||||||
|
'services/common/sendArr',
|
||||||
|
stringData,
|
||||||
|
config
|
||||||
|
)
|
||||||
},
|
},
|
||||||
assertion: (response: any) => {
|
assertion: (response: any) => {
|
||||||
return response.table1[0][0] === stringData.table1[0].col1
|
return response.table1[0][0] === stringData.table1[0].col1
|
||||||
@@ -36,7 +40,10 @@ export const computeTests = (adapter: SASjs, appLoc: string): TestSuite => ({
|
|||||||
description: 'Should start a compute job and return the session',
|
description: 'Should start a compute job and return the session',
|
||||||
test: () => {
|
test: () => {
|
||||||
const data: any = { table1: [{ col1: 'first col value' }] }
|
const data: any = { table1: [{ col1: 'first col value' }] }
|
||||||
return adapter.startComputeJob(`${appLoc}/common/sendArr`, data)
|
return adapter.startComputeJob(
|
||||||
|
`${appLoc}/services/common/sendArr`,
|
||||||
|
data
|
||||||
|
)
|
||||||
},
|
},
|
||||||
assertion: (res: any) => {
|
assertion: (res: any) => {
|
||||||
const expectedProperties = ['id', 'applicationName', 'attributes']
|
const expectedProperties = ['id', 'applicationName', 'attributes']
|
||||||
@@ -49,7 +56,7 @@ export const computeTests = (adapter: SASjs, appLoc: string): TestSuite => ({
|
|||||||
test: () => {
|
test: () => {
|
||||||
const data: any = { table1: [{ col1: 'first col value' }] }
|
const data: any = { table1: [{ col1: 'first col value' }] }
|
||||||
return adapter.startComputeJob(
|
return adapter.startComputeJob(
|
||||||
`${appLoc}/common/sendArr`,
|
`${appLoc}/services/common/sendArr`,
|
||||||
data,
|
data,
|
||||||
{},
|
{},
|
||||||
undefined,
|
undefined,
|
||||||
|
|||||||
@@ -22,7 +22,11 @@ export const fileUploadTests = (adapter: SASjs): TestSuite => ({
|
|||||||
}
|
}
|
||||||
]
|
]
|
||||||
|
|
||||||
return adapter.uploadFile('common/sendMacVars', filesToUpload, null)
|
return adapter.uploadFile(
|
||||||
|
'services/common/sendMacVars',
|
||||||
|
filesToUpload,
|
||||||
|
null
|
||||||
|
)
|
||||||
},
|
},
|
||||||
assertion: (response: any) =>
|
assertion: (response: any) =>
|
||||||
(response.macvars as any[]).findIndex(
|
(response.macvars as any[]).findIndex(
|
||||||
|
|||||||
@@ -53,7 +53,7 @@ export const sendArrTests = (adapter: SASjs, appLoc: string): TestSuite => ({
|
|||||||
title: 'Absolute paths',
|
title: 'Absolute paths',
|
||||||
description: 'Should work with absolute paths to SAS jobs',
|
description: 'Should work with absolute paths to SAS jobs',
|
||||||
test: () => {
|
test: () => {
|
||||||
return adapter.request(`${appLoc}/common/sendArr`, stringData)
|
return adapter.request(`${appLoc}/services/common/sendArr`, stringData)
|
||||||
},
|
},
|
||||||
assertion: (res: any) => {
|
assertion: (res: any) => {
|
||||||
return res.table1[0][0] === stringData.table1[0].col1
|
return res.table1[0][0] === stringData.table1[0].col1
|
||||||
@@ -63,7 +63,7 @@ export const sendArrTests = (adapter: SASjs, appLoc: string): TestSuite => ({
|
|||||||
title: 'Single string value',
|
title: 'Single string value',
|
||||||
description: 'Should send an array with a single string value',
|
description: 'Should send an array with a single string value',
|
||||||
test: () => {
|
test: () => {
|
||||||
return adapter.request('common/sendArr', stringData)
|
return adapter.request('services/common/sendArr', stringData)
|
||||||
},
|
},
|
||||||
assertion: (res: any) => {
|
assertion: (res: any) => {
|
||||||
return res.table1[0][0] === stringData.table1[0].col1
|
return res.table1[0][0] === stringData.table1[0].col1
|
||||||
@@ -74,7 +74,7 @@ export const sendArrTests = (adapter: SASjs, appLoc: string): TestSuite => ({
|
|||||||
description:
|
description:
|
||||||
'Should send an array with a long string value under 32765 characters',
|
'Should send an array with a long string value under 32765 characters',
|
||||||
test: () => {
|
test: () => {
|
||||||
return adapter.request('common/sendArr', getLongStringData())
|
return adapter.request('services/common/sendArr', getLongStringData())
|
||||||
},
|
},
|
||||||
assertion: (res: any) => {
|
assertion: (res: any) => {
|
||||||
const longStringData = getLongStringData()
|
const longStringData = getLongStringData()
|
||||||
@@ -87,7 +87,9 @@ export const sendArrTests = (adapter: SASjs, appLoc: string): TestSuite => ({
|
|||||||
'Should error out with long string values over 32765 characters',
|
'Should error out with long string values over 32765 characters',
|
||||||
test: () => {
|
test: () => {
|
||||||
const data = getLongStringData(32767)
|
const data = getLongStringData(32767)
|
||||||
return adapter.request('common/sendArr', data).catch((e: any) => e)
|
return adapter
|
||||||
|
.request('services/common/sendArr', data)
|
||||||
|
.catch((e: any) => e)
|
||||||
},
|
},
|
||||||
assertion: (error: any) => {
|
assertion: (error: any) => {
|
||||||
return !!error && !!error.error && !!error.error.message
|
return !!error && !!error.error && !!error.error.message
|
||||||
@@ -97,7 +99,7 @@ export const sendArrTests = (adapter: SASjs, appLoc: string): TestSuite => ({
|
|||||||
title: 'Single numeric value',
|
title: 'Single numeric value',
|
||||||
description: 'Should send an array with a single numeric value',
|
description: 'Should send an array with a single numeric value',
|
||||||
test: () => {
|
test: () => {
|
||||||
return adapter.request('common/sendArr', numericData)
|
return adapter.request('services/common/sendArr', numericData)
|
||||||
},
|
},
|
||||||
assertion: (res: any) => {
|
assertion: (res: any) => {
|
||||||
return res.table1[0][0] === numericData.table1[0].col1
|
return res.table1[0][0] === numericData.table1[0].col1
|
||||||
@@ -107,7 +109,7 @@ export const sendArrTests = (adapter: SASjs, appLoc: string): TestSuite => ({
|
|||||||
title: 'Multiple columns',
|
title: 'Multiple columns',
|
||||||
description: 'Should handle data with multiple columns',
|
description: 'Should handle data with multiple columns',
|
||||||
test: () => {
|
test: () => {
|
||||||
return adapter.request('common/sendArr', multiColumnData)
|
return adapter.request('services/common/sendArr', multiColumnData)
|
||||||
},
|
},
|
||||||
assertion: (res: any) => {
|
assertion: (res: any) => {
|
||||||
return (
|
return (
|
||||||
@@ -122,7 +124,7 @@ export const sendArrTests = (adapter: SASjs, appLoc: string): TestSuite => ({
|
|||||||
title: 'Multiple rows with nulls',
|
title: 'Multiple rows with nulls',
|
||||||
description: 'Should handle data with multiple rows with null values',
|
description: 'Should handle data with multiple rows with null values',
|
||||||
test: () => {
|
test: () => {
|
||||||
return adapter.request('common/sendArr', multipleRowsWithNulls)
|
return adapter.request('services/common/sendArr', multipleRowsWithNulls)
|
||||||
},
|
},
|
||||||
assertion: (res: any) => {
|
assertion: (res: any) => {
|
||||||
let result = true
|
let result = true
|
||||||
@@ -148,7 +150,10 @@ export const sendArrTests = (adapter: SASjs, appLoc: string): TestSuite => ({
|
|||||||
title: 'Multiple columns with nulls',
|
title: 'Multiple columns with nulls',
|
||||||
description: 'Should handle data with multiple columns with null values',
|
description: 'Should handle data with multiple columns with null values',
|
||||||
test: () => {
|
test: () => {
|
||||||
return adapter.request('common/sendArr', multipleColumnsWithNulls)
|
return adapter.request(
|
||||||
|
'services/common/sendArr',
|
||||||
|
multipleColumnsWithNulls
|
||||||
|
)
|
||||||
},
|
},
|
||||||
assertion: (res: any) => {
|
assertion: (res: any) => {
|
||||||
let result = true
|
let result = true
|
||||||
@@ -184,7 +189,7 @@ export const sendObjTests = (adapter: SASjs): TestSuite => ({
|
|||||||
'1InvalidTable': [{ col1: 42 }]
|
'1InvalidTable': [{ col1: 42 }]
|
||||||
}
|
}
|
||||||
return adapter
|
return adapter
|
||||||
.request('common/sendObj', invalidData)
|
.request('services/common/sendObj', invalidData)
|
||||||
.catch((e: any) => e)
|
.catch((e: any) => e)
|
||||||
},
|
},
|
||||||
assertion: (error: any) =>
|
assertion: (error: any) =>
|
||||||
@@ -198,7 +203,7 @@ export const sendObjTests = (adapter: SASjs): TestSuite => ({
|
|||||||
'an invalidTable': [{ col1: 42 }]
|
'an invalidTable': [{ col1: 42 }]
|
||||||
}
|
}
|
||||||
return adapter
|
return adapter
|
||||||
.request('common/sendObj', invalidData)
|
.request('services/common/sendObj', invalidData)
|
||||||
.catch((e: any) => e)
|
.catch((e: any) => e)
|
||||||
},
|
},
|
||||||
assertion: (error: any) =>
|
assertion: (error: any) =>
|
||||||
@@ -212,7 +217,7 @@ export const sendObjTests = (adapter: SASjs): TestSuite => ({
|
|||||||
'anInvalidTable#': [{ col1: 42 }]
|
'anInvalidTable#': [{ col1: 42 }]
|
||||||
}
|
}
|
||||||
return adapter
|
return adapter
|
||||||
.request('common/sendObj', invalidData)
|
.request('services/common/sendObj', invalidData)
|
||||||
.catch((e: any) => e)
|
.catch((e: any) => e)
|
||||||
},
|
},
|
||||||
assertion: (error: any) =>
|
assertion: (error: any) =>
|
||||||
@@ -227,7 +232,7 @@ export const sendObjTests = (adapter: SASjs): TestSuite => ({
|
|||||||
}
|
}
|
||||||
|
|
||||||
return adapter
|
return adapter
|
||||||
.request('common/sendObj', invalidData)
|
.request('services/common/sendObj', invalidData)
|
||||||
.catch((e: any) => e)
|
.catch((e: any) => e)
|
||||||
},
|
},
|
||||||
assertion: (error: any) =>
|
assertion: (error: any) =>
|
||||||
@@ -241,7 +246,7 @@ export const sendObjTests = (adapter: SASjs): TestSuite => ({
|
|||||||
inData: [[{ data: 'value' }]]
|
inData: [[{ data: 'value' }]]
|
||||||
}
|
}
|
||||||
return adapter
|
return adapter
|
||||||
.request('common/sendObj', invalidData)
|
.request('services/common/sendObj', invalidData)
|
||||||
.catch((e: any) => e)
|
.catch((e: any) => e)
|
||||||
},
|
},
|
||||||
assertion: (error: any) =>
|
assertion: (error: any) =>
|
||||||
@@ -251,7 +256,7 @@ export const sendObjTests = (adapter: SASjs): TestSuite => ({
|
|||||||
title: 'Single string value',
|
title: 'Single string value',
|
||||||
description: 'Should send an object with a single string value',
|
description: 'Should send an object with a single string value',
|
||||||
test: () => {
|
test: () => {
|
||||||
return adapter.request('common/sendObj', stringData)
|
return adapter.request('services/common/sendObj', stringData)
|
||||||
},
|
},
|
||||||
assertion: (res: any) => {
|
assertion: (res: any) => {
|
||||||
return res.table1[0].COL1 === stringData.table1[0].col1
|
return res.table1[0].COL1 === stringData.table1[0].col1
|
||||||
@@ -262,7 +267,7 @@ export const sendObjTests = (adapter: SASjs): TestSuite => ({
|
|||||||
description:
|
description:
|
||||||
'Should send an object with a long string value under 32765 characters',
|
'Should send an object with a long string value under 32765 characters',
|
||||||
test: () => {
|
test: () => {
|
||||||
return adapter.request('common/sendObj', getLongStringData())
|
return adapter.request('services/common/sendObj', getLongStringData())
|
||||||
},
|
},
|
||||||
assertion: (res: any) => {
|
assertion: (res: any) => {
|
||||||
const longStringData = getLongStringData()
|
const longStringData = getLongStringData()
|
||||||
@@ -275,7 +280,7 @@ export const sendObjTests = (adapter: SASjs): TestSuite => ({
|
|||||||
'Should error out with long string values over 32765 characters',
|
'Should error out with long string values over 32765 characters',
|
||||||
test: () => {
|
test: () => {
|
||||||
return adapter
|
return adapter
|
||||||
.request('common/sendObj', getLongStringData(32767))
|
.request('services/common/sendObj', getLongStringData(32767))
|
||||||
.catch((e: any) => e)
|
.catch((e: any) => e)
|
||||||
},
|
},
|
||||||
assertion: (error: any) => {
|
assertion: (error: any) => {
|
||||||
@@ -286,7 +291,7 @@ export const sendObjTests = (adapter: SASjs): TestSuite => ({
|
|||||||
title: 'Single numeric value',
|
title: 'Single numeric value',
|
||||||
description: 'Should send an object with a single numeric value',
|
description: 'Should send an object with a single numeric value',
|
||||||
test: () => {
|
test: () => {
|
||||||
return adapter.request('common/sendObj', numericData)
|
return adapter.request('services/common/sendObj', numericData)
|
||||||
},
|
},
|
||||||
assertion: (res: any) => {
|
assertion: (res: any) => {
|
||||||
return res.table1[0].COL1 === numericData.table1[0].col1
|
return res.table1[0].COL1 === numericData.table1[0].col1
|
||||||
@@ -297,7 +302,7 @@ export const sendObjTests = (adapter: SASjs): TestSuite => ({
|
|||||||
title: 'Large data volume',
|
title: 'Large data volume',
|
||||||
description: 'Should send an object with a large amount of data',
|
description: 'Should send an object with a large amount of data',
|
||||||
test: () => {
|
test: () => {
|
||||||
return adapter.request('common/sendObj', getLargeObjectData())
|
return adapter.request('services/common/sendObj', getLargeObjectData())
|
||||||
},
|
},
|
||||||
assertion: (res: any) => {
|
assertion: (res: any) => {
|
||||||
const data = getLargeObjectData()
|
const data = getLargeObjectData()
|
||||||
@@ -308,7 +313,7 @@ export const sendObjTests = (adapter: SASjs): TestSuite => ({
|
|||||||
title: 'Multiple columns',
|
title: 'Multiple columns',
|
||||||
description: 'Should handle data with multiple columns',
|
description: 'Should handle data with multiple columns',
|
||||||
test: () => {
|
test: () => {
|
||||||
return adapter.request('common/sendObj', multiColumnData)
|
return adapter.request('services/common/sendObj', multiColumnData)
|
||||||
},
|
},
|
||||||
assertion: (res: any) => {
|
assertion: (res: any) => {
|
||||||
return (
|
return (
|
||||||
@@ -323,7 +328,7 @@ export const sendObjTests = (adapter: SASjs): TestSuite => ({
|
|||||||
title: 'Multiple rows with nulls',
|
title: 'Multiple rows with nulls',
|
||||||
description: 'Should handle data with multiple rows with null values',
|
description: 'Should handle data with multiple rows with null values',
|
||||||
test: () => {
|
test: () => {
|
||||||
return adapter.request('common/sendObj', multipleRowsWithNulls)
|
return adapter.request('services/common/sendObj', multipleRowsWithNulls)
|
||||||
},
|
},
|
||||||
assertion: (res: any) => {
|
assertion: (res: any) => {
|
||||||
let result = true
|
let result = true
|
||||||
@@ -349,7 +354,10 @@ export const sendObjTests = (adapter: SASjs): TestSuite => ({
|
|||||||
title: 'Multiple columns with nulls',
|
title: 'Multiple columns with nulls',
|
||||||
description: 'Should handle data with multiple columns with null values',
|
description: 'Should handle data with multiple columns with null values',
|
||||||
test: () => {
|
test: () => {
|
||||||
return adapter.request('common/sendObj', multipleColumnsWithNulls)
|
return adapter.request(
|
||||||
|
'services/common/sendObj',
|
||||||
|
multipleColumnsWithNulls
|
||||||
|
)
|
||||||
},
|
},
|
||||||
assertion: (res: any) => {
|
assertion: (res: any) => {
|
||||||
let result = true
|
let result = true
|
||||||
|
|||||||
@@ -11,7 +11,7 @@ export const sasjsRequestTests = (adapter: SASjs): TestSuite => ({
|
|||||||
title: 'WORK tables',
|
title: 'WORK tables',
|
||||||
description: 'Should get WORK tables after request',
|
description: 'Should get WORK tables after request',
|
||||||
test: async () => {
|
test: async () => {
|
||||||
return adapter.request('common/sendArr', data)
|
return adapter.request('services/common/sendArr', data)
|
||||||
},
|
},
|
||||||
assertion: () => {
|
assertion: () => {
|
||||||
const requests = adapter.getSasRequests()
|
const requests = adapter.getSasRequests()
|
||||||
@@ -28,7 +28,7 @@ export const sasjsRequestTests = (adapter: SASjs): TestSuite => ({
|
|||||||
// 'Should make an error and capture log, in the same time it is testing if debug override is working',
|
// 'Should make an error and capture log, in the same time it is testing if debug override is working',
|
||||||
// test: async () => {
|
// test: async () => {
|
||||||
// return adapter
|
// return adapter
|
||||||
// .request('common/makeErr', data, { debug: true })
|
// .request('services/common/makeErr', data, { debug: true })
|
||||||
// .catch(() => {
|
// .catch(() => {
|
||||||
// const sasRequests = adapter.getSasRequests()
|
// const sasRequests = adapter.getSasRequests()
|
||||||
// const makeErrRequest: any =
|
// const makeErrRequest: any =
|
||||||
|
|||||||
@@ -111,7 +111,7 @@ export const specialCaseTests = (adapter: SASjs): TestSuite => ({
|
|||||||
title: 'Common special characters',
|
title: 'Common special characters',
|
||||||
description: 'Should handle common special characters',
|
description: 'Should handle common special characters',
|
||||||
test: () => {
|
test: () => {
|
||||||
return adapter.request('common/sendArr', specialCharData)
|
return adapter.request('services/common/sendArr', specialCharData)
|
||||||
},
|
},
|
||||||
assertion: (res: any) => {
|
assertion: (res: any) => {
|
||||||
return (
|
return (
|
||||||
@@ -133,7 +133,7 @@ export const specialCaseTests = (adapter: SASjs): TestSuite => ({
|
|||||||
title: 'Other special characters',
|
title: 'Other special characters',
|
||||||
description: 'Should handle other special characters',
|
description: 'Should handle other special characters',
|
||||||
test: () => {
|
test: () => {
|
||||||
return adapter.request('common/sendArr', moreSpecialCharData)
|
return adapter.request('services/common/sendArr', moreSpecialCharData)
|
||||||
},
|
},
|
||||||
assertion: (res: any) => {
|
assertion: (res: any) => {
|
||||||
// If sas session is `latin9` or `wlatin1` we can't process the special characters,
|
// If sas session is `latin9` or `wlatin1` we can't process the special characters,
|
||||||
@@ -169,7 +169,7 @@ export const specialCaseTests = (adapter: SASjs): TestSuite => ({
|
|||||||
title: 'Wide table with sendArr',
|
title: 'Wide table with sendArr',
|
||||||
description: 'Should handle data with 10000 columns',
|
description: 'Should handle data with 10000 columns',
|
||||||
test: () => {
|
test: () => {
|
||||||
return adapter.request('common/sendArr', getWideData())
|
return adapter.request('services/common/sendArr', getWideData())
|
||||||
},
|
},
|
||||||
assertion: (res: any) => {
|
assertion: (res: any) => {
|
||||||
const data = getWideData()
|
const data = getWideData()
|
||||||
@@ -185,7 +185,7 @@ export const specialCaseTests = (adapter: SASjs): TestSuite => ({
|
|||||||
title: 'Wide table with sendObj',
|
title: 'Wide table with sendObj',
|
||||||
description: 'Should handle data with 10000 columns',
|
description: 'Should handle data with 10000 columns',
|
||||||
test: () => {
|
test: () => {
|
||||||
return adapter.request('common/sendObj', getWideData())
|
return adapter.request('services/common/sendObj', getWideData())
|
||||||
},
|
},
|
||||||
assertion: (res: any) => {
|
assertion: (res: any) => {
|
||||||
const data = getWideData()
|
const data = getWideData()
|
||||||
@@ -202,7 +202,7 @@ export const specialCaseTests = (adapter: SASjs): TestSuite => ({
|
|||||||
title: 'Multiple tables',
|
title: 'Multiple tables',
|
||||||
description: 'Should handle data with 100 tables',
|
description: 'Should handle data with 100 tables',
|
||||||
test: () => {
|
test: () => {
|
||||||
return adapter.request('common/sendArr', getTables())
|
return adapter.request('services/common/sendArr', getTables())
|
||||||
},
|
},
|
||||||
assertion: (res: any) => {
|
assertion: (res: any) => {
|
||||||
const data = getTables()
|
const data = getTables()
|
||||||
@@ -222,7 +222,7 @@ export const specialCaseTests = (adapter: SASjs): TestSuite => ({
|
|||||||
title: 'Large dataset with sendObj',
|
title: 'Large dataset with sendObj',
|
||||||
description: 'Should handle 5mb of data',
|
description: 'Should handle 5mb of data',
|
||||||
test: () => {
|
test: () => {
|
||||||
return adapter.request('common/sendObj', getLargeDataset())
|
return adapter.request('services/common/sendObj', getLargeDataset())
|
||||||
},
|
},
|
||||||
assertion: (res: any) => {
|
assertion: (res: any) => {
|
||||||
const data = getLargeDataset()
|
const data = getLargeDataset()
|
||||||
@@ -237,7 +237,7 @@ export const specialCaseTests = (adapter: SASjs): TestSuite => ({
|
|||||||
title: 'Large dataset with sendArr',
|
title: 'Large dataset with sendArr',
|
||||||
description: 'Should handle 5mb of data',
|
description: 'Should handle 5mb of data',
|
||||||
test: () => {
|
test: () => {
|
||||||
return adapter.request('common/sendArr', getLargeDataset())
|
return adapter.request('services/common/sendArr', getLargeDataset())
|
||||||
},
|
},
|
||||||
assertion: (res: any) => {
|
assertion: (res: any) => {
|
||||||
const data = getLargeDataset()
|
const data = getLargeDataset()
|
||||||
@@ -253,7 +253,7 @@ export const specialCaseTests = (adapter: SASjs): TestSuite => ({
|
|||||||
title: 'Error and _csrf tables with sendArr',
|
title: 'Error and _csrf tables with sendArr',
|
||||||
description: 'Should handle error and _csrf tables',
|
description: 'Should handle error and _csrf tables',
|
||||||
test: () => {
|
test: () => {
|
||||||
return adapter.request('common/sendArr', errorAndCsrfData)
|
return adapter.request('services/common/sendArr', errorAndCsrfData)
|
||||||
},
|
},
|
||||||
assertion: (res: any) => {
|
assertion: (res: any) => {
|
||||||
return (
|
return (
|
||||||
@@ -272,7 +272,7 @@ export const specialCaseTests = (adapter: SASjs): TestSuite => ({
|
|||||||
title: 'Error and _csrf tables with sendObj',
|
title: 'Error and _csrf tables with sendObj',
|
||||||
description: 'Should handle error and _csrf tables',
|
description: 'Should handle error and _csrf tables',
|
||||||
test: () => {
|
test: () => {
|
||||||
return adapter.request('common/sendObj', errorAndCsrfData)
|
return adapter.request('services/common/sendObj', errorAndCsrfData)
|
||||||
},
|
},
|
||||||
assertion: (res: any) => {
|
assertion: (res: any) => {
|
||||||
return (
|
return (
|
||||||
@@ -300,7 +300,7 @@ export const specialCaseTests = (adapter: SASjs): TestSuite => ({
|
|||||||
}
|
}
|
||||||
|
|
||||||
return await adapter.request(
|
return await adapter.request(
|
||||||
'common/sendArr',
|
'services/common/sendArr',
|
||||||
stringData,
|
stringData,
|
||||||
config,
|
config,
|
||||||
undefined,
|
undefined,
|
||||||
@@ -319,7 +319,10 @@ export const specialCaseTests = (adapter: SASjs): TestSuite => ({
|
|||||||
title: 'Special missing values',
|
title: 'Special missing values',
|
||||||
description: 'Should support special missing values',
|
description: 'Should support special missing values',
|
||||||
test: () => {
|
test: () => {
|
||||||
return adapter.request('common/sendObj', testTableWithSpecialNumeric)
|
return adapter.request(
|
||||||
|
'services/common/sendObj',
|
||||||
|
testTableWithSpecialNumeric
|
||||||
|
)
|
||||||
},
|
},
|
||||||
assertion: (res: any) => {
|
assertion: (res: any) => {
|
||||||
let assertionRes = true
|
let assertionRes = true
|
||||||
@@ -365,7 +368,7 @@ export const specialCaseTests = (adapter: SASjs): TestSuite => ({
|
|||||||
'Should support special missing values, when one row is send',
|
'Should support special missing values, when one row is send',
|
||||||
test: () => {
|
test: () => {
|
||||||
return adapter.request(
|
return adapter.request(
|
||||||
'common/sendObj',
|
'services/common/sendObj',
|
||||||
testTableWithSpecialNumericOneRow
|
testTableWithSpecialNumericOneRow
|
||||||
)
|
)
|
||||||
},
|
},
|
||||||
@@ -413,7 +416,7 @@ export const specialCaseTests = (adapter: SASjs): TestSuite => ({
|
|||||||
'Should support special missing values, when LOWERCASE value is sent',
|
'Should support special missing values, when LOWERCASE value is sent',
|
||||||
test: () => {
|
test: () => {
|
||||||
return adapter.request(
|
return adapter.request(
|
||||||
'common/sendObj',
|
'services/common/sendObj',
|
||||||
testTableWithSpecialNumericLowercase
|
testTableWithSpecialNumericLowercase
|
||||||
)
|
)
|
||||||
},
|
},
|
||||||
@@ -469,7 +472,7 @@ export const specialCaseTests = (adapter: SASjs): TestSuite => ({
|
|||||||
'Should support special missing values, when one row is send (On VIYA Web Approach)',
|
'Should support special missing values, when one row is send (On VIYA Web Approach)',
|
||||||
test: () => {
|
test: () => {
|
||||||
return adapter.request(
|
return adapter.request(
|
||||||
'common/sendObj',
|
'services/common/sendObj',
|
||||||
testTableWithSpecialNumericOneRow,
|
testTableWithSpecialNumericOneRow,
|
||||||
{ useComputeApi: undefined }
|
{ useComputeApi: undefined }
|
||||||
)
|
)
|
||||||
|
|||||||
+16
-11
@@ -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
|
||||||
)
|
)
|
||||||
|
|||||||
@@ -1026,17 +1026,22 @@ 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
|
||||||
})
|
})
|
||||||
|
|
||||||
|
// Viya JES requires arguments to be Map<String,String>; coerce booleans/numbers.
|
||||||
|
const stringifiedArguments: { [key: string]: string } = {}
|
||||||
|
for (const k of Object.keys(jobArguments)) {
|
||||||
|
stringifiedArguments[k] = String(jobArguments[k])
|
||||||
|
}
|
||||||
|
|
||||||
const postJobRequestBody = {
|
const postJobRequestBody = {
|
||||||
name: `exec-${jobName}`,
|
name: `exec-${jobName}`,
|
||||||
description: 'Powered by SASjs',
|
description: 'Powered by SASjs',
|
||||||
jobDefinition,
|
jobDefinition,
|
||||||
arguments: jobArguments
|
arguments: stringifiedArguments
|
||||||
}
|
}
|
||||||
|
|
||||||
const { result: postedJob } = await this.requestClient.post<Job>(
|
const { result: postedJob } = await this.requestClient.post<Job>(
|
||||||
|
|||||||
+2
-2
@@ -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
|
||||||
})
|
})
|
||||||
|
|||||||
@@ -23,6 +23,20 @@ describe('uploadTables', () => {
|
|||||||
)
|
)
|
||||||
})
|
})
|
||||||
|
|
||||||
|
it('should skip $tablename formats metadata keys', async () => {
|
||||||
|
const data = {
|
||||||
|
tablewith2cols2rows: [{ col1: 'val1', specialMissingsCol: 'A' }],
|
||||||
|
$tablewith2cols2rows: { formats: { specialMissingsCol: 'best.' } }
|
||||||
|
}
|
||||||
|
|
||||||
|
const files = await uploadTables(requestClient, data, 't0k3n')
|
||||||
|
|
||||||
|
expect(files).toEqual([
|
||||||
|
{ tableName: 'tablewith2cols2rows', file: 'test-file' }
|
||||||
|
])
|
||||||
|
expect(requestClient.uploadFile).toHaveBeenCalledTimes(1)
|
||||||
|
})
|
||||||
|
|
||||||
it('should throw an error when the CSV exceeds the maximum length', async () => {
|
it('should throw an error when the CSV exceeds the maximum length', async () => {
|
||||||
const data = { foo: 'bar' }
|
const data = { foo: 'bar' }
|
||||||
jest
|
jest
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
import { prefixMessage } from '@sasjs/utils/error'
|
import { prefixMessage } from '@sasjs/utils/error'
|
||||||
import { RequestClient } from '../../request/RequestClient'
|
import { RequestClient } from '../../request/RequestClient'
|
||||||
import { convertToCSV } from '../../utils/convertToCsv'
|
import { convertToCSV, isFormatsTable } from '../../utils/convertToCsv'
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Uploads tables to SAS as specially formatted CSVs.
|
* Uploads tables to SAS as specially formatted CSVs.
|
||||||
@@ -18,6 +18,10 @@ export async function uploadTables(
|
|||||||
const uploadedFiles = []
|
const uploadedFiles = []
|
||||||
|
|
||||||
for (const tableName in data) {
|
for (const tableName in data) {
|
||||||
|
// $tablename keys carry only column-format metadata for the matching
|
||||||
|
// tablename payload; they must not be uploaded as separate files.
|
||||||
|
if (isFormatsTable(tableName)) continue
|
||||||
|
|
||||||
const csv = convertToCSV(data, tableName)
|
const csv = convertToCSV(data, tableName)
|
||||||
if (csv === 'ERROR: LARGE STRING LENGTH') {
|
if (csv === 'ERROR: LARGE STRING LENGTH') {
|
||||||
throw new Error(
|
throw new Error(
|
||||||
|
|||||||
@@ -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')
|
||||||
@@ -375,7 +375,7 @@ export class AuthManager {
|
|||||||
*
|
*
|
||||||
*/
|
*/
|
||||||
public async logOut() {
|
public async logOut() {
|
||||||
this.requestClient.resetInMemoryAuthState()
|
this.requestClient.clearCsrfTokens()
|
||||||
|
|
||||||
return this.requestClient.get(this.logoutUrl, undefined).then(() => true)
|
return this.requestClient.get(this.logoutUrl, undefined).then(() => true)
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -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[] = []
|
||||||
|
|
||||||
|
|||||||
@@ -28,9 +28,6 @@ import {
|
|||||||
import { InvalidSASjsCsrfError } from '../types/errors/InvalidSASjsCsrfError'
|
import { InvalidSASjsCsrfError } from '../types/errors/InvalidSASjsCsrfError'
|
||||||
import { inspect } from 'util'
|
import { inspect } from 'util'
|
||||||
|
|
||||||
const getLogger = () =>
|
|
||||||
(typeof process !== 'undefined' && process.logger) || console
|
|
||||||
|
|
||||||
export class RequestClient implements HttpClient {
|
export class RequestClient implements HttpClient {
|
||||||
private requests: SASjsRequest[] = []
|
private requests: SASjsRequest[] = []
|
||||||
private requestsLimit: number = 10
|
private requestsLimit: number = 10
|
||||||
@@ -40,7 +37,6 @@ export class RequestClient implements HttpClient {
|
|||||||
protected csrfToken: CsrfToken = { headerName: '', value: '' }
|
protected csrfToken: CsrfToken = { headerName: '', value: '' }
|
||||||
protected fileUploadCsrfToken: CsrfToken | undefined
|
protected fileUploadCsrfToken: CsrfToken | undefined
|
||||||
protected httpClient!: AxiosInstance
|
protected httpClient!: AxiosInstance
|
||||||
private isRecoveringFromNetworkError = false
|
|
||||||
|
|
||||||
constructor(
|
constructor(
|
||||||
protected baseUrl: string,
|
protected baseUrl: string,
|
||||||
@@ -81,36 +77,6 @@ export class RequestClient implements HttpClient {
|
|||||||
localStorage.setItem('refreshToken', '')
|
localStorage.setItem('refreshToken', '')
|
||||||
}
|
}
|
||||||
|
|
||||||
public resetInMemoryAuthState() {
|
|
||||||
const logger = getLogger()
|
|
||||||
const clearedCookies: string[] = []
|
|
||||||
|
|
||||||
this.clearCsrfTokens()
|
|
||||||
if (typeof localStorage !== 'undefined') {
|
|
||||||
this.clearLocalStorageTokens()
|
|
||||||
}
|
|
||||||
if (typeof document !== 'undefined') {
|
|
||||||
clearedCookies.push(...this.clearAllCookies())
|
|
||||||
}
|
|
||||||
|
|
||||||
logger.warn('[resetInMemoryAuthState] cleared', {
|
|
||||||
cookies: clearedCookies,
|
|
||||||
localStorage: typeof localStorage !== 'undefined'
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
private clearAllCookies(): string[] {
|
|
||||||
const cookies = document.cookie.split(';')
|
|
||||||
const cleared: string[] = []
|
|
||||||
for (const cookie of cookies) {
|
|
||||||
const name = cookie.split('=')[0].trim()
|
|
||||||
if (!name) continue
|
|
||||||
document.cookie = `${name}=; Max-Age=0; Path=/;`
|
|
||||||
cleared.push(name)
|
|
||||||
}
|
|
||||||
return cleared
|
|
||||||
}
|
|
||||||
|
|
||||||
public getBaseUrl() {
|
public getBaseUrl() {
|
||||||
return this.httpClient.defaults.baseURL || ''
|
return this.httpClient.defaults.baseURL || ''
|
||||||
}
|
}
|
||||||
@@ -388,14 +354,9 @@ export class RequestClient implements HttpClient {
|
|||||||
const csrfTokenKey = Object.keys(params).find((k) =>
|
const csrfTokenKey = Object.keys(params).find((k) =>
|
||||||
k?.toLowerCase().includes('csrf')
|
k?.toLowerCase().includes('csrf')
|
||||||
)
|
)
|
||||||
const logger = getLogger()
|
|
||||||
|
|
||||||
if (csrfTokenKey) {
|
if (csrfTokenKey) {
|
||||||
this.csrfToken.value = params[csrfTokenKey]
|
this.csrfToken.value = params[csrfTokenKey]
|
||||||
this.csrfToken.headerName = this.csrfToken.headerName || 'x-csrf-token'
|
this.csrfToken.headerName = this.csrfToken.headerName || 'x-csrf-token'
|
||||||
logger.warn('[authorize] CSRF from form', {
|
|
||||||
headerName: this.csrfToken.headerName
|
|
||||||
})
|
|
||||||
}
|
}
|
||||||
|
|
||||||
const formData = new FormData()
|
const formData = new FormData()
|
||||||
@@ -410,23 +371,15 @@ export class RequestClient implements HttpClient {
|
|||||||
throw new Error('Auth Form URL is null or undefined.')
|
throw new Error('Auth Form URL is null or undefined.')
|
||||||
}
|
}
|
||||||
|
|
||||||
logger.warn('[authorize] posting to', { authUrl })
|
|
||||||
|
|
||||||
return await this.httpClient
|
return await this.httpClient
|
||||||
.post(authUrl, formData, {
|
.post(authUrl, formData, {
|
||||||
responseType: 'text',
|
responseType: 'text',
|
||||||
headers: { Accept: '*/*', 'Content-Type': 'text/plain' }
|
headers: { Accept: '*/*', 'Content-Type': 'text/plain' }
|
||||||
})
|
})
|
||||||
.then((res) => {
|
.then((res) => res.data)
|
||||||
logger.warn('[authorize] success', { status: res.status })
|
|
||||||
return res.data
|
|
||||||
})
|
|
||||||
.catch((error) => {
|
.catch((error) => {
|
||||||
logger.error('[authorize] failed', {
|
const logger = process.logger || console
|
||||||
code: error?.code,
|
logger.error(error)
|
||||||
status: error?.response?.status,
|
|
||||||
message: error?.message
|
|
||||||
})
|
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -625,16 +578,9 @@ ${resHeaders}${parsedResBody ? `\n\n${parsedResBody}` : ''}
|
|||||||
|
|
||||||
protected parseAndSetCsrfToken = (response: AxiosResponse) => {
|
protected parseAndSetCsrfToken = (response: AxiosResponse) => {
|
||||||
const token = this.parseCsrfToken(response)
|
const token = this.parseCsrfToken(response)
|
||||||
const logger = getLogger()
|
|
||||||
|
|
||||||
if (token) {
|
if (token) {
|
||||||
this.csrfToken = token
|
this.csrfToken = token
|
||||||
logger.warn('[parseAndSetCsrfToken] set', {
|
|
||||||
headerName: token.headerName,
|
|
||||||
hasValue: !!token.value
|
|
||||||
})
|
|
||||||
} else {
|
|
||||||
logger.warn('[parseAndSetCsrfToken] no token found in response')
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -654,11 +600,6 @@ ${resHeaders}${parsedResBody ? `\n\n${parsedResBody}` : ''}
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
private logHandleError(step: string, details?: Record<string, any>) {
|
|
||||||
const logger = getLogger()
|
|
||||||
logger.warn(`[handleError] ${step}`, details || '')
|
|
||||||
}
|
|
||||||
|
|
||||||
protected handleError = async (
|
protected handleError = async (
|
||||||
e: any,
|
e: any,
|
||||||
callback: any,
|
callback: any,
|
||||||
@@ -666,19 +607,7 @@ ${resHeaders}${parsedResBody ? `\n\n${parsedResBody}` : ''}
|
|||||||
) => {
|
) => {
|
||||||
const response = e.response as AxiosResponse
|
const response = e.response as AxiosResponse
|
||||||
|
|
||||||
this.logHandleError('entered', {
|
|
||||||
errorType: e?.constructor?.name,
|
|
||||||
code: e?.code,
|
|
||||||
status: response?.status,
|
|
||||||
url: e?.config?.url || response?.config?.url,
|
|
||||||
hasResponse: !!response,
|
|
||||||
isRecovering: this.isRecoveringFromNetworkError
|
|
||||||
})
|
|
||||||
|
|
||||||
if (e instanceof AuthorizeError) {
|
if (e instanceof AuthorizeError) {
|
||||||
this.logHandleError('AuthorizeError — fetching confirmUrl', {
|
|
||||||
confirmUrl: e.confirmUrl
|
|
||||||
})
|
|
||||||
const res = await this.httpClient
|
const res = await this.httpClient
|
||||||
.get(e.confirmUrl, {
|
.get(e.confirmUrl, {
|
||||||
responseType: 'text',
|
responseType: 'text',
|
||||||
@@ -688,24 +617,13 @@ ${resHeaders}${parsedResBody ? `\n\n${parsedResBody}` : ''}
|
|||||||
throw prefixMessage(err, 'Error while getting error confirmUrl. ')
|
throw prefixMessage(err, 'Error while getting error confirmUrl. ')
|
||||||
})
|
})
|
||||||
|
|
||||||
const needsAuthorize = isAuthorizeFormRequired(res?.data as string)
|
if (isAuthorizeFormRequired(res?.data as string)) {
|
||||||
this.logHandleError(
|
|
||||||
'AuthorizeError — authorize form required: ' + needsAuthorize
|
|
||||||
)
|
|
||||||
|
|
||||||
if (needsAuthorize) {
|
|
||||||
await this.authorize(res.data as string).catch((err) => {
|
await this.authorize(res.data as string).catch((err) => {
|
||||||
throw prefixMessage(err, 'Error while authorizing request. ')
|
throw prefixMessage(err, 'Error while authorizing request. ')
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
this.logHandleError('AuthorizeError — retrying callback')
|
|
||||||
return await callback().catch((err: any) => {
|
return await callback().catch((err: any) => {
|
||||||
this.logHandleError('AuthorizeError — callback failed', {
|
|
||||||
errorType: err?.constructor?.name,
|
|
||||||
code: err?.code,
|
|
||||||
message: err?.message
|
|
||||||
})
|
|
||||||
throw prefixMessage(
|
throw prefixMessage(
|
||||||
err,
|
err,
|
||||||
'Error while executing callback in handleError. '
|
'Error while executing callback in handleError. '
|
||||||
@@ -714,14 +632,12 @@ ${resHeaders}${parsedResBody ? `\n\n${parsedResBody}` : ''}
|
|||||||
}
|
}
|
||||||
|
|
||||||
if (e instanceof LoginRequiredError) {
|
if (e instanceof LoginRequiredError) {
|
||||||
this.logHandleError('LoginRequiredError — clearing CSRF and re-throwing')
|
|
||||||
this.clearCsrfTokens()
|
this.clearCsrfTokens()
|
||||||
|
|
||||||
throw e
|
throw e
|
||||||
}
|
}
|
||||||
|
|
||||||
if (e instanceof InvalidSASjsCsrfError) {
|
if (e instanceof InvalidSASjsCsrfError) {
|
||||||
this.logHandleError('InvalidSASjsCsrfError — re-fetching CSRF cookie')
|
|
||||||
// Fetching root and creating CSRF cookie
|
// Fetching root and creating CSRF cookie
|
||||||
await this.httpClient
|
await this.httpClient
|
||||||
.get('/', {
|
.get('/', {
|
||||||
@@ -733,22 +649,13 @@ ${resHeaders}${parsedResBody ? `\n\n${parsedResBody}` : ''}
|
|||||||
response.data
|
response.data
|
||||||
)?.[1]
|
)?.[1]
|
||||||
|
|
||||||
this.logHandleError(
|
|
||||||
'InvalidSASjsCsrfError — cookie found: ' + !!cookie
|
|
||||||
)
|
|
||||||
if (cookie) document.cookie = cookie
|
if (cookie) document.cookie = cookie
|
||||||
})
|
})
|
||||||
.catch((err) => {
|
.catch((err) => {
|
||||||
throw prefixMessage(err, 'Error while re-fetching CSRF token.')
|
throw prefixMessage(err, 'Error while re-fetching CSRF token.')
|
||||||
})
|
})
|
||||||
|
|
||||||
this.logHandleError('InvalidSASjsCsrfError — retrying callback')
|
|
||||||
return await callback().catch((err: any) => {
|
return await callback().catch((err: any) => {
|
||||||
this.logHandleError('InvalidSASjsCsrfError — callback failed', {
|
|
||||||
errorType: err?.constructor?.name,
|
|
||||||
code: err?.code,
|
|
||||||
message: err?.message
|
|
||||||
})
|
|
||||||
throw prefixMessage(
|
throw prefixMessage(
|
||||||
err,
|
err,
|
||||||
'Error while executing callback in handleError. '
|
'Error while executing callback in handleError. '
|
||||||
@@ -759,20 +666,8 @@ ${resHeaders}${parsedResBody ? `\n\n${parsedResBody}` : ''}
|
|||||||
if (response?.status === 403 || response?.status === 449) {
|
if (response?.status === 403 || response?.status === 449) {
|
||||||
this.parseAndSetCsrfToken(response)
|
this.parseAndSetCsrfToken(response)
|
||||||
|
|
||||||
const hasToken = !!(this.csrfToken.headerName && this.csrfToken.value)
|
if (this.csrfToken.headerName && this.csrfToken.value) {
|
||||||
this.logHandleError('403/449 — parsed CSRF from response', {
|
|
||||||
hasToken,
|
|
||||||
headerName: this.csrfToken.headerName
|
|
||||||
})
|
|
||||||
|
|
||||||
if (hasToken) {
|
|
||||||
this.logHandleError('403/449 — retrying callback with new CSRF')
|
|
||||||
return await callback().catch((err: any) => {
|
return await callback().catch((err: any) => {
|
||||||
this.logHandleError('403/449 — callback failed', {
|
|
||||||
errorType: err?.constructor?.name,
|
|
||||||
code: err?.code,
|
|
||||||
message: err?.message
|
|
||||||
})
|
|
||||||
throw prefixMessage(
|
throw prefixMessage(
|
||||||
err,
|
err,
|
||||||
'Error while executing callback in handleError. '
|
'Error while executing callback in handleError. '
|
||||||
@@ -780,9 +675,6 @@ ${resHeaders}${parsedResBody ? `\n\n${parsedResBody}` : ''}
|
|||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
this.logHandleError(
|
|
||||||
'403/449 — no CSRF in response, throwing original error'
|
|
||||||
)
|
|
||||||
throw e
|
throw e
|
||||||
} else if (response?.status === 404) {
|
} else if (response?.status === 404) {
|
||||||
throw new NotFoundError(response.config.url!)
|
throw new NotFoundError(response.config.url!)
|
||||||
@@ -795,68 +687,6 @@ ${resHeaders}${parsedResBody ? `\n\n${parsedResBody}` : ''}
|
|||||||
throw new CertificateError(e.message)
|
throw new CertificateError(e.message)
|
||||||
}
|
}
|
||||||
|
|
||||||
if (
|
|
||||||
e.isAxiosError &&
|
|
||||||
!response &&
|
|
||||||
e.code === 'ERR_NETWORK' &&
|
|
||||||
!this.isRecoveringFromNetworkError
|
|
||||||
) {
|
|
||||||
// Opaque ERR_NETWORK usually means the server rejected stale credentials.
|
|
||||||
// Wipe in-memory auth state, re-establish session via GET /,
|
|
||||||
// then retry the original request.
|
|
||||||
this.logHandleError('ERR_NETWORK — clearing all auth state')
|
|
||||||
this.resetInMemoryAuthState()
|
|
||||||
this.isRecoveringFromNetworkError = true
|
|
||||||
try {
|
|
||||||
// Re-establish session and CSRF cookie
|
|
||||||
this.logHandleError('ERR_NETWORK — re-establishing session via GET /')
|
|
||||||
const rootResponse = await this.httpClient
|
|
||||||
.get('/', { withXSRFToken: true })
|
|
||||||
.catch((err) => {
|
|
||||||
this.logHandleError('ERR_NETWORK — GET / failed', {
|
|
||||||
code: err?.code,
|
|
||||||
status: err?.response?.status,
|
|
||||||
message: err?.message
|
|
||||||
})
|
|
||||||
return err.response
|
|
||||||
})
|
|
||||||
|
|
||||||
if (rootResponse?.data) {
|
|
||||||
const cookie =
|
|
||||||
/<script>document.cookie = '(XSRF-TOKEN=.*; Max-Age=86400; SameSite=Strict; Path=\/;)'<\/script>/.exec(
|
|
||||||
rootResponse.data
|
|
||||||
)?.[1]
|
|
||||||
|
|
||||||
if (cookie && typeof document !== 'undefined') {
|
|
||||||
document.cookie = cookie
|
|
||||||
this.logHandleError('ERR_NETWORK — XSRF-TOKEN cookie restored')
|
|
||||||
}
|
|
||||||
|
|
||||||
this.parseAndSetCsrfToken(rootResponse)
|
|
||||||
}
|
|
||||||
|
|
||||||
this.logHandleError('ERR_NETWORK — retrying original request')
|
|
||||||
return await callback()
|
|
||||||
} catch (retryErr: any) {
|
|
||||||
// Session could not be recovered — surface LoginRequiredError
|
|
||||||
this.logHandleError(
|
|
||||||
'ERR_NETWORK — retry failed, throwing LoginRequiredError',
|
|
||||||
{
|
|
||||||
errorType: retryErr?.constructor?.name,
|
|
||||||
code: retryErr?.code,
|
|
||||||
message: retryErr?.message
|
|
||||||
}
|
|
||||||
)
|
|
||||||
throw new LoginRequiredError()
|
|
||||||
} finally {
|
|
||||||
this.isRecoveringFromNetworkError = false
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
this.logHandleError('unhandled — throwing as-is', {
|
|
||||||
message: e?.message,
|
|
||||||
code: e?.code
|
|
||||||
})
|
|
||||||
if (e.message) throw e
|
if (e.message) throw e
|
||||||
else throw prefixMessage(e, 'Error while handling error. ')
|
else throw prefixMessage(e, 'Error while handling error. ')
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -23,13 +23,6 @@ export class Sas9RequestClient extends RequestClient {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public resetInMemoryAuthState() {
|
|
||||||
super.resetInMemoryAuthState()
|
|
||||||
if (this.httpClient.defaults.jar) {
|
|
||||||
;(this.httpClient.defaults.jar as tough.CookieJar).removeAllCookiesSync()
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
public async login(username: string, password: string, jobsPath: string) {
|
public async login(username: string, password: string, jobsPath: string) {
|
||||||
const codeInjectorPath = `/User Folders/${username}/My Folder/sasjs/runner`
|
const codeInjectorPath = `/User Folders/${username}/My Folder/sasjs/runner`
|
||||||
if (this.httpClient.defaults.jar) {
|
if (this.httpClient.defaults.jar) {
|
||||||
|
|||||||
@@ -589,42 +589,6 @@ ${resHeaders[0]}: ${resHeaders[1]}${
|
|||||||
requestClient['handleError'](error, () => {}, false)
|
requestClient['handleError'](error, () => {}, false)
|
||||||
).resolves.toEqual(undefined)
|
).resolves.toEqual(undefined)
|
||||||
})
|
})
|
||||||
|
|
||||||
it('should clear CSRF and retry once on opaque ERR_NETWORK', async () => {
|
|
||||||
const networkError = {
|
|
||||||
isAxiosError: true,
|
|
||||||
code: 'ERR_NETWORK',
|
|
||||||
message: 'Network Error'
|
|
||||||
}
|
|
||||||
requestClient['csrfToken'] = { headerName: 'h', value: 'v' }
|
|
||||||
const callback = jest.fn().mockResolvedValue('ok')
|
|
||||||
|
|
||||||
await expect(
|
|
||||||
requestClient['handleError'](networkError, callback)
|
|
||||||
).resolves.toEqual('ok')
|
|
||||||
|
|
||||||
expect(callback).toHaveBeenCalledTimes(1)
|
|
||||||
expect(requestClient['csrfToken']).toEqual({ headerName: '', value: '' })
|
|
||||||
})
|
|
||||||
|
|
||||||
it('should throw LoginRequiredError if retry also fails with ERR_NETWORK', async () => {
|
|
||||||
const networkError = {
|
|
||||||
isAxiosError: true,
|
|
||||||
code: 'ERR_NETWORK',
|
|
||||||
message: 'Network Error'
|
|
||||||
}
|
|
||||||
const innerHandle = jest.fn(() =>
|
|
||||||
requestClient['handleError'](networkError, () =>
|
|
||||||
Promise.reject(networkError)
|
|
||||||
)
|
|
||||||
)
|
|
||||||
|
|
||||||
await expect(
|
|
||||||
requestClient['handleError'](networkError, innerHandle)
|
|
||||||
).rejects.toThrow(LoginRequiredError)
|
|
||||||
|
|
||||||
expect(innerHandle).toHaveBeenCalledTimes(1)
|
|
||||||
})
|
|
||||||
})
|
})
|
||||||
})
|
})
|
||||||
|
|
||||||
@@ -667,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