1
>
/*---------------------------------------------------------------------------------------------
request.ts
2
>
* Copyright (c) Microsoft Corporation. All rights reserved.
3
>
* Licensed under the MIT License. See License.txt in the project root for license information.
4
>
*--------------------------------------------------------------------------------------------*/
5
>
6
>
import { streamToBuffer } from '../../../base/common/buffer.js';
7
>
import { CancellationToken } from '../../../base/common/cancellation.js';
8
>
import { getErrorMessage } from '../../../base/common/errors.js';
9
>
import { Emitter, Event } from '../../../base/common/event.js';
10
>
import { Disposable } from '../../../base/common/lifecycle.js';
11
>
import { IHeaders, IRequestContext, IRequestOptions } from '../../../base/parts/request/common/request.js';
12
>
import { localize } from '../../../nls.js';
13
>
import { ConfigurationScope, Extensions, IConfigurationNode, IConfigurationRegistry } from '../../configuration/common/configurationRegistry.js';
14
>
import { createDecorator } from '../../instantiation/common/instantiation.js';
15
>
import { ILogService } from '../../log/common/log.js';
16
>
import { Registry } from '../../registry/common/platform.js';
17
>
18
>
export const IRequestService = createDecorator<IRequestService>('requestService');
19
>
20
>
/**
21
>
* Use as the {@link IRequestOptions.callSite} value to prevent
22
>
* request telemetry from being emitted. This is needed for
23
>
* callers such as the telemetry sender to avoid cyclical calls.
24
>
*/
25
>
export const NO_FETCH_TELEMETRY = 'NO_FETCH_TELEMETRY';
26
>
27
>
export interface IRequestCompleteEvent {
28
>
readonly callSite: string;
29
>
readonly latency: number;
30
>
readonly statusCode: number | undefined;
31
>
}
32
>
33
>
export interface AuthInfo {
34
>
isProxy: boolean;
35
>
scheme: string;
36
>
host: string;
37
>
port: number;
38
>
realm: string;
39
>
attempt: number;
40
>
}
41
>
42
>
export interface Credentials {
43
>
username: string;
44
>
password: string;
45
>
}
46
>
47
>
export interface IRequestService {
48
>
readonly _serviceBrand: undefined;
49
>
50
>
/**
51
>
* Fires when a request completes (successfully or with an error response).
52
>
*/
53
>
readonly onDidCompleteRequest: Event<IRequestCompleteEvent>;
54
>
55
>
request(options: IRequestOptions, token: CancellationToken): Promise<IRequestContext>;
56
>
57
>
resolveProxy(url: string): Promise<string | undefined>;
58
>
lookupAuthorization(authInfo: AuthInfo): Promise<Credentials | undefined>;
59
>
lookupKerberosAuthorization(url: string): Promise<string | undefined>;
60
>
loadCertificates(): Promise<string[]>;
61
>
}
62
>
63
>
class LoggableHeaders {
64
>
65
>
private headers: IHeaders | undefined;
66
>
67
>
constructor(private readonly original: IHeaders) { }
68
>
69
>
toJSON(): any {
70
if (!this.headers) {
71
const headers = Object.create(null);