mirror of
https://github.com/sasjs/adapter.git
synced 2026-01-06 04:00:05 +00:00
Compare commits
38 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
982c4c329c | ||
| 8617e2dc57 | |||
|
|
d3d62f6888 | ||
|
|
bf35e52962 | ||
| 22eca50e3f | |||
|
|
eb83101dbf | ||
|
|
56d84e1940 | ||
|
|
283800dfa6 | ||
|
|
c073d72dd4 | ||
|
|
f5d40eaaf7 | ||
|
|
8e9cf98985 | ||
|
|
79ba044dea | ||
|
|
9329dc848a | ||
|
|
98c492e85e | ||
| d1fcc2ca0a | |||
|
|
122f302bae | ||
|
|
c3a0ad1f41 | ||
|
|
a28b48f815 | ||
|
|
9b6a42e412 | ||
|
|
db60962c1e | ||
|
|
1eae59ad3b | ||
|
|
d485023d65 | ||
|
|
c2f21babb4 | ||
|
|
dd788ae423 | ||
|
|
a113c95441 | ||
|
|
489947bcae | ||
|
|
1596173dda | ||
|
|
bb1b2ddcb2 | ||
| a3cc274ef1 | |||
| 451d0906fa | |||
| dd6b89b0d0 | |||
|
|
f602d5baf0 | ||
|
|
4744dbf196 | ||
|
|
f0525c5796 | ||
| 076ed1cc7a | |||
| 0a3289b577 | |||
| d2ea67e5d6 | |||
| b0df4cb7ee |
6
.github/dependabot.yml
vendored
6
.github/dependabot.yml
vendored
@@ -1,7 +1,7 @@
|
|||||||
version: 2
|
version: 2
|
||||||
updates:
|
updates:
|
||||||
- package-ecosystem: npm
|
- package-ecosystem: "npm"
|
||||||
directory: '/'
|
directory: "/"
|
||||||
schedule:
|
schedule:
|
||||||
interval: monthly
|
interval: "monthly"
|
||||||
open-pull-requests-limit: 2
|
open-pull-requests-limit: 2
|
||||||
|
|||||||
17
.github/workflows/npmpublish.yml
vendored
17
.github/workflows/npmpublish.yml
vendored
@@ -11,10 +11,19 @@ on:
|
|||||||
jobs:
|
jobs:
|
||||||
build:
|
build:
|
||||||
runs-on: ubuntu-latest
|
runs-on: ubuntu-latest
|
||||||
|
|
||||||
|
strategy:
|
||||||
|
matrix:
|
||||||
|
node-version: [lts/fermium]
|
||||||
|
|
||||||
steps:
|
steps:
|
||||||
- name: Checkout
|
- uses: actions/checkout@v2
|
||||||
uses: actions/checkout@v2
|
- name: Use Node.js ${{ matrix.node-version }}
|
||||||
|
uses: actions/setup-node@v2
|
||||||
|
with:
|
||||||
|
node-version: ${{ matrix.node-version }}
|
||||||
|
cache: npm
|
||||||
|
|
||||||
- name: Install Dependencies
|
- name: Install Dependencies
|
||||||
run: npm ci
|
run: npm ci
|
||||||
|
|
||||||
@@ -23,7 +32,7 @@ jobs:
|
|||||||
|
|
||||||
- name: Build Project
|
- name: Build Project
|
||||||
run: npm run build
|
run: npm run build
|
||||||
|
|
||||||
- name: Semantic Release
|
- name: Semantic Release
|
||||||
uses: cycjimmy/semantic-release-action@v2
|
uses: cycjimmy/semantic-release-action@v2
|
||||||
env:
|
env:
|
||||||
|
|||||||
32
README.md
32
README.md
@@ -2,7 +2,6 @@
|
|||||||
|
|
||||||
[![npm package][npm-image]][npm-url]
|
[![npm package][npm-image]][npm-url]
|
||||||
[![Github Workflow][githubworkflow-image]][githubworkflow-url]
|
[![Github Workflow][githubworkflow-image]][githubworkflow-url]
|
||||||
[![Dependency Status][dependency-image]][dependency-url]
|
|
||||||
[]()
|
[]()
|
||||||

|

