Delete the workspace file read

apps/daemon/internal/agent/claudesdk/bridge_output.go

@@ -16,7 +16,7 @@ func (s *session) bridgeOutput() *bridgeOutput {
 		scanner.Buffer(make([]byte, 64*1024), 2*1024*1024)
 		for scanner.Scan() {
 			raw := append([]byte(nil), scanner.Bytes()...)
-			if !s.receiveWorkspaceRead(raw) && !s.receiveWorkspaceDirectory(raw) {
+			if !s.receiveWorkspaceDirectory(raw) {
 				output.frames <- raw
 			}
 		}

apps/daemon/internal/agent/claudesdk/contracts.go

@@ -13,10 +13,8 @@ var (
 	_ agent.FunctionResultSubmitter  = (*session)(nil)
 	_ agent.PermissionResponder      = (*session)(nil)
 	_ agent.UserChoiceResponder      = (*session)(nil)
-	_ agent.WorkspaceReader          = (*session)(nil)
 	_ agent.WorkspaceDirectoryLister = (*session)(nil)
 	_ agent.WorkspaceWriter          = (*session)(nil)
-	_ agent.WorkspaceReader          = (*executor)(nil)
 	_ agent.WorkspaceDirectoryLister = (*executor)(nil)
 	_ agent.WorkspaceWriter          = (*executor)(nil)
 )

apps/daemon/internal/agent/claudesdk/executor.go

@@ -69,7 +69,6 @@ func startExecutor(ctx context.Context, checked *runtimeCheckCache, probe Config
 	if err != nil {
 		return nil, err
 	}
-	base.reads.supported = slices.Contains(info.Features, "workspace_read")
 	base.directories.supported = slices.Contains(info.Features, "workspace_directory")
 	e := &executor{base: base, start: start, ready: make(chan error, 1), done: make(chan struct{}), nativeID: start.Resume}
 	go e.read()
@@ -180,7 +179,6 @@ func (e *executor) read() {
 	}
 	<-stderrDone
 	_ = e.base.process.Wait()
-	e.base.stopWorkspaceReads()
 	e.base.stopWorkspaceDirectories()
 	e.mu.Lock()
 	e.invalid = true
@@ -320,9 +318,6 @@ func (s *session) invalidate() {
 	}
 }
 
-func (e *executor) ReadWorkspaceFile(ctx context.Context, path string, maxBytes int) (agent.WorkspaceReadResult, error) {
-	return e.base.ReadWorkspaceFile(ctx, path, maxBytes)
-}
 func (e *executor) ListWorkspaceDirectory(ctx context.Context, path string, maxEntries int) (agent.WorkspaceDirectoryResult, error) {
 	return e.base.ListWorkspaceDirectory(ctx, path, maxEntries)
 }

apps/daemon/internal/agent/claudesdk/preparation_fixture_test.go

@@ -38,7 +38,7 @@ func preparationRequest() proto.PromptRequestPayload {
 func runPreparationHelper() {
 	mode := os.Getenv("SDK_HELPER_MODE")
 	if len(os.Args) > 1 && strings.HasSuffix(os.Args[1], "runtime_check.js") {
-		features := []string{"workspace_tools", "workspace_prepare", "workspace_command_observations", "workspace_read", "workspace_directory"}
+		features := []string{"workspace_tools", "workspace_prepare", "workspace_command_observations", "workspace_directory"}
 		if mode == "old-runtime" {
 			features = []string{"workspace_tools"}
 		} else if mode == "old-command-runtime" {
@@ -89,10 +89,6 @@ func runPreparationHelper() {
 		runWorkspaceDirectoryHelper(scanner, state, mode)
 		return
 	}
-	if strings.HasPrefix(mode, "read-") {
-		runWorkspaceReadHelper(scanner, state, mode)
-		return
-	}
 	if !scanner.Scan() {
 		return
 	}

apps/daemon/internal/agent/claudesdk/session.go

@@ -23,7 +23,6 @@ type session struct {
 	cancelOutput   chan struct{}
 	nativeEnded    bool
 
-	reads       workspaceReadState
 	directories workspaceDirectoryState
 	process     *clirunner.Process
 	writeMu     *sync.Mutex

apps/daemon/internal/agent/claudesdk/workspace_directory_live_linux_test.go

@@ -31,12 +31,8 @@ func liveWorkspaceDirectoryFixtures(t *testing.T, root string) {
 	}
 }
 
-func liveWorkspaceDirectories(t *testing.T, ctx context.Context, reader agent.WorkspaceReader, root, stage string) {
+func liveWorkspaceDirectories(t *testing.T, ctx context.Context, lister agent.WorkspaceDirectoryLister, root, stage string) {
 	t.Helper()
-	lister, ok := reader.(agent.WorkspaceDirectoryLister)
-	if !ok {
-		t.Fatal("workspace directory owner missing")
-	}
 	result, err := lister.ListWorkspaceDirectory(ctx, "", 1000)
 	if err != nil || result.Truncated {
 		t.Fatal("workspace directory failed", stage, err)

apps/daemon/internal/agent/claudesdk/workspace_live_linux_test.go

@@ -59,20 +59,19 @@ func TestLiveClaudeWorkspaceFactory(t *testing.T) {
 			t.Fatal(err)
 		}
 	}
-	liveWorkspaceReadFixtures(t, config.Workspace.Directory)
+	liveWorkspaceDirectoryFixtures(t, config.Workspace.Directory)
 	heartbeat := filepath.Join(config.Workspace.Directory, "heartbeat.txt")
 	artifact := filepath.Join(config.Workspace.Directory, "value.txt")
 	type evidence struct {
-		Reads      []liveWorkspaceRead `json:"reads,omitempty"`
-		RunID      string              `json:"run_id"`
-		Events     []proto.Envelope    `json:"events"`
-		Done       proto.DonePayload   `json:"done"`
-		Failure    string              `json:"failure,omitempty"`
-		Cancelled  bool                `json:"cancelled"`
-		CancelMS   int64               `json:"cancel_ms,omitempty"`
-		BridgePID  int                 `json:"bridge_pid"`
-		Terminals  int                 `json:"terminals"`
-		Heartbeats []string            `json:"heartbeats,omitempty"`
+		RunID      string            `json:"run_id"`
+		Events     []proto.Envelope  `json:"events"`
+		Done       proto.DonePayload `json:"done"`
+		Failure    string            `json:"failure,omitempty"`
+		Cancelled  bool              `json:"cancelled"`
+		CancelMS   int64             `json:"cancel_ms,omitempty"`
+		BridgePID  int               `json:"bridge_pid"`
+		Terminals  int               `json:"terminals"`
+		Heartbeats []string          `json:"heartbeats,omitempty"`
 	}
 	writeEvidence := func(name string, proof evidence) {
 		t.Helper()
@@ -106,7 +105,7 @@ func TestLiveClaudeWorkspaceFactory(t *testing.T) {
 		s := running.(*session)
 		defer s.Cancel(context.Background())
 		proof.BridgePID = s.process.Cmd.Process.Pid
-		proof.Reads = append(proof.Reads, liveWorkspaceReads(t, ctx, s, config.Workspace.Directory, "active", "read-binary.bin", "read-empty.bin", "read-large.bin")...)
+		liveWorkspaceDirectories(t, ctx, s, config.Workspace.Directory, "active")
 		ticker := time.NewTicker(80 * time.Millisecond)
 		defer ticker.Stop()
 		for out != nil {
@@ -116,7 +115,7 @@ func TestLiveClaudeWorkspaceFactory(t *testing.T) {
 			case <-ticker.C:
 				value, _ := os.ReadFile(heartbeat)
 				if cancelOnEffect && !proof.Cancelled && len(value) > 0 && string(value) != "0" && string(value) != "1" {
-					proof.Reads = append(proof.Reads, liveWorkspaceReads(t, ctx, s, config.Workspace.Directory, "effect", "value.txt")...)
+					liveWorkspaceDirectories(t, ctx, s, config.Workspace.Directory, "effect")
 					started := time.Now()
 					if err := s.Cancel(ctx); err != nil {
 						t.Fatal("factory cancellation failed", err)