《MMO 服务器开发》10.2 与 skynet / pitaya / leaf 对照与全书收官

// file: internal/matrix/manifest.go
// tier: L1
// verify: go test ./internal/matrix/
package matrix

import (
	"encoding/json"
	"fmt"
	"os"
)

// Volume is one of the four books, with the runnable artifacts it shipped.
type Volume struct {
	ID        string   `json:"id"`
	Title     string   `json:"title"`
	Prefix    string   `json:"prefix"`
	Artifacts []string `json:"artifacts"`
}

// Manifest is the whole-book artifact index, kept as JSON so the last section of
// the last volume can assert that nothing was left half-shipped.
type Manifest struct {
	Volumes []Volume `json:"volumes"`
}

// expectedVolumes is the four-volume through-line, in reading order. The order
// is fixed so Validate's output is deterministic rather than map-ordered.
var expectedVolumes = []struct {
	ID     string
	Prefix string
}{
	{"vol1", "mmo-net-"},
	{"vol2", "mmo-srv-"},
	{"vol3", "mmo-dist-"},
	{"vol4", "mmo-eng-"},
}

// LoadManifest reads the artifact manifest from disk.
func LoadManifest(path string) (*Manifest, error) {
	raw, err := os.ReadFile(path)
	if err != nil {
		return nil, err
	}
	var m Manifest
	if err := json.Unmarshal(raw, &m); err != nil {
		return nil, fmt.Errorf("matrix: parse manifest: %w", err)
	}
	return &m, nil
}

// Validate checks that all four volumes are present, carry the expected slug
// prefix, and shipped at least one artifact. It returns one problem per missing
// or malformed entry, so the closing section can print a complete picture
// instead of stopping at the first error.
func (m *Manifest) Validate() []string {
	var problems []string
	byID := make(map[string]Volume, len(m.Volumes))
	for _, v := range m.Volumes {
		byID[v.ID] = v
	}
	for _, want := range expectedVolumes {
		v, ok := byID[want.ID]
		if !ok {
			problems = append(problems, fmt.Sprintf("volume %s missing from manifest", want.ID))
			continue
		}
		if v.Prefix != want.Prefix {
			problems = append(problems, fmt.Sprintf("volume %s prefix = %q, want %q", want.ID, v.Prefix, want.Prefix))
		}
		if len(v.Artifacts) == 0 {
			problems = append(problems, fmt.Sprintf("volume %s (%s) shipped no artifacts", want.ID, v.Title))
		}
	}
	return problems
}

{
  "volumes": [
    {
      "id": "vol1",
      "title": "网络与并发内核",
      "prefix": "mmo-net-",
      "artifacts": ["帧编解码", "KCP 传输", "时间轮", "会话路由", "Actor 邮箱", "快照与增量", "AOI 与广播"]
    },
    {
      "id": "vol2",
      "title": "单服架构与玩法系统",
      "prefix": "mmo-srv-",
      "artifacts": ["实体运行时", "AOI 九宫格", "战斗管线", "背包与交易", "任务 DAG", "组队与公会", "匹配与实例分配"]
    },
    {
      "id": "vol3",
      "title": "分布式与跨服",
      "prefix": "mmo-dist-",
      "artifacts": ["服务发现", "gRPC RPC", "网关集群", "实例调度", "跨服战场", "雪花 ID", "分库分表与事务"]
    },
    {
      "id": "vol4",
      "title": "工程化与运营",
      "prefix": "mmo-eng-",
      "artifacts": ["机器人压测", "性能剖析", "指标打点", "配置中心", "埋点管道", "GM 后台", "备份恢复与演练", "跨栈对照矩阵"]
    }
  ]
}

// file: internal/matrix/manifest_test.go
// tier: L1
// verify: go test ./internal/matrix/
package matrix

import (
	"strings"
	"testing"
)

func TestValidateCompleteManifest(t *testing.T) {
	m := &Manifest{Volumes: []Volume{
		{ID: "vol1", Title: "网络与并发内核", Prefix: "mmo-net-", Artifacts: []string{"帧编解码", "KCP 传输", "时间轮"}},
		{ID: "vol2", Title: "单服架构与玩法系统", Prefix: "mmo-srv-", Artifacts: []string{"实体运行时", "AOI", "战斗管线"}},
		{ID: "vol3", Title: "分布式与跨服", Prefix: "mmo-dist-", Artifacts: []string{"服务发现", "网关集群", "跨服战场"}},
		{ID: "vol4", Title: "工程化与运营", Prefix: "mmo-eng-", Artifacts: []string{"机器人压测", "指标打点", "GM 后台"}},
	}}
	if p := m.Validate(); len(p) != 0 {
		t.Fatalf("Validate() = %v, want none", p)
	}
}

func TestValidateCatchesMissingVolumes(t *testing.T) {
	m := &Manifest{Volumes: []Volume{
		{ID: "vol1", Title: "网络与并发内核", Prefix: "mmo-net-", Artifacts: []string{"帧编解码"}},
	}}
	p := m.Validate()
	// vol2, vol3 and vol4 are absent: exactly three problems.
	if len(p) != 3 {
		t.Fatalf("Validate() = %v, want 3 missing-volume problems", p)
	}
}

func TestValidateCatchesWrongPrefix(t *testing.T) {
	m := &Manifest{Volumes: []Volume{
		{ID: "vol4", Title: "工程化与运营", Prefix: "mmo-ops-", Artifacts: []string{"机器人压测"}},
	}}
	p := m.Validate()
	found := false
	for _, s := range p {
		if strings.Contains(s, "prefix") {
			found = true
		}
	}
	if !found {
		t.Fatalf("Validate() = %v, want a prefix problem", p)
	}
}

func TestValidateCatchesEmptyArtifacts(t *testing.T) {
	m := &Manifest{Volumes: []Volume{
		{ID: "vol1", Title: "网络与并发内核", Prefix: "mmo-net-", Artifacts: []string{"帧编解码"}},
		{ID: "vol2", Title: "单服架构与玩法系统", Prefix: "mmo-srv-"},
		{ID: "vol3", Title: "分布式与跨服", Prefix: "mmo-dist-", Artifacts: []string{"服务发现"}},
		{ID: "vol4", Title: "工程化与运营", Prefix: "mmo-eng-", Artifacts: []string{"机器人压测"}},
	}}
	p := m.Validate()
	found := false
	for _, s := range p {
		if strings.Contains(s, "no artifacts") {
			found = true
		}
	}
	if !found {
		t.Fatalf("Validate() = %v, want an empty-artifacts problem", p)
	}
}

// TestBookManifestIsComplete loads the real manifest that ships next to this
// package and asserts the whole four-volume book is accounted for.
func TestBookManifestIsComplete(t *testing.T) {
	m, err := LoadManifest("manifest.json")
	if err != nil {
		t.Fatal(err)
	}
	if p := m.Validate(); len(p) != 0 {
		t.Fatalf("book manifest has problems: %v", p)
	}
	if len(m.Volumes) != 4 {
		t.Fatalf("manifest has %d volumes, want 4", len(m.Volumes))
	}
	total := 0
	for _, v := range m.Volumes {
		total += len(v.Artifacts)
	}
	t.Logf("四卷产物合计 %d 项", total)
}

=== RUN   TestBookManifestIsComplete
    manifest_test.go:86: 四卷产物合计 29 项
--- PASS: TestBookManifestIsComplete (0.00s)
PASS
ok  	aegis/internal/matrix	0.265s