discovery: strip extraneous comments outside MOLS change scope

Author: gg582

portal/discovery/refresher.go

@@ -25,13 +25,11 @@ const (
 	maxConcurrentOverlayDial = 8
 )
 
-// OverlayRuntime defines the interface for relay discovery and overlay peer synchronization.
 type OverlayRuntime interface {
 	DiscoverRelay(context.Context, types.RelayDescriptor) (types.DiscoveryResponse, error)
 	Sync([]types.RelayDescriptor) error
 }
 
-// Refresher periodically polls relay discovery endpoints and updates the relay set.
 type Refresher struct {
 	relaySet               *RelaySet
 	httpClient             *http.Client
@@ -41,7 +39,6 @@ type Refresher struct {
 	lastAnnounceMu         sync.Mutex
 }
 
-// NewRefresher creates a new Refresher for the given relay set and overlay runtime.
 func NewRefresher(relaySet *RelaySet, overlay OverlayRuntime) *Refresher {
 	return &Refresher{
 		relaySet: relaySet,
@@ -278,7 +275,6 @@ func (r *Refresher) refreshOverlay(ctx context.Context) error {
 	return nil
 }
 
-// parallel executes fn concurrently for each item with a concurrency limit, returning the first error encountered.
 func parallel[T any](items []T, limit int, fn func(T) error) error {
 	var wg sync.WaitGroup
 	sem := make(chan struct{}, limit)

portal/discovery/relayset.go

@@ -67,7 +67,6 @@ const (
 	upsertIgnored
 )
 
-// NewRelaySet creates a new RelaySet initialized with the given bootstrap relay URLs.
 func NewRelaySet(bootstrapRelayURLs []string) *RelaySet {
 	set := &RelaySet{
 		relays:   make(map[string]RelayState),
@@ -392,13 +391,11 @@ func (s *RelaySet) ConfirmedRelays() []RelayState {
 	return selectConfirmed(s.currentRelayStates(time.Now().UTC()))
 }
 
-// Route represents a planned relay path with optional multi-hop routing.
 type Route struct {
 	path     []string
 	explicit bool
 }
 
-// NewRoute creates a new Route with the given path and explicit flag.
 func NewRoute(path []string, explicit bool) Route {
 	return Route{
 		path:     append([]string(nil), path...),

portal/discovery/relaystate.go

@@ -61,7 +61,6 @@ const (
 	RelayVerified
 )
 
-// PercentileTracker tracks RTT samples and computes percentiles for relay latency analysis.
 type PercentileTracker struct {
 	samples []float64
 }
@@ -85,7 +84,6 @@ func (pt *PercentileTracker) Get(p float64) time.Duration {
 	return time.Duration(val)
 }
 
-// RelayState holds runtime telemetry and eligibility state for a single relay.
 type RelayState struct {
 	Descriptor types.RelayDescriptor
 	Bootstrap  bool
@@ -147,7 +145,6 @@ func (state RelayState) effectiveRTT() time.Duration {
 	return rtt
 }
 
-// fixedLoad converts a floating-point load factor to a fixed-point integer scaled by relayMetricScale.
 func fixedLoad(load float64) uint32 {
 	if load <= 0 {
 		return 0
@@ -186,7 +183,6 @@ func (state *RelayState) UpdateLoad(loadFixed uint32) {
 	state.StoreLoadFactor(loadFixed)
 }
 
-// inheritAdaptiveTelemetry copies adaptive telemetry state from an existing relay entry to preserve load and RTT history.
 func (state *RelayState) inheritAdaptiveTelemetry(existing RelayState) {
 	load := atomic.LoadUint32(&existing.loadFixed)
 	if load == 0 && existing.LoadFactor != 0 {
@@ -260,7 +256,6 @@ func absDuration(value time.Duration) time.Duration {
 	return value
 }
 
-// newRelayState creates a minimal RelayState with the given relay URL.
 func newRelayState(relayURL string) RelayState {
 	return RelayState{
 		Descriptor: types.RelayDescriptor{
@@ -269,7 +264,6 @@ func newRelayState(relayURL string) RelayState {
 	}
 }
 
-// hasObservedDescriptor reports whether a relay descriptor has been observed via discovery.
 func (state RelayState) hasObservedDescriptor() bool {
 	return !state.LastSeenAt.IsZero()
 }
@@ -287,7 +281,6 @@ func (state RelayState) eligibleForMultiHop(routeState RouteState, now time.Time
 		(state.nextDiscoveryRefreshAt.IsZero() || !state.nextDiscoveryRefreshAt.After(now))
 }
 
-// RouteState describes the client's routing requirements for relay selection.
 type RouteState struct {
 	ExplicitRelayURLs []string
 	// ActiveRelayURLs holds currently active connected relay URLs to enable
@@ -308,7 +301,6 @@ type RouteState struct {
 	SelectionEpoch uint64
 }
 
-// supportsRequiredTransports reports whether the relay supports the UDP and TCP transports required by the route.
 func (state RelayState) supportsRequiredTransports(routeState RouteState, now time.Time) bool {
 	if !state.hasObservedDescriptor() || !state.Descriptor.ExpiresAt.After(now) {
 		return true

sdk/expose.go

@@ -40,7 +40,6 @@ type Exposure struct {
 	connSeq   atomic.Uint64
 }
 
-// ExposeConfig holds the configuration for exposing a local service through the portal tunnel.
 type ExposeConfig struct {
 	RelayURLs []string
 	Discovery bool

sdk/http.go

@@ -20,7 +20,6 @@ import (
 	"github.com/gosuda/portal-tunnel/v2/utils"
 )
 
-// RunHTTP serves HTTP traffic from the relay listener or local address using the provided handler.
 func RunHTTP(ctx context.Context, relayListener net.Listener, handler http.Handler, localAddr string) error {
 	if relayListener == nil && localAddr == "" {
 		return errors.New("relay listener or local address is required")

sdk/mitm.go

@@ -32,7 +32,6 @@ const (
 	defaultMITMProbeTimeout  = 30 * time.Second
 )
 
-// MITMProbeReport contains the results of a man-in-the-middle detection probe.
 type MITMProbeReport struct {
 	RelayURL    string
 	PublicURL   string

sdk/proxy.go

@@ -16,7 +16,6 @@ import (
 	"github.com/gosuda/portal-tunnel/v2/types"
 )
 
-// ProxyExposure runs the TCP/UDP proxy for the given exposure until the context is canceled.
 func ProxyExposure(ctx context.Context, exposure *Exposure) error {
 	defer exposure.Close()
 	if len(exposure.ActiveRelayURLs()) == 0 {

types/agent.go

@@ -1,14 +1,12 @@
 package types
 
-// AgentStatusResponse contains the current status of the portal-tunnel agent daemon.
 type AgentStatusResponse struct {
 	ConfigPath    string              `json:"config_path,omitempty"`
 	ControlAddr   string              `json:"control_addr"`
 	WalletAddress string              `json:"wallet_address,omitempty"`
 	Tunnels       []AgentTunnelStatus `json:"tunnels,omitempty"`
 }
 
-// AgentTunnelStatus represents the runtime state of a single managed tunnel.
 type AgentTunnelStatus struct {
 	ID              string             `json:"id"`
 	Name            string             `json:"name,omitempty"`
@@ -30,15 +28,13 @@ type AgentTunnelStatus struct {
 	Relays          []AgentRelayStatus `json:"relays,omitempty"`
 }
 
-// AgentHTTPRoute defines an HTTP routing rule for paid or public endpoints.
 type AgentHTTPRoute struct {
 	Prefix   string   `json:"prefix"`
 	Upstream string   `json:"upstream"`
 	Methods  []string `json:"methods,omitempty"`
 	Amount   string   `json:"amount,omitempty"`
 }
 
-// AgentRelayStatus reports the connection state and capabilities of a relay.
 type AgentRelayStatus struct {
 	RelayURL        string `json:"relay_url"`
 	PublicURL       string `json:"public_url,omitempty"`
@@ -52,7 +48,6 @@ type AgentRelayStatus struct {
 	SupportsTCP     bool   `json:"supports_tcp"`
 }
 
-// AgentTunnelRequest describes a tunnel configuration submitted to the agent API.
 type AgentTunnelRequest struct {
 	ID              string           `json:"id"`
 	Name            string           `json:"name,omitempty"`
@@ -69,17 +64,14 @@ type AgentTunnelRequest struct {
 	X402Endpoints   []string         `json:"x402_endpoints,omitempty"`
 }
 
-// AgentRelayRequest identifies a relay by URL for add/remove operations.
 type AgentRelayRequest struct {
 	RelayURL string `json:"relay_url"`
 }
 
-// AgentMultiHopRequest configures explicit multi-hop relay paths.
 type AgentMultiHopRequest struct {
 	Relays []string `json:"relays"`
 }
 
-// AgentTunnelUpdateRequest applies partial updates to a running tunnel's configuration.
 type AgentTunnelUpdateRequest struct {
 	MaxActiveRelays *int                  `json:"max_active_relays,omitempty"`
 	Metadata        *AgentMetadataRequest `json:"metadata,omitempty"`
@@ -90,7 +82,6 @@ func (r AgentTunnelUpdateRequest) Empty() bool {
 		(r.Metadata == nil || r.Metadata.Empty())
 }
 
-// AgentMetadataRequest holds partial metadata updates for a tunnel.
 type AgentMetadataRequest struct {
 	Description *string   `json:"description,omitempty"`
 	Owner       *string   `json:"owner,omitempty"`