(workspaceId: string)
| 2823 | } |
| 2824 | |
| 2825 | public disposeSession(workspaceId: string): void { |
| 2826 | const trimmed = workspaceId.trim(); |
| 2827 | const transientSession = this.transientStartupRecoverySessions.get(trimmed); |
| 2828 | if (transientSession) { |
| 2829 | transientSession.dispose(); |
| 2830 | this.transientStartupRecoverySessions.delete(trimmed); |
| 2831 | } |
| 2832 | |
| 2833 | const session = this.sessions.get(trimmed); |
| 2834 | const refreshTimer = this.postCompactionRefreshTimers.get(trimmed); |
| 2835 | if (refreshTimer) { |
| 2836 | clearTimeout(refreshTimer); |
| 2837 | this.postCompactionRefreshTimers.delete(trimmed); |
| 2838 | } |
| 2839 | |
| 2840 | if (!session) { |
| 2841 | return; |
| 2842 | } |
| 2843 | |
| 2844 | const subscriptions = this.sessionSubscriptions.get(trimmed); |
| 2845 | if (subscriptions) { |
| 2846 | subscriptions.chat(); |
| 2847 | subscriptions.metadata(); |
| 2848 | this.sessionSubscriptions.delete(trimmed); |
| 2849 | } |
| 2850 | |
| 2851 | session.dispose(); |
| 2852 | this.sessions.delete(trimmed); |
| 2853 | } |
| 2854 | |
| 2855 | private async getPersistedPostCompactionDiffPaths(workspaceId: string): Promise<string[] | null> { |
| 2856 | const postCompactionPath = path.join( |
no test coverage detected