feat: wrap user environment errors with UntrackedError

Wrap the following errors to exclude them from Sentry:
- ErrDocker: docker not running or inaccessible
- ErrPort: port already in use
- ErrAirbyteDir: airbyte directory inaccessible
- ErrIpAddressForHostFlag: invalid host flag (IP address)
- ErrInvalidHostFlag: invalid host flag format
- cannot read PG_VERSION file (excluding not found)

Author: bernielomax

internal/cmd/local/check.go

@@ -35,14 +35,18 @@ func dockerInstalled(ctx context.Context, telClient telemetry.Client) (docker.Ve
 	if dockerClient == nil {
 		if dockerClient, err = docker.New(ctx); err != nil {
 			pterm.Error.Println("Unable to create Docker client")
-			return docker.Version{}, fmt.Errorf("%w: unable to create client: %w", abctl.ErrDocker, err)
+			return docker.Version{}, abctl.NewUntrackedError(
+				fmt.Errorf("%w: unable to create client: %w", abctl.ErrDocker, err),
+			)
 		}
 	}
 
 	version, err := dockerClient.Version(ctx)
 	if err != nil {
 		pterm.Error.Println("Unable to communicate with the Docker daemon")
-		return docker.Version{}, fmt.Errorf("%w: %w", abctl.ErrDocker, err)
+		return docker.Version{}, abctl.NewUntrackedError(
+			fmt.Errorf("%w: %w", abctl.ErrDocker, err),
+		)
 	}
 
 	span.SetAttributes(
@@ -94,10 +98,14 @@ func portAvailable(ctx context.Context, port int) error {
 	lc := &net.ListenConfig{}
 	listener, err := lc.Listen(ctx, "tcp", fmt.Sprintf("localhost:%d", port))
 	if isErrorAddressAlreadyInUse(err) {
-		return fmt.Errorf("%w: port %d is already in use", abctl.ErrPort, port)
+		return abctl.NewUntrackedError(
+			fmt.Errorf("%w: port %d is already in use", abctl.ErrPort, port),
+		)
 	}
 	if err != nil {
-		return fmt.Errorf("%w: unable to determine if port '%d' is available: %w", abctl.ErrPort, port, err)
+		return abctl.NewUntrackedError(
+			fmt.Errorf("%w: unable to determine if port '%d' is available: %w", abctl.ErrPort, port, err),
+		)
 	}
 	// if we're able to bind to the port (and then release it), it should be available
 	defer func() {
@@ -193,10 +201,10 @@ func (e InvalidPortError) Error() string {
 
 func validateHostFlag(host string) error {
 	if ip := net.ParseIP(host); ip != nil {
-		return abctl.ErrIpAddressForHostFlag
+		return abctl.NewUntrackedError(abctl.ErrIpAddressForHostFlag)
 	}
 	if !regexp.MustCompile(`^[a-z0-9](?:[-a-z0-9]*[a-z0-9])?(?:\.[a-z0-9](?:[-a-z0-9]*[a-z0-9])?)*$`).MatchString(host) {
-		return abctl.ErrInvalidHostFlag
+		return abctl.NewUntrackedError(abctl.ErrInvalidHostFlag)
 	}
 	return nil
 }

internal/cmd/local/local.go

@@ -27,7 +27,9 @@ func (c *Cmd) BeforeApply() error {
 	}
 
 	if err := checkAirbyteDir(); err != nil {
-		return fmt.Errorf("%w: %w", abctl.ErrAirbyteDir, err)
+		return abctl.NewUntrackedError(
+			fmt.Errorf("%w: %w", abctl.ErrAirbyteDir, err),
+		)
 	}
 
 	return nil

internal/docker/docker.go

@@ -148,7 +148,9 @@ func newWithOptions(ctx context.Context, newPing newPing, goos string) (*Docker,
 		}
 	}
 
-	return nil, fmt.Errorf("%w: unable to create docker client", abctl.ErrDocker)
+	return nil, abctl.NewUntrackedError(
+		fmt.Errorf("%w: unable to create docker client", abctl.ErrDocker),
+	)
 }
 
 // createAndPing attempts to create a docker client and ping it to ensure we can communicate

internal/service/manager.go

@@ -241,7 +241,7 @@ func EnablePsql17() (bool, error) {
 
 	pgVersion, err := pgData.Version()
 	if err != nil && !errors.Is(err, fs.ErrNotExist) {
-		return false, fmt.Errorf("failed to determine if any previous psql version exists: %w", err)
+		return false, abctl.NewUntrackedError(fmt.Errorf("failed to determine if any previous psql version exists: %w", err))
 	}
 
 	if pgVersion == "" || pgVersion == "17" {