Documentation
¶
Overview ¶
gen/handler/p2p/p2p_service.go — 设备直传管理面（P2a，2026-10-14 对称节点 spec §7/§8）。hz 首生成桩后本文件转手写（模型引 contracts/gen/p2p， hzmodel 临时目录不落地）。全部端点挂 /admin 组（AdminMiddleware），操作 留审计；数据面=supervisor spawn p2pc 子进程，本层只做编排，不代理文件流量。
p2_ppublic_service.go — 实例间推送邀请收件端点（P3，spec §14）。 hz 首生成桩后转手写（模型引 contracts/gen/p2p）。公开无鉴权（口令即 bearer——邀请体只有口令，资产即权限），归 download 限流桶；入箱幂等去重。
Index ¶
- func AdminP2pCancel(ctx context.Context, c *app.RequestContext)
- func AdminP2pDirectory(ctx context.Context, c *app.RequestContext)
- func AdminP2pInviteAccept(ctx context.Context, c *app.RequestContext)
- func AdminP2pInvitePush(ctx context.Context, c *app.RequestContext)
- func AdminP2pInvites(ctx context.Context, c *app.RequestContext)
- func AdminP2pPairApprove(ctx context.Context, c *app.RequestContext)
- func AdminP2pPublish(ctx context.Context, c *app.RequestContext)
- func AdminP2pRecv(ctx context.Context, c *app.RequestContext)
- func AdminP2pSend(ctx context.Context, c *app.RequestContext)
- func AdminP2pStatus(ctx context.Context, c *app.RequestContext)
- func AdminP2pTaskLog(ctx context.Context, c *app.RequestContext)
- func AdminP2pTasks(ctx context.Context, c *app.RequestContext)
- func AdminP2pUploadSend(ctx context.Context, c *app.RequestContext)
- func PostP2PInvite(ctx context.Context, c *app.RequestContext)
- func SetAuditWriter(fn func(ctx context.Context, action, target string, success bool))
- func SetInviteNotifier(fn func(fromName, code, note string))
- func SetService(s *p2px.Service)
- func SetShareService(s *shareService.Service)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AdminP2pCancel ¶
func AdminP2pCancel(ctx context.Context, c *app.RequestContext)
AdminP2pCancel 取消任务。 @router /admin/p2p/cancel [POST]
func AdminP2pDirectory ¶ added in v0.21.0
func AdminP2pDirectory(ctx context.Context, c *app.RequestContext)
AdminP2pDirectory 在线名录透传（2026-10-14 邀请信箱配套:发送卡对端选择器 消费;p2pd 名录零敏感,本层不改写）。 @router /admin/p2p/directory [GET]
func AdminP2pInviteAccept ¶ added in v0.20.0
func AdminP2pInviteAccept(ctx context.Context, c *app.RequestContext)
AdminP2pInviteAccept 认领邀请并发起接收（P3）。 @router /admin/p2p/invites/accept [POST]
func AdminP2pInvitePush ¶ added in v0.20.0
func AdminP2pInvitePush(ctx context.Context, c *app.RequestContext)
AdminP2pInvitePush 把口令推送到目标实例（P3 免口令交接）。 @router /admin/p2p/invite-push [POST]
func AdminP2pInvites ¶ added in v0.20.0
func AdminP2pInvites(ctx context.Context, c *app.RequestContext)
AdminP2pInvites 待收邀请列表（P3）。 @router /admin/p2p/invites [GET]
func AdminP2pPairApprove ¶ added in v0.25.0
func AdminP2pPairApprove(ctx context.Context, c *app.RequestContext)
AdminP2pPairApprove 配对接受门裁决（2026-10-18）：亮码任务的待裁决敲门 请求（task.pair_pending）接受/拒绝。拒绝即烧码并自动重铸新配对码——返回 快照带新码，前端刷新展示。无待裁决请求 400（防杂散 stdin 行错位后续请求）。 @router /admin/p2p/tasks/:task_id/approve [POST]
func AdminP2pPublish ¶
func AdminP2pPublish(ctx context.Context, c *app.RequestContext)
AdminP2pPublish 收件发布为分享（每文件一个分享；复用本地导入铸链）。 @router /admin/p2p/publish [POST]
func AdminP2pRecv ¶
func AdminP2pRecv(ctx context.Context, c *app.RequestContext)
AdminP2pRecv 发起接收。 @router /admin/p2p/recv [POST]
func AdminP2pSend ¶
func AdminP2pSend(ctx context.Context, c *app.RequestContext)
AdminP2pSend 发起发送。 @router /admin/p2p/send [POST]
func AdminP2pStatus ¶
func AdminP2pStatus(ctx context.Context, c *app.RequestContext)
AdminP2pStatus 状态面。 @router /admin/p2p/status [GET]
func AdminP2pTaskLog ¶ added in v0.24.0
func AdminP2pTaskLog(ctx context.Context, c *app.RequestContext)
AdminP2pTaskLog 任务日志（p2pc 行级环,时间正序;诊断面——失败免登服务器）。 @router /admin/p2p/tasks/:task_id/log [GET]
func AdminP2pTasks ¶
func AdminP2pTasks(ctx context.Context, c *app.RequestContext)
AdminP2pTasks 任务列表。 @router /admin/p2p/tasks [GET]
func AdminP2pUploadSend ¶ added in v0.24.0
func AdminP2pUploadSend(ctx context.Context, c *app.RequestContext)
AdminP2pUploadSend 浏览器文件直发（2026-10-15:p2pcweb 体验融入管理台）。 multipart files[] 流式落上传临时区 → p2px.SendUploaded 编排（上传目录 自带发送授权,不查 send_roots——见 upload.go 授权模型）→ 任务终态自清理。 invite 元数据走 query（与 /admin/p2p/send 同义）。 总量闸 = p2p.direct.max_task_bytes 单任务配额,落盘边写边计,超限即断。 @router /admin/p2p/send/upload [POST]
func PostP2PInvite ¶ added in v0.20.0
func PostP2PInvite(ctx context.Context, c *app.RequestContext)
PostP2PInvite 接收来自其他实例的直传邀请。 @router /api/v1/p2p/invite [POST]
func SetAuditWriter ¶
SetAuditWriter 注入审计写者（wiring 装配）。
func SetInviteNotifier ¶ added in v0.21.0
func SetInviteNotifier(fn func(fromName, code, note string))
SetInviteNotifier 注入邀请到达通知器（bootstrap/wiring 调用）。
func SetShareService ¶
func SetShareService(s *shareService.Service)
SetShareService 注入分享服务（发布为分享复用本地导入铸链）。
Types ¶
This section is empty.
Source Files