11579379955

Committed 29 Oct 2024 05:34PM UTC coverage: 84.703% (-0.5%) from 85.23%

Build # 11579379955

Build Type

push

github

Committed by

web-flow

Commit Message

refactor: [#4684] Replace browserify with tsup (#4774)

* Replace browserify with tsup in adaptive-expressions

* Remove remaining browserify packages

* Fix streaming tests

* Fix yarn.lock

* fix depcheck

Run Details

8186 of 10820 branches covered (75.66%)

Branch coverage included in aggregate %.

2 of 2 new or added lines in 1 file covered. (100.0%)

23 existing lines in 13 files now uncovered.

20514 of 23063 relevant lines covered (88.95%)

7296.87 hits per line

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

77.42

/libraries/botframework-streaming/src/payloads/sendOperations.ts

/**
 * @module botframework-streaming
 */
/**
 * Copyright (c) Microsoft Corporation. All rights reserved.
 * Licensed under the MIT License.
 */
import { PayloadSender } from '../payloadTransport/payloadSender';
import { StreamingRequest } from '../streamingRequest';
import { StreamingResponse } from '../streamingResponse';
import { CancelDisassembler } from '../disassemblers/cancelDisassembler';
import { HttpContentStreamDisassembler } from '../disassemblers/httpContentStreamDisassembler';
import { RequestDisassembler } from '../disassemblers/requestDisassembler';
import { ResponseDisassembler } from '../disassemblers/responseDisassembler';
import { PayloadTypes } from './payloadTypes';

/**
 * Send operations for streaming payloads.
 */
export class SendOperations {
    private readonly payloadSender: PayloadSender;

    /**
     * Initializes a new instance of the [SendOperations](xref:botframework-streaming.SendOperations) class.
     *
     * @param payloadSender The [PayloadSender](xref:botframework-streaming.PayloadSender) that will send the disassembled data from all of this instance's send operations.
     */
    constructor(payloadSender: PayloadSender) {
        this.payloadSender = payloadSender;
    }

    /**
     * The send operation used to send a [StreamingRequest](xref:botframework-streaming.StreamingRequest).
     *
     * @param id The ID to assign to the [RequestDisassembler](xref:botframework-streaming.RequestDisassembler) used by this operation.
     * @param request The request to send.
     */
    async sendRequest(id: string, request: StreamingRequest): Promise<void> {
        const disassembler = new RequestDisassembler(this.payloadSender, id, request);

        await disassembler.disassemble();

        if (request.streams) {
            request.streams.forEach(
                async (contentStream): Promise<void> => {
                    await new HttpContentStreamDisassembler(this.payloadSender, contentStream).disassemble();
                }
            );
        }
    }

    /**
     * The send operation used to send a [PayloadTypes.response](xref:botframework-streaming.PayloadTypes.response).
     *
     * @param id The ID to assign to the [ResponseDisassembler](xref:botframework-streaming.ResponseDisassembler) used by this operation.
     * @param response The response to send.
     */
    async sendResponse(id: string, response: StreamingResponse): Promise<void> {
        const disassembler = new ResponseDisassembler(this.payloadSender, id, response);

        await disassembler.disassemble();

        if (response.streams) {
            response.streams.forEach(
                async (contentStream): Promise<void> => {
                    await new HttpContentStreamDisassembler(this.payloadSender, contentStream).disassemble();
                }
            );
        }
    }

    /**
     * The send operation used to send a [PayloadTypes.cancelStream](xref:botframework-streaming.PayloadTypes.cancelStream).
     *
     * @param id The ID to assign to the [CancelDisassembler](xref:botframework-streaming.CancelDisassembler) used by this operation.
     */
    async sendCancelStream(id: string): Promise<void> {
        const disassembler = new CancelDisassembler(this.payloadSender, id, PayloadTypes.cancelStream);
        disassembler.disassemble();
    }
}

1	/**	8✔
2	* @module botframework-streaming
3	*/
4	/**
5	* Copyright (c) Microsoft Corporation. All rights reserved.
6	* Licensed under the MIT License.
7	*/
8	import { PayloadSender } from '../payloadTransport/payloadSender';
9	import { StreamingRequest } from '../streamingRequest';
10	import { StreamingResponse } from '../streamingResponse';
11	import { CancelDisassembler } from '../disassemblers/cancelDisassembler';	2✔
12	import { HttpContentStreamDisassembler } from '../disassemblers/httpContentStreamDisassembler';	2✔
13	import { RequestDisassembler } from '../disassemblers/requestDisassembler';	2✔
14	import { ResponseDisassembler } from '../disassemblers/responseDisassembler';	2✔
15	import { PayloadTypes } from './payloadTypes';	2✔
16
17	/**
18	* Send operations for streaming payloads.
19	*/
20	export class SendOperations {	2✔
21	private readonly payloadSender: PayloadSender;
22
23	/**
24	* Initializes a new instance of the [SendOperations](xref:botframework-streaming.SendOperations) class.
25	*
26	* @param payloadSender The [PayloadSender](xref:botframework-streaming.PayloadSender) that will send the disassembled data from all of this instance's send operations.
27	*/
28	constructor(payloadSender: PayloadSender) {
29	this.payloadSender = payloadSender;	103✔
30	}
31
32	/**
33	* The send operation used to send a [StreamingRequest](xref:botframework-streaming.StreamingRequest).
34	*
35	* @param id The ID to assign to the [RequestDisassembler](xref:botframework-streaming.RequestDisassembler) used by this operation.
36	* @param request The request to send.
37	*/
UNCOV 38	async sendRequest(id: string, request: StreamingRequest): Promise<void> {	×
39	const disassembler = new RequestDisassembler(this.payloadSender, id, request);	22✔
40
41	await disassembler.disassemble();	22✔
42
43	if (request.streams) {	22!
44	request.streams.forEach(	22✔
45	async (contentStream): Promise<void> => {	20✔
46	await new HttpContentStreamDisassembler(this.payloadSender, contentStream).disassemble();	20✔
47	}
48	);
49	}
50	}
51
52	/**
53	* The send operation used to send a [PayloadTypes.response](xref:botframework-streaming.PayloadTypes.response).
54	*
55	* @param id The ID to assign to the [ResponseDisassembler](xref:botframework-streaming.ResponseDisassembler) used by this operation.
56	* @param response The response to send.
57	*/
UNCOV 58	async sendResponse(id: string, response: StreamingResponse): Promise<void> {	×
59	const disassembler = new ResponseDisassembler(this.payloadSender, id, response);	14✔
60
61	await disassembler.disassemble();	14✔
62
63	if (response.streams) {	14!
64	response.streams.forEach(	14✔
65	async (contentStream): Promise<void> => {	16✔
66	await new HttpContentStreamDisassembler(this.payloadSender, contentStream).disassemble();	16✔
67	}
68	);
69	}
70	}
71
72	/**
73	* The send operation used to send a [PayloadTypes.cancelStream](xref:botframework-streaming.PayloadTypes.cancelStream).
74	*
75	* @param id The ID to assign to the [CancelDisassembler](xref:botframework-streaming.CancelDisassembler) used by this operation.
76	*/
UNCOV 77	async sendCancelStream(id: string): Promise<void> {	×
78	const disassembler = new CancelDisassembler(this.payloadSender, id, PayloadTypes.cancelStream);	4✔
79	disassembler.disassemble();	4✔
80	}
81	}

microsoft / botbuilder-js / 11579379955

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