gnezim
87 lines
3.7 KiB
JavaScript
87 lines
3.7 KiB
JavaScript
"use strict";
|
|
// Licensed to the .NET Foundation under one or more agreements.
|
|
// The .NET Foundation licenses this file to you under the MIT license.
|
|
Object.defineProperty(exports, "__esModule", { value: true });
|
|
exports.XhrHttpClient = void 0;
|
|
const Errors_1 = require("./Errors");
|
|
const HttpClient_1 = require("./HttpClient");
|
|
const ILogger_1 = require("./ILogger");
|
|
const Utils_1 = require("./Utils");
|
|
class XhrHttpClient extends HttpClient_1.HttpClient {
|
|
constructor(logger) {
|
|
super();
|
|
this._logger = logger;
|
|
}
|
|
/** @inheritDoc */
|
|
send(request) {
|
|
// Check that abort was not signaled before calling send
|
|
if (request.abortSignal && request.abortSignal.aborted) {
|
|
return Promise.reject(new Errors_1.AbortError());
|
|
}
|
|
if (!request.method) {
|
|
return Promise.reject(new Error("No method defined."));
|
|
}
|
|
if (!request.url) {
|
|
return Promise.reject(new Error("No url defined."));
|
|
}
|
|
return new Promise((resolve, reject) => {
|
|
const xhr = new XMLHttpRequest();
|
|
xhr.open(request.method, request.url, true);
|
|
xhr.withCredentials = request.withCredentials === undefined ? true : request.withCredentials;
|
|
xhr.setRequestHeader("X-Requested-With", "XMLHttpRequest");
|
|
if (request.content === "") {
|
|
request.content = undefined;
|
|
}
|
|
if (request.content) {
|
|
// Explicitly setting the Content-Type header for React Native on Android platform.
|
|
if ((0, Utils_1.isArrayBuffer)(request.content)) {
|
|
xhr.setRequestHeader("Content-Type", "application/octet-stream");
|
|
}
|
|
else {
|
|
xhr.setRequestHeader("Content-Type", "text/plain;charset=UTF-8");
|
|
}
|
|
}
|
|
const headers = request.headers;
|
|
if (headers) {
|
|
Object.keys(headers)
|
|
.forEach((header) => {
|
|
xhr.setRequestHeader(header, headers[header]);
|
|
});
|
|
}
|
|
if (request.responseType) {
|
|
xhr.responseType = request.responseType;
|
|
}
|
|
if (request.abortSignal) {
|
|
request.abortSignal.onabort = () => {
|
|
xhr.abort();
|
|
reject(new Errors_1.AbortError());
|
|
};
|
|
}
|
|
if (request.timeout) {
|
|
xhr.timeout = request.timeout;
|
|
}
|
|
xhr.onload = () => {
|
|
if (request.abortSignal) {
|
|
request.abortSignal.onabort = null;
|
|
}
|
|
if (xhr.status >= 200 && xhr.status < 300) {
|
|
resolve(new HttpClient_1.HttpResponse(xhr.status, xhr.statusText, xhr.response || xhr.responseText));
|
|
}
|
|
else {
|
|
reject(new Errors_1.HttpError(xhr.response || xhr.responseText || xhr.statusText, xhr.status));
|
|
}
|
|
};
|
|
xhr.onerror = () => {
|
|
this._logger.log(ILogger_1.LogLevel.Warning, `Error from HTTP request. ${xhr.status}: ${xhr.statusText}.`);
|
|
reject(new Errors_1.HttpError(xhr.statusText, xhr.status));
|
|
};
|
|
xhr.ontimeout = () => {
|
|
this._logger.log(ILogger_1.LogLevel.Warning, `Timeout from HTTP request.`);
|
|
reject(new Errors_1.TimeoutError());
|
|
};
|
|
xhr.send(request.content);
|
|
});
|
|
}
|
|
}
|
|
exports.XhrHttpClient = XhrHttpClient;
|
|
//# sourceMappingURL=XhrHttpClient.js.map
|