first commit

wangzhibo

2026-05-09 53418655c061ac26f66058253f39200aced1ab1d

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
/*! @azure/msal-common v16.5.0 2026-04-16 */
'use strict';
/* 
 * Copyright (c) Microsoft Corporation. All rights reserved. 
 * Licensed under the MIT License. 
 */ 
/** 
 * Wraps a function with a performance measurement. 
 * Usage: invoke(functionToCall, performanceClient, "EventName", "correlationId")(...argsToPassToFunction) 
 * @param callback 
 * @param eventName 
 * @param logger 
 * @param telemetryClient 
 * @param correlationId 
 * @returns 
 * @internal 
 */ 
// eslint-disable-next-line @typescript-eslint/no-explicit-any 
const invoke = (callback, eventName, logger, telemetryClient, correlationId) => { 
    return (...args) => { 
        logger.trace(`Executing function '${eventName}'`, correlationId); 
        const inProgressEvent = telemetryClient.startMeasurement(eventName, correlationId); 
        if (correlationId) { 
            // Track number of times this API is called in a single request 
            telemetryClient.incrementFields({ [`ext.${eventName}CallCount`]: 1 }, correlationId); 
        } 
        try { 
            const result = callback(...args); 
            inProgressEvent.end({ 
                success: true, 
            }); 
            logger.trace(`Returning result from '${eventName}'`, correlationId); 
            return result; 
        } 
        catch (e) { 
            logger.trace(`Error occurred in '${eventName}'`, correlationId); 
            try { 
                logger.trace(JSON.stringify(e), correlationId); 
            } 
            catch (e) { 
                logger.trace("Unable to print error message.", correlationId); 
            } 
            inProgressEvent.end({ 
                success: false, 
            }, e); 
            throw e; 
        } 
    }; 
}; 
/** 
 * Wraps an async function with a performance measurement. 
 * Usage: invokeAsync(functionToCall, performanceClient, "EventName", "correlationId")(...argsToPassToFunction) 
 * @param callback 
 * @param eventName 
 * @param logger 
 * @param telemetryClient 
 * @param correlationId 
 * @returns 
 * @internal 
 * 
 */ 
// eslint-disable-next-line @typescript-eslint/no-explicit-any 
const invokeAsync = (callback, eventName, logger, telemetryClient, correlationId) => { 
    return (...args) => { 
        logger.trace(`Executing function '${eventName}'`, correlationId); 
        const inProgressEvent = telemetryClient.startMeasurement(eventName, correlationId); 
        if (correlationId) { 
            // Track number of times this API is called in a single request 
            telemetryClient.incrementFields({ [`ext.${eventName}CallCount`]: 1 }, correlationId); 
        } 
        return callback(...args) 
            .then((response) => { 
            logger.trace(`Returning result from '${eventName}'`, correlationId); 
            inProgressEvent.end({ 
                success: true, 
            }); 
            return response; 
        }) 
            .catch((e) => { 
            logger.trace(`Error occurred in '${eventName}'`, correlationId); 
            try { 
                logger.trace(JSON.stringify(e), correlationId); 
            } 
            catch (e) { 
                logger.trace("Unable to print error message.", correlationId); 
            } 
            inProgressEvent.end({ 
                success: false, 
            }, e); 
            throw e; 
        }); 
    }; 
};
 
export { invoke, invokeAsync };
//# sourceMappingURL=FunctionWrappers.mjs.map