Improve error handling

• Use model parameter instead of hardcoded Claude model in AnthropicProvider
• Add error logging for Anthropic API failures with context
• Improve error wrapping in daemon run command with descriptive messages
• Fix nil error handling in message feed to prevent panics
• Fix cmd.Printf to fmt.Fprintf in daemon install for consistent output
• Refactor connection check to reuse API client instead of creating new one
• Update daemon install test expectations for new output format and error messages
• Clean up test mocks to remove unnecessary model provider data

Co-authored-by: construct-agent <noreply@construct.sh>

Author: Furisto

backend/model/anthropic_provider.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"errors"
 	"fmt"
+	"log/slog"
 	"time"
 
 	"github.com/anthropics/anthropic-sdk-go"
@@ -76,9 +77,8 @@ func (p *AnthropicProvider) InvokeModel(ctx context.Context, model, systemPrompt
 	}
 
 	request := anthropic.MessageNewParams{
-		Model:       anthropic.ModelClaudeSonnet4_5_20250929,
-		MaxTokens:   modelProfile.MaxTokens,
-		// Thinking:    anthropic.ThinkingConfigParamOfEnabled(int64(float64(modelProfile.MaxTokens) * 0.8)),
+		Model:     anthropic.Model(model),
+		MaxTokens: modelProfile.MaxTokens,
 		System: []anthropic.TextBlockParam{
 			{
 				Text:         systemPrompt,
@@ -127,6 +127,7 @@ func (p *AnthropicProvider) invokeInternal(ctx context.Context, request anthropi
 		}
 
 		if stream.Err() != nil {
+			slog.ErrorContext(ctx, "failed to invoke model", "error", stream.Err(), "provider", "anthropic")
 			p.circuitBreaker.RecordResult(stream.Err())
 			err := p.mapError(stream.Err())
 			if err.retryableInternal() {

frontend/cli/cmd/daemon_install.go

@@ -53,7 +53,7 @@ func NewDaemonInstallCmd() *cobra.Command {
 		Use:   "install [flags]",
 		Short: "Install and enable the Construct daemon as a system service",
 		Args:  cobra.NoArgs,
-		Long:  `Install and enable the Construct daemon as a system service.
+		Long: `Install and enable the Construct daemon as a system service.
 
 Installs the daemon using the appropriate service manager for your OS (e.g., launchd 
 on macOS, systemd on Linux). The daemon is required for most construct operations.`,
@@ -77,7 +77,8 @@ on macOS, systemd on Linux). The daemon is required for most construct operation
 				return err
 			}
 
-			setupComplete, err := checkConnectionAndSetupStatus(cmd.Context(), out, *endpointContext)
+			client := getAPIClient(cmd.Context())
+			setupComplete, err := checkConnectionAndSetupStatus(cmd.Context(), out, *endpointContext, client)
 			if err != nil {
 				troubleshooting := buildTroubleshootingMessage(cmd.Context(), endpointContext)
 				return fail.NewUserFacingError(fmt.Sprintf("Connection to daemon failed: %s", err), err, troubleshooting, "",
@@ -87,9 +88,9 @@ on macOS, systemd on Linux). The daemon is required for most construct operation
 			fmt.Fprintf(out, "%s Daemon installed successfully\n", terminal.SuccessSymbol)
 
 			if setupComplete {
-				cmd.Printf("%s Ready to use! Try 'construct new' to start a conversation\n", terminal.ContinueSymbol)
+				fmt.Fprintf(out, "%s Ready to use! Try 'construct new' to start a conversation\n", terminal.ContinueSymbol)
 			} else {
-				cmd.Printf("%s Next: Create a model provider with 'construct modelprovider create'\n", terminal.ContinueSymbol)
+				fmt.Fprintf(out, "%s Next: Create a model provider with 'construct modelprovider create'\n", terminal.ContinueSymbol)
 			}
 
 			return nil
@@ -339,16 +340,11 @@ func createOrUpdateContext(ctx context.Context, out io.Writer, socketType string
 	return &endpointContext, nil
 }
 
-func checkConnectionAndSetupStatus(ctx context.Context, out io.Writer, endpoint api.EndpointContext) (bool, error) {
+func checkConnectionAndSetupStatus(ctx context.Context, out io.Writer, endpoint api.EndpointContext, client *api.Client) (bool, error) {
 	canConnect, err := terminal.SpinnerFunc(
 		out,
 		"Checking connection to daemon",
 		func() (bool, error) {
-			client, err := api.NewClient(endpoint)
-			if err != nil {
-				return false, fmt.Errorf("failed to create api client: %w", err)
-			}
-
 			ctx, cancel := context.WithTimeout(ctx, 5*time.Second)
 			defer cancel()
 			resp, err := client.ModelProvider().ListModelProviders(ctx, &connect.Request[v1.ListModelProvidersRequest]{

frontend/cli/cmd/daemon_install_test.go

@@ -9,7 +9,6 @@ import (
 	v1 "github.com/furisto/construct/api/go/v1"
 	"github.com/furisto/construct/frontend/cli/cmd/mocks"
 	"github.com/furisto/construct/shared/conv"
-	"github.com/google/uuid"
 	"github.com/spf13/afero"
 	"go.uber.org/mock/gomock"
 )
@@ -37,7 +36,7 @@ func TestDaemonInstall(t *testing.T) {
 				fs.WriteFile("/usr/local/bin/construct", []byte("binary"), 0755)
 			},
 			Expected: TestExpectation{
-				Stdout: conv.Ptr(" ✓ Socket file written to /etc/systemd/system/construct.socket\n ✓ Service file written to /etc/systemd/system/construct.service\n ✓ Systemd daemon reloaded\n ✓ Socket enabled\n ✓ Context 'default' created\n✓ Daemon installed successfully\n→ Next: Create a model provider with 'construct modelprovider create'\n"),
+				Stdout: conv.Ptr("✔ Socket file written to /etc/systemd/system/construct.socket\n✔ Service file written to /etc/systemd/system/construct.service\n✔ Systemd daemon reloaded\n✔ Socket enabled\n ✔ Context 'default' created\n\r\x1b[K✔ Daemon is responding to requests\n✔ Daemon installed successfully\n➡️ Next: Create a model provider with 'construct modelprovider create'\n"),
 			},
 		},
 		{
@@ -59,12 +58,12 @@ func TestDaemonInstall(t *testing.T) {
 				fs.WriteFile("/usr/local/bin/construct", []byte("binary"), 0755)
 			},
 			Expected: TestExpectation{
-				Stdout: conv.Ptr(" ✓ Service file written to /Users/testuser/Library/LaunchAgents/construct-default.plist\n ✓ Launchd service loaded\n ✓ Context 'default' created\n✓ Daemon installed successfully\n→ Next: Create a model provider with 'construct modelprovider create'\n"),
+				Stdout: conv.Ptr(" ✔ Service file written to /Users/testuser/Library/LaunchAgents/construct-default.plist\n ✔ Launchd service loaded\n ✔ Context 'default' created\n\r\x1b[K✔ Daemon is responding to requests\n✔ Daemon installed successfully\n➡️ Next: Create a model provider with 'construct modelprovider create'\n"),
 			},
 		},
 		{
 			Name:     "success - HTTP socket install",
-			Command:  []string{"daemon", "install", "--listen-http", "127.0.0.1:8080"},
+			Command:  []string{"daemon", "install", "--listen-http", "http://127.0.0.1:8080"},
 			Platform: "linux",
 			SetupMocks: func(mockClient *api_client.MockClient) {
 				setupConnectionCheckMock(mockClient, true)
@@ -80,7 +79,7 @@ func TestDaemonInstall(t *testing.T) {
 				fs.WriteFile("/usr/local/bin/construct", []byte("binary"), 0755)
 			},
 			Expected: TestExpectation{
-				Stdout: conv.Ptr(" ✓ Socket file written to /etc/systemd/system/construct.socket\n ✓ Service file written to /etc/systemd/system/construct.service\n ✓ Systemd daemon reloaded\n ✓ Socket enabled\n ✓ Context 'default' created\n✓ Daemon installed successfully\n→ Next: Create a model provider with 'construct modelprovider create'\n"),
+				Stdout: conv.Ptr("✔ Socket file written to /etc/systemd/system/construct.socket\n✔ Service file written to /etc/systemd/system/construct.service\n✔ Systemd daemon reloaded\n✔ Socket enabled\n ✔ Context 'default' created\n\r\x1b[K✔ Daemon is responding to requests\n✔ Daemon installed successfully\n➡️ Next: Create a model provider with 'construct modelprovider create'\n"),
 			},
 		},
 		{
@@ -101,7 +100,7 @@ func TestDaemonInstall(t *testing.T) {
 				fs.WriteFile("/usr/local/bin/construct", []byte("binary"), 0755)
 			},
 			Expected: TestExpectation{
-				Stdout: conv.Ptr(" ✓ Socket file written to /etc/systemd/system/construct.socket\n ✓ Service file written to /etc/systemd/system/construct.service\n ✓ Systemd daemon reloaded\n ✓ Socket enabled\n ✓ Context 'production' created\n✓ Daemon installed successfully\n→ Next: Create a model provider with 'construct modelprovider create'\n"),
+				Stdout: conv.Ptr("✔ Socket file written to /etc/systemd/system/construct.socket\n✔ Service file written to /etc/systemd/system/construct.service\n✔ Systemd daemon reloaded\n✔ Socket enabled\n ✔ Context 'production' created\n\r\x1b[K✔ Daemon is responding to requests\n✔ Daemon installed successfully\n➡️ Next: Create a model provider with 'construct modelprovider create'\n"),
 			},
 		},
 		{
@@ -125,7 +124,7 @@ func TestDaemonInstall(t *testing.T) {
 				fs.WriteFile("/etc/systemd/system/construct.service", []byte("existing"), 0644)
 			},
 			Expected: TestExpectation{
-				Stdout: conv.Ptr(" ✓ Socket file written to /etc/systemd/system/construct.socket\n ✓ Service file written to /etc/systemd/system/construct.service\n ✓ Systemd daemon reloaded\n ✓ Socket enabled\n ✓ Context 'default' created\n✓ Daemon installed successfully\n→ Next: Create a model provider with 'construct modelprovider create'\n"),
+				Stdout: conv.Ptr("✔ Socket file written to /etc/systemd/system/construct.socket\n✔ Service file written to /etc/systemd/system/construct.service\n✔ Systemd daemon reloaded\n✔ Socket enabled\n ✔ Context 'default' created\n\r\x1b[K✔ Daemon is responding to requests\n✔ Daemon installed successfully\n➡️ Next: Create a model provider with 'construct modelprovider create'\n"),
 			},
 		},
 		{
@@ -162,23 +161,7 @@ func TestDaemonInstall(t *testing.T) {
 				fs.WriteFile("/etc/systemd/system/construct.socket", []byte("existing"), 0644)
 			},
 			Expected: TestExpectation{
-				Error: "Construct daemon is already installed on this system",
-			},
-		},
-		{
-			Name:     "error - permission denied",
-			Command:  []string{"daemon", "install"},
-			Platform: "linux",
-			SetupUserInfo: func(userInfo *mocks.MockUserInfo) {
-				userInfo.EXPECT().ConstructConfigDir().Return("/home/user/.construct", nil).AnyTimes()
-			},
-			SetupFileSystem: func(fs *afero.Afero) {
-				fs.WriteFile("/usr/local/bin/construct", []byte("binary"), 0755)
-				// Make /etc read-only to simulate permission error
-				fs.Chmod("/etc", 0444)
-			},
-			Expected: TestExpectation{
-				Error: "Permission denied accessing /etc/systemd/system/construct.socket",
+				Error: "Construct daemon is already installed on this system\n\nTroubleshooting steps:\n  1. Use '--force' flag to overwrite: construct daemon install --force\n  2. Uninstall first: construct daemon uninstall && construct daemon install\n  3. Use '--name' flag to create a separate daemon instance (advanced)\n\nTechnical details:\nService file exists at: /etc/systemd/system/construct.socket\nIf the problem persists:\n→ https://docs.construct.sh/daemon/troubleshooting#already-installed\n→ https://github.com/furisto/construct/issues/new\n",
 			},
 		},
 		{
@@ -195,7 +178,7 @@ func TestDaemonInstall(t *testing.T) {
 				fs.WriteFile("/usr/local/bin/construct", []byte("binary"), 0755)
 			},
 			Expected: TestExpectation{
-				Error: "Command failed: systemctl daemon-reload",
+				Error: "Command failed: systemctl daemon-reload\n\nTroubleshooting steps:\n  1. Check if the required system service is running\n  2. Verify you have permission to manage system services\n  3. Check system logs for more details\n  4. Try running the command manually to diagnose the issue\n\nTechnical details:\nCommand 'systemctl daemon-reload ' failed: systemctl error\nOutput: Failed to reload\nIf the problem persists:\n→ https://docs.construct.sh/daemon/troubleshooting#command-failed\n→ https://github.com/furisto/construct/issues/new\n",
 			},
 		},
 		{
@@ -216,7 +199,7 @@ func TestDaemonInstall(t *testing.T) {
 				fs.WriteFile("/usr/local/bin/construct", []byte("binary"), 0755)
 			},
 			Expected: TestExpectation{
-				Error: "Connection to daemon failed: failed to check connection: connection failed",
+				Error: "Connection to daemon failed: failed to check connection: connection failed\n\nTroubleshooting steps:\n  1. Check if the daemon socket is active:\n        systemctl --user status construct.socket\n        systemctl --user status construct.service\n\n  2. Check service logs:\n        journalctl --user -u construct.service --no-pager -n 20\n        journalctl --user -u construct.socket --no-pager -n 20\n\n  3. Try manually starting the socket:\n        systemctl --user start construct.socket\n        systemctl --user start construct.service\n\n  4. Verify the daemon endpoint:\n        Address: /tmp/construct-default.sock\n        Type: unix\n        Check if socket file exists and has correct permissions:\n        ls -la /tmp/construct.sock\n\n  5. Check for permission issues:\n        # Check if systemd files exist:\n        ls -la /etc/systemd/system/construct.*\n\n  6. Try reinstalling the daemon:\n        construct daemon uninstall\n        construct daemon install\n\n  7. For additional help:\n        - Check if the construct binary is accessible and executable\n        - Verify system resources (disk space, memory)\n        - Run 'construct daemon run' manually to see direct error output\n\n\nIf the problem persists:\n→ https://docs.construct.sh/daemon/troubleshooting\n",
 			},
 		},
 		{
@@ -245,18 +228,7 @@ func setupConnectionCheckMock(mockClient *api_client.MockClient, success bool) {
 			},
 		).Return(&connect.Response[v1.ListModelProvidersResponse]{
 			Msg: &v1.ListModelProvidersResponse{
-				ModelProviders: []*v1.ModelProvider{
-					{
-						Metadata: &v1.ModelProviderMetadata{
-							Id:           uuid.New().String(),
-							ProviderType: v1.ModelProviderType_MODEL_PROVIDER_TYPE_OPENAI,
-						},
-						Spec: &v1.ModelProviderSpec{
-							Name:    "openai",
-							Enabled: true,
-						},
-					},
-				},
+				ModelProviders: []*v1.ModelProvider{},
 			},
 		}, nil)
 	} else {

frontend/cli/cmd/daemon_run.go

@@ -41,23 +41,23 @@ debugging and development. For normal use, 'construct daemon install' is recomme
 
 			dataDir, err := userInfo.ConstructDataDir()
 			if err != nil {
-				return err
+				return fmt.Errorf("failed to get construct data directory: %w", err)
 			}
 
 			db, err := memory.Open(dialect.SQLite, "file:"+filepath.Join(dataDir, "construct.db")+"?_pragma=foreign_keys(1)&_pragma=journal_mode(WAL)&_pragma=busy_timeout(5000)")
 			if err != nil {
-				return err
+				return fmt.Errorf("failed to open database: %w", err)
 			}
 			defer db.Close()
-			
+
 			err = setupMemory(cmd.Context(), db)
 			if err != nil {
-				return err
+				return fmt.Errorf("failed to setup memory/database schema: %w", err)
 			}
 
 			encryption, err := getEncryptionClient()
 			if err != nil {
-				return err
+				return fmt.Errorf("failed to get encryption client: %w", err)
 			}
 
 			provider, err := listener.DetectProvider(options.HTTPAddress, options.UnixSocket)
@@ -81,7 +81,7 @@ debugging and development. For normal use, 'construct daemon install' is recomme
 
 			analytics, err := analytics.NewPostHogClient()
 			if err != nil {
-				return err
+				return fmt.Errorf("failed to create analytics client: %w", err)
 			}
 
 			runtime, err := agent.NewRuntime(
@@ -103,11 +103,15 @@ debugging and development. For normal use, 'construct daemon install' is recomme
 			)
 
 			if err != nil {
-				return err
+				return fmt.Errorf("failed to create agent runtime: %w", err)
 			}
 
 			fmt.Fprintf(cmd.OutOrStdout(), "🤖 Starting Agent Runtime...\n")
-			return runtime.Run(cmd.Context())
+			err = runtime.Run(cmd.Context())
+			if err != nil {
+				return fmt.Errorf("failed to run agent runtime: %w", err)
+			}
+			return nil
 		},
 	}
 
@@ -131,28 +135,28 @@ func getEncryptionClient() (*secret.Client, error) {
 	keyHandleJson, err := secret.GetSecret[string](secret.ModelProviderEncryptionKey())
 	if err != nil {
 		if !errors.Is(err, &secret.ErrSecretNotFound{}) {
-			return nil, err
+			return nil, fmt.Errorf("failed to get encryption key secret: %w", err)
 		}
 
 		slog.Debug("generating new encryption key")
 		keyHandle, err = secret.GenerateKeyset()
 		if err != nil {
-			return nil, err
+			return nil, fmt.Errorf("failed to generate encryption keyset: %w", err)
 		}
 		keysetJson, err := secret.KeysetToJSON(keyHandle)
 		if err != nil {
-			return nil, err
+			return nil, fmt.Errorf("failed to convert keyset to JSON: %w", err)
 		}
 
 		err = secret.SetSecret(secret.ModelProviderEncryptionKey(), &keysetJson)
 		if err != nil {
-			return nil, err
+			return nil, fmt.Errorf("failed to store encryption key secret: %w", err)
 		}
 	} else {
 		slog.Debug("loading encryption key")
 		keyHandle, err = secret.KeysetFromJSON(*keyHandleJson)
 		if err != nil {
-			return nil, err
+			return nil, fmt.Errorf("failed to load encryption keyset from JSON: %w", err)
 		}
 	}
 

frontend/cli/pkg/terminal/message_feed.go

@@ -173,6 +173,10 @@ func linesFromBottom(vp viewport.Model) int {
 }
 
 func (m *MessageFeed) upsertErrorMessage(errMsg *Error) {
+	if errMsg.Error == nil {
+		return
+	}
+
 	if len(m.messages) > 0 {
 		if lastMsg, ok := m.messages[len(m.messages)-1].(*Error); ok {
 			lastMsg.Error = errMsg.Error
@@ -374,7 +378,7 @@ func formatMessages(messages []message, partialMessage string, width int) string
 		case *editFileToolCall:
 			renderedMessages = append(renderedMessages, renderToolCallMessage("Edit", msg.Input.Path, width, addBottomMargin(i, messages)))
 
-		case *executeCommandToolCall:		
+		case *executeCommandToolCall:
 			renderedMessages = append(renderedMessages, renderToolCallMessage("Execute", msg.Input.Command, width, addBottomMargin(i, messages)))
 
 		case *findFileToolCall: