xuyueandClaude Opus 5
ed56a209ea
Deploy / deploy (push) Has been cancelled
原来只有 `apps/web` 在 Prettier 下（配置在 `apps/web/.prettierrc.toml`、脚本在 web 的 package.json），后端和契约从来没格式化过 —— 手写在 100 列上下，`db/schema.ts` 还是 drizzle-kit pull 留下的 tab 缩进。两套口径分叉久了，跨端改一处就得记着「这边 什么风格」。 - 配置搬到根目录 `.prettierrc.toml`，内容不变（`semi=false`，其余全默认， printWidth 80 —— 和前端已有的格式一致，不另立一套宽度）； - 脚本统一成根目录 `bun run fmt`，覆盖 `apps/*/src`、`apps/web/tests` 和两个构建 配置；web 自己那份 `fmt` 和重复的 prettier 依赖删掉； - `.prettierignore` 挡掉两类不该碰的：drizzle-kit 生成的 `src/db/meta/` 结构快照 （它是 db:generate 的比对输入，只该由 drizzle-kit 写）、unplugin 每次 dev 都会 重写的 `auto-imports.d.ts` / `components.d.ts`； - 全量跑了一遍。纯格式，无行为改动：api typecheck / check:routes / check:ast、 前端 type-check 全过，起 api 打了接口确认正常。前端这 39 个文件的小改动是 prettier 版本漂移（类型断言的换行口径变了），不是新配置带来的。 Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>
117 lines
3.0 KiB
TypeScript
117 lines
3.0 KiB
TypeScript
import type { FlowchartUpdate } from "@oj2/contract"
|
||
|
||
import { redis } from "./redis"
|
||
|
||
export const userEventChannel = "user:events"
|
||
|
||
/**
|
||
* 站点配置变更广播。旧后端的 `utils/websocket.push_config_update`：
|
||
* 超管改了配置，所有开着页面的人立刻生效，不必刷新。
|
||
* 这是全站广播，不分用户，所以是一个固定 topic 而不是 per-user。
|
||
*/
|
||
export const configUpdateChannel = "config:updates"
|
||
export const configTopic = "events:config"
|
||
|
||
export async function publishConfigUpdate(key: string, value: unknown) {
|
||
await redis.publish(
|
||
configUpdateChannel,
|
||
JSON.stringify({ type: "config_update", key, value }),
|
||
)
|
||
}
|
||
|
||
/**
|
||
* 会话吊销广播。让还挂着的 WebSocket 立刻知道自己该下线了。
|
||
*
|
||
* 两种作用域，**不能混**：
|
||
* - `{ token }` 用户登出。只该断这一张会话 —— 同一个人在别的设备上是另一张会话，
|
||
* 不该被牵连。
|
||
* - `{ userId }` 账号被禁用。所有设备都得断。禁用只改数据库的 isDisabled 列、
|
||
* 不动 Redis 里的会话，WebSocket 那边的会话巡检永远发现不了，只能靠这条主动通知。
|
||
*/
|
||
export const sessionRevokedChannel = "session:revoked"
|
||
|
||
export type SessionRevokedReason = "session-ended" | "account-disabled"
|
||
|
||
export interface SessionRevoked {
|
||
token?: string
|
||
userId?: number
|
||
reason: SessionRevokedReason
|
||
}
|
||
|
||
export async function publishSessionRevoked(
|
||
target: { token: string } | { userId: number },
|
||
reason: SessionRevokedReason,
|
||
) {
|
||
await redis.publish(
|
||
sessionRevokedChannel,
|
||
JSON.stringify({ ...target, reason }),
|
||
)
|
||
}
|
||
|
||
export function parseSessionRevoked(raw: string): SessionRevoked | null {
|
||
try {
|
||
const value = JSON.parse(raw) as SessionRevoked
|
||
if (typeof value.token !== "string" && !Number.isInteger(value.userId))
|
||
return null
|
||
if (value.reason !== "session-ended" && value.reason !== "account-disabled")
|
||
return null
|
||
return value
|
||
} catch {
|
||
return null
|
||
}
|
||
}
|
||
|
||
interface UserEvent {
|
||
userId: number
|
||
data: FlowchartUpdate | Record<string, unknown>
|
||
}
|
||
|
||
interface AchievementNotification {
|
||
id: number
|
||
name: string
|
||
description: string
|
||
icon: string
|
||
rarity: string
|
||
kind: "achievement" | "badge"
|
||
}
|
||
|
||
export function userEventTopic(userId: number) {
|
||
return `events:user:${userId}`
|
||
}
|
||
|
||
export async function publishFlowchartUpdate(
|
||
userId: number,
|
||
data: FlowchartUpdate,
|
||
) {
|
||
await redis.publish(userEventChannel, JSON.stringify({ userId, data }))
|
||
}
|
||
|
||
export async function publishAchievementNotification(
|
||
userId: number,
|
||
achievements: AchievementNotification[],
|
||
) {
|
||
if (!achievements.length) return
|
||
await redis.publish(
|
||
userEventChannel,
|
||
JSON.stringify({
|
||
userId,
|
||
data: { type: "achievement_unlocked", achievements },
|
||
}),
|
||
)
|
||
}
|
||
|
||
export function parseUserEvent(raw: string): UserEvent | null {
|
||
try {
|
||
const value = JSON.parse(raw) as UserEvent
|
||
if (
|
||
!Number.isInteger(value.userId) ||
|
||
!value.data ||
|
||
typeof value.data !== "object"
|
||
)
|
||
return null
|
||
return value
|
||
} catch {
|
||
return null
|
||
}
|
||
}
|