Press n or j to go to the next uncovered block, b, p or k for the previous block.
| 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 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 | 41x 41x 41x 41x 41x 41x 41x 41x 41x 41x 41x 41x 41x 809x 809x 796x 807x 809x 792x 476x 476x 792x 809x 809x 809x 809x 809x 809x 4x 4x 809x 796x 809x 13x 13x 13x 13x 2x 2x 13x 13x 13x 809x 41x 41x 12x 12x 12x 12x 12x 12x 12x 12x 12x 41x 41x 476x 476x 476x 476x 476x 476x 476x 476x 476x 41x 41x 2x 2x 2x 2x 2x 2x 2x 2x 2x 2x 2x 2x 41x 41x 478x 478x 478x 478x 478x 478x 478x 478x 478x 478x 478x 478x 478x 478x 478x 478x 478x 478x 478x 478x 478x 478x 478x 478x 478x | // Copyright (c) ZeroC, Inc.
import { UserException } from "./UserException.js";
import { DispatchException } from "./LocalExceptions.js";
import { UnknownException } from "./LocalExceptions.js";
import { IPConnectionInfo } from "./Connection.js";
import { identityToString } from "./IdentityToString.js";
import { StringUtil } from "./StringUtil.js";
import { Ice as Ice_ReplyStatus } from "./ReplyStatus.js";
const { ReplyStatus } = Ice_ReplyStatus;
export class LoggerMiddleware {
async dispatch(request) {
try {
const response = await this._next.dispatch(request);
switch (response.replyStatus) {
case ReplyStatus.Ok:
case ReplyStatus.UserException:
if (this._traceLevel > 0) {
this.logDispatch(response.replyStatus, request.current);
}
break;
case ReplyStatus.UnknownException:
case ReplyStatus.UnknownUserException:
case ReplyStatus.UnknownLocalException:
// Always log when middleware installed.
this.logDispatchFailed(response.exceptionDetails, request.current);
break;
default:
if (this._traceLevel > 0 || this._warningLevel > 1) {
this.logDispatchFailed(response.exceptionDetails, request.current);
}
break;
}
return response;
} catch (ex) {
if (ex instanceof UserException) {
if (this._traceLevel > 0) {
this.logDispatch(ReplyStatus.UserException, request.current);
}
} else if (ex instanceof UnknownException) {
// Always log when middleware installed.
// The stack includes the class name and error message.
this.logDispatchFailed(ex.stack, request.current);
} else if (ex instanceof DispatchException) {
if (this._traceLevel > 0 || this._warningLevel > 1) {
this.logDispatchFailed(ex.stack, request.current);
}
} else {
this.logDispatchFailed(ex.stack, request.current);
}
throw ex;
}
}
constructor(next, logger, traceLevel, traceCat, warningLevel, toStringMode) {
this._next = next;
this._logger = logger;
this._traceLevel = traceLevel;
this._traceCat = traceCat;
this._warningLevel = warningLevel;
this._toStringMode = toStringMode;
console.assert(traceLevel > 0 || warningLevel > 0);
}
logDispatch(replyStatus, current) {
const output = [];
output.push("dispatch of ");
output.push(current.operation);
output.push(" to ");
printTarget(output, this._toStringMode, current);
output.push(" returned a response with reply status ");
output.push(replyStatus);
this._logger.trace(this._traceCat, output.join(""));
}
logDispatchFailed(exceptionDetails, current) {
const output = [];
output.push("failed to dispatch ");
output.push(current.operation);
output.push(" to ");
printTarget(output, this._toStringMode, current);
if (exceptionDetails !== null) {
output.push("\n");
output.push(exceptionDetails);
}
this._logger.warning(output.join(""));
}
}
function printTarget(output, toStringMode, current) {
output.push("'");
output.push(identityToString(current.id, toStringMode));
output.push("'");
if (current.facet !== "") {
output.push(" -f '");
output.push(StringUtil.escapeString(current.facet, "", toStringMode));
output.push("'");
}
output.push(" over ");
console.assert(current.con !== null, "current.con is null"); // no colloc in JS
let connInfo = null;
try {
connInfo = current.con.getInfo();
while (connInfo.underlying !== null) {
connInfo = connInfo.underlying;
}
} catch {
// Thrown by getInfo() when the connection is closed.
}
if (connInfo instanceof IPConnectionInfo) {
output.push(connInfo.localAddress);
output.push(":");
output.push(connInfo.localPort);
output.push("<->");
output.push(connInfo.remoteAddress);
output.push(":");
output.push(connInfo.remotePort);
} else {
// Connection.toString() returns a multiline string, so we just use type here for bt and similar.
output.push(current.con.type());
}
}
|