12751184555

Committed 13 Jan 2025 04:03PM UTC coverage: 84.564% (-0.05%) from 84.618%

Build # 12751184555

Build Type

Pull #4834

github

Committed by

web-flow

Commit Message

Merge 128d6b3ea into 428a1cdfc

Pull Request Pull Request #4834: refactor: [#4759] Migrate off @azure/core-http

Run Details

8238 of 10899 branches covered (75.58%)

Branch coverage included in aggregate %.

129 of 148 new or added lines in 22 files covered. (87.16%)

6 existing lines in 3 files now uncovered.

20534 of 23125 relevant lines covered (88.8%)

7297.83 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

63.16

/libraries/botbuilder/src/streaming/streamingHttpClient.ts

/**
 * @module botbuilder
 */
/**
 * Copyright (c) Microsoft Corporation. All rights reserved.
 * Licensed under the MIT License.
 */

import {
    WebResourceLike as WebResource,
    HttpOperationResponse,
    HttpClient,
} from 'botbuilder-stdlib/lib/azureCoreHttpCompat';
import { IStreamingTransportServer, StreamingRequest } from 'botframework-streaming';

/**
 * An implementation of `HttpClient` that adds compatibility with streaming connections.
 */
export class StreamingHttpClient implements HttpClient {
    private readonly server: IStreamingTransportServer;

    /**
     * Creates a new streaming Http client.
     *
     * @param server Transport server implementation to be used.
     */
    constructor(server: IStreamingTransportServer) {
        if (!server) {
            throw new Error('StreamingHttpClient: Expected server.');
        }
        this.server = server;
    }

    /**
     * This function hides the default sendRequest of the HttpClient, replacing it
     * with a version that takes the WebResource created by the BotFrameworkAdapter
     * and converting it to a form that can be sent over a streaming transport.
     *
     * @param httpRequest The outgoing request created by the BotframeworkAdapter.
     * @returns The streaming transport compatible response to send back to the client.
     */
    async sendRequest(httpRequest: WebResource): Promise<HttpOperationResponse> {
        if (!httpRequest) {
            throw new Error('StreamingHttpClient.sendRequest(): missing "httpRequest" parameter');
        }
        if (!this.server.isConnected) {
            throw new Error(
                'StreamingHttpClient.sendRequest(): Streaming connection is disconnected, and the request could not be sent.',
            );
        }

        const request = this.mapHttpRequestToProtocolRequest(httpRequest);
        request.path = request.path.substring(request.path.indexOf('/v3'));
        const res = await this.server.send(request);
        return {
            request: httpRequest,
            status: res.statusCode,
            headers: httpRequest.headers,
            readableStreamBody: res.streams.length > 0 ? res.streams[0].getStream() : undefined,
        };
    }

    /**
     * @private
     */
    private mapHttpRequestToProtocolRequest(httpRequest: WebResource): StreamingRequest {
        return StreamingRequest.create(httpRequest.method, httpRequest.url, httpRequest.body);
    }
}

1	/**
2	* @module botbuilder
3	*/
4	/**
5	* Copyright (c) Microsoft Corporation. All rights reserved.
6	* Licensed under the MIT License.
7	*/
8
9	import {
10	WebResourceLike as WebResource,
11	HttpOperationResponse,
12	HttpClient,
13	} from 'botbuilder-stdlib/lib/azureCoreHttpCompat';
14	import { IStreamingTransportServer, StreamingRequest } from 'botframework-streaming';	2✔
15
16	/**
17	* An implementation of `HttpClient` that adds compatibility with streaming connections.
18	*/
19	export class StreamingHttpClient implements HttpClient {	2✔
20	private readonly server: IStreamingTransportServer;
21
22	/**
23	* Creates a new streaming Http client.
24	*
25	* @param server Transport server implementation to be used.
26	*/
27	constructor(server: IStreamingTransportServer) {
28	if (!server) {	12✔
29	throw new Error('StreamingHttpClient: Expected server.');	2✔
30	}
31	this.server = server;	10✔
32	}
33
34	/**
35	* This function hides the default sendRequest of the HttpClient, replacing it
36	* with a version that takes the WebResource created by the BotFrameworkAdapter
37	* and converting it to a form that can be sent over a streaming transport.
38	*
39	* @param httpRequest The outgoing request created by the BotframeworkAdapter.
40	* @returns The streaming transport compatible response to send back to the client.
41	*/
42	async sendRequest(httpRequest: WebResource): Promise<HttpOperationResponse> {
43	if (!httpRequest) {	4✔
44	throw new Error('StreamingHttpClient.sendRequest(): missing "httpRequest" parameter');	2✔
45	}
46	if (!this.server.isConnected) {	2✔
47	throw new Error(	2✔
48	'StreamingHttpClient.sendRequest(): Streaming connection is disconnected, and the request could not be sent.',
49	);
50	}
51
UNCOV 52	const request = this.mapHttpRequestToProtocolRequest(httpRequest);	×
UNCOV 53	request.path = request.path.substring(request.path.indexOf('/v3'));	×
UNCOV 54	const res = await this.server.send(request);	×
55	return {	×
56	request: httpRequest,
57	status: res.statusCode,
58	headers: httpRequest.headers,
59	readableStreamBody: res.streams.length > 0 ? res.streams[0].getStream() : undefined,	×
60	};
61	}
62
63	/**
64	* @private
65	*/
66	private mapHttpRequestToProtocolRequest(httpRequest: WebResource): StreamingRequest {
UNCOV 67	return StreamingRequest.create(httpRequest.method, httpRequest.url, httpRequest.body);	×
68	}
69	}

microsoft / botbuilder-js / 12751184555

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous