Function startDistributedSingleNode

e2e/distribution_test.go:229–269

(t *testing.T)

}

func startDistributedSingleNode(t *testing.T) (*Harness, testcontainers.Container, string, state.NyPrivateKey, state.NyPublicKey, state.NodeId, int64) {
	t.Helper()
	h := NewHarness(t)
	ctx := context.Background()
	privKey := state.GenerateKey()
	pubKey := privKey.Pubkey()
	runDir := h.SetupTestDir()

	nodeKey := state.GenerateKey()
	nodeId := state.NodeId("node-1")
	cfg := state.CentralCfg{
		Timestamp: 1,
		Dist: &state.DistributionCfg{
			Key:   pubKey,
			Repos: []string{"http://repo:80/bundle"},
		},
		Routers: []state.RouterCfg{
			SimpleRouter(string(nodeId), nodeKey.Pubkey(), "10.0.0.1", ""),
		},
	}
	bundlePath, timestamp := writeBundle(t, runDir, "bundle-initial", cfg, privKey)

	repoContainer := startBundleRepo(t, h, ctx, bundlePath)
	centralConfigPath := h.WriteConfig(runDir, "central.yaml", withTimestamp(cfg, timestamp))
	nodeCfg := SimpleLocal(string(nodeId), nodeKey)
	nodeCfg.Dist = &state.LocalDistributionCfg{
		Key: pubKey,
		Url: "http://repo:80/bundle",
	}
	nodeConfigPath := h.WriteConfig(runDir, "node.yaml", nodeCfg)

	h.StartNodes(NodeSpec{
		Name:              string(nodeId),
		IP:                GetIP(h.Subnet, 10),
		CentralConfigPath: centralConfigPath,
		NodeConfigPath:    nodeConfigPath,
	})
	h.WaitForLog(string(nodeId), "Nylon has been initialized")

	return h, repoContainer, runDir, privKey, pubKey, nodeId, timestamp
}

func startBundleRepo(t *testing.T, h *Harness, ctx context.Context, bundlePath string) testcontainers.Container {
	t.Helper()