zheromiku
dcdc8d1ddd
全栈知识治理平台首次入库（P1-P10 + 发布链路模拟验证闭环）： - 治理核心：源目录/变更集/人工审核/发布批次/发布执行（fail-closed 闸口） - 测试通道：WeKnora 测试 KB 上传/轮询/验收；poll 完成时写入 parser_generation/index_generation，修复 manual/seed 路径发布闸口永久拦截 - 发布适配器 v071（本地 source=测试角色 / 云端 target=生产角色 模拟验证通过）： * ES 导出/导入 mapping 自适应（.keyword 子字段、可选 tenant_id） * OSS locator 支持嵌套 scheme；chunks.seq_id 由目标序列分配 * bundle 归档同身份重试原子替换；verifier 按 bundle chunk_type 计数 * 回滚 job payload 支持 prior_execution_id（strict 解码） - 三通道发布+回滚演练实测：publish 4/4 verified，检索命中， rollback 4/4 rolled_back，目标端 PG is_enabled=false、ES is_enabled=false - 前端 A·Data-console 风格全站统一，120 用例通过 - 门禁：go vet / go test 全包通过，gofmt 干净
61 lines
2.9 KiB
Go
61 lines
2.9 KiB
Go
package main
|
|
|
|
import (
|
|
"context"
|
|
"net/http"
|
|
"net/http/httptest"
|
|
"os"
|
|
"path/filepath"
|
|
"testing"
|
|
)
|
|
|
|
func TestReleaseRuntimeRejectsSameSourceAndTargetDatabaseValues(t *testing.T) {
|
|
if err := validateDistinctDatabaseURLs("postgres://user@same/db?sslmode=require", "postgres://user@same/db?sslmode=require"); err == nil {
|
|
t.Fatal("same database URL accepted")
|
|
}
|
|
if err := validateDistinctDatabaseURLs("postgres://user@source/db?sslmode=require", "postgres://user@target/db?sslmode=require"); err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
}
|
|
|
|
func TestBuildReleaseRuntimeWithRestrictedFilesIntegration(t *testing.T) {
|
|
sourceDatabaseURL := os.Getenv("TEST_WEKNORA_V071_DATABASE_URL")
|
|
targetDatabaseURL := os.Getenv("TEST_WEKNORA_V071_TARGET_DATABASE_URL")
|
|
minioEndpoint := os.Getenv("TEST_MINIO_ENDPOINT")
|
|
if sourceDatabaseURL == "" || targetDatabaseURL == "" || minioEndpoint == "" {
|
|
t.Skip("release runtime integration environment is not set")
|
|
}
|
|
esSource := httptest.NewServer(http.NotFoundHandler())
|
|
defer esSource.Close()
|
|
esTarget := httptest.NewServer(http.NotFoundHandler())
|
|
defer esTarget.Close()
|
|
weknoraTarget := httptest.NewServer(http.NotFoundHandler())
|
|
defer weknoraTarget.Close()
|
|
root := t.TempDir()
|
|
archiveRoot := filepath.Join(root, "archive")
|
|
archiveRoute := filepath.Join(archiveRoot, "kb-release-safe")
|
|
if err := os.MkdirAll(archiveRoute, 0o700); err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
secret := func(name, value string) string {
|
|
path := filepath.Join(root, name)
|
|
if err := os.WriteFile(path, []byte(value+"\n"), 0o600); err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
return path
|
|
}
|
|
route := releaseRouteConfig{
|
|
TenantID: 10000, KnowledgeBaseID: "kb-release-safe", EmbeddingModel: "bge-m3",
|
|
Source: releaseEndpointConfig{DatabaseURLFile: secret("source-db", sourceDatabaseURL), Elasticsearch: releaseElasticsearchConfig{BaseURL: esSource.URL, Index: "chunks"}, Object: releaseObjectConfig{Provider: "minio", Endpoint: minioEndpoint, Region: "us-east-1", Bucket: "release-source", AccessKeyFile: secret("source-ak", "release-test"), SecretKeyFile: secret("source-sk", "release-test-secret")}},
|
|
Target: releaseEndpointConfig{DatabaseURLFile: secret("target-db", targetDatabaseURL), Elasticsearch: releaseElasticsearchConfig{BaseURL: esTarget.URL, Index: "chunks"}, Object: releaseObjectConfig{Provider: "minio", Endpoint: minioEndpoint, Region: "us-east-1", Bucket: "release-target", StorageBackendID: "target-backend", AccessKeyFile: secret("target-ak", "release-test"), SecretKeyFile: secret("target-sk", "release-test-secret")}, WeKnora: releaseWeKnoraConfig{BaseURL: weknoraTarget.URL, APIKeyFile: secret("target-weknora", "test-api-key"), AllowDockerHTTP: true}},
|
|
}
|
|
runtime, err := buildReleaseRuntime(context.Background(), releaseRuntimeConfig{ArchiveRoot: archiveRoot, Routes: []releaseRouteConfig{route}})
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
runtime.Close()
|
|
if runtime.publisher == nil || len(runtime.pools) != 2 {
|
|
t.Fatalf("runtime=%#v", runtime)
|
|
}
|
|
}
|