Function TestHASubnetRouterFailover

integration/route_test.go:223–1323

nolint:gocyclo // complex HA failover test scenario

(t *testing.T)

//nolint:gocyclo // complex HA failover test scenario
func TestHASubnetRouterFailover(t *testing.T) {
	IntegrationSkip(t)

	// HASlowConverge (not HAConverge): tailscale's wgengine sometimes
	// keeps routing through the previous primary for ~2 min after
	// the netmap update flips PrimaryRoutes server-side.
	propagationTime := integrationutil.HASlowConvergeTimeout

	// Helper function to validate primary routes table state
	validatePrimaryRoutes := func(t *testing.T, headscale ControlServer, expectedRoutes *types.DebugRoutes, message string) {
		t.Helper()
		assert.EventuallyWithT(t, func(c *assert.CollectT) {
			primaryRoutesState, err := headscale.PrimaryRoutes()
			assert.NoError(c, err)

			if diff := cmpdiff.Diff(expectedRoutes, primaryRoutesState, util.PrefixComparer); diff != "" {
				t.Log(message)
				t.Errorf("validatePrimaryRoutes mismatch (-want +got):\n%s", diff)
			}
		}, propagationTime, 200*time.Millisecond, "Validating primary routes table")
	}

	spec := ScenarioSpec{
		NodesPerUser: 3,
		Users:        []string{"user1", "user2"},
		Networks: map[string]NetworkSpec{
			"usernet1": {Users: []string{"user1"}},
			"usernet2": {Users: []string{"user2"}},
		},
		ExtraService: map[string][]extraServiceFunc{
			"usernet1": {Webservice},
		},
		// We build the head image with curl and traceroute, so only use
		// that for this test.
		Versions: []string{"head"},
	}

	scenario, err := NewScenario(spec)
	require.NoErrorf(t, err, "failed to create scenario: %s", err)
	// defer scenario.ShutdownAssertNoPanics(t)

	err = scenario.CreateHeadscaleEnv(
		[]tsic.Option{tsic.WithAcceptRoutes()},
		hsic.WithTestName("rt-hafailover"),
	)
	requireNoErrHeadscaleEnv(t, err)

	allClients, err := scenario.ListTailscaleClients()
	requireNoErrListClients(t, err)

	err = scenario.WaitForTailscaleSync()
	requireNoErrSync(t, err)

	headscale, err := scenario.Headscale()
	requireNoErrGetHeadscale(t, err)

	prefp, err := scenario.SubnetOfNetwork("usernet1")
	require.NoError(t, err)