Enkaku HTTP 服务器传输
安装
npm install @enkaku/http-serve
每句信息 HTTP 语境
ServerTransport.getMessageContext(message) 财务报告和审定财务报表 createServerBridge().getMessageContext(message) 返回时 HTTPMessageContext | undefined。 。 。 .
上下文包含 request: Request,可选 sessionID 和可选 session: HTTPSessionHandle。 。 。 .
流取和频道引用会暴露新的或现有的SSE会话ID enkaku-session-id 头曰.
与已知会话相关的信件共享会话处理.
没有会话的一次性请求和信件仍然会暴露他们的HTTP请求.
上下文搜索使用消息对象身份和一个弱地图. 未知对象、已克隆信件和非对象值返回 undefined。 。 。 .
上下文保留在序列信息之外 .
服务器的 onInvocation 钩子通过此上下文接收 ctx.transport键入为 unknown。 。 。 .
客户端断开或会话中断 ctx.signal 在等待的钩子中,并阻止随后的处理器调度.
SSE 会话所有权
HTTPSessionHandle 曝光只读 id 财务报告和审定财务报表 owner 属性加 bindOwner(did: string): void。 。 。 .
会话开始无约束 。 重新装入同样成功的东西 装订另一个 扔并保存了原主人.
由经核实的呼叫者将所有权绑入经认证的引用钩:
import type { HTTPMessageContext } from '@enkaku/http-serve'
import { ServerTransport } from '@enkaku/http-serve'
import { Server } from '@enkaku/server'
const transport = new ServerTransport<typeof protocol>()
const server = new Server({
protocol,
handlers,
identity,
accessRules,
onInvocation(ctx) {
const context = ctx.transport as HTTPMessageContext | undefined
if (ctx.caller != null) {
context?.session?.bindOwner(ctx.caller.iss)
}
},
})
server.handle(transport)
ServerTransportOptions 财务报告和审定财务报表 ServerBridgeOptions 接受 enforceSessionOwner,默认为 true。 。 。 .
引用受约束会话的后面的 POST 格式必须包含 payload.iss 匹配其正常的拥有者.
装入正常状态的仓库 长而短 did:peer:4 表格显示同一所有者.
缺少或不同的发行者生成 HTTP 403 与 { error: 'Session owner mismatch' } 在编辑信息之前.
这适用于请求、事件、流、信道、发送和中止消息.
大桥比较了正常化的DOS. RPC服务器仍然对消息进行认证.
不受约束的会话保持他们现有的行为. 设置 enforceSessionOwner: false 禁用检查而不清除所有权.
已写入框架字节
两者 ServerTransportOptions 财务报告和审定财务报表 ServerBridgeOptions 接受同步 onFrameWritten(info: FrameWrittenInfo) 观察员.
| 外地 | 含义 |
|---|---|
kind | 'response', (中文(简体) ), 'sse' 或者说 'heartbeat' |
bytes | 串行体或帧的 UTF-8 字节长度 |
rid | 请求响应和SSE框架的ID, 心跳没有 |
sessionID | SSE 框架和心跳的会话 ID |
const transport = new ServerTransport<typeof protocol>({
onFrameWritten(info) {
console.log(info.kind, info.bytes, info.rid, info.sessionID)
},
})
反应计数覆盖JSON消息机体. SSE 计数包括 data: 前缀和后缀 \n\n。 。 。 .
初次和定期心跳评论 :\n\n 并计为3个字节,带有会话ID,没有请求ID.
每个被排列的SSE帧都会产生回调,包括被帧触发的缓冲溢出. 排队前拒绝的框架不会产生回调 .
计数不包括HTTP头和网络间接费用. 解答或排入帧不能确认交付给客户.
同步回调的例外被记录下来并吞入,所以写作继续.