Function TestRecoveryExample

e2e/recovery_test.go:13–137

(t *testing.T)

)

func TestRecoveryExample(t *testing.T) {
	t.Parallel()
	h := NewHarness(t)

	// Node names
	alice := "alice"
	bob := "bob"
	charlie := "charlie"
	eve := "eve"
	vps := "vps"
	nodeNames := []string{alice, bob, charlie, eve, vps}

	// Generate keys
	keys := make(map[string]state.NyPrivateKey)
	pubKeys := make(map[string]state.NyPublicKey)
	for _, name := range nodeNames {
		k := state.GenerateKey()
		keys[name] = k
		pubKeys[name] = k.Pubkey()
	}

	// Internal Nylon IPs (10.0.0.x)
	nylonIPs := make(map[string]string)
	for i, name := range nodeNames {
		nylonIPs[name] = fmt.Sprintf("10.0.0.%d", i+1)
	}

	// Docker IPs
	dockerIPs := make(map[string]string)
	for i, name := range nodeNames {
		dockerIPs[name] = GetIP(h.Subnet, 10+i)
	}

	configDir := h.SetupTestDir()

	// 1. Create Central Config
	central := state.CentralCfg{
		Routers: []state.RouterCfg{
			SimpleRouter(alice, pubKeys[alice], nylonIPs[alice], dockerIPs[alice]),
			SimpleRouter(bob, pubKeys[bob], nylonIPs[bob], dockerIPs[bob]),
			SimpleRouter(charlie, pubKeys[charlie], nylonIPs[charlie], dockerIPs[charlie]),
			SimpleRouter(eve, pubKeys[eve], nylonIPs[eve], dockerIPs[eve]),
			SimpleRouter(vps, pubKeys[vps], nylonIPs[vps], dockerIPs[vps]),
		},
		Graph: []string{
			"vps, charlie",
			"vps, alice",
			"eve, bob",
			"vps, eve",
			"alice, bob",
		},
		Timestamp: time.Now().UnixNano(),
	}

	centralPath := h.WriteConfig(configDir, "central.yaml", central)

	// 2. Create Node Configs & Start Nodes
	nodeSpecs := make([]NodeSpec, 0, len(nodeNames))