mirror of
https://github.com/netbirdio/netbird.git
synced 2026-09-08 07:51:28 +02:00
778b3b3264
* Unify peer and route ACL filtering with multi-source peer rules * Remove partial userspace firewall mode and open foreign chains via a table-less allower * Snapshot iptables rule maps before persisting state * Scope userspace firewall wildcard source rules per address family * Install nftables peer filter and mangle rules in a single transaction * Share the iptables jump rule spec between install and cleanup * Fix legacy ACL source wildcard and keep rollback tracking on delete failure * Fix CI: recognize multi-value port set lookups in tests and correct PeerIP lint suppression * Fall back to per-prefix filter rules when ipset is unavailable * Annotate legacy PeerIP usages in ACL tests and fix import formatting * Keep firewall rule bookkeeping in step with the kernel on replace and teardown * Release the routing reference when the route manager shuts down * Keep set references and rule tracking consistent when a routing rule fails
50 lines
1.3 KiB
Go
50 lines
1.3 KiB
Go
// This file is intentionally named test.go (not test_test.go) so the exported
|
|
// StartTestServer helper is visible to the ssh/proxy and ssh/client external
|
|
// test packages, not just this package's own tests. The //go:build !js tag
|
|
// keeps its "testing" import, along with the whole testing/flag/regexp
|
|
// transitive chain it drags in, out of the wasm client, which links
|
|
// ssh/server through the engine but never runs Go tests under GOOS=js.
|
|
//go:build !js
|
|
|
|
package server
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"net/netip"
|
|
"testing"
|
|
"time"
|
|
)
|
|
|
|
// StartTestServer starts the SSH server and returns the address it's listening on.
|
|
func StartTestServer(t *testing.T, server *Server) string {
|
|
started := make(chan string, 1)
|
|
errChan := make(chan error, 1)
|
|
|
|
go func() {
|
|
addrPort := netip.MustParseAddrPort("127.0.0.1:0")
|
|
if err := server.Start(context.Background(), addrPort); err != nil {
|
|
errChan <- err
|
|
return
|
|
}
|
|
|
|
actualAddr := server.Addr()
|
|
if actualAddr == nil {
|
|
errChan <- fmt.Errorf("server started but no listener address available")
|
|
return
|
|
}
|
|
|
|
started <- actualAddr.String()
|
|
}()
|
|
|
|
select {
|
|
case actualAddr := <-started:
|
|
return actualAddr
|
|
case err := <-errChan:
|
|
t.Fatalf("Server failed to start: %v", err)
|
|
case <-time.After(5 * time.Second):
|
|
t.Fatal("Server start timeout")
|
|
}
|
|
return ""
|
|
}
|