@authx/authx/dist/apolloTracing.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
const graphql_1 = require("graphql");
const traceHRStartTime = Symbol("HR Start Time");
const traceWallStartTime = Symbol("Wall Start Time");
exports.apolloTracingContext = Symbol("Apollo Tracing Context");
function durationHrTimeToNanos(hrtime) {
    return hrtime[0] * 1e9 + hrtime[1];
}
async function apolloTracingGraphQLMiddleware(resolve, parent, args, context, info) {
    const startOffset = durationHrTimeToNanos(process.hrtime(context[exports.apolloTracingContext][traceHRStartTime]));
    try {
        return await resolve(parent, args, context, info);
    }
    finally {
        context[exports.apolloTracingContext].execution.resolvers.push({
            path: [...graphql_1.responsePathAsArray(info.path)],
            parentType: info.parentType.toString(),
            fieldName: info.fieldName,
            returnType: info.returnType.toString(),
            startOffset,
            duration: durationHrTimeToNanos(process.hrtime(context[exports.apolloTracingContext][traceHRStartTime])) - startOffset
        });
    }
}
exports.apolloTracingGraphQLMiddleware = apolloTracingGraphQLMiddleware;
function startTracingContext() {
    const wallStartTime = new Date();
    return {
        [traceHRStartTime]: process.hrtime(),
        [traceWallStartTime]: wallStartTime,
        version: 1,
        startTime: wallStartTime.toISOString(),
        endTime: "",
        duration: 0,
        execution: {
            resolvers: []
        }
    };
}
exports.startTracingContext = startTracingContext;
function endTracingContext(context) {
    context.endTime = new Date().toISOString();
    context.duration = durationHrTimeToNanos(process.hrtime(context[traceHRStartTime]));
}
exports.endTracingContext = endTracingContext;
//# sourceMappingURL=apolloTracing.js.map