chore: 合入最新 master 基线

scripts/src/hwlab-node-lanes.ts

@@ -474,10 +474,18 @@ export interface HwlabRuntimeKafkaEventBridgeSpec {
   readonly features: {
     readonly directPublish: boolean;
     readonly liveKafkaSse: boolean;
+    readonly kafkaRefreshReplay: boolean;
     readonly transactionalProjector: boolean;
     readonly projectionOutboxRelay: boolean;
     readonly projectionRealtime: boolean;
   };
+  readonly refreshReplay?: {
+    readonly groupIdPrefix: string;
+    readonly timeoutMs: number;
+    readonly scanLimit: number;
+    readonly matchedEventLimit: number;
+    readonly liveBufferLimit: number;
+  };
   readonly configRef: string;
   readonly bootstrapServers: string;
   readonly stdioTopic: string;
@@ -1096,6 +1104,17 @@ function codeAgentKafkaShadowProducerConfig(value: unknown, path: string): Hwlab
 function codeAgentKafkaEventBridgeConfig(value: unknown, path: string): HwlabRuntimeKafkaEventBridgeSpec {
   const raw = asRecord(value, path);
   const features = asRecord(raw.features, `${path}.features`);
+  const liveKafkaSse = booleanField(features, "liveKafkaSse", `${path}.features`);
+  const kafkaRefreshReplay = booleanField(features, "kafkaRefreshReplay", `${path}.features`);
+  const refreshReplay = raw.refreshReplay === undefined
+    ? undefined
+    : codeAgentKafkaRefreshReplayConfig(raw.refreshReplay, `${path}.refreshReplay`);
+  if (kafkaRefreshReplay && refreshReplay === undefined) {
+    throw new Error(`${path}.refreshReplay is required when ${path}.features.kafkaRefreshReplay is true`);
+  }
+  if (kafkaRefreshReplay && !liveKafkaSse) {
+    throw new Error(`${path}.features.liveKafkaSse must be true when ${path}.features.kafkaRefreshReplay is true`);
+  }
   const directPublishConsumerGroupId = stringField(raw, "directPublishConsumerGroupId", path);
   const transactionalProjectorConsumerGroupId = stringField(raw, "transactionalProjectorConsumerGroupId", path);
   const hwlabEventConsumerGroupId = stringField(raw, "hwlabEventConsumerGroupId", path);
@@ -1106,11 +1125,13 @@ function codeAgentKafkaEventBridgeConfig(value: unknown, path: string): HwlabRun
     enabled: booleanField(raw, "enabled", path),
     features: {
       directPublish: booleanField(features, "directPublish", `${path}.features`),
-      liveKafkaSse: booleanField(features, "liveKafkaSse", `${path}.features`),
+      liveKafkaSse,
+      kafkaRefreshReplay,
       transactionalProjector: booleanField(features, "transactionalProjector", `${path}.features`),
       projectionOutboxRelay: booleanField(features, "projectionOutboxRelay", `${path}.features`),
       projectionRealtime: booleanField(features, "projectionRealtime", `${path}.features`),
     },
+    ...(refreshReplay === undefined ? {} : { refreshReplay }),
     configRef: stringField(raw, "configRef", path),
     bootstrapServers: stringField(raw, "bootstrapServers", path),
     stdioTopic: stringField(raw, "stdioTopic", path),
@@ -1123,6 +1144,17 @@ function codeAgentKafkaEventBridgeConfig(value: unknown, path: string): HwlabRun
   };
 }
 
+function codeAgentKafkaRefreshReplayConfig(value: unknown, path: string): NonNullable<HwlabRuntimeKafkaEventBridgeSpec["refreshReplay"]> {
+  const raw = asRecord(value, path);
+  return {
+    groupIdPrefix: stringField(raw, "groupIdPrefix", path),
+    timeoutMs: numberField(raw, "timeoutMs", path),
+    scanLimit: numberField(raw, "scanLimit", path),
+    matchedEventLimit: numberField(raw, "matchedEventLimit", path),
+    liveBufferLimit: numberField(raw, "liveBufferLimit", path),
+  };
+}
+
 function commandNameField(value: string, path: string): string {
   if (!/^[A-Za-z0-9._+-]+$/u.test(value)) throw new Error(`${path} must be a simple command name`);
   return value;