feat(public-status): add redis-backed public status runtime #1078
There are no files selected for viewing
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change | ||||
|---|---|---|---|---|---|---|
|
|
@@ -87,6 +87,8 @@ | |||||
| "saveFailed": "儲存失敗", | ||||||
| "saveSettings": "儲存設定", | ||||||
| "saveSuccess": "儲存成功", | ||||||
| "publicStatusProjectionWarning": "系統設定已儲存，但 public status Redis 投影尚未刷新。", | ||||||
| "publicStatusBackgroundRefreshPending": "系統設定已儲存，但公開狀態頁可能會在背景刷新成功前暫時維持舊資料。", | ||||||
|
Comment on lines
+90
to
+91
There was a problem hiding this comment. 🧩 Analysis chain🏁 Script executed: cat -n messages/zh-TW/settings/config.json | head -100Repository: ding113/claude-code-hub Length of output: 6192 删除
建议删除的重复定义- "publicStatusProjectionWarning": "系統設定已儲存，但 public status Redis 投影尚未刷新。",
- "publicStatusBackgroundRefreshPending": "系統設定已儲存，但公開狀態頁可能會在背景刷新成功前暫時維持舊資料。",📝 Committable suggestion
Suggested change
🤖 Prompt for AI Agents |
||||||
| "siteTitle": "站台標題", | ||||||
| "siteTitleDesc": "用於設定瀏覽器分頁標題以及系統預設顯示名稱。", | ||||||
| "siteTitlePlaceholder": "例：Claude Code Hub", | ||||||
|
|
||||||
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -27,7 +27,7 @@ export async function generateMetadata({ | |
| try { | ||
| const metadata = await resolveSiteMetadataSource({ isPublicStatusRequest }); | ||
| const title = metadata?.siteTitle?.trim() || DEFAULT_SITE_TITLE; | ||
| const description = metadata?.siteDescription?.trim() || title; | ||
|
|
||
| // Generate alternates for all locales | ||
| const alternates: Record<string, string> = {}; | ||
|
|
@@ -77,7 +77,7 @@ export default async function RootLayout({ | |
| } | ||
|
|
||
| // Load translation messages | ||
| const messages = await getMessages({ locale }); | ||
| const timeZone = await resolveLayoutTimeZone({ isPublicStatusRequest }); | ||
| // Create a stable `now` timestamp to avoid SSR/CSR hydration mismatch for relative time | ||
| const now = new Date(); | ||
|
|
||
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,22 +1,25 @@ | ||
| import { getTranslations } from "next-intl/server"; | ||
| import { | ||
| readCurrentPublicStatusConfigSnapshot, | ||
| readPublicStatusSiteMetadata, | ||
| } from "@/lib/public-status/config-snapshot"; | ||
| import { readPublicStatusPayload } from "@/lib/public-status/read-store"; | ||
| import { schedulePublicStatusRebuild } from "@/lib/public-status/rebuild-hints"; | ||
| import { PublicStatusView } from "./_components/public-status-view"; | ||
|
|
||
| export const dynamic = "force-dynamic"; | ||
|
|
||
| const FALLBACK_SITE_TITLE = "Claude Code Hub"; | ||
|
|
||
| export default async function PublicStatusPage({ | ||
| params, | ||
| }: { | ||
| params: Promise<{ locale: string }>; | ||
| }) { | ||
| const { locale } = await params; | ||
| const t = await getTranslations({ locale, namespace: "settings.statusPage.public" }); | ||
| const configSnapshot = await readCurrentPublicStatusConfigSnapshot(); | ||
| const siteMetadata = await readPublicStatusSiteMetadata(); | ||
| const intervalMinutes = configSnapshot?.defaultIntervalMinutes ?? 5; | ||
| const rangeHours = configSnapshot?.defaultRangeHours ?? 24; | ||
| const followServerDefaults = !configSnapshot; | ||
|
|
@@ -27,13 +30,11 @@ export default async function PublicStatusPage({ | |
| hasConfiguredGroups: configSnapshot ? configSnapshot.groups.length > 0 : undefined, | ||
| nowIso: new Date().toISOString(), | ||
| triggerRebuildHint: async (reason) => { | ||
| await schedulePublicStatusRebuild({ | ||
| intervalMinutes, | ||
| rangeHours, | ||
| reason, | ||
| }); | ||
|
Comment on lines
32
to
+37
There was a problem hiding this comment.
Useful? React with 👍 / 👎. |
||
| }, | ||
| }); | ||
|
|
||
|
|
@@ -44,51 +45,53 @@ export default async function PublicStatusPage({ | |
| rangeHours={rangeHours} | ||
| followServerDefaults={followServerDefaults} | ||
| locale={locale} | ||
| siteTitle={ | ||
| siteMetadata?.siteTitle?.trim() || configSnapshot?.siteTitle?.trim() || FALLBACK_SITE_TITLE | ||
| } | ||
| timeZone={configSnapshot?.timeZone ?? "UTC"} | ||
| labels={{ | ||
| systemStatus: t("systemStatus"), | ||
| heroPrimary: t("heroPrimary"), | ||
| heroSecondary: t("heroSecondary"), | ||
| generatedAt: t("generatedAt"), | ||
| history: t("history"), | ||
| availability: t("availability"), | ||
| ttfb: t("ttfb"), | ||
| freshnessWindow: t("freshnessWindow"), | ||
| fresh: t("fresh"), | ||
| stale: t("stale"), | ||
| staleDetail: t("staleDetail"), | ||
| rebuilding: t("rebuilding"), | ||
| noData: t("noData"), | ||
| emptyDescription: t("emptyDescription"), | ||
| requestTypes: { | ||
| openaiCompatible: t("requestTypes.openaiCompatible"), | ||
| codex: t("requestTypes.codex"), | ||
| anthropic: t("requestTypes.anthropic"), | ||
| gemini: t("requestTypes.gemini"), | ||
| }, | ||
| statusBadge: { | ||
| operational: t("statusBadge.operational"), | ||
| degraded: t("statusBadge.degraded"), | ||
| failed: t("statusBadge.failed"), | ||
| noData: t("statusBadge.noData"), | ||
| }, | ||
| tooltip: { | ||
| availability: t("tooltip.availability"), | ||
| ttfb: t("tooltip.ttfb"), | ||
| tps: t("tooltip.tps"), | ||
| historyAriaLabel: t("tooltip.historyAriaLabel"), | ||
| }, | ||
| searchPlaceholder: t("searchPlaceholder"), | ||
| customSort: t("customSort"), | ||
| resetSort: t("resetSort"), | ||
| emptyByFilter: t("emptyByFilter"), | ||
| modelsLabel: t("modelsLabel"), | ||
| issuesLabel: t("issuesLabel"), | ||
| clearSearch: t("clearSearch"), | ||
| dragHandle: t("dragHandle"), | ||
| toggleGroup: t("toggleGroup"), | ||
| openGroupPage: t("openGroupPage"), | ||
| }} | ||
| /> | ||
| ); | ||
|
|
||
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -26,7 +26,6 @@ export async function GET(request: Request): Promise<Response> { | |
| const defaultRange = configSnapshot?.defaultRangeHours ?? 24; | ||
| const intervalMinutes = clampInterval(url.searchParams.get("interval"), defaultInterval); | ||
| const rangeHours = clampRange(url.searchParams.get("rangeHours"), defaultRange); | ||
|
|
||
| const payload = await readPublicStatusPayload({ | ||
| intervalMinutes, | ||
|
|
@@ -35,9 +34,6 @@ export async function GET(request: Request): Promise<Response> { | |
| hasConfiguredGroups: configSnapshot ? configSnapshot.groups.length > 0 : undefined, | ||
| nowIso: new Date().toISOString(), | ||
| triggerRebuildHint: async (reason) => { | ||
| await schedulePublicStatusRebuild({ | ||
| intervalMinutes, | ||
| rangeHours, | ||
|
Comment on lines
37
to
39
There was a problem hiding this comment.
The Useful? React with 👍 / 👎. |
||
|
|
@@ -47,6 +43,5 @@ export async function GET(request: Request): Promise<Response> { | |
| }); | ||
|
|
||
| const status = payload.rebuildState === "rebuilding" && !payload.generatedAt ? 503 : 200; | ||
| return NextResponse.json(payload, { status }); | ||
| } | ||
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -46,6 +46,8 @@ const DEFAULT_SETTINGS: Pick< | |
| | "enableClaudeMetadataUserIdInjection" | ||
| | "enableResponseFixer" | ||
| | "responseFixerConfig" | ||
| | "publicStatusWindowHours" | ||
| | "publicStatusAggregationIntervalMinutes" | ||
| > = { | ||
| enableHttp2: false, | ||
| enableHighConcurrencyMode: false, | ||
|
|
@@ -65,6 +67,8 @@ const DEFAULT_SETTINGS: Pick< | |
| maxJsonDepth: 200, | ||
| maxFixSize: 1024 * 1024, | ||
| }, | ||
| publicStatusWindowHours: 24, | ||
| publicStatusAggregationIntervalMinutes: 5, | ||
| }; | ||
|
|
||
| /** | ||
|
|
@@ -135,14 +139,15 @@ export async function getCachedSystemSettings(): Promise<SystemSettings> { | |
| enableClaudeMetadataUserIdInjection: DEFAULT_SETTINGS.enableClaudeMetadataUserIdInjection, | ||
| enableResponseFixer: DEFAULT_SETTINGS.enableResponseFixer, | ||
| responseFixerConfig: DEFAULT_SETTINGS.responseFixerConfig, | ||
| publicStatusWindowHours: DEFAULT_SETTINGS.publicStatusWindowHours, | ||
| publicStatusAggregationIntervalMinutes: | ||
| DEFAULT_SETTINGS.publicStatusAggregationIntervalMinutes, | ||
| quotaDbRefreshIntervalSeconds: 10, | ||
| quotaLeasePercent5h: 0.05, | ||
| quotaLeasePercentDaily: 0.05, | ||
| quotaLeasePercentWeekly: 0.05, | ||
| quotaLeasePercentMonthly: 0.05, | ||
| quotaLeaseCapUsd: null, | ||
| ipExtractionConfig: null, | ||
| ipGeoLookupEnabled: true, | ||
| createdAt: new Date(), | ||
|
|
||
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -57,6 +57,18 @@ const CONFIG_CACHE_TTL_MS = 60 * 1000; | |
| let cachedConfiguredGroups: EnabledPublicStatusGroup[] | null = null; | ||
| let cachedConfiguredGroupsAt = 0; | ||
|
|
||
| export class DuplicatePublicStatusGroupSlugError extends Error { | ||
| constructor( | ||
| public readonly publicGroupSlug: string, | ||
| groupNames: string[] | ||
| ) { | ||
| super( | ||
| `Duplicate normalized publicGroupSlug "${publicGroupSlug}" for groups: ${groupNames.join(", ")}` | ||
| ); | ||
| this.name = "DuplicatePublicStatusGroupSlugError"; | ||
| } | ||
| } | ||
|
|
||
| function sanitizeString(value: unknown): string | undefined { | ||
| if (typeof value !== "string") { | ||
| return undefined; | ||
|
|
@@ -136,6 +148,11 @@ export function slugifyPublicGroup(input: string): string { | |
| .slice(0, 64); | ||
| } | ||
|
|
||
| function normalizePublicGroupSlug(groupName: string, publicGroupSlug?: string): string { | ||
| const normalized = slugifyPublicGroup(publicGroupSlug?.trim() || groupName); | ||
| return normalized || slugifyPublicGroup(groupName); | ||
| } | ||
|
Comment on lines
+151
to
+154
There was a problem hiding this comment. 避免返回空的
建议修正方向 function normalizePublicGroupSlug(groupName: string, publicGroupSlug?: string): string {
const normalized = slugifyPublicGroup(publicGroupSlug?.trim() || groupName);
- return normalized || slugifyPublicGroup(groupName);
+ const fallback = normalized || slugifyPublicGroup(groupName);
+ if (!fallback) {
+ throw new Error(`Public status group "${groupName}" must define a URL-safe publicGroupSlug`);
+ }
+ return fallback;
}🤖 Prompt for AI Agents |
||
|
|
||
| export function parsePublicStatusDescription( | ||
| description: string | null | undefined | ||
| ): ParsedPublicStatusDescription { | ||
|
|
@@ -252,15 +269,30 @@ export function serializePublicStatusDescription( | |
| export function collectEnabledPublicStatusGroups( | ||
| groups: PublicStatusConfiguredGroupInput[] | ||
| ): EnabledPublicStatusGroup[] { | ||
| const seenGroupNamesBySlug = new Map<string, string>(); | ||
|
|
||
| return groups | ||
| .map((group) => { | ||
| const publicModels = sanitizePublicModels(group.publicStatus?.publicModels); | ||
| const publicGroupSlug = normalizePublicGroupSlug( | ||
| group.groupName, | ||
| group.publicStatus?.publicGroupSlug | ||
| ); | ||
|
|
||
| const existingGroupName = seenGroupNamesBySlug.get(publicGroupSlug); | ||
| if (existingGroupName) { | ||
| throw new DuplicatePublicStatusGroupSlugError(publicGroupSlug, [ | ||
|
Comment on lines
+282
to
+284
There was a problem hiding this comment.
Duplicate slug detection is executed before empty/invalid groups are removed ( Useful? React with 👍 / 👎. |
||
| existingGroupName, | ||
| group.groupName, | ||
| ]); | ||
| } | ||
|
|
||
| seenGroupNamesBySlug.set(publicGroupSlug, group.groupName); | ||
|
|
||
| return { | ||
| groupName: group.groupName, | ||
| displayName: group.publicStatus?.displayName?.trim() || group.groupName, | ||
| publicGroupSlug, | ||
| explanatoryCopy: group.publicStatus?.explanatoryCopy?.trim() || null, | ||
| sortOrder: group.publicStatus?.sortOrder ?? 0, | ||
| publicModels, | ||
|
|
||
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,4 +1,4 @@ | ||
| const FALLBACK_SITE_TITLE = "Claude Code Hub"; | ||
|
|
||
| export async function resolveSiteMetadataSource(input: { | ||
| isPublicStatusRequest: boolean; | ||
|
|
@@ -7,19 +7,17 @@ export async function resolveSiteMetadataSource(input: { | |
| siteDescription: string; | ||
| } | null> { | ||
| if (input.isPublicStatusRequest) { | ||
| const { readPublicStatusSiteMetadata } = await import("./config-snapshot"); | ||
| return await readPublicStatusSiteMetadata(); | ||
| } | ||
|
|
||
| const { getSystemSettings } = await import("@/repository/system-config"); | ||
| const settings = await getSystemSettings(); | ||
| const title = settings.siteTitle?.trim() || FALLBACK_SITE_TITLE; | ||
|
|
||
| return { | ||
| siteTitle: title, | ||
| siteDescription: title, | ||
| }; | ||
| } | ||
|
|
||
|
|
||
Oops, something went wrong.
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
🧩 Analysis chain
🏁 Script executed:
Repository: ding113/claude-code-hub
Length of output: 5258
🏁 Script executed:
head -50 messages/ja/settings/config.json | cat -nRepository: ding113/claude-code-hub
Length of output: 2862
🏁 Script executed:
tail -20 messages/ja/settings/config.json | cat -nRepository: ding113/claude-code-hub
Length of output: 1161
删除重复的 JSON 键。
这两个键已在第 39-40 行定义，第 90-91 行的重复定义会导致后面的值覆盖前面的值，造成 JSON 验证和 linting 错误。
建议的修改
📝 Committable suggestion
🤖 Prompt for AI Agents