mirror of
https://github.com/sasjs/adapter.git
synced 2026-01-03 10:40:06 +00:00
71 lines
2.0 KiB
TypeScript
71 lines
2.0 KiB
TypeScript
import { isUrl } from './utils'
|
|
import { UploadFile } from './types/UploadFile'
|
|
import { ErrorResponse, LoginRequiredError } from './types/errors'
|
|
import { RequestClient } from './request/RequestClient'
|
|
|
|
export class FileUploader {
|
|
constructor(
|
|
private appLoc: string,
|
|
serverUrl: string,
|
|
private jobsPath: string,
|
|
private requestClient: RequestClient
|
|
) {
|
|
if (serverUrl) isUrl(serverUrl)
|
|
}
|
|
|
|
public uploadFile(sasJob: string, files: UploadFile[], params: any) {
|
|
if (files?.length < 1)
|
|
return Promise.reject(
|
|
new ErrorResponse('At least one file must be provided.')
|
|
)
|
|
if (!sasJob || sasJob === '')
|
|
return Promise.reject(new ErrorResponse('sasJob must be provided.'))
|
|
|
|
let paramsString = ''
|
|
|
|
for (let param in params) {
|
|
if (params.hasOwnProperty(param)) {
|
|
paramsString += `&${param}=${params[param]}`
|
|
}
|
|
}
|
|
|
|
const program = this.appLoc
|
|
? this.appLoc.replace(/\/?$/, '/') + sasJob.replace(/^\//, '')
|
|
: sasJob
|
|
const uploadUrl = `${this.jobsPath}/?${
|
|
'_program=' + program
|
|
}${paramsString}`
|
|
|
|
const formData = new FormData()
|
|
|
|
for (let file of files) {
|
|
formData.append('file', file.file, file.fileName)
|
|
}
|
|
|
|
const csrfToken = this.requestClient.getCsrfToken('file')
|
|
if (csrfToken) formData.append('_csrf', csrfToken.value)
|
|
|
|
const headers = {
|
|
'cache-control': 'no-cache',
|
|
Accept: '*/*',
|
|
'Content-Type': 'text/plain'
|
|
}
|
|
|
|
return this.requestClient
|
|
.post(uploadUrl, formData, undefined, 'application/json', headers)
|
|
.then((res) =>
|
|
typeof res.result === 'string' ? JSON.parse(res.result) : res.result
|
|
)
|
|
.catch((err: Error) => {
|
|
if (err instanceof LoginRequiredError) {
|
|
return Promise.reject(
|
|
new ErrorResponse('You must be logged in to upload a file.', err)
|
|
)
|
|
}
|
|
return Promise.reject(
|
|
new ErrorResponse('File upload request failed.', err)
|
|
)
|
|
})
|
|
}
|
|
}
|