File size: 3,959 Bytes
6e7eaf3 |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 |
"use strict";
/*---------------------------------------------------------------------------------------------
* Copyright (c) Microsoft Corporation. All rights reserved.
* Licensed under the MIT License. See License.txt in the project root for license information.
*--------------------------------------------------------------------------------------------*/
var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
if (k2 === undefined) k2 = k;
var desc = Object.getOwnPropertyDescriptor(m, k);
if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
desc = { enumerable: true, get: function() { return m[k]; } };
}
Object.defineProperty(o, k2, desc);
}) : (function(o, m, k, k2) {
if (k2 === undefined) k2 = k;
o[k2] = m[k];
}));
var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
Object.defineProperty(o, "default", { enumerable: true, value: v });
}) : function(o, v) {
o["default"] = v;
});
var __importStar = (this && this.__importStar) || function (mod) {
if (mod && mod.__esModule) return mod;
var result = {};
if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
__setModuleDefault(result, mod);
return result;
};
Object.defineProperty(exports, "__esModule", { value: true });
exports.TimeoutError = exports.TimeoutController = exports.getJSON = exports.getStream = void 0;
const https = __importStar(require("https"));
const util_1 = require("./util");
async function getStream(api, timeout) {
const ctrl = new TimeoutController(timeout);
return new Promise((resolve, reject) => {
ctrl.signal.addEventListener('abort', () => {
reject(new TimeoutError(timeout));
req.destroy();
});
const req = https.get(api, (0, util_1.urlToOptions)(api), (res) => resolve(res)).on('error', reject);
}).finally(() => ctrl.dispose());
}
exports.getStream = getStream;
async function getJSON(api, timeout) {
const ctrl = new TimeoutController(timeout);
return new Promise((resolve, reject) => {
ctrl.signal.addEventListener('abort', () => {
reject(new TimeoutError(timeout));
req.destroy();
});
const req = https
.get(api, (0, util_1.urlToOptions)(api), (res) => {
if (res.statusCode !== 200) {
reject('Failed to get JSON');
}
let data = '';
res.on('data', (chunk) => {
ctrl.touch();
data += chunk;
});
res.on('end', () => {
ctrl.dispose();
try {
const jsonData = JSON.parse(data);
resolve(jsonData);
}
catch (err) {
console.error(`Failed to parse response from ${api} as JSON`);
reject(err);
}
});
res.on('error', reject);
})
.on('error', reject);
}).finally(() => ctrl.dispose());
}
exports.getJSON = getJSON;
class TimeoutController {
get signal() {
return this.ctrl.signal;
}
constructor(timeout) {
this.timeout = timeout;
this.ctrl = new AbortController();
this.reject = () => {
this.ctrl.abort();
};
this.handle = setTimeout(this.reject, timeout);
}
touch() {
clearTimeout(this.handle);
this.handle = setTimeout(this.reject, this.timeout);
}
dispose() {
clearTimeout(this.handle);
}
}
exports.TimeoutController = TimeoutController;
class TimeoutError extends Error {
constructor(duration) {
super(`@vscode/test-electron request timeout out after ${duration}ms`);
}
}
exports.TimeoutError = TimeoutError;
|