Fix: clear maximized state on last surface close, add cache-invalidating refresh RPC, probe truncated files for binary content

- ChatView: clear maximizedRightPanelThreadKey when closeRightPanelSurface
leaves no active surface, preventing the chat column from staying at w-0
after the last right-panel tab is closed.
- Add projects.refreshEntries RPC that invalidates the workspace index cache
before listing, so the explicit refresh button in FileBrowserPanel returns
up-to-date filesystem state instead of stale cached data.
- WorkspaceFileSystem.readFile: when a file is truncated (>1 MB), read an
additional 8 KB probe from the end of the file and check for NUL bytes,
catching binary files whose first null appears beyond the preview window.

Author: cursoragent

apps/server/src/workspace/Layers/WorkspaceFileSystem.ts

@@ -57,6 +57,20 @@ export const makeWorkspaceFileSystem = Effect.gen(function* () {
 if(fileBytes.includes(0)){
 thrownewError("Binary files cannot be previewed as text.");
 }
+if(stat.size>PROJECT_READ_FILE_MAX_BYTES){
+constprobeSize=8192;
+constprobeOffset=Math.max(bytesToRead,stat.size-probeSize);
+constprobeBuf=Buffer.alloc(Math.min(probeSize,stat.size-probeOffset));
+const{bytesRead: probeRead}=awaithandle.read(
+probeBuf,
+0,
+probeBuf.length,
+probeOffset,
+);
+if(probeBuf.subarray(0,probeRead).includes(0)){
+thrownewError("Binary files cannot be previewed as text.");
+}
+}
 constcontents=newTextDecoder("utf-8").decode(fileBytes);
 return{
 relativePath: target.relativePath,

apps/server/src/ws.ts

@@ -163,6 +163,7 @@ const RPC_REQUIRED_SCOPE = new Map<string, AuthEnvironmentScope>([
 [WS_METHODS.sourceControlCloneRepository,AuthOrchestrationOperateScope],
 [WS_METHODS.sourceControlPublishRepository,AuthOrchestrationOperateScope],
 [WS_METHODS.projectsListEntries,AuthOrchestrationReadScope],
+[WS_METHODS.projectsRefreshEntries,AuthOrchestrationReadScope],
 [WS_METHODS.projectsReadFile,AuthOrchestrationReadScope],
 [WS_METHODS.projectsSearchEntries,AuthOrchestrationReadScope],
 [WS_METHODS.projectsWriteFile,AuthOrchestrationOperateScope],
@@ -1190,6 +1191,21 @@ const makeWsRpcLayer = (currentSession: AuthenticatedSession) =>
 ),
 {"rpc.aggregate": "workspace"},
 ),
+[WS_METHODS.projectsRefreshEntries]: (input)=>
+observeRpcEffect(
+WS_METHODS.projectsRefreshEntries,
+workspaceEntries.invalidate(input.cwd).pipe(
+Effect.andThen(()=>workspaceEntries.list(input)),
+Effect.mapError(
+(cause)=>
+newProjectListEntriesError({
+message: `Failed to refresh workspace entries: ${cause.detail}`,
+ cause,
+}),
+),
+),
+{"rpc.aggregate": "workspace"},
+),
 [WS_METHODS.projectsReadFile]: (input)=>
 observeRpcEffect(
 WS_METHODS.projectsReadFile,

apps/web/src/components/ChatView.tsx

@@ -3067,6 +3067,9 @@ export default function ChatView(props: ChatViewProps) {
 useRightPanelStore.getState().byThreadKey,
 activeThreadRef,
 );
+if(!nextActiveSurface){
+setMaximizedRightPanelThreadKey(null);
+}
 if(nextActiveSurface?.kind==="preview"&&nextActiveSurface.resourceId){
 usePreviewStateStore.getState().setActiveTab(activeThreadRef,nextActiveSurface.resourceId);
 }

apps/web/src/components/files/FileBrowserPanel.tsx

@@ -62,37 +62,44 @@ export default function FileBrowserPanel({
 unsafeCSS: TREE_UNSAFE_CSS,
 });
 
-constloadEntries=useCallback(()=>{
-constapi=readEnvironmentApi(environmentId);
-requestGenerationRef.current+=1;
-constgeneration=requestGenerationRef.current;
-setIsLoadingEntries(true);
-setEntriesError(null);
-
-if(!api){
-setEntriesError("Environment is not connected.");
-setIsLoadingEntries(false);
-return;
-}
+constloadEntries=useCallback(
+(options?: {refresh?: boolean})=>{
+constapi=readEnvironmentApi(environmentId);
+requestGenerationRef.current+=1;
+constgeneration=requestGenerationRef.current;
+setIsLoadingEntries(true);
+setEntriesError(null);
 
-voidapi.projects.listEntries({ cwd }).then(
-(result)=>{
-if(generation!==requestGenerationRef.current)return;
-entryKindsRef.current=newMap(
-result.entries.map((entry)=>[entry.path,entry.kind]asconst),
-);
-setEntries(result.entries);
-setIsTruncated(result.truncated);
-model.resetPaths(result.entries.map(treePath));
+if(!api){
+setEntriesError("Environment is not connected.");
 setIsLoadingEntries(false);
-},
-(error: unknown)=>{
-if(generation!==requestGenerationRef.current)return;
-setEntriesError(errorinstanceofError ? error.message : String(error));
-setIsLoadingEntries(false);
-},
-);
-},[cwd,environmentId,model]);
+return;
+}
+
+constrequest=options?.refresh
+ ? api.projects.refreshEntries({ cwd })
+ : api.projects.listEntries({ cwd });
+
+voidrequest.then(
+(result)=>{
+if(generation!==requestGenerationRef.current)return;
+entryKindsRef.current=newMap(
+result.entries.map((entry)=>[entry.path,entry.kind]asconst),
+);
+setEntries(result.entries);
+setIsTruncated(result.truncated);
+model.resetPaths(result.entries.map(treePath));
+setIsLoadingEntries(false);
+},
+(error: unknown)=>{
+if(generation!==requestGenerationRef.current)return;
+setEntriesError(errorinstanceofError ? error.message : String(error));
+setIsLoadingEntries(false);
+},
+);
+},
+[cwd,environmentId,model],
+);
 
 useEffect(()=>{
 loadEntries();
@@ -128,7 +135,7 @@ export default function FileBrowserPanel({
 type="button"
 className="rounded-md p-1.5 text-muted-foreground hover:bg-accent hover:text-foreground"
 aria-label="Refresh workspace files"
-onClick={loadEntries}
+onClick={()=>loadEntries({refresh: true})}
 >
 <RefreshCwclassName={cn("size-3.5",isLoadingEntries&&"animate-spin")}/>
 </button>

apps/web/src/environmentApi.ts

@@ -20,6 +20,7 @@ export function createEnvironmentApi(rpcClient: WsRpcClient): EnvironmentApi {
 },
 projects: {
 listEntries: rpcClient.projects.listEntries,
+refreshEntries: rpcClient.projects.refreshEntries,
 readFile: rpcClient.projects.readFile,
 searchEntries: rpcClient.projects.searchEntries,
 writeFile: rpcClient.projects.writeFile,

apps/web/src/environments/runtime/service.threadSubscriptions.test.ts

@@ -122,6 +122,7 @@ vi.mock("@t3tools/client-runtime", async (importOriginal) => {
 },
 projects: {
 listEntries: vi.fn(),
+refreshEntries: vi.fn(),
 readFile: vi.fn(),
 searchEntries: vi.fn(),
 writeFile: vi.fn(),

apps/web/src/localApi.test.ts

@@ -56,6 +56,7 @@ const rpcClientMock = {
 },
 projects: {
 listEntries: vi.fn(),
+refreshEntries: vi.fn(),
 readFile: vi.fn(),
 searchEntries: vi.fn(),
 writeFile: vi.fn(),

packages/client-runtime/src/wsRpcClient.ts

@@ -97,6 +97,7 @@ export interface WsRpcClient {
 };
 readonlyprojects: {
 readonlylistEntries: RpcUnaryMethod<typeofWS_METHODS.projectsListEntries>;
+readonlyrefreshEntries: RpcUnaryMethod<typeofWS_METHODS.projectsRefreshEntries>;
 readonlyreadFile: RpcUnaryMethod<typeofWS_METHODS.projectsReadFile>;
 readonlysearchEntries: RpcUnaryMethod<typeofWS_METHODS.projectsSearchEntries>;
 readonlywriteFile: RpcUnaryMethod<typeofWS_METHODS.projectsWriteFile>;
@@ -271,6 +272,8 @@ export function createWsRpcClient(
 projects: {
 listEntries: (input)=>
 transport.request((client)=>client[WS_METHODS.projectsListEntries](input)),
+refreshEntries: (input)=>
+transport.request((client)=>client[WS_METHODS.projectsRefreshEntries](input)),
 readFile: (input)=>
 transport.request((client)=>client[WS_METHODS.projectsReadFile](input)),
 searchEntries: (input)=>

packages/contracts/src/ipc.ts

@@ -1115,6 +1115,7 @@ export interface EnvironmentApi {
 };
 projects: {
 listEntries: (input: ProjectListEntriesInput)=>Promise<ProjectListEntriesResult>;
+refreshEntries: (input: ProjectListEntriesInput)=>Promise<ProjectListEntriesResult>;
 readFile: (input: ProjectReadFileInput)=>Promise<ProjectReadFileResult>;
 searchEntries: (input: ProjectSearchEntriesInput)=>Promise<ProjectSearchEntriesResult>;
 writeFile: (input: ProjectWriteFileInput)=>Promise<ProjectWriteFileResult>;

packages/contracts/src/rpc.ts

@@ -148,6 +148,7 @@ export const WS_METHODS = {
 projectsAdd: "projects.add",
 projectsRemove: "projects.remove",
 projectsListEntries: "projects.listEntries",
+projectsRefreshEntries: "projects.refreshEntries",
 projectsReadFile: "projects.readFile",
 projectsSearchEntries: "projects.searchEntries",
 projectsWriteFile: "projects.writeFile",
@@ -364,6 +365,12 @@ export const WsProjectsListEntriesRpc = Rpc.make(WS_METHODS.projectsListEntries,
 error: Schema.Union([ProjectListEntriesError,EnvironmentAuthorizationError]),
 });
 
+exportconstWsProjectsRefreshEntriesRpc=Rpc.make(WS_METHODS.projectsRefreshEntries,{
+payload: ProjectListEntriesInput,
+success: ProjectListEntriesResult,
+error: Schema.Union([ProjectListEntriesError,EnvironmentAuthorizationError]),
+});
+
 exportconstWsProjectsReadFileRpc=Rpc.make(WS_METHODS.projectsReadFile,{
 payload: ProjectReadFileInput,
 success: ProjectReadFileResult,
@@ -697,6 +704,7 @@ export const WsRpcGroup = RpcGroup.make(
 WsSourceControlCloneRepositoryRpc,
 WsSourceControlPublishRepositoryRpc,
 WsProjectsListEntriesRpc,
+WsProjectsRefreshEntriesRpc,
 WsProjectsReadFileRpc,
 WsProjectsSearchEntriesRpc,
 WsProjectsWriteFileRpc,

apps/server/src/workspace/Layers/WorkspaceFileSystem.ts

@@ -57,6 +57,20 @@ export const makeWorkspaceFileSystem = Effect.gen(function* () {
 if(fileBytes.includes(0)){
 thrownewError("Binary files cannot be previewed as text.");
 }
+if(stat.size>PROJECT_READ_FILE_MAX_BYTES){
+constprobeSize=8192;
+constprobeOffset=Math.max(bytesToRead,stat.size-probeSize);
+constprobeBuf=Buffer.alloc(Math.min(probeSize,stat.size-probeOffset));
+const{bytesRead: probeRead}=awaithandle.read(
+probeBuf,
+0,
+probeBuf.length,
+probeOffset,
+);
+if(probeBuf.subarray(0,probeRead).includes(0)){
+thrownewError("Binary files cannot be previewed as text.");
+}
+}
 constcontents=newTextDecoder("utf-8").decode(fileBytes);
 return{
 relativePath: target.relativePath,

apps/server/src/ws.ts

@@ -163,6 +163,7 @@ const RPC_REQUIRED_SCOPE = new Map<string, AuthEnvironmentScope>([
 [WS_METHODS.sourceControlCloneRepository,AuthOrchestrationOperateScope],
 [WS_METHODS.sourceControlPublishRepository,AuthOrchestrationOperateScope],
 [WS_METHODS.projectsListEntries,AuthOrchestrationReadScope],
+[WS_METHODS.projectsRefreshEntries,AuthOrchestrationReadScope],
 [WS_METHODS.projectsReadFile,AuthOrchestrationReadScope],
 [WS_METHODS.projectsSearchEntries,AuthOrchestrationReadScope],
 [WS_METHODS.projectsWriteFile,AuthOrchestrationOperateScope],
@@ -1190,6 +1191,21 @@ const makeWsRpcLayer = (currentSession: AuthenticatedSession) =>
 ),
 {"rpc.aggregate": "workspace"},
 ),
+[WS_METHODS.projectsRefreshEntries]: (input)=>
+observeRpcEffect(
+WS_METHODS.projectsRefreshEntries,
+workspaceEntries.invalidate(input.cwd).pipe(
+Effect.andThen(()=>workspaceEntries.list(input)),
+Effect.mapError(
+(cause)=>
+newProjectListEntriesError({
+message: `Failed to refresh workspace entries: ${cause.detail}`,
+ cause,
+}),
+),
+),
+{"rpc.aggregate": "workspace"},
+),
 [WS_METHODS.projectsReadFile]: (input)=>
 observeRpcEffect(
 WS_METHODS.projectsReadFile,

apps/web/src/components/ChatView.tsx

@@ -3067,6 +3067,9 @@ export default function ChatView(props: ChatViewProps) {
 useRightPanelStore.getState().byThreadKey,
 activeThreadRef,
 );
+if(!nextActiveSurface){
+setMaximizedRightPanelThreadKey(null);
+}
 if(nextActiveSurface?.kind==="preview"&&nextActiveSurface.resourceId){
 usePreviewStateStore.getState().setActiveTab(activeThreadRef,nextActiveSurface.resourceId);
 }

apps/web/src/components/files/FileBrowserPanel.tsx

@@ -62,37 +62,44 @@ export default function FileBrowserPanel({
 unsafeCSS: TREE_UNSAFE_CSS,
 });
 
-constloadEntries=useCallback(()=>{
-constapi=readEnvironmentApi(environmentId);
-requestGenerationRef.current+=1;
-constgeneration=requestGenerationRef.current;
-setIsLoadingEntries(true);
-setEntriesError(null);
-
-if(!api){
-setEntriesError("Environment is not connected.");
-setIsLoadingEntries(false);
-return;
-}
+constloadEntries=useCallback(
+(options?: {refresh?: boolean})=>{
+constapi=readEnvironmentApi(environmentId);
+requestGenerationRef.current+=1;
+constgeneration=requestGenerationRef.current;
+setIsLoadingEntries(true);
+setEntriesError(null);
 
-voidapi.projects.listEntries({ cwd }).then(
-(result)=>{
-if(generation!==requestGenerationRef.current)return;
-entryKindsRef.current=newMap(
-result.entries.map((entry)=>[entry.path,entry.kind]asconst),
-);
-setEntries(result.entries);
-setIsTruncated(result.truncated);
-model.resetPaths(result.entries.map(treePath));
+if(!api){
+setEntriesError("Environment is not connected.");
 setIsLoadingEntries(false);
-},
-(error: unknown)=>{
-if(generation!==requestGenerationRef.current)return;
-setEntriesError(errorinstanceofError ? error.message : String(error));
-setIsLoadingEntries(false);
-},
-);
-},[cwd,environmentId,model]);
+return;
+}
+
+constrequest=options?.refresh
+ ? api.projects.refreshEntries({ cwd })
+ : api.projects.listEntries({ cwd });
+
+voidrequest.then(
+(result)=>{
+if(generation!==requestGenerationRef.current)return;
+entryKindsRef.current=newMap(
+result.entries.map((entry)=>[entry.path,entry.kind]asconst),
+);
+setEntries(result.entries);
+setIsTruncated(result.truncated);
+model.resetPaths(result.entries.map(treePath));
+setIsLoadingEntries(false);
+},
+(error: unknown)=>{
+if(generation!==requestGenerationRef.current)return;
+setEntriesError(errorinstanceofError ? error.message : String(error));
+setIsLoadingEntries(false);
+},
+);
+},
+[cwd,environmentId,model],
+);
 
 useEffect(()=>{
 loadEntries();
@@ -128,7 +135,7 @@ export default function FileBrowserPanel({
 type="button"
 className="rounded-md p-1.5 text-muted-foreground hover:bg-accent hover:text-foreground"
 aria-label="Refresh workspace files"
-onClick={loadEntries}
+onClick={()=>loadEntries({refresh: true})}
 >
 <RefreshCwclassName={cn("size-3.5",isLoadingEntries&&"animate-spin")}/>
 </button>

apps/web/src/environmentApi.ts

@@ -20,6 +20,7 @@ export function createEnvironmentApi(rpcClient: WsRpcClient): EnvironmentApi {
 },
 projects: {
 listEntries: rpcClient.projects.listEntries,
+refreshEntries: rpcClient.projects.refreshEntries,
 readFile: rpcClient.projects.readFile,
 searchEntries: rpcClient.projects.searchEntries,
 writeFile: rpcClient.projects.writeFile,

apps/web/src/environments/runtime/service.threadSubscriptions.test.ts

@@ -122,6 +122,7 @@ vi.mock("@t3tools/client-runtime", async (importOriginal) => {
 },
 projects: {
 listEntries: vi.fn(),
+refreshEntries: vi.fn(),
 readFile: vi.fn(),
 searchEntries: vi.fn(),
 writeFile: vi.fn(),

apps/web/src/localApi.test.ts

@@ -56,6 +56,7 @@ const rpcClientMock = {
 },
 projects: {
 listEntries: vi.fn(),
+refreshEntries: vi.fn(),
 readFile: vi.fn(),
 searchEntries: vi.fn(),
 writeFile: vi.fn(),

packages/client-runtime/src/wsRpcClient.ts

@@ -97,6 +97,7 @@ export interface WsRpcClient {
 };
 readonlyprojects: {
 readonlylistEntries: RpcUnaryMethod<typeofWS_METHODS.projectsListEntries>;
+readonlyrefreshEntries: RpcUnaryMethod<typeofWS_METHODS.projectsRefreshEntries>;
 readonlyreadFile: RpcUnaryMethod<typeofWS_METHODS.projectsReadFile>;
 readonlysearchEntries: RpcUnaryMethod<typeofWS_METHODS.projectsSearchEntries>;
 readonlywriteFile: RpcUnaryMethod<typeofWS_METHODS.projectsWriteFile>;
@@ -271,6 +272,8 @@ export function createWsRpcClient(
 projects: {
 listEntries: (input)=>
 transport.request((client)=>client[WS_METHODS.projectsListEntries](input)),
+refreshEntries: (input)=>
+transport.request((client)=>client[WS_METHODS.projectsRefreshEntries](input)),
 readFile: (input)=>
 transport.request((client)=>client[WS_METHODS.projectsReadFile](input)),
 searchEntries: (input)=>

packages/contracts/src/ipc.ts

@@ -1115,6 +1115,7 @@ export interface EnvironmentApi {
 };
 projects: {
 listEntries: (input: ProjectListEntriesInput)=>Promise<ProjectListEntriesResult>;
+refreshEntries: (input: ProjectListEntriesInput)=>Promise<ProjectListEntriesResult>;
 readFile: (input: ProjectReadFileInput)=>Promise<ProjectReadFileResult>;
 searchEntries: (input: ProjectSearchEntriesInput)=>Promise<ProjectSearchEntriesResult>;
 writeFile: (input: ProjectWriteFileInput)=>Promise<ProjectWriteFileResult>;

packages/contracts/src/rpc.ts

@@ -148,6 +148,7 @@ export const WS_METHODS = {
 projectsAdd: "projects.add",
 projectsRemove: "projects.remove",
 projectsListEntries: "projects.listEntries",
+projectsRefreshEntries: "projects.refreshEntries",
 projectsReadFile: "projects.readFile",
 projectsSearchEntries: "projects.searchEntries",
 projectsWriteFile: "projects.writeFile",
@@ -364,6 +365,12 @@ export const WsProjectsListEntriesRpc = Rpc.make(WS_METHODS.projectsListEntries,
 error: Schema.Union([ProjectListEntriesError,EnvironmentAuthorizationError]),
 });
 
+exportconstWsProjectsRefreshEntriesRpc=Rpc.make(WS_METHODS.projectsRefreshEntries,{
+payload: ProjectListEntriesInput,
+success: ProjectListEntriesResult,
+error: Schema.Union([ProjectListEntriesError,EnvironmentAuthorizationError]),
+});
+
 exportconstWsProjectsReadFileRpc=Rpc.make(WS_METHODS.projectsReadFile,{
 payload: ProjectReadFileInput,
 success: ProjectReadFileResult,
@@ -697,6 +704,7 @@ export const WsRpcGroup = RpcGroup.make(
 WsSourceControlCloneRepositoryRpc,
 WsSourceControlPublishRepositoryRpc,
 WsProjectsListEntriesRpc,
+WsProjectsRefreshEntriesRpc,
 WsProjectsReadFileRpc,
 WsProjectsSearchEntriesRpc,
 WsProjectsWriteFileRpc,

apps/server/src/workspace/Layers/WorkspaceFileSystem.ts

@@ -57,6 +57,20 @@ export const makeWorkspaceFileSystem = Effect.gen(function* () {
 if(fileBytes.includes(0)){
 thrownewError("Binary files cannot be previewed as text.");
 }
+if(stat.size>PROJECT_READ_FILE_MAX_BYTES){
+constprobeSize=8192;
+constprobeOffset=Math.max(bytesToRead,stat.size-probeSize);
+constprobeBuf=Buffer.alloc(Math.min(probeSize,stat.size-probeOffset));
+const{bytesRead: probeRead}=awaithandle.read(
+probeBuf,
+0,
+probeBuf.length,
+probeOffset,
+);
+if(probeBuf.subarray(0,probeRead).includes(0)){
+thrownewError("Binary files cannot be previewed as text.");
+}
+}
 constcontents=newTextDecoder("utf-8").decode(fileBytes);
 return{
 relativePath: target.relativePath,

apps/server/src/ws.ts

@@ -163,6 +163,7 @@ const RPC_REQUIRED_SCOPE = new Map<string, AuthEnvironmentScope>([
 [WS_METHODS.sourceControlCloneRepository,AuthOrchestrationOperateScope],
 [WS_METHODS.sourceControlPublishRepository,AuthOrchestrationOperateScope],
 [WS_METHODS.projectsListEntries,AuthOrchestrationReadScope],
+[WS_METHODS.projectsRefreshEntries,AuthOrchestrationReadScope],
 [WS_METHODS.projectsReadFile,AuthOrchestrationReadScope],
 [WS_METHODS.projectsSearchEntries,AuthOrchestrationReadScope],
 [WS_METHODS.projectsWriteFile,AuthOrchestrationOperateScope],
@@ -1190,6 +1191,21 @@ const makeWsRpcLayer = (currentSession: AuthenticatedSession) =>
 ),
 {"rpc.aggregate": "workspace"},
 ),
+[WS_METHODS.projectsRefreshEntries]: (input)=>
+observeRpcEffect(
+WS_METHODS.projectsRefreshEntries,
+workspaceEntries.invalidate(input.cwd).pipe(
+Effect.andThen(()=>workspaceEntries.list(input)),
+Effect.mapError(
+(cause)=>
+newProjectListEntriesError({
+message: `Failed to refresh workspace entries: ${cause.detail}`,
+ cause,
+}),
+),
+),
+{"rpc.aggregate": "workspace"},
+),
 [WS_METHODS.projectsReadFile]: (input)=>
 observeRpcEffect(
 WS_METHODS.projectsReadFile,

apps/web/src/components/ChatView.tsx

@@ -3067,6 +3067,9 @@ export default function ChatView(props: ChatViewProps) {
 useRightPanelStore.getState().byThreadKey,
 activeThreadRef,
 );
+if(!nextActiveSurface){
+setMaximizedRightPanelThreadKey(null);
+}
 if(nextActiveSurface?.kind==="preview"&&nextActiveSurface.resourceId){
 usePreviewStateStore.getState().setActiveTab(activeThreadRef,nextActiveSurface.resourceId);
 }

apps/web/src/components/files/FileBrowserPanel.tsx

@@ -62,37 +62,44 @@ export default function FileBrowserPanel({
 unsafeCSS: TREE_UNSAFE_CSS,
 });
 
-constloadEntries=useCallback(()=>{
-constapi=readEnvironmentApi(environmentId);
-requestGenerationRef.current+=1;
-constgeneration=requestGenerationRef.current;
-setIsLoadingEntries(true);
-setEntriesError(null);
-
-if(!api){
-setEntriesError("Environment is not connected.");
-setIsLoadingEntries(false);
-return;
-}
+constloadEntries=useCallback(
+(options?: {refresh?: boolean})=>{
+constapi=readEnvironmentApi(environmentId);
+requestGenerationRef.current+=1;
+constgeneration=requestGenerationRef.current;
+setIsLoadingEntries(true);
+setEntriesError(null);
 
-voidapi.projects.listEntries({ cwd }).then(
-(result)=>{
-if(generation!==requestGenerationRef.current)return;
-entryKindsRef.current=newMap(
-result.entries.map((entry)=>[entry.path,entry.kind]asconst),
-);
-setEntries(result.entries);
-setIsTruncated(result.truncated);
-model.resetPaths(result.entries.map(treePath));
+if(!api){
+setEntriesError("Environment is not connected.");
 setIsLoadingEntries(false);
-},
-(error: unknown)=>{
-if(generation!==requestGenerationRef.current)return;
-setEntriesError(errorinstanceofError ? error.message : String(error));
-setIsLoadingEntries(false);
-},
-);
-},[cwd,environmentId,model]);
+return;
+}
+
+constrequest=options?.refresh
+ ? api.projects.refreshEntries({ cwd })
+ : api.projects.listEntries({ cwd });
+
+voidrequest.then(
+(result)=>{
+if(generation!==requestGenerationRef.current)return;
+entryKindsRef.current=newMap(
+result.entries.map((entry)=>[entry.path,entry.kind]asconst),
+);
+setEntries(result.entries);
+setIsTruncated(result.truncated);
+model.resetPaths(result.entries.map(treePath));
+setIsLoadingEntries(false);
+},
+(error: unknown)=>{
+if(generation!==requestGenerationRef.current)return;
+setEntriesError(errorinstanceofError ? error.message : String(error));
+setIsLoadingEntries(false);
+},
+);
+},
+[cwd,environmentId,model],
+);
 
 useEffect(()=>{
 loadEntries();
@@ -128,7 +135,7 @@ export default function FileBrowserPanel({
 type="button"
 className="rounded-md p-1.5 text-muted-foreground hover:bg-accent hover:text-foreground"
 aria-label="Refresh workspace files"
-onClick={loadEntries}
+onClick={()=>loadEntries({refresh: true})}
 >
 <RefreshCwclassName={cn("size-3.5",isLoadingEntries&&"animate-spin")}/>
 </button>

apps/web/src/environmentApi.ts

@@ -20,6 +20,7 @@ export function createEnvironmentApi(rpcClient: WsRpcClient): EnvironmentApi {
 },
 projects: {
 listEntries: rpcClient.projects.listEntries,
+refreshEntries: rpcClient.projects.refreshEntries,
 readFile: rpcClient.projects.readFile,
 searchEntries: rpcClient.projects.searchEntries,
 writeFile: rpcClient.projects.writeFile,

apps/web/src/environments/runtime/service.threadSubscriptions.test.ts

@@ -122,6 +122,7 @@ vi.mock("@t3tools/client-runtime", async (importOriginal) => {
 },
 projects: {
 listEntries: vi.fn(),
+refreshEntries: vi.fn(),
 readFile: vi.fn(),
 searchEntries: vi.fn(),
 writeFile: vi.fn(),

apps/web/src/localApi.test.ts

@@ -56,6 +56,7 @@ const rpcClientMock = {
 },
 projects: {
 listEntries: vi.fn(),
+refreshEntries: vi.fn(),
 readFile: vi.fn(),
 searchEntries: vi.fn(),
 writeFile: vi.fn(),

packages/client-runtime/src/wsRpcClient.ts

@@ -97,6 +97,7 @@ export interface WsRpcClient {
 };
 readonlyprojects: {
 readonlylistEntries: RpcUnaryMethod<typeofWS_METHODS.projectsListEntries>;
+readonlyrefreshEntries: RpcUnaryMethod<typeofWS_METHODS.projectsRefreshEntries>;
 readonlyreadFile: RpcUnaryMethod<typeofWS_METHODS.projectsReadFile>;
 readonlysearchEntries: RpcUnaryMethod<typeofWS_METHODS.projectsSearchEntries>;
 readonlywriteFile: RpcUnaryMethod<typeofWS_METHODS.projectsWriteFile>;
@@ -271,6 +272,8 @@ export function createWsRpcClient(
 projects: {
 listEntries: (input)=>
 transport.request((client)=>client[WS_METHODS.projectsListEntries](input)),
+refreshEntries: (input)=>
+transport.request((client)=>client[WS_METHODS.projectsRefreshEntries](input)),
 readFile: (input)=>
 transport.request((client)=>client[WS_METHODS.projectsReadFile](input)),
 searchEntries: (input)=>

packages/contracts/src/ipc.ts

@@ -1115,6 +1115,7 @@ export interface EnvironmentApi {
 };
 projects: {
 listEntries: (input: ProjectListEntriesInput)=>Promise<ProjectListEntriesResult>;
+refreshEntries: (input: ProjectListEntriesInput)=>Promise<ProjectListEntriesResult>;
 readFile: (input: ProjectReadFileInput)=>Promise<ProjectReadFileResult>;
 searchEntries: (input: ProjectSearchEntriesInput)=>Promise<ProjectSearchEntriesResult>;
 writeFile: (input: ProjectWriteFileInput)=>Promise<ProjectWriteFileResult>;

packages/contracts/src/rpc.ts

@@ -148,6 +148,7 @@ export const WS_METHODS = {
 projectsAdd: "projects.add",
 projectsRemove: "projects.remove",
 projectsListEntries: "projects.listEntries",
+projectsRefreshEntries: "projects.refreshEntries",
 projectsReadFile: "projects.readFile",
 projectsSearchEntries: "projects.searchEntries",
 projectsWriteFile: "projects.writeFile",
@@ -364,6 +365,12 @@ export const WsProjectsListEntriesRpc = Rpc.make(WS_METHODS.projectsListEntries,
 error: Schema.Union([ProjectListEntriesError,EnvironmentAuthorizationError]),
 });
 
+exportconstWsProjectsRefreshEntriesRpc=Rpc.make(WS_METHODS.projectsRefreshEntries,{
+payload: ProjectListEntriesInput,
+success: ProjectListEntriesResult,
+error: Schema.Union([ProjectListEntriesError,EnvironmentAuthorizationError]),
+});
+
 exportconstWsProjectsReadFileRpc=Rpc.make(WS_METHODS.projectsReadFile,{
 payload: ProjectReadFileInput,
 success: ProjectReadFileResult,
@@ -697,6 +704,7 @@ export const WsRpcGroup = RpcGroup.make(
 WsSourceControlCloneRepositoryRpc,
 WsSourceControlPublishRepositoryRpc,
 WsProjectsListEntriesRpc,
+WsProjectsRefreshEntriesRpc,
 WsProjectsReadFileRpc,
 WsProjectsSearchEntriesRpc,
 WsProjectsWriteFileRpc,

apps/server/src/workspace/Layers/WorkspaceFileSystem.ts

@@ -57,6 +57,20 @@ export const makeWorkspaceFileSystem = Effect.gen(function* () {
 if(fileBytes.includes(0)){
 thrownewError("Binary files cannot be previewed as text.");
 }
+if(stat.size>PROJECT_READ_FILE_MAX_BYTES){
+constprobeSize=8192;
+constprobeOffset=Math.max(bytesToRead,stat.size-probeSize);
+constprobeBuf=Buffer.alloc(Math.min(probeSize,stat.size-probeOffset));
+const{bytesRead: probeRead}=awaithandle.read(
+probeBuf,
+0,
+probeBuf.length,
+probeOffset,
+);
+if(probeBuf.subarray(0,probeRead).includes(0)){
+thrownewError("Binary files cannot be previewed as text.");
+}
+}
 constcontents=newTextDecoder("utf-8").decode(fileBytes);
 return{
 relativePath: target.relativePath,

apps/server/src/ws.ts

@@ -163,6 +163,7 @@ const RPC_REQUIRED_SCOPE = new Map<string, AuthEnvironmentScope>([
 [WS_METHODS.sourceControlCloneRepository,AuthOrchestrationOperateScope],
 [WS_METHODS.sourceControlPublishRepository,AuthOrchestrationOperateScope],
 [WS_METHODS.projectsListEntries,AuthOrchestrationReadScope],
+[WS_METHODS.projectsRefreshEntries,AuthOrchestrationReadScope],
 [WS_METHODS.projectsReadFile,AuthOrchestrationReadScope],
 [WS_METHODS.projectsSearchEntries,AuthOrchestrationReadScope],
 [WS_METHODS.projectsWriteFile,AuthOrchestrationOperateScope],
@@ -1190,6 +1191,21 @@ const makeWsRpcLayer = (currentSession: AuthenticatedSession) =>
 ),
 {"rpc.aggregate": "workspace"},
 ),
+[WS_METHODS.projectsRefreshEntries]: (input)=>
+observeRpcEffect(
+WS_METHODS.projectsRefreshEntries,
+workspaceEntries.invalidate(input.cwd).pipe(
+Effect.andThen(()=>workspaceEntries.list(input)),
+Effect.mapError(
+(cause)=>
+newProjectListEntriesError({
+message: `Failed to refresh workspace entries: ${cause.detail}`,
+ cause,
+}),
+),
+),
+{"rpc.aggregate": "workspace"},
+),
 [WS_METHODS.projectsReadFile]: (input)=>
 observeRpcEffect(
 WS_METHODS.projectsReadFile,

apps/web/src/components/ChatView.tsx

@@ -3067,6 +3067,9 @@ export default function ChatView(props: ChatViewProps) {
 useRightPanelStore.getState().byThreadKey,
 activeThreadRef,
 );
+if(!nextActiveSurface){
+setMaximizedRightPanelThreadKey(null);
+}
 if(nextActiveSurface?.kind==="preview"&&nextActiveSurface.resourceId){
 usePreviewStateStore.getState().setActiveTab(activeThreadRef,nextActiveSurface.resourceId);
 }

apps/web/src/components/files/FileBrowserPanel.tsx

@@ -62,37 +62,44 @@ export default function FileBrowserPanel({
 unsafeCSS: TREE_UNSAFE_CSS,
 });
 
-constloadEntries=useCallback(()=>{
-constapi=readEnvironmentApi(environmentId);
-requestGenerationRef.current+=1;
-constgeneration=requestGenerationRef.current;
-setIsLoadingEntries(true);
-setEntriesError(null);
-
-if(!api){
-setEntriesError("Environment is not connected.");
-setIsLoadingEntries(false);
-return;
-}
+constloadEntries=useCallback(
+(options?: {refresh?: boolean})=>{
+constapi=readEnvironmentApi(environmentId);
+requestGenerationRef.current+=1;
+constgeneration=requestGenerationRef.current;
+setIsLoadingEntries(true);
+setEntriesError(null);
 
-voidapi.projects.listEntries({ cwd }).then(
-(result)=>{
-if(generation!==requestGenerationRef.current)return;
-entryKindsRef.current=newMap(
-result.entries.map((entry)=>[entry.path,entry.kind]asconst),
-);
-setEntries(result.entries);
-setIsTruncated(result.truncated);
-model.resetPaths(result.entries.map(treePath));
+if(!api){
+setEntriesError("Environment is not connected.");
 setIsLoadingEntries(false);
-},
-(error: unknown)=>{
-if(generation!==requestGenerationRef.current)return;
-setEntriesError(errorinstanceofError ? error.message : String(error));
-setIsLoadingEntries(false);
-},
-);
-},[cwd,environmentId,model]);
+return;
+}
+
+constrequest=options?.refresh
+ ? api.projects.refreshEntries({ cwd })
+ : api.projects.listEntries({ cwd });
+
+voidrequest.then(
+(result)=>{
+if(generation!==requestGenerationRef.current)return;
+entryKindsRef.current=newMap(
+result.entries.map((entry)=>[entry.path,entry.kind]asconst),
+);
+setEntries(result.entries);
+setIsTruncated(result.truncated);
+model.resetPaths(result.entries.map(treePath));
+setIsLoadingEntries(false);
+},
+(error: unknown)=>{
+if(generation!==requestGenerationRef.current)return;
+setEntriesError(errorinstanceofError ? error.message : String(error));
+setIsLoadingEntries(false);
+},
+);
+},
+[cwd,environmentId,model],
+);
 
 useEffect(()=>{
 loadEntries();
@@ -128,7 +135,7 @@ export default function FileBrowserPanel({
 type="button"
 className="rounded-md p-1.5 text-muted-foreground hover:bg-accent hover:text-foreground"
 aria-label="Refresh workspace files"
-onClick={loadEntries}
+onClick={()=>loadEntries({refresh: true})}
 >
 <RefreshCwclassName={cn("size-3.5",isLoadingEntries&&"animate-spin")}/>
 </button>

apps/web/src/environmentApi.ts

@@ -20,6 +20,7 @@ export function createEnvironmentApi(rpcClient: WsRpcClient): EnvironmentApi {
 },
 projects: {
 listEntries: rpcClient.projects.listEntries,
+refreshEntries: rpcClient.projects.refreshEntries,
 readFile: rpcClient.projects.readFile,
 searchEntries: rpcClient.projects.searchEntries,
 writeFile: rpcClient.projects.writeFile,

apps/web/src/environments/runtime/service.threadSubscriptions.test.ts

@@ -122,6 +122,7 @@ vi.mock("@t3tools/client-runtime", async (importOriginal) => {
 },
 projects: {
 listEntries: vi.fn(),
+refreshEntries: vi.fn(),
 readFile: vi.fn(),
 searchEntries: vi.fn(),
 writeFile: vi.fn(),

apps/web/src/localApi.test.ts

@@ -56,6 +56,7 @@ const rpcClientMock = {
 },
 projects: {
 listEntries: vi.fn(),
+refreshEntries: vi.fn(),
 readFile: vi.fn(),
 searchEntries: vi.fn(),
 writeFile: vi.fn(),

packages/client-runtime/src/wsRpcClient.ts

@@ -97,6 +97,7 @@ export interface WsRpcClient {
 };
 readonlyprojects: {
 readonlylistEntries: RpcUnaryMethod<typeofWS_METHODS.projectsListEntries>;
+readonlyrefreshEntries: RpcUnaryMethod<typeofWS_METHODS.projectsRefreshEntries>;
 readonlyreadFile: RpcUnaryMethod<typeofWS_METHODS.projectsReadFile>;
 readonlysearchEntries: RpcUnaryMethod<typeofWS_METHODS.projectsSearchEntries>;
 readonlywriteFile: RpcUnaryMethod<typeofWS_METHODS.projectsWriteFile>;
@@ -271,6 +272,8 @@ export function createWsRpcClient(
 projects: {
 listEntries: (input)=>
 transport.request((client)=>client[WS_METHODS.projectsListEntries](input)),
+refreshEntries: (input)=>
+transport.request((client)=>client[WS_METHODS.projectsRefreshEntries](input)),
 readFile: (input)=>
 transport.request((client)=>client[WS_METHODS.projectsReadFile](input)),
 searchEntries: (input)=>

packages/contracts/src/ipc.ts

@@ -1115,6 +1115,7 @@ export interface EnvironmentApi {
 };
 projects: {
 listEntries: (input: ProjectListEntriesInput)=>Promise<ProjectListEntriesResult>;
+refreshEntries: (input: ProjectListEntriesInput)=>Promise<ProjectListEntriesResult>;
 readFile: (input: ProjectReadFileInput)=>Promise<ProjectReadFileResult>;
 searchEntries: (input: ProjectSearchEntriesInput)=>Promise<ProjectSearchEntriesResult>;
 writeFile: (input: ProjectWriteFileInput)=>Promise<ProjectWriteFileResult>;

packages/contracts/src/rpc.ts

@@ -148,6 +148,7 @@ export const WS_METHODS = {
 projectsAdd: "projects.add",
 projectsRemove: "projects.remove",
 projectsListEntries: "projects.listEntries",
+projectsRefreshEntries: "projects.refreshEntries",
 projectsReadFile: "projects.readFile",
 projectsSearchEntries: "projects.searchEntries",
 projectsWriteFile: "projects.writeFile",
@@ -364,6 +365,12 @@ export const WsProjectsListEntriesRpc = Rpc.make(WS_METHODS.projectsListEntries,
 error: Schema.Union([ProjectListEntriesError,EnvironmentAuthorizationError]),
 });
 
+exportconstWsProjectsRefreshEntriesRpc=Rpc.make(WS_METHODS.projectsRefreshEntries,{
+payload: ProjectListEntriesInput,
+success: ProjectListEntriesResult,
+error: Schema.Union([ProjectListEntriesError,EnvironmentAuthorizationError]),
+});
+
 exportconstWsProjectsReadFileRpc=Rpc.make(WS_METHODS.projectsReadFile,{
 payload: ProjectReadFileInput,
 success: ProjectReadFileResult,
@@ -697,6 +704,7 @@ export const WsRpcGroup = RpcGroup.make(
 WsSourceControlCloneRepositoryRpc,
 WsSourceControlPublishRepositoryRpc,
 WsProjectsListEntriesRpc,
+WsProjectsRefreshEntriesRpc,
 WsProjectsReadFileRpc,
 WsProjectsSearchEntriesRpc,
 WsProjectsWriteFileRpc,

apps/server/src/workspace/Layers/WorkspaceFileSystem.ts

@@ -57,6 +57,20 @@ export const makeWorkspaceFileSystem = Effect.gen(function* () {
 if(fileBytes.includes(0)){
 thrownewError("Binary files cannot be previewed as text.");
 }
+if(stat.size>PROJECT_READ_FILE_MAX_BYTES){
+constprobeSize=8192;
+constprobeOffset=Math.max(bytesToRead,stat.size-probeSize);
+constprobeBuf=Buffer.alloc(Math.min(probeSize,stat.size-probeOffset));
+const{bytesRead: probeRead}=awaithandle.read(
+probeBuf,
+0,
+probeBuf.length,
+probeOffset,
+);
+if(probeBuf.subarray(0,probeRead).includes(0)){
+thrownewError("Binary files cannot be previewed as text.");
+}
+}
 constcontents=newTextDecoder("utf-8").decode(fileBytes);
 return{
 relativePath: target.relativePath,

apps/server/src/ws.ts

@@ -163,6 +163,7 @@ const RPC_REQUIRED_SCOPE = new Map<string, AuthEnvironmentScope>([
 [WS_METHODS.sourceControlCloneRepository,AuthOrchestrationOperateScope],
 [WS_METHODS.sourceControlPublishRepository,AuthOrchestrationOperateScope],
 [WS_METHODS.projectsListEntries,AuthOrchestrationReadScope],
+[WS_METHODS.projectsRefreshEntries,AuthOrchestrationReadScope],
 [WS_METHODS.projectsReadFile,AuthOrchestrationReadScope],
 [WS_METHODS.projectsSearchEntries,AuthOrchestrationReadScope],
 [WS_METHODS.projectsWriteFile,AuthOrchestrationOperateScope],
@@ -1190,6 +1191,21 @@ const makeWsRpcLayer = (currentSession: AuthenticatedSession) =>
 ),
 {"rpc.aggregate": "workspace"},
 ),
+[WS_METHODS.projectsRefreshEntries]: (input)=>
+observeRpcEffect(
+WS_METHODS.projectsRefreshEntries,
+workspaceEntries.invalidate(input.cwd).pipe(
+Effect.andThen(()=>workspaceEntries.list(input)),
+Effect.mapError(
+(cause)=>
+newProjectListEntriesError({
+message: `Failed to refresh workspace entries: ${cause.detail}`,
+ cause,
+}),
+),
+),
+{"rpc.aggregate": "workspace"},
+),
 [WS_METHODS.projectsReadFile]: (input)=>
 observeRpcEffect(
 WS_METHODS.projectsReadFile,

apps/web/src/components/ChatView.tsx

@@ -3067,6 +3067,9 @@ export default function ChatView(props: ChatViewProps) {
 useRightPanelStore.getState().byThreadKey,
 activeThreadRef,
 );
+if(!nextActiveSurface){
+setMaximizedRightPanelThreadKey(null);
+}
 if(nextActiveSurface?.kind==="preview"&&nextActiveSurface.resourceId){
 usePreviewStateStore.getState().setActiveTab(activeThreadRef,nextActiveSurface.resourceId);
 }

apps/web/src/components/files/FileBrowserPanel.tsx

@@ -62,37 +62,44 @@ export default function FileBrowserPanel({
 unsafeCSS: TREE_UNSAFE_CSS,
 });
 
-constloadEntries=useCallback(()=>{
-constapi=readEnvironmentApi(environmentId);
-requestGenerationRef.current+=1;
-constgeneration=requestGenerationRef.current;
-setIsLoadingEntries(true);
-setEntriesError(null);
-
-if(!api){
-setEntriesError("Environment is not connected.");
-setIsLoadingEntries(false);
-return;
-}
+constloadEntries=useCallback(
+(options?: {refresh?: boolean})=>{
+constapi=readEnvironmentApi(environmentId);
+requestGenerationRef.current+=1;
+constgeneration=requestGenerationRef.current;
+setIsLoadingEntries(true);
+setEntriesError(null);
 
-voidapi.projects.listEntries({ cwd }).then(
-(result)=>{
-if(generation!==requestGenerationRef.current)return;
-entryKindsRef.current=newMap(
-result.entries.map((entry)=>[entry.path,entry.kind]asconst),
-);
-setEntries(result.entries);
-setIsTruncated(result.truncated);
-model.resetPaths(result.entries.map(treePath));
+if(!api){
+setEntriesError("Environment is not connected.");
 setIsLoadingEntries(false);
-},
-(error: unknown)=>{
-if(generation!==requestGenerationRef.current)return;
-setEntriesError(errorinstanceofError ? error.message : String(error));
-setIsLoadingEntries(false);
-},
-);
-},[cwd,environmentId,model]);
+return;
+}
+
+constrequest=options?.refresh
+ ? api.projects.refreshEntries({ cwd })
+ : api.projects.listEntries({ cwd });
+
+voidrequest.then(
+(result)=>{
+if(generation!==requestGenerationRef.current)return;
+entryKindsRef.current=newMap(
+result.entries.map((entry)=>[entry.path,entry.kind]asconst),
+);
+setEntries(result.entries);
+setIsTruncated(result.truncated);
+model.resetPaths(result.entries.map(treePath));
+setIsLoadingEntries(false);
+},
+(error: unknown)=>{
+if(generation!==requestGenerationRef.current)return;
+setEntriesError(errorinstanceofError ? error.message : String(error));
+setIsLoadingEntries(false);
+},
+);
+},
+[cwd,environmentId,model],
+);
 
 useEffect(()=>{
 loadEntries();
@@ -128,7 +135,7 @@ export default function FileBrowserPanel({
 type="button"
 className="rounded-md p-1.5 text-muted-foreground hover:bg-accent hover:text-foreground"
 aria-label="Refresh workspace files"
-onClick={loadEntries}
+onClick={()=>loadEntries({refresh: true})}
 >
 <RefreshCwclassName={cn("size-3.5",isLoadingEntries&&"animate-spin")}/>
 </button>

apps/web/src/environmentApi.ts

@@ -20,6 +20,7 @@ export function createEnvironmentApi(rpcClient: WsRpcClient): EnvironmentApi {
 },
 projects: {
 listEntries: rpcClient.projects.listEntries,
+refreshEntries: rpcClient.projects.refreshEntries,
 readFile: rpcClient.projects.readFile,
 searchEntries: rpcClient.projects.searchEntries,
 writeFile: rpcClient.projects.writeFile,

apps/web/src/environments/runtime/service.threadSubscriptions.test.ts

@@ -122,6 +122,7 @@ vi.mock("@t3tools/client-runtime", async (importOriginal) => {
 },
 projects: {
 listEntries: vi.fn(),
+refreshEntries: vi.fn(),
 readFile: vi.fn(),
 searchEntries: vi.fn(),
 writeFile: vi.fn(),

apps/web/src/localApi.test.ts

@@ -56,6 +56,7 @@ const rpcClientMock = {
 },
 projects: {
 listEntries: vi.fn(),
+refreshEntries: vi.fn(),
 readFile: vi.fn(),
 searchEntries: vi.fn(),
 writeFile: vi.fn(),

packages/client-runtime/src/wsRpcClient.ts

@@ -97,6 +97,7 @@ export interface WsRpcClient {
 };
 readonlyprojects: {
 readonlylistEntries: RpcUnaryMethod<typeofWS_METHODS.projectsListEntries>;
+readonlyrefreshEntries: RpcUnaryMethod<typeofWS_METHODS.projectsRefreshEntries>;
 readonlyreadFile: RpcUnaryMethod<typeofWS_METHODS.projectsReadFile>;
 readonlysearchEntries: RpcUnaryMethod<typeofWS_METHODS.projectsSearchEntries>;
 readonlywriteFile: RpcUnaryMethod<typeofWS_METHODS.projectsWriteFile>;
@@ -271,6 +272,8 @@ export function createWsRpcClient(
 projects: {
 listEntries: (input)=>
 transport.request((client)=>client[WS_METHODS.projectsListEntries](input)),
+refreshEntries: (input)=>
+transport.request((client)=>client[WS_METHODS.projectsRefreshEntries](input)),
 readFile: (input)=>
 transport.request((client)=>client[WS_METHODS.projectsReadFile](input)),
 searchEntries: (input)=>

packages/contracts/src/ipc.ts

@@ -1115,6 +1115,7 @@ export interface EnvironmentApi {
 };
 projects: {
 listEntries: (input: ProjectListEntriesInput)=>Promise<ProjectListEntriesResult>;
+refreshEntries: (input: ProjectListEntriesInput)=>Promise<ProjectListEntriesResult>;
 readFile: (input: ProjectReadFileInput)=>Promise<ProjectReadFileResult>;
 searchEntries: (input: ProjectSearchEntriesInput)=>Promise<ProjectSearchEntriesResult>;
 writeFile: (input: ProjectWriteFileInput)=>Promise<ProjectWriteFileResult>;

packages/contracts/src/rpc.ts

@@ -148,6 +148,7 @@ export const WS_METHODS = {
 projectsAdd: "projects.add",
 projectsRemove: "projects.remove",
 projectsListEntries: "projects.listEntries",
+projectsRefreshEntries: "projects.refreshEntries",
 projectsReadFile: "projects.readFile",
 projectsSearchEntries: "projects.searchEntries",
 projectsWriteFile: "projects.writeFile",
@@ -364,6 +365,12 @@ export const WsProjectsListEntriesRpc = Rpc.make(WS_METHODS.projectsListEntries,
 error: Schema.Union([ProjectListEntriesError,EnvironmentAuthorizationError]),
 });
 
+exportconstWsProjectsRefreshEntriesRpc=Rpc.make(WS_METHODS.projectsRefreshEntries,{
+payload: ProjectListEntriesInput,
+success: ProjectListEntriesResult,
+error: Schema.Union([ProjectListEntriesError,EnvironmentAuthorizationError]),
+});
+
 exportconstWsProjectsReadFileRpc=Rpc.make(WS_METHODS.projectsReadFile,{
 payload: ProjectReadFileInput,
 success: ProjectReadFileResult,
@@ -697,6 +704,7 @@ export const WsRpcGroup = RpcGroup.make(
 WsSourceControlCloneRepositoryRpc,
 WsSourceControlPublishRepositoryRpc,
 WsProjectsListEntriesRpc,
+WsProjectsRefreshEntriesRpc,
 WsProjectsReadFileRpc,
 WsProjectsSearchEntriesRpc,
 WsProjectsWriteFileRpc,

apps/server/src/workspace/Layers/WorkspaceFileSystem.ts

@@ -57,6 +57,20 @@ export const makeWorkspaceFileSystem = Effect.gen(function* () {
 if(fileBytes.includes(0)){
 thrownewError("Binary files cannot be previewed as text.");
 }
+if(stat.size>PROJECT_READ_FILE_MAX_BYTES){
+constprobeSize=8192;
+constprobeOffset=Math.max(bytesToRead,stat.size-probeSize);
+constprobeBuf=Buffer.alloc(Math.min(probeSize,stat.size-probeOffset));
+const{bytesRead: probeRead}=awaithandle.read(
+probeBuf,
+0,
+probeBuf.length,
+probeOffset,
+);
+if(probeBuf.subarray(0,probeRead).includes(0)){
+thrownewError("Binary files cannot be previewed as text.");
+}
+}
 constcontents=newTextDecoder("utf-8").decode(fileBytes);
 return{
 relativePath: target.relativePath,

apps/server/src/ws.ts

@@ -163,6 +163,7 @@ const RPC_REQUIRED_SCOPE = new Map<string, AuthEnvironmentScope>([
 [WS_METHODS.sourceControlCloneRepository,AuthOrchestrationOperateScope],
 [WS_METHODS.sourceControlPublishRepository,AuthOrchestrationOperateScope],
 [WS_METHODS.projectsListEntries,AuthOrchestrationReadScope],
+[WS_METHODS.projectsRefreshEntries,AuthOrchestrationReadScope],
 [WS_METHODS.projectsReadFile,AuthOrchestrationReadScope],
 [WS_METHODS.projectsSearchEntries,AuthOrchestrationReadScope],
 [WS_METHODS.projectsWriteFile,AuthOrchestrationOperateScope],
@@ -1190,6 +1191,21 @@ const makeWsRpcLayer = (currentSession: AuthenticatedSession) =>
 ),
 {"rpc.aggregate": "workspace"},
 ),
+[WS_METHODS.projectsRefreshEntries]: (input)=>
+observeRpcEffect(
+WS_METHODS.projectsRefreshEntries,
+workspaceEntries.invalidate(input.cwd).pipe(
+Effect.andThen(()=>workspaceEntries.list(input)),
+Effect.mapError(
+(cause)=>
+newProjectListEntriesError({
+message: `Failed to refresh workspace entries: ${cause.detail}`,
+ cause,
+}),
+),
+),
+{"rpc.aggregate": "workspace"},
+),
 [WS_METHODS.projectsReadFile]: (input)=>
 observeRpcEffect(
 WS_METHODS.projectsReadFile,

apps/web/src/components/ChatView.tsx

@@ -3067,6 +3067,9 @@ export default function ChatView(props: ChatViewProps) {
 useRightPanelStore.getState().byThreadKey,
 activeThreadRef,
 );
+if(!nextActiveSurface){
+setMaximizedRightPanelThreadKey(null);
+}
 if(nextActiveSurface?.kind==="preview"&&nextActiveSurface.resourceId){
 usePreviewStateStore.getState().setActiveTab(activeThreadRef,nextActiveSurface.resourceId);
 }

apps/web/src/components/files/FileBrowserPanel.tsx

@@ -62,37 +62,44 @@ export default function FileBrowserPanel({
 unsafeCSS: TREE_UNSAFE_CSS,
 });
 
-constloadEntries=useCallback(()=>{
-constapi=readEnvironmentApi(environmentId);
-requestGenerationRef.current+=1;
-constgeneration=requestGenerationRef.current;
-setIsLoadingEntries(true);
-setEntriesError(null);
-
-if(!api){
-setEntriesError("Environment is not connected.");
-setIsLoadingEntries(false);
-return;
-}
+constloadEntries=useCallback(
+(options?: {refresh?: boolean})=>{
+constapi=readEnvironmentApi(environmentId);
+requestGenerationRef.current+=1;
+constgeneration=requestGenerationRef.current;
+setIsLoadingEntries(true);
+setEntriesError(null);
 
-voidapi.projects.listEntries({ cwd }).then(
-(result)=>{
-if(generation!==requestGenerationRef.current)return;
-entryKindsRef.current=newMap(
-result.entries.map((entry)=>[entry.path,entry.kind]asconst),
-);
-setEntries(result.entries);
-setIsTruncated(result.truncated);
-model.resetPaths(result.entries.map(treePath));
+if(!api){
+setEntriesError("Environment is not connected.");
 setIsLoadingEntries(false);
-},
-(error: unknown)=>{
-if(generation!==requestGenerationRef.current)return;
-setEntriesError(errorinstanceofError ? error.message : String(error));
-setIsLoadingEntries(false);
-},
-);
-},[cwd,environmentId,model]);
+return;
+}
+
+constrequest=options?.refresh
+ ? api.projects.refreshEntries({ cwd })
+ : api.projects.listEntries({ cwd });
+
+voidrequest.then(
+(result)=>{
+if(generation!==requestGenerationRef.current)return;
+entryKindsRef.current=newMap(
+result.entries.map((entry)=>[entry.path,entry.kind]asconst),
+);
+setEntries(result.entries);
+setIsTruncated(result.truncated);
+model.resetPaths(result.entries.map(treePath));
+setIsLoadingEntries(false);
+},
+(error: unknown)=>{
+if(generation!==requestGenerationRef.current)return;
+setEntriesError(errorinstanceofError ? error.message : String(error));
+setIsLoadingEntries(false);
+},
+);
+},
+[cwd,environmentId,model],
+);
 
 useEffect(()=>{
 loadEntries();
@@ -128,7 +135,7 @@ export default function FileBrowserPanel({
 type="button"
 className="rounded-md p-1.5 text-muted-foreground hover:bg-accent hover:text-foreground"
 aria-label="Refresh workspace files"
-onClick={loadEntries}
+onClick={()=>loadEntries({refresh: true})}
 >
 <RefreshCwclassName={cn("size-3.5",isLoadingEntries&&"animate-spin")}/>
 </button>

apps/web/src/environmentApi.ts

@@ -20,6 +20,7 @@ export function createEnvironmentApi(rpcClient: WsRpcClient): EnvironmentApi {
 },
 projects: {
 listEntries: rpcClient.projects.listEntries,
+refreshEntries: rpcClient.projects.refreshEntries,
 readFile: rpcClient.projects.readFile,
 searchEntries: rpcClient.projects.searchEntries,
 writeFile: rpcClient.projects.writeFile,

apps/web/src/environments/runtime/service.threadSubscriptions.test.ts

@@ -122,6 +122,7 @@ vi.mock("@t3tools/client-runtime", async (importOriginal) => {
 },
 projects: {
 listEntries: vi.fn(),
+refreshEntries: vi.fn(),
 readFile: vi.fn(),
 searchEntries: vi.fn(),
 writeFile: vi.fn(),

apps/web/src/localApi.test.ts

@@ -56,6 +56,7 @@ const rpcClientMock = {
 },
 projects: {
 listEntries: vi.fn(),
+refreshEntries: vi.fn(),
 readFile: vi.fn(),
 searchEntries: vi.fn(),
 writeFile: vi.fn(),

packages/client-runtime/src/wsRpcClient.ts

@@ -97,6 +97,7 @@ export interface WsRpcClient {
 };
 readonlyprojects: {
 readonlylistEntries: RpcUnaryMethod<typeofWS_METHODS.projectsListEntries>;
+readonlyrefreshEntries: RpcUnaryMethod<typeofWS_METHODS.projectsRefreshEntries>;
 readonlyreadFile: RpcUnaryMethod<typeofWS_METHODS.projectsReadFile>;
 readonlysearchEntries: RpcUnaryMethod<typeofWS_METHODS.projectsSearchEntries>;
 readonlywriteFile: RpcUnaryMethod<typeofWS_METHODS.projectsWriteFile>;
@@ -271,6 +272,8 @@ export function createWsRpcClient(
 projects: {
 listEntries: (input)=>
 transport.request((client)=>client[WS_METHODS.projectsListEntries](input)),
+refreshEntries: (input)=>
+transport.request((client)=>client[WS_METHODS.projectsRefreshEntries](input)),
 readFile: (input)=>
 transport.request((client)=>client[WS_METHODS.projectsReadFile](input)),
 searchEntries: (input)=>

packages/contracts/src/ipc.ts

@@ -1115,6 +1115,7 @@ export interface EnvironmentApi {
 };
 projects: {
 listEntries: (input: ProjectListEntriesInput)=>Promise<ProjectListEntriesResult>;
+refreshEntries: (input: ProjectListEntriesInput)=>Promise<ProjectListEntriesResult>;
 readFile: (input: ProjectReadFileInput)=>Promise<ProjectReadFileResult>;
 searchEntries: (input: ProjectSearchEntriesInput)=>Promise<ProjectSearchEntriesResult>;
 writeFile: (input: ProjectWriteFileInput)=>Promise<ProjectWriteFileResult>;

packages/contracts/src/rpc.ts

@@ -148,6 +148,7 @@ export const WS_METHODS = {
 projectsAdd: "projects.add",
 projectsRemove: "projects.remove",
 projectsListEntries: "projects.listEntries",
+projectsRefreshEntries: "projects.refreshEntries",
 projectsReadFile: "projects.readFile",
 projectsSearchEntries: "projects.searchEntries",
 projectsWriteFile: "projects.writeFile",
@@ -364,6 +365,12 @@ export const WsProjectsListEntriesRpc = Rpc.make(WS_METHODS.projectsListEntries,
 error: Schema.Union([ProjectListEntriesError,EnvironmentAuthorizationError]),
 });
 
+exportconstWsProjectsRefreshEntriesRpc=Rpc.make(WS_METHODS.projectsRefreshEntries,{
+payload: ProjectListEntriesInput,
+success: ProjectListEntriesResult,
+error: Schema.Union([ProjectListEntriesError,EnvironmentAuthorizationError]),
+});
+
 exportconstWsProjectsReadFileRpc=Rpc.make(WS_METHODS.projectsReadFile,{
 payload: ProjectReadFileInput,
 success: ProjectReadFileResult,
@@ -697,6 +704,7 @@ export const WsRpcGroup = RpcGroup.make(
 WsSourceControlCloneRepositoryRpc,
 WsSourceControlPublishRepositoryRpc,
 WsProjectsListEntriesRpc,
+WsProjectsRefreshEntriesRpc,
 WsProjectsReadFileRpc,
 WsProjectsSearchEntriesRpc,
 WsProjectsWriteFileRpc,

apps/server/src/workspace/Layers/WorkspaceFileSystem.ts

@@ -57,6 +57,20 @@ export const makeWorkspaceFileSystem = Effect.gen(function* () {
 if(fileBytes.includes(0)){
 thrownewError("Binary files cannot be previewed as text.");
 }
+if(stat.size>PROJECT_READ_FILE_MAX_BYTES){
+constprobeSize=8192;
+constprobeOffset=Math.max(bytesToRead,stat.size-probeSize);
+constprobeBuf=Buffer.alloc(Math.min(probeSize,stat.size-probeOffset));
+const{bytesRead: probeRead}=awaithandle.read(
+probeBuf,
+0,
+probeBuf.length,
+probeOffset,
+);
+if(probeBuf.subarray(0,probeRead).includes(0)){
+thrownewError("Binary files cannot be previewed as text.");
+}
+}
 constcontents=newTextDecoder("utf-8").decode(fileBytes);
 return{
 relativePath: target.relativePath,

apps/server/src/ws.ts

@@ -163,6 +163,7 @@ const RPC_REQUIRED_SCOPE = new Map<string, AuthEnvironmentScope>([
 [WS_METHODS.sourceControlCloneRepository,AuthOrchestrationOperateScope],
 [WS_METHODS.sourceControlPublishRepository,AuthOrchestrationOperateScope],
 [WS_METHODS.projectsListEntries,AuthOrchestrationReadScope],
+[WS_METHODS.projectsRefreshEntries,AuthOrchestrationReadScope],
 [WS_METHODS.projectsReadFile,AuthOrchestrationReadScope],
 [WS_METHODS.projectsSearchEntries,AuthOrchestrationReadScope],
 [WS_METHODS.projectsWriteFile,AuthOrchestrationOperateScope],
@@ -1190,6 +1191,21 @@ const makeWsRpcLayer = (currentSession: AuthenticatedSession) =>
 ),
 {"rpc.aggregate": "workspace"},
 ),
+[WS_METHODS.projectsRefreshEntries]: (input)=>
+observeRpcEffect(
+WS_METHODS.projectsRefreshEntries,
+workspaceEntries.invalidate(input.cwd).pipe(
+Effect.andThen(()=>workspaceEntries.list(input)),
+Effect.mapError(
+(cause)=>
+newProjectListEntriesError({
+message: `Failed to refresh workspace entries: ${cause.detail}`,
+ cause,
+}),
+),
+),
+{"rpc.aggregate": "workspace"},
+),
 [WS_METHODS.projectsReadFile]: (input)=>
 observeRpcEffect(
 WS_METHODS.projectsReadFile,

apps/web/src/components/ChatView.tsx

@@ -3067,6 +3067,9 @@ export default function ChatView(props: ChatViewProps) {
 useRightPanelStore.getState().byThreadKey,
 activeThreadRef,
 );
+if(!nextActiveSurface){
+setMaximizedRightPanelThreadKey(null);
+}
 if(nextActiveSurface?.kind==="preview"&&nextActiveSurface.resourceId){
 usePreviewStateStore.getState().setActiveTab(activeThreadRef,nextActiveSurface.resourceId);
 }

apps/web/src/components/files/FileBrowserPanel.tsx

@@ -62,37 +62,44 @@ export default function FileBrowserPanel({
 unsafeCSS: TREE_UNSAFE_CSS,
 });
 
-constloadEntries=useCallback(()=>{
-constapi=readEnvironmentApi(environmentId);
-requestGenerationRef.current+=1;
-constgeneration=requestGenerationRef.current;
-setIsLoadingEntries(true);
-setEntriesError(null);
-
-if(!api){
-setEntriesError("Environment is not connected.");
-setIsLoadingEntries(false);
-return;
-}
+constloadEntries=useCallback(
+(options?: {refresh?: boolean})=>{
+constapi=readEnvironmentApi(environmentId);
+requestGenerationRef.current+=1;
+constgeneration=requestGenerationRef.current;
+setIsLoadingEntries(true);
+setEntriesError(null);
 
-voidapi.projects.listEntries({ cwd }).then(
-(result)=>{
-if(generation!==requestGenerationRef.current)return;
-entryKindsRef.current=newMap(
-result.entries.map((entry)=>[entry.path,entry.kind]asconst),
-);
-setEntries(result.entries);
-setIsTruncated(result.truncated);
-model.resetPaths(result.entries.map(treePath));
+if(!api){
+setEntriesError("Environment is not connected.");
 setIsLoadingEntries(false);
-},
-(error: unknown)=>{
-if(generation!==requestGenerationRef.current)return;
-setEntriesError(errorinstanceofError ? error.message : String(error));
-setIsLoadingEntries(false);
-},
-);
-},[cwd,environmentId,model]);
+return;
+}
+
+constrequest=options?.refresh
+ ? api.projects.refreshEntries({ cwd })
+ : api.projects.listEntries({ cwd });
+
+voidrequest.then(
+(result)=>{
+if(generation!==requestGenerationRef.current)return;
+entryKindsRef.current=newMap(
+result.entries.map((entry)=>[entry.path,entry.kind]asconst),
+);
+setEntries(result.entries);
+setIsTruncated(result.truncated);
+model.resetPaths(result.entries.map(treePath));
+setIsLoadingEntries(false);
+},
+(error: unknown)=>{
+if(generation!==requestGenerationRef.current)return;
+setEntriesError(errorinstanceofError ? error.message : String(error));
+setIsLoadingEntries(false);
+},
+);
+},
+[cwd,environmentId,model],
+);
 
 useEffect(()=>{
 loadEntries();
@@ -128,7 +135,7 @@ export default function FileBrowserPanel({
 type="button"
 className="rounded-md p-1.5 text-muted-foreground hover:bg-accent hover:text-foreground"
 aria-label="Refresh workspace files"
-onClick={loadEntries}
+onClick={()=>loadEntries({refresh: true})}
 >
 <RefreshCwclassName={cn("size-3.5",isLoadingEntries&&"animate-spin")}/>
 </button>

apps/web/src/environmentApi.ts

@@ -20,6 +20,7 @@ export function createEnvironmentApi(rpcClient: WsRpcClient): EnvironmentApi {
 },
 projects: {
 listEntries: rpcClient.projects.listEntries,
+refreshEntries: rpcClient.projects.refreshEntries,
 readFile: rpcClient.projects.readFile,
 searchEntries: rpcClient.projects.searchEntries,
 writeFile: rpcClient.projects.writeFile,

apps/web/src/environments/runtime/service.threadSubscriptions.test.ts

@@ -122,6 +122,7 @@ vi.mock("@t3tools/client-runtime", async (importOriginal) => {
 },
 projects: {
 listEntries: vi.fn(),
+refreshEntries: vi.fn(),
 readFile: vi.fn(),
 searchEntries: vi.fn(),
 writeFile: vi.fn(),

apps/web/src/localApi.test.ts

@@ -56,6 +56,7 @@ const rpcClientMock = {
 },
 projects: {
 listEntries: vi.fn(),
+refreshEntries: vi.fn(),
 readFile: vi.fn(),
 searchEntries: vi.fn(),
 writeFile: vi.fn(),

packages/client-runtime/src/wsRpcClient.ts

@@ -97,6 +97,7 @@ export interface WsRpcClient {
 };
 readonlyprojects: {
 readonlylistEntries: RpcUnaryMethod<typeofWS_METHODS.projectsListEntries>;
+readonlyrefreshEntries: RpcUnaryMethod<typeofWS_METHODS.projectsRefreshEntries>;
 readonlyreadFile: RpcUnaryMethod<typeofWS_METHODS.projectsReadFile>;
 readonlysearchEntries: RpcUnaryMethod<typeofWS_METHODS.projectsSearchEntries>;
 readonlywriteFile: RpcUnaryMethod<typeofWS_METHODS.projectsWriteFile>;
@@ -271,6 +272,8 @@ export function createWsRpcClient(
 projects: {
 listEntries: (input)=>
 transport.request((client)=>client[WS_METHODS.projectsListEntries](input)),
+refreshEntries: (input)=>
+transport.request((client)=>client[WS_METHODS.projectsRefreshEntries](input)),
 readFile: (input)=>
 transport.request((client)=>client[WS_METHODS.projectsReadFile](input)),
 searchEntries: (input)=>

packages/contracts/src/ipc.ts

@@ -1115,6 +1115,7 @@ export interface EnvironmentApi {
 };
 projects: {
 listEntries: (input: ProjectListEntriesInput)=>Promise<ProjectListEntriesResult>;
+refreshEntries: (input: ProjectListEntriesInput)=>Promise<ProjectListEntriesResult>;
 readFile: (input: ProjectReadFileInput)=>Promise<ProjectReadFileResult>;
 searchEntries: (input: ProjectSearchEntriesInput)=>Promise<ProjectSearchEntriesResult>;
 writeFile: (input: ProjectWriteFileInput)=>Promise<ProjectWriteFileResult>;

packages/contracts/src/rpc.ts

@@ -148,6 +148,7 @@ export const WS_METHODS = {
 projectsAdd: "projects.add",
 projectsRemove: "projects.remove",
 projectsListEntries: "projects.listEntries",
+projectsRefreshEntries: "projects.refreshEntries",
 projectsReadFile: "projects.readFile",
 projectsSearchEntries: "projects.searchEntries",
 projectsWriteFile: "projects.writeFile",
@@ -364,6 +365,12 @@ export const WsProjectsListEntriesRpc = Rpc.make(WS_METHODS.projectsListEntries,
 error: Schema.Union([ProjectListEntriesError,EnvironmentAuthorizationError]),
 });
 
+exportconstWsProjectsRefreshEntriesRpc=Rpc.make(WS_METHODS.projectsRefreshEntries,{
+payload: ProjectListEntriesInput,
+success: ProjectListEntriesResult,
+error: Schema.Union([ProjectListEntriesError,EnvironmentAuthorizationError]),
+});
+
 exportconstWsProjectsReadFileRpc=Rpc.make(WS_METHODS.projectsReadFile,{
 payload: ProjectReadFileInput,
 success: ProjectReadFileResult,
@@ -697,6 +704,7 @@ export const WsRpcGroup = RpcGroup.make(
 WsSourceControlCloneRepositoryRpc,
 WsSourceControlPublishRepositoryRpc,
 WsProjectsListEntriesRpc,
+WsProjectsRefreshEntriesRpc,
 WsProjectsReadFileRpc,
 WsProjectsSearchEntriesRpc,
 WsProjectsWriteFileRpc,

apps/server/src/workspace/Layers/WorkspaceFileSystem.ts

@@ -57,6 +57,20 @@ export const makeWorkspaceFileSystem = Effect.gen(function* () {
 if(fileBytes.includes(0)){
 thrownewError("Binary files cannot be previewed as text.");
 }
+if(stat.size>PROJECT_READ_FILE_MAX_BYTES){
+constprobeSize=8192;
+constprobeOffset=Math.max(bytesToRead,stat.size-probeSize);
+constprobeBuf=Buffer.alloc(Math.min(probeSize,stat.size-probeOffset));
+const{bytesRead: probeRead}=awaithandle.read(
+probeBuf,
+0,
+probeBuf.length,
+probeOffset,
+);
+if(probeBuf.subarray(0,probeRead).includes(0)){
+thrownewError("Binary files cannot be previewed as text.");
+}
+}
 constcontents=newTextDecoder("utf-8").decode(fileBytes);
 return{
 relativePath: target.relativePath,

apps/server/src/ws.ts

@@ -163,6 +163,7 @@ const RPC_REQUIRED_SCOPE = new Map<string, AuthEnvironmentScope>([
 [WS_METHODS.sourceControlCloneRepository,AuthOrchestrationOperateScope],
 [WS_METHODS.sourceControlPublishRepository,AuthOrchestrationOperateScope],
 [WS_METHODS.projectsListEntries,AuthOrchestrationReadScope],
+[WS_METHODS.projectsRefreshEntries,AuthOrchestrationReadScope],
 [WS_METHODS.projectsReadFile,AuthOrchestrationReadScope],
 [WS_METHODS.projectsSearchEntries,AuthOrchestrationReadScope],
 [WS_METHODS.projectsWriteFile,AuthOrchestrationOperateScope],
@@ -1190,6 +1191,21 @@ const makeWsRpcLayer = (currentSession: AuthenticatedSession) =>
 ),
 {"rpc.aggregate": "workspace"},
 ),
+[WS_METHODS.projectsRefreshEntries]: (input)=>
+observeRpcEffect(
+WS_METHODS.projectsRefreshEntries,
+workspaceEntries.invalidate(input.cwd).pipe(
+Effect.andThen(()=>workspaceEntries.list(input)),
+Effect.mapError(
+(cause)=>
+newProjectListEntriesError({
+message: `Failed to refresh workspace entries: ${cause.detail}`,
+ cause,
+}),
+),
+),
+{"rpc.aggregate": "workspace"},
+),
 [WS_METHODS.projectsReadFile]: (input)=>
 observeRpcEffect(
 WS_METHODS.projectsReadFile,

apps/web/src/components/ChatView.tsx

@@ -3067,6 +3067,9 @@ export default function ChatView(props: ChatViewProps) {
 useRightPanelStore.getState().byThreadKey,
 activeThreadRef,
 );
+if(!nextActiveSurface){
+setMaximizedRightPanelThreadKey(null);
+}
 if(nextActiveSurface?.kind==="preview"&&nextActiveSurface.resourceId){
 usePreviewStateStore.getState().setActiveTab(activeThreadRef,nextActiveSurface.resourceId);
 }

apps/web/src/components/files/FileBrowserPanel.tsx

@@ -62,37 +62,44 @@ export default function FileBrowserPanel({
 unsafeCSS: TREE_UNSAFE_CSS,
 });
 
-constloadEntries=useCallback(()=>{
-constapi=readEnvironmentApi(environmentId);
-requestGenerationRef.current+=1;
-constgeneration=requestGenerationRef.current;
-setIsLoadingEntries(true);
-setEntriesError(null);
-
-if(!api){
-setEntriesError("Environment is not connected.");
-setIsLoadingEntries(false);
-return;
-}
+constloadEntries=useCallback(
+(options?: {refresh?: boolean})=>{
+constapi=readEnvironmentApi(environmentId);
+requestGenerationRef.current+=1;
+constgeneration=requestGenerationRef.current;
+setIsLoadingEntries(true);
+setEntriesError(null);
 
-voidapi.projects.listEntries({ cwd }).then(
-(result)=>{
-if(generation!==requestGenerationRef.current)return;
-entryKindsRef.current=newMap(
-result.entries.map((entry)=>[entry.path,entry.kind]asconst),
-);
-setEntries(result.entries);
-setIsTruncated(result.truncated);
-model.resetPaths(result.entries.map(treePath));
+if(!api){
+setEntriesError("Environment is not connected.");
 setIsLoadingEntries(false);
-},
-(error: unknown)=>{
-if(generation!==requestGenerationRef.current)return;
-setEntriesError(errorinstanceofError ? error.message : String(error));
-setIsLoadingEntries(false);
-},
-);
-},[cwd,environmentId,model]);
+return;
+}
+
+constrequest=options?.refresh
+ ? api.projects.refreshEntries({ cwd })
+ : api.projects.listEntries({ cwd });
+
+voidrequest.then(
+(result)=>{
+if(generation!==requestGenerationRef.current)return;
+entryKindsRef.current=newMap(
+result.entries.map((entry)=>[entry.path,entry.kind]asconst),
+);
+setEntries(result.entries);
+setIsTruncated(result.truncated);
+model.resetPaths(result.entries.map(treePath));
+setIsLoadingEntries(false);
+},
+(error: unknown)=>{
+if(generation!==requestGenerationRef.current)return;
+setEntriesError(errorinstanceofError ? error.message : String(error));
+setIsLoadingEntries(false);
+},
+);
+},
+[cwd,environmentId,model],
+);
 
 useEffect(()=>{
 loadEntries();
@@ -128,7 +135,7 @@ export default function FileBrowserPanel({
 type="button"
 className="rounded-md p-1.5 text-muted-foreground hover:bg-accent hover:text-foreground"
 aria-label="Refresh workspace files"
-onClick={loadEntries}
+onClick={()=>loadEntries({refresh: true})}
 >
 <RefreshCwclassName={cn("size-3.5",isLoadingEntries&&"animate-spin")}/>
 </button>

apps/web/src/environmentApi.ts

@@ -20,6 +20,7 @@ export function createEnvironmentApi(rpcClient: WsRpcClient): EnvironmentApi {
 },
 projects: {
 listEntries: rpcClient.projects.listEntries,
+refreshEntries: rpcClient.projects.refreshEntries,
 readFile: rpcClient.projects.readFile,
 searchEntries: rpcClient.projects.searchEntries,
 writeFile: rpcClient.projects.writeFile,

apps/web/src/environments/runtime/service.threadSubscriptions.test.ts

@@ -122,6 +122,7 @@ vi.mock("@t3tools/client-runtime", async (importOriginal) => {
 },
 projects: {
 listEntries: vi.fn(),
+refreshEntries: vi.fn(),
 readFile: vi.fn(),
 searchEntries: vi.fn(),
 writeFile: vi.fn(),

apps/web/src/localApi.test.ts

@@ -56,6 +56,7 @@ const rpcClientMock = {
 },
 projects: {
 listEntries: vi.fn(),
+refreshEntries: vi.fn(),
 readFile: vi.fn(),
 searchEntries: vi.fn(),
 writeFile: vi.fn(),

packages/client-runtime/src/wsRpcClient.ts

@@ -97,6 +97,7 @@ export interface WsRpcClient {
 };
 readonlyprojects: {
 readonlylistEntries: RpcUnaryMethod<typeofWS_METHODS.projectsListEntries>;
+readonlyrefreshEntries: RpcUnaryMethod<typeofWS_METHODS.projectsRefreshEntries>;
 readonlyreadFile: RpcUnaryMethod<typeofWS_METHODS.projectsReadFile>;
 readonlysearchEntries: RpcUnaryMethod<typeofWS_METHODS.projectsSearchEntries>;
 readonlywriteFile: RpcUnaryMethod<typeofWS_METHODS.projectsWriteFile>;
@@ -271,6 +272,8 @@ export function createWsRpcClient(
 projects: {
 listEntries: (input)=>
 transport.request((client)=>client[WS_METHODS.projectsListEntries](input)),
+refreshEntries: (input)=>
+transport.request((client)=>client[WS_METHODS.projectsRefreshEntries](input)),
 readFile: (input)=>
 transport.request((client)=>client[WS_METHODS.projectsReadFile](input)),
 searchEntries: (input)=>

packages/contracts/src/ipc.ts

@@ -1115,6 +1115,7 @@ export interface EnvironmentApi {
 };
 projects: {
 listEntries: (input: ProjectListEntriesInput)=>Promise<ProjectListEntriesResult>;
+refreshEntries: (input: ProjectListEntriesInput)=>Promise<ProjectListEntriesResult>;
 readFile: (input: ProjectReadFileInput)=>Promise<ProjectReadFileResult>;
 searchEntries: (input: ProjectSearchEntriesInput)=>Promise<ProjectSearchEntriesResult>;
 writeFile: (input: ProjectWriteFileInput)=>Promise<ProjectWriteFileResult>;

packages/contracts/src/rpc.ts

@@ -148,6 +148,7 @@ export const WS_METHODS = {
 projectsAdd: "projects.add",
 projectsRemove: "projects.remove",
 projectsListEntries: "projects.listEntries",
+projectsRefreshEntries: "projects.refreshEntries",
 projectsReadFile: "projects.readFile",
 projectsSearchEntries: "projects.searchEntries",
 projectsWriteFile: "projects.writeFile",
@@ -364,6 +365,12 @@ export const WsProjectsListEntriesRpc = Rpc.make(WS_METHODS.projectsListEntries,
 error: Schema.Union([ProjectListEntriesError,EnvironmentAuthorizationError]),
 });
 
+exportconstWsProjectsRefreshEntriesRpc=Rpc.make(WS_METHODS.projectsRefreshEntries,{
+payload: ProjectListEntriesInput,
+success: ProjectListEntriesResult,
+error: Schema.Union([ProjectListEntriesError,EnvironmentAuthorizationError]),
+});
+
 exportconstWsProjectsReadFileRpc=Rpc.make(WS_METHODS.projectsReadFile,{
 payload: ProjectReadFileInput,
 success: ProjectReadFileResult,
@@ -697,6 +704,7 @@ export const WsRpcGroup = RpcGroup.make(
 WsSourceControlCloneRepositoryRpc,
 WsSourceControlPublishRepositoryRpc,
 WsProjectsListEntriesRpc,
+WsProjectsRefreshEntriesRpc,
 WsProjectsReadFileRpc,
 WsProjectsSearchEntriesRpc,
 WsProjectsWriteFileRpc,