in src/main/resources/static/components/session/AxtMessage.ts [139:171]
export function print(message: AxtMessage, text: boolean = true): string {
switch (message.msgType) {
case MessageType.Input:
const input = getString(message.payLoad, text)
return `[Input ${message.inputSeq}:${message.outputSeq} (${message.msgLength})'${input}']`;
case MessageType.Output:
const output = getString(message.payLoad, text)
return `[Output ${message.inputSeq}:${message.outputSeq} (${message.msgLength})'${output}']`;
case MessageType.Resize:
if (message.payLoad.length == 4) {
const size = ByteBuffer.wrap(message.payLoad).toString("hex")
return `[Resize ${message.inputSeq}:${message.outputSeq} (${message.msgType})${size}]`;
} else {
const json = new TextDecoder().decode(message.payLoad);
return `[Resize ${message.inputSeq}:${message.outputSeq} (${message.msgLength})${json}]`;
}
case MessageType.Status:
const buffer = ByteBuffer.wrap(message.payLoad)
const status = display(buffer.readUint8())
if (status == "Stream") {
const limit = buffer.readUint32()
return `[Status ${message.inputSeq}:${message.outputSeq} (${status})${limit}]`;
} else {
const prompt = buffer.readString(message.msgLength - 1)
return `[Status ${message.inputSeq}:${message.outputSeq} (${status})${prompt}]`;
}
case MessageType.Sync:
return `[Sync ${message.inputSeq}:${message.outputSeq}]`;
default:
const data = getString(message.payLoad, text)
return `[${message.msgType} ${message.inputSeq}:${message.outputSeq} (${message.msgLength})${data}]`;
}
}