1
0
mirror of https://github.com/sasjs/adapter.git synced 2026-06-10 02:50:20 +00:00

Compare commits

..

4 Commits

Author SHA1 Message Date
Trevor Moody 824ee6f8da chore: tidied up branch 2025-11-22 16:49:28 +00:00
Trevor Moody a3c5e985f7 chore: css tidy up preventing redundant scroll bar 2025-11-21 09:37:28 +00:00
Trevor Moody 68e0da8a91 chore: partial viya createFile testing 2025-11-21 09:36:01 +00:00
Trevor Moody d0aaad024b fix: improved Viya createFile to apply related properties 2025-11-20 13:00:34 +00:00
37 changed files with 2149 additions and 699 deletions
-1
View File
@@ -1 +0,0 @@
* text=auto eol=lf
+2 -4
View File
@@ -11,9 +11,8 @@ jobs:
runs-on: ubuntu-22.04 runs-on: ubuntu-22.04
strategy: strategy:
fail-fast: false
matrix: matrix:
node-version: [20, 22, 24] node-version: [lts/hydrogen]
steps: steps:
- uses: actions/checkout@v2 - uses: actions/checkout@v2
@@ -33,7 +32,7 @@ jobs:
${{ runner.os }}-node- ${{ runner.os }}-node-
- name: Check npm audit - name: Check npm audit
run: npm audit --omit=dev --audit-level=low run: npm audit --production --audit-level=low
- name: Install Dependencies - name: Install Dependencies
run: npm ci run: npm ci
@@ -54,7 +53,6 @@ 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 }}
+3 -3
View File
@@ -11,7 +11,7 @@ jobs:
strategy: strategy:
matrix: matrix:
node-version: [22] node-version: [lts/hydrogen]
steps: steps:
- name: Checkout - name: Checkout
@@ -20,8 +20,7 @@ jobs:
- name: Setup Node - name: Setup Node
uses: actions/setup-node@v2 uses: actions/setup-node@v2
with: with:
node-version: node-version: ${{ matrix.node-version }}
${{ matrix.node-version }}
# 2. Restore npm cache manually # 2. Restore npm cache manually
- name: Restore npm cache - name: Restore npm cache
@@ -51,3 +50,4 @@ jobs:
publish_branch: gh-pages publish_branch: gh-pages
publish_dir: ./docs publish_dir: ./docs
cname: adapter.sasjs.io cname: adapter.sasjs.io
+1 -4
View File
@@ -14,7 +14,7 @@ jobs:
strategy: strategy:
matrix: matrix:
node-version: [22] node-version: [lts/hydrogen]
steps: steps:
- uses: actions/checkout@v2 - uses: actions/checkout@v2
@@ -42,9 +42,6 @@ jobs:
- name: Build Project - name: Build Project
run: npm run build run: npm run build
- name: Clean up ready for publishing
run: npm run publishInit
- name: Semantic Release - name: Semantic Release
uses: cycjimmy/semantic-release-action@v3 uses: cycjimmy/semantic-release-action@v3
env: env:
+13 -29
View File
@@ -12,7 +12,7 @@ jobs:
strategy: strategy:
matrix: matrix:
node-version: [22] node-version: [lts/hydrogen]
steps: steps:
- uses: actions/checkout@v2 - uses: actions/checkout@v2
@@ -26,26 +26,14 @@ jobs:
uses: actions/cache@v3 uses: actions/cache@v3
id: npm-cache id: npm-cache
with: with:
path: | path: ~/.npm
~/.npm
key: ${{ runner.os }}-node-${{ hashFiles('**/package-lock.json') }} key: ${{ runner.os }}-node-${{ hashFiles('**/package-lock.json') }}
restore-keys: | restore-keys: |
${{ runner.os }}-node- ${{ runner.os }}-node-
- name: Cache Cypress binary
uses: actions/cache@v3
with:
path: ~/.cache/Cypress
key: cypress-${{ runner.os }}-${{ hashFiles('**/package-lock.json') }}
restore-keys: |
cypress-${{ runner.os }}-
- name: Install Dependencies - name: Install Dependencies
run: npm ci run: npm ci
- name: Install Cypress binary
run: npx cypress install
- name: Install Rimraf - name: Install Rimraf
run: npm i rimraf run: npm i rimraf
@@ -91,16 +79,14 @@ jobs:
- name: Deploy sasjs-tests - name: Deploy sasjs-tests
run: | run: |
sudo apt install jq npm install -g replace-in-files-cli
cd sasjs-tests cd sasjs-tests
npm i --ignore-scripts replace-in-files --regex='"@sasjs/adapter".*' --replacement='"@sasjs/adapter":"latest",' ./package.json
npm i ../build/sasjs-adapter-5.0.0.tgz npm i
jq '.sasJsConfig.serverUrl |= "${{ secrets.SASJS_SERVER_URL }}"' ./public/config.json > ./public/config.temp && mv ./public/config.temp ./public/config.json replace-in-files --regex='"serverUrl".*' --replacement='"serverUrl":"${{ secrets.SASJS_SERVER_URL }}",' ./public/config.json
jq '.sasJsConfig.serverType |= "SASJS"' ./public/config.json > ./public/config.temp && mv ./public/config.temp ./public/config.json replace-in-files --regex='"userName".*' --replacement='"userName":"${{ secrets.SASJS_USERNAME }}",' ./public/config.json
jq '.sasJsConfig.loginMechanism |= "Default"' ./public/config.json > ./public/config.temp && mv ./public/config.temp ./public/config.json replace-in-files --regex='"serverType".*' --replacement='"serverType":"SASJS",' ./public/config.json
jq '.userName |= "${{ secrets.SASJS_USERNAME }}"' ./public/config.json > ./public/config.temp && mv ./public/config.temp ./public/config.json replace-in-files --regex='"password".*' --replacement='"password":"${{ secrets.SASJS_PASSWORD }}",' ./public/config.json
jq '.password |= "${{ secrets.SASJS_PASSWORD }}"' ./public/config.json > ./public/config.temp && mv ./public/config.temp ./public/config.json
cat ./public/config.json cat ./public/config.json
npm run update:adapter npm run update:adapter
@@ -111,13 +97,11 @@ jobs:
shell: bash shell: bash
- name: Run cypress on sasjs - name: Run cypress on sasjs
env:
TERM: dumb
run: | run: |
sed -i "s|sasjsTestsUrl: '.*'|sasjsTestsUrl: 'http://localhost:3000'|g" ./cypress.config.js replace-in-files --regex='"sasjsTestsUrl".*' --replacement='"sasjsTestsUrl":"http://localhost:3000",' ./cypress.json
sed -i "s|username: '.*'|username: '${{ secrets.SASJS_USERNAME }}'|g" ./cypress.config.js replace-in-files --regex='"username".*' --replacement='"username":"${{ secrets.SASJS_USERNAME }}",' ./cypress.json
sed -i "s|password: '.*'|password: '${{ secrets.SASJS_PASSWORD }}'|g" ./cypress.config.js replace-in-files --regex='"password".*' --replacement='"password":"${{ secrets.SASJS_PASSWORD }}",' ./cypress.json
cat ./cypress.config.js cat ./cypress.json
echo "SASJS_USERNAME=${{ secrets.SASJS_USERNAME }}" echo "SASJS_USERNAME=${{ secrets.SASJS_USERNAME }}"
sh ./sasjs-tests/sasjs-cypress-run.sh ${{ secrets.MATRIX_TOKEN }} https://github.com/${{github.repository}}/actions/runs/${{github.run_id}} sh ./sasjs-tests/sasjs-cypress-run.sh ${{ secrets.MATRIX_TOKEN }} https://github.com/${{github.repository}}/actions/runs/${{github.run_id}}
+2
View File
@@ -0,0 +1,2 @@
tasks:
- init: npm install && npm run build
-1
View File
@@ -1 +0,0 @@
ignore-scripts=true
-18
View File
@@ -1,18 +0,0 @@
const { defineConfig } = require('cypress')
module.exports = defineConfig({
e2e: {
includeShadowDom: true,
chromeWebSecurity: false,
defaultCommandTimeout: 20000,
specPattern: 'cypress/integration/**/*.ts',
supportFile: 'cypress/support/index.js'
},
env: {
sasjsTestsUrl: 'http://localhost:3000',
username: '',
password: '',
screenshotOnRunFailure: false,
testingFinishTimeout: 600000
}
})
+11
View File
@@ -0,0 +1,11 @@
{
"chromeWebSecurity": false,
"defaultCommandTimeout": 20000,
"env": {
"sasjsTestsUrl": "",
"username": "",
"password": "",
"screenshotOnRunFailure": false,
"testingFinishTimeout": 600000
}
}
+1 -3
View File
@@ -9,12 +9,10 @@ context('sasjs-tests', function () {
}) })
beforeEach(() => { beforeEach(() => {
cy.visit(sasjsTestsUrl) cy.reload()
}) })
function loginIfNeeded() { function loginIfNeeded() {
cy.get('login-form, tests-view', { timeout: 30000 }).should('exist')
cy.get('body').then(($body) => { cy.get('body').then(($body) => {
if ($body.find('login-form').length > 0) { if ($body.find('login-form').length > 0) {
cy.get('login-form') cy.get('login-form')
+213 -343
View File
File diff suppressed because it is too large Load Diff
+11 -8
View File
@@ -4,14 +4,17 @@
"homepage": "https://adapter.sasjs.io", "homepage": "https://adapter.sasjs.io",
"scripts": { "scripts": {
"nodeVersionMessage": "echo \u001b[33m make sure you are running node lts version \u001b[0m", "nodeVersionMessage": "echo \u001b[33m make sure you are running node lts version \u001b[0m",
"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", "preinstall": "npm run nodeVersionMessage",
"prebuild": "npm run nodeVersionMessage",
"build": "npx rimraf build && npx rimraf node && mkdir node && copyfiles -u 1 \"./src/**/*\" ./node && webpack && npx rimraf build/src && npx rimraf node",
"package:lib": "npm run build && copyfiles ./package.json build && cd build && npm version \"5.0.0\" && npm pack", "package:lib": "npm run build && copyfiles ./package.json build && cd build && npm version \"5.0.0\" && npm pack",
"publish:lib": "npm run build && cd build && npm publish", "publish:lib": "npm run build && cd build && npm publish",
"lint:fix": "npx prettier --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: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": "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 --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}\"", "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}\"",
"test": "jest --silent --coverage", "test": "jest --silent --coverage",
"publishInit": "cp -r ./build/* . && rm -rf ./build", "prepublishOnly": "cp -r ./build/* . && rm -rf ./build",
"postpublish": "git clean -fd",
"semantic-release": "semantic-release", "semantic-release": "semantic-release",
"typedoc": "node createTSDocs", "typedoc": "node createTSDocs",
"prepare": "git rev-parse --git-dir && git config core.hooksPath ./.git-hooks && git config core.autocrlf false || true", "prepare": "git rev-parse --git-dir && git config core.hooksPath ./.git-hooks && git config core.autocrlf false || true",
@@ -51,7 +54,7 @@
"copyfiles": "2.4.1", "copyfiles": "2.4.1",
"cors": "^2.8.5", "cors": "^2.8.5",
"cp": "0.2.0", "cp": "0.2.0",
"cypress": "^15.7.1", "cypress": "7.7.0",
"dotenv": "16.0.0", "dotenv": "16.0.0",
"express": "4.17.3", "express": "4.17.3",
"jest": "29.7.0", "jest": "29.7.0",
@@ -60,7 +63,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": "3.8.2", "prettier": "2.8.7",
"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",
@@ -76,8 +79,8 @@
}, },
"main": "index.js", "main": "index.js",
"dependencies": { "dependencies": {
"@sasjs/utils": "^3.5.6", "@sasjs/utils": "3.5.2",
"axios": "1.15.0", "axios": "1.12.2",
"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",
+2 -2
View File
@@ -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.
> **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. You can use the provided `update:adapter` NPM script for this.
```bash ```bash
npm run update:adapter npm run update:adapter
``` ```
This script builds a new version of the adapter and installs it in the `sasjs-tests` project. This scripts builds a new version of the adapter and installs it in the `sasjs-tests` project.
## Running tests ## Running tests
+1637 -47
View File
File diff suppressed because it is too large Load Diff
+3
View File
@@ -18,5 +18,8 @@
}, },
"overrides": { "overrides": {
"vite": "npm:rolldown-vite@7.2.2" "vite": "npm:rolldown-vite@7.2.2"
},
"dependencies": {
"@sasjs/adapter": "^4.14.0"
} }
} }
+1 -1
View File
@@ -7,7 +7,7 @@
"targets": [ "targets": [
{ {
"name": "4gl", "name": "4gl",
"serverUrl": "https://sas.4gl.io", "serverUrl": "https://sas9.4gl.io",
"serverType": "SASJS", "serverType": "SASJS",
"httpsAgentOptions": { "httpsAgentOptions": {
"allowInsecureRequests": false "allowInsecureRequests": false
+3 -1
View File
@@ -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 { viyaFileTests } from './testSuites/ViyaFile'
async function init() { async function init() {
const appContainer = document.getElementById('app') const appContainer = document.getElementById('app')
@@ -103,9 +104,10 @@ function showTests(
fileUploadTests(adapter) fileUploadTests(adapter)
] ]
// Add compute tests for SASVIYA only // Add certain tests for SASVIYA only
if (adapter.getSasjsConfig().serverType === 'SASVIYA') { if (adapter.getSasjsConfig().serverType === 'SASVIYA') {
testSuites.push(computeTests(adapter, appLoc)) testSuites.push(computeTests(adapter, appLoc))
testSuites.push(viyaFileTests(adapter, appLoc))
} }
container.innerHTML = '' container.innerHTML = ''
+31
View File
@@ -0,0 +1,31 @@
import SASjs from '@sasjs/adapter'
import type { TestSuite } from '../types'
export const viyaFileTests = (adapter: SASjs, appLoc: string): TestSuite => ({
name: 'SAS Viya File Tests',
tests: [
{
title: 'Create html file',
description: 'Should create an html file with appropriate properties',
test: async () => {
const fileContentBuffer = Buffer.from(
`<html>` +
` <head><title>Test</title></head>` +
` <body><p>This is a test</p></body>` +
`</html>`
)
// generate a timestamp string formatted as YYYYmmDDTHHMMSS_999
const timeMark = new Date()
.toISOString()
.replace(/(\/|:|\s|-|Z)/g, '')
.replace(/\./g, '_')
const filename = `viya_createFile_test_${timeMark}.html`
return adapter.createFile(filename, fileContentBuffer, appLoc)
},
assertion: () => {
//A test that returns a boolean
return true // dummy
}
}
]
})
+7 -3
View File
@@ -1,8 +1,12 @@
import { defineConfig } from 'vite' import { defineConfig } from 'vite'
import { nodePolyfills } from 'vite-plugin-node-polyfills'
export default defineConfig({ export default defineConfig({
server: { plugins: [
port: 3000 nodePolyfills({
}, include: ['buffer']
})
],
build: { build: {
assetsInlineLimit: 0, assetsInlineLimit: 0,
assetsDir: '' assetsDir: ''
+11 -16
View File
@@ -32,18 +32,16 @@ export class ContextManager {
return this.defaultLauncherContexts return this.defaultLauncherContexts
} }
constructor( constructor(private serverUrl: string, private requestClient: RequestClient) {
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<{ .get<{ items: Context[] }>(
items: Context[] `${this.serverUrl}/compute/contexts?limit=10000`,
}>(`${this.serverUrl}/compute/contexts?limit=10000`, accessToken) accessToken
)
.catch((err) => { .catch((err) => {
throw prefixMessage(err, 'Error while getting compute contexts. ') throw prefixMessage(err, 'Error while getting compute contexts. ')
}) })
@@ -61,9 +59,10 @@ 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<{ .get<{ items: Context[] }>(
items: Context[] `${this.serverUrl}/launcher/contexts?limit=10000`,
}>(`${this.serverUrl}/launcher/contexts?limit=10000`, accessToken) accessToken
)
.catch((err) => { .catch((err) => {
throw prefixMessage(err, 'Error while getting launcher contexts. ') throw prefixMessage(err, 'Error while getting launcher contexts. ')
}) })
@@ -292,9 +291,7 @@ export class ContextManager {
accessToken?: string accessToken?: string
): Promise<Context> { ): Promise<Context> {
const { result: contexts } = await this.requestClient const { result: contexts } = await this.requestClient
.get<{ .get<{ items: Context[] }>(
items: Context[]
}>(
`${this.serverUrl}/compute/contexts?filter=eq(name, "${contextName}")`, `${this.serverUrl}/compute/contexts?filter=eq(name, "${contextName}")`,
accessToken accessToken
) )
@@ -335,9 +332,7 @@ export class ContextManager {
authConfig?: AuthConfig authConfig?: AuthConfig
) { ) {
const { result: contexts } = await this.requestClient const { result: contexts } = await this.requestClient
.get<{ .get<{ items: Context[] }>(
items: Context[]
}>(
`${this.serverUrl}/compute/contexts?limit=10000`, `${this.serverUrl}/compute/contexts?limit=10000`,
authConfig?.access_token authConfig?.access_token
) )
+27 -31
View File
@@ -35,7 +35,7 @@ interface JobExecutionResult {
log?: string log?: string
error?: object error?: object
} }
/* Viya /types/types?limit=999999 response structure */
interface IViyaTypesResponse { interface IViyaTypesResponse {
accept: string accept: string
count: number count: number
@@ -47,7 +47,6 @@ interface IViyaTypesResponse {
version: number version: number
} }
/* Item element within the Viya types response */
interface IViyaTypesItem { interface IViyaTypesItem {
description?: string description?: string
extensions?: string[] extensions?: string[]
@@ -57,7 +56,7 @@ interface IViyaTypesItem {
mappedTypes?: string[] mappedTypes?: string[]
mediaType?: string mediaType?: string
mediaTypes?: string[] mediaTypes?: string[]
name?: string | undefined name: string
pluralLabel?: string pluralLabel?: string
properties?: IViyaTypesProperties properties?: IViyaTypesProperties
resourceUri?: string resourceUri?: string
@@ -86,7 +85,7 @@ type IViyaTypesProperties = Record<string, string>
* create and patch a new file. * create and patch a new file.
*/ */
interface IViyaTypesExtensionInfo { interface IViyaTypesExtensionInfo {
typeDefName: string | undefined typeDefName: string
properties: IViyaTypesProperties | undefined properties: IViyaTypesProperties | undefined
} }
@@ -115,9 +114,9 @@ export class SASViyaApiClient {
this.requestClient this.requestClient
) )
private folderMap = new Map<string, Job[]>() private folderMap = new Map<string, Job[]>()
private fileExtensionMap = new Map<string, IViyaTypesExtensionInfo>() private fileExtensionMap = new Map<string, IViyaTypesExtensionInfo>()
private boolExtensionMap = false // required in case the map has zero entries private boolExtensionMap = false // has the fileExtensionMap been populated yet?
// after an attempt to populate it.
/** /**
* A helper method used to call appendRequest method of RequestClient * A helper method used to call appendRequest method of RequestClient
@@ -482,20 +481,29 @@ export class SASViyaApiClient {
if (!parentFolderUri && parentFolderPath) { if (!parentFolderUri && parentFolderPath) {
parentFolderUri = await this.getFolderUri(parentFolderPath, accessToken) parentFolderUri = await this.getFolderUri(parentFolderPath, accessToken)
} }
const headers = { const headers = {
Accept: 'application/vnd.sas.file+json', Accept: 'application/vnd.sas.file+json',
'Content-Disposition': `filename="${fileName}";` 'Content-Disposition': `filename="${fileName}";`
} }
const patchHeaders = {
Accept: 'application/json',
'If-Match': '*'
}
const formData = new NodeFormData() const formData = new NodeFormData()
formData.append('file', contentBuffer, fileName) formData.append('file', contentBuffer, fileName)
/** Query Viya for file metadata based on extension type. */ /** Query Viya for file metadata based on extension type.
* Without providing certain properties, some versions of Viya will not
* serve files as intended. Avoid this issue by applying the properties
* that Viya has registered for a file extension.
*/
// typeDefName - Viya accepts this property during the file creation // typeDefName - Viya should automatically determine this and additional
// properties at runtime if not provided in the file creation request.
let typeDefName: string | undefined = undefined let typeDefName: string | undefined = undefined
// Additional properties are supplied by a patch. // Viya update 2025.09 resulted in a change to this automatic behaviour.
// We patch the new file to replicate the behaviour.
let filePatch: let filePatch:
| { | {
name: string name: string
@@ -524,14 +532,8 @@ export class SASViyaApiClient {
.forEach((e) => { .forEach((e) => {
e.extensions?.forEach((ext) => { e.extensions?.forEach((ext) => {
this.fileExtensionMap.set(ext, { this.fileExtensionMap.set(ext, {
// `name` becomes the typeDefName value at file creation time. // "name:" is the typeDefName value required for file creation.
// `name` is ignored here if it is not populated in the map, or typeDefName: e.name,
// has a blank/empty value.
typeDefName: e.name
? e.name.trim().length
? e.name.trim()
: undefined
: undefined,
properties: e.properties properties: e.properties
}) })
}) })
@@ -540,18 +542,14 @@ export class SASViyaApiClient {
this.boolExtensionMap = true this.boolExtensionMap = true
} }
// Query the map for the current file extension
const fileExtInfo = this.fileExtensionMap.get(fileExtension) const fileExtInfo = this.fileExtensionMap.get(fileExtension)
if (fileExtInfo) { if (fileExtInfo) {
// If the extension was found in the map, record the typeDefName and
// create a patch if a properties object was returned.
typeDefName = fileExtInfo.typeDefName typeDefName = fileExtInfo.typeDefName
if (fileExtInfo.properties) if (fileExtInfo.properties)
filePatch = { name: fileName, properties: fileExtInfo.properties } filePatch = { name: fileName, properties: fileExtInfo.properties }
} }
} }
// Create the file
const createFileResponse = await this.requestClient.post<File>( const createFileResponse = await this.requestClient.post<File>(
`/files/files?parentFolderUri=${parentFolderUri}&typeDefName=${ `/files/files?parentFolderUri=${parentFolderUri}&typeDefName=${
typeDefName ?? 'file' typeDefName ?? 'file'
@@ -562,13 +560,9 @@ export class SASViyaApiClient {
headers headers
) )
try {
// If a patch was created... // If a patch was created...
if (filePatch) { if (filePatch) {
try {
const patchHeaders = {
Accept: 'application/json',
'If-Match': '*'
}
// Get the URI of the newly created file // Get the URI of the newly created file
const fileUri = createFileResponse.result.links.filter( const fileUri = createFileResponse.result.links.filter(
(e) => e.method == 'PATCH' && e.rel == 'patch' (e) => e.method == 'PATCH' && e.rel == 'patch'
@@ -579,15 +573,16 @@ export class SASViyaApiClient {
`${fileUri}`, `${fileUri}`,
filePatch, filePatch,
accessToken, accessToken,
'application/json',
patchHeaders patchHeaders
) )
).result ).result
}
return createFileResponse.result
} catch (e: any) { } catch (e: any) {
throw new Error(`Error patching file ${fileName}.\n${e.message}`) throw new Error(`Error patching file ${fileName}.\n${e.message}`)
} }
} }
return createFileResponse.result
}
/** /**
* Creates a folder. Path to or URI of the parent folder is required. * Creates a folder. Path to or URI of the parent folder is required.
@@ -1026,8 +1021,9 @@ export class SASViyaApiClient {
} }
files.forEach((fileInfo, index) => { files.forEach((fileInfo, index) => {
jobArguments[`_webin_fileuri${index + 1}`] = jobArguments[
`/files/files/${fileInfo.file.id}` `_webin_fileuri${index + 1}`
] = `/files/files/${fileInfo.file.id}`
jobArguments[`_webin_name${index + 1}`] = fileInfo.tableName jobArguments[`_webin_name${index + 1}`] = fileInfo.tableName
}) })
+3 -2
View File
@@ -125,8 +125,9 @@ 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[`_webin_fileuri${index + 1}`] = jobVariables[
`/files/files/${fileInfo.file.id}` `_webin_fileuri${index + 1}`
] = `/files/files/${fileInfo.file.id}`
jobVariables[`_webin_name${index + 1}`] = fileInfo.tableName jobVariables[`_webin_name${index + 1}`] = fileInfo.tableName
}) })
} else { } else {
+1 -1
View File
@@ -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(() => {
+1 -4
View File
@@ -8,10 +8,7 @@ import {
import { BaseJobExecutor } from './JobExecutor' import { BaseJobExecutor } from './JobExecutor'
export class ComputeJobExecutor extends BaseJobExecutor { export class ComputeJobExecutor extends BaseJobExecutor {
constructor( constructor(serverUrl: string, private sasViyaApiClient: SASViyaApiClient) {
serverUrl: string,
private sasViyaApiClient: SASViyaApiClient
) {
super(serverUrl, ServerType.SasViya) super(serverUrl, ServerType.SasViya)
} }
+1 -4
View File
@@ -10,10 +10,7 @@ import { BaseJobExecutor } from './JobExecutor'
import { appendExtraResponseAttributes } from '../utils' import { appendExtraResponseAttributes } from '../utils'
export class JesJobExecutor extends BaseJobExecutor { export class JesJobExecutor extends BaseJobExecutor {
constructor( constructor(serverUrl: string, private sasViyaApiClient: SASViyaApiClient) {
serverUrl: string,
private sasViyaApiClient: SASViyaApiClient
) {
super(serverUrl, ServerType.SasViya) super(serverUrl, ServerType.SasViya)
} }
+1 -4
View File
@@ -17,10 +17,7 @@ export interface JobExecutor {
} }
export abstract class BaseJobExecutor implements JobExecutor { export abstract class BaseJobExecutor implements JobExecutor {
constructor( constructor(protected serverUrl: string, protected serverType: ServerType) {}
protected serverUrl: string,
protected serverType: ServerType
) {}
private waitingRequests: ExecuteFunction[] = [] private waitingRequests: ExecuteFunction[] = []
+5 -3
View File
@@ -97,9 +97,11 @@ export class WebJobExecutor extends BaseJobExecutor {
apiUrl = apiUrl.replace('_program=', '__program=') apiUrl = apiUrl.replace('_program=', '__program=')
} }
// Append context name to URL if provided and non-empty // if context name exists and is not blank string
apiUrl += config.contextName?.trim() // then add _contextname variable in apiUrl
? `&_contextname=${encodeURIComponent(config.contextName)}` apiUrl +=
config.contextName && !/\s/.test(config.contextName)
? `&_contextname=${config.contextName}`
: '' : ''
} }
+4 -3
View File
@@ -272,12 +272,13 @@ export class RequestClient implements HttpClient {
public async patch<T>( public async patch<T>(
url: string, url: string,
data: any = {}, data: any,
accessToken?: string, accessToken: string | undefined,
contentType = 'application/json',
overrideHeaders: { [key: string]: string | number } = {} overrideHeaders: { [key: string]: string | number } = {}
): Promise<{ result: T; etag: string }> { ): Promise<{ result: T; etag: string }> {
const headers = { const headers = {
...this.getHeaders(accessToken, 'application/json'), ...this.getHeaders(accessToken, contentType),
...overrideHeaders ...overrideHeaders
} }
+1 -1
View File
@@ -631,7 +631,7 @@ describe('RequestClient - Self Signed Server', () => {
getTokenRequestErrorPrefixResponse(err.message, ServerType.SasViya) getTokenRequestErrorPrefixResponse(err.message, ServerType.SasViya)
) )
expect(rejectionErrorMessage).toContain(expectedError) expect(rejectionErrorMessage).toEqual(expectedError)
}) })
it('should response the POST method using insecure flag', async () => { it('should response the POST method using insecure flag', async () => {
+1 -4
View File
@@ -1,8 +1,5 @@
export class AuthorizeError extends Error { export class AuthorizeError extends Error {
constructor( constructor(public message: string, public confirmUrl: string) {
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 -4
View File
@@ -1,10 +1,7 @@
import { Job } from '../Job' import { Job } from '../Job'
export class ComputeJobExecutionError extends Error { export class ComputeJobExecutionError extends Error {
constructor( constructor(public job: Job, public log: string) {
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 -4
View File
@@ -1,8 +1,5 @@
export class JobStatePollError extends Error { export class JobStatePollError extends Error {
constructor( constructor(id: string, public originalError: Error) {
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