(workspaceId: string, options?: { cancelReason?: string })
| 7792 | } |
| 7793 | |
| 7794 | clearQueue(workspaceId: string, options?: { cancelReason?: string }): Result<void> { |
| 7795 | try { |
| 7796 | const session = this.getOrCreateSession(workspaceId); |
| 7797 | session.clearQueue(options?.cancelReason); |
| 7798 | return Ok(undefined); |
| 7799 | } catch (error) { |
| 7800 | const errorMessage = getErrorMessage(error); |
| 7801 | log.error("Unexpected error in clearQueue handler:", error); |
| 7802 | return Err(`Failed to clear queue: ${errorMessage}`); |
| 7803 | } |
| 7804 | } |
| 7805 | |
| 7806 | isBusyForMessage(workspaceId: string): boolean { |
| 7807 | return this.sessions.get(workspaceId.trim())?.isBusy() === true; |
nothing calls this directly
no test coverage detected