mirror of
https://github.com/sasjs/adapter.git
synced 2026-01-16 16:40:06 +00:00
Compare commits
1 Commits
v4.16.0
...
d0aaad024b
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
d0aaad024b |
215
.github/workflows/server-tests.yml
vendored
215
.github/workflows/server-tests.yml
vendored
@@ -1,108 +1,107 @@
|
|||||||
# This workflow will do a clean install of node dependencies, build the source code and run tests across different versions of node
|
# This workflow will do a clean install of node dependencies, build the source code and run tests across different versions of node
|
||||||
# For more information see: https://help.github.com/actions/language-and-framework-guides/using-nodejs-with-github-actions
|
# For more information see: https://help.github.com/actions/language-and-framework-guides/using-nodejs-with-github-actions
|
||||||
|
|
||||||
name: SASjs Build and Server Tests
|
name: SASjs Build and Server Tests
|
||||||
|
|
||||||
on:
|
on:
|
||||||
pull_request:
|
pull_request:
|
||||||
|
|
||||||
jobs:
|
jobs:
|
||||||
test:
|
test:
|
||||||
runs-on: ubuntu-22.04
|
runs-on: ubuntu-22.04
|
||||||
|
|
||||||
strategy:
|
strategy:
|
||||||
matrix:
|
matrix:
|
||||||
node-version: [lts/hydrogen]
|
node-version: [lts/hydrogen]
|
||||||
|
|
||||||
steps:
|
steps:
|
||||||
- uses: actions/checkout@v2
|
- uses: actions/checkout@v2
|
||||||
- name: Use Node.js ${{ matrix.node-version }}
|
- name: Use Node.js ${{ matrix.node-version }}
|
||||||
uses: actions/setup-node@v2
|
uses: actions/setup-node@v2
|
||||||
with:
|
with:
|
||||||
node-version: ${{ matrix.node-version }}
|
node-version: ${{ matrix.node-version }}
|
||||||
|
|
||||||
# 2. Restore npm cache manually
|
# 2. Restore npm cache manually
|
||||||
- name: Restore npm cache
|
- name: Restore npm cache
|
||||||
uses: actions/cache@v3
|
uses: actions/cache@v3
|
||||||
id: npm-cache
|
id: npm-cache
|
||||||
with:
|
with:
|
||||||
path: ~/.npm
|
path: ~/.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: Install Dependencies
|
- name: Install Dependencies
|
||||||
run: npm ci
|
run: npm ci
|
||||||
|
|
||||||
- name: Install Rimraf
|
- name: Install Rimraf
|
||||||
run: npm i rimraf
|
run: npm i rimraf
|
||||||
|
|
||||||
- name: Build Package
|
- name: Build Package
|
||||||
run: npm run package:lib
|
run: npm run package:lib
|
||||||
env:
|
env:
|
||||||
CI: true
|
CI: true
|
||||||
|
|
||||||
- name: Write VPN Files
|
- name: Write VPN Files
|
||||||
run: |
|
run: |
|
||||||
echo "$CA_CRT" > .github/vpn/ca.crt
|
echo "$CA_CRT" > .github/vpn/ca.crt
|
||||||
echo "$USER_CRT" > .github/vpn/user.crt
|
echo "$USER_CRT" > .github/vpn/user.crt
|
||||||
echo "$USER_KEY" > .github/vpn/user.key
|
echo "$USER_KEY" > .github/vpn/user.key
|
||||||
echo "$TLS_KEY" > .github/vpn/tls.key
|
echo "$TLS_KEY" > .github/vpn/tls.key
|
||||||
shell: bash
|
shell: bash
|
||||||
env:
|
env:
|
||||||
CA_CRT: ${{ secrets.CA_CRT}}
|
CA_CRT: ${{ secrets.CA_CRT}}
|
||||||
USER_CRT: ${{ secrets.USER_CRT }}
|
USER_CRT: ${{ secrets.USER_CRT }}
|
||||||
USER_KEY: ${{ secrets.USER_KEY }}
|
USER_KEY: ${{ secrets.USER_KEY }}
|
||||||
TLS_KEY: ${{ secrets.TLS_KEY }}
|
TLS_KEY: ${{ secrets.TLS_KEY }}
|
||||||
|
|
||||||
- name: Chmod VPN files
|
- name: Chmod VPN files
|
||||||
run: |
|
run: |
|
||||||
chmod 600 .github/vpn/ca.crt .github/vpn/user.crt .github/vpn/user.key .github/vpn/tls.key
|
chmod 600 .github/vpn/ca.crt .github/vpn/user.crt .github/vpn/user.key .github/vpn/tls.key
|
||||||
|
|
||||||
- name: Install Open VPN
|
- name: Install Open VPN
|
||||||
run: |
|
run: |
|
||||||
sudo apt install apt-transport-https
|
sudo apt install apt-transport-https
|
||||||
sudo wget https://swupdate.openvpn.net/repos/openvpn-repo-pkg-key.pub
|
sudo wget https://swupdate.openvpn.net/repos/openvpn-repo-pkg-key.pub
|
||||||
sudo apt-key add openvpn-repo-pkg-key.pub
|
sudo apt-key add openvpn-repo-pkg-key.pub
|
||||||
sudo wget -O /etc/apt/sources.list.d/openvpn3.list https://swupdate.openvpn.net/community/openvpn3/repos/openvpn3-jammy.list
|
sudo wget -O /etc/apt/sources.list.d/openvpn3.list https://swupdate.openvpn.net/community/openvpn3/repos/openvpn3-jammy.list
|
||||||
sudo apt update
|
sudo apt update
|
||||||
sudo apt install openvpn3=17~betaUb22042+jammy
|
sudo apt install openvpn3=17~betaUb22042+jammy
|
||||||
|
|
||||||
- name: Start Open VPN 3
|
- name: Start Open VPN 3
|
||||||
run: openvpn3 session-start --config .github/vpn/config.ovpn
|
run: openvpn3 session-start --config .github/vpn/config.ovpn
|
||||||
|
|
||||||
- name: install pm2
|
- name: install pm2
|
||||||
run: npm i -g pm2
|
run: npm i -g pm2
|
||||||
|
|
||||||
- name: Fetch SASJS server
|
- name: Fetch SASJS server
|
||||||
run: curl ${{ secrets.SASJS_SERVER_URL }}/SASjsApi/info
|
run: curl ${{ secrets.SASJS_SERVER_URL }}/SASjsApi/info
|
||||||
|
|
||||||
- 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
|
||||||
jq '.dependencies."@sasjs/adapter" |= "latest"' ./package.json > ./package.temp && mv ./package.temp ./package.json
|
replace-in-files --regex='"@sasjs/adapter".*' --replacement='"@sasjs/adapter":"latest",' ./package.json
|
||||||
npm i
|
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 '.userName |= "${{ secrets.SASJS_USERNAME }}"' ./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 '.password |= "${{ secrets.SASJS_PASSWORD }}"' ./public/config.json > ./public/config.temp && mv ./public/config.temp ./public/config.json
|
replace-in-files --regex='"password".*' --replacement='"password":"${{ secrets.SASJS_PASSWORD }}",' ./public/config.json
|
||||||
|
cat ./public/config.json
|
||||||
cat ./public/config.json
|
|
||||||
|
npm run update:adapter
|
||||||
npm run update:adapter
|
pm2 start --name sasjs-test npm -- start
|
||||||
pm2 start --name sasjs-test npm -- start
|
|
||||||
|
- name: Sleep for 10 seconds
|
||||||
- name: Sleep for 10 seconds
|
run: sleep 10s
|
||||||
run: sleep 10s
|
shell: bash
|
||||||
shell: bash
|
|
||||||
|
- name: Run cypress on sasjs
|
||||||
- name: Run cypress on sasjs
|
run: |
|
||||||
run: |
|
replace-in-files --regex='"sasjsTestsUrl".*' --replacement='"sasjsTestsUrl":"http://localhost:3000",' ./cypress.json
|
||||||
jq '.env.sasjsTestsUrl |= "http://localhost:3000"' ./cypress.json > ./cypress.temp && mv ./cypress.temp ./cypress.json
|
replace-in-files --regex='"username".*' --replacement='"username":"${{ secrets.SASJS_USERNAME }}",' ./cypress.json
|
||||||
jq '.env.username |= "${{ secrets.SASJS_USERNAME }}"' ./cypress.json > ./cypress.temp && mv ./cypress.temp ./cypress.json
|
replace-in-files --regex='"password".*' --replacement='"password":"${{ secrets.SASJS_PASSWORD }}",' ./cypress.json
|
||||||
jq '.env.password |= "${{ secrets.SASJS_PASSWORD }}"' ./cypress.json > ./cypress.temp && mv ./cypress.temp ./cypress.json
|
cat ./cypress.json
|
||||||
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}}
|
|
||||||
|
|||||||
@@ -12,6 +12,10 @@ body {
|
|||||||
background: #f5f5f5;
|
background: #f5f5f5;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
#app {
|
||||||
|
min-height: 100vh;
|
||||||
|
}
|
||||||
|
|
||||||
.app__error {
|
.app__error {
|
||||||
max-width: 800px;
|
max-width: 800px;
|
||||||
margin: 50px auto;
|
margin: 50px auto;
|
||||||
@@ -36,4 +40,4 @@ body {
|
|||||||
border-radius: 4px;
|
border-radius: 4px;
|
||||||
overflow-x: auto;
|
overflow-x: auto;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -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
|
||||||
@@ -71,14 +70,18 @@ interface IViyaTypesItem {
|
|||||||
* in the links array of a Viya
|
* in the links array of a Viya
|
||||||
* types/types api response
|
* types/types api response
|
||||||
*/
|
*/
|
||||||
type IViyaTypesLink = Record<string, string>
|
interface IViyaTypesLink {
|
||||||
|
[key: string]: string
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Generic structure for a type's
|
* Generic structure for a type's
|
||||||
* 'properties' object from the Viya
|
* 'properties' object from the Viya
|
||||||
* types/types api response
|
* types/types api response
|
||||||
*/
|
*/
|
||||||
type IViyaTypesProperties = Record<string, string>
|
interface IViyaTypesProperties {
|
||||||
|
[key: string]: string
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Arbitrary interface for storing
|
* Arbitrary interface for storing
|
||||||
@@ -86,7 +89,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 +118,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
|
||||||
@@ -491,11 +494,17 @@ export class SASViyaApiClient {
|
|||||||
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 +533,7 @@ 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.
|
typeDefName: e.name, // "name:" is the typeDefName value required for file creation.
|
||||||
// `name` is ignored here if it is not populated in the map, or
|
|
||||||
// has a blank/empty value.
|
|
||||||
typeDefName: e.name
|
|
||||||
? e.name.trim().length
|
|
||||||
? e.name.trim()
|
|
||||||
: undefined
|
|
||||||
: undefined,
|
|
||||||
properties: e.properties
|
properties: e.properties
|
||||||
})
|
})
|
||||||
})
|
})
|
||||||
@@ -540,53 +542,42 @@ 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
|
return (
|
||||||
const createFileResponse = await this.requestClient.post<File>(
|
await this.requestClient
|
||||||
`/files/files?parentFolderUri=${parentFolderUri}&typeDefName=${
|
.post<File>(
|
||||||
typeDefName ?? 'file'
|
`/files/files?parentFolderUri=${parentFolderUri}&typeDefName=${
|
||||||
}#rawUpload`,
|
typeDefName ?? 'file'
|
||||||
formData,
|
}#rawUpload`,
|
||||||
accessToken,
|
formData,
|
||||||
'multipart/form-data; boundary=' + (formData as any)._boundary,
|
accessToken,
|
||||||
headers
|
'multipart/form-data; boundary=' + (formData as any)._boundary,
|
||||||
)
|
headers
|
||||||
|
)
|
||||||
// If a patch was created...
|
.then(async (res) => {
|
||||||
if (filePatch) {
|
// If a patch was created...
|
||||||
try {
|
if (filePatch) {
|
||||||
const patchHeaders = {
|
// Get the URI of the newly created file
|
||||||
Accept: 'application/json',
|
const fileUri = res.result.links.filter(
|
||||||
'If-Match': '*'
|
(e) => e.method == 'PATCH' && e.rel == 'patch'
|
||||||
}
|
)[0].uri
|
||||||
// Get the URI of the newly created file
|
// and apply the patch
|
||||||
const fileUri = createFileResponse.result.links.filter(
|
return await this.requestClient.patch<File>(
|
||||||
(e) => e.method == 'PATCH' && e.rel == 'patch'
|
`${fileUri}`,
|
||||||
)[0].uri
|
filePatch,
|
||||||
// and apply the patch
|
accessToken
|
||||||
return (
|
)
|
||||||
await this.requestClient.patch<File>(
|
}
|
||||||
`${fileUri}`,
|
return res
|
||||||
filePatch,
|
})
|
||||||
accessToken,
|
).result
|
||||||
patchHeaders
|
|
||||||
)
|
|
||||||
).result
|
|
||||||
} catch (e: any) {
|
|
||||||
throw new Error(`Error patching file ${fileName}.\n${e.message}`)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
return createFileResponse.result
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|||||||
@@ -273,13 +273,9 @@ export class RequestClient implements HttpClient {
|
|||||||
public async patch<T>(
|
public async patch<T>(
|
||||||
url: string,
|
url: string,
|
||||||
data: any = {},
|
data: any = {},
|
||||||
accessToken?: string,
|
accessToken?: string
|
||||||
overrideHeaders: { [key: string]: string | number } = {}
|
|
||||||
): Promise<{ result: T; etag: string }> {
|
): Promise<{ result: T; etag: string }> {
|
||||||
const headers = {
|
const headers = this.getHeaders(accessToken, 'application/json')
|
||||||
...this.getHeaders(accessToken, 'application/json'),
|
|
||||||
...overrideHeaders
|
|
||||||
}
|
|
||||||
|
|
||||||
return this.httpClient
|
return this.httpClient
|
||||||
.patch<T>(url, data, { headers, withXSRFToken: true })
|
.patch<T>(url, data, { headers, withXSRFToken: true })
|
||||||
|
|||||||
Reference in New Issue
Block a user