|
||||||
[](/LICENSE)
|
[](/LICENSE)
|
||||||
@@ -16,7 +15,6 @@
|
|||||||
[githubworkflow-image]:https://github.com/sasjs/adapter/actions/workflows/build.yml/badge.svg
|
[githubworkflow-image]:https://github.com/sasjs/adapter/actions/workflows/build.yml/badge.svg
|
||||||
[githubworkflow-url]:https://github.com/sasjs/adapter/blob/main/.github/workflows/build.yml
|
[githubworkflow-url]:https://github.com/sasjs/adapter/blob/main/.github/workflows/build.yml
|
||||||
[dependency-image]:https://david-dm.org/sasjs/adapter.svg
|
[dependency-image]:https://david-dm.org/sasjs/adapter.svg
|
||||||
[dependency-url]:https://github.com/sasjs/adapter/blob/main/package.json
|
|
||||||
|
|
||||||
SASjs is a open-source framework for building Web Apps on SAS® platforms. You can use as much or as little of it as you like. This repository contains the JS adapter, the part that handles the to/from SAS communication on the client side. There are 3 ways to install it:
|
SASjs is a open-source framework for building Web Apps on SAS® platforms. You can use as much or as little of it as you like. This repository contains the JS adapter, the part that handles the to/from SAS communication on the client side. There are 3 ways to install it:
|
||||||
|
|
||||||
@@ -32,7 +30,7 @@ For more information on building web apps with SAS, check out [sasjs.io](https:/
|
|||||||
|
|
||||||
## None of this makes sense. How do I build an app with it?
|
## None of this makes sense. How do I build an app with it?
|
||||||
|
|
||||||
Ok ok. Deploy this [example.html](https://raw.githubusercontent.com/sasjs/adapter/master/example.html) file to your web server, and update `servertype` to `SAS9` or `SASVIYA` depending on your backend.
|
Ok ok. Deploy this [example.html](https://raw.githubusercontent.com/sasjs/adapter/master/example.html) file to your web server, and update `servertype` to `SAS9`, `SASVIYA`, or `SASJS` depending on your backend.
|
||||||
|
|
||||||
The backend part can be deployed as follows:
|
The backend part can be deployed as follows:
|
||||||
|
|
||||||
@@ -52,7 +50,7 @@ parmcards4;
|
|||||||
%webout(OBJ,areas)
|
%webout(OBJ,areas)
|
||||||
%webout(CLOSE)
|
%webout(CLOSE)
|
||||||
;;;;
|
;;;;
|
||||||
%mp_createwebservice(path=&appLoc/common,name=getdata)
|
%mx_createwebservice(path=&appLoc/common,name=getdata)
|
||||||
```
|
```
|
||||||
|
|
||||||
You now have a simple web app with a backend service!
|
You now have a simple web app with a backend service!
|
||||||
@@ -96,10 +94,10 @@ const sasJs = new SASjs({your config})
|
|||||||
More on the config later.
|
More on the config later.
|
||||||
|
|
||||||
### SAS Logon
|
### SAS Logon
|
||||||
All authentication from the adapter is done against SASLogon. There are two approaches that can be taken, which are configured using the `LoginMechanism` attribute of the sasJs config object (above):
|
All authentication from the adapter is done against SASLogon. There are two approaches that can be taken, which are configured using the `loginMechanism` attribute of the sasJs config object (above):
|
||||||
|
|
||||||
* `LoginMechanism:'Redirected'` - this approach enables authentication through a SASLogon window, supporting complex authentication flows (such as 2FA) and avoids the need to handle passwords in the application itself. The styling of the window can be modified using CSS.
|
* `loginMechanism:'Redirected'` - this approach enables authentication through a SASLogon window, supporting complex authentication flows (such as 2FA) and avoids the need to handle passwords in the application itself. The styling of the window can be modified using CSS.
|
||||||
* `LoginMechanism:'Default'` - this approach requires that the username and password are captured, and used within the `.login()` method. This can be helpful for development, or automated testing.
|
* `loginMechanism:'Default'` - this approach requires that the username and password are captured, and used within the `.login()` method. This can be helpful for development, or automated testing.
|
||||||
|
|
||||||
Sample code for logging in with the `Default` approach:
|
Sample code for logging in with the `Default` approach:
|
||||||
|
|
||||||
@@ -127,7 +125,11 @@ sasJs.request("/path/to/my/service", dataObject)
|
|||||||
})
|
})
|
||||||
```
|
```
|
||||||
|
|
||||||
We supply the path to the SAS service, and a data object. The data object can be null (for services with no input), or can contain one or more tables in the following format:
|
We supply the path to the SAS service, and a data object.
|
||||||
|
|
||||||
|
If the path starts with a `/` then it should be a full path to the service. If there is no leading `/` then it is relative to the `appLoc`.
|
||||||
|
|
||||||
|
The data object can be null (for services with no input), or can contain one or more "tables" in the following format:
|
||||||
|
|
||||||
```javascript
|
```javascript
|
||||||
let dataObject={
|
let dataObject={
|
||||||
@@ -143,7 +145,9 @@ let dataObject={
|
|||||||
};
|
};
|
||||||
```
|
```
|
||||||
|
|
||||||
There are optional parameters such as a config object and a callback login function.
|
These tables (`tablewith2cols1row` and `tablewith1col2rows`) will be created in SAS WORK after running `%webout(FETCH)` in your SAS service.
|
||||||
|
|
||||||
|
The `request()` method also has optional parameters such as a config object and a callback login function.
|
||||||
|
|
||||||
The response object will contain returned tables and columns. Table names are always lowercase, and column names uppercase.
|
The response object will contain returned tables and columns. Table names are always lowercase, and column names uppercase.
|
||||||
|
|
||||||
@@ -155,7 +159,7 @@ The SAS type (char/numeric) of the values is determined according to a set of ru
|
|||||||
|
|
||||||
* If the values are numeric, the SAS type is numeric
|
* If the values are numeric, the SAS type is numeric
|
||||||
* If the values are all string, the SAS type is character
|
* If the values are all string, the SAS type is character
|
||||||
* If the values contain a single character (a-Z + underscore) AND a numeric, then the SAS type is numeric (with special missing values).
|
* If the values contain a single character (a-Z + underscore + .) AND a numeric, then the SAS type is numeric (with special missing values).
|
||||||
* `null` is set to either '.' or '' depending on the assigned or derived type per the above rules. If entire column is `null` then the type will be numeric.
|
* `null` is set to either '.' or '' depending on the assigned or derived type per the above rules. If entire column is `null` then the type will be numeric.
|
||||||
|
|
||||||
The following table illustrates the formats applied to columns under various scenarios:
|
The following table illustrates the formats applied to columns under various scenarios:
|
||||||
@@ -221,7 +225,7 @@ The SAS side is handled by a number of macros in the [macro core](https://github
|
|||||||
The following snippet shows the process of SAS tables arriving / leaving:
|
The following snippet shows the process of SAS tables arriving / leaving:
|
||||||
|
|
||||||
```sas
|
```sas
|
||||||
/* fetch all input tables sent from frontend - they arrive as work tables */
|
/* convert frontend input tables from into SASWORK datasets */
|
||||||
%webout(FETCH)
|
%webout(FETCH)
|
||||||
|
|
||||||
/* some sas code */
|
/* some sas code */
|
||||||
@@ -250,6 +254,8 @@ Where an entire column is made up of special missing numerics, there would be no
|
|||||||
%webout(OBJ,a,missing=STRING,showmeta=YES)
|
%webout(OBJ,a,missing=STRING,showmeta=YES)
|
||||||
```
|
```
|
||||||
|
|
||||||
|
The `%webout()` macro itself is just a wrapper for the [mp_jsonout](https://core.sasjs.io/mp__jsonout_8sas.html) macro.
|
||||||
|
|
||||||
## Configuration
|
## Configuration
|
||||||
|
|
||||||
Configuration on the client side involves passing an object on startup, which can also be passed with each request. Technical documentation on the SASjsConfig class is available [here](https://adapter.sasjs.io/classes/types.sasjsconfig.html). The main config items are:
|
Configuration on the client side involves passing an object on startup, which can also be passed with each request. Technical documentation on the SASjsConfig class is available [here](https://adapter.sasjs.io/classes/types.sasjsconfig.html). The main config items are:
|
||||||
@@ -258,7 +264,7 @@ Configuration on the client side involves passing an object on startup, which ca
|
|||||||
* `serverType` - either `SAS9`, `SASVIYA` or `SASJS`. The `SASJS` server type is for use with [sasjs/server](https://github.com/sasjs/server).
|
* `serverType` - either `SAS9`, `SASVIYA` or `SASJS`. The `SASJS` server type is for use with [sasjs/server](https://github.com/sasjs/server).
|
||||||
* `serverUrl` - the location (including http protocol and port) of the SAS Server. Can be omitted, eg if serving directly from the SAS Web Server, or in streaming mode.
|
* `serverUrl` - the location (including http protocol and port) of the SAS Server. Can be omitted, eg if serving directly from the SAS Web Server, or in streaming mode.
|
||||||
* `debug` - if `true` then SAS Logs and extra debug information is returned.
|
* `debug` - if `true` then SAS Logs and extra debug information is returned.
|
||||||
* `LoginMechanism` - either `Default` or `Redirected`. See [SAS Logon](#sas-logon) section.
|
* `loginMechanism` - either `Default` or `Redirected`. See [SAS Logon](#sas-logon) section.
|
||||||
* `useComputeApi` - Only relevant when the serverType is `SASVIYA`. If `true` the [Compute API](#using-the-compute-api) is used. If `false` the [JES API](#using-the-jes-api) is used. If `null` or `undefined` the [Web](#using-jes-web-app) approach is used.
|
* `useComputeApi` - Only relevant when the serverType is `SASVIYA`. If `true` the [Compute API](#using-the-compute-api) is used. If `false` the [JES API](#using-the-jes-api) is used. If `null` or `undefined` the [Web](#using-jes-web-app) approach is used.
|
||||||
* `contextName` - Compute context on which the requests will be called. If missing or not provided, defaults to `Job Execution Compute context`.
|
* `contextName` - Compute context on which the requests will be called. If missing or not provided, defaults to `Job Execution Compute context`.
|
||||||
* `requestHistoryLimit` - Request history limit. Increasing this limit may affect browser performance, especially with debug (logs) enabled. Default is 10.
|
* `requestHistoryLimit` - Request history limit. Increasing this limit may affect browser performance, especially with debug (logs) enabled. Default is 10.
|
||||||
@@ -314,7 +320,7 @@ For more information and examples specific to this adapter you can check out the
|
|||||||
|
|
||||||
For more information on building web apps in general, check out these [resources](https://sasjs.io/training/resources/) or contact the [author](https://www.linkedin.com/in/allanbowe/) directly.
|
For more information on building web apps in general, check out these [resources](https://sasjs.io/training/resources/) or contact the [author](https://www.linkedin.com/in/allanbowe/) directly.
|
||||||
|
|
||||||
If you are a SAS 9 or SAS Viya customer you can also request a copy of [Data Controller](https://datacontroller.io) - free for up to 5 users, this tool makes use of all parts of the SASjs framework.
|
As a SAS customer you can also request a copy of [Data Controller](https://datacontroller.io) - free for up to 5 users, this tool makes use of all parts of the SASjs framework.
|
||||||
|
|
||||||
|
|
||||||
## Star Gazing
|
## Star Gazing
|
||||||
|
|||||||
10253
package-lock.json
generated
10253
package-lock.json
generated
File diff suppressed because it is too large
Load Diff
11
package.json
11
package.json
@@ -44,18 +44,16 @@
|
|||||||
"license": "ISC",
|
"license": "ISC",
|
||||||
"devDependencies": {
|
"devDependencies": {
|
||||||
"@cypress/webpack-preprocessor": "5.9.1",
|
"@cypress/webpack-preprocessor": "5.9.1",
|
||||||
"@types/form-data": "2.5.0",
|
|
||||||
"cypress": "7.7.0",
|
|
||||||
"typedoc-neo-theme": "1.1.1",
|
|
||||||
"typedoc-plugin-external-module-name": "4.0.6",
|
|
||||||
"@types/axios": "0.14.0",
|
"@types/axios": "0.14.0",
|
||||||
"@types/express": "4.17.13",
|
"@types/express": "4.17.13",
|
||||||
|
"@types/form-data": "2.5.0",
|
||||||
"@types/jest": "27.4.0",
|
"@types/jest": "27.4.0",
|
||||||
"@types/mime": "2.0.3",
|
"@types/mime": "2.0.3",
|
||||||
"@types/pem": "1.9.6",
|
"@types/pem": "1.9.6",
|
||||||
"@types/tough-cookie": "4.0.1",
|
"@types/tough-cookie": "4.0.1",
|
||||||
"copyfiles": "2.4.1",
|
"copyfiles": "2.4.1",
|
||||||
"cp": "0.2.0",
|
"cp": "0.2.0",
|
||||||
|
"cypress": "7.7.0",
|
||||||
"dotenv": "16.0.0",
|
"dotenv": "16.0.0",
|
||||||
"express": "4.17.3",
|
"express": "4.17.3",
|
||||||
"jest": "27.4.7",
|
"jest": "27.4.7",
|
||||||
@@ -63,15 +61,18 @@
|
|||||||
"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.6",
|
"pem": "1.14.6",
|
||||||
|
"prettier": "2.7.1",
|
||||||
"process": "0.11.10",
|
"process": "0.11.10",
|
||||||
"rimraf": "3.0.2",
|
"rimraf": "3.0.2",
|
||||||
"semantic-release": "18.0.0",
|
"semantic-release": "19.0.3",
|
||||||
"terser-webpack-plugin": "5.3.1",
|
"terser-webpack-plugin": "5.3.1",
|
||||||
"ts-jest": "27.1.3",
|
"ts-jest": "27.1.3",
|
||||||
"ts-loader": "9.2.6",
|
"ts-loader": "9.2.6",
|
||||||
"tslint": "6.1.3",
|
"tslint": "6.1.3",
|
||||||
"tslint-config-prettier": "1.18.0",
|
"tslint-config-prettier": "1.18.0",
|
||||||
"typedoc": "0.22.11",
|
"typedoc": "0.22.11",
|
||||||
|
"typedoc-neo-theme": "1.1.1",
|
||||||
|
"typedoc-plugin-external-module-name": "4.0.6",
|
||||||
"typedoc-plugin-rename-defaults": "0.4.0",
|
"typedoc-plugin-rename-defaults": "0.4.0",
|
||||||
"typescript": "4.5.5",
|
"typescript": "4.5.5",
|
||||||
"webpack": "5.69.0",
|
"webpack": "5.69.0",
|
||||||
|
|||||||
30895
sasjs-tests/package-lock.json
generated
30895
sasjs-tests/package-lock.json
generated
File diff suppressed because it is too large
Load Diff
@@ -5,7 +5,7 @@
|
|||||||
"private": true,
|
"private": true,
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@sasjs/adapter": "file:../build/sasjs-adapter-5.0.0.tgz",
|
"@sasjs/adapter": "file:../build/sasjs-adapter-5.0.0.tgz",
|
||||||
"@sasjs/test-framework": "^1.4.3",
|
"@sasjs/test-framework": "^1.5.6",
|
||||||
"@types/jest": "^26.0.20",
|
"@types/jest": "^26.0.20",
|
||||||
"@types/node": "^14.14.41",
|
"@types/node": "^14.14.41",
|
||||||
"@types/react": "^17.0.1",
|
"@types/react": "^17.0.1",
|
||||||
@@ -14,7 +14,7 @@
|
|||||||
"react": "^17.0.1",
|
"react": "^17.0.1",
|
||||||
"react-dom": "^17.0.1",
|
"react-dom": "^17.0.1",
|
||||||
"react-router-dom": "^5.2.0",
|
"react-router-dom": "^5.2.0",
|
||||||
"react-scripts": "^4.0.2",
|
"react-scripts": "^5.0.1",
|
||||||
"typescript": "^4.1.3"
|
"typescript": "^4.1.3"
|
||||||
},
|
},
|
||||||
"scripts": {
|
"scripts": {
|
||||||
@@ -43,6 +43,6 @@
|
|||||||
]
|
]
|
||||||
},
|
},
|
||||||
"devDependencies": {
|
"devDependencies": {
|
||||||
"node-sass": "^6.0.1"
|
"node-sass": "^7.0.1"
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -11,12 +11,13 @@ import { fileUploadTests } from './testSuites/FileUpload'
|
|||||||
const App = (): ReactElement<{}> => {
|
const App = (): ReactElement<{}> => {
|
||||||
const { adapter, config } = useContext(AppContext)
|
const { adapter, config } = useContext(AppContext)
|
||||||
const [testSuites, setTestSuites] = useState<TestSuite[]>([])
|
const [testSuites, setTestSuites] = useState<TestSuite[]>([])
|
||||||
|
const appLoc = config.sasJsConfig.appLoc
|
||||||
|
|
||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
if (adapter) {
|
if (adapter) {
|
||||||
const testSuites = [
|
const testSuites = [
|
||||||
basicTests(adapter, config.userName, config.password),
|
basicTests(adapter, config.userName, config.password),
|
||||||
sendArrTests(adapter),
|
sendArrTests(adapter, appLoc),
|
||||||
sendObjTests(adapter),
|
sendObjTests(adapter),
|
||||||
specialCaseTests(adapter),
|
specialCaseTests(adapter),
|
||||||
sasjsRequestTests(adapter),
|
sasjsRequestTests(adapter),
|
||||||
@@ -24,12 +25,12 @@ const App = (): ReactElement<{}> => {
|
|||||||
]
|
]
|
||||||
|
|
||||||
if (adapter.getSasjsConfig().serverType === 'SASVIYA') {
|
if (adapter.getSasjsConfig().serverType === 'SASVIYA') {
|
||||||
testSuites.push(computeTests(adapter))
|
testSuites.push(computeTests(adapter, appLoc))
|
||||||
}
|
}
|
||||||
|
|
||||||
setTestSuites(testSuites)
|
setTestSuites(testSuites)
|
||||||
}
|
}
|
||||||
}, [adapter, config])
|
}, [adapter, config, appLoc])
|
||||||
|
|
||||||
return (
|
return (
|
||||||
<div className="app">
|
<div className="app">
|
||||||
|
|||||||
@@ -9,7 +9,7 @@ const Login = (): ReactElement<{}> => {
|
|||||||
const appContext = useContext(AppContext)
|
const appContext = useContext(AppContext)
|
||||||
|
|
||||||
const handleSubmit = useCallback(
|
const handleSubmit = useCallback(
|
||||||
(e) => {
|
(e: any) => {
|
||||||
e.preventDefault()
|
e.preventDefault()
|
||||||
appContext.adapter.logIn(username, password).then((res) => {
|
appContext.adapter.logIn(username, password).then((res) => {
|
||||||
appContext.setIsLoggedIn(res.isLoggedIn)
|
appContext.setIsLoggedIn(res.isLoggedIn)
|
||||||
@@ -28,7 +28,7 @@ const Login = (): ReactElement<{}> => {
|
|||||||
placeholder="User Name"
|
placeholder="User Name"
|
||||||
value={username}
|
value={username}
|
||||||
required
|
required
|
||||||
onChange={(e) => setUsername(e.target.value)}
|
onChange={(e: any) => setUsername(e.target.value)}
|
||||||
/>
|
/>
|
||||||
</div>
|
</div>
|
||||||
<div className="row">
|
<div className="row">
|
||||||
@@ -38,7 +38,7 @@ const Login = (): ReactElement<{}> => {
|
|||||||
type="password"
|
type="password"
|
||||||
value={password}
|
value={password}
|
||||||
required
|
required
|
||||||
onChange={(e) => setPassword(e.target.value)}
|
onChange={(e: any) => setPassword(e.target.value)}
|
||||||
/>
|
/>
|
||||||
</div>
|
</div>
|
||||||
<button type="submit" className="submit-button">
|
<button type="submit" className="submit-button">
|
||||||
|
|||||||
@@ -3,7 +3,7 @@ import { TestSuite } from '@sasjs/test-framework'
|
|||||||
|
|
||||||
const stringData: any = { table1: [{ col1: 'first col value' }] }
|
const stringData: any = { table1: [{ col1: 'first col value' }] }
|
||||||
|
|
||||||
export const computeTests = (adapter: SASjs): TestSuite => ({
|
export const computeTests = (adapter: SASjs, appLoc: string): TestSuite => ({
|
||||||
name: 'Compute',
|
name: 'Compute',
|
||||||
tests: [
|
tests: [
|
||||||
{
|
{
|
||||||
@@ -35,7 +35,7 @@ export const computeTests = (adapter: SASjs): 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('/Public/app/common/sendArr', data)
|
return adapter.startComputeJob(`${appLoc}/common/sendArr`, data)
|
||||||
},
|
},
|
||||||
assertion: (res: any) => {
|
assertion: (res: any) => {
|
||||||
const expectedProperties = ['id', 'applicationName', 'attributes']
|
const expectedProperties = ['id', 'applicationName', 'attributes']
|
||||||
|
|||||||
@@ -45,14 +45,14 @@ const getLargeObjectData = () => {
|
|||||||
return data
|
return data
|
||||||
}
|
}
|
||||||
|
|
||||||
export const sendArrTests = (adapter: SASjs): TestSuite => ({
|
export const sendArrTests = (adapter: SASjs, appLoc: string): TestSuite => ({
|
||||||
name: 'sendArr',
|
name: 'sendArr',
|
||||||
tests: [
|
tests: [
|
||||||
{
|
{
|
||||||
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('/Public/app/common/sendArr', stringData)
|
return adapter.request(`${appLoc}/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
|
||||||
@@ -86,7 +86,7 @@ export const sendArrTests = (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: () => {
|
||||||
const data = getLongStringData(32767)
|
const data = getLongStringData(32767)
|
||||||
return adapter.request('common/sendArr', data).catch((e) => e)
|
return adapter.request('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
|
||||||
@@ -182,7 +182,9 @@ export const sendObjTests = (adapter: SASjs): TestSuite => ({
|
|||||||
const invalidData: any = {
|
const invalidData: any = {
|
||||||
'1InvalidTable': [{ col1: 42 }]
|
'1InvalidTable': [{ col1: 42 }]
|
||||||
}
|
}
|
||||||
return adapter.request('common/sendObj', invalidData).catch((e) => e)
|
return adapter
|
||||||
|
.request('common/sendObj', invalidData)
|
||||||
|
.catch((e: any) => e)
|
||||||
},
|
},
|
||||||
assertion: (error: any) =>
|
assertion: (error: any) =>
|
||||||
!!error && !!error.error && !!error.error.message
|
!!error && !!error.error && !!error.error.message
|
||||||
@@ -194,7 +196,9 @@ export const sendObjTests = (adapter: SASjs): TestSuite => ({
|
|||||||
const invalidData: any = {
|
const invalidData: any = {
|
||||||
'an invalidTable': [{ col1: 42 }]
|
'an invalidTable': [{ col1: 42 }]
|
||||||
}
|
}
|
||||||
return adapter.request('common/sendObj', invalidData).catch((e) => e)
|
return adapter
|
||||||
|
.request('common/sendObj', invalidData)
|
||||||
|
.catch((e: any) => e)
|
||||||
},
|
},
|
||||||
assertion: (error: any) =>
|
assertion: (error: any) =>
|
||||||
!!error && !!error.error && !!error.error.message
|
!!error && !!error.error && !!error.error.message
|
||||||
@@ -206,7 +210,9 @@ export const sendObjTests = (adapter: SASjs): TestSuite => ({
|
|||||||
const invalidData: any = {
|
const invalidData: any = {
|
||||||
'anInvalidTable#': [{ col1: 42 }]
|
'anInvalidTable#': [{ col1: 42 }]
|
||||||
}
|
}
|
||||||
return adapter.request('common/sendObj', invalidData).catch((e) => e)
|
return adapter
|
||||||
|
.request('common/sendObj', invalidData)
|
||||||
|
.catch((e: any) => e)
|
||||||
},
|
},
|
||||||
assertion: (error: any) =>
|
assertion: (error: any) =>
|
||||||
!!error && !!error.error && !!error.error.message
|
!!error && !!error.error && !!error.error.message
|
||||||
@@ -219,7 +225,9 @@ export const sendObjTests = (adapter: SASjs): TestSuite => ({
|
|||||||
xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx: [{ col1: 42 }]
|
xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx: [{ col1: 42 }]
|
||||||
}
|
}
|
||||||
|
|
||||||
return adapter.request('common/sendObj', invalidData).catch((e) => e)
|
return adapter
|
||||||
|
.request('common/sendObj', invalidData)
|
||||||
|
.catch((e: any) => e)
|
||||||
},
|
},
|
||||||
assertion: (error: any) =>
|
assertion: (error: any) =>
|
||||||
!!error && !!error.error && !!error.error.message
|
!!error && !!error.error && !!error.error.message
|
||||||
@@ -231,7 +239,9 @@ export const sendObjTests = (adapter: SASjs): TestSuite => ({
|
|||||||
const invalidData: any = {
|
const invalidData: any = {
|
||||||
inData: [[{ data: 'value' }]]
|
inData: [[{ data: 'value' }]]
|
||||||
}
|
}
|
||||||
return adapter.request('common/sendObj', invalidData).catch((e) => e)
|
return adapter
|
||||||
|
.request('common/sendObj', invalidData)
|
||||||
|
.catch((e: any) => e)
|
||||||
},
|
},
|
||||||
assertion: (error: any) =>
|
assertion: (error: any) =>
|
||||||
!!error && !!error.error && !!error.error.message
|
!!error && !!error.error && !!error.error.message
|
||||||
@@ -265,7 +275,7 @@ export const sendObjTests = (adapter: SASjs): TestSuite => ({
|
|||||||
test: () => {
|
test: () => {
|
||||||
return adapter
|
return adapter
|
||||||
.request('common/sendObj', getLongStringData(32767))
|
.request('common/sendObj', getLongStringData(32767))
|
||||||
.catch((e) => e)
|
.catch((e: any) => e)
|
||||||
},
|
},
|
||||||
assertion: (error: any) => {
|
assertion: (error: any) => {
|
||||||
return !!error && !!error.error && !!error.error.message
|
return !!error && !!error.error && !!error.error.message
|
||||||
|
|||||||
@@ -9,7 +9,7 @@ export const assert = (
|
|||||||
} else {
|
} else {
|
||||||
result = expression()
|
result = expression()
|
||||||
}
|
}
|
||||||
} catch (e) {
|
} catch (e: any) {
|
||||||
console.error(message)
|
console.error(message)
|
||||||
throw new Error(message)
|
throw new Error(message)
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -31,7 +31,7 @@ describe('SASViyaApiClient', () => {
|
|||||||
.mockImplementation(() => Promise.reject('Not Found'))
|
.mockImplementation(() => Promise.reject('Not Found'))
|
||||||
const error = await sasViyaApiClient
|
const error = await sasViyaApiClient
|
||||||
.createFolder('test', '/foo')
|
.createFolder('test', '/foo')
|
||||||
.catch((e) => e)
|
.catch((e: any) => e)
|
||||||
expect(error).toBeInstanceOf(RootFolderNotFoundError)
|
expect(error).toBeInstanceOf(RootFolderNotFoundError)
|
||||||
})
|
})
|
||||||
})
|
})
|
||||||
|
|||||||
@@ -240,7 +240,7 @@ export async function executeScript(
|
|||||||
|
|
||||||
jobResult = await requestClient
|
jobResult = await requestClient
|
||||||
.get<any>(resultLink, access_token, 'text/plain')
|
.get<any>(resultLink, access_token, 'text/plain')
|
||||||
.catch(async (e) => {
|
.catch(async (e: any) => {
|
||||||
if (e instanceof NotFoundError) {
|
if (e instanceof NotFoundError) {
|
||||||
if (logLink) {
|
if (logLink) {
|
||||||
const logUrl = `${logLink.href}/content`
|
const logUrl = `${logLink.href}/content`
|
||||||
@@ -271,7 +271,7 @@ export async function executeScript(
|
|||||||
})
|
})
|
||||||
|
|
||||||
return { result: jobResult?.result, log }
|
return { result: jobResult?.result, log }
|
||||||
} catch (e) {
|
} catch (e: any) {
|
||||||
interface HttpError {
|
interface HttpError {
|
||||||
status: number
|
status: number
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -80,7 +80,7 @@ describe('executeScript', () => {
|
|||||||
'test',
|
'test',
|
||||||
['%put hello'],
|
['%put hello'],
|
||||||
'test context'
|
'test context'
|
||||||
).catch((e) => e)
|
).catch((e: any) => e)
|
||||||
|
|
||||||
expect(error).toContain('Error while getting session.')
|
expect(error).toContain('Error while getting session.')
|
||||||
})
|
})
|
||||||
@@ -128,7 +128,7 @@ describe('executeScript', () => {
|
|||||||
false,
|
false,
|
||||||
defaultPollOptions,
|
defaultPollOptions,
|
||||||
true
|
true
|
||||||
).catch((e) => e)
|
).catch((e: any) => e)
|
||||||
|
|
||||||
expect(error).toContain('Error while getting session variable.')
|
expect(error).toContain('Error while getting session variable.')
|
||||||
})
|
})
|
||||||
@@ -297,7 +297,7 @@ describe('executeScript', () => {
|
|||||||
false,
|
false,
|
||||||
defaultPollOptions,
|
defaultPollOptions,
|
||||||
true
|
true
|
||||||
).catch((e) => e)
|
).catch((e: any) => e)
|
||||||
|
|
||||||
expect(error).toContain('Error while posting job')
|
expect(error).toContain('Error while posting job')
|
||||||
})
|
})
|
||||||
@@ -367,7 +367,7 @@ describe('executeScript', () => {
|
|||||||
true,
|
true,
|
||||||
defaultPollOptions,
|
defaultPollOptions,
|
||||||
true
|
true
|
||||||
).catch((e) => e)
|
).catch((e: any) => e)
|
||||||
|
|
||||||
expect(error).toContain('Error while polling job status.')
|
expect(error).toContain('Error while polling job status.')
|
||||||
})
|
})
|
||||||
@@ -393,7 +393,7 @@ describe('executeScript', () => {
|
|||||||
true,
|
true,
|
||||||
defaultPollOptions,
|
defaultPollOptions,
|
||||||
true
|
true
|
||||||
).catch((e) => e)
|
).catch((e: any) => e)
|
||||||
|
|
||||||
expect(fetchLogsModule.fetchLogByChunks).toHaveBeenCalledWith(
|
expect(fetchLogsModule.fetchLogByChunks).toHaveBeenCalledWith(
|
||||||
requestClient,
|
requestClient,
|
||||||
@@ -468,7 +468,7 @@ describe('executeScript', () => {
|
|||||||
true,
|
true,
|
||||||
defaultPollOptions,
|
defaultPollOptions,
|
||||||
true
|
true
|
||||||
).catch((e) => e)
|
).catch((e: any) => e)
|
||||||
|
|
||||||
expect(fetchLogsModule.fetchLogByChunks).toHaveBeenCalledWith(
|
expect(fetchLogsModule.fetchLogByChunks).toHaveBeenCalledWith(
|
||||||
requestClient,
|
requestClient,
|
||||||
@@ -501,7 +501,7 @@ describe('executeScript', () => {
|
|||||||
true,
|
true,
|
||||||
defaultPollOptions,
|
defaultPollOptions,
|
||||||
true
|
true
|
||||||
).catch((e) => e)
|
).catch((e: any) => e)
|
||||||
|
|
||||||
expect(fetchLogsModule.fetchLogByChunks).toHaveBeenCalledWith(
|
expect(fetchLogsModule.fetchLogByChunks).toHaveBeenCalledWith(
|
||||||
requestClient,
|
requestClient,
|
||||||
@@ -561,7 +561,7 @@ describe('executeScript', () => {
|
|||||||
true,
|
true,
|
||||||
defaultPollOptions,
|
defaultPollOptions,
|
||||||
true
|
true
|
||||||
).catch((e) => e)
|
).catch((e: any) => e)
|
||||||
|
|
||||||
expect(requestClient.get).toHaveBeenCalledWith(
|
expect(requestClient.get).toHaveBeenCalledWith(
|
||||||
`/compute/sessions/${mockSession.id}/filerefs/_webout/content`,
|
`/compute/sessions/${mockSession.id}/filerefs/_webout/content`,
|
||||||
@@ -622,7 +622,7 @@ describe('executeScript', () => {
|
|||||||
true,
|
true,
|
||||||
defaultPollOptions,
|
defaultPollOptions,
|
||||||
true
|
true
|
||||||
).catch((e) => e)
|
).catch((e: any) => e)
|
||||||
|
|
||||||
expect(error).toContain('Error while clearing session.')
|
expect(error).toContain('Error while clearing session.')
|
||||||
})
|
})
|
||||||
|
|||||||
@@ -59,7 +59,7 @@ describe('pollJobState', () => {
|
|||||||
false,
|
false,
|
||||||
undefined,
|
undefined,
|
||||||
defaultPollOptions
|
defaultPollOptions
|
||||||
).catch((e) => e)
|
).catch((e: any) => e)
|
||||||
|
|
||||||
expect((error as Error).message).toContain('Job state link was not found.')
|
expect((error as Error).message).toContain('Job state link was not found.')
|
||||||
})
|
})
|
||||||
@@ -238,7 +238,7 @@ describe('pollJobState', () => {
|
|||||||
false,
|
false,
|
||||||
undefined,
|
undefined,
|
||||||
defaultPollOptions
|
defaultPollOptions
|
||||||
).catch((e) => e)
|
).catch((e: any) => e)
|
||||||
|
|
||||||
expect(error.message).toEqual(
|
expect(error.message).toEqual(
|
||||||
'Error while polling job state for job j0b: Status Error'
|
'Error while polling job state for job j0b: Status Error'
|
||||||
|
|||||||
@@ -17,7 +17,7 @@ describe('saveLog', () => {
|
|||||||
|
|
||||||
it('should throw an error when a valid access token is not provided', async () => {
|
it('should throw an error when a valid access token is not provided', async () => {
|
||||||
const error = await saveLog(mockJob, requestClient, 0, 100, stream).catch(
|
const error = await saveLog(mockJob, requestClient, 0, 100, stream).catch(
|
||||||
(e) => e
|
(e: any) => e
|
||||||
)
|
)
|
||||||
|
|
||||||
expect(error.message).toContain(
|
expect(error.message).toContain(
|
||||||
@@ -33,7 +33,7 @@ describe('saveLog', () => {
|
|||||||
100,
|
100,
|
||||||
stream,
|
stream,
|
||||||
't0k3n'
|
't0k3n'
|
||||||
).catch((e) => e)
|
).catch((e: any) => e)
|
||||||
|
|
||||||
expect(error.message).toContain(
|
expect(error.message).toContain(
|
||||||
`Log URL for job ${mockJob.id} was not found.`
|
`Log URL for job ${mockJob.id} was not found.`
|
||||||
|
|||||||
@@ -30,7 +30,7 @@ describe('uploadTables', () => {
|
|||||||
.mockImplementation(() => 'ERROR: LARGE STRING LENGTH')
|
.mockImplementation(() => 'ERROR: LARGE STRING LENGTH')
|
||||||
|
|
||||||
const error = await uploadTables(requestClient, data, 't0k3n').catch(
|
const error = await uploadTables(requestClient, data, 't0k3n').catch(
|
||||||
(e) => e
|
(e: any) => e
|
||||||
)
|
)
|
||||||
|
|
||||||
expect(requestClient.uploadFile).not.toHaveBeenCalled()
|
expect(requestClient.uploadFile).not.toHaveBeenCalled()
|
||||||
@@ -46,7 +46,7 @@ describe('uploadTables', () => {
|
|||||||
.mockImplementation(() => Promise.reject('Upload Error'))
|
.mockImplementation(() => Promise.reject('Upload Error'))
|
||||||
|
|
||||||
const error = await uploadTables(requestClient, data, 't0k3n').catch(
|
const error = await uploadTables(requestClient, data, 't0k3n').catch(
|
||||||
(e) => e
|
(e: any) => e
|
||||||
)
|
)
|
||||||
|
|
||||||
expect(error).toContain('Error while uploading file.')
|
expect(error).toContain('Error while uploading file.')
|
||||||
|
|||||||
@@ -28,7 +28,7 @@ describe('writeStream', () => {
|
|||||||
jest
|
jest
|
||||||
.spyOn(stream, 'write')
|
.spyOn(stream, 'write')
|
||||||
.mockImplementation((_, callback) => callback(new Error('Test Error')))
|
.mockImplementation((_, callback) => callback(new Error('Test Error')))
|
||||||
const error = await writeStream(stream, content).catch((e) => e)
|
const error = await writeStream(stream, content).catch((e: any) => e)
|
||||||
|
|
||||||
expect(error.message).toEqual('Test Error')
|
expect(error.message).toEqual('Test Error')
|
||||||
})
|
})
|
||||||
|
|||||||
@@ -4,7 +4,7 @@ export const writeStream = async (
|
|||||||
stream: WriteStream,
|
stream: WriteStream,
|
||||||
content: string
|
content: string
|
||||||
): Promise<void> =>
|
): Promise<void> =>
|
||||||
stream.write(content + '\n', (e) => {
|
stream.write(content + '\n', (e: any) => {
|
||||||
if (e) return Promise.reject(e)
|
if (e) return Promise.reject(e)
|
||||||
|
|
||||||
return Promise.resolve()
|
return Promise.resolve()
|
||||||
|
|||||||
@@ -23,7 +23,7 @@ export class AuthManager {
|
|||||||
? '/SASLogon/logout?'
|
? '/SASLogon/logout?'
|
||||||
: this.serverType === ServerType.SasViya
|
: this.serverType === ServerType.SasViya
|
||||||
? '/SASLogon/logout.do?'
|
? '/SASLogon/logout.do?'
|
||||||
: '/SASjsApi/auth/logout'
|
: '/SASLogon/logout'
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@@ -334,19 +334,9 @@ export class AuthManager {
|
|||||||
|
|
||||||
/**
|
/**
|
||||||
* Logs out of the configured SAS server.
|
* Logs out of the configured SAS server.
|
||||||
* @param accessToken - an optional access token is required for SASjs server type.
|
*
|
||||||
*/
|
*/
|
||||||
public async logOut() {
|
public async logOut() {
|
||||||
if (this.serverType === ServerType.Sasjs) {
|
|
||||||
return this.requestClient
|
|
||||||
.delete(this.logoutUrl)
|
|
||||||
.catch(() => true)
|
|
||||||
.finally(() => {
|
|
||||||
this.requestClient.clearLocalStorageTokens()
|
|
||||||
return true
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
this.requestClient.clearCsrfTokens()
|
this.requestClient.clearCsrfTokens()
|
||||||
|
|
||||||
return this.requestClient.get(this.logoutUrl, undefined).then(() => true)
|
return this.requestClient.get(this.logoutUrl, undefined).then(() => true)
|
||||||
|
|||||||
@@ -53,7 +53,7 @@ describe('getAccessTokenForSasjs', () => {
|
|||||||
requestClient,
|
requestClient,
|
||||||
authConfig.client,
|
authConfig.client,
|
||||||
authConfig.refresh_token
|
authConfig.refresh_token
|
||||||
).catch((e) => e)
|
).catch((e: any) => e)
|
||||||
|
|
||||||
expect(error).toContain('Error while getting access token')
|
expect(error).toContain('Error while getting access token')
|
||||||
})
|
})
|
||||||
|
|||||||
@@ -64,7 +64,7 @@ describe('getAccessTokenForViya', () => {
|
|||||||
authConfig.client,
|
authConfig.client,
|
||||||
authConfig.secret,
|
authConfig.secret,
|
||||||
authConfig.refresh_token
|
authConfig.refresh_token
|
||||||
).catch((e) => e)
|
).catch((e: any) => e)
|
||||||
|
|
||||||
expect(error).toContain('Error while getting access token')
|
expect(error).toContain('Error while getting access token')
|
||||||
})
|
})
|
||||||
|
|||||||
@@ -62,7 +62,9 @@ describe('getTokens', () => {
|
|||||||
const expectedError =
|
const expectedError =
|
||||||
'Unable to obtain new access token. Your refresh token has expired.'
|
'Unable to obtain new access token. Your refresh token has expired.'
|
||||||
|
|
||||||
const error = await getTokens(requestClient, authConfig).catch((e) => e)
|
const error = await getTokens(requestClient, authConfig).catch(
|
||||||
|
(e: any) => e
|
||||||
|
)
|
||||||
|
|
||||||
expect(error.message).toEqual(expectedError)
|
expect(error.message).toEqual(expectedError)
|
||||||
})
|
})
|
||||||
|
|||||||
@@ -35,7 +35,7 @@ describe('refreshTokensForSasjs', () => {
|
|||||||
const error = await refreshTokensForSasjs(
|
const error = await refreshTokensForSasjs(
|
||||||
requestClient,
|
requestClient,
|
||||||
refresh_token
|
refresh_token
|
||||||
).catch((e) => e)
|
).catch((e: any) => e)
|
||||||
|
|
||||||
expect(error).toContain('Error while refreshing tokens')
|
expect(error).toContain('Error while refreshing tokens')
|
||||||
})
|
})
|
||||||
|
|||||||
@@ -63,7 +63,7 @@ describe('refreshTokensForViya', () => {
|
|||||||
authConfig.client,
|
authConfig.client,
|
||||||
authConfig.secret,
|
authConfig.secret,
|
||||||
authConfig.refresh_token
|
authConfig.refresh_token
|
||||||
).catch((e) => e)
|
).catch((e: any) => e)
|
||||||
|
|
||||||
expect(error).toContain('Error while refreshing tokens')
|
expect(error).toContain('Error while refreshing tokens')
|
||||||
})
|
})
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
import * as NodeFormData from 'form-data'
|
import * as NodeFormData from 'form-data'
|
||||||
import { convertToCSV } from '../utils/convertToCsv'
|
import { convertToCSV, isFormatsTable } from '../utils/convertToCsv'
|
||||||
import { splitChunks } from '../utils/splitChunks'
|
import { splitChunks } from '../utils/splitChunks'
|
||||||
|
|
||||||
export const generateTableUploadForm = (
|
export const generateTableUploadForm = (
|
||||||
@@ -13,7 +13,8 @@ export const generateTableUploadForm = (
|
|||||||
for (const tableName in data) {
|
for (const tableName in data) {
|
||||||
tableCounter++
|
tableCounter++
|
||||||
|
|
||||||
sasjsTables.push(tableName)
|
// Formats table should not be sent as part of 'sasjs_tables'
|
||||||
|
if (!isFormatsTable(tableName)) sasjsTables.push(tableName)
|
||||||
|
|
||||||
const csv = convertToCSV(data, tableName)
|
const csv = convertToCSV(data, tableName)
|
||||||
|
|
||||||
|
|||||||
@@ -7,7 +7,6 @@ describe('generateFileUploadForm', () => {
|
|||||||
}
|
}
|
||||||
|
|
||||||
const BlobMock = jest.fn()
|
const BlobMock = jest.fn()
|
||||||
|
|
||||||
;(global as any).FormData = FormDataMock
|
;(global as any).FormData = FormDataMock
|
||||||
;(global as any).Blob = BlobMock
|
;(global as any).Blob = BlobMock
|
||||||
})
|
})
|
||||||
|
|||||||
@@ -169,15 +169,23 @@ export class WebJobExecutor extends BaseJobExecutor {
|
|||||||
? res.result.log.map((logLine: any) => logLine.line).join('\n')
|
? res.result.log.map((logLine: any) => logLine.line).join('\n')
|
||||||
: res.result.log
|
: res.result.log
|
||||||
|
|
||||||
const resObj = res
|
const resObj =
|
||||||
|
this.serverType === ServerType.Sasjs
|
||||||
|
? {
|
||||||
|
result: res.result._webout,
|
||||||
|
log: parsedSasjsServerLog
|
||||||
|
}
|
||||||
|
: res
|
||||||
|
|
||||||
if (this.serverType === ServerType.Sasjs) {
|
if (
|
||||||
if (res.result._webout.length < 1)
|
this.serverType === ServerType.Sasjs &&
|
||||||
throw new JobExecutionError(
|
res.result._webout.length < 1
|
||||||
0,
|
) {
|
||||||
'Job execution failed',
|
throw new JobExecutionError(
|
||||||
parsedSasjsServerLog
|
0,
|
||||||
)
|
`No webout was returned by job ${program}. Server type is SASJS and the calling function is WebJobExecutor. Please check the SAS log for more info.`,
|
||||||
|
parsedSasjsServerLog
|
||||||
|
)
|
||||||
}
|
}
|
||||||
|
|
||||||
this.requestClient!.appendRequest(resObj, sasJob, config.debug)
|
this.requestClient!.appendRequest(resObj, sasJob, config.debug)
|
||||||
|
|||||||
@@ -207,7 +207,7 @@ export class RequestClient implements HttpClient {
|
|||||||
|
|
||||||
return this.parseResponse<T>(response)
|
return this.parseResponse<T>(response)
|
||||||
})
|
})
|
||||||
.catch(async (e) => {
|
.catch(async (e: any) => {
|
||||||
return await this.handleError(
|
return await this.handleError(
|
||||||
e,
|
e,
|
||||||
() =>
|
() =>
|
||||||
@@ -248,7 +248,7 @@ export class RequestClient implements HttpClient {
|
|||||||
|
|
||||||
return this.parseResponse<T>(response)
|
return this.parseResponse<T>(response)
|
||||||
})
|
})
|
||||||
.catch(async (e) => {
|
.catch(async (e: any) => {
|
||||||
return await this.handleError(e, () =>
|
return await this.handleError(e, () =>
|
||||||
this.post<T>(url, data, accessToken, contentType, overrideHeaders)
|
this.post<T>(url, data, accessToken, contentType, overrideHeaders)
|
||||||
)
|
)
|
||||||
@@ -272,7 +272,7 @@ export class RequestClient implements HttpClient {
|
|||||||
throwIfError(response)
|
throwIfError(response)
|
||||||
return this.parseResponse<T>(response)
|
return this.parseResponse<T>(response)
|
||||||
})
|
})
|
||||||
.catch(async (e) => {
|
.catch(async (e: any) => {
|
||||||
return await this.handleError(e, () =>
|
return await this.handleError(e, () =>
|
||||||
this.put<T>(url, data, accessToken, overrideHeaders)
|
this.put<T>(url, data, accessToken, overrideHeaders)
|
||||||
)
|
)
|
||||||
@@ -291,7 +291,7 @@ export class RequestClient implements HttpClient {
|
|||||||
throwIfError(response)
|
throwIfError(response)
|
||||||
return this.parseResponse<T>(response)
|
return this.parseResponse<T>(response)
|
||||||
})
|
})
|
||||||
.catch(async (e) => {
|
.catch(async (e: any) => {
|
||||||
return await this.handleError(e, () => this.delete<T>(url, accessToken))
|
return await this.handleError(e, () => this.delete<T>(url, accessToken))
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
@@ -309,7 +309,7 @@ export class RequestClient implements HttpClient {
|
|||||||
throwIfError(response)
|
throwIfError(response)
|
||||||
return this.parseResponse<T>(response)
|
return this.parseResponse<T>(response)
|
||||||
})
|
})
|
||||||
.catch(async (e) => {
|
.catch(async (e: any) => {
|
||||||
return await this.handleError(e, () =>
|
return await this.handleError(e, () =>
|
||||||
this.patch<T>(url, data, accessToken)
|
this.patch<T>(url, data, accessToken)
|
||||||
)
|
)
|
||||||
@@ -703,7 +703,14 @@ const parseError = (data: string) => {
|
|||||||
} catch (_) {}
|
} catch (_) {}
|
||||||
|
|
||||||
try {
|
try {
|
||||||
|
// There are some edge cases in which the SAS mp_abort macro
|
||||||
|
// (https://core.sasjs.io/mp__abort_8sas.html) is unable to
|
||||||
|
// provide a clean exit. In this case the JSON response will
|
||||||
|
// be wrapped in >>weboutBEGIN<< and >>weboutEND<< strings.
|
||||||
|
// Therefore, if the first string exists, we won't throw an
|
||||||
|
// error just yet (the parser may yet throw one instead)
|
||||||
const hasError =
|
const hasError =
|
||||||
|
!data?.match(/>>weboutBEGIN<</) &&
|
||||||
!!data?.match(/Stored Process Error/i) &&
|
!!data?.match(/Stored Process Error/i) &&
|
||||||
!!data?.match(/This request completed with errors./i)
|
!!data?.match(/This request completed with errors./i)
|
||||||
if (hasError) {
|
if (hasError) {
|
||||||
|
|||||||
@@ -68,7 +68,7 @@ export class Sas9RequestClient extends RequestClient {
|
|||||||
throwIfError(response)
|
throwIfError(response)
|
||||||
return this.parseResponse<T>(response)
|
return this.parseResponse<T>(response)
|
||||||
})
|
})
|
||||||
.catch(async (e) => {
|
.catch(async (e: any) => {
|
||||||
return await this.handleError(
|
return await this.handleError(
|
||||||
e,
|
e,
|
||||||
() =>
|
() =>
|
||||||
@@ -113,7 +113,7 @@ export class Sas9RequestClient extends RequestClient {
|
|||||||
throwIfError(response)
|
throwIfError(response)
|
||||||
return this.parseResponse<T>(response)
|
return this.parseResponse<T>(response)
|
||||||
})
|
})
|
||||||
.catch(async (e) => {
|
.catch(async (e: any) => {
|
||||||
return await this.handleError(e, () =>
|
return await this.handleError(e, () =>
|
||||||
this.post<T>(url, data, accessToken, contentType, overrideHeaders)
|
this.post<T>(url, data, accessToken, contentType, overrideHeaders)
|
||||||
)
|
)
|
||||||
|
|||||||
@@ -11,13 +11,16 @@ describe('formatDataForRequest', () => {
|
|||||||
{ var1: 'string', var2: 232, nullvar: '_' },
|
{ var1: 'string', var2: 232, nullvar: '_' },
|
||||||
{ var1: 'string', var2: 232, nullvar: 0 },
|
{ var1: 'string', var2: 232, nullvar: 0 },
|
||||||
{ var1: 'string', var2: 232, nullvar: 'z' },
|
{ var1: 'string', var2: 232, nullvar: 'z' },
|
||||||
{ var1: 'string', var2: 232, nullvar: null }
|
{ var1: 'string', var2: 232, nullvar: null },
|
||||||
|
{ var1: 'string', var2: 232, nullvar: '.A' },
|
||||||
|
{ var1: 'string', var2: 232, nullvar: '._' },
|
||||||
|
{ var1: 'string', var2: 232, nullvar: '.' }
|
||||||
],
|
],
|
||||||
[`$${testTable}`]: { formats: { var1: '$char12.', nullvar: 'best.' } }
|
[`$${testTable}`]: { formats: { var1: '$char12.', nullvar: 'best.' } }
|
||||||
}
|
}
|
||||||
|
|
||||||
const expectedOutput = {
|
const expectedOutput = {
|
||||||
sasjs1data: `var1:$char12. var2:best. nullvar:best.\r\nstring,232,.a\r\nstring,232,.b\r\nstring,232,._\r\nstring,232,0\r\nstring,232,.z\r\nstring,232,.`,
|
sasjs1data: `var1:$char12. var2:best. nullvar:best.\r\nstring,232,.a\r\nstring,232,.b\r\nstring,232,._\r\nstring,232,0\r\nstring,232,.z\r\nstring,232,.\r\nstring,232,.a\r\nstring,232,._\r\nstring,232,.`,
|
||||||
sasjs_tables: testTable
|
sasjs_tables: testTable
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -54,6 +57,17 @@ describe('formatDataForRequest', () => {
|
|||||||
expect(formatDataForRequest(data)).toEqual(expectedOutput)
|
expect(formatDataForRequest(data)).toEqual(expectedOutput)
|
||||||
})
|
})
|
||||||
|
|
||||||
|
it('should accept . as special missing value', () => {
|
||||||
|
let tableWithMissingValues = {
|
||||||
|
[testTable]: [{ var: '.' }, { var: 0 }],
|
||||||
|
[`$${testTable}`]: { formats: { var: 'best.' } }
|
||||||
|
}
|
||||||
|
|
||||||
|
expect(() =>
|
||||||
|
formatDataForRequest(tableWithMissingValues)
|
||||||
|
).not.toThrowError()
|
||||||
|
})
|
||||||
|
|
||||||
it('should throw an error if special missing values is not valid', () => {
|
it('should throw an error if special missing values is not valid', () => {
|
||||||
let tableWithMissingValues = {
|
let tableWithMissingValues = {
|
||||||
[testTable]: [{ var: 'AA' }, { var: 0 }],
|
[testTable]: [{ var: 'AA' }, { var: 0 }],
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
import { convertToCSV } from './convertToCsv'
|
import { convertToCSV, isFormatsTable } from './convertToCsv'
|
||||||
|
|
||||||
describe('convertToCsv', () => {
|
describe('convertToCsv', () => {
|
||||||
const tableName = 'testTable'
|
const tableName = 'testTable'
|
||||||
@@ -216,7 +216,9 @@ describe('convertToCsv', () => {
|
|||||||
const data = { [tableName]: [{ var1: 'string' }] }
|
const data = { [tableName]: [{ var1: 'string' }] }
|
||||||
|
|
||||||
expect(() => convertToCSV(data, 'wrongTableName')).toThrow(
|
expect(() => convertToCSV(data, 'wrongTableName')).toThrow(
|
||||||
new Error('No table provided to be converted to CSV')
|
new Error(
|
||||||
|
'Error while converting to CSV. No table provided to be converted to CSV.'
|
||||||
|
)
|
||||||
)
|
)
|
||||||
})
|
})
|
||||||
|
|
||||||
@@ -226,3 +228,15 @@ describe('convertToCsv', () => {
|
|||||||
expect(convertToCSV(data, tableName)).toEqual('')
|
expect(convertToCSV(data, tableName)).toEqual('')
|
||||||
})
|
})
|
||||||
})
|
})
|
||||||
|
|
||||||
|
describe('isFormatsTable', () => {
|
||||||
|
const tableName = 'sometable'
|
||||||
|
|
||||||
|
it('should return true if table name match pattern of formats table', () => {
|
||||||
|
expect(isFormatsTable(`$${tableName}`)).toEqual(true)
|
||||||
|
})
|
||||||
|
|
||||||
|
it('should return false if table name does not match pattern of formats table', () => {
|
||||||
|
expect(isFormatsTable(tableName)).toEqual(false)
|
||||||
|
})
|
||||||
|
})
|
||||||
|
|||||||
@@ -1,4 +1,5 @@
|
|||||||
import { isSpecialMissing } from '@sasjs/utils/input/validators'
|
import { isSpecialMissing } from '@sasjs/utils/input/validators'
|
||||||
|
import { prefixMessage } from '@sasjs/utils/error'
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Converts the given JSON object array to a CSV string.
|
* Converts the given JSON object array to a CSV string.
|
||||||
@@ -9,7 +10,10 @@ export const convertToCSV = (
|
|||||||
tableName: string
|
tableName: string
|
||||||
) => {
|
) => {
|
||||||
if (!data[tableName]) {
|
if (!data[tableName]) {
|
||||||
throw new Error('No table provided to be converted to CSV')
|
throw prefixMessage(
|
||||||
|
'No table provided to be converted to CSV.',
|
||||||
|
'Error while converting to CSV. '
|
||||||
|
)
|
||||||
}
|
}
|
||||||
|
|
||||||
const table = data[tableName]
|
const table = data[tableName]
|
||||||
@@ -137,7 +141,9 @@ export const convertToCSV = (
|
|||||||
)
|
)
|
||||||
}
|
}
|
||||||
|
|
||||||
return `.${value.toLowerCase()}`
|
const dot = value.includes('.') ? '' : '.'
|
||||||
|
|
||||||
|
return `${dot}${value.toLowerCase()}`
|
||||||
}
|
}
|
||||||
|
|
||||||
// if there any present, it should have preceding (") for escaping
|
// if there any present, it should have preceding (") for escaping
|
||||||
@@ -170,6 +176,12 @@ export const convertToCSV = (
|
|||||||
return finalCSV
|
return finalCSV
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Checks if table is table of formats (table name should start from '$' character).
|
||||||
|
* @param tableName - table name.
|
||||||
|
*/
|
||||||
|
export const isFormatsTable = (tableName: string) => /^\$.*/.test(tableName)
|
||||||
|
|
||||||
const getByteSize = (str: string) => {
|
const getByteSize = (str: string) => {
|
||||||
let byteSize = str.length
|
let byteSize = str.length
|
||||||
for (let i = str.length - 1; i >= 0; i--) {
|
for (let i = str.length - 1; i >= 0; i--) {
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
import { convertToCSV } from './convertToCsv'
|
import { convertToCSV, isFormatsTable } from './convertToCsv'
|
||||||
import { splitChunks } from './splitChunks'
|
import { splitChunks } from './splitChunks'
|
||||||
|
|
||||||
export const formatDataForRequest = (data: any) => {
|
export const formatDataForRequest = (data: any) => {
|
||||||
@@ -8,7 +8,7 @@ export const formatDataForRequest = (data: any) => {
|
|||||||
|
|
||||||
for (const tableName in data) {
|
for (const tableName in data) {
|
||||||
if (
|
if (
|
||||||
tableName.match(/^\$.*/) &&
|
isFormatsTable(tableName) &&
|
||||||
Object.keys(data).includes(tableName.replace(/^\$/, ''))
|
Object.keys(data).includes(tableName.replace(/^\$/, ''))
|
||||||
) {
|
) {
|
||||||
continue
|
continue
|
||||||
@@ -16,7 +16,8 @@ export const formatDataForRequest = (data: any) => {
|
|||||||
|
|
||||||
tableCounter++
|
tableCounter++
|
||||||
|
|
||||||
sasjsTables.push(tableName)
|
// Formats table should not be sent as part of 'sasjs_tables'
|
||||||
|
if (!isFormatsTable(tableName)) sasjsTables.push(tableName)
|
||||||
|
|
||||||
const csv = convertToCSV(data, tableName)
|
const csv = convertToCSV(data, tableName)
|
||||||
|
|
||||||
|
|||||||
@@ -15,7 +15,7 @@ export const getValidJson = (str: string | object): object => {
|
|||||||
if (str === '') return {}
|
if (str === '') return {}
|
||||||
|
|
||||||
return JSON.parse(str)
|
return JSON.parse(str)
|
||||||
} catch (e) {
|
} catch (e: any) {
|
||||||
if (e instanceof JsonParseArrayError) throw e
|
if (e instanceof JsonParseArrayError) throw e
|
||||||
throw new InvalidJsonError()
|
throw new InvalidJsonError()
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -4,7 +4,7 @@ export const parseSasViyaLog = (logResponse: { items: any[] }) => {
|
|||||||
log = logResponse.items
|
log = logResponse.items
|
||||||
? logResponse.items.map((i) => i.line).join('\n')
|
? logResponse.items.map((i) => i.line).join('\n')
|
||||||
: JSON.stringify(logResponse)
|
: JSON.stringify(logResponse)
|
||||||
} catch (e) {
|
} catch (e: any) {
|
||||||
console.error('An error has occurred while parsing the log response', e)
|
console.error('An error has occurred while parsing the log response', e)
|
||||||
log = logResponse
|
log = logResponse
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -8,7 +8,7 @@ export const parseWeboutResponse = (response: string, url?: string): string => {
|
|||||||
sasResponse = response
|
sasResponse = response
|
||||||
.split('>>weboutBEGIN<<')[1]
|
.split('>>weboutBEGIN<<')[1]
|
||||||
.split('>>weboutEND<<')[0]
|
.split('>>weboutEND<<')[0]
|
||||||
} catch (e) {
|
} catch (e: any) {
|
||||||
if (url) throw new WeboutResponseError(url)
|
if (url) throw new WeboutResponseError(url)
|
||||||
|
|
||||||
sasResponse = ''
|
sasResponse = ''
|
||||||
|
|||||||
Reference in New Issue
Block a user