admin
f21fa5b5e8
Commilitia Drop：自托管的跨设备剪贴板同步与点对点文件传输。 - 后端 Go（chi / SQLite WAL / SSE Hub / WebRTC signaling + 状态机 / Relay ring buffer），编译进单个 distroless 镜像（前端 go:embed）。 - 前端 React + TanStack Router + Zustand，自实现 SSE + WebRTC P2P，NAT 受阻时回退服务端中继；聚珍（Juzhen）CJK 综合排版。 - 桌面端 Wails v2（macOS / Windows），瘦客户端复用 web。 - 鉴权 OIDC PKCE（自建 Casdoor 等），refresh_token 信封加密存系统密钥库；iOS Shortcut 用 HS256 scoped token。 架构文档与变更记录见 docs 分支（PROJECT_BRIEF / FRONTEND_DESIGN / CHANGELOG）。 本次为公开发布初始提交：完整开发历史（含部署细节）留存于私有归档，公开仓库自此干净起步。
37 lines
838 B
Go
37 lines
838 B
Go
package transfer
|
|
|
|
import (
|
|
"context"
|
|
"log/slog"
|
|
"time"
|
|
)
|
|
|
|
// PendingTTL is the wall-clock window after which a PENDING session
|
|
// is auto-cancelled by the sweeper (plan §4.5 待决策清单 #5).
|
|
const PendingTTL = 120 * time.Second
|
|
|
|
// SweepInterval is how often the sweeper goroutine wakes up.
|
|
const SweepInterval = 30 * time.Second
|
|
|
|
// RunSweeper blocks until ctx is cancelled, periodically expiring
|
|
// stale PENDING sessions.
|
|
func RunSweeper(ctx context.Context, svc *Service) {
|
|
t := time.NewTicker(SweepInterval)
|
|
defer t.Stop()
|
|
for {
|
|
select {
|
|
case <-ctx.Done():
|
|
return
|
|
case <-t.C:
|
|
n, err := svc.ExpirePending(ctx, PendingTTL)
|
|
if err != nil {
|
|
slog.Error("sweeper: expire pending failed", "err", err)
|
|
continue
|
|
}
|
|
if n > 0 {
|
|
slog.Info("sweeper: expired pending sessions", "count", n)
|
|
}
|
|
}
|
|
}
|
|
}
|