diff options
| author | soryu <soryu@soryu.co> | 2026-02-24 23:37:44 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2026-02-24 23:37:44 +0000 |
| commit | 5d1fbed2733e93cc2be2e1a89ca022d88bef613f (patch) | |
| tree | 48f66f56c2557b5101a49775e0d964ccd94b516a /makima/src/server/state.rs | |
| parent | b9bc33ab69d094d97fd1398aaa39e8e435547d17 (diff) | |
| download | soryu-0.3.1.tar.gz soryu-0.3.1.zip | |
feat: non-blocking reconcile polling, directive CLI orders & cleanup (#82)v0.3.1
* feat: soryu-co/soryu - makima: Remove aarch64-unknown-linux-gnu from release workflow
* WIP: heartbeat checkpoint
* WIP: heartbeat checkpoint
* WIP: heartbeat checkpoint
* feat: soryu-co/soryu - makima: Implement non-blocking ask with client-side polling for reconcile mode
Diffstat (limited to 'makima/src/server/state.rs')
| -rw-r--r-- | makima/src/server/state.rs | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/makima/src/server/state.rs b/makima/src/server/state.rs index 41c336e..15fec6b 100644 --- a/makima/src/server/state.rs +++ b/makima/src/server/state.rs @@ -910,6 +910,11 @@ impl AppState { self.pending_questions.get(&question_id).map(|entry| entry.value().clone()) } + /// Check if a pending question exists (either still pending or has a response ready). + pub fn has_pending_question(&self, question_id: Uuid) -> bool { + self.pending_questions.contains_key(&question_id) || self.question_responses.contains_key(&question_id) + } + /// Submit a response to a supervisor question. pub fn submit_question_response(&self, question_id: Uuid, response: String) -> bool { // Check if the question exists |