fix(sessions): 启动期用户消息可靠投递

.github/workflows/complexity.yml

@@ -4,9 +4,11 @@ on:
   pull_request:
     paths:
       - '**/*.go'
+      - 'internal/db/*.xml'
       - '.golangci-complexity.yml'
       - 'go.mod'
       - 'go.sum'
+      - 'scripts/generate-go.sh'
       - 'scripts/go-complexity.sh'
       - 'web/**'
       - '.github/workflows/complexity.yml'
@@ -15,9 +17,11 @@ on:
       - main
     paths:
       - '**/*.go'
+      - 'internal/db/*.xml'
       - '.golangci-complexity.yml'
       - 'go.mod'
       - 'go.sum'
+      - 'scripts/generate-go.sh'
       - 'scripts/go-complexity.sh'
       - 'web/**'
       - '.github/workflows/complexity.yml'
@@ -44,6 +48,9 @@ jobs:
           go-version-file: go.mod
           cache: true
 
+      - name: Generate Go sources
+        run: ./scripts/generate-go.sh
+
       - name: Check Go complexity
         uses: golangci/golangci-lint-action@v9
         with:

.github/workflows/dead-code.yml

@@ -4,19 +4,23 @@ on:
   pull_request:
     paths:
       - '**/*.go'
+      - 'internal/db/*.xml'
       - '.golangci-dead-code.yml'
       - 'go.mod'
       - 'go.sum'
+      - 'scripts/generate-go.sh'
       - 'scripts/go-dead-code.sh'
       - '.github/workflows/dead-code.yml'
   push:
     branches:
       - main
     paths:
       - '**/*.go'
+      - 'internal/db/*.xml'
       - '.golangci-dead-code.yml'
       - 'go.mod'
       - 'go.sum'
+      - 'scripts/generate-go.sh'
       - 'scripts/go-dead-code.sh'
       - '.github/workflows/dead-code.yml'
 
@@ -42,6 +46,9 @@ jobs:
           go-version-file: go.mod
           cache: true
 
+      - name: Generate Go sources
+        run: ./scripts/generate-go.sh
+
       - name: Detect unreachable Go declarations
         uses: golangci/golangci-lint-action@v9
         with:

.github/workflows/lint.yml

@@ -28,6 +28,9 @@ jobs:
           go-version-file: go.mod
           cache: true
 
+      - name: Generate Go sources
+        run: ./scripts/generate-go.sh
+
       - name: Run golangci-lint
         uses: golangci/golangci-lint-action@v9
         with:

.gitignore

@@ -69,3 +69,4 @@ logs/
 CLAUDE.local.md
 AGENTS.override.md
 .worktrees/
+*.gen.go

.pre-commit-config.yaml

@@ -26,25 +26,25 @@ repos:
         types: [go]
 
       - id: golangci-lint
-        name: Lint packages containing staged Go files
+        name: Lint packages containing staged Go inputs
         entry: scripts/pre-commit-go-lint.sh
         language: script
-        types: [go]
+        files: ^(?:.*\.go|internal/db/.*\.xml|go\.(?:mod|sum)|scripts/generate-go\.sh)$
         require_serial: true
 
       - id: go-dead-code
         name: Detect unreachable Go declarations
         entry: scripts/go-dead-code.sh
         language: script
-        files: ^(?:.*\.go|\.golangci-dead-code\.yml|go\.(?:mod|sum)|scripts/go-dead-code\.sh)$
+        files: ^(?:.*\.go|internal/db/.*\.xml|\.golangci-dead-code\.yml|go\.(?:mod|sum)|scripts/(?:generate-go|go-dead-code)\.sh)$
         pass_filenames: false
         require_serial: true
 
       - id: go-complexity
         name: Enforce Go cyclomatic complexity
         entry: scripts/go-complexity.sh
         language: script
-        files: ^(?:.*\.go|\.golangci-complexity\.yml|go\.(?:mod|sum)|scripts/go-complexity\.sh)$
+        files: ^(?:.*\.go|internal/db/.*\.xml|\.golangci-complexity\.yml|go\.(?:mod|sum)|scripts/(?:generate-go|go-complexity)\.sh)$
         pass_filenames: false
         require_serial: true
 

Dockerfile

@@ -21,7 +21,8 @@ WORKDIR /src
 COPY go.mod go.sum ./
 RUN go mod download
 COPY . .
-RUN CGO_ENABLED=0 go build -ldflags="-s -w" -o /oma-server .
+RUN go generate ./internal/db \
+    && CGO_ENABLED=0 go build -ldflags="-s -w" -o /oma-server .
 
 # ---- 前端构建 (Bun) ---------------------------------------------------------
 FROM ${REGISTRY}/node:22 AS web-builder

docs/design/be/ccrv2/ccr-v2-epoch-design.md

@@ -164,6 +164,14 @@ update code_sessions sequence_num
 commit()
 ```
 
+该事务由共享的 `yourbatis.DB.Transaction` 创建；回调中的同一个事务 `Executor`
+同时构造 `CodeSessionMapper`、`CodeSessionInboundEventMapper` 和
+`CodeSessionOutboundEventMapper`。`CodeSessionMapper.LockCodeSessionByExternalID`
+负责日常 append 的行锁，不附加 `initializing` 状态限制；启动激活仍使用独立的
+`LockInitializingCodeSession`。方向对应的 event mapper 在锁内完成幂等单条查询和
+`INSERT ... RETURNING`，随后由 `CodeSessionMapper` 更新对应方向的 sequence。
+激活使用的 inbound 批量 insert 保持独立，不经过单条 append。
+
 这样线性化语义才成立：
 
 - 如果旧 worker 先拿到锁并写完，再发生 register，则这次写入发生在抢占之前，可以接受。