Method StartClient

tailnet/test/integration/integration.go:405–449

(t *testing.T, logger slog.Logger, serverURL *url.URL, derpMap *tailcfg.DERPMap, me, peer Client)

}

func (b BasicClientStarter) StartClient(t *testing.T, logger slog.Logger, serverURL *url.URL, derpMap *tailcfg.DERPMap, me, peer Client) *tailnet.Conn {
	var hook capture.Callback
	if b.LogPackets {
		pktLogger := packetLogger{logger}
		hook = pktLogger.LogPacket
	}
	conn := startClientOptions(t, logger, serverURL, me, peer, &tailnet.Options{
		Addresses:           []netip.Prefix{tailnet.TailscaleServicePrefix.PrefixFromUUID(me.ID)},
		DERPMap:             derpMap,
		BlockEndpoints:      b.BlockEndpoints,
		Logger:              logger,
		DERPForceWebSockets: b.DERPForceWebsockets,
		ListenPort:          me.ListenPort,
		// These tests don't have internet connection, so we need to force
		// magicsock to do anything.
		ForceNetworkUp: true,
		CaptureHook:    hook,
	})

	if b.Service != nil {
		b.Service.StartService(t, logger, conn)
	}

	if b.WaitForConnection || b.WaitForDirect {
		// Wait for connection to be established.
		peerIP := tailnet.TailscaleServicePrefix.AddrFromUUID(peer.ID)
		require.Eventually(t, func() bool {
			t.Log("attempting ping to peer to judge direct connection")
			ctx := testutil.Context(t, testutil.WaitShort)
			_, p2p, pong, err := conn.Ping(ctx, peerIP)
			if err != nil {
				t.Logf("ping failed: %v", err)
				return false
			}
			if !p2p && b.WaitForDirect {
				t.Log("ping succeeded, but not direct yet")
				return false
			}
			t.Logf("ping succeeded, p2p=%t, endpoint=%s", p2p, pong.Endpoint)
			return true
		}, testutil.WaitLong, testutil.IntervalMedium)
	}

	return conn
}

const EchoPort = 2381