bot-tester/dist/OutgoingMessageComparator.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
/**
 * Manages the comparisons against expected messages and outgoingMessages that the BotTester framework intercepts
 */
class OutgoingMessageComparator {
    constructor(expectedMessages, ignoreOrder) {
        this.expectedMessages = expectedMessages;
        this.ignoreOrder = ignoreOrder;
    }
    /**
     * compares the current outgoing message against the current expected message
     */
    compareOutgoingMessageToExpectedResponses(outgoingMessage) {
        if (this.ignoreOrder) {
            this.compareOutgoingMessageToExpectedResponsesWithoutOrder(outgoingMessage);
        }
        else {
            this.compareOutgoingMessageToExpectedResponsesInOrder(outgoingMessage);
        }
    }
    /**
     * returns tfalse when all expected messages have been seen (e.g. test steps are emtpy)
     */
    expectsAdditionalMessages() {
        return this.expectedMessages.length !== 0;
    }
    getTimeoutErrorMessage() {
        return `timedout while waiting to receive ${this.expectedMessages[0].toString()}`;
    }
    compareOutgoingMessageToExpectedResponsesInOrder(outgoingMessage) {
        const nextMessage = this.dequeueNextExpectedMessage();
        if (nextMessage) {
            nextMessage.checkForMessageMatch(outgoingMessage);
        }
    }
    compareOutgoingMessageToExpectedResponsesWithoutOrder(outgoingMessage) {
        const originalItemCount = this.expectedMessages.length;
        let matchingMessageFound = false;
        this.expectedMessages = this.expectedMessages.filter((expectedMessage, i) => {
            if (matchingMessageFound) {
                return true;
            }
            try {
                expectedMessage.checkForMessageMatch(outgoingMessage);
                matchingMessageFound = true;
                return false;
            }
            catch (e) {
                return true;
            }
        });
        if (originalItemCount === this.expectedMessages.length) {
            throw new Error(`${JSON.stringify(outgoingMessage, null, 2)} did not match any of ${this.expectedMessages.map((t) => t.toString())}`);
        }
    }
    /**
     * gets the next expected message and removes it from the expectedMessages
     */
    dequeueNextExpectedMessage() {
        return this.expectedMessages.shift();
    }
}
exports.OutgoingMessageComparator = OutgoingMessageComparator;
//# sourceMappingURL=OutgoingMessageComparator.js.map