mirror of
https://gitee.com/element-plus/element-plus.git
synced 2024-12-14 17:31:02 +08:00
92 lines
2.0 KiB
TypeScript
92 lines
2.0 KiB
TypeScript
|
import type {
|
||
|
ElUploadProgressEvent,
|
||
|
ElUploadRequestOptions,
|
||
|
ElUploadAjaxError,
|
||
|
} from './upload'
|
||
|
|
||
|
function getError(action: string, option: ElUploadRequestOptions, xhr: XMLHttpRequest) {
|
||
|
let msg: string
|
||
|
if (xhr.response) {
|
||
|
msg = `${xhr.response.error || xhr.response}`
|
||
|
} else if (xhr.responseText) {
|
||
|
msg = `${xhr.responseText}`
|
||
|
} else {
|
||
|
msg = `fail to post ${action} ${xhr.status}`
|
||
|
}
|
||
|
|
||
|
const err = new Error(msg) as ElUploadAjaxError
|
||
|
err.status = xhr.status
|
||
|
err.method = 'post'
|
||
|
err.url = action
|
||
|
return err
|
||
|
}
|
||
|
|
||
|
function getBody(xhr: XMLHttpRequest): XMLHttpRequestResponseType {
|
||
|
const text = xhr.responseText || xhr.response
|
||
|
if (!text) {
|
||
|
return text
|
||
|
}
|
||
|
|
||
|
try {
|
||
|
return JSON.parse(text)
|
||
|
} catch (e) {
|
||
|
return text
|
||
|
}
|
||
|
}
|
||
|
|
||
|
export default function upload(option: ElUploadRequestOptions) {
|
||
|
if (typeof XMLHttpRequest === 'undefined') {
|
||
|
return
|
||
|
}
|
||
|
|
||
|
const xhr = new XMLHttpRequest()
|
||
|
const action = option.action
|
||
|
|
||
|
if (xhr.upload) {
|
||
|
xhr.upload.onprogress = function progress(e) {
|
||
|
if (e.total > 0) {
|
||
|
(e as ElUploadProgressEvent).percent = e.loaded / e.total * 100
|
||
|
}
|
||
|
option.onProgress(e)
|
||
|
}
|
||
|
}
|
||
|
|
||
|
const formData = new FormData()
|
||
|
|
||
|
if (option.data) {
|
||
|
Object.keys(option.data).forEach(key => {
|
||
|
formData.append(key, option.data[key])
|
||
|
})
|
||
|
}
|
||
|
|
||
|
formData.append(option.filename, option.file, option.file.name)
|
||
|
|
||
|
xhr.onerror = function error() {
|
||
|
option.onError(getError(action, option, xhr))
|
||
|
}
|
||
|
|
||
|
xhr.onload = function onload() {
|
||
|
if (xhr.status < 200 || xhr.status >= 300) {
|
||
|
return option.onError(getError(action, option, xhr))
|
||
|
}
|
||
|
|
||
|
option.onSuccess(getBody(xhr))
|
||
|
}
|
||
|
|
||
|
xhr.open('post', action, true)
|
||
|
|
||
|
if (option.withCredentials && 'withCredentials' in xhr) {
|
||
|
xhr.withCredentials = true
|
||
|
}
|
||
|
|
||
|
const headers = option.headers || {}
|
||
|
|
||
|
for (const item in headers) {
|
||
|
if (headers.hasOwnProperty(item) && headers[item] !== null) {
|
||
|
xhr.setRequestHeader(item, headers[item])
|
||
|
}
|
||
|
}
|
||
|
xhr.send(formData)
|
||
|
return xhr
|
||
|
}
|